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

fix(telegram): prioritize explicit editMessageId in delivery to fix fast status update bug

Browse Source
This commit is contained in:
USO Status 2026-01-26 22:17:51 +01:00
parent 0152717535
commit 6aec985b1b
1 changed files with 7 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
src/telegram/bot/delivery.ts
View File

@ -7,7 +7,7 @@ import {
} from "../format.js"; } from "../format.js";
import { chunkMarkdownTextWithMode, type ChunkMode } from "../../auto-reply/chunk.js"; import { chunkMarkdownTextWithMode, type ChunkMode } from "../../auto-reply/chunk.js";
import { splitTelegramCaption } from "../caption.js"; import { splitTelegramCaption } from "../caption.js";
import { getLastSentMessage, recordSentMessage } from "../sent-message-cache.js"; import { recordSentMessage } from "../sent-message-cache.js";
import type { ReplyPayload } from "../../auto-reply/types.js"; import type { ReplyPayload } from "../../auto-reply/types.js";
import type { ReplyToMode } from "../../config/config.js"; import type { ReplyToMode } from "../../config/config.js";
import type { MarkdownTableMode } from "../../config/types.base.js"; import type { MarkdownTableMode } from "../../config/types.base.js";
@ -83,26 +83,20 @@ export async function deliverReplies(params: {
? [reply.mediaUrl] ? [reply.mediaUrl]
: []; : [];
if (mediaList.length === 0) { if (mediaList.length === 0) {
// Check if the previous message was a status message.
// If so, we should edit it instead of sending a new message.
const lastSent = getLastSentMessage(chatId);
const shouldEditLast =
lastSent?.isStatus && lastSent.messageId && Date.now() - lastSent.timestamp < 120000; // 2 min threshold
let sentMessageId: string | undefined; let sentMessageId: string | undefined;
const explicitEditId = reply.editMessageId;
if (shouldEditLast && reply.text) { if (explicitEditId && reply.text) {
const editId = String(lastSent!.messageId); // Explicit edit requested by StatusUpdateController/agent-runner
try { try {
await editMessageTelegram(chatId, editId, reply.text, { await editMessageTelegram(chatId, explicitEditId, reply.text, {
token: params.token, token: params.token,
accountId: params.accountId, accountId: params.accountId,
api: bot.api, api: bot.api,
}); });
sentMessageId = editId; sentMessageId = explicitEditId;
} catch (err) { } catch (err) {
logVerbose(`Telegram edit failed, falling back to new message: ${String(err)}`); logVerbose(`Telegram explicit edit failed, falling back to new message: ${String(err)}`);
// Fall through to send new message // Fall through to send new message
} }
} }