From d43164830403245353080f5d6f838ed9f56d9a35 Mon Sep 17 00:00:00 2001
From: Andrew Branson <andrew.branson@cern.ch>
Date: Mon, 18 Nov 2013 09:48:03 +0100
Subject: 3.0-SNAPSHOT (Will be first open source version) New StateMachine
 desc IssueID #28

---
 src/main/java/com/c2kernel/entity/proxy/AgentProxy.java | 17 +++++++----------
 1 file changed, 7 insertions(+), 10 deletions(-)

(limited to 'src/main/java/com/c2kernel/entity/proxy/AgentProxy.java')

diff --git a/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java b/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java
index 24172dc..3569421 100644
--- a/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java
+++ b/src/main/java/com/c2kernel/entity/proxy/AgentProxy.java
@@ -25,7 +25,6 @@ import com.c2kernel.entity.C2KLocalObject;
 import com.c2kernel.entity.ManageableEntity;
 import com.c2kernel.entity.agent.Job;
 import com.c2kernel.lifecycle.instance.predefined.PredefinedStep;
-import com.c2kernel.lifecycle.instance.stateMachine.Transitions;
 import com.c2kernel.lookup.AgentPath;
 import com.c2kernel.lookup.DomainPath;
 import com.c2kernel.lookup.EntityPath;
@@ -111,14 +110,13 @@ public class AgentProxy extends EntityProxy
         ScriptErrorException
     {
         OutcomeValidator validator = null;
-        String scriptName = job.getActPropString("ScriptName");
         Date startTime = new Date();
         Logger.msg(3, "AgentProxy - executing "+job.getStepPath()+" for "+path.getAgentName());
         // get the outcome validator if present
-        if (job.requiresOutcome() || job.isError())
+        if (job.hasOutcome())
         {
-        	String schemaName = job.isError()?"Errors":job.getSchemaType();
-        	int schemaVersion = job.isError()?0:job.getSchemaVersion();
+        	String schemaName = job.getSchemaName();
+        	int schemaVersion = job.getSchemaVersion();
 
             Logger.msg(5, "AgentProxy - fetching schema "+schemaName+"_"+schemaVersion+" for validation");
             // retrieve schema
@@ -134,9 +132,8 @@ public class AgentProxy extends EntityProxy
             }
         }
 
-        if(scriptName != null && scriptName.length() > 0 &&
-            (job.getPossibleTransition() == Transitions.DONE || job.getPossibleTransition() == Transitions.COMPLETE)) {
-            Logger.msg(3, "AgentProxy - executing script "+scriptName);
+        if(job.hasScript()) {
+            Logger.msg(3, "AgentProxy - executing script "+job.getScriptName()+" v"+job.getScriptVersion());
             try {
 
                 // pre-validate outcome from script if there is one
@@ -151,7 +148,6 @@ public class AgentProxy extends EntityProxy
 
                 // load script
                 ErrorInfo scriptErrors = (ErrorInfo)callScript(item, job);
-
                 String errorString = scriptErrors.toString();
                 if (scriptErrors.getFatal()) {
                     Logger.msg(3, "AgentProxy - fatal script error");
@@ -171,6 +167,7 @@ public class AgentProxy extends EntityProxy
             if (error.length() > 0)
                 throw new InvalidDataException(error, "");
         }
+        else if (job.isOutcomeRequired())
 
         job.setAgentId(getSystemKey());
         Logger.msg(3, "AgentProxy - submitting job to item proxy");
@@ -243,7 +240,7 @@ public class AgentProxy extends EntityProxy
            PersistencyException,
            ObjectAlreadyExistsException
     {
-        item.requestAction(getSystemKey(), "workflow/predefined/"+predefStep, Transitions.DONE, PredefinedStep.bundleData(params));
+        item.requestAction(getSystemKey(), "workflow/predefined/"+predefStep, PredefinedStep.DONE, PredefinedStep.bundleData(params));
     }
 
     /** Wrappers for scripts */
-- 
cgit v1.2.3