Add initialrun to CreateWorkflowInstance

Author: skadefro

OpenFlow/src/Messages/CreateWorkflowInstanceMessage.ts

@@ -13,6 +13,7 @@ export class CreateWorkflowInstanceMessage<T extends Base> implements IReplyMess
     public targetid: string;
     public parentid: string;
     public name: string;
+    public initialrun: boolean;
 
     public payload: any;
 

OpenFlow/src/Messages/Message.ts

@@ -1367,10 +1367,10 @@ export class Message {
             var res2 = await Config.db.InsertOne(_data, "workflow_instances", 1, true, msg.jwt);
             msg.newinstanceid = res2._id;
 
-
-            var message = { _id: res2._id };
-            cli.consumers[0].sendToQueueWithReply(msg.queue, msg.resultqueue, msg.correlationId, message);
-
+            if (msg.initialrun) {
+                var message = { _id: res2._id };
+                cli.consumers[0].sendToQueueWithReply(msg.queue, msg.resultqueue, msg.correlationId, message);
+            }
         } catch (error) {
             cli._logger.error(error);
             if (Util.IsNullUndefinded(msg)) { (msg as any) = {}; }

OpenFlowNodeRED/src/Message.ts

@@ -303,6 +303,7 @@ export class CreateWorkflowInstanceMessage {
     public resultqueue: string;
     public targetid: string;
     public parentid: string;
+    public initialrun: boolean;
 
     public payload: any;
     static assign<T>(o: any): CreateWorkflowInstanceMessage {

OpenFlowNodeRED/src/nodered/nodes/NoderedUtil.ts

@@ -201,9 +201,9 @@ export class NoderedUtil {
         return result;
     }
 
-    public static async CreateWorkflowInstance(targetid: string, workflowid: string, correlationId: string, resultqueue: string, parentid: string, payload: any, jwt: string): Promise<string> {
+    public static async CreateWorkflowInstance(targetid: string, workflowid: string, correlationId: string, resultqueue: string, parentid: string, payload: any, initialrun: boolean, jwt: string): Promise<string> {
         var q: CreateWorkflowInstanceMessage = new CreateWorkflowInstanceMessage();
-        q.targetid = targetid; q.workflowid = workflowid; q.resultqueue = resultqueue;
+        q.targetid = targetid; q.workflowid = workflowid; q.resultqueue = resultqueue; q.initialrun = initialrun;
         q.correlationId = correlationId; q.parentid = parentid; q.jwt = jwt; q.payload = payload;
         var _msg: Message = new Message();
         _msg.command = "createworkflowinstance"; _msg.data = JSON.stringify(q);

OpenFlowNodeRED/src/nodered/nodes/workflow.html

@@ -166,12 +166,18 @@
         </select>
         <input id="node-input-targetid" type="hidden">
     </div>
+    <div class="form-row">
+        <label for="node-input-initialrun"><i class="fa fa-tasks"></i> Initial Run</label>
+        <input type="checkbox" id="node-input-initialrun">
+
+    </div>
 </script>
 <script type="text/x-red" data-help-name="run workflow">
     <p>
         Create a new task asssigned to a user or role.<br>
         You can set Workflow using msg.workflowid<br>
         You can set Target using msg.targetid<br>
+        You can set Initial Run using msg.initialrun<br>
         msg.payload will be sent to the workflow when calling the workflow_forms
         <br><br>
         will return the result in msg.payload when the workflow completes or fails, ( msg.state = "completed" ? "failed" )
@@ -189,7 +195,8 @@
             name: { value: "", required: true },
             queue: { value: "", required: true },
             targetid: { value: "" },
-            workflowid: { value: "" }
+            workflowid: { value: "" },
+            initialrun: { value: false }
         },
         inputs: 1,
         outputs: 2,

OpenFlowNodeRED/src/nodered/nodes/workflow_nodes.ts

@@ -405,6 +405,7 @@ export interface Irun_workflow_node {
     queue: string;
     targetid: string;
     workflowid: string;
+    initialrun: boolean;
 }
 export class run_workflow_node {
     public node: Red = null;
@@ -539,6 +540,11 @@ export class run_workflow_node {
                 var i: WebSocketClient = WebSocketClient.instance;
                 jwt = i.jwt;
             }
+            var initialrun = this.config.initialrun;
+            if (!NoderedUtil.IsNullEmpty(msg.initialrun)) {
+                initialrun = msg.initialrun;
+            }
+
 
             msg.jwt = (await NoderedUtil.RenewToken(jwt, true)).jwt;
             // Logger.instanse.info("run workflow called with id " + msg._id + " (" + msg.name + ")");
@@ -554,7 +560,7 @@ export class run_workflow_node {
             // Logger.instanse.info("created runner instance with id " + res3._id + " (" + res3.name + ")");
             msg._parentid = res3._id;
 
-            msg.newinstanceid = await NoderedUtil.CreateWorkflowInstance(targetid, workflowid, null, resultqueue, res3._id, msg.payload, jwt);;
+            msg.newinstanceid = await NoderedUtil.CreateWorkflowInstance(targetid, workflowid, null, resultqueue, res3._id, msg.payload, initialrun, jwt);;
 
             this.node.send(msg);
             this.node.status({ fill: "green", shape: "dot", text: "Connected" });

VERSION

@@ -1 +1 @@
-0.0.483
+0.0.484