Update app.py

app.py

@@ -1,44 +1,111 @@
 import gradio as gr
-from codexflow_core import CodexFlowEngine
-
-# Instantiate the core engine once
-engine = CodexFlowEngine()
-
-def run_codexflow(contract_json: str):
-    """
-    Main UI handler for CodexFlow_TM:
-    - Accepts a JSON contract or cashflow spec
-    - Executes distortion/confidence logic + enforced reconciliation
-    - Returns structured system output
-    """
-    try:
-        result = engine.process(contract_json)
+from datetime import datetime
+
+from core_engine import run_engine
+from ingest import normalize_input
+from utils import validate_api_key
+
+
+# ─────────────────────────────────────────────
+# CodexFlow ΩΞ Execution Bridge
+# ─────────────────────────────────────────────
+
+def codexflow_execute(
+    api_key: str,
+    commodity: str,
+    physical_anchor: float,
+    reporting_lag: int,
+    use_live_feed: bool
+):
+    # --- Security gate ---
+    if not validate_api_key(api_key):
         return {
-            "status": "OK",
-            "distortion_index": result["distortion"],
-            "confidence_score": result["confidence"],
-            "harmonized_state": result["harmonized"],
-            "messages": result.get("messages", [])
+            "status": "ERROR",
+            "message": "Invalid or missing API key"
         }
-    except Exception as e:
-        return {"status": "ERROR", "message": str(e)}
-
-demo = gr.Interface(
-    fn=run_codexflow,
-    inputs=gr.Textbox(
-        label="CodexFlow Contract / Specification (JSON)",
-        placeholder='{"type":"cashflow","terms":{...}}',
-        lines=10
-    ),
-    outputs=gr.JSON(label="CodexFlow System Output"),
-    title="CodexFlow™ — Global Cashflow Orchestrator",
-    description=(
-        "Paste your CodexFlow contract or cashflow declaration. "
-        "The system evaluates distortion, confidence, "
-        "and produces harmonized state signals."
-    ),
-    theme="default"
-)
+
+    # --- Normalize input ---
+    payload = normalize_input(
+        commodity=commodity,
+        physical_anchor=physical_anchor,
+        reporting_lag=reporting_lag,
+        live_feed=use_live_feed
+    )
+
+    # --- Execute CodexFlow engine ---
+    result = run_engine(payload)
+
+    return {
+        "status": "OK",
+        "engine": "CodexFlow ΩΞ",
+        "timestamp": datetime.utcnow().isoformat() + "Z",
+        "input": payload,
+        "output": result
+    }
+
+
+# ─────────────────────────────────────────────
+# Hugging Face UI
+# ─────────────────────────────────────────────
+
+with gr.Blocks(title="CodexFlow ΩΞ") as demo:
+
+    gr.Markdown(
+        """
+        # CodexFlow ΩΞ  
+        **Autonomous Economic Reflex Operating System**
+
+        Harmonizes global economic signals by correcting:
+        • reporting lag  
+        • synthetic distortion  
+        • physical supply mismatch
+        """
+    )
+
+    api_key = gr.Textbox(
+        label="API Key",
+        type="password",
+        placeholder="Enter API key"
+    )
+
+    commodity = gr.Dropdown(
+        ["Gold", "Iron Ore", "Oil", "Copper"],
+        value="Gold",
+        label="Commodity"
+    )
+
+    physical_anchor = gr.Number(
+        label="Physical Anchor",
+        value=950
+    )
+
+    reporting_lag = gr.Slider(
+        minimum=0,
+        maximum=30,
+        value=7,
+        step=1,
+        label="Reporting Lag (Days)"
+    )
+
+    live_feed = gr.Checkbox(
+        value=True,
+        label="Use Live Exchange Feed"
+    )
+
+    execute_btn = gr.Button("Execute")
+    output = gr.JSON(label="Result")
+
+    execute_btn.click(
+        fn=codexflow_execute,
+        inputs=[
+            api_key,
+            commodity,
+            physical_anchor,
+            reporting_lag,
+            live_feed
+        ],
+        outputs=output
+    )
 
 if __name__ == "__main__":
     demo.launch()