package com.c2kernel.lifecycle.instance.predefined.agent;

import com.c2kernel.common.CannotManageException;
import com.c2kernel.common.InvalidDataException;
import com.c2kernel.common.ObjectCannotBeUpdated;
import com.c2kernel.common.ObjectNotFoundException;
import com.c2kernel.lifecycle.instance.predefined.PredefinedStep;
import com.c2kernel.lookup.AgentPath;
import com.c2kernel.lookup.InvalidAgentPathException;
import com.c2kernel.lookup.ItemPath;
import com.c2kernel.lookup.RolePath;
import com.c2kernel.persistency.ClusterStorageException;
import com.c2kernel.process.Gateway;
import com.c2kernel.utils.Logger;

public class RemoveAgent extends PredefinedStep {

	public RemoveAgent() {
        super();
	}
	
	@Override
	protected String runActivityLogic(AgentPath agent, ItemPath itemPath,
			int transitionID, String requestData) throws InvalidDataException {
	
		Logger.msg(1, "RemoveAgent::request() - Starting.");
		
		AgentPath targetAgent;
		try {
			targetAgent = new AgentPath(itemPath);
		} catch (InvalidAgentPathException ex) {
			throw new InvalidDataException("Could not resolve "+itemPath+" as an Agent.");
		}
		String agentName = targetAgent.getAgentName();
		
		//remove from roles
		for (RolePath role: targetAgent.getRoles()) {
			try {
				role.removeAgent(targetAgent);
			} catch (ObjectCannotBeUpdated e) {
				Logger.error(e);
				throw new InvalidDataException("Error removing "+agentName+" from Role "+role.getName(), "");
			} catch (ObjectNotFoundException e) {
				Logger.error(e);
				throw new InvalidDataException("Tried to remove "+agentName+" from Role "+role.getName()+" that doesn't exist.", "");
			} catch (CannotManageException e) {
				throw new InvalidDataException("Tried to alter roles in a non-server process.", "");
			}
		}
		
		//clear out all storages
        try {
			Gateway.getStorage().removeCluster(targetAgent, "", null);
		} catch (ClusterStorageException e) {
			Logger.error(e);
			throw new InvalidDataException("Error deleting storage for  "+agentName, "");
		}
        
        //remove entity path
        try {
			Gateway.getLookupManager().delete(targetAgent);
		} catch (Exception e) {
			throw new InvalidDataException("Error deleting AgentPath for  "+agentName, "");
		}
        return requestData;

	}

}