From b086f57f56bf0eb9dab9cf321a0f69aaaae84347 Mon Sep 17 00:00:00 2001
From: Andrew Branson <andrew.branson@cern.ch>
Date: Wed, 30 May 2012 08:37:45 +0200
Subject: Initial Maven Conversion

---
 .../java/com/c2kernel/scripting/ErrorInfo.java     |  46 +++
 .../java/com/c2kernel/scripting/Parameter.java     |  52 +++
 .../com/c2kernel/scripting/ParameterException.java |  20 +
 src/main/java/com/c2kernel/scripting/Script.java   | 456 +++++++++++++++++++++
 .../java/com/c2kernel/scripting/ScriptConsole.java | 229 +++++++++++
 .../c2kernel/scripting/ScriptLoadingException.java |  24 ++
 .../c2kernel/scripting/ScriptParsingException.java |  21 +
 .../scripting/ScriptingEngineException.java        |  20 +
 8 files changed, 868 insertions(+)
 create mode 100644 src/main/java/com/c2kernel/scripting/ErrorInfo.java
 create mode 100644 src/main/java/com/c2kernel/scripting/Parameter.java
 create mode 100644 src/main/java/com/c2kernel/scripting/ParameterException.java
 create mode 100644 src/main/java/com/c2kernel/scripting/Script.java
 create mode 100644 src/main/java/com/c2kernel/scripting/ScriptConsole.java
 create mode 100644 src/main/java/com/c2kernel/scripting/ScriptLoadingException.java
 create mode 100644 src/main/java/com/c2kernel/scripting/ScriptParsingException.java
 create mode 100644 src/main/java/com/c2kernel/scripting/ScriptingEngineException.java

(limited to 'src/main/java/com/c2kernel/scripting')

diff --git a/src/main/java/com/c2kernel/scripting/ErrorInfo.java b/src/main/java/com/c2kernel/scripting/ErrorInfo.java
new file mode 100644
index 0000000..26c0384
--- /dev/null
+++ b/src/main/java/com/c2kernel/scripting/ErrorInfo.java
@@ -0,0 +1,46 @@
+package com.c2kernel.scripting;
+
+import java.util.ArrayList;
+
+/**************************************************************************
+ *
+ * $Revision: 1.2 $
+ * $Date: 2003/06/06 11:37:45 $
+ *
+ * Copyright (C) 2003 CERN - European Organization for Nuclear Research
+ * All rights reserved.
+ **************************************************************************/
+public class ErrorInfo {
+    ArrayList<String> msg;
+    boolean fatal = false;
+
+    public ErrorInfo() {
+        super();
+        msg = new ArrayList<String>();
+    }
+    
+    public ErrorInfo(String error) {
+    	this();
+    	msg.add(error);
+    }
+
+    public void addError(String error) {
+        msg.add(error);
+    }
+
+    public String getErrors() {
+        StringBuffer err = new StringBuffer();
+        for (String element : msg) {
+            err.append(element+"\n");
+        }
+        return err.toString();
+    }
+
+    public void setFatal() {
+        fatal=true;
+    }
+
+    public boolean getFatal() {
+        return fatal;
+    }
+}
diff --git a/src/main/java/com/c2kernel/scripting/Parameter.java b/src/main/java/com/c2kernel/scripting/Parameter.java
new file mode 100644
index 0000000..ed9a963
--- /dev/null
+++ b/src/main/java/com/c2kernel/scripting/Parameter.java
@@ -0,0 +1,52 @@
+package com.c2kernel.scripting;
+
+
+/**************************************************************************
+* Place holder for the Parameter details to be passed to the script.
+**************************************************************************/
+public class Parameter {
+
+    private String name;
+    private Class<?> type;
+    private boolean initialised=false;
+
+    public Parameter(String name) {
+        this.name = name;
+    }
+    
+    public Parameter(String name, Class<?> type) {
+        this.name = name;
+        this.type = type;
+    }
+
+    public void setName(String n)
+    {
+        name=n;
+    }
+
+    public String getName()
+    {
+        return name;
+    }
+
+    public void setType(Class<?> t)
+    {
+        type=t;
+    }
+
+    public Class<?> getType()
+    {
+        return type;
+    }
+
+    public void setInitialised(boolean state)
+    {
+        initialised=state;
+    }
+
+    public boolean getInitialised()
+    {
+        return initialised;
+    }
+
+}
diff --git a/src/main/java/com/c2kernel/scripting/ParameterException.java b/src/main/java/com/c2kernel/scripting/ParameterException.java
new file mode 100644
index 0000000..b191908
--- /dev/null
+++ b/src/main/java/com/c2kernel/scripting/ParameterException.java
@@ -0,0 +1,20 @@
+package com.c2kernel.scripting;
+
+public class ParameterException extends ScriptingEngineException {
+
+     /**
+     * Creates new <code>ParameterException</code> without detail message.
+     */
+    public ParameterException() {
+    }
+
+    /**
+     * Constructs an <code>ParameterException</code> with the specified detail message.
+     * @param msg the detail message.
+     */
+    public ParameterException(String msg) {
+        super(msg);
+    }
+}
+
+
diff --git a/src/main/java/com/c2kernel/scripting/Script.java b/src/main/java/com/c2kernel/scripting/Script.java
new file mode 100644
index 0000000..7e40003
--- /dev/null
+++ b/src/main/java/com/c2kernel/scripting/Script.java
@@ -0,0 +1,456 @@
+package com.c2kernel.scripting;
+
+import java.io.StringReader;
+import java.util.ArrayList;
+import java.util.HashMap;
+
+import javax.script.Bindings;
+import javax.script.ScriptEngine;
+import javax.script.ScriptEngineFactory;
+import javax.script.ScriptEngineManager;
+import javax.xml.parsers.DocumentBuilder;
+import javax.xml.parsers.DocumentBuilderFactory;
+
+import org.w3c.dom.Document;
+import org.w3c.dom.Element;
+import org.w3c.dom.NodeList;
+import org.w3c.dom.Text;
+import org.xml.sax.InputSource;
+
+import com.c2kernel.common.ObjectNotFoundException;
+import com.c2kernel.entity.agent.Job;
+import com.c2kernel.entity.proxy.AgentProxy;
+import com.c2kernel.entity.proxy.ItemProxy;
+import com.c2kernel.utils.LocalObjectLoader;
+import com.c2kernel.utils.Logger;
+
+/**************************************************************************
+ *
+ * $Revision: 1.25 $
+ * $Date: 2005/10/05 07:39:37 $
+ *
+ * Copyright (C) 2003 CERN - European Organization for Nuclear Research
+ * All rights reserved.
+ **************************************************************************/
+public class Script
+{
+    String mScript = "";
+    String mName;
+    String mVersion;
+    HashMap<String, Parameter> mInputParams = new HashMap<String, Parameter>();
+    HashMap<String, Parameter> mAllInputParams = new HashMap<String, Parameter>();
+    HashMap<String, Parameter> mOutputParams = new HashMap<String, Parameter>();
+    ArrayList<Script> mIncludes = new ArrayList<Script>();
+    ScriptEngine engine;
+    Bindings beans;
+
+    /**
+     * Loads script xml and parses it for script source, parameters and output specifications.
+     * First tries to load the script from resource path /scriptFiles/scriptName_scriptVersion.xml
+     * If not found tries to find item at /desc/ScriptDesc/scriptName and load Viewpoint scriptVersion from it.
+     *
+     * For the specification of script xml, see the Script schema from resources.
+     *
+     * @param scriptName - name of the script
+     * @param scriptVersion - named version of the script (must be numbered viewpoint)
+     * @throws ScriptParsingException - when script not found (ScriptLoadingException) or xml is invalid (ScriptParsingException)
+     */
+    public Script(String scriptName, int scriptVersion, Bindings context) throws ScriptingEngineException
+    {
+    	this(scriptName, scriptVersion);
+        beans = context;
+
+    }
+    
+    public Script(String scriptName, int scriptVersion) throws ScriptingEngineException
+    {
+        mName = scriptName;
+        mVersion = String.valueOf(scriptVersion);
+        if (!scriptName.equals("")) 
+        	setScript(mName, mVersion);
+    }
+
+    /**
+     * Creates a script executor for the supplied expression, bypassing the xml parsing bit
+     * Output class is forced to an object.
+     */
+    public Script(String lang, String expr, Class<?> returnType) throws ScriptingEngineException
+    {
+        mName = "<expr>";
+        setScriptEngine(lang);
+        mVersion = "";
+        addOutput(null, returnType);
+        mScript = expr;
+    }
+
+    public Script(String lang, String expr) throws ScriptingEngineException
+    {
+        this(lang, expr, Object.class);
+    }
+
+    public Script(ItemProxy object, AgentProxy subject, Job job) throws ScriptingEngineException
+    {
+        this(job.getActPropString("ScriptName"), job.getActPropString("ScriptVersion") == null ? -1 : Integer.parseInt(job.getActPropString("ScriptVersion")));
+        // set enviroment - this needs to be well documented for script developers
+        if (!mInputParams.containsKey("item"))
+        	addInputParam("item", ItemProxy.class);
+        setInputParamValue("item", object);
+
+        if (!mInputParams.containsKey("agent"))
+        	addInputParam("agent", AgentProxy.class);
+        setInputParamValue("agent", subject);
+
+        if (!mInputParams.containsKey("job"))
+        	addInputParam("job", Job.class);
+        setInputParamValue("job", job);
+
+        if (!mOutputParams.containsKey("errors"))
+        	addOutput("errors", ErrorInfo.class);
+    }
+
+    public void setScriptEngine(String lang) {
+    	engine = new ScriptEngineManager().getEngineByName(lang);
+    	beans = engine.createBindings();
+    }
+    
+    public void setScript(String scriptName, String scriptVersion) throws ScriptingEngineException
+    {
+        try
+        {
+            mName = scriptName;
+            mVersion = scriptVersion;
+            parseScriptXML(LocalObjectLoader.getScript(scriptName, scriptVersion));
+        }
+        catch (ObjectNotFoundException e)
+        {
+            throw new ScriptingEngineException("Script "+scriptName+" not found");
+        }
+    }
+
+    /**
+     * Extracts script data from script xml.
+     *
+     * @param scriptXML
+     * @throws ScriptParsingException - when script is invalid
+     */
+    private void parseScriptXML(String scriptXML) throws ScriptParsingException, ParameterException
+    {
+        Document scriptDoc = null;
+
+        // get the DOM document from the XML
+        DocumentBuilderFactory factory = DocumentBuilderFactory.newInstance();
+        try
+        {
+            DocumentBuilder domBuilder = factory.newDocumentBuilder();
+            scriptDoc = domBuilder.parse(new InputSource(new StringReader(scriptXML)));
+        }
+        catch (Exception ex)
+        {
+            throw new ScriptParsingException("Error parsing Script XML : " + ex.toString());
+        }
+
+        Element root = scriptDoc.getDocumentElement();
+        NodeList scriptNodes = root.getChildNodes();
+        for (int i = 0; i < scriptNodes.getLength(); i++)
+        {
+            Element currentParam;
+            String paramName;
+
+            try
+            {
+                currentParam = (Element) scriptNodes.item(i);
+            }
+            catch (ClassCastException ex)
+            {
+                // not an element, skip
+                continue;
+            }
+            paramName = currentParam.getTagName();
+            Logger.msg(9, "Script.parseScriptXML() - Found element " + paramName);
+
+            // Process script parameters
+
+            // input parameter
+            if (paramName.equals("param"))
+            {
+                if (!(currentParam.hasAttribute("name") && currentParam.hasAttribute("type")))
+                    throw new ScriptParsingException("Script Input Param incomplete, must have name and type");
+                addInputParam(currentParam.getAttribute("name"), currentParam.getAttribute("type"));
+            }
+
+            //load output type
+            else if (paramName.equals("output"))
+            {
+                if (!currentParam.hasAttribute("type"))
+                    throw new ScriptParsingException("Script Output declaration incomplete, must have type");
+                addOutput(currentParam.getAttribute("name"), currentParam.getAttribute("type"));
+            }
+
+            //load any included scripts
+            else if (paramName.equals("include"))
+            {
+                if (!(currentParam.hasAttribute("name") && currentParam.hasAttribute("version")))
+                    throw new ScriptParsingException("Script include declaration incomplete, must have name and version");
+                String includeName = currentParam.getAttribute("name");
+                String includeVersion =  currentParam.getAttribute("version");
+                try {
+                    Script includedScript = new Script(includeName, Integer.parseInt(includeVersion), beans);
+                    mIncludes.add(includedScript);
+                    for (Parameter includeParam : includedScript.getInputParams().values()) {
+                        addIncludedInputParam(includeParam.getName(), includeParam.getType());
+                    }
+                } catch (NumberFormatException e) {
+                    throw new ScriptParsingException("Invalid version in imported script "+includeName+"_"+includeVersion);
+                } catch (ScriptingEngineException e) {
+                    throw new ScriptParsingException("Error parsing imported script "+includeName+"_"+includeVersion+": "+e.getMessage());
+                }
+
+
+            }
+            //load Script
+            else if (paramName.equals("script"))
+            {
+                if (!currentParam.hasAttribute("language"))
+                    throw new ScriptParsingException("Script data incomplete, must specify scripting language");
+                Logger.msg(6, "Script.parseScriptXML() - Script Language: " + currentParam.getAttribute("language"));
+                setScriptEngine(currentParam.getAttribute("language"));
+
+                // get script source
+                NodeList scriptChildNodes = currentParam.getChildNodes();
+                if (scriptChildNodes.getLength() != 1)
+                    throw new ScriptParsingException("More than one child element found under script tag. Script characters may need escaping - suggest convert to CDATA section");
+                if (scriptChildNodes.item(0) instanceof Text)
+                    mScript = ((Text) scriptChildNodes.item(0)).getData();
+                else
+                    throw new ScriptParsingException("Child element of script tag was not text");
+                Logger.msg(6, "Script.parseScriptXML() - script:" + mScript);
+            }
+        }
+    }
+
+    protected void addInputParam(String name, String type) throws ParameterException
+    {
+    	try
+        {
+            addInputParam(name, Class.forName(type));
+        }
+        catch (ClassNotFoundException ex)
+        {
+            throw new ParameterException("Input parameter " + name + " specifies class " + type + " which was not found.");
+        }
+    }
+    
+    protected void addInputParam(String name, Class<?> type) throws ParameterException
+    {
+        Parameter inputParam = new Parameter(name, type);
+
+        
+
+        Logger.msg(6, "ScriptExecutor.parseScriptXML() - declared parameter " + name + " (" + type + ")");
+        //add parameter to hashtable
+        mInputParams.put(inputParam.getName(), inputParam);
+        mAllInputParams.put(inputParam.getName(), inputParam);
+
+    }
+
+    protected void addIncludedInputParam(String name, Class<?> type) throws ParameterException
+    {
+        // check if we already have it
+        if (mAllInputParams.containsKey(name)) {
+            Parameter existingParam = mAllInputParams.get(name);
+            // check the types match
+            if (existingParam.getType() == type)
+                return; // matches
+            else // error
+                throw new ParameterException("Parameter conflict. Parameter'"+name+"' is declared as  "
+                        +existingParam.getType().getName()+" is declared in another script as "+type.getName());
+        }
+
+        Parameter inputParam = new Parameter(name);
+        inputParam.setType(type);
+
+        //add parameter to hashtable
+        mAllInputParams.put(inputParam.getName(), inputParam);
+
+    }
+
+    protected void addOutput(String name, String type) throws ParameterException
+    {
+        try
+        {
+            addOutput(name, Class.forName(type));
+        }
+        catch (ClassNotFoundException ex) {
+            throw new ParameterException("Output parameter " + name + " specifies class " + type + " which was not found.");
+        }
+    }
+
+    protected void addOutput(String name, Class<?> type) throws ParameterException
+    {
+        String outputName = name;
+
+        Parameter outputParam = new Parameter(name, type);
+
+        if (mOutputParams.containsKey(outputName))
+        	throw new ParameterException("Output parameter '"+outputName+"' declared more than once.");
+
+        mOutputParams.put(outputName, outputParam);
+        
+    }
+
+    /**
+     * Gets all declared parameters
+     * @return HashMap of String (name), com.c2kernel.scripting.Parameter (param)
+     * @see com.c2kernel.scripting.Parameter
+     */
+    public HashMap<String, Parameter> getInputParams()
+    {
+        return mInputParams;
+    }
+
+    /**
+     * Gets all declared parameters, including those of imported scripts
+     * @return HashMap of String (name), com.c2kernel.scripting.Parameter (param)
+     * @see com.c2kernel.scripting.Parameter
+     */
+    public HashMap<String, Parameter> getAllInputParams()
+    {
+        return mAllInputParams;
+    }
+
+    /**
+     * Submits an input parameter to the script. Must be declared by name and type in the script XML.
+     *
+     * @param name - input parameter name from the script xml
+     * @param value - object to use for this parameter
+     * @throws ParameterException - name not found or wrong type
+     */
+    public void setInputParamValue(String name, Object value) throws ParameterException
+    {
+        Parameter param = mInputParams.get(name);
+
+        if (!mAllInputParams.containsKey(name))
+            throw new ParameterException("Parameter " + name + " not found in parameter list");
+
+        if (param != null) { // param is in this script
+            if (value.getClass() != param.getType())
+                throw new ParameterException(
+                    "Parameter " + name + " is wrong type \n" + "Required: " + param.getType().toString() + "\n" + "Supplied: " + value.getClass().toString());
+            beans.put(name, value);
+            Logger.msg(7, "Script.setInputParamValue() - " + name + ": " + value.toString());
+            param.setInitialised(true);
+        }
+
+        // pass param down to child scripts
+        for (Script importScript : mIncludes) {
+            importScript.setInputParamValue(name, value);
+        }
+    }
+
+    /**
+     * Executes the script with the submitted parameters. All declared input parametes should have been set first.
+     *
+     * @return The return value depends on the way the output type was declared in the script xml.
+     * <ul><li>If there was no output class declared then null is returned
+     * <li>If a class was declared, but not named, then the object returned by the script is checked
+     * to be of that type, then returned.
+     * <li>If the output value was named and typed, then an object of that class is created and
+     * passed to the script as an input parameter. The script should set this before it returns.
+     * </ul>
+     * @throws ScriptingEngineException - input parameters weren't set, there was an error executing the script, or the output was invalid
+     */
+    public Object execute() throws ScriptingEngineException
+    {
+
+        // check input params
+        StringBuffer missingParams = new StringBuffer();
+        for (Parameter thisParam : mInputParams.values()) {
+            if (!thisParam.getInitialised())
+                missingParams.append(thisParam.getName()).append("\n");
+        }
+        // croak if any missing
+        if (missingParams.length() > 0)
+            throw new ScriptingEngineException("Execution aborted, the following declared parameters were not set: \n" + missingParams.toString());
+
+        for (Parameter outputParam : mOutputParams.values()) {
+        	if (outputParam.getName() == null) continue; // If the name is null then it's the return type. don't pre-register it
+            Logger.msg(8, "Script.setOutput() - Initialising output bean '" + outputParam.getName() + "'");
+            Object emptyObject;
+			try {
+				emptyObject = outputParam.getType().newInstance();
+			} catch (Exception e) {
+				emptyObject = null;
+			}
+            beans.put(outputParam.getName(), emptyObject);
+
+		}
+
+        // execute the child scripts
+        for (Script importScript : mIncludes) {
+            importScript.execute();
+        }
+
+        // run the script
+        Object returnValue = null;
+        try
+        {
+            Logger.msg(7, "Script.execute() - Executing script");
+            if (engine == null)
+            	throw new ScriptingEngineException("Script engine not set. Cannot execute scripts.");
+            returnValue = engine.eval(mScript, beans);
+            Logger.msg(8, "Script.execute() - script returned \"" + returnValue + "\"");
+        }
+        catch (Exception ex)
+        {
+            throw new ScriptingEngineException("Error executing script: " + ex.getMessage());
+        }
+        
+        // if no outputs are defined, return null
+        if (mOutputParams.size() == 0) {
+        	Logger.msg(4, "Script.execute() - No output params. Returning null.");
+        	return null;
+        }
+        
+		HashMap<String, Object> outputs = new HashMap<String, Object>();
+		
+        for (Parameter outputParam : mOutputParams.values()) {
+        	String outputName = outputParam.getName();
+        	Object outputValue;
+        	if (outputName == null)
+        		outputValue = returnValue;
+        	else
+        		outputValue = beans.get(outputParam.getName());
+        	Logger.msg(4, "Script.execute() - Output parameter "+outputName+"="+(outputValue==null?"null":outputValue.toString()));
+        	
+       		// check the class
+       		if (outputValue!=null && !(outputParam.getType().isInstance(outputValue)))
+       			throw new ScriptingEngineException(
+                     "Script output "+outputName+" was not null or instance of " + outputParam.getType().getName() + ", it was a " + outputValue.getClass().getName());    
+                  		
+       		Logger.msg(8, "Script.execute() - output "+outputValue);
+       		if (mOutputParams.size() == 1) {
+       			Logger.msg(6, "Script.execute() - only one parameter, returning "+(outputValue==null?"null":outputValue.toString()));
+       			return outputValue;
+       		}
+       		outputs.put(outputParam.getName(), outputValue);
+		}
+        
+        return outputs;
+    }
+
+    /**
+     * Resets the scripting enviroment, clearing all state and parameters for another execution.
+     */
+    public void reset()
+    {
+        for (Parameter parameter : mInputParams.values())
+			parameter.setInitialised(false);
+        beans = engine.createBindings();
+    }
+    
+    static public void main(String[] args) {
+    	for(ScriptEngineFactory sef: new ScriptEngineManager().getEngineFactories()) {
+    		System.out.println(sef.getEngineName()+" v"+sef.getEngineVersion()+" using "+sef.getLanguageName()+" v"+sef.getLanguageVersion());
+    	}
+    }
+}
diff --git a/src/main/java/com/c2kernel/scripting/ScriptConsole.java b/src/main/java/com/c2kernel/scripting/ScriptConsole.java
new file mode 100644
index 0000000..be3f79f
--- /dev/null
+++ b/src/main/java/com/c2kernel/scripting/ScriptConsole.java
@@ -0,0 +1,229 @@
+package com.c2kernel.scripting;
+
+import java.io.BufferedReader;
+import java.io.IOException;
+import java.io.InputStreamReader;
+import java.io.InterruptedIOException;
+import java.io.PrintStream;
+import java.net.InetAddress;
+import java.net.Socket;
+import java.net.UnknownHostException;
+import java.util.ArrayList;
+import java.util.StringTokenizer;
+
+import javax.script.Bindings;
+import javax.script.ScriptEngine;
+import javax.script.ScriptEngineManager;
+
+import org.tanukisoftware.wrapper.WrapperManager;
+
+import com.c2kernel.process.Gateway;
+import com.c2kernel.utils.Logger;
+import com.c2kernel.utils.Resource;
+import com.c2kernel.utils.server.SocketHandler;
+
+/**************************************************************************
+ *
+ * $Revision: 1.16 $
+ * $Date: 2005/08/31 07:20:40 $
+ *
+ * Copyright (C) 2003 CERN - European Organization for Nuclear Research
+ * All rights reserved.
+ **************************************************************************/
+
+
+
+public class ScriptConsole implements SocketHandler {
+    BufferedReader input;
+    PrintStream output;
+    Socket socket = null;
+    ScriptEngine engine;
+    Bindings beans;
+    static ArrayList<String> securityHosts = new ArrayList<String>();
+    public static final short NONE = 0;
+    public static final short ALLOW = 1;
+    public static final short DENY = 2;
+    static short securityMode;
+
+    static {
+        securityMode = ALLOW;
+        String hosts = Gateway.getProperty("ItemServer.Console.allow");
+        if (hosts == null || hosts.equals("")) {
+            securityMode = DENY;
+            hosts = Gateway.getProperty("ItemServer.Console.deny");
+        }
+        if (hosts == null || hosts.equals("")) { // by default only allow localhost
+            securityMode = ALLOW;
+            securityHosts.add("127.0.0.1");
+        }
+        else {
+            StringTokenizer tok = new StringTokenizer(hosts, ",");
+            while(tok.hasMoreTokens()) {
+                try {
+                    securityHosts.add(InetAddress.getByName(tok.nextToken()).getHostAddress());
+                } catch (UnknownHostException ex) {
+                    Logger.error("Host not found "+ex.getMessage());
+                }
+            }
+        }
+    }
+    public ScriptConsole() {
+    }
+
+    @Override
+	public String getName() {
+        return "Script Console";
+    }
+
+    @Override
+	public boolean isBusy() {
+        return (socket != null);
+    }
+
+    @Override
+	public void setSocket(Socket newSocket) {
+        try {
+            input = new BufferedReader(new InputStreamReader(newSocket.getInputStream()));
+            output = new PrintStream(newSocket.getOutputStream());
+            newSocket.setSoTimeout(0);
+            socket = newSocket;
+        } catch (IOException ex) {
+            try {
+                newSocket.close();
+            } catch (IOException ex2) {
+            }
+            socket = null;
+            return;
+        }
+    }
+
+    @Override
+	public void shutdown() {
+        Socket closingSocket = socket;
+        socket = null;
+        if (closingSocket == null)
+            return;
+        try {
+            Logger.removeLogStream(output);
+            closingSocket.shutdownInput();
+            closingSocket.shutdownOutput();
+            closingSocket.close();
+            Logger.msg("Script console to "+closingSocket.getInetAddress()+" closed");
+        } catch (IOException e) {
+            Logger.error("Script Console to " + closingSocket.getInetAddress() + " - Error closing.");
+            Logger.error(e);
+        }
+    }
+
+
+    @Override
+	public void run() {
+        // check permission
+        boolean allowed = true;
+        if (securityMode!=NONE) {
+            if (securityHosts.contains(socket.getInetAddress().getHostAddress())) {
+                if (securityMode==DENY)
+                    allowed = false;
+            }
+            else if (securityMode==ALLOW)
+                allowed = false;
+        }
+
+        if (!allowed) {
+            Logger.error("Host "+socket.getInetAddress()+" access denied");
+            output.println("Host "+socket.getInetAddress()+" access denied");
+            shutdown();
+            return;
+        }
+
+        // get system objects
+        try {
+            Logger.addLogStream(output, 0);
+            
+            engine = new ScriptEngineManager().getEngineByName("JavaScript");
+            beans = engine.createBindings();
+            beans.put("storage", Gateway.getStorage());
+            beans.put("db", Gateway.getStorage().getDb());
+            beans.put("proxy", Gateway.getProxyManager());
+            beans.put("lookup", Gateway.getLDAPLookup());
+            beans.put("orb", Gateway.getORB());
+            try {
+            	beans.put("system", Gateway.getProxyManager().getProxy(
+            		Gateway.getLDAPLookup().getRoleManager().getAgentPath("system")));
+            } catch (Exception ex) {
+            	output.println("System agent unavailable");
+            }
+ 
+            StringBuffer commandBuffer = new StringBuffer();
+            while (socket != null) {
+
+                output.println();
+                output.print('>');
+
+                String command = null;
+                boolean gotCommand = false;
+                while (!gotCommand) {
+                    try {
+                        command = input.readLine();
+                        gotCommand = true;
+                    } catch (InterruptedIOException ex) {
+                    }
+                }
+                if (command == null) // disconnected
+                    shutdown();
+                else {
+                    if (command.equals("exit")) {
+                        shutdown();
+                        continue;
+                    }
+                    else if(command.startsWith("log")) {
+                        try {
+                            int newLogLevel = Integer.parseInt(command.substring(4));
+                            Logger.removeLogStream(output);
+                            Logger.addLogStream(output, newLogLevel);
+                            Logger.msg("Log level for "+socket.getInetAddress()+" set to "+newLogLevel);
+                            continue;
+                        } catch (NumberFormatException ex) { }
+                    }
+                    else if(command.equals("help")) {
+                        output.println(Resource.findTextResource("textFiles/consoleHelp.txt"));
+                        continue;
+                    }
+                    else if(command.equals("version")) {
+						output.println("Kernel version: "+Resource.getKernelVersion());
+						output.println("Modules loaded: "+Gateway.getModuleManager().getModuleVersions());
+						continue;
+                    }
+                    try {
+                        if (command.endsWith("\\")) {
+                            commandBuffer.append(command.substring(0,command.length()-1));
+                            continue;
+                        }
+                        commandBuffer.append(command);
+                        command = commandBuffer.toString();
+                        commandBuffer = new StringBuffer();
+                        Logger.msg("Console command from "+socket.getInetAddress()+": "+command);
+
+                        // process control
+                        if (command.equals("shutdown")) {
+                        			WrapperManager.stop(0);
+                        }
+                        else {
+                        	Object response = engine.eval(command, beans);
+                        	if (response instanceof sun.org.mozilla.javascript.internal.Undefined)
+                        		output.println("Ok");
+                        	else
+                        		output.println(response);
+                        }
+                    } catch (Throwable ex) {
+                       	ex.printStackTrace(output);
+                    }
+                    output.flush();
+                }
+            }
+        } catch (IOException ex) {
+            Logger.error("IO Exception reading from script console socket");
+            shutdown();
+        }
+    }
+}
diff --git a/src/main/java/com/c2kernel/scripting/ScriptLoadingException.java b/src/main/java/com/c2kernel/scripting/ScriptLoadingException.java
new file mode 100644
index 0000000..16f9ab5
--- /dev/null
+++ b/src/main/java/com/c2kernel/scripting/ScriptLoadingException.java
@@ -0,0 +1,24 @@
+package com.c2kernel.scripting;
+
+/**************************************************************************
+ *
+ * $Revision: 1.1 $
+ * $Date: 2003/04/06 12:32:51 $
+ *
+ * Copyright (C) 2003 CERN - European Organization for Nuclear Research
+ * All rights reserved.
+ **************************************************************************/
+public class ScriptLoadingException extends ScriptingEngineException {
+  /**
+     *
+     */
+    public ScriptLoadingException() {
+        super();
+    }
+    /**
+     *
+     */
+    public ScriptLoadingException(String msg) {
+        super(msg);
+    }
+}
diff --git a/src/main/java/com/c2kernel/scripting/ScriptParsingException.java b/src/main/java/com/c2kernel/scripting/ScriptParsingException.java
new file mode 100644
index 0000000..939372b
--- /dev/null
+++ b/src/main/java/com/c2kernel/scripting/ScriptParsingException.java
@@ -0,0 +1,21 @@
+package com.c2kernel.scripting;
+
+public class ScriptParsingException extends ScriptingEngineException {
+
+     /**
+     * Creates new <code>ScriptParsingException</code> without detail message.
+     */
+    public ScriptParsingException() {
+    }
+
+
+    /**
+     * Constructs an <code>ScriptParsingException</code> with the specified detail message.
+     * @param msg the detail message.
+     */
+    public ScriptParsingException(String msg) {
+        super(msg);
+    }
+}
+
+
diff --git a/src/main/java/com/c2kernel/scripting/ScriptingEngineException.java b/src/main/java/com/c2kernel/scripting/ScriptingEngineException.java
new file mode 100644
index 0000000..ab8383c
--- /dev/null
+++ b/src/main/java/com/c2kernel/scripting/ScriptingEngineException.java
@@ -0,0 +1,20 @@
+package com.c2kernel.scripting;
+
+public class ScriptingEngineException extends java.lang.Exception {
+
+     /**
+     * Creates new <code>sciptingEngineException</code> without detail message.
+     */
+    public ScriptingEngineException() {
+    }
+
+    /**
+     * Constructs an <code>sciptingEngineException</code> with the specified detail message.
+     * @param msg the detail message.
+     */
+    public ScriptingEngineException(String msg) {
+        super(msg);
+    }
+}
+
+
-- 
cgit v1.2.3