fix(telegram): address progress preview review

Patrick-Erichsen · Patrick-Erichsen · commit 8941ca0af2a9 · 2026-05-18T21:04:33.000-07:00
diff --git a/docs/concepts/progress-drafts.md b/docs/concepts/progress-drafts.md
@@ -95,29 +95,29 @@ normal block delivery. Use `streaming.block.enabled` or legacy
 Progress labels live under `channels.<channel>.streaming.progress`.
 
 The default label is `auto`, which chooses from OpenClaw's built-in
-single-word-with-ellipsis label pool:
+single-word label pool:
 
 ```text
 Working
-Shelling...
-Scuttling...
-Clawing...
-Pinching...
-Molting...
-Bubbling...
-Tiding...
-Reefing...
-Cracking...
-Sifting...
-Brining...
-Nautiling...
-Krilling...
-Barnacling...
-Lobstering...
-Tidepooling...
-Pearling...
-Snapping...
-Surfacing...
+Shelling
+Scuttling
+Clawing
+Pinching
+Molting
+Bubbling
+Tiding
+Reefing
+Cracking
+Sifting
+Brining
+Nautiling
+Krilling
+Barnacling
+Lobstering
+Tidepooling
+Pearling
+Snapping
+Surfacing
 ```
 
 Use a fixed label:
diff --git a/extensions/telegram/src/bot-message-dispatch.ts b/extensions/telegram/src/bot-message-dispatch.ts
@@ -658,7 +658,9 @@ export const dispatchTelegramMessage = async ({
     return true;
   };
   const progressDraftGate = createChannelProgressDraftGate({
-    onStart: () => renderProgressDraft({ flush: true }),
+    onStart: async () => {
+      await renderProgressDraft({ flush: true });
+    },
   });
   const pushStreamToolProgress = async (
     line?: string | ChannelProgressDraftLine,
diff --git a/scripts/dev/channel-message-flows.ts b/scripts/dev/channel-message-flows.ts
@@ -9,6 +9,7 @@ import {
 } from "../../extensions/telegram/runtime-api.js";
 import { resolveTelegramAccount } from "../../extensions/telegram/src/accounts.js";
 import { normalizeTelegramApiRoot } from "../../extensions/telegram/src/api-root.js";
+import type { TelegramThreadSpec } from "../../extensions/telegram/src/bot/helpers.js";
 import {
   createTelegramDraftStream,
   type TelegramDraftStream,
@@ -226,6 +227,10 @@ function createTelegramFlowApi(params: { accountId?: string; cfg: OpenClawConfig
   } as Bot["api"];
 }
 
+export function resolveTelegramFlowThreadSpec(threadId?: number): TelegramThreadSpec | undefined {
+  return typeof threadId === "number" ? { id: threadId, scope: "forum" } : undefined;
+}
+
 function createDefaultTelegramDraftStream(params: {
   accountId?: string;
   cfg: OpenClawConfig;
@@ -240,8 +245,7 @@ function createDefaultTelegramDraftStream(params: {
       parseMode: "HTML",
       text: renderTelegramHtmlText(text, { textMode: "markdown" }),
     }),
-    thread:
-      typeof params.threadId === "number" ? { id: params.threadId, scope: "forum" } : undefined,
+    thread: resolveTelegramFlowThreadSpec(params.threadId),
     throttleMs: 250,
   });
 }
@@ -276,7 +280,7 @@ function createDefaultNativeToolProgressDraft(params: {
   const draft = createNativeTelegramToolProgressDraft({
     api: createTelegramNativeDraftApi(params),
     chatId: params.target,
-    thread: typeof params.threadId === "number" ? { id: params.threadId, scope: "dm" } : undefined,
+    thread: resolveTelegramFlowThreadSpec(params.threadId),
   });
   if (!draft) {
     throw new Error("Telegram Bot API client does not expose sendMessageDraft.");
diff --git a/test/scripts/channel-message-flows.test.ts b/test/scripts/channel-message-flows.test.ts
@@ -1,6 +1,7 @@
 import { describe, expect, it, vi } from "vitest";
 import {
   parseChannelMessageFlowArgs,
+  resolveTelegramFlowThreadSpec,
   runTelegramThinkingFinalFlow,
   runTelegramWorkingFinalFlow,
 } from "../../scripts/dev/channel-message-flows.ts";
@@ -174,4 +175,9 @@ describe("channel message flows dev runner", () => {
     expect(sleep).toHaveBeenCalledWith(2_000);
     expect(result.previewUpdates).toBe(7);
   });
+
+  it("maps flow thread ids to Telegram forum topic specs", () => {
+    expect(resolveTelegramFlowThreadSpec(42)).toEqual({ id: 42, scope: "forum" });
+    expect(resolveTelegramFlowThreadSpec()).toBeUndefined();
+  });
 });
