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%2FJcrExecutionProcess.java;h=180d8f008f84bc7e7d8644896b4486ade72c7fcb;hb=2ecb1e7ce15a25ba8026b5ded625f36c1be467bd;hp=83b442fbf77c1f6462f88a8e1bfbb1de9e1b69e8;hpb=038f9fd2f7be36befe4427b4a85a55bddb207c4a;p=gpl%2Fargeo-slc.git

diff --git a/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrExecutionProcess.java b/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrExecutionProcess.java
index 83b442fbf..180d8f008 100644
--- a/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrExecutionProcess.java
+++ b/runtime/org.argeo.slc.support.jcr/src/main/java/org/argeo/slc/jcr/execution/JcrExecutionProcess.java
@@ -1,24 +1,47 @@
+/*
+ * Copyright (C) 2007-2012 Argeo GmbH
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *         http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
 package org.argeo.slc.jcr.execution;
 
+import java.util.ArrayList;
 import java.util.Calendar;
 import java.util.GregorianCalendar;
 import java.util.List;
 
 import javax.jcr.Node;
+import javax.jcr.NodeIterator;
+import javax.jcr.Property;
+import javax.jcr.Repository;
 import javax.jcr.RepositoryException;
 
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 import org.argeo.jcr.JcrUtils;
+import org.argeo.slc.NameVersion;
 import org.argeo.slc.SlcException;
+import org.argeo.slc.core.execution.ProcessThread;
 import org.argeo.slc.execution.ExecutionProcess;
 import org.argeo.slc.execution.ExecutionStep;
+import org.argeo.slc.execution.RealizedFlow;
+import org.argeo.slc.jcr.SlcJcrUtils;
 import org.argeo.slc.jcr.SlcNames;
 import org.argeo.slc.jcr.SlcTypes;
 
 /** Execution process implementation based on a JCR node. */
 public class JcrExecutionProcess implements ExecutionProcess, SlcNames {
-	private Log log = LogFactory.getLog(JcrExecutionProcess.class);
+	private final static Log log = LogFactory.getLog(JcrExecutionProcess.class);
 	private final Node node;
 
 	private Long nextLogLine = 1l;
@@ -27,7 +50,7 @@ public class JcrExecutionProcess implements ExecutionProcess, SlcNames {
 		this.node = node;
 	}
 
-	public String getUuid() {
+	public synchronized String getUuid() {
 		try {
 			return node.getProperty(SLC_UUID).getString();
 		} catch (RepositoryException e) {
@@ -35,7 +58,7 @@ public class JcrExecutionProcess implements ExecutionProcess, SlcNames {
 		}
 	}
 
-	public String getStatus() {
+	public synchronized String getStatus() {
 		try {
 			return node.getProperty(SLC_STATUS).getString();
 		} catch (RepositoryException e) {
@@ -47,7 +70,7 @@ public class JcrExecutionProcess implements ExecutionProcess, SlcNames {
 		}
 	}
 
-	public void setStatus(String status) {
+	public synchronized void setStatus(String status) {
 		try {
 			node.setProperty(SLC_STATUS, status);
 			// last modified properties needs to be manually updated
@@ -85,13 +108,13 @@ public class JcrExecutionProcess implements ExecutionProcess, SlcNames {
 					// skip
 					continue steps;
 
-				String relPath = SLC_LOG + '/' + step.getThread() + '/'
+				String relPath = SLC_LOG + '/'
+						+ step.getThread().replace('/', '_') + '/'
 						+ step.getLocation().replace('.', '/');
 				String path = node.getPath() + '/' + relPath;
 				// clean special character
 				// TODO factorize in JcrUtils
-				path = path.replace('@', '_').replace('/', '_')
-						.replace(':', '_');
+				path = path.replace('@', '_');
 
 				Node location = JcrUtils.mkdirs(node.getSession(), path);
 				Node logEntry = location.addNode(Long.toString(nextLogLine),
@@ -117,8 +140,55 @@ public class JcrExecutionProcess implements ExecutionProcess, SlcNames {
 		}
 	}
 
-	public Node getNode() {
-		return node;
+	// public Node getNode() {
+	// return node;
+	// }
+
+	public List<RealizedFlow> getRealizedFlows() {
+		try {
+			List<RealizedFlow> realizedFlows = new ArrayList<RealizedFlow>();
+			Node rootRealizedFlowNode = node.getNode(SLC_FLOW);
+			// we just manage one level for the time being
+			NodeIterator nit = rootRealizedFlowNode.getNodes(SLC_FLOW);
+			while (nit.hasNext()) {
+				Node realizedFlowNode = nit.nextNode();
+
+				if (realizedFlowNode.hasNode(SLC_ADDRESS)) {
+					String flowPath = realizedFlowNode.getNode(SLC_ADDRESS)
+							.getProperty(Property.JCR_PATH).getString();
+					NameVersion moduleNameVersion = SlcJcrUtils
+							.moduleNameVersion(flowPath);
+					((ProcessThread) Thread.currentThread())
+							.getExecutionModulesManager().start(
+									moduleNameVersion);
+				}
+
+				RealizedFlow realizedFlow = new JcrRealizedFlow(
+						realizedFlowNode);
+				if (realizedFlow != null)
+					realizedFlows.add(realizedFlow);
+			}
+			return realizedFlows;
+		} catch (RepositoryException e) {
+			throw new SlcException("Cannot get realized flows", e);
+		}
+	}
+
+	public String getNodePath() {
+		try {
+			return node.getPath();
+		} catch (RepositoryException e) {
+			throw new SlcException("Cannot get process node path for " + node,
+					e);
+		}
 	}
 
+	public Repository getRepository() {
+		try {
+			return node.getSession().getRepository();
+		} catch (RepositoryException e) {
+			throw new SlcException("Cannot get process JCR repository for "
+					+ node, e);
+		}
+	}
 }