from core.execution.executioncontract import executeContract
from core.execution.action import buildAction
from core.apirequest import executeRequest
from core.runtime.resolver import resolveItem
from core.runtime.applyconditions import applyConditions
from plugins.rmass.actions import login, refresh_tokens
from core.runtime import buildOutput

outputs = {}
resolved = {}
def buildMonitor(monitor, outputs):

    outputs, response = buildAction(refresh_tokens, outputs)    
    outputs, response = buildAction(monitor, outputs)
    
    readitems = resolveItem(monitor, response.json())
    match, filter = applyConditions(monitor, readitems, outputs)
    outputs = buildOutput(response, monitor, outputs)

    if match:
        #print("FILTERING")
        outputs = executeContract(filter["execute"], outputs)
        response, outputs = executeRequest(monitor, outputs, outputs)

    return outputs