from core.execution.action.action import buildAction
from plugins.rmass.actions import synapsenotify

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)
            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

def recursiveAction(definition, outputs):
    recursiveset = definition.recursiveset["actions"]
    for item in outputs[definition.recursiveset["source"]]:
        outputs[definition.recursiveset["outputlabel"]] = item
        #outputs["recursive"] = item

        for job in recursiveset:
            outputs, response = buildAction(job, outputs)


    return outputs