Update app.py

app.py

@@ -4,9 +4,17 @@ import time
 import hashlib
 import json
 import random
+from collections import defaultdict
 
 # ======================================================
-# PUBLIC MACRO DATA (SAFE, LEGAL, OPEN)
+# GLOBAL MEMORY (CONVERSATION + STATE)
+# ======================================================
+
+CHAT_MEMORY = []
+LAST_STATE = {}
+
+# ======================================================
+# PUBLIC MACRO DATA (WORLD BANK — SAFE)
 # ======================================================
 
 WORLD_BANK_BASE = "https://api.worldbank.org/v2"
@@ -28,16 +36,17 @@ def fetch_indicator(indicator, country="WLD", year="2022"):
     except Exception:
         return None
 
-def fetch_macro_anchor():
+def fetch_macro_anchor(country="WLD"):
     return {
-        "global_gdp": fetch_indicator(INDICATORS["GDP"]),
-        "global_inflation": fetch_indicator(INDICATORS["INFLATION"]),
-        "population": fetch_indicator(INDICATORS["POPULATION"]),
+        "country": country,
+        "global_gdp": fetch_indicator(INDICATORS["GDP"], country),
+        "inflation": fetch_indicator(INDICATORS["INFLATION"], country),
+        "population": fetch_indicator(INDICATORS["POPULATION"], country),
         "timestamp": time.time(),
     }
 
 # ======================================================
-# ECONOMIC WORLD ENGINE (CORE)
+# ECONOMIC KERNEL
 # ======================================================
 
 def economic_kernel(commodity, physical_anchor, macro):
@@ -57,6 +66,10 @@ def economic_kernel(commodity, physical_anchor, macro):
         "currency_flow": round(demand * price_index, 2),
     }
 
+# ======================================================
+# AUXILIARY ENGINES
+# ======================================================
+
 def logistics_engine(econ):
     friction = abs(econ["supply"] - econ["demand"]) / max(econ["supply"], 1)
     return {
@@ -93,6 +106,23 @@ def analytics_engine(econ, logistics, energy, sentiment, lag_days):
         "volatility_index": round(0.015 * lag_days, 4),
     }
 
+# ======================================================
+# COMMODITY NETWORK GRAPH (LIGHTWEIGHT)
+# ======================================================
+
+def commodity_graph(commodity):
+    graph = {
+        "Gold": ["USD", "Inflation", "Energy"],
+        "Oil": ["Transport", "USD", "Energy"],
+        "Gas": ["Electricity", "Industry"],
+        "Wheat": ["Food", "Transport"],
+        "Copper": ["Construction", "Energy"],
+    }
+    return {
+        "node": commodity,
+        "connections": graph.get(commodity, [])
+    }
+
 # ======================================================
 # Ω-PROOF (DETERMINISTIC TRACE)
 # ======================================================
@@ -101,14 +131,33 @@ def omega_proof(state):
     canonical = json.dumps(state, sort_keys=True).encode()
     return hashlib.sha256(canonical).hexdigest()
 
+# ======================================================
+# FEDERATION ENVELOPE
+# ======================================================
+
+def federate_node(state, proof):
+    return {
+        "node": "CodexFlow_ΩΞ_Node",
+        "version": "ΩΞ-1.0",
+        "state": state,
+        "proof": proof,
+    }
+
 # ======================================================
 # MASTER ORCHESTRATION
 # ======================================================
 
-def run_codexflow(commodity, physical_anchor, lag_days, use_live_data):
-    macro = fetch_macro_anchor() if use_live_data else {
+def run_codexflow(
+    commodity,
+    physical_anchor,
+    lag_days,
+    country,
+    use_live_data
+):
+    macro = fetch_macro_anchor(country) if use_live_data else {
+        "country": country,
         "global_gdp": None,
-        "global_inflation": None,
+        "inflation": None,
         "population": None,
         "timestamp": time.time(),
     }
@@ -120,6 +169,7 @@ def run_codexflow(commodity, physical_anchor, lag_days, use_live_data):
     projection = analytics_engine(
         econ, logistics, energy, sentiment, lag_days
     )
+    network = commodity_graph(commodity)
 
     state = {
         "macro_anchor": macro,
@@ -128,44 +178,49 @@ def run_codexflow(commodity, physical_anchor, lag_days, use_live_data):
         "energy": energy,
         "sentiment": sentiment,
         "projection": projection,
+        "commodity_network": network,
     }
 
-    return state, omega_proof(state)
+    proof = omega_proof(state)
+    federated = federate_node(state, proof)
+
+    global LAST_STATE
+    LAST_STATE = federated
+
+    return federated, proof
 
 # ======================================================
-# JARVIS X CHATBOT INTERFACE
+# JARVIS X CHATBOT (SYSTEM INTERFACE)
 # ======================================================
 
 def jarvis_x_chat(user_message, history):
-    msg = user_message.lower()
+    CHAT_MEMORY.append(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 "state" in user_message.lower():
+        return json.dumps(LAST_STATE, indent=2) if LAST_STATE else "No state yet."
 
-    if "price" in msg:
+    if "what is this" in user_message.lower():
         return (
-            "Prices emerge from supply, demand, logistics friction, "
-            "energy costs, and macroeconomic anchors."
+            "CodexFlow ΩΞ is a world-economic execution engine. "
+            "It simulates supply, demand, cashflow, logistics, energy, "
+            "and macro anchors as one auditable system."
         )
 
-    if "beyond sota" in msg:
+    if "proof" in user_message.lower():
+        return "Each run emits an Ω-proof: a deterministic hash of the full world state."
+
+    if "beyond sota" in user_message.lower():
         return (
             "Yes. This system executes economic state transitions directly, "
-            "rather than only visualizing data. That is beyond traditional SOTA dashboards."
+            "rather than only visualizing data."
         )
 
-    if "proof" in msg:
-        return (
-            "Each simulation produces an Ω-proof: a deterministic hash of the full world state."
-        )
+    if "memory" in user_message.lower():
+        return f"I currently retain {len(CHAT_MEMORY)} interaction steps."
 
     return (
-        "Jarvis X acknowledges. "
-        "You can ask about system design, economics, projections, or execution logic."
+        "Jarvis X acknowledged. "
+        "You may query system state, projections, architecture, or proofs."
     )
 
 # ======================================================
@@ -174,7 +229,7 @@ def jarvis_x_chat(user_message, history):
 
 with gr.Blocks(title="CodexFlow ΩΞ") as app:
     gr.Markdown("# 🌍 CodexFlow ΩΞ")
-    gr.Markdown("**Autonomous Economic World Engine + Jarvis X Interface**")
+    gr.Markdown("**Autonomous Economic World Engine + Jarvis X Master Orchestrator**")
 
     with gr.Row():
         with gr.Column(scale=2):
@@ -185,22 +240,26 @@ with gr.Blocks(title="CodexFlow ΩΞ") as app:
             )
             physical_anchor = gr.Number(
                 value=950,
-                label="Physical Anchor (Base Units)"
+                label="Physical Anchor"
             )
             lag_days = gr.Slider(
                 1, 365, value=7, step=1, label="Reporting Lag (days)"
             )
+            country = gr.Textbox(
+                value="WLD",
+                label="Country Code (WLD, USA, CHN, ZAF, etc.)"
+            )
             use_live = gr.Checkbox(
                 value=True, label="Use Live Public Macro Data"
             )
-            run_btn = gr.Button("Run CodexFlow Simulation")
+            run_btn = gr.Button("Execute CodexFlow")
 
-            output_state = gr.JSON(label="Economic World State")
+            output_state = gr.JSON(label="Federated Economic State")
             output_proof = gr.Textbox(label="Ω-State Proof")
 
             run_btn.click(
                 fn=run_codexflow,
-                inputs=[commodity, physical_anchor, lag_days, use_live],
+                inputs=[commodity, physical_anchor, lag_days, country, use_live],
                 outputs=[output_state, output_proof],
             )
 
@@ -213,8 +272,8 @@ with gr.Blocks(title="CodexFlow ΩΞ") as app:
             )
 
     gr.Markdown(
-        "_CodexFlow ΩΞ is a simulation and intelligence engine, "
-        "not a trading platform or enforcement authority._"
+        "_CodexFlow ΩΞ is a simulation and intelligence engine. "
+        "It does not execute trades, enforce contracts, or access private systems._"
     )
 
 app.launch()