[Fix] Telegram working status disappears during active Fast turns

packages/sdk/src/server/lib/fast-agent-parent-event.ts

@@ -118,7 +118,10 @@ import {
   type TelegramLiveTaskStreamProvider,
 } from './telegram-live-task-stream';
 import { createFastAgentTypingActivity } from './fast-agent-typing-activity';
-import { createFastAgentTelegramActivity } from './fast-agent-telegram-activity';
+import {
+  createFastAgentTelegramActivity,
+  runWithFastAgentTelegramActivityReassertion,
+} from './fast-agent-telegram-activity';
 import { findTeamsConversationRoute } from '../automations/destination';
 import {
   isFastAgentManagedTelegramTopic,
@@ -1903,20 +1906,25 @@ async function createTelegramFastAgentParentTurn(
     sessionId: session.id,
     footerContext: params.footerContext,
   });
+  const launchTask = createFastAgentCommunicationTaskLauncher({
+    userId: actorUserId,
+    conversation,
+    telegramLiveTaskProvider: provider,
+    automation: await resolveFastAutomationLaunchContext({
+      event: params.event,
+      conversation,
+    }),
+  });
   return {
     userId: actorUserId,
     conversation,
     adapter: {
       activity,
-      launchTask: createFastAgentCommunicationTaskLauncher({
-        userId: actorUserId,
-        conversation,
-        telegramLiveTaskProvider: provider,
-        automation: await resolveFastAutomationLaunchContext({
-          event: params.event,
-          conversation,
-        }),
-      }),
+      launchTask: async (input) => {
+        return runWithFastAgentTelegramActivityReassertion(activity, () =>
+          launchTask(input),
+        );
+      },
       replaceReply: async (handle, reply) => {
         const result = await replaceReply(handle, reply);
         activity.reassert();

packages/sdk/src/server/lib/fast-agent-surface-reply.ts

@@ -78,7 +78,10 @@ import {
 } from './source-control-fast-delivery';
 import { buildFastAgentArtifactCreator } from './artifacts/fast-agent-artifact-creator';
 import { createFastAgentTypingActivity } from './fast-agent-typing-activity';
-import { createFastAgentTelegramActivity } from './fast-agent-telegram-activity';
+import {
+  createFastAgentTelegramActivity,
+  runWithFastAgentTelegramActivityReassertion,
+} from './fast-agent-telegram-activity';
 import { addFastAgentTelegramTopicTitleSync } from './fast-agent-telegram-title-sync';
 
 const SLACK_QUOTE_MAX_LENGTH = 100;
@@ -640,6 +643,11 @@ export async function buildFastAgentSurfaceReplyDelivery(params: {
       sessionId: session.id,
       footerContext,
     });
+    const launchTask = createFastAgentCommunicationTaskLauncher({
+      userId: params.userId,
+      conversation,
+      telegramLiveTaskProvider: provider,
+    });
     const postReply: FastAgentTurnAdapter['postReply'] = async ({
       message,
     }) => {
@@ -679,11 +687,11 @@ export async function buildFastAgentSurfaceReplyDelivery(params: {
             }
           : {}),
         createArtifact,
-        launchTask: createFastAgentCommunicationTaskLauncher({
-          userId: params.userId,
-          conversation,
-          telegramLiveTaskProvider: provider,
-        }),
+        launchTask: async (input) => {
+          return runWithFastAgentTelegramActivityReassertion(activity, () =>
+            launchTask(input),
+          );
+        },
         postReply,
         replaceReply: async (handle, reply) => {
           const result = await replaceReply(handle, reply);

packages/sdk/src/server/lib/fast-agent-telegram-activity.ts

@@ -21,6 +21,17 @@ export const FAST_AGENT_TELEGRAM_PROCESSING_DELAY_MS = 300;
 export const FAST_AGENT_TELEGRAM_STREAM_INTERVAL_MS = 800;
 const FAST_AGENT_TELEGRAM_THINKING_TEXT = 'Roomote is working...';
 
+export async function runWithFastAgentTelegramActivityReassertion<T>(
+  activity: { reassert: () => void },
+  operation: () => Promise<T>,
+): Promise<T> {
+  try {
+    return await operation();
+  } finally {
+    activity.reassert();
+  }
+}
+
 function isTelegramPrivateChatId(channelId: string): boolean {
   const parsed = Number(channelId);
   return Number.isSafeInteger(parsed) && parsed > 0;

packages/sdk/src/server/lib/fast-agent-telegram-title-sync.ts

@@ -41,7 +41,8 @@ export async function syncFastAgentTelegramTopicTitleBestEffort(input: {
   category?: TaskTitleCategory | null;
   titleChanged?: boolean;
   resolveSession: () => Promise<FastAgentConversationRecord | null>;
-}): Promise<void> {
+}): Promise<boolean> {
+  let updated = false;
   try {
     for (let attempt = 0; attempt < 2; attempt += 1) {
       const session = await input.resolveSession();
@@ -51,7 +52,7 @@ export async function syncFastAgentTelegramTopicTitleBestEffort(input: {
         session.conversation.replyTarget.channelId !== input.channelId ||
         session.conversation.replyTarget.threadId !== input.threadId
       ) {
-        return;
+        return updated;
       }
 
       const title = buildCommunicationTaskThreadName(session.title);
@@ -63,32 +64,34 @@ export async function syncFastAgentTelegramTopicTitleBestEffort(input: {
             .catch(() => undefined)
         : undefined;
       if (input.titleChanged === false && !iconCustomEmojiId) {
-        return;
+        return updated;
       }
       await input.provider.editForumTopic({
         channelId: input.channelId,
         threadId: input.threadId,
         ...(input.titleChanged === false ? {} : { name: title }),
         ...(iconCustomEmojiId ? { iconCustomEmojiId } : {}),
       });
+      updated = true;
 
       if (input.titleChanged === false) {
-        return;
+        return updated;
       }
 
       const latest = await input.resolveSession();
       if (
         !latest?.title ||
         buildCommunicationTaskThreadName(latest.title) === title
       ) {
-        return;
+        return updated;
       }
     }
   } catch (error) {
     console.warn(
       `[Fast Agent] Failed to sync Telegram topic title for session ${input.sessionId}: ${error instanceof Error ? error.message : String(error)}`,
     );
   }
+  return updated;
 }
 
 export function addFastAgentTelegramTopicTitleSync<
@@ -126,13 +129,14 @@ export function addFastAgentTelegramTopicTitleSync<
       lastRequestedTitle = title;
       lastRequestedCategory = category;
       lastRequestedTitleChanged = titleChanged;
-      titleUpdate = titleUpdate.then(() =>
-        syncFastAgentTelegramTopicTitleBestEffort({
+      titleUpdate = titleUpdate.then(async () => {
+        const updated = await syncFastAgentTelegramTopicTitleBestEffort({
           ...input,
           category,
           titleChanged,
-        }),
-      );
+        });
+        if (updated) input.activity.reassert();
+      });
     },
     async dispose() {
       await Promise.all([input.activity.dispose(), titleUpdate]);