Extended recursive.py to include recursiveAction and removed commented debug lines. recursiveAction not yet applied

core/runtime/recursive.py

@@ -1,38 +1,39 @@
 from core.execution.action.action import buildAction
-from plugins.rmass.actions import synapsenotify
+from core.runtime.runtimecontract import buildPreRuntimeAttr, buildRuntimeAttr
+from core.apirequest import executeRequest
 
 def recursiveSet(definition, outputs, responses):
     recursiveset = definition.recursiveset["actions"]
     for item in outputs[definition.recursiveset["source"]]:
         outputs[definition.recursiveset["outputlabel"]] = item
 
-        #print("DEBUGGING recursiveset item")
-        #print(outputs[definition.recursiveset["outputlabel"]])
-
         for job in recursiveset:
-            outputs, response = buildAction(job, outputs)
+            outputs, response, match, filter = buildAction(job, outputs)
             responses.append(response)
 
-            #response_data = response.json()
-            #print(f"RECURSIVESET {job.name} DEBUG")
-            #print(response_data)
-    
-            #if response.status_code != 200:
-                #outputs, response = buildAction(synapsenotify, outputs)
-                #print("GETRMASSMESSAGEIDDEBUG")
-                #print(outputs)
     return outputs, responses
 
-from core.execution.action.action import buildAction
+#from core.execution.action.action import buildAction
 
-def recursiveAction(definition, outputs):
+def recursiveAction(action, outputs):
-    recursiveset = definition.recursiveset["actions"]
+    recursiveresponses = []
-    for item in outputs[definition.recursiveset["source"]]:
+    items = outputs[action.recursive["source"]]
-        outputs[definition.recursiveset["outputlabel"]] = item
+    reverse = action.recursive.get("reverse", False)
-        #outputs["recursive"] = item
     
-        for job in recursiveset:
+    if reverse:
-            outputs, response = buildAction(job, outputs)
+        items = reversed(items)
 
+    for item in items:
+        outputs[action.recursive["label"]] = item
 
-    return outputs
+        outputs, resolved, match, filter = buildPreRuntimeAttr(action, outputs)
+
+        if match:
+            continue
+
+        response, outputs = executeRequest(action, outputs, resolved)
+        recursiveresponses.append(response)
+
+        outputs, response = buildRuntimeAttr(action, outputs, resolved, response)
+
+    return outputs, recursiveresponses, match, filter