Created monitor execution shell
This commit is contained in:
@@ -0,0 +1,25 @@
|
|||||||
|
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
|
||||||
Reference in New Issue
Block a user