// ── AIWHISPERERS · FRONTEND CONNECTOR ───────────────────────────────────── // Wklej do modułu. Podmień MODULE_ID i PORT. Zaimplementuj applyState() i getMock(). const MODULE_ID = 'breath'; const API = location.protocol === 'file:' ? null : `${location.origin}/api`; const WS_URL = API ? `ws://${location.host}/ws/${MODULE_ID}` : null; // ── Live/Mock indicator ──────────────────────────────────────────────────── function setLive(isLive) { const el = document.getElementById('live-dot'); if (!el) return; el.textContent = isLive ? 'live' : 'mock'; el.style.color = isLive ? 'var(--green)' : 'var(--ink-faint)'; } // ── Mock data ───────────────────────────────────────────────────────────── function getMock() { return { activity_key: 'mysli', started_at: Date.now(), duration_ms: 9000, metrics: {} }; } // ── REST Polling (MVP) ──────────────────────────────────────────────────── async function fetchState() { if (!API) { applyState(getMock()); return; } try { const r = await fetch(`${API}/${MODULE_ID}/state`); if (!r.ok) throw new Error(); applyState(await r.json()); setLive(true); } catch { setLive(false); applyState(getMock()); } } async function fetchLog() { if (!API) return; try { renderLog(await (await fetch(`${API}/${MODULE_ID}/log?limit=40`)).json()); } catch {} } fetchState(); const _stateTimer = setInterval(fetchState, 4000); const _logTimer = setInterval(fetchLog, 12000); // ── WebSocket AiWConnector (zastąp polling gdy gotowy) ──────────────────── class AiWConnector { constructor(moduleId, wsUrl) { this.id = moduleId; this.url = wsUrl; this.ws = null; this.delay = 1000; this.dead = false; } connect() { if (!this.url || this.dead) { setLive(false); return; } this.ws = new WebSocket(this.url); this.ws.onopen = () => { setLive(true); this.delay = 1000; }; this.ws.onclose = () => { setLive(false); applyState(getMock()); setTimeout(() => this.connect(), this.delay); this.delay = Math.min(this.delay * 2, 30000); }; this.ws.onerror = () => {}; this.ws.onmessage = (e) => this.route(JSON.parse(e.data)); } route(data) { if (data.type === 'BROADCAST_SIGNAL') updateTelemetry(data.telemetry); if (data.type === 'STATE_UPDATE' && data.target === this.id) applyState(data.payload); if (data.type === 'TASK_READY') handleTaskResult(data); } send(action, params = {}) { if (this.ws?.readyState === WebSocket.OPEN) this.ws.send(JSON.stringify({ type: 'ACTION', action, params })); } } // const connector = new AiWConnector(MODULE_ID, WS_URL); // connector.connect(); // clearInterval(_stateTimer); clearInterval(_logTimer); // gdy WS zastępuje polling // ── Zaimplementuj w module ──────────────────────────────────────────────── function applyState(data) { /* aktualizuj UI na podstawie data.activity_key */ } function renderLog(entries) { /* renderuj log z entries[] */ } function updateTelemetry(t) { /* reaguj wizualnie na t.cpu / t.mem / t.temp */ } function handleTaskResult(data) { /* obsłuż wynik zadania data.result */ } // ── HTML: wskaźnik live/mock (wklej do hud-l) ───────────────────────────── // <span id="live-dot" style="font-family:var(--mono);font-size:7px;letter-spacing:2px; // color:var(--ink-faint);text-transform:uppercase;">mock</span>

# ── AIWHISPERERS · ENGINE TEMPLATE ────────────────────────────────────────── # Podmień MODULE_ID i PORT. Zaimplementuj logikę w engine.py. # Topologia A — dedykowany port: jeden moduł, jeden silnik (domyślna konwencja 8001–8006+). # Topologia B — wspólny port: wiele modułów łączy się do jednego silnika po artifact_id w URL. # Kod silnika jest identyczny w obu — różni się tylko konfiguracja uruchomienia. from fastapi import FastAPI, WebSocket, WebSocketDisconnect, BackgroundTasks from fastapi.middleware.cors import CORSMiddleware from contextlib import asynccontextmanager import asyncio, psutil, time MODULE_ID = "breath" PORT = 8006 # ── ConnectionManager ──────────────────────────────────────────────────────── class ConnectionManager: def __init__(self): self.active: dict[str, WebSocket] = {} async def connect(self, aid: str, ws: WebSocket): await ws.accept(); self.active[aid] = ws def disconnect(self, aid: str): self.active.pop(aid, None) async def broadcast(self, data: dict): dead = [] for aid, ws in self.active.items(): try: await ws.send_json(data) except: dead.append(aid) for aid in dead: self.disconnect(aid) async def send_to(self, aid: str, data: dict): if ws := self.active.get(aid): try: await ws.send_json(data) except: self.disconnect(aid) manager = ConnectionManager() # ── Telemetry broadcast loop ────────────────────────────────────────────────── async def telemetry_loop(): while True: await manager.broadcast({ "type": "BROADCAST_SIGNAL", "telemetry": { "cpu": psutil.cpu_percent(), "mem": psutil.virtual_memory().percent } }) await asyncio.sleep(1) @asynccontextmanager async def lifespan(app: FastAPI): asyncio.create_task(telemetry_loop()) yield # ── FastAPI app ─────────────────────────────────────────────────────────────── app = FastAPI(lifespan=lifespan) app.add_middleware( CORSMiddleware, allow_origins=["*"], allow_methods=["*"], allow_headers=["*"] ) # ── REST · state ────────────────────────────────────────────────────────────── # module_id w URL — topologia A: zawsze MODULE_ID; topologia B: routing per moduł. @app.get("/api/{module_id}/state") async def get_state(module_id: str): return { "activity_key": "mysli", "started_at": int(time.time() * 1000), "duration_ms": 9000, "metrics": {} } # ── REST · log ──────────────────────────────────────────────────────────────── @app.get("/api/{module_id}/log") async def get_log(module_id: str, limit: int = 40): return [] # zaimplementuj odczyt z .data/<id>/ # ── WebSocket · AiWBroadcast (opcjonalny) ───────────────────────────────────── @app.websocket("/ws/broadcast") async def ws_broadcast(ws: WebSocket): await manager.connect("broadcast", ws) try: while True: await asyncio.sleep(60) # keepalive except WebSocketDisconnect: manager.disconnect("broadcast") # ── WebSocket · AiWProtocol (kanał artefaktu) ───────────────────────────────── # artifact_id z URL — topologia A: zawsze MODULE_ID; topologia B: dowolny id klienta. @app.websocket("/ws/{artifact_id}") async def ws_protocol(ws: WebSocket, artifact_id: str): await manager.connect(artifact_id, ws) try: while True: data = await ws.receive_json() if data.get("type") == "ACTION": await handle_action(artifact_id, data, manager) except WebSocketDisconnect: manager.disconnect(artifact_id) async def handle_action(artifact_id: str, data: dict, mgr: ConnectionManager): # zaimplementuj obsługę akcji; mgr.send_to(artifact_id, ...) lub mgr.broadcast(...) pass # ── Uruchamianie ────────────────────────────────────────────────────────────── # Topologia A — dedykowany port per moduł (domyślna konwencja): # cd engines/breath && uv run uvicorn breath.main:app --port 8005 --reload # Topologia B — wspólny port dla wielu modułów: # cd engines/hub && uv run uvicorn hub.main:app --port 8000 --reload # (artefakty różnych modułów łączą się po /ws/{artifact_id} i /api/{module_id}/)