fix(streaming): suppress notification during streaming, notify only on final message

Author: grinev

src/bot/index.ts

@@ -369,7 +369,7 @@ async function ensureEventSubscription(directory: string): Promise<void> {
       return;
     }
 
-    preparedStreamPayload.sendOptions = undefined;
+    preparedStreamPayload.sendOptions = { disable_notification: true };
     preparedStreamPayload.editOptions = undefined;
 
     responseStreamer.enqueue(sessionId, messageId, preparedStreamPayload);

src/bot/utils/finalize-assistant-response.ts

@@ -37,7 +37,7 @@ export async function finalizeAssistantResponse({
 
   const preparedStreamPayload = prepareStreamingPayload(messageText);
   if (preparedStreamPayload) {
-    preparedStreamPayload.sendOptions = undefined;
+    preparedStreamPayload.sendOptions = { disable_notification: true };
     preparedStreamPayload.editOptions = undefined;
   }
 

tests/bot/utils/finalize-assistant-response.test.ts

@@ -27,7 +27,7 @@ describe("bot/utils/finalize-assistant-response", () => {
     expect(responseStreamer.complete).toHaveBeenCalledWith("s1", "m1", {
       parts: ["final reply"],
       format: "raw",
-      sendOptions: undefined,
+      sendOptions: { disable_notification: true },
       editOptions: undefined,
     });
     expect(flushPendingServiceMessages).toHaveBeenCalledTimes(1);
@@ -74,7 +74,7 @@ describe("bot/utils/finalize-assistant-response", () => {
     expect(responseStreamer.complete).toHaveBeenCalledWith("s1", "m1", {
       parts: ["reply"],
       format: "raw",
-      sendOptions: undefined,
+      sendOptions: { disable_notification: true },
       editOptions: undefined,
     });
     expect(flushPendingServiceMessages).toHaveBeenCalledTimes(1);