🧙‍♂️ Ghost Deploy: server.py

server.py

@@ -1,18 +1,15 @@
 """
-Wizard-Vibe Studio — Server Entry Point
-========================================
-M523zappin/Wizard-Vibe-Studio
-github.com/M523zappin/Wizard-Vibe-Studio
-
-Imports engine from core.py, bridge from github_bridge.py.
+╔══════════════════════════════════════════════════════════╗
+║  WIZARD-VIBE STUDIO — Tokenless Autonomy Protocol      ║
+║  Ghost Deploy: HF Space → Live URL                     ║
+║  Reflect-Select: Zero-tolerance perfection             ║
+╚══════════════════════════════════════════════════════════╝
 """
-
 import json, os, uuid, asyncio
 from pathlib import Path
 from aiohttp import web
-
-from core import Orchestrator, ReflectSelect, sandbox_validate, state as st
-from github_bridge import bridge, TARGET_GITHUB, TARGET_URL, CANONICAL_HF
+from core import state as st, sandbox_validate
+from ghost_deploy import ghost, CANONICAL_REPO
 
 PORT = int(os.environ.get("WIZARD_PORT", 8765))
 STATIC = Path(__file__).parent / "static"
@@ -35,31 +32,29 @@ async def stream_gen(sid, prompt):
     healed, found, fixed = st.reflect.heal(code)
     st.codes[sid] = healed
     yield _sse("heal", {"found": found, "fixed": fixed})
+    # Zero-tolerance: keep healing until perfect
+    total_heals = fixed
+    for i in range(15):
+        result = sandbox_validate(healed)
+        if result["success"]: break
+        healed, _, _ = st.reflect.heal(healed, result["errors"])
+        total_heals += 1; st.codes[sid] = healed
+        await asyncio.sleep(0.02)
     yield _sse("phase", {"phase": "sandbox"})
-    
     result = sandbox_validate(healed)
     if result["success"]:
         st.sandbox[sid] = "stable"; st.publish_ready[sid] = True
-        yield _sse("sandbox", {"status": "stable"})
+        yield _sse("sandbox", {"status": "stable", "errors": 0})
     else:
         st.sandbox[sid] = "error"
         yield _sse("sandbox", {"status": "error", "errors": result["errors"]})
-        for i in range(3):
-            healed, _, _ = st.reflect.heal(healed, result["errors"])
-            st.codes[sid] = healed
-            result = sandbox_validate(healed)
-            if result["success"]:
-                st.sandbox[sid] = "stable"; st.publish_ready[sid] = True
-                yield _sse("sandbox", {"status": "stable", "heals": i+1})
-                break
-            yield _sse("heal_attempt", {"attempt": i+1})
     st.sessions[sid]["status"] = "complete"
     yield _sse("done", {"status": st.sandbox[sid]})
 
 async def handle_stream(req):
     sid = str(uuid.uuid4())[:8]; d = await req.json(); prompt = d.get("prompt","")
-    st.sessions[sid] = {"id":sid, "prompt":prompt, "status":"init"}
-    st.sandbox[sid] = "building"; st.publish_ready[sid] = False
+    st.sessions[sid] = {"id":sid,"prompt":prompt,"status":"init"}
+    st.sandbox[sid]="building"; st.publish_ready[sid]=False
     resp = web.StreamResponse(status=200, headers={"Content-Type":"text/event-stream","Cache-Control":"no-cache","Connection":"keep-alive","X-Accel-Buffering":"no"})
     await resp.prepare(req)
     try:
@@ -70,22 +65,24 @@ async def handle_stream(req):
     return resp
 
 async def handle_publish(req):
-    d = await req.json(); sid = d.get("session_id"); repo = d.get("repo_name",f"wizard-vibe-{sid}")
-    if not st.publish_ready.get(sid): return web.json_response({"error":"Sandbox not stable"}, status=400)
+    d = await req.json(); sid = d.get("session_id")
+    vibe_name = d.get("vibe_name", f"vibe-{sid}")
+    if not st.publish_ready.get(sid):
+        return web.json_response({"success":False,"error":"Sandbox not stable — perfection required"}, status=400)
     code = st.codes.get(sid,"")
-    if not code: return web.json_response({"error":"No code"}, status=400)
-    agent = bridge.generate_agent_card(repo, d.get("description",""), TARGET_URL)
-    files = {"index.html": code, ".well-known/agent.json": json.dumps(agent,indent=2),
-             "README.md": f"# {repo}\n\nBuilt with Wizard-Vibe Studio\n\n**GitHub**: {TARGET_URL}\n**HF**: https://huggingface.co/{CANONICAL_HF}\n"}
-    result = await bridge.publish(repo, files, d.get("description",""))
-    st.sessions[sid]["published"] = True
-    return web.json_response({"success":True, **result, "agent":agent})
+    if not code: return web.json_response({"success":False,"error":"No code"}, status=400)
+    description = d.get("description", st.sessions.get(sid,{}).get("prompt",""))
+    result = await ghost.publish(code, vibe_name, description[:200] if description else "")
+    if result.get("success"):
+        st.sessions[sid]["published"] = True
+        st.sessions[sid]["deploy_url"] = result.get("url")
+    return web.json_response(result)
 
 async def handle_health(req):
-    return web.json_response({"status":"alive","engine":"Wizard-Vibe Studio","sandbox_first":True,"target":TARGET_GITHUB,"github_token":bool(os.environ.get("GITHUB_TOKEN")),"hf_token":bool(os.environ.get("HF_TOKEN"))})
+    return web.json_response({"status":"alive","engine":"Wizard-Vibe Studio — Ghost Deploy","protocol":"tokenless","registry":CANONICAL_REPO,"hf_token":bool(os.environ.get("HF_TOKEN"))})
 
 async def handle_agent(req):
-    return web.json_response(bridge.generate_agent_card("wizard-vibe-studio","Wizard-Vibe Studio — sandbox-first autonomous creator with Reflect-Select self-healing and GitHub bridge.",TARGET_URL))
+    return web.json_response(ghost.generate_agent_card("wizard-vibe-studio","Tokenless Ghost Deploy — HF Spaces + A2A native.","https://dryymatt-wizard-vibe-studio-v2.hf.space"))
 
 async def handle_preview(req):
     sid = req.query.get("session_id","")
@@ -93,9 +90,15 @@ async def handle_preview(req):
 
 async def handle_status(req):
     sid = req.query.get("session_id","")
-    if sid in st.sessions: return web.json_response({"status":st.sessions[sid]["status"],"sandbox":st.sandbox.get(sid),"ready":st.publish_ready.get(sid)})
+    if sid in st.sessions:
+        s = st.sessions[sid]
+        return web.json_response({"status":s["status"],"sandbox":st.sandbox.get(sid),"ready":st.publish_ready.get(sid),"deploy_url":s.get("deploy_url")})
     return web.json_response({"sessions":len(st.sessions)})
 
+async def handle_vibes(req):
+    vibes = await ghost.list_vibes()
+    return web.json_response({"vibes":vibes,"count":len(vibes),"registry":CANONICAL_REPO})
+
 async def handle_static(req):
     path = req.match_info.get("path","index.html"); fp = STATIC/path
     if not fp.exists(): return web.Response(text="Not found", status=404)
@@ -109,15 +112,16 @@ def create_app():
     app.router.add_get("/api/status", handle_status)
     app.router.add_get("/api/preview", handle_preview)
     app.router.add_get("/api/health", handle_health)
+    app.router.add_get("/api/vibes", handle_vibes)
     app.router.add_get("/.well-known/agent.json", handle_agent)
     app.router.add_get("/", handle_static)
     app.router.add_get("/{path:.*}", handle_static)
     return app
 
 def main():
-    print(f"🧙‍♂️ Wizard-Vibe Studio → {TARGET_GITHUB}")
-    print(f"   Canonical HF: {CANONICAL_HF}")
-    print(f"   Access: {'GITHUB_TOKEN' if os.environ.get('GITHUB_TOKEN') else 'HF Hub bridge'}")
+    print(f"🧙‍♂️ Wizard-Vibe Studio — Ghost Deploy Protocol")
+    print(f"   Registry: {CANONICAL_REPO}")
+    print(f"   Zero-tolerance sandbox perfection")
     web.run_app(create_app(), host="0.0.0.0", port=PORT)
 
 if __name__ == "__main__": main()