diff --git a/apps/api/src/modules/notification/websocket/sse.handler.ts b/apps/api/src/modules/notification/websocket/sse.handler.ts index 3ce2b760..996ee11b 100644 --- a/apps/api/src/modules/notification/websocket/sse.handler.ts +++ b/apps/api/src/modules/notification/websocket/sse.handler.ts @@ -46,7 +46,8 @@ export async function handleSSEConnection( } const query = request.query as Record; - const lastEventId = parseInt(query['lastEventId'] ?? '0', 10); + const parsedLastEventId = parseInt(query['lastEventId'] ?? '0', 10); + const lastEventId = Number.isNaN(parsedLastEventId) ? 0 : parsedLastEventId; sseResponse.sequence = lastEventId; const initialEvent = createSSEEvent(