diff options
Diffstat (limited to 'dgbuilder/public/util/js/migrateFlow.js')
| -rw-r--r-- | dgbuilder/public/util/js/migrateFlow.js | 184 |
1 files changed, 184 insertions, 0 deletions
diff --git a/dgbuilder/public/util/js/migrateFlow.js b/dgbuilder/public/util/js/migrateFlow.js new file mode 100644 index 00000000..399db606 --- /dev/null +++ b/dgbuilder/public/util/js/migrateFlow.js @@ -0,0 +1,184 @@ +fs=require('fs'); +_=require('lodash'); +//extras=require("/home/users/schinthakayala/nodered/sheshi/dgxml/extras"); +//puts=extras.puts; +var path = require('path'); +var appDir = path.dirname(require.main.filename); + +var dgjson = []; +var level = 0; + +function getJSON() { +var filename = process.argv[2]; + console.log("reading json from flows file" + filename); + //flowsJson=fs.readFileSync(appDir + "/flows_ss4nj01dev01.localdomain.json").toString(); + flowsJson=fs.readFileSync(filename).toString(); + // Let's make a backup while we're here... + ts=Date.now().toString(); + flows=JSON.parse(flowsJson); + //console.log("returning flows"); + return(flows); +} + +function getStartTag(xmlStr){ + var startTag= 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){ + startTag = match[2]; + } + } + }catch(e){ + console.log(e); + } + return startTag; + +} + +function getAttributeValue(xmlStr,attribute){ + var attrVal=null; + try{ + var myRe = new RegExp(attribute + "=['\"](.*)['\"] ","m"); + var myArray = myRe.exec(xmlStr); + if(myArray != null && myArray[1] != null){ + attrVal=myArray[1]; + } + }catch(err){ + console.log(err); + } + return attrVal; +} + +function processNodes(){ + var nodes = getJSON(); + //console.dir(nodes); + + nodes.forEach( function(node) { + if( 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 != 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 != 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 != 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 != null && node.xml.indexOf("<exists") != -1){ + node.type="exists"; + }else if( 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 != null && node.xml.indexOf("<save") != -1){ + node.type="save"; + }else if( node.xml != null && node.xml.indexOf("<switch") != -1){ + node.type="switchNode"; + }else if( node.xml != null && node.xml.indexOf("<record") != -1){ + node.type="record"; + }else if( node.xml != null && node.xml.indexOf("<call") != -1){ + node.type="call"; + }else if( node.xml != null && node.xml.indexOf("<release") != -1){ + node.type="release"; + }else if( node.xml != null && node.xml.indexOf("<set") != -1){ + node.type="set"; + }else if( node.xml != null && node.xml.indexOf("<for") != -1){ + node.type="for"; + }else if( node.xml != null && node.xml.indexOf("<is-available") != -1){ + node.type="is-available"; + }else if( node.xml != null && node.xml.indexOf("<reserve") != -1){ + node.type="reserve"; + }else if( node.xml != null && node.xml.indexOf("<get-resource") != -1){ + node.type="get-resource"; + }else if( node.xml != null && node.xml.indexOf("<configure") != -1){ + node.type="configure"; + }else if( node.xml != null && node.xml.indexOf("<delete") != -1){ + node.type="delete"; + }else if( node.xml != null && node.xml.indexOf("<execute") != -1){ + node.type="execute"; + } + //console.dir(node); + }); +/* + var moduleName = "service-logic"; + var methodName = "method"; + for(var i=0;nodes != null && i<nodes.length;i++){ + if(nodes[i].type == "service-logic"){ + moduleName = nodes[i].name; + } + if(nodes[i].type == "method"){ + methodName = nodes[i].name; + } + } + var fName = moduleName + "_" + methodName + ".json"; + fName = fName.replace(/\s/g, "_"); + + var newFilename = process.argv[3]; + var filename = newFilename + "/" + fName; + console.log("filename" + filename); + fs.writeFileSync(filename, JSON.stringify(nodes,null,4)); + */ +} + + +processNodes(); |