/**************************************************************************
 * CreateItemFromDescription
 *
 * $Workfile$
 * $Revision: 1.47 $
 * $Date: 2005/10/13 08:13:58 $
 *
 * Copyright (C) 2001 CERN - European Organization for Nuclear Research
 * All rights reserved.
 **************************************************************************/

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

import com.c2kernel.common.AccessRightsException;
import com.c2kernel.common.InvalidDataException;
import com.c2kernel.common.ObjectAlreadyExistsException;
import com.c2kernel.common.ObjectNotFoundException;
import com.c2kernel.entity.CorbaServer;
import com.c2kernel.entity.agent.ActiveEntity;
import com.c2kernel.lifecycle.instance.predefined.item.CreateItemFromDescription;
import com.c2kernel.lookup.AgentPath;
import com.c2kernel.lookup.RolePath;
import com.c2kernel.process.Gateway;
import com.c2kernel.utils.Logger;

/**************************************************************************
 *
 * @author $Author: abranson $ $Date: 2005/10/13 08:13:58 $
 * @version $Revision: 1.47 $
 **************************************************************************/
public class CreateAgentFromDescription extends CreateItemFromDescription
{
	public CreateAgentFromDescription()
	{
		super();
	}

	/**
	 * Params:
	 * <ol><li>1: new Agent name</li>
	 * <li>2...: Roles to assign to the agent. Must already exist.
	 * @see com.c2kernel.lifecycle.instance.predefined.item.CreateItemFromDescription#runActivityLogic(com.c2kernel.lookup.AgentPath, int, int, java.lang.String)
	 */
	@Override
	protected String runActivityLogic(AgentPath agent, int itemSysKey,
			int transitionID, String requestData) throws InvalidDataException {
		
		String[] input = getDataList(requestData);
		String newName = input[0];

		Logger.msg(1, "CreateAgentFromDescription::request() - Starting.");

        try {
        	
        	if (input.length < 2)
        		throw new InvalidDataException("Agent should have at least one Role defined on creation");
        	// check if given roles exist
        	for(int i=1; i<input.length; i++) {
            	RolePath thisRole = new RolePath(input[i]);
            	if (!thisRole.exists()) throw new InvalidDataException("Role "+input[i]+" does not exist");
            }
        	
            // check if the path is already taken
        	try {
        		Gateway.getLookup().getAgentPath(newName);
        		throw new ObjectAlreadyExistsException("The agent name " +newName+ " exists already.", "");
        	} catch (ObjectNotFoundException ex) { }

            // generate new entity key
            Logger.msg(6, "CreateItemFromDescription - Requesting new sysKey");
            AgentPath newAgentPath = Gateway.getNextKeyManager().generateNextAgentKey();

            // resolve the item factory
            Logger.msg(6, "CreateItemFromDescription - Resolving item factory");

            // create the Item object
            Logger.msg(3, "CreateItemFromDescription - Creating Item");
            CorbaServer factory = Gateway.getCorbaServer();
            if (factory == null) throw new AccessRightsException("This process cannot create new Items", "");
            ActiveEntity newAgent = (ActiveEntity)factory.createEntity(newAgentPath);
            Gateway.getLookupManager().add(newAgentPath);

            // initialise it with its properties and workflow

            Logger.msg(3, "CreateItemFromDescription - Initializing Item");

            newAgent.initialise(
                agent.getSysKey(),
            	Gateway.getMarshaller().marshall(getNewProperties(itemSysKey, newName, agent)),
            	Gateway.getMarshaller().marshall(getNewWorkflow(itemSysKey)),
            	Gateway.getMarshaller().marshall(getNewCollections(itemSysKey))
            	);
            
            // add roles if given
            
            for(int i=1; i<input.length; i++) {
            	newAgent.addRole(input[i]);
            }

            return requestData;
        } catch (Exception e) {
            Logger.error(e);
            throw new InvalidDataException(e.getMessage(), "");
        }
	}
}