--- /dev/null
+/**\r
+ * The selector view\r
+ * \r
+ */\r
+qx.Class.define("org.argeo.slc.ria.FlowsSelectorView", {\r
+ extend : qx.ui.container.Composite,\r
+ implement : [org.argeo.ria.components.IView],\r
+\r
+ construct : function() {\r
+ this.base(arguments);\r
+ this.setLayout(new qx.ui.layout.Dock());\r
+ },\r
+\r
+ properties : {\r
+ /**\r
+ * The viewPane inside which this applet is added.\r
+ */\r
+ view : {\r
+ init : null\r
+ },\r
+ viewSelection : {\r
+ nullable : false,\r
+ check : "org.argeo.ria.components.ViewSelection"\r
+ },\r
+ instanceId : {\r
+ init : ""\r
+ },\r
+ instanceLabel : {\r
+ init : ""\r
+ },\r
+ /**\r
+ * Commands definition, see\r
+ * {@link org.argeo.ria.event.CommandsManager#definitions}\r
+ */\r
+ commands : {\r
+ init : {\r
+ "addtobatch" : {\r
+ label : "Add to batch",\r
+ icon : "resource/slc/list-add.png",\r
+ shortcut : null,\r
+ enabled : true,\r
+ menu : null,\r
+ toolbar : null,\r
+ callback : function(e) {\r
+ if (this.tree.isSelectionEmpty()) {\r
+ return;\r
+ }\r
+ var batchView = org.argeo.ria.components.ViewsManager.getInstance().getViewPaneById("batch").getContent();\r
+ if(!batchView) return;\r
+ selection = this.tree.getSelection();\r
+ if (selection.length > 1) {\r
+ for (var i = 0; i < selection.length; i++) {\r
+ try{\r
+ batchView.addFlowToBatch(selection[i], null, true);\r
+ }catch(e){\r
+ return;\r
+ }\r
+ }\r
+ return;\r
+ } else {\r
+ try{\r
+ batchView.addFlowToBatch(selection[0], null);\r
+ }catch(e){\r
+ return;\r
+ }\r
+ }\r
+ },\r
+ selectionChange : function(viewId, selection) {\r
+ if (viewId != "form:tree")\r
+ return;\r
+ if (!selection || selection.length != 1)\r
+ return;\r
+ var item = selection[0];\r
+ this.setEnabled(false);\r
+ switch (item.classname) {\r
+ case "qx.ui.tree.TreeFile" :\r
+ this.setEnabled(true);\r
+ break;\r
+ case "qx.ui.tree.TreeFolder" :\r
+ if (item.getTree().getRoot() == item)\r
+ break;\r
+ this.setEnabled(true);\r
+ break;\r
+ case "org.argeo.ria.components.DynamicTreeFolder" :\r
+ if (item.getTree().getRoot() == item)\r
+ break; \r
+ if (item.getState() == "loaded")\r
+ this.setEnabled(true);\r
+ break;\r
+ }\r
+ },\r
+ command : null\r
+ },\r
+ "reloadtree" : {\r
+ label : "Reload",\r
+ icon : "resource/slc/view-refresh.png",\r
+ shortcut : "Control+m",\r
+ enabled : false,\r
+ menu : "Launcher",\r
+ toolbar : "launcher",\r
+ callback : function(e) {\r
+ if (this.tree.isSelectionEmpty()) { return; } \r
+ var selected = this.tree.getSelection()[0];\r
+ if (selected.classname == "org.argeo.ria.components.DynamicTreeFolder") {\r
+ if (selected.getUserData("moduleData")) {\r
+ // It's a "module" node, first trigger the\r
+ // reloadBundle.service\r
+ selected.setUserData("dataModel", {});\r
+ selected.setEnabled(false);\r
+ selected.setOpen(false);\r
+ var moduleData = selected\r
+ .getUserData("moduleData");\r
+ var bundleService = org.argeo.slc.ria.SlcApi\r
+ .getReloadBundleService(\r
+ moduleData.name,\r
+ moduleData.version);\r
+ bundleService.addListener("completed",\r
+ function(response) {\r
+ selected.setEnabled(true);\r
+ selected.setOpen(true);\r
+ selected.reload();\r
+ }, this);\r
+ // bundleService.send();\r
+ // Do not send, not implemented yet, false timer\r
+ // instead.\r
+ qx.event.Timer.once(function(response) {\r
+ selected.setEnabled(true);\r
+ selected.setOpen(true);\r
+ selected.reload();\r
+ }, this, 2000);\r
+ } else {\r
+ selected.reload();\r
+ }\r
+ }\r
+ },\r
+ selectionChange : function(viewId, selection) {\r
+ if (viewId != "form:tree")\r
+ return;\r
+ if (!selection)\r
+ return;\r
+ if (selection.length > 1) {\r
+ this.setEnabled(false);\r
+ return;\r
+ }\r
+ var item = selection[0];\r
+ if (!qx.Class.isSubClassOf(qx.Class\r
+ .getByName(item.classname),\r
+ qx.ui.tree.AbstractTreeItem))\r
+ return;\r
+ this.setEnabled(false);\r
+ if (qx.Class.isSubClassOf(qx.Class\r
+ .getByName(item.classname),\r
+ org.argeo.ria.components.DynamicTreeFolder)) {\r
+ this.setEnabled(true);\r
+ }\r
+ },\r
+ command : null\r
+ }\r
+ }\r
+ }\r
+ },\r
+\r
+ statics : {\r
+ /**\r
+ * Static loader for the "agent" level (first level)\r
+ * \r
+ * @param folder\r
+ * {qx.ui.tree.TreeFolder} The root Tree Folder.\r
+ */\r
+ agentLoader : function(folder) {\r
+\r
+ var req = org.argeo.slc.ria.SlcApi.getListAgentsService("agents"); \r
+ var agents = {};\r
+ if(folder.getState() == "loaded" && folder.getUserData("agentsMap")){\r
+ // Diff loading, just add new nodes.\r
+ agents = folder.getUserData("agentsMap");\r
+ var newAgents = {};\r
+ }\r
+ req.addListener("completed", function(response) {\r
+ var xmlDoc = response.getContent();\r
+ var nodes = org.argeo.ria.util.Element.selectNodes(xmlDoc,\r
+ "//slc:slc-agent-descriptor");\r
+ var modulesLoader = org.argeo.slc.ria.FlowsSelectorView.modulesLoader;\r
+ \r
+ for (var i = 0; i < nodes.length; i++) {\r
+ var uuid = org.argeo.ria.util.Element.getSingleNodeText(\r
+ nodes[i], "@uuid");\r
+ if(agents[uuid]){\r
+ newAgents[uuid] = host;\r
+ continue;\r
+ }\r
+ var host = org.argeo.ria.util.Element.getSingleNodeText(nodes[i], "slc:host");\r
+ agents[uuid] = host;\r
+ if(newAgents) newAgents[uuid] = host;\r
+ var agentFolder = new org.argeo.ria.components.DynamicTreeFolder(\r
+ host + ' (' + uuid + ')', modulesLoader,\r
+ "Loading Modules...", folder.getDragData());\r
+ agentFolder.setUserData("agentUuid", uuid);\r
+ agentFolder.setIcon("resource/slc/mime-xsl-22.png");\r
+ folder.add(agentFolder);\r
+ }\r
+ if(newAgents){\r
+ // Make sure some agents should not be removed\r
+ for(var agentKey in agents){\r
+ if(!newAgents[agentKey]){\r
+ var node = org.argeo.slc.ria.FlowsSelectorView.findAgentNodeById(folder, agentKey);\r
+ if(node) folder.remove(node);\r
+ delete agents[agentKey];\r
+ var batchView = org.argeo.ria.components.ViewsManager.getInstance().getViewPaneById("batch").getContent();\r
+ if(batchView) batchView.clearBatchForAgentId(agentKey);\r
+ }\r
+ }\r
+ }\r
+ folder.setUserData("agentsMap", agents);\r
+ folder.setLoaded(true);\r
+ folder.getTree().fireEvent("changeSelection"); \r
+ });\r
+ req.addListener("failed", function(response) {\r
+ folder.setLoaded(true);\r
+ });\r
+ req.send();\r
+\r
+ },\r
+\r
+ /**\r
+ * Loader for the "modules" level : takes any tree folder, currently the\r
+ * root folder.\r
+ * \r
+ * @param folder\r
+ * {qx.ui.tree.TreeFolder} The root folder\r
+ */\r
+ modulesLoader : function(folder) {\r
+ var agentId = folder.getUserData("agentUuid");\r
+ var req = org.argeo.slc.ria.SlcApi.getListModulesService(agentId);\r
+ req.addListener("completed", function(response) {\r
+ var descriptors = org.argeo.ria.util.Element.selectNodes(\r
+ response.getContent(),\r
+ "slc:object-list/slc:execution-module-descriptor");\r
+ var mods = {};\r
+ for (var i = 0; i < descriptors.length; i++) {\r
+ var name = org.argeo.ria.util.Element.getSingleNodeText(\r
+ descriptors[i], "slc:name");\r
+ var version = org.argeo.ria.util.Element.getSingleNodeText(\r
+ descriptors[i], "slc:version");\r
+ if (!mods[name])\r
+ mods[name] = [];\r
+ mods[name].push(version);\r
+ }\r
+ var flowLoader = org.argeo.slc.ria.FlowsSelectorView.flowLoader;\r
+ for (var key in mods) {\r
+ for (var i = 0; i < mods[key].length; i++) {\r
+ var versionFolder = new org.argeo.ria.components.DynamicTreeFolder(\r
+ key + ' (' + mods[key][i] + ')', flowLoader,\r
+ "Loading Flows", folder.getDragData());\r
+ folder.add(versionFolder);\r
+ versionFolder.setUserData("moduleData", {\r
+ name : key,\r
+ version : mods[key][i]\r
+ });\r
+ versionFolder.setUserData("agentUuid", agentId);\r
+ }\r
+ }\r
+ folder.setLoaded(true);\r
+ folder.getTree().fireEvent("changeSelection");\r
+ });\r
+ req.addListener("failed", function(response) {\r
+ folder.setLoaded(true);\r
+ });\r
+ req.send();\r
+ },\r
+\r
+ /**\r
+ * Loader for the "flow" level : takes a folder containing "moduleData"\r
+ * and create its children.\r
+ * \r
+ * @param folder\r
+ * {qx.ui.tree.TreeFolder} A Tree folder containing in the\r
+ * key "moduleData" of its user data a map containing the\r
+ * keys {name,version}\r
+ */\r
+ flowLoader : function(folder) {\r
+ var moduleData = folder.getUserData("moduleData");\r
+ var agentUuid = folder.getUserData("agentUuid");\r
+\r
+ var req = org.argeo.slc.ria.SlcApi\r
+ .getLoadExecutionDescriptorService(agentUuid,\r
+ moduleData.name, moduleData.version);\r
+ req.addListener("completed", function(response) {\r
+ var executionModule = new org.argeo.slc.ria.execution.Module();\r
+ try {\r
+ executionModule.setXmlNode(response.getContent());\r
+ } catch (e) {\r
+ this.error(e);\r
+ }\r
+ var execFlows = executionModule.getExecutionFlows();\r
+ for (var key in execFlows) {\r
+ var file = new qx.ui.tree.TreeFile(key);\r
+ var path = execFlows[key].getPath();\r
+ file.setUserData("executionModule", executionModule);\r
+ file.setUserData("executionFlow", execFlows[key]);\r
+ file.setUserData("agentUuid", agentUuid);\r
+ org.argeo.slc.ria.FlowsSelectorView.attachNodeByPath(folder, path, file, {\r
+ agentUuid : folder.getUserData("agentUuid")\r
+ });\r
+ folder.appendDragData(file);\r
+ }\r
+ folder.setLoaded(true);\r
+ folder.getTree().fireEvent("changeSelection");\r
+ });\r
+ req.addListener("failed", function(response) {\r
+ folder.setLoaded(true);\r
+ });\r
+ req.send();\r
+ },\r
+\r
+ /**\r
+ * Parse a string path and search if there is a root node.\r
+ * \r
+ * @param rootNode\r
+ * {org.argeo.ria.components.DynamicTreeFolder} The parent\r
+ * node (containing data model)\r
+ * @param path\r
+ * {String} The path of the node to attach.\r
+ * @param childNode\r
+ * {qx.ui.tree.TreeFile} The leaf node\r
+ * @param userData\r
+ * {Map} User data to attach at all levels.\r
+ */\r
+ attachNodeByPath : function(rootNode, path, childNode, userData) {\r
+ if (!path || path == "" || path == "/") {\r
+ rootNode.add(childNode);\r
+ return;\r
+ }\r
+ var model = rootNode.getUserData("dataModel");\r
+ if (!model) {\r
+ model = {};\r
+ rootNode.setUserData("dataModel", model);\r
+ }\r
+ var parts = path.split("/");\r
+ var keys = qx.lang.Object.getKeys(model);\r
+ var crtPath = "";\r
+ var crtFolder = rootNode; \r
+ for (var i = 0; i < parts.length; i++) {\r
+ if (parts[i] == "")\r
+ continue;\r
+ crtPath += "/" + parts[i]; \r
+ if (!model[crtPath]) {\r
+ var virtualFolder = new qx.ui.tree.TreeFolder(parts[i]);\r
+ if (userData && qx.lang.Object.getLength(userData)) {\r
+ for (var key in userData) {\r
+ virtualFolder.setUserData(key, userData[key]);\r
+ }\r
+ }\r
+ rootNode.appendDragData(virtualFolder);\r
+ model[crtPath] = virtualFolder;\r
+ crtFolder.add(virtualFolder);\r
+ crtFolder = virtualFolder;\r
+ } else {\r
+ crtFolder = model[crtPath];\r
+ }\r
+ }\r
+ crtFolder.add(childNode);\r
+ },\r
+ \r
+ findAgentNodeById : function(node, agentId){\r
+ var nodeAgents = node.getItems();\r
+ for(var i=0;i<nodeAgents.length;i++){\r
+ if(nodeAgents[i].getUserData("agentUuid") == agentId){\r
+ return nodeAgents[i];\r
+ }\r
+ }\r
+ } \r
+ },\r
+\r
+ members : {\r
+ /**\r
+ * Called at applet creation. Just registers viewPane.\r
+ * \r
+ * @param viewPane\r
+ * {org.argeo.ria.components.ViewPane} The viewPane.\r
+ */\r
+ init : function(viewPane) {\r
+ this.setView(viewPane);\r
+ this.setViewSelection(new org.argeo.ria.components.ViewSelection(viewPane.getViewId()));\r
+ this.remoteNotifier = new org.argeo.ria.remote.RemoteNotifier(\r
+ "/org.argeo.slc.webapp/", "pollEvent.service",\r
+ "addEventListener.service", "removeEventListener.service");\r
+ this.remoteNotifier.setEventParamName("slc_eventType");\r
+ this.remoteNotifier.setEventXPath("/slc:slc-event");\r
+ this.remoteNotifier\r
+ .setEventTypeXPath('slc:headers/slc:header[@name="slc_eventType"]');\r
+ this.remoteNotifier\r
+ .setEventDataXPath('slc:headers/slc:header[@name="slc_agentId"]');\r
+ this.remoteNotifier.startPolling();\r
+ this.UIBus = org.argeo.ria.event.UIBus.getInstance();\r
+ this.UIBus.registerNotifier(this.remoteNotifier);\r
+ },\r
+\r
+ /**\r
+ * \r
+ */\r
+ load : function() {\r
+ this._createLayout();\r
+ this.getView().setViewTitle("Available Scripts");\r
+ this.UIBus.addListener("agentRegistered", this._addAgentHandler, this);\r
+ this.UIBus.addListener("agentUnregistered", this._removeAgentHandler, this);\r
+ },\r
+\r
+ _addAgentHandler : function(agentId){\r
+ this.rootNode.load();\r
+ },\r
+ \r
+ _removeAgentHandler : function(agentId){\r
+ var treeNode = this.self(arguments).findAgentNodeById(this.rootNode, agentId);\r
+ if(treeNode){\r
+ this.rootNode.remove(treeNode);\r
+ }\r
+ var agentsMap = this.getAgentsMap();\r
+ if(agentsMap[agentId]){ \r
+ delete agentsMap[agentId];\r
+ }\r
+ var batchView = org.argeo.ria.components.ViewsManager.getInstance().getViewPaneById("batch").getContent();\r
+ if(batchView){\r
+ batchView.clearBatchForAgentId(agentId);\r
+ }\r
+ },\r
+ \r
+ addScroll : function() {\r
+ return false;\r
+ },\r
+\r
+ close : function() {\r
+ this.UIBus.removeListener("agentRegistered", this._addAgentHandler, this);\r
+ this.UIBus.removeListener("agentUnregistered", this._removeAgentHandler, this);\r
+ this.remoteNotifier.stopPolling();\r
+ },\r
+\r
+ /**\r
+ * Creates the main applet layout.\r
+ */\r
+ _createLayout : function() {\r
+\r
+ this.tree = new qx.ui.tree.Tree();\r
+ this.tree.setDecorator(null);\r
+ this.tree.setSelectionMode("multi");\r
+ var dragData = {\r
+ "file" : {\r
+ "type" : ["items"],\r
+ "action" : ["move"]\r
+ },\r
+ "folder" : {\r
+ "type" : ["items"],\r
+ "action" : ["move"]\r
+ }\r
+ };\r
+\r
+ this.rootNode = new org.argeo.ria.components.DynamicTreeFolder(\r
+ "Tests", this.self(arguments).agentLoader,\r
+ "Loading Agents", dragData);\r
+ this.tree.setRoot(this.rootNode);\r
+ this.rootNode.setOpen(true);\r
+ this.tree.setContextMenu(org.argeo.ria.event.CommandsManager\r
+ .getInstance().createMenuFromIds(["addtobatch",\r
+ "reloadtree"]));\r
+\r
+ this.tree.addListener("changeSelection", function(e) {\r
+ var viewSelection = this.getViewSelection();\r
+ viewSelection.setViewId("form:tree");\r
+ viewSelection.clear();\r
+ var sel = this.tree.getSortedSelection();\r
+ for (var i = 0; i < sel.length; i++) {\r
+ viewSelection.addNode(sel[i]);\r
+ }\r
+ }, this);\r
+\r
+\r
+ this.add(this.tree);\r
+ },\r
+ \r
+ getAgentsMap : function(){\r
+ return this.rootNode.getUserData("agentsMap");\r
+ } \r
+ }\r
+});
\ No newline at end of file
projects / gpl / argeo-slc.git / blobdiff