Update app.py

app.py

@@ -1,27 +1,45 @@
-# app.py
+# api.py
 
-import gradio as gr
-from api_endpoints import run_harmonization
+from fastapi import FastAPI
+from pydantic import BaseModel
+from economic_service import harmonize
+from proof_engine import generate_proof
+from federation import package_for_federation
 
-def handle_submit(commodity, physical_anchor, reporting_lag):
-    request = {
-        "commodity": commodity,
-        "physical_anchor": physical_anchor,
-        "reporting_lag": reporting_lag
-    }
-    return run_harmonization(request)
-
-demo = gr.Interface(
-    fn=handle_submit,
-    inputs=[
-        gr.Dropdown(["Gold", "Iron Ore", "Oil", "Copper"], label="Commodity"),
-        gr.Number(value=950, label="Physical Anchor"),
-        gr.Slider(0, 30, step=1, label="Reporting Lag (days)")
-    ],
-    outputs=gr.JSON(label="Result"),
-    title="CodexFlow ΩΞ • Economic Web Service",
-    description="Harmonized economic state + proof bundle"
+app = FastAPI(
+    title="CodexFlow ΩΞ API",
+    description="Autonomous Economic Harmonization Web Service",
+    version="1.0.0",
 )
 
-if __name__ == "__main__":
-    demo.launch()
+class HarmonizationRequest(BaseModel):
+    commodity: str
+    physical_anchor: float
+    reporting_lag: int
+
+@app.get("/")
+def root():
+    return {
+        "service": "CodexFlow ΩΞ",
+        "status": "online",
+        "mode": "simulation",
+    }
+
+@app.post("/harmonize")
+def harmonize_endpoint(req: HarmonizationRequest):
+    input_data = req.dict()
+
+    result = harmonize(
+        commodity=req.commodity,
+        physical_anchor=req.physical_anchor,
+        reporting_lag=req.reporting_lag,
+    )
+
+    proof = generate_proof(input_data, result)
+
+    response = {
+        "result": result,
+        "proof": proof,
+    }
+
+    return package_for_federation(response)