summaryrefslogtreecommitdiff
path: root/src/main/java/com/c2kernel/dev/DevObjectOutcomeInitiator.java
diff options
context:
space:
mode:
Diffstat (limited to 'src/main/java/com/c2kernel/dev/DevObjectOutcomeInitiator.java')
-rw-r--r--src/main/java/com/c2kernel/dev/DevObjectOutcomeInitiator.java70
1 files changed, 70 insertions, 0 deletions
diff --git a/src/main/java/com/c2kernel/dev/DevObjectOutcomeInitiator.java b/src/main/java/com/c2kernel/dev/DevObjectOutcomeInitiator.java
new file mode 100644
index 0000000..be0c996
--- /dev/null
+++ b/src/main/java/com/c2kernel/dev/DevObjectOutcomeInitiator.java
@@ -0,0 +1,70 @@
+package com.c2kernel.dev;
+
+import com.c2kernel.common.InvalidDataException;
+import com.c2kernel.entity.agent.Job;
+import com.c2kernel.entity.proxy.ItemProxy;
+import com.c2kernel.lifecycle.ActivityDef;
+import com.c2kernel.lifecycle.CompositeActivityDef;
+import com.c2kernel.lifecycle.instance.stateMachine.StateMachine;
+import com.c2kernel.lookup.DomainPath;
+import com.c2kernel.persistency.outcome.OutcomeInitiator;
+import com.c2kernel.persistency.outcome.Viewpoint;
+import com.c2kernel.process.Gateway;
+import com.c2kernel.utils.DescriptionObject;
+import com.c2kernel.utils.Logger;
+
+public class DevObjectOutcomeInitiator implements OutcomeInitiator {
+
+ public DevObjectOutcomeInitiator() {
+ }
+
+ @Override
+ public String initOutcome(Job job) throws InvalidDataException {
+ String type = job.getActPropString("SchemaType");
+
+ // create empty object for activities and state machine
+ DescriptionObject emptyObj = null;
+ if (type.equals("CompositeActivityDef"))
+ emptyObj = new CompositeActivityDef();
+ else if (type.equals("ElementaryActivityDef"))
+ emptyObj = new ActivityDef();
+ else if (type.equals("StateMachine"))
+ emptyObj = new StateMachine();
+
+ if (emptyObj != null) {
+ try {
+ emptyObj.setName(job.getItemProxy().getName());
+ return Gateway.getMarshaller().marshall(emptyObj);
+ } catch (Exception e) {
+ Logger.error("Error creating empty "+type);
+ Logger.error(e);
+ return null;
+ }
+ }
+
+ // else load empty one from factory
+ DomainPath factoryPath; String schema;
+ if (type.equals("Schema")) {
+ factoryPath = new DomainPath("/desc/dev/SchemaFactory");
+ schema = "Schema";
+ }
+ else if (type.equals("Script")) {
+ factoryPath = new DomainPath("/desc/dev/ScriptFactory");
+ schema = "Script";
+ }
+ else
+ throw new InvalidDataException("Unknown dev object type: "+type, "");
+ ItemProxy factory;
+ Viewpoint newInstance;
+ try {
+ factory = (ItemProxy) Gateway.getProxyManager().getProxy(factoryPath);
+ newInstance = factory.getViewpoint(schema, "last");
+ return newInstance.getOutcome().getData();
+ } catch (Exception e) {
+ Logger.error(e);
+ throw new InvalidDataException("Error loading new "+schema);
+ }
+
+ }
+
+}