Force fitted strings in arguments for subflow

Author: frikky

azure-sentinel/1.0.0/api.yaml

@@ -243,7 +243,7 @@ actions:
     parameters:
       - name: query 
         description: The query to run
-        multiline: false
+        multiline: true
         example: "SecurityEvent | where EventID == \"4688\" | where CommandLine contains \"-noni -ep bypass $\""
         required: true
         schema:

shuffle-subflow/1.0.0/src/app.py

@@ -34,27 +34,27 @@ def run_subflow(self, user_apikey, workflow, argument, source_workflow="", sourc
         url = "%s/api/v1/workflows/%s/execute" % (self.url, workflow)
 
         params = {}
-        if len(source_workflow) > 0:
+        if len(str(source_workflow)) > 0:
             params["source_workflow"] = source_workflow
         else:
             print("No source workflow")
 
-        if len(source_auth) > 0:
+        if len(str(source_auth)) > 0:
             params["source_auth"] = source_auth
         else:
             print("No source auth")
 
-        if len(source_node) > 0:
+        if len(str(source_node)) > 0:
             params["source_node"] = source_node
         else:
             print("No source node")
 
-        if len(source_execution) > 0:
+        if len(str(source_execution)) > 0:
             params["source_execution"] = source_execution
         else:
             print("No source execution")
 
-        if len(startnode) > 0:
+        if len(str(startnode)) > 0:
             params["start"] = startnode 
         else:
             print("No startnode")
@@ -63,7 +63,7 @@ def run_subflow(self, user_apikey, workflow, argument, source_workflow="", sourc
             "Authorization": "Bearer %s" % user_apikey,
         }
 
-        if len(argument) == 0:
+        if len(str(argument)) == 0:
             ret = requests.post(url, headers=headers, params=params)
         else:
             if not isinstance(argument, list) and not isinstance(argument, object) and not isinstance(argument, dict):
@@ -74,7 +74,7 @@ def run_subflow(self, user_apikey, workflow, argument, source_workflow="", sourc
 
             try:
                 ret = requests.post(url, headers=headers, params=params, json=argument)
-                print(f"Successfully sent argument of length {len(argument)} as JSON")
+                print(f"Successfully sent argument of length {len(str(argument))} as JSON")
             except:
                 try:
                     ret = requests.post(url, headers=headers, json=argument, params=params)