+++ /dev/null
-function getDgStartNode(nodeList){
- for(var i=0;i<nodeList.length;i++){
- if(nodeList[i].type == 'dgstart' && nodeList[i].wires != null && nodeList[i].wires != undefined){
- return nodeList[i];
- }
- }
- RED.notify("DGSTART node not found.");
- return null;
-}
-
-
-var loopDetectionEnabled = true;
-
-function detectLoopPrev(){
- var activeWorkspace=RED.view.getWorkspace();
- /*
- RED.nodes.links.filter(function(d) {
- if(d.source.z == activeWorkspace && d.target.z == activeWorkspace){
- console.log(d.source.id+":"+d.sourcePort+":"+d.target.id);
- }
- });
- */
- //console.dir(RED.nodes.links);
- var nSet=[];
-
- RED.nodes.eachNode(function(n) {
- if (n.z == activeWorkspace) {
- nSet.push({'n':n});
- }
- });
-
- var nodeSet = RED.nodes.createExportableNodeSet(nSet);
- //console.dir(nodeSet);
-
- //console.log("nodeSet length:" + nodeSet.length);
-
- var isLoopDetected = false;
- var dgStartNode = getDgStartNode(nodeSet);
- if(dgStartNode == null || dgStartNode == undefined) {
- console.log("dgstart node not linked.");
- return true;
- }
-
- var wires = dgStartNode.wires;
- var nodesInPath = {};
- var dgStartNodeId = dgStartNode.id;
- if(wires != null && wires != undefined && wires[0] != undefined){
- for(var k=0;k<wires[0].length;k++){
- var val = wires[0][k];
- nodesInPath[dgStartNodeId + "->" + val] = "";
- }
- }else{
- nodesInPath[dgStartNodeId + "->" + ""] = "";
- }
-
- //console.dir(nodesInPath);
- var loopDetectedObj = {};
- /* the nodes will not be order so will need to loop thru again */
- for(var m=0;nodeSet != null && m<nodeSet.length;m++){
- for(var i=0;nodeSet != null && i<nodeSet.length;i++){
- var link=nodeSet[i].id;
- //console.log("NAME:" + nodeSet[i].name + ":" + link);
- if(link == dgStartNodeId) continue;
- var wires = nodeSet[i].wires;
- //console.log("link:" + link);
- var delKeys = [];
- if(wires != null && wires != undefined && wires[0] != undefined){
- for(var k=0;k<wires[0].length;k++){
- var val = (wires[0])[k];
- var keys = Object.keys(nodesInPath);
- //console.log("keys:" + keys);
- for (var j=0;j<keys.length;j++){
- //console.log("key:" + keys[j]);
- //console.log("val:" + val);
- var index = -1;
- if(keys[j] != null){
- index = keys[j].indexOf("->" + link);
- }
- var lastIndex = keys[j].lastIndexOf("->");
- if(index != -1 && index == lastIndex){
- //delete nodesInPath[key];
- var previousNodeId = keys[j].substr(lastIndex +2);
- var indexOfArrow = -1;
- if(previousNodeId != ""){
- indexOfArrow = previousNodeId.indexOf("->");
- }
- if(previousNodeId != null && indexOfArrow != -1){
- previousNodeId = previousNodeId.substr(0,indexOfArrow);
- }
- nodesInPath[keys[j] + "->" + val] = "";
- //console.log("keys[j]:" + keys[j]);
- delKeys.push(keys[j]);
- var prevNodeIdIndex = keys[j].indexOf("->" + previousNodeId);
- var priorOccurence = keys[j].indexOf(val + "->");
- if(priorOccurence != -1 && priorOccurence<prevNodeIdIndex){
- //console.log("previousNodeId:" + previousNodeId);
- //console.log("val:" + val);
- var n1 = getNode(nodeSet,previousNodeId);
- var n2 = getNode(nodeSet,val);
- //console.log("loop detected for node " + n1.name + " and " + n2.name);
- loopDetectedObj[n1.name + "->" + n2.name] ="looped";
- //console.dir(loopDetectedObj);
- isLoopDetected = true;
- }
- }
- }
- }
- }
- for(var l=0;delKeys != null && l<delKeys.length;l++){
- delete nodesInPath[delKeys[l]];
- }
- }
-
-
- }
- if(loopDetectedObj != null ){
- var msg = "";
- for(var key in loopDetectedObj){
- if(loopDetectedObj.hasOwnProperty(key)) {
- console.log("Loop detected " + key);
- msg += "<strong>Loop detected for:" + key + "</strong><br>";
- }
- }
- if(msg != ""){
- isLoopDetected = true;
- RED.notify(msg);
- }
- }
-/*
- for(var i=0;nodeSet != null && i<nodeSet.length;i++){
- var foundCount=0;
- var nodeId = nodeSet[i].id;
- var nodeName = nodeSet[i].name;
- for(var j=0;nodeSet != null && j<nodeSet.length;j++){
- var node = nodeSet[j];
- if(node.id == nodeId){
- continue;
- }
- var wires = node.wires;
- console.log(node.type + ":wires:" + wires);
- for(var k=0;wires != null && wires != undefined && wires[0] != undefined && k<wires[0].length;k++){
- var id = (wires[0])[k];
- console.log(nodeName + ":" + nodeId + ":" + id);
- if(id == nodeId ){
- foundCount++;
- if(foundCount>1){
- console.log("Loop detected for node " + nodeName + "with node:" + node.name);
- RED.notify("<strong>Flow error detected for node '" + nodeName + "' with node '" + node.name + "'</strong>");
- //RED.nodes.eachLink(function(d){
- // if(d.source.id == nodeSet[i] || d.target.id == nodeSet[j]){
- // d.selected = true;
- // }else if(d.source.id == nodeSet[j] || d.target.id == nodeSet[i]){
- // d.selected = true;
- // }
- //});
- //RED.view.redraw();
- isLoopDetected = true;
- return true;
- }
- }
- }
-
- }
- }
-*/
- //console.log("isLoopDetected:" + isLoopDetected);
- return isLoopDetected;
-}
-
-function generateNodePath(nodeIdToNodeObj,nodeId,pathStr,nodesInPath,errList){
- var node = nodeIdToNodeObj[nodeId];
- var wires = node.wires;
- if(wires != null && wires != undefined && wires[0] != undefined){
- for(var k=0;k<wires[0].length;k++){
- var val = wires[0][k];
- if(pathStr.indexOf(val + "->") != -1){
- //console.log("pathStr:" + pathStr);
- var n1= nodeIdToNodeObj[nodeId].name;
- var n2= nodeIdToNodeObj[val].name;
- errList.push("Loop detected between nodes '" + n1 + "' and " + "'" + n2 + "'");
- }else{
- pathStr += "->" + val ;
- generateNodePath(nodeIdToNodeObj,val,pathStr,nodesInPath,errList);
- }
- }
- }else{
- //pathStr += nodeId + "->" + "";
- nodesInPath.push(pathStr);
- }
-}
-
-function detectLoop(){
- var activeWorkspace=RED.view.getWorkspace();
- var nSet=[];
- var nodeIdToNodeObj = {};
- RED.nodes.eachNode(function(n) {
- if (n.z == activeWorkspace) {
- nSet.push({'n':n});
- }
- });
-
- var nodeSet = RED.nodes.createExportableNodeSet(nSet);
- nodeIdToNodeObj = getNodeIdToNodeMap(nodeSet);
- var isLoopDetected = false;
- //var dgStartNode = getDgStartNode(nodeSet);
- var dgStartNode = nodeIdToNodeObj["dgstart"];
- var errList = [];
- var dgStartNodeId = dgStartNode.id;
- var nodesInPathArr = [];
- generateNodePath(nodeIdToNodeObj,dgStartNodeId,dgStartNodeId,nodesInPathArr,errList);
- if(errList != null && errList != undefined && errList.length > 0){
- isLoopDetected = true;
- var htmlStr="<div id='loop-detect-err-list-div'><table id='loopErrListTable' border='1'><tr><th>Error List</th></tr>";
- for(var j=0;errList != null && j<errList.length;j++){
- var errSeq = j+1;
- htmlStr += "<tr><td>" + errSeq + ")" + errList[j] + "</td></tr>";
- }
- htmlStr += "</table></div>";
-
- $("#loop-detection-dialog").dialog({
- autoOpen : false,
- modal: true,
- title: "DG Flow validation Error List ",
- width: 500,
- buttons: {
- Close: function () {
- $("#loop-detection-dialog").dialog("close");
- }
- }
- }).dialog("open").html(htmlStr); // end dialog div
- }
- nodesInPathArr=null;
- nodeSet ={};
- nodeIdToNodeObj={};
- return isLoopDetected;
-}
-
-
-var xmlNumberCnt = 0;
-function processForXmlNumbers(nodeSet,node){
- if( node != null && node.type != 'dgstart'){
- if(node.xmlnumber != null && node.xmlnumber){
- node.xmlnumber.push(++xmlNumberCnt);
- }else{
- node.xmlnumber = [++xmlNumberCnt];
- }
- }
-
- if(node != null && node.wires != null && node.wires.length>0){
- var wiredNodes=node.wires[0];
- var wiredNodesArr=[];
- for(var k=0;wiredNodes != undefined && wiredNodes != null && k<wiredNodes.length;k++){
- wiredNodesArr.push(getNode(nodeSet,wiredNodes[k]));
- }
-
- //use this sort to sort by y position
- wiredNodesArr.sort(function(a, b){
- return a.y-b.y;
- });
-
- for(var k=0;k<wiredNodesArr.length;k++){
- var n = wiredNodesArr[k];
- processForXmlNumbers(nodeSet,n);
- }
- }
-}
-
-function updateXmlNumbers(){
- xmlNumberCnt = 0;
- var nodeSet = getCurrentFlowNodeSet();
- if(nodeSet == null && nodeSet.length >0){
- nodeSet.forEach(function(n){
- if(n.xmlnumber){
- delete n.xmlnumber;
- }
- });
- }
- var dgStartNode = getDgStartNode(nodeSet);
- processForXmlNumbers(nodeSet,dgStartNode);
- var activeWorkspace=RED.view.getWorkspace();
- RED.nodes.eachNode(function(n) {
- //console.log("Node processed in eachNode");
- if (n.z == activeWorkspace) {
- if(n != null){
- var updatedNode = getNode(nodeSet,n.id);
- //console.log("updated Node processed in eachNode");
- //console.dir(updatedNode);
-
- if (n.id == updatedNode.id) {
- n.xmlnumber = updatedNode.xmlnumber;
- n.dirty = true;
- }
- }
- }
- });
-}
-
-function getOutcomeValue(node){
- var xmlStr = "";
- if(node != null && node.xml != undefined && node.xml !=""){
- xmlStr = node.xml + "</outcome>";
- }
- var xmlDoc;
- if (window.DOMParser){
- try{
- var parser=new DOMParser();
- xmlDoc=parser.parseFromString(xmlStr,'text/xml');
- //console.log("Not IE");
- var n = xmlDoc.documentElement.nodeName;
- if(n == "html"){
- resp=false;
- console.log("Error parsing");
- return resp;
- }
- }catch(e){
- console.log("xmlStr:" + xmlStr);
- console.log("Error parsing" +e);
- return null;
- }
- }else{
- try{
- //console.log("IE");
- // code for IE
- xmlDoc=new ActiveXObject("Microsoft.XMLDOM");
- xmlDoc.async=false;
- xmlDoc.loadXMLString(xmlStr);
- }catch(e){
- console.log("xmlStr:" + xmlStr);
- console.log("Error parsing" +e);
- return null;
- }
- }
- if(xmlDoc != null){
- var xmlNode = xmlDoc.documentElement;
- //console.dir(xmlNode);
- var processedNode = xmlNode.nodeName;
- //console.log("processedNode:" + processedNode);
- var attrs = xmlNode.attributes;
- for(var i=0;i<attrs.length;i++){
- if(attrs[i].nodeName == "value"){
- return attrs[i].value;
- }
- }
- }
- return null;
-}
-
-var dgNumberCnt = 0;
-function processForDgNumbers(nodeSet,node){
- var outcomeTypes = [ "already-active", "failure", "not-found", "other", "outcomeFalse", "outcome", "outcomeTrue", "success" ];
- if( node != null && node.type != 'dgstart' && node.type != 'service-logic' && node.type != 'method' ){
- //console.log("child of " + parentNodeType + " :" + nodeType);
- //check if NOT outcome node
- if(outcomeTypes.indexOf(node.type) == -1){
- if(node.type == "GenericXML"){
- if(node.xml != undefined && node.xml != null && node.xml.indexOf("<outcome ") != -1){
- //this GenericXML node is used for outcome , so need to skip
- }else{
- if(node.dgnumber != undefined && node.dgnumber != null && node.dgnumber){
- node.dgnumber.push(++dgNumberCnt);
- }else{
- node.dgnumber = [++dgNumberCnt];
- }
- }
-
- }else{
- if(node.dgnumber != undefined && node.dgnumber != null && node.dgnumber){
- node.dgnumber.push(++dgNumberCnt);
- }else{
- node.dgnumber = [++dgNumberCnt];
- }
- }
- }
- }
-
- var hasOutcomeNodes = false;
- if(node != null && node.wires != null && node.wires.length>0){
- var wiredNodes=node.wires[0];
- var wiredNodesArr=[];
- for(var k=0;wiredNodes != undefined && wiredNodes != null && k<wiredNodes.length;k++){
- var wiredNode = getNode(nodeSet,wiredNodes[k]);
- //check if outcome node
- if(outcomeTypes.indexOf(wiredNode.type) != -1){
- hasOutcomeNodes = true;
- }
- if(wiredNode.type == "GenericXML"){
- if( node.xml != undefined && node.xml != null && node.xml.indexOf("<outcome ") != -1){
- //this GenericXML node is used for outcome
- hasOutcomeNodes = true;
- }
- }
- wiredNodesArr.push(wiredNode);
-
- }
-
- //use this sort to sort by y position
- wiredNodesArr.sort(function(a, b){
- return a.y-b.y;
- });
-
- /*
- //USE THIS LOGIC TO SORT BY OUTCOME VALUE FOR SPECIFIC NODES
- var parentNodeType = node.type;
- if(hasOutcomeNodes && parentNodeType != 'switchNode' && parentNodeType != 'block' && parentNodeType != 'configure' ){
- //use the value of outcome to sort the wired nodes
- wiredNodesArr.sort(function(a, b){
- var val1 = getOutcomeValue(a);
- var val2 = getOutcomeValue(b);
- //console.log("val1:" + val1);
- //console.log("val2:" + val2);
- if ( val1 < val2 ){
- return -1;
- }else if ( val1 > val2 ){
- return 1;
- }else{
- return 0;
- }
- });
- }else{
- //use this sort to sort by y position
- wiredNodesArr.sort(function(a, b){
- return a.y-b.y;
- });
- }
-
- */
-
- for(var k=0;k<wiredNodesArr.length;k++){
- var n = wiredNodesArr[k];
- processForDgNumbers(nodeSet,n);
- }
- }
-}
-
-function updateDgNumbers(){
- dgNumberCnt = 0;
- var nodeSet = getCurrentFlowNodeSet();
- if(nodeSet == null && nodeSet.length >0){
- nodeSet.forEach(function(n){
- if(n.dgnumber){
- delete n.dgnumber;
- }
- });
- }
- var dgStartNode = getDgStartNode(nodeSet);
- processForDgNumbers(nodeSet,dgStartNode);
- var activeWorkspace=RED.view.getWorkspace();
- RED.nodes.eachNode(function(n) {
- //console.log("Node processed in eachNode");
- if (n.z == activeWorkspace) {
- if(n != null){
- var updatedNode = getNode(nodeSet,n.id);
- //console.log("updated Node processed in eachNode");
- //console.dir(updatedNode);
-
- if (n.id == updatedNode.id) {
- //console.log(n.type + ":" + updatedNode.dgnumber);
- n.dgnumber = updatedNode.dgnumber;
- n.dirty = true;
- }
- }
- }
- });
- return nodeSet;
-}
-
-function customValidation(currNodeSet){
- //validation to make sure there a block node infront of mutiple dgelogic nodes
- flowDesignErrors=[];
- var dgStartCnt=0;
- var serviceLogicCnt=0;
- var methodCnt=0;
- for(var i=0;currNodeSet != null && i<currNodeSet.length;i++){
- var node = currNodeSet[i];
- var parentNodeName = node.name;
- var parentNodeType = node.type;
- var dgNumber = node.dgnumber;
- if(parentNodeType == 'dgstart'){
- dgStartCnt++;
- }
- if(parentNodeType == 'service-logic'){
- serviceLogicCnt++;
- }
- if(parentNodeType == 'method'){
- methodCnt++;
- }
- if(parentNodeType == "GenericXML"){
- if( node.xml != undefined && node.xml != null && node.xml.indexOf("<service-logic ") != -1 ){
- //this GenericXML node is used for service-logic
- serviceLogicCnt++;
- }else if( node.xml != undefined && node.xml != null && node.xml.indexOf("<method ") != -1 ){
- //this GenericXML node is used for method
- methodCnt++;
- }else if( node.xml != undefined && node.xml != null && node.xml.indexOf("<block") != -1 ){
- //this GenericXML node is used for block
- parentNodeType = "block";
- }
- }
- if(node != null && node.wires != null && node.wires.length>0){
- var wiredNodes=node.wires[0];
- var wiredNodesArr=[];
- for(var k=0;wiredNodes != undefined && wiredNodes != null && k<wiredNodes.length;k++){
- wiredNodesArr.push(getNode(currNodeSet,wiredNodes[k]));
- }
- var countChildLogicNodes =0;
- for(var k=0;k<wiredNodesArr.length;k++){
- var n = wiredNodesArr[k];
- var nodeType = n.type;
- var outcomeTypes = [ "already-active", "failure", "not-found", "other", "outcomeFalse", "outcome", "outcomeTrue", "success" ];
- var isOutcomeOrSetNode = false;
- if(nodeType == "GenericXML"){
- if( n.xml != undefined && n.xml != null && (n.xml.indexOf("<outcome ") != -1 || n.xml.indexOf("<set ") != -1)){
- //this GenericXML node is used for outcome
- isOutcomeOrSetNode = true;
- }
- }
- //console.log("child of " + parentNodeType + " :" + nodeType);
- if(outcomeTypes.indexOf(nodeType) > -1 ||nodeType == 'set' || isOutcomeOrSetNode){
- //its a outcome or set node
- }else{
- countChildLogicNodes++;
- }
-
- //console.log("parentNodeType:" + parentNodeType);
- if(countChildLogicNodes >1 && parentNodeType != 'block' && parentNodeType != 'for' ){
- if(node.dgnumber != undefined && node.dgnumber){
- 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] );
- }else{
- flowDesignErrors.push("Warning:May need a block Node after Node <br><span style='color:red'>Node name:</span>" + parentNodeName);
- }
- break;
- }
- }
- }
- }
- if(dgStartCnt > 1){
- flowDesignErrors.push("Error:There should only be 1 dgstart Node in the current workspace.");
- }
-
- if(serviceLogicCnt > 1){
- flowDesignErrors.push("Error:There should only be 1 service-logic Node in the current workspace.");
- }
-
- if(methodCnt > 1){
- flowDesignErrors.push("Error:There should only be 1 method Node in the current workspace.");
- }
-
- if(flowDesignErrors != null && flowDesignErrors.length >0){
- return false;
- }
- return true;
-}
-
-var flowDesignErrors = [];
-function showFlowDesignErrorBox(){
- if(flowDesignErrors != null && flowDesignErrors.length >0){
- var htmlStr="<div id='flowpath-err-list-div'><table id='fpeTable' border='1'><tr><th>Error List</th></tr>";
- for(var j=0;flowDesignErrors != null && j<flowDesignErrors.length;j++){
- var errSeq = j+1;
- htmlStr += "<tr><td>" + errSeq + ")" + flowDesignErrors[j] + "</td></tr>";
- }
- htmlStr += "</table></div>";
-
- //$('<div></div>').dialog({
-
- $('#flow-design-err-dialog').dialog({
- modal: true,
- title: "Flow design Error List ",
- width: 500,
- /*open: function () {
- $(this).html(htmlStr);
- },*/
- buttons: {
- Close: function () {
- $(this).dialog("close");
- }
- }
- }).html(htmlStr); // end dialog div
- }
-}
-
-
-function getCurrentFlowNodeSet(){
- var nodeSet=[];
- //console.dir(RED);
- //RED.view.dirty();
- //RED.view.redraw();
- var activeWorkspace=RED.view.getWorkspace();
- RED.nodes.eachNode(function(n) {
- if (n.z == activeWorkspace) {
- nodeSet.push({'n':n});
- }
- });
-
- var exportableNodeSet = RED.nodes.createExportableNodeSet(nodeSet);
- //console.dir(exportableNodeSet);
- //console.log(JSON.stringify(exportableNodeSet));
- return exportableNodeSet;
-}
-
-function getNode(nodeSet,id){
- for(var i=0;i<nodeSet.length;i++){
- if(nodeSet[i].id == id){
- return nodeSet[i];
- }
- }
- return null;
-}
-function getNodeIdToNodeMap(nodeSet){
- var nodeIdToNodeMap ={};
- for(var i=0;i<nodeSet.length;i++){
- nodeIdToNodeMap[nodeSet[i].id] = nodeSet[i];
- if(nodeSet[i].type == "dgstart"){
- nodeIdToNodeMap["dgstart"] = nodeSet[i];
- }
- }
- return nodeIdToNodeMap;
-}
-
-function validateEachNodeXml(){
- var activeWorkspace=RED.view.getWorkspace();
- RED.nodes.eachNode(function(n) {
- if (n.z == activeWorkspace) {
- var xml = n.xml;
- if( xml != null && xml != ''){
- var validationSuccess = validateXML(n.xml);
- if(validationSuccess){
- n.status = {fill:"green",shape:"dot",text:"OK"};
- }else{
- n.status = {fill:"red",shape:"dot",text:"ERROR"};
- }
- }
- }
- });
-}
-
-
-function getNodeToXml(inputNodeSet){
- var exportableNodeSet;
- //uses inputNodeSet if passed otherwise build the latest nodeSet
-
- //$("#btn-deploy").removeClass("disabled");
-
-
- function getNode(id){
- for(var i=0;i<exportableNodeSet.length;i++){
- if(exportableNodeSet[i].id == id){
- return exportableNodeSet[i];
- }
- }
- return null;
- }
-
- function getStartTag(node){
- var startTag="";
- var xmlStr="";
- if(node != null && node.type != 'dgstart'){
- xmlStr=node.xml;
- var regex = /(<)([\w-]+)(.*)?/;
- var match = regex.exec(xmlStr);
- if(match != null){
- if(match[1] != undefined && match[2] != undefined){
- startTag = match[2];
- }
- }else{
- console.log("startTag not found.");
- }
- }
- return startTag;
- }
-
- if(inputNodeSet == null || inputNodeSet == undefined){
- exportableNodeSet = getCurrentFlowNodeSet();
- }else{
- exportableNodeSet = JSON.parse(inputNodeSet);
- }
- var dgstartNode = getDgStartNode(exportableNodeSet);
-
- var level=0;
- var fullXmlStr="";
-
- printXml(dgstartNode);
-
-
- function printXml(node){
- var xmlStr="";
- var startTag = "";
- if(node != null && node.type != 'dgstart'){
- var comments=node.comments;
- if(comments != null && comments != ""){
- //if xml comments field already has the <!-- and --> remove them
- comments=comments.replace("<!--","");
- comments=comments.replace("-->","");
- xmlStr="<!--" + comments + "-->";
- }
- xmlStr+=node.xml;
- startTag = getStartTag(node);
- fullXmlStr +=xmlStr;
- /*
- if(level > 0){
- var spacing = Array(level).join(" ");
- xmlStr=xmlStr.replace(/\n/g,spacing);
- fullXmlStr +=xmlStr;
-
- console.log(xmlStr);
- }else{
- fullXmlStr +=xmlStr;
- console.log(xmlStr);
- }
- */
- }
-
- //console.log("startTag:" + startTag);
-
- var wiredNodes = [];
- var wiredNodesArr = [];
- if(node != null && node.wires != null && node.wires[0] != null && node.wires[0] != undefined && node.wires[0].length >0 ){
- wiredNodes=node.wires[0];
- //console.log("Before sort");
- for(var k=0;wiredNodes != undefined && wiredNodes != null && k<wiredNodes.length;k++){
- wiredNodesArr.push(getNode(wiredNodes[k]));
- }
- //console.dir(wiredNodesArr);
- //sort based on y position
- wiredNodesArr.sort(function(a, b){
- return a.y-b.y;
- });
- //console.log("After sort");
- //console.dir(wiredNodesArr);
- }
-
- for(var k=0;wiredNodesArr != null && k<wiredNodesArr.length;k++){
- level++;
- var nd = wiredNodesArr[k];
- printXml(nd);
- }
-
- //append end tag
- if(startTag != ""){
- fullXmlStr += "</" + startTag + ">";
- /*
- if(level >0){
- var spacing = Array(level).join(" ");
- fullXmlStr += spacing + "</" + startTag + ">";
- console.log(spacing + "</" + startTag + ">");
- }else{
- fullXmlStr += "</" + startTag + ">";
- console.log("</" + startTag + ">");
- }
- */
- }
-
- /*if(level>0){
- level=level-1;
- }
- */
- //console.log("endTag:" + startTag);
- //console.log("xml:" + fullXmlStr);
- }
- //console.log("fullXmlStr:" + fullXmlStr);
- return fullXmlStr;
-}
-
-function showFlow(filePath){
-var jqxhr = $.post( "/getSharedFlow",{"filePath":filePath})
- .done(function(data) {
- $( "#dgflow-browser-dialog").dialog("close");
- var migratedNodes = migrateNodes(data);
- //RED.view.importNodes(data)
- RED.view.importNodes(JSON.stringify(migratedNodes));
- //console.log( "import done");
- })
- .fail(function() {
- RED.notify("Could not import user flow .");
- $( "#dgflow-browser-dialog").dialog("close");
- console.log( "error occured importing flow.");
- })
- .always(function() {
- //console.log( "complete" );
- });
-}
-
-function showFlowXml(filePath){
-var jqxhr = $.post( "/getSharedFlow",{"filePath":filePath})
- .done(function(data) {
- //console.dir(data);
- var xmlStr=getNodeToXml(data);
- showImportedXml(xmlStr,this);
- })
- .fail(function() {
- RED.notify("Could not convert to XML.");
- $( "#dgflow-browser-dialog").dialog("close");
- console.log( "error occured importing flow.");
- })
- .always(function() {
- //console.log( "complete" );
- });
-}
-
-function showFlowFiles(userName){
- //var divStyle="color:#07c; margin-bottom: 1.2em; font-size: 16px;";
- //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>";
- 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>";
-
- var htmlStr=divStyle + "<div class='header'>List of Flow files of User " + userName + "</div><div id='data-container'><ul>" ;
- $.post( "/getFiles/" + userName)
- .done(function( data ) {
- //console.dir(data);
- //console.log("found " + data.length + " files");
- if(data != null && data.length != undefined && data.length != 0){
- if(data != null && data.length>0){
- for(var k=0;k<data.length;k++){
- htmlStr += "<li><a href=\"#\" onclick=\"showFlow('" +data[k].filePath + "')\">" + data[k].name + "</a></li>";
- /*
- //Use this code to display the View Xml Link
- 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>";
- */
- }
- htmlStr+="</ul></div>";
- }
- $( "#dgflow-browser-dialog").html(htmlStr);
- }else{
- //console.log("no flow files found for user " + userName);
- 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>";
- $( "#dgflow-browser-dialog").html(noFlowFilesHtml);
- }
- })
- .fail(function(err) {
- console.log( "error" + err );
- })
- .always(function() {
- //console.log("done");
- });
-
-}
-
- function closeAndShowFlowShareUsers(){
- $("#dgflow-browser-dialog").dialog( "close" );
- 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>";
- $.get( "/flowShareUsers")
- .done(function( data ) {
-
- var header="<div class='header'>List of downloaded DG Flows </div>";
- var html= divStyle + header + "<div id='data-container'>";
- html+="<ul>";
- if(data != null){
- var users=data.flowShareUsers;
- users.sort(function (a,b){
- if(a.name > b.name){
- return 1;
- }else if(a.name < b.name){
- return -1;
- }else{
- return 0;
- }
- });
- for(var i=0;users != null && i<users.length;i++){
- html+="<li><a href=\"#\" onclick=\"showFlowFiles('" + users[i].rootDir + "')\">" + users[i].name + "</a></li>";
- }
- }
- html+="</ul>";
- html+="</div>";
- $( "#dgflow-browser-dialog" ).dialog({
- title: "Dowloaded DG Flow Browser",
- modal: true,
- autoOpen: true,
- width: 530,
- height: 530,
- buttons: [
- {
- text: "Close",
- click: function() {
- $( this ).dialog( "close" );
- }
- }
- ]
- }).html(html);
- $("#dgflow-browser-dialog").show();
- })
- .fail(function(err) {
- RED.notify("Failed to get users.");
- })
- .always(function() {
- });
- }
-
-function showImportedXml(xmlStr,dialogBox){
- var formattedXml=vkbeautify.xml(xmlStr);
- var that = dialogBox;
- require(["orion/editor/edit"], function(edit) {
- that.editor = edit({
- parent:document.getElementById('dgflow-browser-dialog'),
- lang:"html",
- readonly:true,
- contents: formattedXml
- });
- RED.library.create({
- url:"functions", // where to get the data from
- type:"function", // the type of object the library is for
- editor:that.editor, // the field name the main text body goes to
- fields:['name','outputs']
- });
- });
-}
-
-function getTag(xmlStr){
- var tag= null ;
- if(xmlStr != null){
- xmlStr = xmlStr.trim();
- }
- try{
- var regex = new RegExp("(<)([^ >]+)");
- var match = regex.exec(xmlStr);
- if(match != null){
- if(match[1] != undefined && match[2] != undefined){
- tag = match[2];
- }
- }
- }catch(e){
- console.log(e);
- }
- return tag;
-
-}
-
-function getAttributeValue(xmlStr,attribute){
-
- var attrVal=null;
- try{
- var myRe = new RegExp(attribute + "[\s+]?=[\s+]?['\"]([^'\"]+)['\"]","m");
- var myArray = myRe.exec(xmlStr);
- if(myArray != null && myArray[1] != null){
- attrVal=myArray[1];
- }
- }catch(err){
- console.log(err);
- }
- return attrVal;
-}
-
-function showOrHideTab(checkbox,idVal){
-
- var activeWorkspace=RED.view.getWorkspace();
- var table = $("#ftab02");
- $('td input:checkbox',table).each(function(i){
- console.log(this.checked);
- });
- //console.dir($('td input:checkbox',table).prop('checked',this.checked));
-
- $(".red-ui-tabs li a").each(function(i){
- var id=$(this).attr("href").replace('#','');
- if(id == idVal){
- $(this).parent().toggle();
- var isVisible = $(this).parent().is(":visible");
- if(isVisible){
- checkbox.checked = true;
- }else{
- checkbox.checked = false;
- }
- if(activeWorkspace == id){
- //$("#chart").hide();
- //var li = ul.find("a[href='#"+id+"']").parent();
- var li = $(this).parent();
- if (li.hasClass("active")) {
- li.removeClass("active");
- if(li.parent().children().size() != 0){
- }
- console.log("has Class active");
- var tab = li.prev();
- if (tab.size() === 0) {
- console.log("li prev size 0");
- tab = li.next();
- }
- if(tab.is(":visible")){
- console.log("added active");
- tab.addClass("active");
- tab.click();
- //tab.trigger("click");
- }
- //console.dir(tab);
- //tab.parent().addClass("active");
- //tab.click();
- }
- }else{
- console.log("added active id" +id);
- if(isVisible){
- var li = $(this).parent();
- li.addClass("active");
- li.click();
- //console.dir(li);
- }else{
- var li = $(this).parent();
- li.removeClass("active");
- }
- }
- }
- });
-/*
- $(".red-ui-tabs li a").each(function(i){
- var id=$(this).attr("href").replace('#','');
- if(id != idVal){
- $(this).trigger("click");
- if(activeWorkspace == idVal){
- $("#chart").show();
- }
- return false;
- }
- });
-*/
-}
-
-function performGitCheckout(){
- $("#responseId").text("");
- if(!event) event = window.event;
- var target = $(event.target);
- target.val("Processing");
- target.css({ "background-image": "url('images/page-loading.gif')" });
- target.css({ "background-repeat": "no-repeat" });
- target.css({ "background-size": "25px 25px" });
-
- var branch = document.getElementById("branchId").value.trim();
- var statusObj = document.getElementById("responseId");
- if(branch == null || branch == ''){
- statusObj.innerText = "Branch is required.";
- return;
- }
- var urlVal = "/gitcheckout?branch=" + branch;
- $.get(urlVal)
- .done(function( data ) {
- var output = data.output;
- if(output != null){
- output=output.replace(/\n/g,"<br>");
- statusObj.innerHTML = output;
- }
- })
- .fail(function(err) {
- statusObj.innerText = "Failed to do git checkout.";
- })
- .always(function() {
- $("#responseId").show();
- target.val("Checkout");
- target.css({ "background-image": "none" });
- });
-}
-
-function performGitPull(){
- $("#responseId").text("");
- if(!event) event = window.event;
- var target = $(event.target);
- target.val("Processing");
- target.css({ "background-image": "url('images/page-loading.gif')" });
- target.css({ "background-repeat": "no-repeat" });
- target.css({ "background-size": "25px 25px" });
-
- var statusObj = document.getElementById("responseId");
- var urlVal = "/gitpull";
- $.get(urlVal)
- .done(function( data ) {
- var output = data.output;
- if(output != null){
- output=output.replace(/\n/g,"<br>");
- statusObj.innerHTML = output;
- }
- })
- .fail(function(err) {
- statusObj.innerText = "Failed to do git pull.";
- })
- .always(function() {
- $("#responseId").show();
- target.val("Pull");
- target.css({ "background-image": "none" });
- });
-}
-
-
-function activateClickedTab(idVal) {
-
- $("#filter-tabs-dialog").dialog( "close" );
- var ul = $("#workspace-tabs");
- ul.children().each(function(){
- var li = $(this);
- var link =li.find("a");
- var href = link.prop("href");
- var hrefId = href.split("#");
- if(hrefId[1] == idVal){
- link.trigger("click");
- }
- });
-}
-
-function deleteOrRenameTab(idVal) {
- $("#filter-tabs-dialog").dialog( "close" );
- var ul = $("#workspace-tabs");
- ul.children().each(function(){
- var li = $(this);
- var link =li.find("a");
- var href = link.prop("href");
- var hrefId = href.split("#");
- if(hrefId[1] == idVal){
- link.trigger("click");
- link.trigger("dblclick");
- }
- });
-}
-
-function deleteSelectedTab(idVal,title,_module,rpc,version){
- 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>";
- var alertMsg = dgInfo + "<p>Are you sure you want to Delete this Tab ?</p>";
-
-$( "#tabAlertDialog" ).dialog({
- dialogClass: "no-close",
- modal:true,
- draggable : true,
- /*dialogClass: "alert",*/
- title: "Confirm Tab sheet Delete",
- width: 600,
- buttons: [
- {
- text: "Delete",
- class:"alertDialogButton",
- click: function() {
- var ws = RED.nodes.workspace(idVal);
- RED.view.removeWorkspace(ws);
- var historyEvent = RED.nodes.removeWorkspace(idVal);
- historyEvent.t = 'delete';
- historyEvent.dirty = true;
- historyEvent.workspaces = [ws];
- RED.history.push(historyEvent);
- RED.view.dirty(true);
- $( this ).dialog( "close" );
- $("#filter-tabs-dialog").dialog( "close" );
- $("#btn-manage-tabs").trigger("click");
- }
- },
- {
- text: "Cancel",
- class:"alertDialogButton",
- click: function() {
- $( this ).dialog( "close" );
- }
- }
- ]
-}).html(alertMsg);
-}
-
-function renameSelectedTab(idVal,title,_module,rpc,version){
- 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>";
- var alertMsg = dgInfo + "<p>Change the title and click Rename.</p>";
-
-$( "#tabAlertDialog" ).dialog({
- dialogClass: "no-close",
- modal:true,
- draggable : true,
- /*dialogClass: "alert",*/
- title: "Rename Tab sheet",
- width: 600,
- buttons: [
- {
- text: "Rename",
- class:"alertDialogButton",
- click: function() {
- var ws = RED.nodes.workspace(idVal);
- var label = document.getElementById("tab-name-" + idVal).value;
- //console.log("label:" +label);
- //console.log("ws.label:" + ws.label);
- if (ws.label != label) {
- ws.label = label;
- var link = $("#workspace-tabs a[href='#"+idVal+"']");
- link.attr("title",label);
- link.text(label);
- RED.view.dirty(true);
- }
- $("#tabAlertDialog").dialog('destroy').remove();
- //$(this).dialog( "close" );
- $("#filter-tabs-dialog").dialog( "close" );
- $("#btn-manage-tabs").trigger("click");
- }
- },
- {
- text: "Cancel",
- class:"alertDialogButton",
- click: function() {
- $( this ).dialog( "close" );
- }
- }
- ]
-}).html(alertMsg);
-}
-
-function performGitStatus(){
- $("#responseId").text("");
- if(!event) event = window.event;
- var target = $(event.target);
- target.val("Processing");
- target.css({ "background-image": "url('images/page-loading.gif')" });
- target.css({ "background-repeat": "no-repeat" });
- target.css({ "background-size": "25px 25px" });
-
- var statusObj = document.getElementById("responseId");
- var urlVal = "/gitstatus";
- $.get(urlVal)
- .done(function( data ) {
- var output = data.output;
- if(output != null){
- output=output.replace(/\n/g,"<br>");
- statusObj.innerHTML = output;
- }
- //statusObj.innerText = data.output;
- })
- .fail(function(err) {
- statusObj.innerText = "Failed to do git status.";
- })
- .always(function() {
- $("#responseId").show();
- target.val("Status");
- target.css({ "background-image": "none" });
- });
-}
-
-function migrateNodes(jsonStr){
- var nodes = JSON.parse(jsonStr);
- nodes.forEach( function(node) {
- if( node.xml != undefined && node.xml != null && node.xml.indexOf("<service-logic") != -1){
- //console.log(node.xml);
- var module="";
- var version="";
- module=getAttributeValue(node.xml,"module");
- /*
- var myRe = new RegExp("module=\"(.*)\" ", "m");
- var myArray = myRe.exec(node.xml);
- if(myArray != null && myArray[1] != null){
- module=myArray[1];
- }
- myRe = new RegExp("version=\"(.*)\">", "m");
- myArray = myRe.exec(node.xml);
- if(myArray != null && myArray[1] != null){
- version=myArray[1];
- //console.dir(myArray);
- }
- */
- version=getAttributeValue(node.xml,"version");
- node.type="service-logic";
- //node.category="DGEmain";
- node.module=module;
- node.version=version;
- if(module != null && version != null){
- node.name=module+ " " + version;
- }
- console.log("module=" + module);
- console.log("version=" + version);
- }else if( node.xml != undefined && node.xml != null && node.xml.indexOf("<method") != -1){
- var rpc=getAttributeValue(node.xml,"rpc");
- node.type="method";
- if(rpc != null){
- node.name=rpc;
- }
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<outcome") != -1){
- var uxml = node.xml.toUpperCase();
- if(uxml.indexOf("FAILURE") != -1){
- node.type="failure";
- }else if(uxml.indexOf("SUCCESS") != -1){
- node.type="success";
- }else if(uxml.indexOf("TRUE") != -1){
- node.type="outcomeTrue";
- }else if(uxml.indexOf("FALSE") != -1){
- node.type="outcomeFalse";
- }else if(uxml.indexOf("ALREADY-ACTIVE") != -1){
- node.type="already-active";
- }else if(uxml.indexOf("NOT-FOUND") != -1){
- node.type="not-found";
- }else{
- node.type="other";
- }
- }else if( node.xml != undefined &&node.xml != null && node.xml.indexOf("<return") != -1){
- var uxml = node.xml.toUpperCase();
- if(uxml.indexOf("FAILURE") != -1){
- node.type="returnFailure";
- }else if(uxml.indexOf("SUCCESS") != -1){
- node.type="returnSuccess";
- }
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<exists") != -1){
- node.type="exists";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<block") != -1){
- node.type="block";
- var atomic=getAttributeValue(node.xml,"atomic");
-
- if(atomic=='true'){
- node.atomic="true";
- node.name="block : atomic";
- }else{
- node.atomic="false";
- node.name="block";
- }
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<save") != -1){
- node.type="save";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<switch") != -1){
- node.type="switchNode";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<record") != -1){
- node.type="record";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<call") != -1){
- node.type="call";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<release") != -1){
- node.type="release";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<set") != -1){
- node.type="set";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<for") != -1){
- node.type="for";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<is-available") != -1){
- node.type="is-available";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<reserve") != -1){
- node.type="reserve";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<get-resource") != -1){
- node.type="get-resource";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<configure") != -1){
- node.type="configure";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<delete") != -1){
- node.type="delete";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<execute") != -1){
- node.type="execute";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<notify") != -1){
- node.type="notify";
- }else if(node.xml != undefined && node.xml != null && node.xml.indexOf("<update") != -1){
- node.type="update";
- }
- //console.dir(node);
- });
- return nodes;
-}
Code Review / sdnc / oam.git / blobdiff