From f09e07e3314bb9c0cb7a6da7055ecb01da3ed722 Mon Sep 17 00:00:00 2001
From: Andrew Branson <andrew.branson@cern.ch>
Date: Fri, 11 Apr 2014 17:03:38 +0200
Subject: OutcomeInitiator based description initialization. Absorbs all
 description editing from the kernel. Module.debug functionality missing -
 kernel now creates all imported module descriptions with NoWorkflow. Need a
 way to patch them in later (must be part of this module)

---
 .../c2kernel/dev/DevObjectOutcomeInitiator.java    | 70 ++++++++++++++++++++++
 1 file changed, 70 insertions(+)
 create mode 100644 src/main/java/com/c2kernel/dev/DevObjectOutcomeInitiator.java

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

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);
+		}
+			
+	}
+
+}
-- 
cgit v1.2.3