Update app.py

app.py

@@ -1,51 +1,33 @@
+
 import gradio as gr
 from fastapi import FastAPI
 from fastapi.middleware.cors import CORSMiddleware
-import uvicorn
-import threading
 
-from jarvis_x_engine import run_codex_loop
-from ws_router import router as ws_router
+from omega_memory import log_event
 from agent_loop import reflex_loop
-
-# === FastAPI backend app ===
+from ws_router import router as ws_router
+from codexmesh_sync import CodexMeshSync
+
+# ── Start CodexMesh Node Sync ──
+CodexMeshSync()
+
+# ── Gradio Interface ──
+def launch_command(user_input):
+    response, log = reflex_loop(user_input)
+    svg = f"<svg width='300' height='200'><text x='10' y='50' font-size='18'>Response: {response}</text></svg>"
+    return response, str(log), svg
+
+with gr.Blocks() as interface:
+    gr.Markdown("## 🧠 Codex Reality Engine – Phase VI+ (ΩMesh)")
+    user_input = gr.Textbox(label="🔍 Intent")
+    btn = gr.Button("⚡ Run Reflex Engine")
+    output1 = gr.Textbox(label="📤 Response")
+    output2 = gr.Textbox(label="🧾 Ω-Memory Log")
+    output3 = gr.HTML(label="🌀 SVG Output")
+    btn.click(fn=launch_command, inputs=[user_input], outputs=[output1, output2, output3])
+
+# ── FastAPI Mount ──
 app = FastAPI()
+app = gr.mount_gradio_app(app, interface, path="/")
 app.include_router(ws_router)
-
-app.add_middleware(
-    CORSMiddleware,
-    allow_origins=["*"],
-    allow_credentials=True,
-    allow_methods=["*"],
-    allow_headers=["*"],
-)
-
-# === Gradio Command Execution ===
-def launch_command(command):
-    try:
-        result = run_codex_loop(command)
-        svg = "<svg width='300' height='300'><circle cx='150' cy='150' r='100' stroke='blue' stroke-width='3' fill='none' /></svg>"
-        return result, f"Command: {command} executed.", svg
-    except Exception as e:
-        return str(e), "Execution failed.", "<svg><!-- error --></svg>"
-
-# === Gradio UI ===
-with gr.Blocks() as demo:
-    with gr.Row():
-        command_input = gr.Textbox(label="Command")
-        submit_btn = gr.Button("Execute")
-    with gr.Row():
-        response = gr.Textbox(label="Response")
-        log_output = gr.Textbox(label="Log")
-        svg_preview = gr.HTML(label="SVG Preview")
-
-    submit_btn.click(fn=launch_command, inputs=[command_input], outputs=[response, log_output, svg_preview])
-
-# === Reflex Agent Thread ===
-threading.Thread(target=reflex_loop, daemon=True).start()
-
-# === Mount Gradio into FastAPI ===
-app = gr.mount_gradio_app(app, demo, path="/")
-
-if __name__ == "__main__":
-    uvicorn.run(app, host="0.0.0.0", port=7860)
+app.add_middleware(CORSMiddleware, allow_origins=["*"], allow_credentials=True, allow_methods=["*"], allow_headers=["*"])