Update app.py

app.py

@@ -1,309 +1,29 @@
 import gradio as gr
-import os, json, time, uuid, hashlib, random, math
-from datetime import datetime
-from typing import Dict
-
-# ============================================================
-# 1. WHITE-LABEL / IDENTITY CONFIG
-# ============================================================
-
-BRAND = os.getenv("CODEX_BRAND", "CodexFlow ΩΞ")
-ORG   = os.getenv("CODEX_ORG", "Codex Sovereign")
-CCY   = os.getenv("CODEX_CCY", "USD")
-
-STATE_DIR = "state"
-os.makedirs(STATE_DIR, exist_ok=True)
-
-FILES = {
-    "history": f"{STATE_DIR}/history.json",
-    "audit": f"{STATE_DIR}/audit.json",
-    "usage": f"{STATE_DIR}/usage.json",
-    "graph": f"{STATE_DIR}/causal_graph.json",
-    "prov": f"{STATE_DIR}/provenance.json",
-    "sys": f"{STATE_DIR}/system_state.json",
-}
-
-# ============================================================
-# 2. ACCESS CONTROL (RBAC + QUOTAS)
-# ============================================================
-
-API_KEYS = {
-    "DEMO_KEY": {"tier": "demo", "quota": 50},
-    "PRO_KEY": {"tier": "pro", "quota": 500},
-    "INSTITUTIONAL_KEY": {"tier": "institutional", "quota": 50_000},
-    "SOVEREIGN_KEY": {"tier": "sovereign", "quota": 10**9},
-}
-
-# ============================================================
-# 3. STORAGE UTILITIES
-# ============================================================
-
-def load(path, default=None):
-    if os.path.exists(path):
-        with open(path, "r") as f:
-            return json.load(f)
-    return [] if default is None else default
-
-def save(path, data, limit=5000):
-    with open(path, "w") as f:
-        json.dump(data[-limit:], f, indent=2)
-
-# ============================================================
-# 4. SECURITY / QUOTA ENFORCEMENT
-# ============================================================
-
-def authorize(key: str) -> str:
-    if key not in API_KEYS:
-        raise ValueError("Invalid API key")
-
-    usage = load(FILES["usage"], [])
-    if sum(1 for u in usage if u["k"] == key) >= API_KEYS[key]["quota"]:
-        raise ValueError("Quota exceeded")
-
-    usage.append({"k": key, "t": time.time()})
-    save(FILES["usage"], usage)
-    return API_KEYS[key]["tier"]
-
-# ============================================================
-# 5. CRYPTOGRAPHIC PROVENANCE (HASH-CHAIN)
-# ============================================================
-
-def sha(obj):
-    return hashlib.sha256(json.dumps(obj, sort_keys=True).encode()).hexdigest()
-
-def attest(payload: Dict) -> Dict:
-    chain = load(FILES["prov"], [])
-    prev = chain[-1]["hash"] if chain else "GENESIS"
-
-    record = {
-        "id": str(uuid.uuid4()),
-        "time": datetime.utcnow().isoformat(),
-        "prev": prev,
-        "hash": sha({**payload, "prev": prev}),
-    }
-
-    chain.append(record)
-    save(FILES["prov"], chain)
-    payload["provenance"] = record
-    return payload
-
-# ============================================================
-# 6. FEDERATED CODEX MESH (NODE ID + BROADCAST HOOK)
-# ============================================================
-
-def mesh_node():
-    return sha(os.getenv("HOSTNAME", "codex-node"))[:16]
-
-def mesh_emit(payload: Dict) -> Dict:
-    payload["mesh"] = {
-        "node": mesh_node(),
-        "msg_id": str(uuid.uuid4()),
-        "time": datetime.utcnow().isoformat(),
-    }
-    return payload
-
-# ============================================================
-# 7. REALITY ADAPTERS (SAFE STUBS)
-# ============================================================
-
-def exchange_price(commodity: str) -> float:
-    base = {"Gold": 1000, "Iron Ore": 1200, "Crude Oil": 800}
-    return round(base.get(commodity, 1000) + random.uniform(-6, 6), 2)
-
-def producer_state(commodity: str) -> Dict:
-    return {
-        "output_tpd": random.randint(8000, 15000),
-        "inventory_t": random.randint(20_000, 60_000),
-        "logistics": random.choice(["normal", "tight"]),
-        "energy": random.choice(["stable", "volatile"]),
-    }
-
-# ============================================================
-# 8. CAUSAL GRAPH + ANOMALY DETECTION
-# ============================================================
-
-def update_graph(commodity, distortion, lag):
-    g = load(FILES["graph"], [])
-    g.append({
-        "commodity": commodity,
-        "distortion": distortion,
-        "lag": lag,
-        "time": datetime.utcnow().isoformat(),
-    })
-    save(FILES["graph"], g)
-
-def anomaly(distortion):
-    return abs(distortion) > 0.15
-
-# ============================================================
-# 9. AUTONOMOUS MATHEMATICAL CORE
-# ============================================================
-
-"""
-System evolves via a stabilising gradient flow:
-
-E = d² + 0.01·lag² + (1 − c)²
-biasₜ₊₁ = clamp(biasₜ − η ∂E/∂d)
-
-This ensures:
-• no runaway correction
-• bounded adaptation
-• deterministic convergence
-"""
-
-def system_state():
-    return load(FILES["sys"], {"eta": 0.2, "bias": 0.0})
-
-def save_state(s):
-    save(FILES["sys"], [s], limit=1)
-
-def energy(d, lag, c):
-    return d*d + 0.01*lag*lag + (1-c)**2
-
-def update_state(d, lag, c):
-    s = system_state()
-    grad = 2*d + 0.02*lag - 2*(1-c)
-    s["bias"] = max(-0.2, min(0.2, s["bias"] - s["eta"] * grad))
-    save_state(s)
-    return s
-
-# ============================================================
-# 10. ECONOMIC TRANSFORMS
-# ============================================================
-
-def harmonize(synth, phys, lag):
-    lf = min(lag / 10, 1.0)
-    corr = (synth - phys) * lf
-    harm = synth - corr
-    conf = max(0.0, 1 - abs(corr) / max(synth, 1))
-    return round(harm, 2), round(-corr, 2), round(conf, 2)
-
-def accelerate(value, lag, conf):
-    rate = 0.03 + (1 - conf) * 0.05
-    return round(value / ((1 + rate) ** (lag / 365)), 2)
-
-def grade(conf):
-    return "AAA" if conf >= 0.9 else "AA" if conf >= 0.75 else "A"
-
-def scenarios(base):
-    return {
-        "optimistic": round(base * 1.05, 2),
-        "baseline": round(base, 2),
-        "stress": round(base * 0.9, 2),
-    }
-
-# ============================================================
-# 11. TREASURY / SOVEREIGN POLICY LAYER
-# ============================================================
-
-def treasury(tier, conf):
-    if tier == "sovereign":
-        return {"gate": "open", "confidence_floor": 0.7}
-    return {"gate": "market", "confidence_floor": 0.75}
-
-# ============================================================
-# 12. REGULATORY EXPORT
-# ============================================================
-
-def regulatory(entry):
-    return {
-        "engine": BRAND,
-        "org": ORG,
-        "commodity": entry["commodity"],
-        "harmonized_price": entry["harmonized_price"],
-        "confidence": entry["confidence"],
-        "mesh_node": entry["mesh"]["node"],
-        "prov_hash": entry["provenance"]["hash"],
-        "time": entry["timestamp"],
-    }
-
-# ============================================================
-# 13. MAIN AUTONOMOUS RUNTIME
-# ============================================================
-
-def run(commodity, physical_anchor, lag_days, api_key, live_feed):
-    tier = authorize(api_key)
-
-    synth = exchange_price(commodity) if live_feed else round(physical_anchor * 1.05, 2)
-    producer = producer_state(commodity)
-
-    harm, dist, conf = harmonize(synth, physical_anchor, lag_days)
-
-    state = update_state(abs(dist), lag_days, conf)
-    harm = round(harm * (1 + state["bias"]), 2)
-
-    accel = accelerate(harm, lag_days, conf)
-    update_graph(commodity, dist, lag_days)
-
-    result = {
-        "engine": BRAND,
-        "org": ORG,
-        "tier": tier,
-        "currency": CCY,
-        "timestamp": datetime.utcnow().isoformat(),
-        "commodity": commodity,
-        "synthetic_price": synth,
-        "physical_anchor": physical_anchor,
-        "harmonized_price": harm,
-        "distortion": dist,
-        "confidence": conf,
-        "grade": grade(conf),
-        "accelerated_cashflow": accel,
-        "anomaly": anomaly(dist),
-        "producer_state": producer,
-        "scenarios": scenarios(harm),
-        "treasury": treasury(tier, conf),
-        "system_state": state,
-    }
-
-    hist = load(FILES["history"], [])
-    hist.append(result)
-    save(FILES["history"], hist)
-
-    aud = load(FILES["audit"], [])
-    aud.append(result)
-    save(FILES["audit"], aud)
-
-    result = mesh_emit(result)
-    result = attest(result)
-    result["regulatory_export"] = regulatory(result)
-    return result
-
-# ============================================================
-# 14. HUGGING FACE UI
-# ============================================================
-
-with gr.Blocks() as demo:
-    gr.Markdown(f"# {BRAND}\n### Autonomous Economic Reflex Operating System")
-
-    api = gr.Textbox(label="API Key", type="password")
-    com = gr.Dropdown(["Gold", "Iron Ore", "Crude Oil"], label="Commodity")
-    phys = gr.Number(950, label="Physical Anchor")
-    lag = gr.Slider(0, 30, 7, 1, label="Reporting Lag (Days)")
-    live = gr.Checkbox(True, label="Use Live Exchange Feed")
-
-    btn = gr.Button("Execute")
-    out = gr.JSON()
-
-    btn.click(run, inputs=[com, phys, lag, api, live], outputs=out)
-
-    with gr.Tab("Audit Log"):
-        gr.Button("Load").click(lambda: load(FILES["audit"], []), outputs=gr.JSON())
-
-    with gr.Tab("Causal Graph"):
-        gr.Button("Load").click(lambda: load(FILES["graph"], []), outputs=gr.JSON())
-
-    with gr.Tab("Provenance"):
-        gr.Button("Load").click(lambda: load(FILES["prov"], []), outputs=gr.JSON())
-
-# ============================================================
-# 15. HF DEPLOY PATCH
-# ============================================================
-
-if __name__ == "__main__":
-    demo.launch(
-        server_name="0.0.0.0",
-        server_port=7860,
-        show_error=True,
-        ssr_mode=False,
-    )
+from compiler import compile_codexbyte
+from codexbyte_vm import CodexByteVM
+
+vm = CodexByteVM()
+
+def run_codexbyte(source: str):
+    try:
+        program = compile_codexbyte(source.strip().splitlines())
+        ledger = vm.run(program)
+        return {
+            "registers": vm.reg,
+            "memory": vm.mem,
+            "omega_ledger": ledger
+        }
+    except Exception as e:
+        return {"error": str(e)}
+
+gr.Interface(
+    fn=run_codexbyte,
+    inputs=gr.Textbox(
+        lines=16,
+        label="CodexByte Program",
+        placeholder="LOAD_IMM 0 1000\nLOAD_MEM 1 0x20\nCMP 1 0\nJZ 10\nHALT"
+    ),
+    outputs=gr.JSON(label="Ω-State Proof"),
+    title="CodexByte ΩΞ Runtime",
+    description="Bytecode execution is enforcement. Execution trace is proof."
+).launch()