feat(web): bridge logs to typed event stream

src/web/log-broadcaster.ts

@@ -1,5 +1,7 @@
-import type { Request, Response } from 'express';
+import type { Request, RequestHandler, Response } from 'express';
 import type { LogEntry } from './types.js';
+import { RealtimeEventHub } from './events/index.js';
+import { createExpressSseHandler } from './events/express-sse-adapter.js';
 
 const MAX_LOGS = 500;
 const INITIAL_LOGS_ON_CONNECT = 50;
@@ -11,6 +13,13 @@ const INITIAL_LOGS_ON_CONNECT = 50;
 export class LogBroadcaster {
   private entries: LogEntry[] = [];
   private clients = new Set<Response>();
+  private readonly eventHub: RealtimeEventHub;
+  readonly events: RequestHandler;
+
+  constructor(eventHub?: RealtimeEventHub) {
+    this.eventHub = eventHub ?? new RealtimeEventHub({ capacity: MAX_LOGS });
+    this.events = createExpressSseHandler({ hub: this.eventHub });
+  }
 
   push(level: LogEntry['level'], message: string, data?: unknown): void {
     const entry: LogEntry = { timestamp: Date.now(), level, message, data };
@@ -19,6 +28,10 @@ export class LogBroadcaster {
       this.entries = this.entries.slice(-MAX_LOGS);
     }
 
+    if (!this.eventHub.closed) {
+      this.eventHub.publish('log.created', { level, message, data });
+    }
+
     this.fanout(JSON.stringify({ type: 'log', ...entry }));
   }
 
@@ -76,5 +89,6 @@ export class LogBroadcaster {
       }
     }
     this.clients.clear();
+    this.eventHub.close();
   }
 }

src/web/routes/logs.ts

@@ -4,6 +4,7 @@ import type { WebContext } from '../context.js';
 export function createLogsRouter(ctx: WebContext): Router {
   const router = Router();
   router.get('/logs/stream', ctx.broadcaster.stream);
+  router.get('/events/stream', ctx.broadcaster.events);
   router.get('/logs', ctx.broadcaster.recent);
   return router;
 }