Initial commit2.2

5 files changed, 590 insertions, 0 deletions

diff --git a/source/com/c2kernel/persistency/outcome/Outcome.java b/source/com/c2kernel/persistency/outcome/Outcome.java
new file mode 100755
index 0000000..f919230
--- /dev/null
+++ b/source/com/c2kernel/persistency/outcome/Outcome.java
@@ -0,0 +1,159 @@
+package com.c2kernel.persistency.outcome;

+import java.io.StringReader;

+import java.io.StringWriter;

+import java.util.StringTokenizer;

+

+import javax.xml.parsers.DocumentBuilder;

+import javax.xml.parsers.DocumentBuilderFactory;

+import javax.xml.parsers.ParserConfigurationException;

+

+import org.apache.xml.serialize.Method;

+import org.apache.xml.serialize.OutputFormat;

+import org.apache.xml.serialize.XMLSerializer;

+import org.w3c.dom.Document;

+import org.xml.sax.InputSource;

+

+import com.c2kernel.common.PersistencyException;

+import com.c2kernel.entity.C2KLocalObject;

+import com.c2kernel.persistency.ClusterStorage;

+import com.c2kernel.utils.Logger;

+

+public class Outcome implements C2KLocalObject {

+    int mID = -1;

+    String mData;

+    String mSchemaType;

+    int mSchemaVersion;

+    static DocumentBuilder parser;

+    

+    static {

+        DocumentBuilderFactory dbf = DocumentBuilderFactory.newInstance();

+        dbf.setValidating(false);

+        dbf.setNamespaceAware(false); 

+        try {

+            parser = dbf.newDocumentBuilder();

+        } catch (ParserConfigurationException e) {

+            Logger.error(e);

+        }          

+    }

+    

+    //id is the eventID

+    public Outcome(int id, String data, String schemaType, int schemaVersion) {

+        mID = id;

+        mData = data;

+        mSchemaType = schemaType;

+        mSchemaVersion = schemaVersion;

+    }

+    

+    public Outcome(String path, String data) throws PersistencyException {

+    // derive all the meta data from the path

+        StringTokenizer tok = new StringTokenizer(path,"/");

+        if (tok.countTokens() != 3 && !(tok.nextToken().equals("Outcome"))) 

+            throw new PersistencyException("Outcome() - Outcome path must have three components: "+path, null);

+        mSchemaType = tok.nextToken();

+        String verstring = tok.nextToken();

+        String objId = tok.nextToken();

+        try {

+            mSchemaVersion = Integer.parseInt(verstring);

+        } catch (NumberFormatException ex) { 

+            throw new PersistencyException("Outcome() - Outcome version was an invalid number: "+verstring, null);

+        }

+        try {

+            mID = Integer.parseInt(objId);

+        } catch (NumberFormatException ex) { 

+            mID = -1;

+        }

+        mData = data;

+    }

+

+    public void setID(int ID) {

+        mID = ID;

+    }

+

+    public int getID() {

+        return mID;

+    }

+

+    public void setName(String name) {

+    	try {

+    		mID = Integer.parseInt(name);

+    	} catch (NumberFormatException e) {

+    		Logger.error("Invalid id set on Outcome:"+name);

+    	}

+    }

+

+    public String getName() {

+        return String.valueOf(mID);

+    }

+

+    public void setData(String data) {

+        mData = data;

+    }

+    

+    public void setData(Document data) {

+        mData = serialize(data, false);

+    }

+

+    public String getData() {

+        return mData;

+    }

+    

+    public void setSchemaType(String schemaType) {

+        mSchemaType = schemaType;

+    }

+    

+    public String getSchemaType() {

+        return mSchemaType;

+    }

+

+    public void setSchemaURL(int schemaVersion) {

+        mSchemaVersion = schemaVersion;

+    }

+    

+    public int getSchemaVersion() {

+        return mSchemaVersion;

+    }    

+    

+    public void setSchemaVersion(int schVer) {

+        mSchemaVersion = schVer;

+    } 

+    

+	public String getClusterType() {

+		return ClusterStorage.OUTCOME;

+	}

+    

+    // special script API methods

+

+    /**

+     * Parses the outcome into a DOM tree

+     * @return a DOM Document 

+     */

+    public Document getDOM() {

+        try {

+            synchronized (parser) {

+                return parser.parse(new InputSource(new StringReader(mData)));

+            }

+        } catch (Exception e) {

+            Logger.error(e);

+            return null;

+        }

+    }

+    

+    static public String serialize(Document doc, boolean prettyPrint)

+    {

+        String serializedDoc = null;

+        OutputFormat format = new OutputFormat(Method.XML, null, prettyPrint);

+        StringWriter stringOut = new StringWriter();

+        XMLSerializer serial = new XMLSerializer(stringOut, format);

+        try

+        {

+            serial.asDOMSerializer();

+            serial.serialize(doc);

+        }

+        catch (java.io.IOException ex)

+        {

+            Logger.error(ex.toString());

+        }

+        serializedDoc = stringOut.toString();

+        return serializedDoc;

+    }

+}

diff --git a/source/com/c2kernel/persistency/outcome/OutcomeValidator.java b/source/com/c2kernel/persistency/outcome/OutcomeValidator.java
new file mode 100755
index 0000000..1a76322
--- /dev/null
+++ b/source/com/c2kernel/persistency/outcome/OutcomeValidator.java
@@ -0,0 +1,183 @@
+

+package com.c2kernel.persistency.outcome;

+

+import java.io.IOException;

+import java.io.StringReader;

+

+import org.apache.xerces.parsers.DOMParser;

+import org.apache.xerces.parsers.IntegratedParserConfiguration;

+import org.apache.xerces.parsers.XMLGrammarPreparser;

+import org.apache.xerces.util.SymbolTable;

+import org.apache.xerces.util.XMLGrammarPoolImpl;

+import org.apache.xerces.xni.XNIException;

+import org.apache.xerces.xni.grammars.Grammar;

+import org.apache.xerces.xni.grammars.XMLGrammarDescription;

+import org.apache.xerces.xni.parser.XMLErrorHandler;

+import org.apache.xerces.xni.parser.XMLInputSource;

+import org.apache.xerces.xni.parser.XMLParseException;

+import org.apache.xerces.xni.parser.XMLParserConfiguration;

+import org.xml.sax.ErrorHandler;

+import org.xml.sax.SAXException;

+import org.xml.sax.SAXParseException;

+

+import com.c2kernel.common.InvalidDataException;

+import com.c2kernel.utils.Logger;

+

+/**************************************************************************

+ *

+ * $Revision: 1.24 $

+ * $Date: 2005/06/09 13:50:10 $

+ *

+ * Copyright (C) 2003 CERN - European Organization for Nuclear Research

+ * All rights reserved.

+ **************************************************************************/

+

+

+public class OutcomeValidator implements ErrorHandler, XMLErrorHandler {

+

+	protected static final String NAMESPACES_FEATURE_ID = "http://xml.org/sax/features/namespaces";

+	/** Validation feature id (http://xml.org/sax/features/validation). */

+	protected static final String VALIDATION_FEATURE_ID = "http://xml.org/sax/features/validation";

+	/** Schema validation feature id (http://apache.org/xml/features/validation/schema). */

+	protected static final String SCHEMA_VALIDATION_FEATURE_ID = "http://apache.org/xml/features/validation/schema";

+	/** Schema full checking feature id (http://apache.org/xml/features/validation/schema-full-checking). */

+	protected static final String SCHEMA_FULL_CHECKING_FEATURE_ID = "http://apache.org/xml/features/validation/schema-full-checking";

+    public static final String GRAMMAR_POOL = "http://apache.org/xml/properties/internal/grammar-pool";

+	

+    static SchemaValidator schemaValid = new SchemaValidator();

+    	

+    Schema schema;

+    protected StringBuffer errors = null;

+    XMLGrammarPoolImpl schemaGrammarPool = new XMLGrammarPoolImpl(1);  

+    SymbolTable sym = new SymbolTable();     

+    

+    public static OutcomeValidator getValidator(Schema schema) throws InvalidDataException {

+        String schemaId = schema.docType+"_"+schema.docVersion;

+        

+        if (schemaId.equals("Schema_0"))

+            return schemaValid;

+        

+         return new OutcomeValidator(schema);

+    }

+        

+    protected OutcomeValidator() {

+        errors = new StringBuffer();

+    }

+    

+	public OutcomeValidator(Schema schema) throws InvalidDataException {

+		this.schema = schema;

+        

+        if (schema.docType.equals("Schema"))

+            throw new InvalidDataException("Use SchemaValidator to validate schema", "");

+            

+		errors = new StringBuffer();

+        Logger.msg(5, "Parsing "+schema.docType+" version "+schema.docVersion+". "+schema.schema.length()+" chars");

+

+        XMLGrammarPreparser preparser = new XMLGrammarPreparser(sym);

+        preparser.registerPreparser(XMLGrammarDescription.XML_SCHEMA, null);

+        preparser.setProperty(GRAMMAR_POOL, schemaGrammarPool);

+

+        preparser.setFeature(NAMESPACES_FEATURE_ID, true);

+        preparser.setFeature(VALIDATION_FEATURE_ID, true);

+        preparser.setFeature(SCHEMA_VALIDATION_FEATURE_ID, true);

+        preparser.setFeature(SCHEMA_FULL_CHECKING_FEATURE_ID, true);

+        preparser.setErrorHandler(this);

+        try {

+            Grammar g = preparser.preparseGrammar(XMLGrammarDescription.XML_SCHEMA, new XMLInputSource(null, null, null, new StringReader(schema.schema), null));

+        } catch (IOException ex) {

+            throw new InvalidDataException("Error parsing schema: "+ex.getMessage(), "");

+        }

+

+		if (errors.length() > 0) {

+            throw new InvalidDataException("Schema error: \n"+errors.toString(), "");

+		}

+			

+	}

+    

+	public synchronized String validate(Outcome outcome) {

+        if (outcome == null) return "Outcome object was null";

+        Logger.msg(5, "Validating outcome no "+outcome.getID()+" as "+schema.docType+" v"+schema.docVersion);

+        if (outcome.getSchemaType().equals(schema.docType) 

+                    && outcome.getSchemaVersion() == schema.docVersion) {

+            return validate(outcome.getData());

+        }

+        else

+            return "Outcome type and version did not match schema "+schema.docType;

+    }

+

+    public synchronized String validate(String outcome) {

+        if (outcome == null) return "Outcome String was null";

+        errors = new StringBuffer();

+        try {

+            XMLParserConfiguration parserConfiguration = new IntegratedParserConfiguration(sym, schemaGrammarPool);

+            parserConfiguration.setFeature(NAMESPACES_FEATURE_ID, true);

+            parserConfiguration.setFeature(VALIDATION_FEATURE_ID, true);

+            // now we can still do schema features just in case, 

+            // so long as it's our configuraiton......

+            parserConfiguration.setFeature(SCHEMA_VALIDATION_FEATURE_ID, true);

+            parserConfiguration.setFeature(SCHEMA_FULL_CHECKING_FEATURE_ID, true);

+            DOMParser parser = new DOMParser(parserConfiguration);

+            parser.setErrorHandler(this);

+                

+            parser.parse(new XMLInputSource(null, null, null, new StringReader(outcome), null));

+        } catch (Exception e) {

+            return e.getMessage();

+        }

+        return errors.toString();        

+    } 

+    

+    private void appendError(String level, Exception ex) {

+        errors.append(level);

+        String message = ex.getMessage();

+        if (message == null || message.length()==0)

+            message = ex.getClass().getName();

+        errors.append(message);

+        errors.append("\n");

+    }

+        

+    /**

+     * ErrorHandler for instances

+     */

+    public void error(SAXParseException ex) throws SAXException {

+        appendError("ERROR: ", ex);

+    }

+

+    /**

+     *

+     */

+    public void fatalError(SAXParseException ex) throws SAXException {

+        appendError("FATAL: ", ex);

+    }

+

+    /**

+     *

+     */

+    public void warning(SAXParseException ex) throws SAXException {

+        appendError("WARNING: ", ex);

+    }

+

+    /**

+     * XMLErrorHandler for schema

+     */

+    public void error(String domain, String key, XMLParseException ex)

+        throws XNIException {

+        appendError("ERROR: ", ex);

+    }

+

+    /**

+     *

+     */

+    public void fatalError(String domain, String key, XMLParseException ex)

+        throws XNIException {

+        appendError("FATAL: ", ex);

+    }

+

+    /**

+     *

+     */

+    public void warning(String domain, String key, XMLParseException ex)

+        throws XNIException {

+            appendError("WARNING: ", ex);    

+    }

+

+}

diff --git a/source/com/c2kernel/persistency/outcome/Schema.java b/source/com/c2kernel/persistency/outcome/Schema.java
new file mode 100755
index 0000000..9514ebe
--- /dev/null
+++ b/source/com/c2kernel/persistency/outcome/Schema.java
@@ -0,0 +1,18 @@
+package com.c2kernel.persistency.outcome;

+

+/**

+ * @author Andrew Branson

+ *

+ * $Revision: 1.3 $

+ * $Date: 2006/09/14 14:13:26 $

+ *

+ * Copyright (C) 2003 CERN - European Organization for Nuclear Research

+ * All rights reserved. 

+ */

+

+public class Schema {

+    public String docType;

+	public int docVersion;

+	public boolean breakApart;

+	public String schema;

+	}

diff --git a/source/com/c2kernel/persistency/outcome/SchemaValidator.java b/source/com/c2kernel/persistency/outcome/SchemaValidator.java
new file mode 100755
index 0000000..f2dfa0b
--- /dev/null
+++ b/source/com/c2kernel/persistency/outcome/SchemaValidator.java
@@ -0,0 +1,54 @@
+package com.c2kernel.persistency.outcome;

+

+import java.io.IOException;

+import java.io.StringReader;

+

+import org.exolab.castor.xml.schema.reader.SchemaReader;

+import org.xml.sax.InputSource;

+

+

+/**************************************************************************

+ *

+ * $Revision: 1.2 $

+ * $Date: 2005/04/26 06:48:13 $

+ *

+ * Copyright (C) 2003 CERN - European Organization for Nuclear Research

+ * All rights reserved.

+ **************************************************************************/

+

+

+

+public class SchemaValidator extends OutcomeValidator {

+

+    org.exolab.castor.xml.schema.Schema castorSchema;

+    /**

+     *

+     */

+

+    public SchemaValidator() {

+        

+    }

+

+    public org.exolab.castor.xml.schema.Schema getSOM() {

+        return castorSchema;   

+    }

+

+    /**

+     *

+     */

+

+    public synchronized String validate(String outcome) {

+        errors = new StringBuffer();

+        try {

+            InputSource schemaSource = new InputSource(new StringReader(outcome));

+            SchemaReader mySchemaReader = new SchemaReader(schemaSource);

+            mySchemaReader.setErrorHandler(this);

+            mySchemaReader.setValidation(true);

+            castorSchema = mySchemaReader.read();

+        } catch (IOException e) {

+            errors.append(e.getMessage());

+        }

+        return errors.toString();

+    }

+

+}

diff --git a/source/com/c2kernel/persistency/outcome/Viewpoint.java b/source/com/c2kernel/persistency/outcome/Viewpoint.java
new file mode 100755
index 0000000..7fc2aa5
--- /dev/null
+++ b/source/com/c2kernel/persistency/outcome/Viewpoint.java
@@ -0,0 +1,176 @@
+package com.c2kernel.persistency.outcome;

+

+import com.c2kernel.common.InvalidDataException;

+import com.c2kernel.common.ObjectNotFoundException;

+import com.c2kernel.entity.C2KLocalObject;

+import com.c2kernel.events.Event;

+import com.c2kernel.lookup.Path;

+import com.c2kernel.persistency.ClusterStorage;

+import com.c2kernel.persistency.ClusterStorageException;

+import com.c2kernel.process.Gateway;

+

+/**

+ * @author Andrew Branson

+ *

+ * $Revision: 1.10 $

+ * $Date: 2005/10/05 07:39:36 $

+ *

+ * Copyright (C) 2003 CERN - European Organization for Nuclear Research

+ * All rights reserved. 

+ */

+

+//    public static final String codeRevision =

+//           "$Revision: 1.10 $ $Date: 2005/10/05 07:39:36 $ $Author: abranson $";

+public class Viewpoint implements C2KLocalObject {

+	

+	int ID = -1; // not really used in this

+

+	// db fields

+	int sysKey;

+	String schemaName;

+	String name;

+	int schemaVersion;

+	int eventId;	

+	public static final int NONE = -1;

+	

+	public Viewpoint() {

+		eventId = NONE;

+		sysKey = Path.INVALID;

+		schemaVersion = NONE;

+		schemaName = null;

+		name = null;

+	}

+	

+	public Viewpoint(int sysKey, String schemaName, String name, int schemaVersion, int eventId) {

+		this.sysKey = sysKey;

+		this.schemaName = schemaName;

+		this.name = name;

+		this.schemaVersion = schemaVersion;

+		this.eventId = eventId;

+	}

+

+	public Outcome getOutcome() throws ObjectNotFoundException, ClusterStorageException {

+		if (eventId == NONE) throw new ObjectNotFoundException("No last eventId defined", "");

+		Outcome retVal = (Outcome)Gateway.getStorage().get(sysKey, ClusterStorage.OUTCOME+"/"+schemaName+"/"+schemaVersion+"/"+eventId, null);

+		return retVal;

+	}

+

+	public String getClusterType() {

+		return ClusterStorage.VIEWPOINT;

+	}

+

+

+	/**

+	 * Returns the eventId.

+	 * @return int

+	 */

+	public int getEventId() {

+		return eventId;

+	}

+

+	/**

+	 * Returns the iD.

+	 * @return int

+	 */

+	public int getID() {

+		return ID;

+	}

+

+	/**

+	 * Returns the name.

+	 * @return String

+	 */

+	public String getName() {

+		return name;

+	}

+

+	/**

+	 * Returns the schemaName.

+	 * @return String

+	 */

+	public String getSchemaName() {

+		return schemaName;

+	}

+

+	/**

+	 * Returns the schemaVersion.

+	 * @return int

+	 */

+	public int getSchemaVersion() {

+		return schemaVersion;

+	}

+

+	/**

+	 * Returns the sysKey.

+	 * @return int

+	 */

+	public int getSysKey() {

+		return sysKey;

+	}

+

+	/**

+	 * Sets the eventId.

+	 * @param eventId The eventId to set

+	 */

+	public void setEventId(int eventId) {

+		this.eventId = eventId;

+	}

+

+	/**

+	 * Sets the iD.

+	 * @param iD The iD to set

+	 */

+	public void setID(int iD) {

+		ID = iD;

+	}

+

+	/**

+	 * Sets the name.

+	 * @param name The name to set

+	 */

+	public void setName(String name) {

+		this.name = name;

+	}

+

+	/**

+	 * Sets the schemaName.

+	 * @param schemaName The schemaName to set

+	 */

+	public void setSchemaName(String schemaName) {

+		this.schemaName = schemaName;

+	}

+

+	/**

+	 * Sets the schemaVersion.

+	 * @param schemaVersion The schemaVersion to set

+	 */

+	public void setSchemaVersion(int schemaVersion) {

+		this.schemaVersion = schemaVersion;

+	}

+

+	/**

+	 * Sets the sysKey.

+	 * @param sysKey The sysKey to set

+	 */

+	public void setSysKey(int sysKey) {

+		this.sysKey = sysKey;

+	}

+

+	/**

+	 * Method getEvent.

+	 * @return GDataRecord

+	 */

+	public Event getEvent()

+        throws InvalidDataException, ClusterStorageException, ObjectNotFoundException

+	{

+        if (eventId == NONE)

+            throw new InvalidDataException("No last eventId defined", "");

+

+        return (Event)Gateway.getStorage().get(sysKey, ClusterStorage.HISTORY+"/"+eventId, null);

+	}

+    

+    public String toString() {

+        return name;

+    }

+

+}