Remove children indicator on flows

[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 00e517c5373fbbd1916df553576e3c3a633904e7..490a1c31d26ace5f510bbf30006a9a85ef71b777 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
@@ -18,10 +18,13 @@ 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;
@@ -55,6 +58,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);
@@ -133,11 +138,30 @@ public class JcrExecutionModulesView extends ViewPart implements SlcTypes,
                                throws RepositoryException {
                        for (Iterator<Node> it = children.iterator(); it.hasNext();) {
                                Node node = it.next();
+                               // execution spec definitions
                                if (node.getName().equals(SLC_EXECUTION_SPECS))
                                        it.remove();
+                               // flow values
+                               else if (node.getParent().isNodeType(
+                                               SlcTypes.SLC_EXECUTION_FLOW))
+                                       it.remove();
                        }
                        return super.filterChildren(children);
                }
+
+               @Override
+               public boolean hasChildren(Object element) {
+                       if (element instanceof Node) {
+                               Node node = (Node) element;
+                               try {
+                                       if (node.isNodeType(SlcTypes.SLC_EXECUTION_FLOW))
+                                               return false;
+                               } catch (RepositoryException e) {
+                                       throw new SlcException("Cannot check has children", e);
+                               }
+                       }
+                       return super.hasChildren(element);
+               }
        }
 
        static class ViewComparator implements Comparator<Object> {
@@ -200,6 +224,46 @@ 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();
                }
@@ -232,9 +296,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;
@@ -273,6 +340,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) {
@@ -322,4 +402,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