From 2a76041e1916197d57857512f2c3b7f6782bceb3 Mon Sep 17 00:00:00 2001 From: Jannik Stehle Date: Thu, 20 Nov 2025 13:26:39 +0100 Subject: [PATCH] fix: catching errors in sse events (cherry picked from commit 00243a80fd6c8ff75f87cd42a78454c9fb0bd6ad) --- packages/web-runtime/src/container/sse/helpers.ts | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/packages/web-runtime/src/container/sse/helpers.ts b/packages/web-runtime/src/container/sse/helpers.ts index 9c12c9c69a..5ee2ea55f4 100644 --- a/packages/web-runtime/src/container/sse/helpers.ts +++ b/packages/web-runtime/src/container/sse/helpers.ts @@ -1,12 +1,12 @@ import { eventSchema, SseEventWrapperOptions } from './types' -export const sseEventWrapper = (options: SseEventWrapperOptions) => { +export const sseEventWrapper = async (options: SseEventWrapperOptions) => { const { topic, msg, method, ...sseEventOptions } = options try { const sseData = eventSchema.parse(JSON.parse(msg.data)) console.debug(`SSE event '${topic}'`, sseData) - return method({ ...sseEventOptions, sseData }) + await method({ ...sseEventOptions, sseData }) } catch (e) { console.error(`Unable to process sse event ${topic}`, e) }