Start / stop modules

[gpl/argeo-slc.git] / eclipse / plugins / org.argeo.slc.client.ui / src / main / java / org / argeo / slc / client / ui / views / JcrExecutionModulesView.java

diff --git a/eclipse/plugins/org.argeo.slc.client.ui/src/main/java/org/argeo/slc/client/ui/views/JcrExecutionModulesView.java b/eclipse/plugins/org.argeo.slc.client.ui/src/main/java/org/argeo/slc/client/ui/views/JcrExecutionModulesView.java
index d87be4f29f90cfab9f9a8fcf52218fd6dfe16963..5cb83c1523e39b261394b7769eb69d6301786876 100644 (file)
--- a/eclipse/plugins/org.argeo.slc.client.ui/src/main/java/org/argeo/slc/client/ui/views/JcrExecutionModulesView.java
+++ b/eclipse/plugins/org.argeo.slc.client.ui/src/main/java/org/argeo/slc/client/ui/views/JcrExecutionModulesView.java
@@ -14,17 +14,23 @@ import javax.jcr.nodetype.NodeType;
 import javax.jcr.observation.Event;
 import javax.jcr.observation.EventIterator;
 
+import org.apache.commons.logging.Log;
+import org.apache.commons.logging.LogFactory;
 import org.argeo.ArgeoException;
 import org.argeo.eclipse.ui.jcr.AsyncUiEventListener;
 import org.argeo.eclipse.ui.jcr.DefaultNodeLabelProvider;
 import org.argeo.eclipse.ui.jcr.SimpleNodeContentProvider;
+import org.argeo.slc.BasicNameVersion;
+import org.argeo.slc.NameVersion;
 import org.argeo.slc.SlcException;
 import org.argeo.slc.client.ui.SlcImages;
 import org.argeo.slc.client.ui.editors.ProcessEditor;
 import org.argeo.slc.client.ui.editors.ProcessEditorInput;
+import org.argeo.slc.execution.ExecutionModulesManager;
 import org.argeo.slc.jcr.SlcJcrConstants;
 import org.argeo.slc.jcr.SlcNames;
 import org.argeo.slc.jcr.SlcTypes;
+import org.eclipse.jface.fieldassist.SimpleContentProposalProvider;
 import org.eclipse.jface.viewers.ColumnViewerToolTipSupport;
 import org.eclipse.jface.viewers.DoubleClickEvent;
 import org.eclipse.jface.viewers.IDoubleClickListener;
@@ -46,8 +52,8 @@ import org.eclipse.ui.part.ViewPart;
 /** JCR based view of the execution modules. */
 public class JcrExecutionModulesView extends ViewPart implements SlcTypes,
                SlcNames {
-       // private final static Log log = LogFactory
-       // .getLog(JcrExecutionModulesView.class);
+       private final static Log log = LogFactory
+                       .getLog(JcrExecutionModulesView.class);
 
        public static final String ID = "org.argeo.slc.client.ui.jcrExecutionModulesView";
 
@@ -55,6 +61,8 @@ public class JcrExecutionModulesView extends ViewPart implements SlcTypes,
 
        private Session session;
 
+       private ExecutionModulesManager modulesManager;
+
        public void createPartControl(Composite parent) {
                viewer = new TreeViewer(parent, SWT.MULTI | SWT.H_SCROLL | SWT.V_SCROLL);
                ColumnViewerToolTipSupport.enableFor(viewer);
@@ -66,6 +74,7 @@ public class JcrExecutionModulesView extends ViewPart implements SlcTypes,
                viewer.setLabelProvider(viewLabelProvider);
                viewer.setInput(getViewSite());
                viewer.addDoubleClickListener(new ViewDoubleClickListener());
+               getViewSite().setSelectionProvider(viewer);
 
                Transfer[] tt = new Transfer[] { TextTransfer.getInstance() };
                // Transfer[] tt = new Transfer[] { EditorInputTransfer.getInstance() };
@@ -199,6 +208,47 @@ public class JcrExecutionModulesView extends ViewPart implements SlcTypes,
 
        class VmAgentObserver extends AsyncUiEventListener {
                protected void onEventInUiThread(EventIterator events) {
+//                     List<Node> baseNodes = ((SimpleNodeContentProvider) viewer
+//                                     .getContentProvider()).getBaseNodes();
+//                     Node baseNode = baseNodes.get(0);
+//
+//                     while (events.hasNext()) {
+//                             Event event = events.nextEvent();
+//                             try {
+//                                     String path = event.getPath();
+//                                     String baseNodePath = baseNode.getPath();
+//                                     if (path.startsWith(baseNodePath)) {
+//                                             String relPath = path
+//                                                             .substring(baseNodePath.length() + 1);
+//                                             log.debug("relPath: " + relPath);
+//                                             if (baseNode.hasNode(relPath)) {
+//                                                     Node refreshNode = baseNode.getNode(relPath);
+//                                                     log.debug("refreshNode: " + refreshNode);
+//                                                     viewer.refresh(refreshNode);
+//                                             }
+//
+//                                     }
+//                                     // if (log.isDebugEnabled())
+//                                     // log.debug("Process " + path + ": " + event);
+//
+//                                     // if (session.itemExists(path)) {
+//                                     // Node parentNode = session.getNode(path).getParent();
+//                                     // log.debug("Parent: " + parentNode);
+//                                     // viewer.refresh(parentNode);
+//                                     // }
+//                             } catch (RepositoryException e) {
+//                                     log.warn("Cannot process event " + event + ": " + e);
+//                             }
+//                     }
+
+                       // try {
+                       // Node vmAgentNode = session
+                       // .getNode(SlcJcrConstants.VM_AGENT_FACTORY_PATH);
+                       // viewer.refresh(vmAgentNode);
+                       // } catch (RepositoryException e) {
+                       // log.warn("Cannot process event : " + e);
+                       // }
+                       // TODO: optimize based on event
                        viewer.refresh();
                }
        }
@@ -230,9 +280,12 @@ public class JcrExecutionModulesView extends ViewPart implements SlcTypes,
                                return SlcImages.EXECUTION_SPECS;
                        else if (node.isNodeType(SlcTypes.SLC_EXECUTION_FLOW))
                                return SlcImages.FLOW;
-                       else if (node.isNodeType(SlcTypes.SLC_MODULE))
-                               return SlcImages.MODULE;
-                       else if (node.isNodeType(SlcTypes.SLC_AGENT))
+                       else if (node.isNodeType(SlcTypes.SLC_MODULE)) {
+                               if (node.getProperty(SLC_STARTED).getBoolean())
+                                       return SlcImages.MODULE;
+                               else
+                                       return SlcImages.MODULE_STOPPED;
+                       } else if (node.isNodeType(SlcTypes.SLC_AGENT))
                                return SlcImages.AGENT;
                        else if (node.isNodeType(SlcTypes.SLC_AGENT_FACTORY))
                                return SlcImages.AGENT_FACTORY;
@@ -271,6 +324,19 @@ public class JcrExecutionModulesView extends ViewPart implements SlcTypes,
                                                                .getActiveWorkbenchWindow().getActivePage();
                                                activePage.openEditor(new ProcessEditorInput(paths,
                                                                true), ProcessEditor.ID);
+                                       } else if (node.isNodeType(SLC_EXECUTION_MODULE)) {
+                                               String name = node.getProperty(SLC_NAME).getString();
+                                               String version = node.getProperty(SLC_VERSION)
+                                                               .getString();
+                                               NameVersion nameVersion = new BasicNameVersion(name,
+                                                               version);
+                                               Boolean started = node.getProperty(SLC_STARTED)
+                                                               .getBoolean();
+                                               if (started) {
+                                                       modulesManager.stop(nameVersion);
+                                               } else {
+                                                       modulesManager.start(nameVersion);
+                                               }
                                        }
                                }
                        } catch (Exception e) {
@@ -320,4 +386,8 @@ public class JcrExecutionModulesView extends ViewPart implements SlcTypes,
                this.session = session;
        }
 
+       public void setModulesManager(ExecutionModulesManager modulesManager) {
+               this.modulesManager = modulesManager;
+       }
+
 }
\ No newline at end of file