fix(telegram): clear split reasoning previews

stainlu · stainlu · commit 85b3a8d2a508 · 2026-05-12T17:26:52.000+08:00
diff --git a/CHANGELOG.md b/CHANGELOG.md
@@ -6,6 +6,7 @@ Docs: https://docs.openclaw.ai
 
 ### Fixes
 
+- Telegram: clear the previous `/reasoning stream` preview before starting a split reasoning segment, preventing stale reasoning messages from piling up while preserving final cleanup. Fixes #80862. Thanks @kyle20026.
 - Build: skip copied metadata for bundled plugins that are excluded from build entries, preventing update/status rebuilds from advertising missing QQ Bot runtime files. (#80925)
 - Control UI/sessions: nest subagent sessions under their parent session in the session picker dropdown using a visual `└─ ` prefix, making the parent-child relationship clear. Fixes #77628. (#78623) Thanks @chinar-amrutkar.
 
diff --git a/extensions/telegram/src/bot-message-dispatch.test.ts b/extensions/telegram/src/bot-message-dispatch.test.ts
@@ -1369,6 +1369,36 @@ describe("dispatchTelegramMessage draft streaming", () => {
     expect(deliverReplies).not.toHaveBeenCalled();
   });
 
+  it("clears an ended reasoning preview before starting a split reasoning segment", async () => {
+    const { answerDraftStream, reasoningDraftStream } = setupDraftStreams({
+      answerMessageId: 2001,
+      reasoningMessageId: 3001,
+    });
+    dispatchReplyWithBufferedBlockDispatcher.mockImplementation(
+      async ({ dispatcherOptions, replyOptions }) => {
+        await replyOptions?.onReasoningStream?.({ text: "<think>First</think>" });
+        await replyOptions?.onReasoningEnd?.();
+        await replyOptions?.onReasoningStream?.({ text: "<think>Second</think>" });
+        await dispatcherOptions.deliver({ text: "Answer" }, { kind: "final" });
+        return { queuedFinal: true };
+      },
+    );
+
+    await dispatchWithContext({ context: createReasoningStreamContext() });
+
+    expect(reasoningDraftStream.update).toHaveBeenNthCalledWith(1, "Reasoning:\n_First_");
+    expect(reasoningDraftStream.update).toHaveBeenNthCalledWith(2, "Reasoning:\n_Second_");
+    expect(reasoningDraftStream.clear).toHaveBeenCalledTimes(2);
+    expect(reasoningDraftStream.forceNewMessage).toHaveBeenCalledTimes(1);
+    const splitClearOrder = reasoningDraftStream.clear.mock.invocationCallOrder[0];
+    const splitForceOrder = reasoningDraftStream.forceNewMessage.mock.invocationCallOrder[0];
+    const secondReasoningUpdateOrder = reasoningDraftStream.update.mock.invocationCallOrder[1];
+    expect(splitClearOrder).toBeLessThan(splitForceOrder);
+    expect(splitForceOrder).toBeLessThan(secondReasoningUpdateOrder);
+    expect(answerDraftStream.update).toHaveBeenCalledWith("Answer");
+    expect(deliverReplies).not.toHaveBeenCalled();
+  });
+
   it("streams reasoning from configured defaults", async () => {
     const { answerDraftStream, reasoningDraftStream } = setupDraftStreams({
       answerMessageId: 2001,
diff --git a/extensions/telegram/src/bot-message-dispatch.ts b/extensions/telegram/src/bot-message-dispatch.ts
@@ -1439,6 +1439,7 @@ export const dispatchTelegramMessage = async ({
                     ? (payload) =>
                         enqueueDraftLaneEvent(async () => {
                           if (splitReasoningOnNextStream) {
+                            await reasoningLane.stream?.clear();
                             reasoningLane.stream?.forceNewMessage();
                             resetDraftLaneState(reasoningLane);
                             splitReasoningOnNextStream = false;
