fix(telegram): retain preview on generation race

zhangguiping-xydt · obviyus · commit 0a4927d0b8c2 · 2026-06-03T18:28:13.000+05:30
diff --git a/extensions/telegram/src/draft-stream.test.ts b/extensions/telegram/src/draft-stream.test.ts
@@ -315,7 +315,7 @@ describe("createTelegramDraftStream", () => {
     }
   });
 
-  it("does not rebind to an old message when forceNewMessage races an in-flight send", async () => {
+  it("retains an old message when forceNewMessage races an in-flight send", async () => {
     let resolveFirstSend: ((value: { message_id: number }) => void) | undefined;
     const firstSend = new Promise<{ message_id: number }>((resolve) => {
       resolveFirstSend = resolve;
@@ -349,6 +349,7 @@ describe("createTelegramDraftStream", () => {
       textSnapshot: "Message A partial",
       parseMode: undefined,
       visibleSinceMs: supersededPreview.visibleSinceMs,
+      retain: true,
     });
     expect(typeof supersededPreview.visibleSinceMs).toBe("number");
     expect(Number.isFinite(supersededPreview.visibleSinceMs)).toBe(true);
diff --git a/extensions/telegram/src/draft-stream.ts b/extensions/telegram/src/draft-stream.ts
@@ -177,6 +177,7 @@ export function createTelegramDraftStream(params: {
         textSnapshot: renderedText,
         parseMode: renderedParseMode,
         visibleSinceMs,
+        retain: true,
       });
       return true;
     }

Original file line number	Diff line number	Diff line change
`@@ -177,6 +177,7 @@ export function createTelegramDraftStream(params: {`
`177`	`177`	`textSnapshot: renderedText,`
`178`	`178`	`parseMode: renderedParseMode,`
`179`	`179`	`visibleSinceMs,`
	`180`	`+ retain: true,`
`180`	`181`	`});`
`181`	`182`	`return true;`
`182`	`183`	`}`