added HTTP + Resubmit for FlowService plus details

Author: sagpembo

experimental.js

@@ -41,6 +41,9 @@ var data;
 var type;
 var flowServiceId;
 var scheduleStatus;
+var optionEnable;
+var flowOptionType;
+var incEdgeFlows;
 
 
 const maxRunningWorkflows = 20;
@@ -72,20 +75,77 @@ function init(inDomainName, inUsername, inPassword,inTimeout,inPrettyprint){
 }
 
 
+function flowserviceDetails(inProjectId,includeEdgeFlows)
+{
+    projectId = inProjectId;
+    incEdgeFlows = includeEdgeFlows
+    finalCall = processflowDetails;
+    loginPhase1();
+}
+
+function processflowDetails()
+{
+    debug("Process FlowService Details - Project [" + projectId + "] Include Edge flows [" + incEdgeFlows + "]");
+    var endPoint = "https://" +domainName + "/integration/rest/ut-flow/flow-metadata/" + projectId + "?limit=" + returnCount+ "&skip=" + returnStart;
+    var body;
+    debug("Next URL [" + endPoint + "]");
+    var headers = setHeaders();
+    rest.custom(endPoint,undefined,undefined,timeout,body,undefined,"GET",processResponse,undefined,headers,true,false);  
+}
+
+function flowserviceOption(inFlowServiceId, inEnable, inProjectId,inOptionType)
+{
+    flowServiceId = inFlowServiceId;
+    optionEnable = inEnable;
+    projectId = inProjectId;
+    flowOptionType = inOptionType;
+    finalCall = processflowOption;
+    loginPhase1();
+}
+
+function processflowOption()
+{
+    debug("Process FlowService Option [" + flowOptionType + "] - Project [" + projectId + "] FlowService [" + flowServiceId + "] Enable [" + optionEnable + "]");
+    if(optionEnable!==undefined&&optionEnable!==null&optionEnable.length>1){
+        optionEnable = (optionEnable.toLowerCase()=="true");
+    }
+
+    var endPoint = "https://" +domainName + "/integration/rest/ut-flow/flow/";
+    var body={};
+    if(flowOptionType=="http")
+    {
+        endPoint+= "export/" + flowServiceId +"?projectName="+ projectId ;
+        body = {"integration":{"serviceData":{"stages":[{"stageName":"stage00","markExportable":optionEnable}]}}};
+    }
+    else if(flowOptionType=="resubmit")
+    {
+        endPoint+= "resubmit/" + flowServiceId +"?projectName="+ projectId ;
+        body = {"integration":{"serviceData":{"stages":[{"stageName":"stage00","markResubmittable":optionEnable}]}}};
+    }
+    else
+    {
+        console.log("Unable to determine flow option type: " + flowOptionType);
+        process.exit(1);
+    }
+
+    debug("Next URL [" + endPoint + "]");
+    var headers = setHeaders();
+    rest.custom(endPoint,undefined,undefined,timeout,body,undefined,"PUT",processResponse,undefined,headers,true,false);  
+}
+
+
 function flowserviceScheduler(inFlowServiceId, inScheduleStatus, inProjectId)
 {
     flowServiceId = inFlowServiceId;
     scheduleStatus = inScheduleStatus;
     projectId = inProjectId;
     finalCall = processScheduleStatus;
-    debug("******************Starting FlowService Scheduler");
     loginPhase1();
 }
 
 function processScheduleStatus()
 {
     debug("Process FlowService Schedule Status - Project [" + projectId + "] FlowService [" + flowServiceId + "] Status [" + scheduleStatus + "]");
-
     var endPoint = "https://" +domainName + "/integration/rest/scheduler/"+ scheduleStatus +"/" + flowServiceId +"?projectName="+ projectId ;
     debug("Next URL [" + endPoint + "]");
     var headers = setHeaders();
@@ -1037,4 +1097,4 @@ module.exports = {init,
     connectorAccounts,getProjectAccountConfig,
     getMonitorInfo,workflowResubmit,
     messagingCreate,messagingStats,messagingDelete,
-    vbidAnalysis, flowserviceScheduler};
+    vbidAnalysis, flowserviceScheduler,flowserviceOption,flowserviceDetails};

wmiocli.js

@@ -753,8 +753,8 @@ program.command('experimental-workflow-execution-analysis <vbid> [format]', { hi
   })
 
 
-program.command('experimental-flowservice-scheduler <project-id> <flowservice-id> <schdeule-status>', { hidden: hideExperimental })
-  .description('Provide workflow exedcution analysis')
+program.command('experimental-flowservice-scheduler <project-id> <flowservice-id> <schedule-status>', { hidden: hideExperimental })
+  .description('Enable/Disable FlowService Schedules')
   .action((projectId, flowServiceId,scheduleStatus) => {
     checkOptions();
     //Valid status = pause or resume.
@@ -767,6 +767,45 @@ program.command('experimental-flowservice-scheduler <project-id> <flowservice-id
     experimental.init(tenantDomain, tenantUser, tenantPw, program.opts().timeout, program.opts().prettyprint)
     experimental.flowserviceScheduler(flowServiceId,scheduleStatus,projectId);
   })
+
+program.command('experimental-flowservice-http <project-id> <flowservice-id> <enable>', { hidden: hideExperimental })
+  .description('Enable/Disable FlowService HTTP')
+  .action((projectId, flowServiceId,enable) => {
+    checkOptions();
+    //Valid status = pause or resume.
+    enable = enable.toLowerCase();
+    if(enable != "true" && enable !="false")
+    {
+      console.log("Enable should be set to one of either true or false. You provided: " + enable);
+      process.exit(1);
+    }
+    experimental.init(tenantDomain, tenantUser, tenantPw, program.opts().timeout, program.opts().prettyprint)
+    experimental.flowserviceOption(flowServiceId,enable,projectId,"http");
+  })
+
+  program.command('experimental-flowservice-resubmit <project-id> <flowservice-id> <enable>', { hidden: hideExperimental })
+  .description('Enable/Disable FlowService Resubmit')
+  .action((projectId, flowServiceId,enable) => {
+    checkOptions();
+    //Valid status = pause or resume.
+    enable = enable.toLowerCase();
+    if(enable != "true" && enable !="false")
+    {
+      console.log("Enable should be set to one of either true or false. You provided: " + enable);
+      process.exit(1);
+    }
+    experimental.init(tenantDomain, tenantUser, tenantPw, program.opts().timeout, program.opts().prettyprint)
+    experimental.flowserviceOption(flowServiceId,enable,projectId,"resubmit");
+  })
+
+  program.command('experimental-flowservice-details <project-id>', { hidden: hideExperimental })
+  .description('Get FlowService details from project')
+  .action((projectId) => {
+    checkOptions();
+    experimental.init(tenantDomain, tenantUser, tenantPw, program.opts().timeout, program.opts().prettyprint)
+    experimental.flowserviceDetails(projectId,"false");
+  })  
+
 program.parse();