Update app.py

app.py

@@ -1,30 +1,146 @@
 import gradio as gr
-from ingest import ingest_physical_metrics, load_schema
-from core_engine import harmonize_price
-from cashflow import accelerate_receivable
-from utils import compute_risk_score
+from datetime import datetime
+from typing import Dict
 
-def codexflow_endpoint(raw_price: float, inventory_val: float):
-    physical = ingest_physical_metrics("placeholder")
-    schema = load_schema()
 
-    harm = harmonize_price(raw_price, physical["production"], physical["transport_delay"] / 10)
-    risk = compute_risk_score(harm["confidence"], inventory_val)
+# =========================
+# CORE CODEX ENGINE
+# =========================
 
-    accelerated = accelerate_receivable(raw_price, physical["transport_delay"], risk)
+def harmonize_price(
+    synthetic_price: float,
+    physical_anchor: float,
+    lag_factor: float
+) -> Dict[str, float]:
+    """
+    Harmonize synthetic price signals with physical reality.
+    """
+    correction = (synthetic_price - physical_anchor) * min(1.0, lag_factor)
+    harmonized = synthetic_price - correction
+    confidence = 1.0 - abs(correction) / max(synthetic_price, 1.0)
 
     return {
-        "harmonized": harm,
-        "risk_score": risk,
-        "accelerated_cashflow": accelerated
+        "synthetic_price_index": round(synthetic_price, 2),
+        "correction": round(-correction, 2),
+        "harmonized_price_index": round(harmonized, 2),
+        "confidence": round(max(0.0, min(confidence, 1.0)), 2)
     }
 
+
+def accelerate_cashflow(
+    amount: float,
+    days_delay: int,
+    confidence: float
+) -> float:
+    """
+    Time-value cashflow acceleration (non-speculative).
+    """
+    base_rate = 0.03
+    risk_penalty = (1.0 - confidence) * 0.05
+    discount_rate = base_rate + risk_penalty
+
+    accelerated_value = amount / ((1 + discount_rate) ** (days_delay / 365))
+    return round(accelerated_value, 2)
+
+
+# =========================
+# SYSTEM ENTRYPOINT
+# =========================
+
+def codexflow_runtime(
+    commodity: str,
+    synthetic_price: float,
+    physical_price: float,
+    reporting_lag_days: int
+) -> Dict:
+    """
+    Full CodexFlow runtime execution.
+    """
+    lag_factor = min(reporting_lag_days / 10, 1.0)
+
+    harmonized = harmonize_price(
+        synthetic_price=synthetic_price,
+        physical_anchor=physical_price,
+        lag_factor=lag_factor
+    )
+
+    accelerated_cashflow = accelerate_cashflow(
+        amount=harmonized["harmonized_price_index"],
+        days_delay=reporting_lag_days,
+        confidence=harmonized["confidence"]
+    )
+
+    return {
+        "status": "ok",
+        "engine": "CodexFlow ΩΞ",
+        "timestamp": datetime.utcnow().isoformat(),
+        "commodity": commodity,
+        "harmonized_state": harmonized,
+        "accelerated_cashflow_estimate": accelerated_cashflow
+    }
+
+
+# =========================
+# GRADIO UI
+# =========================
+
 with gr.Blocks() as demo:
-    gr.Markdown("# CodexFlow ΩΞ – Cashflow Accelerator")
-    raw_price = gr.Number(label="Raw Market Price")
-    inventory_val = gr.Number(label="Inventory Confidence (0-1)")
-    btn = gr.Button("Compute")
-    output = gr.JSON()
-    btn.click(codexflow_endpoint, inputs=[raw_price, inventory_val], outputs=output)
-
-demo.launch(server_name="0.0.0.0", server_port=7860)
+    gr.Markdown(
+        """
+        # CodexFlow ΩΞ Runtime  
+        **Reality-Anchored Cashflow Acceleration Engine**
+
+        Harmonizes synthetic market signals with physical reality and
+        accelerates cashflow without speculation or leverage.
+        """
+    )
+
+    with gr.Row():
+        commodity = gr.Dropdown(
+            ["Gold", "Iron Ore", "Crude Oil"],
+            label="Commodity"
+        )
+        synthetic_price = gr.Number(
+            label="Synthetic Price Index",
+            value=1000
+        )
+
+    with gr.Row():
+        physical_price = gr.Number(
+            label="Physical / Production Price Anchor",
+            value=950
+        )
+        reporting_lag = gr.Slider(
+            minimum=0,
+            maximum=30,
+            step=1,
+            label="Reporting Lag (Days)",
+            value=7
+        )
+
+    run_btn = gr.Button("Run CodexFlow Harmonization")
+    output = gr.JSON(label="CodexFlow Output")
+
+    run_btn.click(
+        codexflow_runtime,
+        inputs=[
+            commodity,
+            synthetic_price,
+            physical_price,
+            reporting_lag
+        ],
+        outputs=output
+    )
+
+
+# =========================
+# HUGGING FACE PATCH
+# =========================
+
+if __name__ == "__main__":
+    demo.launch(
+        server_name="0.0.0.0",
+        server_port=7860,
+        show_error=True,
+        ssr_mode=False
+    )