Update core_engine.py

core_engine.py

@@ -1,23 +1,25 @@
-# core_engine.py
-# CodexFlow Core Execution Engine
+from economic_kernel import economic_kernel
+from logistics_engine import logistics_kernel
+from energy_engine import energy_kernel
+from sentiment_engine import sentiment_kernel
+from analytics_engine import analytics_kernel
 
-def run_engine(payload: dict) -> dict:
-    """
-    Deterministic execution core for CodexFlow_TM.
-    This is the single public entrypoint.
-    """
-
-    commodity = payload.get("commodity", "UNKNOWN")
-    anchor = float(payload.get("physical_anchor", 0))
-    lag = int(payload.get("reporting_lag", 0))
-
-    harmonized_index = round(anchor * (1 + 0.001 * lag), 4)
-
-    return {
-        "status": "ok",
-        "engine": "CodexFlow_Core",
+def run_engine(commodity, anchor, lag_days):
+    econ = economic_kernel(commodity, anchor)
+    logistics = logistics_kernel(econ)
+    energy = energy_kernel(econ)
+    sentiment = sentiment_kernel(commodity)
+    
+    world = {
         "commodity": commodity,
-        "physical_anchor": anchor,
-        "reporting_lag_days": lag,
-        "harmonized_index": harmonized_index
-    }
+        "anchor": anchor,
+        "cashflow": econ,
+        "logistics": logistics,
+        "energy": energy,
+        "sentiment": sentiment,
+        "projection": analytics_kernel(
+            econ, logistics, energy, sentiment, lag_days
+        )
+    }
+
+    return world