1 function getDgStartNode(nodeList){
2 for(var i=0;i<nodeList.length;i++){
3 if(nodeList[i].type == 'dgstart' && nodeList[i].wires != null && nodeList[i].wires != undefined){
7 RED.notify("DGSTART node not found.");
12 var loopDetectionEnabled = true;
14 function detectLoopPrev(){
15 var activeWorkspace=RED.view.getWorkspace();
17 RED.nodes.links.filter(function(d) {
18 if(d.source.z == activeWorkspace && d.target.z == activeWorkspace){
19 console.log(d.source.id+":"+d.sourcePort+":"+d.target.id);
23 //console.dir(RED.nodes.links);
26 RED.nodes.eachNode(function(n) {
27 if (n.z == activeWorkspace) {
32 var nodeSet = RED.nodes.createExportableNodeSet(nSet);
33 //console.dir(nodeSet);
35 //console.log("nodeSet length:" + nodeSet.length);
37 var isLoopDetected = false;
38 var dgStartNode = getDgStartNode(nodeSet);
39 if(dgStartNode == null || dgStartNode == undefined) {
40 console.log("dgstart node not linked.");
44 var wires = dgStartNode.wires;
46 var dgStartNodeId = dgStartNode.id;
47 if(wires != null && wires != undefined && wires[0] != undefined){
48 for(var k=0;k<wires[0].length;k++){
49 var val = wires[0][k];
50 nodesInPath[dgStartNodeId + "->" + val] = "";
53 nodesInPath[dgStartNodeId + "->" + ""] = "";
56 //console.dir(nodesInPath);
57 var loopDetectedObj = {};
58 /* the nodes will not be order so will need to loop thru again */
59 for(var m=0;nodeSet != null && m<nodeSet.length;m++){
60 for(var i=0;nodeSet != null && i<nodeSet.length;i++){
61 var link=nodeSet[i].id;
62 //console.log("NAME:" + nodeSet[i].name + ":" + link);
63 if(link == dgStartNodeId) continue;
64 var wires = nodeSet[i].wires;
65 //console.log("link:" + link);
67 if(wires != null && wires != undefined && wires[0] != undefined){
68 for(var k=0;k<wires[0].length;k++){
69 var val = (wires[0])[k];
70 var keys = Object.keys(nodesInPath);
71 //console.log("keys:" + keys);
72 for (var j=0;j<keys.length;j++){
73 //console.log("key:" + keys[j]);
74 //console.log("val:" + val);
77 index = keys[j].indexOf("->" + link);
79 var lastIndex = keys[j].lastIndexOf("->");
80 if(index != -1 && index == lastIndex){
81 //delete nodesInPath[key];
82 var previousNodeId = keys[j].substr(lastIndex +2);
83 var indexOfArrow = -1;
84 if(previousNodeId != ""){
85 indexOfArrow = previousNodeId.indexOf("->");
87 if(previousNodeId != null && indexOfArrow != -1){
88 previousNodeId = previousNodeId.substr(0,indexOfArrow);
90 nodesInPath[keys[j] + "->" + val] = "";
91 //console.log("keys[j]:" + keys[j]);
92 delKeys.push(keys[j]);
93 var prevNodeIdIndex = keys[j].indexOf("->" + previousNodeId);
94 var priorOccurence = keys[j].indexOf(val + "->");
95 if(priorOccurence != -1 && priorOccurence<prevNodeIdIndex){
96 //console.log("previousNodeId:" + previousNodeId);
97 //console.log("val:" + val);
98 var n1 = getNode(nodeSet,previousNodeId);
99 var n2 = getNode(nodeSet,val);
100 //console.log("loop detected for node " + n1.name + " and " + n2.name);
101 loopDetectedObj[n1.name + "->" + n2.name] ="looped";
102 //console.dir(loopDetectedObj);
103 isLoopDetected = true;
109 for(var l=0;delKeys != null && l<delKeys.length;l++){
110 delete nodesInPath[delKeys[l]];
116 if(loopDetectedObj != null ){
118 for(var key in loopDetectedObj){
119 if(loopDetectedObj.hasOwnProperty(key)) {
120 console.log("Loop detected " + key);
121 msg += "<strong>Loop detected for:" + key + "</strong><br>";
125 isLoopDetected = true;
130 for(var i=0;nodeSet != null && i<nodeSet.length;i++){
132 var nodeId = nodeSet[i].id;
133 var nodeName = nodeSet[i].name;
134 for(var j=0;nodeSet != null && j<nodeSet.length;j++){
135 var node = nodeSet[j];
136 if(node.id == nodeId){
139 var wires = node.wires;
140 console.log(node.type + ":wires:" + wires);
141 for(var k=0;wires != null && wires != undefined && wires[0] != undefined && k<wires[0].length;k++){
142 var id = (wires[0])[k];
143 console.log(nodeName + ":" + nodeId + ":" + id);
147 console.log("Loop detected for node " + nodeName + "with node:" + node.name);
148 RED.notify("<strong>Flow error detected for node '" + nodeName + "' with node '" + node.name + "'</strong>");
149 //RED.nodes.eachLink(function(d){
150 // if(d.source.id == nodeSet[i] || d.target.id == nodeSet[j]){
151 // d.selected = true;
152 // }else if(d.source.id == nodeSet[j] || d.target.id == nodeSet[i]){
153 // d.selected = true;
157 isLoopDetected = true;
166 //console.log("isLoopDetected:" + isLoopDetected);
167 return isLoopDetected;
170 function generateNodePath(nodeIdToNodeObj,nodeId,pathStr,nodesInPath,errList){
171 var node = nodeIdToNodeObj[nodeId];
172 var wires = node.wires;
173 if(wires != null && wires != undefined && wires[0] != undefined){
174 for(var k=0;k<wires[0].length;k++){
175 var val = wires[0][k];
176 if(pathStr.indexOf(val + "->") != -1){
177 //console.log("pathStr:" + pathStr);
178 var n1= nodeIdToNodeObj[nodeId].name;
179 var n2= nodeIdToNodeObj[val].name;
180 errList.push("Loop detected between nodes '" + n1 + "' and " + "'" + n2 + "'");
182 pathStr += "->" + val ;
183 generateNodePath(nodeIdToNodeObj,val,pathStr,nodesInPath,errList);
187 //pathStr += nodeId + "->" + "";
188 nodesInPath.push(pathStr);
192 function detectLoop(){
193 var activeWorkspace=RED.view.getWorkspace();
195 var nodeIdToNodeObj = {};
196 RED.nodes.eachNode(function(n) {
197 if (n.z == activeWorkspace) {
202 var nodeSet = RED.nodes.createExportableNodeSet(nSet);
203 nodeIdToNodeObj = getNodeIdToNodeMap(nodeSet);
204 var isLoopDetected = false;
205 //var dgStartNode = getDgStartNode(nodeSet);
206 var dgStartNode = nodeIdToNodeObj["dgstart"];
208 var dgStartNodeId = dgStartNode.id;
209 var nodesInPathArr = [];
210 generateNodePath(nodeIdToNodeObj,dgStartNodeId,dgStartNodeId,nodesInPathArr,errList);
211 if(errList != null && errList != undefined && errList.length > 0){
212 isLoopDetected = true;
213 var htmlStr="<div id='loop-detect-err-list-div'><table id='loopErrListTable' border='1'><tr><th>Error List</th></tr>";
214 for(var j=0;errList != null && j<errList.length;j++){
216 htmlStr += "<tr><td>" + errSeq + ")" + errList[j] + "</td></tr>";
218 htmlStr += "</table></div>";
220 $("#loop-detection-dialog").dialog({
223 title: "DG Flow validation Error List ",
227 $("#loop-detection-dialog").dialog("close");
230 }).dialog("open").html(htmlStr); // end dialog div
235 return isLoopDetected;
239 var xmlNumberCnt = 0;
240 function processForXmlNumbers(nodeSet,node){
241 if( node != null && node.type != 'dgstart'){
242 if(node.xmlnumber != null && node.xmlnumber){
243 node.xmlnumber.push(++xmlNumberCnt);
245 node.xmlnumber = [++xmlNumberCnt];
249 if(node != null && node.wires != null && node.wires.length>0){
250 var wiredNodes=node.wires[0];
251 var wiredNodesArr=[];
252 for(var k=0;wiredNodes != undefined && wiredNodes != null && k<wiredNodes.length;k++){
253 wiredNodesArr.push(getNode(nodeSet,wiredNodes[k]));
256 //use this sort to sort by y position
257 wiredNodesArr.sort(function(a, b){
261 for(var k=0;k<wiredNodesArr.length;k++){
262 var n = wiredNodesArr[k];
263 processForXmlNumbers(nodeSet,n);
268 function updateXmlNumbers(){
270 var nodeSet = getCurrentFlowNodeSet();
271 if(nodeSet == null && nodeSet.length >0){
272 nodeSet.forEach(function(n){
278 var dgStartNode = getDgStartNode(nodeSet);
279 processForXmlNumbers(nodeSet,dgStartNode);
280 var activeWorkspace=RED.view.getWorkspace();
281 RED.nodes.eachNode(function(n) {
282 //console.log("Node processed in eachNode");
283 if (n.z == activeWorkspace) {
285 var updatedNode = getNode(nodeSet,n.id);
286 //console.log("updated Node processed in eachNode");
287 //console.dir(updatedNode);
289 if (n.id == updatedNode.id) {
290 n.xmlnumber = updatedNode.xmlnumber;
298 function getOutcomeValue(node){
300 if(node != null && node.xml != undefined && node.xml !=""){
301 xmlStr = node.xml + "</outcome>";
304 if (window.DOMParser){
306 var parser=new DOMParser();
307 xmlDoc=parser.parseFromString(xmlStr,'text/xml');
308 //console.log("Not IE");
309 var n = xmlDoc.documentElement.nodeName;
312 console.log("Error parsing");
316 console.log("xmlStr:" + xmlStr);
317 console.log("Error parsing" +e);
324 xmlDoc=new ActiveXObject("Microsoft.XMLDOM");
326 xmlDoc.loadXMLString(xmlStr);
328 console.log("xmlStr:" + xmlStr);
329 console.log("Error parsing" +e);
334 var xmlNode = xmlDoc.documentElement;
335 //console.dir(xmlNode);
336 var processedNode = xmlNode.nodeName;
337 //console.log("processedNode:" + processedNode);
338 var attrs = xmlNode.attributes;
339 for(var i=0;i<attrs.length;i++){
340 if(attrs[i].nodeName == "value"){
341 return attrs[i].value;
349 function processForDgNumbers(nodeSet,node){
350 var outcomeTypes = [ "already-active", "failure", "not-found", "other", "outcomeFalse", "outcome", "outcomeTrue", "success" ];
351 if( node != null && node.type != 'dgstart' && node.type != 'service-logic' && node.type != 'method' ){
352 //console.log("child of " + parentNodeType + " :" + nodeType);
353 //check if NOT outcome node
354 if(outcomeTypes.indexOf(node.type) == -1){
355 if(node.type == "GenericXML"){
356 if(node.xml != undefined && node.xml != null && node.xml.indexOf("<outcome ") != -1){
357 //this GenericXML node is used for outcome , so need to skip
359 if(node.dgnumber != undefined && node.dgnumber != null && node.dgnumber){
360 node.dgnumber.push(++dgNumberCnt);
362 node.dgnumber = [++dgNumberCnt];
367 if(node.dgnumber != undefined && node.dgnumber != null && node.dgnumber){
368 node.dgnumber.push(++dgNumberCnt);
370 node.dgnumber = [++dgNumberCnt];
376 var hasOutcomeNodes = false;
377 if(node != null && node.wires != null && node.wires.length>0){
378 var wiredNodes=node.wires[0];
379 var wiredNodesArr=[];
380 for(var k=0;wiredNodes != undefined && wiredNodes != null && k<wiredNodes.length;k++){
381 var wiredNode = getNode(nodeSet,wiredNodes[k]);
382 //check if outcome node
383 if(outcomeTypes.indexOf(wiredNode.type) != -1){
384 hasOutcomeNodes = true;
386 if(wiredNode.type == "GenericXML"){
387 if( node.xml != undefined && node.xml != null && node.xml.indexOf("<outcome ") != -1){
388 //this GenericXML node is used for outcome
389 hasOutcomeNodes = true;
392 wiredNodesArr.push(wiredNode);
396 //use this sort to sort by y position
397 wiredNodesArr.sort(function(a, b){
402 //USE THIS LOGIC TO SORT BY OUTCOME VALUE FOR SPECIFIC NODES
403 var parentNodeType = node.type;
404 if(hasOutcomeNodes && parentNodeType != 'switchNode' && parentNodeType != 'block' && parentNodeType != 'configure' ){
405 //use the value of outcome to sort the wired nodes
406 wiredNodesArr.sort(function(a, b){
407 var val1 = getOutcomeValue(a);
408 var val2 = getOutcomeValue(b);
409 //console.log("val1:" + val1);
410 //console.log("val2:" + val2);
413 }else if ( val1 > val2 ){
420 //use this sort to sort by y position
421 wiredNodesArr.sort(function(a, b){
428 for(var k=0;k<wiredNodesArr.length;k++){
429 var n = wiredNodesArr[k];
430 processForDgNumbers(nodeSet,n);
435 function updateDgNumbers(){
437 var nodeSet = getCurrentFlowNodeSet();
438 if(nodeSet == null && nodeSet.length >0){
439 nodeSet.forEach(function(n){
445 var dgStartNode = getDgStartNode(nodeSet);
446 processForDgNumbers(nodeSet,dgStartNode);
447 var activeWorkspace=RED.view.getWorkspace();
448 RED.nodes.eachNode(function(n) {
449 //console.log("Node processed in eachNode");
450 if (n.z == activeWorkspace) {
452 var updatedNode = getNode(nodeSet,n.id);
453 //console.log("updated Node processed in eachNode");
454 //console.dir(updatedNode);
456 if (n.id == updatedNode.id) {
457 //console.log(n.type + ":" + updatedNode.dgnumber);
458 n.dgnumber = updatedNode.dgnumber;
467 function customValidation(currNodeSet){
468 //validation to make sure there a block node infront of mutiple dgelogic nodes
471 var serviceLogicCnt=0;
473 for(var i=0;currNodeSet != null && i<currNodeSet.length;i++){
474 var node = currNodeSet[i];
475 var parentNodeName = node.name;
476 var parentNodeType = node.type;
477 var dgNumber = node.dgnumber;
478 if(parentNodeType == 'dgstart'){
481 if(parentNodeType == 'service-logic'){
484 if(parentNodeType == 'method'){
487 if(parentNodeType == "GenericXML"){
488 if( node.xml != undefined && node.xml != null && node.xml.indexOf("<service-logic ") != -1 ){
489 //this GenericXML node is used for service-logic
491 }else if( node.xml != undefined && node.xml != null && node.xml.indexOf("<method ") != -1 ){
492 //this GenericXML node is used for method
494 }else if( node.xml != undefined && node.xml != null && node.xml.indexOf("<block") != -1 ){
495 //this GenericXML node is used for block
496 parentNodeType = "block";
499 if(node != null && node.wires != null && node.wires.length>0){
500 var wiredNodes=node.wires[0];
501 var wiredNodesArr=[];
502 for(var k=0;wiredNodes != undefined && wiredNodes != null && k<wiredNodes.length;k++){
503 wiredNodesArr.push(getNode(currNodeSet,wiredNodes[k]));
505 var countChildLogicNodes =0;
506 for(var k=0;k<wiredNodesArr.length;k++){
507 var n = wiredNodesArr[k];
508 var nodeType = n.type;
509 var outcomeTypes = [ "already-active", "failure", "not-found", "other", "outcomeFalse", "outcome", "outcomeTrue", "success" ];
510 var isOutcomeOrSetNode = false;
511 if(nodeType == "GenericXML"){
512 if( n.xml != undefined && n.xml != null && (n.xml.indexOf("<outcome ") != -1 || n.xml.indexOf("<set ") != -1)){
513 //this GenericXML node is used for outcome
514 isOutcomeOrSetNode = true;
517 //console.log("child of " + parentNodeType + " :" + nodeType);
518 if(outcomeTypes.indexOf(nodeType) > -1 ||nodeType == 'set' || isOutcomeOrSetNode){
519 //its a outcome or set node
521 countChildLogicNodes++;
524 //console.log("parentNodeType:" + parentNodeType);
525 if(countChildLogicNodes >1 && parentNodeType != 'block' && parentNodeType != 'for' ){
526 if(node.dgnumber != undefined && node.dgnumber){
527 flowDesignErrors.push("Warning:May need a block Node after Node. <br><span style='color:red'>Node Name:</span>" + node.name + "<br><span style='color:red'>DG Number:</span>" + node.dgnumber[0] );
529 flowDesignErrors.push("Warning:May need a block Node after Node <br><span style='color:red'>Node name:</span>" + parentNodeName);
537 flowDesignErrors.push("Error:There should only be 1 dgstart Node in the current workspace.");
540 if(serviceLogicCnt > 1){
541 flowDesignErrors.push("Error:There should only be 1 service-logic Node in the current workspace.");
545 flowDesignErrors.push("Error:There should only be 1 method Node in the current workspace.");
548 if(flowDesignErrors != null && flowDesignErrors.length >0){
554 var flowDesignErrors = [];
555 function showFlowDesignErrorBox(){
556 if(flowDesignErrors != null && flowDesignErrors.length >0){
557 var htmlStr="<div id='flowpath-err-list-div'><table id='fpeTable' border='1'><tr><th>Error List</th></tr>";
558 for(var j=0;flowDesignErrors != null && j<flowDesignErrors.length;j++){
560 htmlStr += "<tr><td>" + errSeq + ")" + flowDesignErrors[j] + "</td></tr>";
562 htmlStr += "</table></div>";
564 //$('<div></div>').dialog({
566 $('#flow-design-err-dialog').dialog({
568 title: "Flow design Error List ",
570 /*open: function () {
571 $(this).html(htmlStr);
575 $(this).dialog("close");
578 }).html(htmlStr); // end dialog div
583 function getCurrentFlowNodeSet(){
588 var activeWorkspace=RED.view.getWorkspace();
589 RED.nodes.eachNode(function(n) {
590 if (n.z == activeWorkspace) {
591 nodeSet.push({'n':n});
595 var exportableNodeSet = RED.nodes.createExportableNodeSet(nodeSet);
596 //console.dir(exportableNodeSet);
597 //console.log(JSON.stringify(exportableNodeSet));
598 return exportableNodeSet;
601 function getNode(nodeSet,id){
602 for(var i=0;i<nodeSet.length;i++){
603 if(nodeSet[i].id == id){
609 function getNodeIdToNodeMap(nodeSet){
610 var nodeIdToNodeMap ={};
611 for(var i=0;i<nodeSet.length;i++){
612 nodeIdToNodeMap[nodeSet[i].id] = nodeSet[i];
613 if(nodeSet[i].type == "dgstart"){
614 nodeIdToNodeMap["dgstart"] = nodeSet[i];
617 return nodeIdToNodeMap;
620 function validateEachNodeXml(){
621 var activeWorkspace=RED.view.getWorkspace();
622 RED.nodes.eachNode(function(n) {
623 if (n.z == activeWorkspace) {
625 if( xml != null && xml != ''){
626 var validationSuccess = validateXML(n.xml);
627 if(validationSuccess){
628 n.status = {fill:"green",shape:"dot",text:"OK"};
630 n.status = {fill:"red",shape:"dot",text:"ERROR"};
638 function getNodeToXml(inputNodeSet){
639 var exportableNodeSet;
640 //uses inputNodeSet if passed otherwise build the latest nodeSet
642 //$("#btn-deploy").removeClass("disabled");
645 function getNode(id){
646 for(var i=0;i<exportableNodeSet.length;i++){
647 if(exportableNodeSet[i].id == id){
648 return exportableNodeSet[i];
654 function getStartTag(node){
657 if(node != null && node.type != 'dgstart'){
659 var regex = /(<)([\w-]+)(.*)?/;
660 var match = regex.exec(xmlStr);
662 if(match[1] != undefined && match[2] != undefined){
666 console.log("startTag not found.");
672 if(inputNodeSet == null || inputNodeSet == undefined){
673 exportableNodeSet = getCurrentFlowNodeSet();
675 exportableNodeSet = JSON.parse(inputNodeSet);
677 var dgstartNode = getDgStartNode(exportableNodeSet);
682 printXml(dgstartNode);
685 function printXml(node){
688 if(node != null && node.type != 'dgstart'){
689 var comments=node.comments;
690 if(comments != null && comments != ""){
691 //if xml comments field already has the <!-- and --> remove them
692 comments=comments.replace("<!--","");
693 comments=comments.replace("-->","");
694 xmlStr="<!--" + comments + "-->";
697 startTag = getStartTag(node);
701 var spacing = Array(level).join(" ");
702 xmlStr=xmlStr.replace(/\n/g,spacing);
713 //console.log("startTag:" + startTag);
716 var wiredNodesArr = [];
717 if(node != null && node.wires != null && node.wires[0] != null && node.wires[0] != undefined && node.wires[0].length >0 ){
718 wiredNodes=node.wires[0];
719 //console.log("Before sort");
720 for(var k=0;wiredNodes != undefined && wiredNodes != null && k<wiredNodes.length;k++){
721 wiredNodesArr.push(getNode(wiredNodes[k]));
723 //console.dir(wiredNodesArr);
724 //sort based on y position
725 wiredNodesArr.sort(function(a, b){
728 //console.log("After sort");
729 //console.dir(wiredNodesArr);
732 for(var k=0;wiredNodesArr != null && k<wiredNodesArr.length;k++){
734 var nd = wiredNodesArr[k];
740 fullXmlStr += "</" + startTag + ">";
743 var spacing = Array(level).join(" ");
744 fullXmlStr += spacing + "</" + startTag + ">";
745 console.log(spacing + "</" + startTag + ">");
747 fullXmlStr += "</" + startTag + ">";
748 console.log("</" + startTag + ">");
757 //console.log("endTag:" + startTag);
758 //console.log("xml:" + fullXmlStr);
760 //console.log("fullXmlStr:" + fullXmlStr);
764 function showFlow(filePath){
765 var jqxhr = $.post( "/getSharedFlow",{"filePath":filePath})
766 .done(function(data) {
767 $( "#dgflow-browser-dialog").dialog("close");
768 var migratedNodes = migrateNodes(data);
769 //RED.view.importNodes(data)
770 RED.view.importNodes(JSON.stringify(migratedNodes));
771 //console.log( "import done");
774 RED.notify("Could not import user flow .");
775 $( "#dgflow-browser-dialog").dialog("close");
776 console.log( "error occured importing flow.");
779 //console.log( "complete" );
783 function showFlowXml(filePath){
784 var jqxhr = $.post( "/getSharedFlow",{"filePath":filePath})
785 .done(function(data) {
787 var xmlStr=getNodeToXml(data);
788 showImportedXml(xmlStr,this);
791 RED.notify("Could not convert to XML.");
792 $( "#dgflow-browser-dialog").dialog("close");
793 console.log( "error occured importing flow.");
796 //console.log( "complete" );
800 function showFlowFiles(userName){
801 //var divStyle="color:#07c; margin-bottom: 1.2em; font-size: 16px;";
802 //var divStyle="<style>#data-container a { color: #067ab4; font-size: 0.75em;} #data-container a:hover { text-decoration: underline; padding: -15px -15px -15px 15px; } </style>";
803 var divStyle="<style>#data-container a { color: #067ab4; font-size: 0.75em;} #data-container a:hover { text-decoration: underline; padding: -15px -15px -15px 15px; } .header { height: 40px; border-bottom: 1px solid #EEE; background-color: #ffffff; height: 40px; -webkit-border-top-left-radius: 5px; -webkit-border-top-right-radius: 5px; -moz-border-radius-topleft: 5px; -moz-border-radius-topright: 5px; border-top-left-radius: 5px; border-top-right-radius: 5px; } .footer { height: 40px; background-color: whiteSmoke; border-top: 1px solid #DDD; -webkit-border-bottom-left-radius: 5px; -webkit-border-bottom-right-radius: 5px; -moz-border-radius-bottomleft: 5px; -moz-border-radius-bottomright: 5px; border-bottom-left-radius: 5px; border-bottom-right-radius: 5px; }</style>";
805 var htmlStr=divStyle + "<div class='header'>List of Flow files of User " + userName + "</div><div id='data-container'><ul>" ;
806 $.post( "/getFiles/" + userName)
807 .done(function( data ) {
809 //console.log("found " + data.length + " files");
810 if(data != null && data.length != undefined && data.length != 0){
811 if(data != null && data.length>0){
812 for(var k=0;k<data.length;k++){
813 htmlStr += "<li><a href=\"#\" onclick=\"showFlow('" +data[k].filePath + "')\">" + data[k].name + "</a></li>";
815 //Use this code to display the View Xml Link
816 htmlStr += "<li><a href=\"#\" onclick=\"showFlow('" +data[k].filePath + "')\">" + data[k].name + "</a><span style=\"margin-left:15px;color:blue\"><a href=\#\" onclick=\"showFlowXml('" +data[k].filePath + "')\">[View Xml]</a></span></li>";
819 htmlStr+="</ul></div>";
821 $( "#dgflow-browser-dialog").html(htmlStr);
823 //console.log("no flow files found for user " + userName);
824 var noFlowFilesHtml = divStyle + "<div id='data-container'><p>No downloaded Flow files found in " + userName + " directory</p><a href='#' onclick='javascript:closeAndShowFlowShareUsers()'>Back to List.</a></div>";
825 $( "#dgflow-browser-dialog").html(noFlowFilesHtml);
828 .fail(function(err) {
829 console.log( "error" + err );
832 //console.log("done");
837 function closeAndShowFlowShareUsers(){
838 $("#dgflow-browser-dialog").dialog( "close" );
839 var divStyle="<style>#data-container a { color: #067ab4; font-size: 0.75em;} #data-container a:hover { text-decoration: underline; padding: -15px -15px -15px 15px; } .header { height: 40px; border-bottom: 1px solid #EEE; background-color: #ffffff; height: 40px; -webkit-border-top-left-radius: 5px; -webkit-border-top-right-radius: 5px; -moz-border-radius-topleft: 5px; -moz-border-radius-topright: 5px; border-top-left-radius: 5px; border-top-right-radius: 5px; } .footer { height: 40px; background-color: whiteSmoke; border-top: 1px solid #DDD; -webkit-border-bottom-left-radius: 5px; -webkit-border-bottom-right-radius: 5px; -moz-border-radius-bottomleft: 5px; -moz-border-radius-bottomright: 5px; border-bottom-left-radius: 5px; border-bottom-right-radius: 5px; }</style>";
840 $.get( "/flowShareUsers")
841 .done(function( data ) {
843 var header="<div class='header'>List of downloaded DG Flows </div>";
844 var html= divStyle + header + "<div id='data-container'>";
847 var users=data.flowShareUsers;
848 users.sort(function (a,b){
851 }else if(a.name < b.name){
857 for(var i=0;users != null && i<users.length;i++){
858 html+="<li><a href=\"#\" onclick=\"showFlowFiles('" + users[i].rootDir + "')\">" + users[i].name + "</a></li>";
863 $( "#dgflow-browser-dialog" ).dialog({
864 title: "Dowloaded DG Flow Browser",
873 $( this ).dialog( "close" );
878 $("#dgflow-browser-dialog").show();
880 .fail(function(err) {
881 RED.notify("Failed to get users.");
887 function showImportedXml(xmlStr,dialogBox){
888 var formattedXml=vkbeautify.xml(xmlStr);
889 var that = dialogBox;
890 require(["orion/editor/edit"], function(edit) {
892 parent:document.getElementById('dgflow-browser-dialog'),
895 contents: formattedXml
898 url:"functions", // where to get the data from
899 type:"function", // the type of object the library is for
900 editor:that.editor, // the field name the main text body goes to
901 fields:['name','outputs']
906 function getTag(xmlStr){
909 xmlStr = xmlStr.trim();
912 var regex = new RegExp("(<)([^ >]+)");
913 var match = regex.exec(xmlStr);
915 if(match[1] != undefined && match[2] != undefined){
926 function getAttributeValue(xmlStr,attribute){
930 var myRe = new RegExp(attribute + "[\s+]?=[\s+]?['\"]([^'\"]+)['\"]","m");
931 var myArray = myRe.exec(xmlStr);
932 if(myArray != null && myArray[1] != null){
941 function showOrHideTab(checkbox,idVal){
943 var activeWorkspace=RED.view.getWorkspace();
944 var table = $("#ftab02");
945 $('td input:checkbox',table).each(function(i){
946 console.log(this.checked);
948 //console.dir($('td input:checkbox',table).prop('checked',this.checked));
950 $(".red-ui-tabs li a").each(function(i){
951 var id=$(this).attr("href").replace('#','');
953 $(this).parent().toggle();
954 var isVisible = $(this).parent().is(":visible");
956 checkbox.checked = true;
958 checkbox.checked = false;
960 if(activeWorkspace == id){
961 //$("#chart").hide();
962 //var li = ul.find("a[href='#"+id+"']").parent();
963 var li = $(this).parent();
964 if (li.hasClass("active")) {
965 li.removeClass("active");
966 if(li.parent().children().size() != 0){
968 console.log("has Class active");
970 if (tab.size() === 0) {
971 console.log("li prev size 0");
974 if(tab.is(":visible")){
975 console.log("added active");
976 tab.addClass("active");
978 //tab.trigger("click");
981 //tab.parent().addClass("active");
985 console.log("added active id" +id);
987 var li = $(this).parent();
988 li.addClass("active");
992 var li = $(this).parent();
993 li.removeClass("active");
999 $(".red-ui-tabs li a").each(function(i){
1000 var id=$(this).attr("href").replace('#','');
1002 $(this).trigger("click");
1003 if(activeWorkspace == idVal){
1012 function performGitCheckout(){
1013 $("#responseId").text("");
1014 if(!event) event = window.event;
1015 var target = $(event.target);
1016 target.val("Processing");
1017 target.css({ "background-image": "url('images/page-loading.gif')" });
1018 target.css({ "background-repeat": "no-repeat" });
1019 target.css({ "background-size": "25px 25px" });
1021 var branch = document.getElementById("branchId").value.trim();
1022 var statusObj = document.getElementById("responseId");
1023 if(branch == null || branch == ''){
1024 statusObj.innerText = "Branch is required.";
1027 var urlVal = "/gitcheckout?branch=" + branch;
1029 .done(function( data ) {
1030 var output = data.output;
1032 output=output.replace(/\n/g,"<br>");
1033 statusObj.innerHTML = output;
1036 .fail(function(err) {
1037 statusObj.innerText = "Failed to do git checkout.";
1039 .always(function() {
1040 $("#responseId").show();
1041 target.val("Checkout");
1042 target.css({ "background-image": "none" });
1046 function performGitPull(){
1047 $("#responseId").text("");
1048 if(!event) event = window.event;
1049 var target = $(event.target);
1050 target.val("Processing");
1051 target.css({ "background-image": "url('images/page-loading.gif')" });
1052 target.css({ "background-repeat": "no-repeat" });
1053 target.css({ "background-size": "25px 25px" });
1055 var statusObj = document.getElementById("responseId");
1056 var urlVal = "/gitpull";
1058 .done(function( data ) {
1059 var output = data.output;
1061 output=output.replace(/\n/g,"<br>");
1062 statusObj.innerHTML = output;
1065 .fail(function(err) {
1066 statusObj.innerText = "Failed to do git pull.";
1068 .always(function() {
1069 $("#responseId").show();
1071 target.css({ "background-image": "none" });
1076 function activateClickedTab(idVal) {
1078 $("#filter-tabs-dialog").dialog( "close" );
1079 var ul = $("#workspace-tabs");
1080 ul.children().each(function(){
1082 var link =li.find("a");
1083 var href = link.prop("href");
1084 var hrefId = href.split("#");
1085 if(hrefId[1] == idVal){
1086 link.trigger("click");
1091 function deleteOrRenameTab(idVal) {
1092 $("#filter-tabs-dialog").dialog( "close" );
1093 var ul = $("#workspace-tabs");
1094 ul.children().each(function(){
1096 var link =li.find("a");
1097 var href = link.prop("href");
1098 var hrefId = href.split("#");
1099 if(hrefId[1] == idVal){
1100 link.trigger("click");
1101 link.trigger("dblclick");
1106 function deleteSelectedTab(idVal,title,_module,rpc,version){
1107 var dgInfo = "<div><table width='100%' border='1'><tr style='background-color:#65a9d7;color:white;' ><th>Tab Title</th><th>Module</th><th>RPC</th><th>Version</th></tr><tr style='background-color:white'><td>" + title + "</td><td>" + _module +"</td><td>" + rpc + "</td><td>" +version + "</td></tr></table></div><br>";
1108 var alertMsg = dgInfo + "<p>Are you sure you want to Delete this Tab ?</p>";
1110 $( "#tabAlertDialog" ).dialog({
1111 dialogClass: "no-close",
1114 /*dialogClass: "alert",*/
1115 title: "Confirm Tab sheet Delete",
1120 class:"alertDialogButton",
1122 var ws = RED.nodes.workspace(idVal);
1123 RED.view.removeWorkspace(ws);
1124 var historyEvent = RED.nodes.removeWorkspace(idVal);
1125 historyEvent.t = 'delete';
1126 historyEvent.dirty = true;
1127 historyEvent.workspaces = [ws];
1128 RED.history.push(historyEvent);
1129 RED.view.dirty(true);
1130 $( this ).dialog( "close" );
1131 $("#filter-tabs-dialog").dialog( "close" );
1132 $("#btn-manage-tabs").trigger("click");
1137 class:"alertDialogButton",
1139 $( this ).dialog( "close" );
1146 function renameSelectedTab(idVal,title,_module,rpc,version){
1147 var dgInfo = "<div><table width='100%' border='1'><tr style='background-color:#65a9d7;color:white;' ><th>Tab Title</th><th>Module</th><th>RPC</th><th>Version</th></tr><tr style='background-color:white'><td><input id='tab-name-" + idVal + "' type='text' value='" + title + "'></td><td>" + _module +"</td><td>" + rpc + "</td><td>" +version + "</td></tr></table></div><br>";
1148 var alertMsg = dgInfo + "<p>Change the title and click Rename.</p>";
1150 $( "#tabAlertDialog" ).dialog({
1151 dialogClass: "no-close",
1154 /*dialogClass: "alert",*/
1155 title: "Rename Tab sheet",
1160 class:"alertDialogButton",
1162 var ws = RED.nodes.workspace(idVal);
1163 var label = document.getElementById("tab-name-" + idVal).value;
1164 //console.log("label:" +label);
1165 //console.log("ws.label:" + ws.label);
1166 if (ws.label != label) {
1168 var link = $("#workspace-tabs a[href='#"+idVal+"']");
1169 link.attr("title",label);
1171 RED.view.dirty(true);
1173 $("#tabAlertDialog").dialog('destroy').remove();
1174 //$(this).dialog( "close" );
1175 $("#filter-tabs-dialog").dialog( "close" );
1176 $("#btn-manage-tabs").trigger("click");
1181 class:"alertDialogButton",
1183 $( this ).dialog( "close" );
1190 function performGitStatus(){
1191 $("#responseId").text("");
1192 if(!event) event = window.event;
1193 var target = $(event.target);
1194 target.val("Processing");
1195 target.css({ "background-image": "url('images/page-loading.gif')" });
1196 target.css({ "background-repeat": "no-repeat" });
1197 target.css({ "background-size": "25px 25px" });
1199 var statusObj = document.getElementById("responseId");
1200 var urlVal = "/gitstatus";
1202 .done(function( data ) {
1203 var output = data.output;
1205 output=output.replace(/\n/g,"<br>");
1206 statusObj.innerHTML = output;
1208 //statusObj.innerText = data.output;
1210 .fail(function(err) {
1211 statusObj.innerText = "Failed to do git status.";
1213 .always(function() {
1214 $("#responseId").show();
1215 target.val("Status");
1216 target.css({ "background-image": "none" });
1220 function migrateNodes(jsonStr){
1221 var nodes = JSON.parse(jsonStr);
1222 nodes.forEach( function(node) {
1223 if( node.xml != undefined && node.xml != null && node.xml.indexOf("<service-logic") != -1){
1224 //console.log(node.xml);
1227 module=getAttributeValue(node.xml,"module");
1229 var myRe = new RegExp("module=\"(.*)\" ", "m");
1230 var myArray = myRe.exec(node.xml);
1231 if(myArray != null && myArray[1] != null){
1234 myRe = new RegExp("version=\"(.*)\">", "m");
1235 myArray = myRe.exec(node.xml);
1236 if(myArray != null && myArray[1] != null){
1238 //console.dir(myArray);
1241 version=getAttributeValue(node.xml,"version");
1242 node.type="service-logic";
1243 //node.category="DGEmain";
1245 node.version=version;
1246 if(module != null && version != null){
1247 node.name=module+ " " + version;
1249 console.log("module=" + module);
1250 console.log("version=" + version);
1251 }else if( node.xml != undefined && node.xml != null && node.xml.indexOf("<method") != -1){
1252 var rpc=getAttributeValue(node.xml,"rpc");
1257 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<outcome") != -1){
1258 var uxml = node.xml.toUpperCase();
1259 if(uxml.indexOf("FAILURE") != -1){
1260 node.type="failure";
1261 }else if(uxml.indexOf("SUCCESS") != -1){
1262 node.type="success";
1263 }else if(uxml.indexOf("TRUE") != -1){
1264 node.type="outcomeTrue";
1265 }else if(uxml.indexOf("FALSE") != -1){
1266 node.type="outcomeFalse";
1267 }else if(uxml.indexOf("ALREADY-ACTIVE") != -1){
1268 node.type="already-active";
1269 }else if(uxml.indexOf("NOT-FOUND") != -1){
1270 node.type="not-found";
1274 }else if( node.xml != undefined &&node.xml != null && node.xml.indexOf("<return") != -1){
1275 var uxml = node.xml.toUpperCase();
1276 if(uxml.indexOf("FAILURE") != -1){
1277 node.type="returnFailure";
1278 }else if(uxml.indexOf("SUCCESS") != -1){
1279 node.type="returnSuccess";
1281 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<exists") != -1){
1283 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<block") != -1){
1285 var atomic=getAttributeValue(node.xml,"atomic");
1289 node.name="block : atomic";
1291 node.atomic="false";
1294 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<save") != -1){
1296 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<switch") != -1){
1297 node.type="switchNode";
1298 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<record") != -1){
1300 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<call") != -1){
1302 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<release") != -1){
1303 node.type="release";
1304 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<set") != -1){
1306 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<for") != -1){
1308 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<is-available") != -1){
1309 node.type="is-available";
1310 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<reserve") != -1){
1311 node.type="reserve";
1312 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<get-resource") != -1){
1313 node.type="get-resource";
1314 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<configure") != -1){
1315 node.type="configure";
1316 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<delete") != -1){
1318 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<execute") != -1){
1319 node.type="execute";
1320 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<notify") != -1){
1322 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<update") != -1){
1325 //console.dir(node);