Working resolver tool

core/apirequest/path.py

@@ -6,10 +6,12 @@ def buildPath(path, outputs):
 
     for part in path:
         if isinstance(part, dict):
-            value = outputs[part["output"]]
+            value = outputs[part["output"]][part["keys"]]
 
-            for key in part.get("keys", []):
-                value = value[key]
+            
+
+            #for key in part.get("keys", []):
+                #value = value[key]
 
             result += str(value)
         else:

core/execution/operation/operation.py

@@ -6,6 +6,7 @@ from core.runtime.outputs import buildOutput
 from core.runtime.managefailure import manageFailure
 from core.execution.action.action import buildAction
 from .skipstep import skipStep
+from core.runtime.resolver import resolveItem
 
 def buildOperation(definition):
     actions = definition.actions
@@ -20,15 +21,23 @@ def buildOperation(definition):
                 continue
 
         if hasattr(action, "recursive"):
+            outputs[action.recursive["target"]] = {}
             for item in outputs[action.recursive["source"]]:
+                resolved = resolveItem(action, item)
+                print("Resolved value:", resolved)
+                #outputs[action.recursive["target"]] = outputs[action.recursive["source"]][][action.recursive["target"]]
+                #print(outputs[action.recursive["target"]])
+                outputs[action.recursive["target"]] = item
+                print(outputs[action.recursive["target"]])
                 #target = outputs[action.recursive["source"]["target"]
                 outputs, response = buildAction(action, outputs)
-                #print(outputs["message"])
-                return outputs
-        outputs, response = buildAction(action, outputs)
-        responses.append(response)
+                #print(item)
+                #return outputs
+        else:
+            outputs, response = buildAction(action, outputs)
+            responses.append(response)
             
         #except Exception as error:
             #outputs = manageFailure(error, action, outputs)
-    #print(outputs["message"])
+    print(outputs["message"])
     return outputs

core/runtime/resolver.py

@@ -0,0 +1,22 @@
+def resolveItem(action, item):
+    resolved = {}
+    label = action.resolve["label"]
+    targetkeys = action.resolve["targetkeys"]
+
+    target = item
+    for key in targetkeys:
+        target = target[key]
+
+    resolved[label] = target
+
+    #for label, keys in action.resolve.items():
+        #target = item
+
+        #print(target)
+        #for key in keys:
+            #target = target[key]
+
+        #resolved[label] = target
+        #print(resolved[label])
+
+    return resolved

plugins/rmass/actions/getmessage.py

@@ -18,11 +18,17 @@ method = "GET"
 #    {"output": "[messageid][0].id"}
 #]
 
+resolve = {
+    "targetkeys": ["id"],
+    "label": "path",
+}
+
 path = [
     "https://rentmasseur.com/api/v1/mailbox/",
     {
-        "output": "emails",
-        "keys": [0, "id"]
+        "output": "id",
+        #"keys": [0, "id"]
+        "keys": "id"
     }
 ]
 
@@ -45,15 +51,6 @@ outputs = {
     "message": "messages"
 }
 
-#select = {
-#    "source": "message",
-#    "selectmethod": "include",
-    #"key": "id",
-#    "key": "seen",
-    #"value": {"emails": [0, "id"]},
-#    "value": "false",
-#}
-
 select = {
     "source": "message",
     "include": {

tokens.json

@@ -1 +1 @@
-{"access_token": "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzUxMiJ9.eyJleHAiOjE3OTE4NTc3MTgsIm5iZiI6MTc5MTg1NzUzOCwic3ViIjoiMjM4MzAyIiwidXNlcm5hbWUiOiJYeHhvdGlxIiwidXNlclR5cGUiOjEsInN0YWdlTmFtZSI6Ilh4eG90aXEiLCJhcHByb3ZlZCI6MSwibG9jYXRpb25JZCI6NDcyLCJzZWFyY2hDaXR5IjoiYXRsYW50YSIsImNvdW50cnlTaG9ydCI6IlVTIiwic2Vzc2lvbkNvdW50cnlDb250aW5lbnQiOiJOQSIsImlzRnJvemVuIjowLCJsb2NhdGlvbkxhYmVsIjoiQXRsYW50YSwgR0EiLCJpc3MiOiJodHRwczovL3JlbnRtYXNzZXVyLmNvbSIsImlhdCI6MTc5MTg1NzU5OH0.3TLzOxoQQtnfOuPsLzRjueSDLxQ6w1xSTBdJLfUnVacq6qVEVxj51WfedKO7TXhNyPWtI7WP0e8B1PkGjJsSjA", "refresh_token": "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzUxMiJ9.eyJleHAiOjE3OTQ0NDk1OTgsIm5iZiI6MTc5MTg1NzUzOCwianRpIjoiZmJ6YnNxSlY2RUcrTGc4UGVyZzN5WDdPMWhvaXdGZ25NVkFuU0ZYdFJ6cz0iLCJpc3MiOiJodHRwczovL3JlbnRtYXNzZXVyLmNvbSIsImlhdCI6MTc5MTg1NzU5OCwic3ViIjoiMjM4MzAyIn0.GRlPPC4Ifv-XIrqUNsrBPst5_tW5UIbapGVZOzXroVJDW3F2FMolDNg-0CM_Vrz_uwlyPpnc1aUoAOIIhl2V0w"}
+{"access_token": "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzUxMiJ9.eyJleHAiOjE3OTE5MDM5MDEsIm5iZiI6MTc5MTkwMzcyMSwic3ViIjoiMjM4MzAyIiwidXNlcm5hbWUiOiJYeHhvdGlxIiwidXNlclR5cGUiOjEsInN0YWdlTmFtZSI6Ilh4eG90aXEiLCJhcHByb3ZlZCI6MSwibG9jYXRpb25JZCI6NDcyLCJzZWFyY2hDaXR5IjoiYXRsYW50YSIsImNvdW50cnlTaG9ydCI6IlVTIiwic2Vzc2lvbkNvdW50cnlDb250aW5lbnQiOiJOQSIsImlzRnJvemVuIjowLCJsb2NhdGlvbkxhYmVsIjoiQXRsYW50YSwgR0EiLCJpc3MiOiJodHRwczovL3JlbnRtYXNzZXVyLmNvbSIsImlhdCI6MTc5MTkwMzc4MX0.dwJ10VfIyUSANbKlG0UqzoRqWfZpU0vdUh44IoEbwKeaNPk6d_J6yvrLQy_uY18IfQR_3t4PEp7Qrwa9Eqtyig", "refresh_token": "eyJ0eXAiOiJKV1QiLCJhbGciOiJIUzUxMiJ9.eyJleHAiOjE3OTQ0OTU3ODEsIm5iZiI6MTc5MTkwMzcyMSwianRpIjoiK3pMamtvVlhnN1ZhZmd1OGtib21CQkhxR0R5QmZVdVMxeTgzb0NmQWttcz0iLCJpc3MiOiJodHRwczovL3JlbnRtYXNzZXVyLmNvbSIsImlhdCI6MTc5MTkwMzc4MSwic3ViIjoiMjM4MzAyIn0.q_Bjzys1sCFe29BewT3Ez6cTMvL6vmAwvspSafOmPV980W5Rh2RuytxHnz8JiYj8zGKbi-oM5pNfrOG3gS5Heg"}