From d65ac6af1d83a610a346ba0f23719ef63b83ac01 Mon Sep 17 00:00:00 2001
From: Muhammed Mukhthar CM <mukhtharcm@gmail.com>
Date: Fri, 23 Jan 2026 11:08:29 +0000
Subject: [PATCH] Telegram-user: guard typing send errors

---
 extensions/telegram-user/src/monitor/handler.ts | 17 ++++++++++-------
 1 file changed, 10 insertions(+), 7 deletions(-)

diff --git a/extensions/telegram-user/src/monitor/handler.ts b/extensions/telegram-user/src/monitor/handler.ts
index 18519a112..ef2378a74 100644
--- a/extensions/telegram-user/src/monitor/handler.ts
+++ b/extensions/telegram-user/src/monitor/handler.ts
@@ -625,11 +625,12 @@ export function createTelegramUserMessageHandler(params: TelegramUserHandlerPara
             const mediaUrl = payload.mediaUrl;
             if (mediaUrl) {
               if (payload.audioAsVoice) {
-                await client
-                  .sendTyping(typingTarget, "record_voice", typingParams)
-                  .catch((err) => {
-                    runtime.error?.(`telegram-user voice typing failed: ${String(err)}`);
-                  });
+                try {
+                  await client.sendTyping(typingTarget, "record_voice", typingParams);
+                } catch (err) {
+                  if (isDestroyedClientError(err)) return;
+                  runtime.error?.(`telegram-user voice typing failed: ${String(err)}`);
+                }
               }
               try {
                 await sendMediaTelegramUser(replyTarget, replyText, {
@@ -675,10 +676,12 @@ export function createTelegramUserMessageHandler(params: TelegramUserHandlerPara
             }
           },
           onReplyStart: async () => {
-            await client.sendTyping(typingTarget, "typing", typingParams).catch((err) => {
+            try {
+              await client.sendTyping(typingTarget, "typing", typingParams);
+            } catch (err) {
               if (isDestroyedClientError(err)) return;
               runtime.error?.(`telegram-user typing failed: ${String(err)}`);
-            });
+            }
           },
           onError: (err) => {
             runtime.error?.(`telegram-user reply failed: ${String(err)}`);