Update core_engine.py

core_engine.py

@@ -1,18 +1,23 @@
-import math
-from typing import Dict
+# core_engine.py
+# CodexFlow Core Execution Engine
 
-def harmonize_price(raw_price: float, physical_indicator: float, lag_factor: float) -> Dict[str, float]:
+def run_engine(payload: dict) -> dict:
     """
-    Returns harmonized pricing with distortion and confidence.
+    Deterministic execution core for CodexFlow_TM.
+    This is the single public entrypoint.
     """
-    # Correction reduces false inflation from synthetic trading
-    correction = (raw_price - physical_indicator) * min(1.0, lag_factor)
-    harmonized = raw_price - correction
-    confidence = 1.0 - abs(correction) / max(raw_price, 1)
+
+    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 {
-        "raw_price": raw_price,
-        "harmonized_price": round(harmonized, 4),
-        "distortion": round(correction, 4),
-        "confidence": round(max(0.0, min(confidence, 1.0)), 4)
+        "status": "ok",
+        "engine": "CodexFlow_Core",
+        "commodity": commodity,
+        "physical_anchor": anchor,
+        "reporting_lag_days": lag,
+        "harmonized_index": harmonized_index
     }