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

fix: remove sendMediaGroup method, use sendMediaGroupTelegram directly

Browse Source 
- Removed separate sendMediaGroup method that wasn't in the type
- Call sendMediaGroupTelegram directly instead of through deps
- Simplified the code while keeping album functionality in sendPayload
This commit is contained in:
Ubuntu 2026-01-28 13:30:40 +00:00
parent 01767f3504
commit 74b867084e
1 changed files with 1 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
src/channels/plugins/outbound/telegram.ts
View File

@ -53,7 +53,6 @@ export const telegramOutbound: ChannelOutboundAdapter = {
}, },
sendPayload: async ({ to, payload, accountId, deps, replyToId, threadId }) => { sendPayload: async ({ to, payload, accountId, deps, replyToId, threadId }) => {
const send = deps?.sendTelegram ?? sendMessageTelegram; const send = deps?.sendTelegram ?? sendMessageTelegram;
const sendGroup = deps?.sendMediaGroupTelegram ?? sendMediaGroupTelegram;
const replyToMessageId = parseReplyToMessageId(replyToId); const replyToMessageId = parseReplyToMessageId(replyToId);
const messageThreadId = parseThreadId(threadId); const messageThreadId = parseThreadId(threadId);
const telegramData = payload.channelData?.telegram as const telegramData = payload.channelData?.telegram as
@ -86,7 +85,7 @@ export const telegramOutbound: ChannelOutboundAdapter = {
// Use media group (album) for 2-10 images - sends as a single album // Use media group (album) for 2-10 images - sends as a single album
if (mediaUrls.length >= 2 && mediaUrls.length <= 10) { if (mediaUrls.length >= 2 && mediaUrls.length <= 10) {
const groupResult = await sendGroup(to, mediaUrls, text, { const groupResult = await sendMediaGroupTelegram(to, mediaUrls, text, {
messageThreadId, messageThreadId,
replyToMessageId, replyToMessageId,
accountId: accountId ?? undefined, accountId: accountId ?? undefined,
@ -101,7 +100,6 @@ export const telegramOutbound: ChannelOutboundAdapter = {
return { return {
channel: "telegram", channel: "telegram",
messageId: groupResult.messageIds[0] ?? "unknown", messageId: groupResult.messageIds[0] ?? "unknown",
messageIds: groupResult.messageIds,
chatId: groupResult.chatId, chatId: groupResult.chatId,
}; };
} }
@ -119,21 +117,4 @@ export const telegramOutbound: ChannelOutboundAdapter = {
} }
return { channel: "telegram", ...(finalResult ?? { messageId: "unknown", chatId: to }) }; return { channel: "telegram", ...(finalResult ?? { messageId: "unknown", chatId: to }) };
}, },
sendMediaGroup: async ({ to, mediaUrls, caption, accountId, deps, replyToId, threadId }) => {
const sendGroup = deps?.sendMediaGroupTelegram ?? sendMediaGroupTelegram;
const replyToMessageId = parseReplyToMessageId(replyToId);
const messageThreadId = parseThreadId(threadId);
const result = await sendGroup(to, mediaUrls, caption, {
messageThreadId,
replyToMessageId,
accountId: accountId ?? undefined,
});
// Return first message ID as the main one
return {
channel: "telegram",
messageId: result.messageIds[0] ?? "unknown",
messageIds: result.messageIds,
chatId: result.chatId,
};
},
}; };