fix(telegram): notify users when agent returns empty response

Co-Authored-By: Claude Opus 4.5 <noreply@anthropic.com>
This commit is contained in:
kiranjd 2026-01-27 13:33:41 +05:30 committed by Ayaan Zaidi
parent 34291321b4
commit 80480132d2
3 changed files with 19 additions and 2 deletions

View File

@ -228,6 +228,7 @@ export const dispatchTelegramMessage = async ({
onVoiceRecording: sendRecordVoice, onVoiceRecording: sendRecordVoice,
linkPreview: telegramCfg.linkPreview, linkPreview: telegramCfg.linkPreview,
replyQuoteText, replyQuoteText,
notifyEmptyResponse: info.kind === "final",
}); });
}, },
onError: (err, info) => { onError: (err, info) => {

View File

@ -488,7 +488,7 @@ export const registerTelegramNativeCommands = ({
cfg, cfg,
dispatcherOptions: { dispatcherOptions: {
responsePrefix: resolveEffectiveMessagesConfig(cfg, route.agentId).responsePrefix, responsePrefix: resolveEffectiveMessagesConfig(cfg, route.agentId).responsePrefix,
deliver: async (payload) => { deliver: async (payload, info) => {
await deliverReplies({ await deliverReplies({
replies: [payload], replies: [payload],
chatId: String(chatId), chatId: String(chatId),
@ -501,6 +501,7 @@ export const registerTelegramNativeCommands = ({
tableMode, tableMode,
chunkMode, chunkMode,
linkPreview: telegramCfg.linkPreview, linkPreview: telegramCfg.linkPreview,
notifyEmptyResponse: info.kind === "final",
}); });
}, },
onError: (err, info) => { onError: (err, info) => {

View File

@ -44,7 +44,9 @@ export async function deliverReplies(params: {
linkPreview?: boolean; linkPreview?: boolean;
/** Optional quote text for Telegram reply_parameters. */ /** Optional quote text for Telegram reply_parameters. */
replyQuoteText?: string; replyQuoteText?: string;
}) { /** If true, send a fallback message when all replies are empty. Default: false */
notifyEmptyResponse?: boolean;
}): Promise<{ delivered: boolean }> {
const { const {
replies, replies,
chatId, chatId,
@ -58,6 +60,7 @@ export async function deliverReplies(params: {
} = params; } = params;
const chunkMode = params.chunkMode ?? "length"; const chunkMode = params.chunkMode ?? "length";
let hasReplied = false; let hasReplied = false;
let skippedEmpty = 0;
const chunkText = (markdown: string) => { const chunkText = (markdown: string) => {
const markdownChunks = const markdownChunks =
chunkMode === "newline" chunkMode === "newline"
@ -85,6 +88,7 @@ export async function deliverReplies(params: {
continue; continue;
} }
runtime.error?.(danger("reply missing text/media")); runtime.error?.(danger("reply missing text/media"));
skippedEmpty++;
continue; continue;
} }
const replyToId = replyToMode === "off" ? undefined : resolveTelegramReplyId(reply.replyToId); const replyToId = replyToMode === "off" ? undefined : resolveTelegramReplyId(reply.replyToId);
@ -268,6 +272,17 @@ export async function deliverReplies(params: {
} }
} }
} }
// If all replies were empty and notifyEmptyResponse is enabled, send a fallback message
if (!hasReplied && skippedEmpty > 0 && params.notifyEmptyResponse) {
const fallbackText = "No response generated. Please try again.";
await sendTelegramText(bot, chatId, fallbackText, runtime, {
messageThreadId,
});
hasReplied = true;
}
return { delivered: hasReplied };
} }
export async function resolveMedia( export async function resolveMedia(