X-Git-Url: http://git.argeo.org/?a=blobdiff_plain;f=runtime%2Forg.argeo.slc.support.jcr%2Fsrc%2Fmain%2Fjava%2Forg%2Fargeo%2Fslc%2Fjcr%2Fexecution%2FJcrExecutionModulesListener.java;h=8d6d96784ab64562ea0e2e78b3647d01c9188b3e;hb=699640c58cc0578beebfc3edd00dac9eed65ee0b;hp=d108e9dd5b3d6cb7bf3710bbc3681dd4bef0a018;hpb=74904a755b5b344238eafa798419b80c5e74f7ed;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrExecutionModulesListener.java b/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrExecutionModulesListener.java
index d108e9dd5..8d6d96784 100644
--- a/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrExecutionModulesListener.java
+++ b/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrExecutionModulesListener.java
@@ -29,7 +29,6 @@ import javax.jcr.nodetype.NodeType;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
-import org.argeo.jcr.ArgeoNames;
 import org.argeo.jcr.JcrUtils;
 import org.argeo.slc.SlcException;
 import org.argeo.slc.core.execution.PrimitiveSpecAttribute;
@@ -38,6 +37,7 @@ import org.argeo.slc.core.execution.RefSpecAttribute;
 import org.argeo.slc.core.execution.RefValueChoice;
 import org.argeo.slc.deploy.ModuleDescriptor;
 import org.argeo.slc.execution.ExecutionFlowDescriptor;
+import org.argeo.slc.execution.ExecutionModuleDescriptor;
 import org.argeo.slc.execution.ExecutionModulesListener;
 import org.argeo.slc.execution.ExecutionModulesManager;
 import org.argeo.slc.execution.ExecutionSpec;
@@ -76,38 +76,62 @@ public class JcrExecutionModulesListener implements ExecutionModulesListener,
 			session = repository.login();
 			clearAgent();
 			if (modulesManager != null) {
+				Node agentNode = session.getNode(agent.getNodePath());
+
 				List<ModuleDescriptor> moduleDescriptors = modulesManager
 						.listModules();
+
+				// scan SLC-ExecutionModule metadata
+				for (ModuleDescriptor md : moduleDescriptors) {
+					if (md.getMetadata().containsKey(
+							ExecutionModuleDescriptor.SLC_EXECUTION_MODULE)) {
+						String moduleNodeName = SlcJcrUtils
+								.getModuleNodeName(md);
+						Node moduleNode = agentNode.hasNode(moduleNodeName) ? agentNode
+								.getNode(moduleNodeName) : agentNode
+								.addNode(moduleNodeName);
+						moduleNode.addMixin(SlcTypes.SLC_EXECUTION_MODULE);
+						moduleNode.setProperty(SLC_NAME, md.getName());
+						moduleNode.setProperty(SLC_VERSION, md.getVersion());
+						moduleNode.setProperty(Property.JCR_TITLE,
+								md.getTitle());
+						moduleNode.setProperty(Property.JCR_DESCRIPTION,
+								md.getDescription());
+						moduleNode.setProperty(SLC_STARTED, md.getStarted());
+					}
+				}
+
+				// scan execution modules property
 				String executionModules = System
 						.getProperty(SLC_EXECUTION_MODULES_PROPERTY);
 				if (executionModules != null) {
-					Node agentNode = session.getNode(agent.getNodePath());
 					for (String executionModule : executionModules.split(",")) {
-						allModules: for (ModuleDescriptor moduleDescriptor : moduleDescriptors) {
+						allModules: for (ModuleDescriptor md : moduleDescriptors) {
 							String moduleNodeName = SlcJcrUtils
-									.getModuleNodeName(moduleDescriptor);
-							if (moduleDescriptor.getName().equals(
-									executionModule)) {
+									.getModuleNodeName(md);
+							if (md.getName().equals(executionModule)) {
 								Node moduleNode = agentNode
 										.hasNode(moduleNodeName) ? agentNode
 										.getNode(moduleNodeName) : agentNode
 										.addNode(moduleNodeName);
 								moduleNode
 										.addMixin(SlcTypes.SLC_EXECUTION_MODULE);
-								moduleNode.setProperty(SLC_NAME,
-										moduleDescriptor.getName());
+								moduleNode.setProperty(SLC_NAME, md.getName());
 								moduleNode.setProperty(SLC_VERSION,
-										moduleDescriptor.getVersion());
+										md.getVersion());
 								moduleNode.setProperty(Property.JCR_TITLE,
-										moduleDescriptor.getTitle());
+										md.getTitle());
 								moduleNode.setProperty(
 										Property.JCR_DESCRIPTION,
-										moduleDescriptor.getDescription());
-								moduleNode.setProperty(SLC_STARTED, false);
+										md.getDescription());
+								moduleNode.setProperty(SLC_STARTED,
+										md.getStarted());
 								break allModules;
 							}
 						}
 					}
+
+					// save if needed
 					if (session.hasPendingChanges())
 						session.save();
 				}