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);
698 //special handling for break node
699 if(xmlStr != undefined && xmlStr != null && xmlStr.trim() == "<break>"){
700 fullXmlStr += "<break/>";
706 var spacing = Array(level).join(" ");
707 xmlStr=xmlStr.replace(/\n/g,spacing);
718 //console.log("startTag:" + startTag);
721 var wiredNodesArr = [];
722 if(node != null && node.wires != null && node.wires[0] != null && node.wires[0] != undefined && node.wires[0].length >0 ){
723 wiredNodes=node.wires[0];
724 //console.log("Before sort");
725 for(var k=0;wiredNodes != undefined && wiredNodes != null && k<wiredNodes.length;k++){
726 wiredNodesArr.push(getNode(wiredNodes[k]));
728 //console.dir(wiredNodesArr);
729 //sort based on y position
730 wiredNodesArr.sort(function(a, b){
733 //console.log("After sort");
734 //console.dir(wiredNodesArr);
737 for(var k=0;wiredNodesArr != null && k<wiredNodesArr.length;k++){
739 var nd = wiredNodesArr[k];
745 if(startTag != "break"){
746 fullXmlStr += "</" + startTag + ">";
750 var spacing = Array(level).join(" ");
751 fullXmlStr += spacing + "</" + startTag + ">";
752 console.log(spacing + "</" + startTag + ">");
754 fullXmlStr += "</" + startTag + ">";
755 console.log("</" + startTag + ">");
764 //console.log("endTag:" + startTag);
765 //console.log("xml:" + fullXmlStr);
767 //console.log("fullXmlStr:" + fullXmlStr);
771 function showFlow(filePath){
772 var jqxhr = $.post( "/getSharedFlow",{"filePath":filePath})
773 .done(function(data) {
774 $( "#dgflow-browser-dialog").dialog("close");
775 var migratedNodes = migrateNodes(data);
776 var nodeSet = getCurrentFlowNodeSet();
777 //console.dir(nodeSet);
778 if(nodeSet != null && nodeSet.length == 0){
779 RED.view.setIsImportAction(true);
781 //RED.view.importNodes(data)
782 RED.view.importNodes(JSON.stringify(migratedNodes));
783 //console.log( "import done");
786 RED.notify("Could not import user flow .");
787 $( "#dgflow-browser-dialog").dialog("close");
788 console.log( "error occured importing flow.");
791 //console.log( "complete" );
795 function showFlowXml(filePath){
796 var jqxhr = $.post( "/getSharedFlow",{"filePath":filePath})
797 .done(function(data) {
799 var xmlStr=getNodeToXml(data);
800 showImportedXml(xmlStr,this);
803 RED.notify("Could not convert to XML.");
804 $( "#dgflow-browser-dialog").dialog("close");
805 console.log( "error occured importing flow.");
808 //console.log( "complete" );
812 function showFlowFiles(userName){
813 //var divStyle="color:#07c; margin-bottom: 1.2em; font-size: 16px;";
814 //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>";
815 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>";
817 var htmlStr=divStyle + "<div class='header'>List of Flow files of User " + userName + "</div><div id='data-container'><ul>" ;
818 $.post( "/getFiles/" + userName)
819 .done(function( data ) {
821 //console.log("found " + data.length + " files");
822 if(data != null && data.length != undefined && data.length != 0){
823 if(data != null && data.length>0){
824 for(var k=0;k<data.length;k++){
825 htmlStr += "<li><a href=\"#\" onclick=\"showFlow('" +data[k].filePath + "')\">" + data[k].name + "</a></li>";
827 //Use this code to display the View Xml Link
828 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>";
831 htmlStr+="</ul></div>";
833 $( "#dgflow-browser-dialog").html(htmlStr);
835 //console.log("no flow files found for user " + userName);
836 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>";
837 $( "#dgflow-browser-dialog").html(noFlowFilesHtml);
840 .fail(function(err) {
841 console.log( "error" + err );
844 //console.log("done");
849 function closeAndShowFlowShareUsers(){
850 $("#dgflow-browser-dialog").dialog( "close" );
851 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>";
852 $.get( "/flowShareUsers")
853 .done(function( data ) {
855 var header="<div class='header'>List of downloaded DG Flows </div>";
856 var html= divStyle + header + "<div id='data-container'>";
859 var users=data.flowShareUsers;
860 users.sort(function (a,b){
863 }else if(a.name < b.name){
869 for(var i=0;users != null && i<users.length;i++){
870 html+="<li><a href=\"#\" onclick=\"showFlowFiles('" + users[i].rootDir + "')\">" + users[i].name + "</a></li>";
875 $( "#dgflow-browser-dialog" ).dialog({
876 title: "Dowloaded DG Flow Browser",
885 $( this ).dialog( "close" );
890 $("#dgflow-browser-dialog").show();
892 .fail(function(err) {
893 RED.notify("Failed to get users.");
899 function showImportedXml(xmlStr,dialogBox){
900 var formattedXml=vkbeautify.xml(xmlStr);
901 var that = dialogBox;
902 require(["orion/editor/edit"], function(edit) {
904 parent:document.getElementById('dgflow-browser-dialog'),
907 contents: formattedXml
910 url:"functions", // where to get the data from
911 type:"function", // the type of object the library is for
912 editor:that.editor, // the field name the main text body goes to
913 fields:['name','outputs']
918 function getTag(xmlStr){
921 xmlStr = xmlStr.trim();
924 var regex = new RegExp("(<)([^ >]+)");
925 var match = regex.exec(xmlStr);
927 if(match[1] != undefined && match[2] != undefined){
938 function getAttributeValue(xmlStr,attribute){
942 var myRe = new RegExp(attribute + "[\s+]?=[\s+]?['\"]([^'\"]+)['\"]","m");
943 var myArray = myRe.exec(xmlStr);
944 if(myArray != null && myArray[1] != null){
953 function showOrHideTab(checkbox,idVal){
955 var activeWorkspace=RED.view.getWorkspace();
956 var table = $("#ftab02");
957 $('td input:checkbox',table).each(function(i){
958 console.log(this.checked);
960 //console.dir($('td input:checkbox',table).prop('checked',this.checked));
962 $(".red-ui-tabs li a").each(function(i){
963 var id=$(this).attr("href").replace('#','');
965 $(this).parent().toggle();
966 var isVisible = $(this).parent().is(":visible");
968 checkbox.checked = true;
970 checkbox.checked = false;
972 if(activeWorkspace == id){
973 //$("#chart").hide();
974 //var li = ul.find("a[href='#"+id+"']").parent();
975 var li = $(this).parent();
976 if (li.hasClass("active")) {
977 li.removeClass("active");
978 if(li.parent().children().size() != 0){
980 console.log("has Class active");
982 if (tab.size() === 0) {
983 console.log("li prev size 0");
986 if(tab.is(":visible")){
987 console.log("added active");
988 tab.addClass("active");
990 //tab.trigger("click");
993 //tab.parent().addClass("active");
997 console.log("added active id" +id);
999 var li = $(this).parent();
1000 li.addClass("active");
1004 var li = $(this).parent();
1005 li.removeClass("active");
1011 $(".red-ui-tabs li a").each(function(i){
1012 var id=$(this).attr("href").replace('#','');
1014 $(this).trigger("click");
1015 if(activeWorkspace == idVal){
1024 function performGitCheckout(){
1025 $("#responseId").text("");
1026 if(!event) event = window.event;
1027 var target = $(event.target);
1028 target.val("Processing");
1029 target.css({ "background-image": "url('images/page-loading.gif')" });
1030 target.css({ "background-repeat": "no-repeat" });
1031 target.css({ "background-size": "25px 25px" });
1033 var branch = document.getElementById("branchId").value.trim();
1034 var statusObj = document.getElementById("responseId");
1035 if(branch == null || branch == ''){
1036 statusObj.innerText = "Branch is required.";
1039 var urlVal = "/gitcheckout?branch=" + branch;
1041 .done(function( data ) {
1042 var output = data.output;
1044 output=output.replace(/\n/g,"<br>");
1045 statusObj.innerHTML = output;
1048 .fail(function(err) {
1049 statusObj.innerText = "Failed to do git checkout.";
1051 .always(function() {
1052 $("#responseId").show();
1053 target.val("Checkout");
1054 target.css({ "background-image": "none" });
1058 function performGitPull(){
1059 $("#responseId").text("");
1060 if(!event) event = window.event;
1061 var target = $(event.target);
1062 target.val("Processing");
1063 target.css({ "background-image": "url('images/page-loading.gif')" });
1064 target.css({ "background-repeat": "no-repeat" });
1065 target.css({ "background-size": "25px 25px" });
1067 var statusObj = document.getElementById("responseId");
1068 var urlVal = "/gitpull";
1070 .done(function( data ) {
1071 var output = data.output;
1073 output=output.replace(/\n/g,"<br>");
1074 statusObj.innerHTML = output;
1077 .fail(function(err) {
1078 statusObj.innerText = "Failed to do git pull.";
1080 .always(function() {
1081 $("#responseId").show();
1083 target.css({ "background-image": "none" });
1088 function activateClickedTab(idVal) {
1090 $("#filter-tabs-dialog").dialog( "close" );
1091 var ul = $("#workspace-tabs");
1092 ul.children().each(function(){
1094 var link =li.find("a");
1095 var href = link.prop("href");
1096 var hrefId = href.split("#");
1097 if(hrefId[1] == idVal){
1098 link.trigger("click");
1103 function deleteOrRenameTab(idVal) {
1104 $("#filter-tabs-dialog").dialog( "close" );
1105 var ul = $("#workspace-tabs");
1106 ul.children().each(function(){
1108 var link =li.find("a");
1109 var href = link.prop("href");
1110 var hrefId = href.split("#");
1111 if(hrefId[1] == idVal){
1112 link.trigger("click");
1113 link.trigger("dblclick");
1118 function deleteSelectedTab(idVal,title,_module,rpc,version){
1119 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>";
1120 var alertMsg = dgInfo + "<p>Are you sure you want to Delete this Tab ?</p>";
1122 $( "#tabAlertDialog" ).dialog({
1123 dialogClass: "no-close",
1126 /*dialogClass: "alert",*/
1127 title: "Confirm Tab sheet Delete",
1132 class:"alertDialogButton",
1134 var ws = RED.nodes.workspace(idVal);
1135 RED.view.removeWorkspace(ws);
1136 var historyEvent = RED.nodes.removeWorkspace(idVal);
1137 historyEvent.t = 'delete';
1138 historyEvent.dirty = true;
1139 historyEvent.workspaces = [ws];
1140 RED.history.push(historyEvent);
1141 RED.view.dirty(true);
1142 $( this ).dialog( "close" );
1143 $("#filter-tabs-dialog").dialog( "close" );
1144 $("#btn-manage-tabs").trigger("click");
1149 class:"alertDialogButton",
1151 $( this ).dialog( "close" );
1158 function renameSelectedTab(idVal,title,_module,rpc,version){
1159 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>";
1160 var alertMsg = dgInfo + "<p>Change the title and click Rename.</p>";
1162 $( "#tabAlertDialog" ).dialog({
1163 dialogClass: "no-close",
1166 /*dialogClass: "alert",*/
1167 title: "Rename Tab sheet",
1172 class:"alertDialogButton",
1174 var ws = RED.nodes.workspace(idVal);
1175 var label = document.getElementById("tab-name-" + idVal).value;
1176 //console.log("label:" +label);
1177 //console.log("ws.label:" + ws.label);
1178 if (ws.label != label) {
1180 var link = $("#workspace-tabs a[href='#"+idVal+"']");
1181 link.attr("title",label);
1183 RED.view.dirty(true);
1185 $("#tabAlertDialog").dialog('destroy').remove();
1186 //$(this).dialog( "close" );
1187 $("#filter-tabs-dialog").dialog( "close" );
1188 $("#btn-manage-tabs").trigger("click");
1193 class:"alertDialogButton",
1195 $( this ).dialog( "close" );
1202 function performGitStatus(){
1203 $("#responseId").text("");
1204 if(!event) event = window.event;
1205 var target = $(event.target);
1206 target.val("Processing");
1207 target.css({ "background-image": "url('images/page-loading.gif')" });
1208 target.css({ "background-repeat": "no-repeat" });
1209 target.css({ "background-size": "25px 25px" });
1211 var statusObj = document.getElementById("responseId");
1212 var urlVal = "/gitstatus";
1214 .done(function( data ) {
1215 var output = data.output;
1217 output=output.replace(/\n/g,"<br>");
1218 statusObj.innerHTML = output;
1220 //statusObj.innerText = data.output;
1222 .fail(function(err) {
1223 statusObj.innerText = "Failed to do git status.";
1225 .always(function() {
1226 $("#responseId").show();
1227 target.val("Status");
1228 target.css({ "background-image": "none" });
1232 function migrateNodes(jsonStr){
1233 var nodes = JSON.parse(jsonStr);
1234 nodes.forEach( function(node) {
1235 if( node.xml != undefined && node.xml != null && node.xml.indexOf("<service-logic") != -1){
1236 //console.log(node.xml);
1239 module=getAttributeValue(node.xml,"module");
1241 var myRe = new RegExp("module=\"(.*)\" ", "m");
1242 var myArray = myRe.exec(node.xml);
1243 if(myArray != null && myArray[1] != null){
1246 myRe = new RegExp("version=\"(.*)\">", "m");
1247 myArray = myRe.exec(node.xml);
1248 if(myArray != null && myArray[1] != null){
1250 //console.dir(myArray);
1253 version=getAttributeValue(node.xml,"version");
1254 node.type="service-logic";
1255 //node.category="DGEmain";
1257 node.version=version;
1258 if(module != null && version != null){
1259 node.name=module+ " " + version;
1261 console.log("module=" + module);
1262 console.log("version=" + version);
1263 }else if( node.xml != undefined && node.xml != null && node.xml.indexOf("<method") != -1){
1264 var rpc=getAttributeValue(node.xml,"rpc");
1269 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<outcome") != -1){
1270 var uxml = node.xml.toUpperCase();
1271 if(uxml.indexOf("FAILURE") != -1){
1272 node.type="failure";
1273 }else if(uxml.indexOf("SUCCESS") != -1){
1274 node.type="success";
1275 }else if(uxml.indexOf("TRUE") != -1){
1276 node.type="outcomeTrue";
1277 }else if(uxml.indexOf("FALSE") != -1){
1278 node.type="outcomeFalse";
1279 }else if(uxml.indexOf("ALREADY-ACTIVE") != -1){
1280 node.type="already-active";
1281 }else if(uxml.indexOf("NOT-FOUND") != -1){
1282 node.type="not-found";
1286 }else if( node.xml != undefined &&node.xml != null && node.xml.indexOf("<return") != -1){
1287 var uxml = node.xml.toUpperCase();
1288 if(uxml.indexOf("FAILURE") != -1){
1289 node.type="returnFailure";
1290 }else if(uxml.indexOf("SUCCESS") != -1){
1291 node.type="returnSuccess";
1293 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<exists") != -1){
1295 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<break") != -1){
1297 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<block") != -1){
1299 var atomic=getAttributeValue(node.xml,"atomic");
1303 node.name="block : atomic";
1305 node.atomic="false";
1308 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<save") != -1){
1310 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<while") != -1){
1312 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<switch") != -1){
1313 node.type="switchNode";
1314 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<record") != -1){
1316 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<call") != -1){
1318 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<release") != -1){
1319 node.type="release";
1320 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<set") != -1){
1322 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<for") != -1){
1324 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<is-available") != -1){
1325 node.type="is-available";
1326 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<reserve") != -1){
1327 node.type="reserve";
1328 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<get-resource") != -1){
1329 node.type="get-resource";
1330 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<configure") != -1){
1331 node.type="configure";
1332 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<delete") != -1){
1334 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<execute") != -1){
1335 node.type="execute";
1336 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<notify") != -1){
1338 }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<update") != -1){
1341 //console.dir(node);