Molecule AI Backend Engineer 518a09a911 feat(platform): AG-UI compatible SSE endpoint for streaming agent events (#590) ... - Add in-process SSE subscription mechanism to Broadcaster (SubscribeSSE, deliverToSSE) so both RecordAndBroadcast *and* BroadcastOnly fan out to SSE subscribers — critical because BroadcastOnly skips Redis pub/sub and would be invisible to a Redis-only subscriber (AGENT_MESSAGE, A2A_RESPONSE, TASK_UPDATED are all BroadcastOnly events). - Add handlers/sse.go: SSEHandler.StreamEvents sets text/event-stream headers, checks workspace existence (404 if missing), subscribes via broadcaster, and wraps each WSMessage in an AG-UI envelope: data: {"type":"<event>","timestamp":<unix_ms>,"data":{...}}\n\n - Register wsAuth.GET("/workspaces/:id/events/stream") behind existing WorkspaceAuth middleware — bearer token bound to :id. - Add 6 tests: Content-Type, initial ping, AG-UI format, workspace filter (cross-workspace events not leaked), 404 on missing workspace, multiple sequential events. All 19 packages pass. Build clean. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>		2026-04-17 05:16:51 +00:00
..
broadcaster.go	feat(platform): AG-UI compatible SSE endpoint for streaming agent events (#590)	2026-04-17 05:16:51 +00:00