ExecutionContext transformed to interface; mapping from ExecutionContexts to Threads...

[gpl/argeo-slc.git] / runtime / org.argeo.slc.support.simple / src / main / java / org / argeo / slc / core / execution / DefaultModulesManager.java

diff --git a/runtime/org.argeo.slc.support.simple/src/main/java/org/argeo/slc/core/execution/DefaultModulesManager.java b/runtime/org.argeo.slc.support.simple/src/main/java/org/argeo/slc/core/execution/DefaultModulesManager.java
index 5daa5822b2d09f5889ec4627f298b2c990399693..9bb6aae6442b6247e1a9daf9a9bb67825145e67a 100644 (file)
--- a/runtime/org.argeo.slc.support.simple/src/main/java/org/argeo/slc/core/execution/DefaultModulesManager.java
+++ b/runtime/org.argeo.slc.support.simple/src/main/java/org/argeo/slc/core/execution/DefaultModulesManager.java
@@ -1,13 +1,20 @@
 package org.argeo.slc.core.execution;
 
 import java.util.ArrayList;
+import java.util.HashMap;
 import java.util.List;
+import java.util.Map;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
+import org.argeo.slc.SlcException;
+import org.argeo.slc.execution.ExecutionContext;
+import org.argeo.slc.execution.ExecutionFlow;
+import org.argeo.slc.execution.ExecutionFlowDescriptor;
 import org.argeo.slc.execution.ExecutionModule;
 import org.argeo.slc.execution.ExecutionModuleDescriptor;
 import org.argeo.slc.execution.ExecutionModulesManager;
+import org.argeo.slc.process.RealizedFlow;
 import org.argeo.slc.process.SlcExecution;
 import org.springframework.util.Assert;
 
@@ -16,18 +23,22 @@ public class DefaultModulesManager implements ExecutionModulesManager {
                        .getLog(DefaultModulesManager.class);
 
        private List<ExecutionModule> executionModules = new ArrayList<ExecutionModule>();
-
-       public ExecutionModuleDescriptor getExecutionModuleDescriptor(
-                       String moduleName, String version) {
-               ExecutionModule module = null;
+       
+       protected ExecutionModule getExecutionModule(String moduleName, String version) {
                for (ExecutionModule moduleT : executionModules) {
                        if (moduleT.getName().equals(moduleName)) {
-                               // TODO: check version
-                               module = moduleT;
-                               break;
+                               if(moduleT.getVersion().equals(version)) {
+                                       return moduleT;
+                               }
                        }
                }
-
+               return null;
+       }
+       
+       public ExecutionModuleDescriptor getExecutionModuleDescriptor(
+                       String moduleName, String version) {
+               ExecutionModule module = getExecutionModule(moduleName, version);
+               
                Assert.notNull(module);
 
                return module.getDescriptor();
@@ -41,9 +52,67 @@ public class DefaultModulesManager implements ExecutionModulesManager {
                this.executionModules = executionModules;
        }
 
+       protected Map<String, Object> convertValues(ExecutionFlowDescriptor executionFlowDescriptor) {
+               // convert the values of flow.getFlowDescriptor()
+               Map<String, Object> values = executionFlowDescriptor.getValues();
+               
+               Map<String, Object> convertedValues = new HashMap<String, Object>();
+               
+               for(String key : values.keySet()) {
+                       Object value = values.get(key);
+                       if(value instanceof PrimitiveValue) {
+                               PrimitiveValue primitiveValue = (PrimitiveValue) value;
+
+                               // TODO: check that the class of the the primitiveValue.value matches
+                               // the primitiveValue.type
+                               convertedValues.put(key, primitiveValue.getValue());
+                       }
+                       else if(value instanceof RefValue) {
+                               RefValue refValue = (RefValue) value;
+                               convertedValues.put(key, refValue.getLabel());
+                       }
+               }               
+               return convertedValues;
+       }
+       
        public void process(SlcExecution slcExecution) {
-               log.info("SlcExecution " + slcExecution);
+               log.info("##\n## Process SLC Execution " + slcExecution+"\n##");
 
+               for(RealizedFlow flow : slcExecution.getRealizedFlows()) {
+                       ExecutionModule module = getExecutionModule(flow.getModuleName(),
+                                       flow.getModuleVersion());
+                       if(module != null) {
+                               ExecutionThread thread = new ExecutionThread(flow.getFlowDescriptor(), module);
+                               thread.start();
+                       }
+                       else {
+                               throw new SlcException("ExecutionModule " + flow.getModuleName() + ", version " 
+                                               + flow.getModuleVersion() + " not found.");
+                       }
+               }
        }
 
+       private class ExecutionThread extends Thread {
+               private final ExecutionFlowDescriptor executionFlowDescriptor;
+               private final ExecutionModule executionModule;
+
+               public ExecutionThread(ExecutionFlowDescriptor executionFlowDescriptor,
+                               ExecutionModule executionModule) {
+                       super("SLC Execution #" /*+ executionContext.getUuid()*/);
+                       this.executionFlowDescriptor = executionFlowDescriptor;
+                       this.executionModule = executionModule;
+               }
+
+               public void run() {
+                       ExecutionContext executionContext = executionModule.getExecutionContext();
+                       executionContext.addVariables(convertValues(executionFlowDescriptor));
+                       try {
+                               executionModule.execute(executionFlowDescriptor);
+                       } catch (Exception e) {
+                               //TODO: re-throw exception ?
+                               log.error("Execution " + executionContext.getUuid()
+                                               + " failed.", e);
+                       }
+               }
+       }               
 }