General housekeeping
This commit is contained in:
@@ -2,8 +2,6 @@ import logging
|
|||||||
|
|
||||||
from core.apirequest import executeRequest
|
from core.apirequest import executeRequest
|
||||||
from core.runtime.runtimecontract import buildRuntimeAttr, buildPreRuntimeAttr
|
from core.runtime.runtimecontract import buildRuntimeAttr, buildPreRuntimeAttr
|
||||||
#from core.runtime.stopsignals import addStopSignal
|
|
||||||
|
|
||||||
|
|
||||||
def buildAction (action, outputs):
|
def buildAction (action, outputs):
|
||||||
action_log = True
|
action_log = True
|
||||||
|
|||||||
@@ -27,16 +27,13 @@ def registerLifecycle(module, lifecycles):
|
|||||||
mode = getattr(module, "mode")
|
mode = getattr(module, "mode")
|
||||||
lifecycles[module.name]["mode"] = mode
|
lifecycles[module.name]["mode"] = mode
|
||||||
else:
|
else:
|
||||||
lifecycles[module.name]["mode"] = {}
|
lifecycles[module.name]["mode"] = "oneshot"
|
||||||
|
|
||||||
#else:
|
|
||||||
# lifecycles[module.name]["mode"] = "oneshot"
|
|
||||||
|
|
||||||
if lifecycles[module.name]["mode"] == "continuous":
|
if lifecycles[module.name]["mode"] == "continuous":
|
||||||
lifecycles[module.name]["refresh_rate"] = module.sleeptime
|
lifecycles[module.name]["refresh_rate"] = module.sleeptime
|
||||||
|
|
||||||
if lifecycles[module.name]["mode"] == {}:
|
#if lifecycles[module.name]["mode"] == {}:
|
||||||
lifecycles[module.name]["mode"] = "oneshot"
|
# lifecycles[module.name]["mode"] = "oneshot"
|
||||||
|
|
||||||
#lifecycles[module.name][registryname] = registryvalue
|
#lifecycles[module.name][registryname] = registryvalue
|
||||||
|
|
||||||
|
|||||||
@@ -32,14 +32,10 @@ def buildListener(listener, self):
|
|||||||
allow, status_code = buildFirewall(listener, outputs)
|
allow, status_code = buildFirewall(listener, outputs)
|
||||||
|
|
||||||
if allow:
|
if allow:
|
||||||
#from core.execution.executioncontract import executeContract
|
|
||||||
from core.execution.createthread import buildThread
|
from core.execution.createthread import buildThread
|
||||||
|
|
||||||
#Print allowed items for logging purposes
|
|
||||||
logging.info(outputs["firewall_allowed"])
|
logging.info(outputs["firewall_allowed"])
|
||||||
|
|
||||||
#Process and forward to RMASS
|
|
||||||
#responses = executeContract(listener.execute, outputs)
|
|
||||||
thread = buildThread(listener.execute)
|
thread = buildThread(listener.execute)
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -10,16 +10,9 @@ showstatus = True
|
|||||||
|
|
||||||
resolve = {
|
resolve = {
|
||||||
"get": {
|
"get": {
|
||||||
#"sender": ["events"],
|
|
||||||
"event_id": ["events", 0, "event_id"],
|
"event_id": ["events", 0, "event_id"],
|
||||||
"room_id": ["events", 0, "room_id"],
|
"room_id": ["events", 0, "room_id"],
|
||||||
},
|
},
|
||||||
# "deconstruct": {
|
|
||||||
# "sender" : [
|
|
||||||
# "#rmass_dm_",
|
|
||||||
# ":loxthelion.com",
|
|
||||||
# ],
|
|
||||||
# },
|
|
||||||
}
|
}
|
||||||
|
|
||||||
keys = [
|
keys = [
|
||||||
|
|||||||
Reference in New Issue
Block a user