From c273272e521c2858dff8dfd2e026cbb246aa1ef2 Mon Sep 17 00:00:00 2001 From: Peter Steinberger Date: Mon, 28 Jul 2025 16:05:22 +0200 Subject: [PATCH] update push event --- web/src/server/routes/events.ts | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/web/src/server/routes/events.ts b/web/src/server/routes/events.ts index cb6ebda3..1af44be7 100644 --- a/web/src/server/routes/events.ts +++ b/web/src/server/routes/events.ts @@ -1,5 +1,5 @@ import { type Request, type Response, Router } from 'express'; -import { type ServerEvent } from '../../shared/types.js'; +import { type ServerEvent, ServerEventType } from '../../shared/types.js'; import type { SessionMonitor } from '../services/session-monitor.js'; import { createLogger } from '../utils/logger.js'; @@ -64,11 +64,17 @@ export function createEventsRouter(sessionMonitor?: SessionMonitor): Router { // SessionMonitor already provides properly formatted ServerEvent objects logger.info(`๐Ÿ“ข SessionMonitor notification: ${event.type} for session ${event.sessionId}`); + // Log test notifications specifically for debugging + if (event.type === ServerEventType.TestNotification) { + logger.info('๐Ÿงช Forwarding test notification through SSE:', event); + } + // Proper SSE format with id, event, and data fields const sseMessage = `id: ${++eventId}\nevent: ${event.type}\ndata: ${JSON.stringify(event)}\n\n`; try { res.write(sseMessage); + logger.debug(`โœ… SSE event written: ${event.type}`); } catch (error) { logger.debug('Failed to write SSE event:', error); cleanup();