romtuck/openclaw
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Telegram-user: skip typing when client destroyed

Browse Source
This commit is contained in:
Muhammed Mukhthar CM 2026-01-23 11:17:58 +00:00
parent d65ac6af1d
commit 62873a11b7
1 changed files with 38 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

50
extensions/telegram-user/src/monitor/handler.ts
View File

@ -78,6 +78,28 @@ function isDestroyedClientError(err: unknown): boolean {
return /client is destroyed/i.test(message); return /client is destroyed/i.test(message);
} }
function isClientDestroyed(client: TelegramClient): boolean {
const candidate = client as TelegramClient & { destroyed?: boolean };
return candidate.destroyed === true;
}
async function safeSendTyping(params: {
client: TelegramClient;
target: number | string;
status: Parameters<TelegramClient["sendTyping"]>[1];
typingParams?: Parameters<TelegramClient["sendTyping"]>[2];
runtime: TelegramUserHandlerParams["runtime"];
logLabel: string;
}) {
if (isClientDestroyed(params.client)) return;
try {
await params.client.sendTyping(params.target, params.status, params.typingParams);
} catch (err) {
if (isDestroyedClientError(err)) return;
params.runtime.error?.(`telegram-user ${params.logLabel} failed: ${String(err)}`);
}
}
function firstDefined<T>(...values: Array<T | undefined>): T | undefined { function firstDefined<T>(...values: Array<T | undefined>): T | undefined {
for (const value of values) { for (const value of values) {
if (typeof value !== "undefined") return value; if (typeof value !== "undefined") return value;
@ -625,12 +647,14 @@ export function createTelegramUserMessageHandler(params: TelegramUserHandlerPara
const mediaUrl = payload.mediaUrl; const mediaUrl = payload.mediaUrl;
if (mediaUrl) { if (mediaUrl) {
if (payload.audioAsVoice) { if (payload.audioAsVoice) {
try { await safeSendTyping({
await client.sendTyping(typingTarget, "record_voice", typingParams); client,
} catch (err) { target: typingTarget,
if (isDestroyedClientError(err)) return; status: "record_voice",
runtime.error?.(`telegram-user voice typing failed: ${String(err)}`); typingParams,
} runtime,
logLabel: "voice typing",
});
} }
try { try {
await sendMediaTelegramUser(replyTarget, replyText, { await sendMediaTelegramUser(replyTarget, replyText, {
@ -676,12 +700,14 @@ export function createTelegramUserMessageHandler(params: TelegramUserHandlerPara
} }
}, },
onReplyStart: async () => { onReplyStart: async () => {
try { await safeSendTyping({
await client.sendTyping(typingTarget, "typing", typingParams); client,
} catch (err) { target: typingTarget,
if (isDestroyedClientError(err)) return; status: "typing",
runtime.error?.(`telegram-user typing failed: ${String(err)}`); typingParams,
} runtime,
logLabel: "typing",
});
}, },
onError: (err) => { onError: (err) => {
runtime.error?.(`telegram-user reply failed: ${String(err)}`); runtime.error?.(`telegram-user reply failed: ${String(err)}`);