Spaces:

LordXido
/

CodexHF_API_Gateway

Sleeping

App Files Files Community

LordXido commited on Jan 16

Commit

ec89b57

verified ·

1 Parent(s): 85e23d2

Update api_gateway.py

Browse files

Files changed (1) hide show

api_gateway.py +66 -34

api_gateway.py CHANGED Viewed

@@ -1,34 +1,66 @@
-from fastapi import FastAPI
-from pydantic import BaseModel
-from codex_logic import assess_work_description, validate_use_case
-from fastapi.responses import HTMLResponse, RedirectResponse
-app = FastAPI()
-class EvaluationRequest(BaseModel):
-    work_description: str
-@app.get("/", response_class=HTMLResponse)
-def root():
-    return """
-    <html>
-      <head><title>CodexHF API Gateway</title></head>
-      <body style='font-family:monospace; background:#111; color:#0f0; text-align:center; padding:2em;'>
-        <h1>🧠 CodexHF Sovereign API Gateway</h1>
-        <p>✅ Status: <b>Running</b></p>
-        <p>Use <code>/evaluate</code> endpoint via POST</p>
-        <p><a href='/docs' style='color:#0f0;'>View API Documentation</a></p>
-      </body>
-    </html>
-    """
-@app.get("/docs_redirect")
-def docs_redirect():
-    return RedirectResponse(url="/docs")
-@app.post("/evaluate")
-def evaluate_work(req: EvaluationRequest):
-    if not validate_use_case(req.work_description):
-        return {"codex_response": "⚠ Rejected: Use case violates CodexΛ constraint."}
-    response = assess_work_description(req.work_description)
-    return {"codex_response": response}

+from fastapi import FastAPI, HTTPException
+from datetime import datetime
+import uuid
+from codex_logic import (
+    list_capabilities,
+    invoke_capability,
+    wake_module
+)
+app = FastAPI(
+    title="CodexHF API Gateway",
+    version="1.0.0",
+    description="Sovereign orchestration gateway for Codex Spaces",
+)
+@app.get("/health")
+async def health():
+    return {
+        "status": "ok",
+        "timestamp": datetime.utcnow().isoformat()
+    }
+@app.get("/capabilities")
+async def capabilities():
+    return {
+        "capabilities": list_capabilities()
+    }
+@app.post("/invoke")
+async def invoke(request: dict):
+    trace_id = request.get("trace_id", str(uuid.uuid4()))
+    capability = request.get("capability")
+    payload = request.get("payload", {})
+    mode = request.get("execution_mode", "sync")
+    if not capability:
+        raise HTTPException(status_code=400, detail="Missing capability")
+    if mode == "async":
+        return {
+            "trace_id": trace_id,
+            "status": "accepted"
+        }
+    try:
+        result, duration = await invoke_capability(capability, payload)
+        return {
+            "trace_id": trace_id,
+            "result": result,
+            "duration_ms": duration
+        }
+    except ValueError as e:
+        raise HTTPException(status_code=404, detail=str(e))
+@app.post("/wake")
+async def wake(request: dict):
+    module = request.get("module")
+    if not module:
+        raise HTTPException(status_code=400, detail="Missing module")
+    await wake_module(module)
+    return {
+        "status": "awakened",
+        "module": module
+    }