Update app.py

app.py

@@ -1,53 +1,220 @@
 import gradio as gr
-from core_engine import run_engine
-from proof_engine import generate_proof
-
-def execute_simulation(
-    commodity,
-    physical_anchor,
-    reporting_lag
-):
-    state = run_engine(
-        commodity=commodity,
-        anchor=physical_anchor,
-        lag_days=reporting_lag
+import requests
+import time
+import hashlib
+import json
+import random
+
+# ======================================================
+# PUBLIC MACRO DATA (SAFE, LEGAL, OPEN)
+# ======================================================
+
+WORLD_BANK_BASE = "https://api.worldbank.org/v2"
+
+INDICATORS = {
+    "GDP": "NY.GDP.MKTP.CD",
+    "INFLATION": "FP.CPI.TOTL.ZG",
+    "POPULATION": "SP.POP.TOTL",
+}
+
+def fetch_indicator(indicator, country="WLD", year="2022"):
+    try:
+        url = (
+            f"{WORLD_BANK_BASE}/country/{country}/indicator/"
+            f"{indicator}?format=json&per_page=1&date={year}"
+        )
+        r = requests.get(url, timeout=8)
+        return r.json()[1][0]["value"]
+    except Exception:
+        return None
+
+def fetch_macro_anchor():
+    return {
+        "global_gdp": fetch_indicator(INDICATORS["GDP"]),
+        "global_inflation": fetch_indicator(INDICATORS["INFLATION"]),
+        "population": fetch_indicator(INDICATORS["POPULATION"]),
+        "timestamp": time.time(),
+    }
+
+# ======================================================
+# ECONOMIC WORLD ENGINE (CORE)
+# ======================================================
+
+def economic_kernel(commodity, physical_anchor, macro):
+    gdp_scale = 1.0
+    if macro["global_gdp"]:
+        gdp_scale = macro["global_gdp"] / 1e14
+
+    supply = physical_anchor * gdp_scale
+    demand = supply * 0.95
+    price_index = round((supply / 10) * gdp_scale, 2)
+
+    return {
+        "commodity": commodity,
+        "supply": round(supply, 2),
+        "demand": round(demand, 2),
+        "price_index": price_index,
+        "currency_flow": round(demand * price_index, 2),
+    }
+
+def logistics_engine(econ):
+    friction = abs(econ["supply"] - econ["demand"]) / max(econ["supply"], 1)
+    return {
+        "throughput": round(econ["supply"] * (1 - friction), 2),
+        "friction": round(friction, 4),
+    }
+
+def energy_engine(econ):
+    return {
+        "energy_cost_index": round(econ["price_index"] * 0.4, 2),
+        "energy_dependency": (
+            "high" if econ["commodity"].lower() in ["oil", "gas"] else "moderate"
+        ),
+    }
+
+def sentiment_engine(commodity):
+    seed = sum(ord(c) for c in commodity)
+    random.seed(seed)
+    confidence = random.uniform(0.6, 0.9)
+    return {
+        "market_confidence": round(confidence, 3),
+        "risk_bias": "neutral" if confidence > 0.7 else "risk_off",
+    }
+
+def analytics_engine(econ, logistics, energy, sentiment, lag_days):
+    projected_price = econ["price_index"] * (
+        1
+        + (1 - sentiment["market_confidence"]) * 0.08
+        - logistics["friction"] * 0.1
     )
+    return {
+        "projected_price": round(projected_price, 2),
+        "lag_days": lag_days,
+        "volatility_index": round(0.015 * lag_days, 4),
+    }
 
-    proof = generate_proof(state)
+# ======================================================
+# Ω-PROOF (DETERMINISTIC TRACE)
+# ======================================================
 
-    return state, proof
+def omega_proof(state):
+    canonical = json.dumps(state, sort_keys=True).encode()
+    return hashlib.sha256(canonical).hexdigest()
 
+# ======================================================
+# MASTER ORCHESTRATION
+# ======================================================
 
-with gr.Blocks(title="CodexFlow ΩΞ") as demo:
-    gr.Markdown("## CodexFlow ΩΞ — Autonomous Economic World Engine")
+def run_codexflow(commodity, physical_anchor, lag_days, use_live_data):
+    macro = fetch_macro_anchor() if use_live_data else {
+        "global_gdp": None,
+        "global_inflation": None,
+        "population": None,
+        "timestamp": time.time(),
+    }
 
-    with gr.Row():
-        commodity = gr.Dropdown(
-            ["Gold", "Oil", "Wheat", "Electricity"],
-            label="Commodity",
-            value="Gold"
+    econ = economic_kernel(commodity, physical_anchor, macro)
+    logistics = logistics_engine(econ)
+    energy = energy_engine(econ)
+    sentiment = sentiment_engine(commodity)
+    projection = analytics_engine(
+        econ, logistics, energy, sentiment, lag_days
+    )
+
+    state = {
+        "macro_anchor": macro,
+        "economic_state": econ,
+        "logistics": logistics,
+        "energy": energy,
+        "sentiment": sentiment,
+        "projection": projection,
+    }
+
+    return state, omega_proof(state)
+
+# ======================================================
+# JARVIS X CHATBOT INTERFACE
+# ======================================================
+
+def jarvis_x_chat(user_message, history):
+    msg = user_message.lower()
+
+    if "what is this system" in msg:
+        return (
+            "CodexFlow ΩΞ is a simulated economic world engine. "
+            "It models supply, demand, cashflow, logistics, energy, and sentiment "
+            "as a unified, auditable system."
+        )
+
+    if "price" in msg:
+        return (
+            "Prices emerge from supply, demand, logistics friction, "
+            "energy costs, and macroeconomic anchors."
         )
-        anchor = gr.Number(
-            value=950,
-            label="Physical Anchor (Base Units)"
+
+    if "beyond sota" in msg:
+        return (
+            "Yes. This system executes economic state transitions directly, "
+            "rather than only visualizing data. That is beyond traditional SOTA dashboards."
         )
 
-    lag = gr.Slider(
-        1, 30,
-        value=7,
-        step=1,
-        label="Reporting Lag (days)"
+    if "proof" in msg:
+        return (
+            "Each simulation produces an Ω-proof: a deterministic hash of the full world state."
+        )
+
+    return (
+        "Jarvis X acknowledges. "
+        "You can ask about system design, economics, projections, or execution logic."
     )
 
-    run = gr.Button("Run Simulation")
+# ======================================================
+# GRADIO APPLICATION
+# ======================================================
+
+with gr.Blocks(title="CodexFlow ΩΞ") as app:
+    gr.Markdown("# 🌍 CodexFlow ΩΞ")
+    gr.Markdown("**Autonomous Economic World Engine + Jarvis X Interface**")
+
+    with gr.Row():
+        with gr.Column(scale=2):
+            commodity = gr.Dropdown(
+                ["Gold", "Oil", "Gas", "Wheat", "Copper"],
+                value="Gold",
+                label="Commodity"
+            )
+            physical_anchor = gr.Number(
+                value=950,
+                label="Physical Anchor (Base Units)"
+            )
+            lag_days = gr.Slider(
+                1, 365, value=7, step=1, label="Reporting Lag (days)"
+            )
+            use_live = gr.Checkbox(
+                value=True, label="Use Live Public Macro Data"
+            )
+            run_btn = gr.Button("Run CodexFlow Simulation")
+
+            output_state = gr.JSON(label="Economic World State")
+            output_proof = gr.Textbox(label="Ω-State Proof")
+
+            run_btn.click(
+                fn=run_codexflow,
+                inputs=[commodity, physical_anchor, lag_days, use_live],
+                outputs=[output_state, output_proof],
+            )
 
-    output = gr.JSON(label="World State")
-    proof = gr.JSON(label="Ω-State Proof")
+        with gr.Column(scale=1):
+            gr.Markdown("## 🧠 Jarvis X")
+            gr.ChatInterface(
+                fn=jarvis_x_chat,
+                chatbot_name="Jarvis X",
+                height=420
+            )
 
-    run.click(
-        execute_simulation,
-        inputs=[commodity, anchor, lag],
-        outputs=[output, proof]
+    gr.Markdown(
+        "_CodexFlow ΩΞ is a simulation and intelligence engine, "
+        "not a trading platform or enforcement authority._"
     )
 
-demo.launch()
+app.launch()