{/* Mini brand bar */}

◆intent mirror

session 8af3 · replay-broadcaster · pending approval

{/* ── SECTION 1 · INTENT ───────────────────── */}

01INTENT

session 8af3· scope 14 files across 3 services· est 55 min · ~92 tool calls: plan v3 · revised 6m ago

Replace the polling-based event stream with a Redis-backed broadcaster so multiple clients can replay the same session timeline without each one opening its own /events subscription.

SUCCESS CRITERIA

01One /events stream serves N clients without duplicate tool-call records.

02Replay scrubber stays in sync across two browser tabs (drift < 1 event).

03Backpressure handled — slow clients don't stall the broadcaster queue.

04Full type-check + integration tests pass; existing /events consumers unaffected.

ASSUMPTIONS

{[ { i: 1, t: "Redis is already running and reachable via REDIS_URL env var." }, { i: 2, t: "Single Redis instance is sufficient — no clustering needed for v1." }, { i: 3, t: "Existing sessionStore queries are fast enough to not need caching." }, { i: 4, t: "Clients reconnect on disconnect — broadcaster doesn't need to replay buffered events." }, { i: 5, t: "events table can take a new broadcast_id column without migration drama." }, ].map(a => (

{ e.stopPropagation(); setPinnedAssump({ ...pinnedAssump, [a.i]: !pinnedAssump[a.i] }); }}> ✓ {a.t}

))}

OUT OF SCOPE

—Persisting broadcaster state across server restarts.

—Authenticating SSE connections (handled upstream by /auth).

—Rate-limiting per-client; assume trusted internal users for v1.

—Backfilling broadcast_id for historical events.

{/* ── SECTION 2 · ARCHITECTURE ─────────────── */}

02ARCHITECTURE

NEW MODIFIED UNCHANGED

{/* Clusters */} {clusters.map(c => (

{c.label}

))} {/* Edges */} {/* Edge labels (positioned at midpoints) */} {edges.map((e, i) => { const a = getNode(e.from), b = getNode(e.to); if (!a || !b) return null; const ax = a.x + 70, ay = a.y + 30, bx = b.x + 70, by = b.y + 30; const mx = (ax + bx) / 2 - 30; const my = (ay + by) / 2 - 6; return ( {e.label} ); })} {/* Nodes */} {nodes.map(n => (

setOpenNode(n.id)}> {n.state === "new" && "NEW"} {n.state === "modified" && (n.delta || "MOD")} {n.state === "unchanged" && "—"}

{n.label}

{n.type}

))} {/* Detail panel */} {sel && ( <>

setOpenNode(null)}/>

{sel.state.toUpperCase()} · {sel.type.toUpperCase()}

{sel.label}

src/server/services/ws-broadcaster.ts

RESPONSIBILITY

Single source of truth for broadcasting session events to subscribed clients. Bridges the per-session event stream to a Redis pubsub channel so any number of /events consumers (live or replay) see the same ordering.

CONTRACT

{`class `}WsBroadcaster{` { `}subscribe{`(sessionId: `}string{`): `}AsyncIterable<Event>{` `}publish{`(sessionId: `}string{`, event: `}Event{`): `}Promise<void>{` `}close{`(sessionId: `}string{`): `}void{` }`}

SIDE EFFECTS

publishes to Redis channel ccm:events:<sessionId>
writes broadcast_id into events table on each publish
holds an in-memory subscriber map; cleans up on close()

)}

{/* ── SECTION 3 · EXECUTION ────────────────── */}

03EXECUTION

Eleven steps across four phases.

11 steps · ~92 tool calls · est 55 min · 3 done · 1 running

{tasks.map((t, i) => (

{t.name}

{t.file} {t.phase}

{t.tools.map(([tool, n], j) => ( {tool}×{n} ))}

{t.status}

))}

{/* ── STICKY ACTION BAR ────────────────────── */}

4 phases · agent pauses after each · ⌘↵ approve · ⌘R replan · C comment