package com.c2kernel.process.module;

import java.util.ArrayList;
import java.util.Properties;

import com.c2kernel.common.ObjectNotFoundException;
import com.c2kernel.entity.imports.ImportAgent;
import com.c2kernel.entity.imports.ImportDependency;
import com.c2kernel.entity.imports.ImportDependencyMember;
import com.c2kernel.entity.imports.ImportItem;
import com.c2kernel.entity.imports.ImportOutcome;
import com.c2kernel.entity.imports.ImportRole;
import com.c2kernel.entity.proxy.AgentProxy;
import com.c2kernel.entity.proxy.ItemProxy;
import com.c2kernel.lookup.DomainPath;
import com.c2kernel.lookup.RolePath;
import com.c2kernel.process.Gateway;
import com.c2kernel.property.Property;
import com.c2kernel.scripting.ErrorInfo;
import com.c2kernel.scripting.ScriptingEngineException;
import com.c2kernel.utils.Logger;

public class Module extends ImportItem {

	private ModuleInfo info;
	private String resURL;
	private ModuleImports imports = new ModuleImports();
	private ArrayList<ModuleConfig> config = new ArrayList<ModuleConfig>();
	private ArrayList<ModuleScript> scripts = new ArrayList<ModuleScript>();
    
	public Module() {
		super();
		// Module properties
		properties.add(new com.c2kernel.property.Property("Type", "Module", false));
		setInitialPath("/desc/modules/");
		setWorkflow("NoWorkflow");
		setWorkflowVer(0);
		imports.list.add(this);
	}
	
	public void runScript(String event, AgentProxy user, boolean isServer) throws ScriptingEngineException {
		for (ModuleScript script : scripts) {
			if (script.shouldRun(event, isServer)) {
				Logger.msg("Running "+script.event+" "+script.target+" script from "+name);
				Object result = script.getScript(ns, user).execute();
				if (result instanceof ErrorInfo) {
					ErrorInfo error = (ErrorInfo) result;
					Logger.error(error.toString());
					if (error.getFatal())
						throw new ScriptingEngineException("Fatal Script Error");
				}
				else if (result != null)
					Logger.msg(result.toString());
			}
		}
	}
	
	public void setModuleXML(String moduleXML) {
		ImportOutcome moduleOutcome = new ImportOutcome("Module", 0, "last", null);
		moduleOutcome.data = moduleXML;
		outcomes.add(moduleOutcome);
	}
	
	@Override
	public void setNamespace(String ns) {
		super.setNamespace(ns);
		replaceProp(new Property("Namespace", ns, false));
	}

	@Override
	public void setName(String name) {
		super.setName(name);
		replaceProp(new Property("Name", name, false));
	}

	private void replaceProp(Property newProp) {
		for (Property prop : properties) {
			if (prop.getName().equals("Namespace")) {
				prop.setMutable(newProp.isMutable());
				prop.setValue(newProp.getValue());
				return;
			}
		}
		properties.add(newProp);
	}
	public void importAll(ItemProxy serverEntity, AgentProxy systemAgent, String moduleXML, boolean reset) throws Exception {
		setModuleXML(moduleXML);
		
		for (ModuleResource thisRes : imports.getResources()) {
			try {
				thisRes.setNamespace(ns);
				thisRes.create(systemAgent.getPath(), reset);
			} catch (Exception ex) {
				Logger.error(ex);
				Logger.die("Error importing module resources. Unsafe to continue.");
			}
		}

		for (ImportRole thisRole : imports.getRoles()) {
			RolePath rolePath;
			try {
				String roleName = thisRole.name;
				if (roleName.indexOf('/') > -1) roleName = roleName.substring(roleName.indexOf('/')+1);
				rolePath = Gateway.getLookup().getRolePath(roleName);
				if (rolePath.hasJobList() != thisRole.hasJobList()) {
					Logger.msg("Module.importAll() - Role '"+thisRole.name+"' has incorrect joblist settings. Correcting.");
					rolePath.setHasJobList(thisRole.hasJobList());
					Gateway.getLookupManager().createRole(rolePath);
				}
			} catch (ObjectNotFoundException ex) {
				Logger.msg("Module.importAll() - Role '"+thisRole.name+"' not found. Creating.");
				thisRole.create(systemAgent.getPath(), reset);
			}
		}
		
		for (ImportAgent thisAgent : imports.getAgents()) {
			try {
				Gateway.getLookup().getAgentPath(thisAgent.name);
			    Logger.msg(3, "Module.importAll() - User '"+thisAgent.name+"' found.");
			    continue;
			 } catch (ObjectNotFoundException ex) { }
			 Logger.msg("Module.importAll() - User '"+thisAgent.name+"' not found. Creating.");
			thisAgent.create(systemAgent.getPath(), reset);
		}
		
		for (ImportItem thisItem : imports.getItems()) {
			thisItem.setNamespace(ns);
			thisItem.create(systemAgent.getPath(), reset);
		}
		
	}
	
	public Properties getProperties(boolean isServer) {
		Properties props = new Properties();
		for (ModuleConfig thisProp : config) {
			if (thisProp.include(isServer))
				props.put(thisProp.name, thisProp.value);
		}
		return props;
	}

	public ArrayList<ModuleScript> getScripts() {
		return scripts;
	}

	public void setResURL(String resURL) {
		this.resURL = resURL;
	}
	public String getDesc() {
		return info.desc;
	}
	public String getVersion() {
		return info.version;
	}
	public String getResURL() {
		return resURL;
	}
	public ArrayList<String> getDependencies() {
		return info.dependency;
	}
	public boolean hasDependency(String dep) {
		return info.dependency.contains(dep);
	}

	public ModuleInfo getInfo() {
		return info;
	}

	public void setInfo(ModuleInfo info) {
		this.info = info;
		replaceProp(new Property("Version", info.version, true));
	}

	public ModuleImports getImports() {
		return imports;
	}
	
	public void setImports(ModuleImports imp) {
		// Add dependency for all children
		imports = imp;
		ImportDependency children = new ImportDependency("Contents");
		for (ModuleImport thisImport : imports.list) {
			DomainPath path = thisImport.domainPath;
			if (path != null)
			children.dependencyMemberList.add(new ImportDependencyMember(path.toString()));
		}
		dependencyList.add(children);
	}
	
	public void setConfig(ArrayList<ModuleConfig> config) {
		this.config = config;
	}
	
	public void setScripts(ArrayList<ModuleScript> scripts) {
		this.scripts = scripts;
	}

	public ArrayList<ModuleConfig> getConfig() {
		return config;
	}
	
	
}