From 63330c9ecde670c3512cd53c895ac4f74d271ea4 Mon Sep 17 00:00:00 2001
From: Lyncoln <arcticfoxx_dlf@hotmail.com>
Date: Fri, 30 Oct 2026 02:18:24 -0400
Subject: [PATCH] Imported outputs from external module to facilitate thread
 building and consistent runtime operation from various entrypoints

---
 core/execution/executioncontract.py                 | 3 +++
 core/execution/lifecyclemanager/lifecyclemanager.py | 3 ++-
 core/execution/operation/operation.py               | 2 +-
 core/runtime/createruntime.py                       | 4 ++++
 core/server/createlistener.py                       | 9 ++++++---
 5 files changed, 16 insertions(+), 5 deletions(-)
 create mode 100644 core/runtime/createruntime.py

diff --git a/core/execution/executioncontract.py b/core/execution/executioncontract.py
index 50a8b6a..0bb2718 100644
--- a/core/execution/executioncontract.py
+++ b/core/execution/executioncontract.py
@@ -3,8 +3,11 @@ from core.execution.operation import buildOperation
 from core.execution.monitor import buildMonitor
 #from core.runtime import manageFailure
 from core.execution.recursive import buildRecursive
+#from core.runtime.createruntime import outputs
 
 def executeContract(module, outputs):
+    #print(outputs)
+
 
     if module.kind == "operation":
 
diff --git a/core/execution/lifecyclemanager/lifecyclemanager.py b/core/execution/lifecyclemanager/lifecyclemanager.py
index 2cf2dd9..2faf25d 100644
--- a/core/execution/lifecyclemanager/lifecyclemanager.py
+++ b/core/execution/lifecyclemanager/lifecyclemanager.py
@@ -6,9 +6,10 @@ from core.apirequest.execute import getSession
 from core.execution.lifecyclemanager.lifecycleregistry import registerLifecycle
 
 lifecycles = {}
-outputs = {}
+#outputs = {}
 
 def manageLifecycle(module):
+    from core.runtime.createruntime import outputs
     lifecycle_log = os.environ.get("LOGS_LIFECYCLE", "false").lower() == "true"
 
     registerLifecycle (module, lifecycles)
diff --git a/core/execution/operation/operation.py b/core/execution/operation/operation.py
index 85421fa..eb05c10 100644
--- a/core/execution/operation/operation.py
+++ b/core/execution/operation/operation.py
@@ -8,7 +8,7 @@ from core.runtime.stopsignals import checkDependency
 from core.execution import processregistry
 from core.console import console
 
-outputs = {}
+#outputs = {}
 
 def buildOperation(definition, outputs):
     process_log = True
diff --git a/core/runtime/createruntime.py b/core/runtime/createruntime.py
new file mode 100644
index 0000000..b050547
--- /dev/null
+++ b/core/runtime/createruntime.py
@@ -0,0 +1,4 @@
+outputs = {}
+
+def getOuputs():
+    return outputs
\ No newline at end of file
diff --git a/core/server/createlistener.py b/core/server/createlistener.py
index ffc74c4..2c3c30d 100644
--- a/core/server/createlistener.py
+++ b/core/server/createlistener.py
@@ -3,6 +3,7 @@ import logging
 
 from core.runtime.outputs import buildOutput
 from core.runtime.firewall import buildFirewall
+from core.runtime.createruntime import outputs
 
 
 def buildListener(listener, self):
@@ -24,20 +25,22 @@ def buildListener(listener, self):
         data = self.rfile.read(content_length)
         request = json.loads(data)
 
-        outputs = {}
+        #outputs = {}
 
         buildOutput(data, listener, outputs)
 
         allow, status_code = buildFirewall(listener, outputs)
 
         if allow:
-            from core.execution.executioncontract import executeContract
+            #from core.execution.executioncontract import executeContract
+            from core.execution.createthread import buildThread
             
             #Print allowed items for logging purposes
             logging.info(outputs["firewall_allowed"])
 
             #Process and forward to RMASS
-            responses = executeContract(listener.execute, outputs)
+            #responses = executeContract(listener.execute, outputs)
+            thread = buildThread(listener.execute)