fix(telegram): honor outbound media max bytes (#83478) · ...

Recent Commits to openclaw:main

luoyanglang · 2026-05-23 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -372,6 +372,7 @@ export function createTelegramBotCore(`
`372`	`372`	`groupAllowFrom,`
`373`	`373`	`replyToMode,`
`374`	`374`	`textLimit,`
	`375`	`+ mediaMaxBytes,`
`375`	`376`	`useAccessGroups,`
`376`	`377`	`nativeEnabled,`
`377`	`378`	`nativeSkillsEnabled,`

Original file line number	Diff line number	Diff line change
`@@ -1790,6 +1790,7 @@ describe("dispatchTelegramMessage draft streaming", () => {`
`1790`	`1790`
`1791`	`1791`	`it("keeps streamed final text in place when late media arrives", async () => {`
`1792`	`1792`	`const { answerDraftStream } = setupDraftStreams({ answerMessageId: 2001 });`
	`1793`	`+const mediaMaxBytes = 50 * 1024 * 1024;`
`1793`	`1794`	`dispatchReplyWithBufferedBlockDispatcher.mockImplementation(`
`1794`	`1795`	`async ({ dispatcherOptions, replyOptions }) => {`
`1795`	`1796`	`await replyOptions?.onPartialReply?.({ text: "Photo" });`
`@@ -1801,10 +1802,14 @@ describe("dispatchTelegramMessage draft streaming", () => {`
`1801`	`1802`	`},`
`1802`	`1803`	`);`
`1803`	`1804`
`1804`		`-await dispatchWithContext({ context: createContext() });`
	`1805`	`+await dispatchWithContext({`
	`1806`	`+context: createContext(),`
	`1807`	`+telegramCfg: { mediaMaxMb: 50 },`
	`1808`	`+});`
`1805`	`1809`
`1806`	`1810`	`expect(answerDraftStream.clear).not.toHaveBeenCalled();`
`1807`	`1811`	`expect(answerDraftStream.update).toHaveBeenCalledWith("Photo");`
	`1812`	`+expectDeliverRepliesParams({ mediaMaxBytes });`
`1808`	`1813`	`expectDeliveredReply(0, { text: undefined, mediaUrl: "https://example.com/a.png" });`
`1809`	`1814`	`});`
`1810`	`1815`

Original file line number	Diff line number	Diff line change
`@@ -228,7 +228,7 @@ type DispatchTelegramMessageParams = {`
`228`	`228`	`textLimit: number;`
`229`	`229`	`telegramCfg: TelegramAccountConfig;`
`230`	`230`	`telegramDeps?: TelegramBotDeps;`
`231`		`-opts: Pick<TelegramBotOptions, "token">;`
	`231`	`+opts: Pick<TelegramBotOptions, "token" \| "mediaMaxMb">;`
`232`	`232`	`};`
`233`	`233`
`234`	`234`	`type TelegramReasoningLevel = "off" \| "on" \| "stream";`
`@@ -1001,6 +1001,7 @@ export const dispatchTelegramMessage = async ({`
`1001`	`1001`	`runtime,`
`1002`	`1002`	`bot,`
`1003`	`1003`	`mediaLocalRoots,`
	`1004`	`+mediaMaxBytes: (opts.mediaMaxMb ?? telegramCfg.mediaMaxMb ?? 100) * 1024 * 1024,`
`1004`	`1005`	`replyToMode,`
`1005`	`1006`	`textLimit,`
`1006`	`1007`	`thread: threadSpec,`

Original file line number	Diff line number	Diff line change
`@@ -59,8 +59,8 @@ function registerPlugCommand(params: PlugCommandHarnessParams = {}) {`
`59`	`59`	`registerTelegramNativeCommands({`
`60`	`60`	`...createNativeCommandTestParams(params.cfg ?? {}, {`
`61`	`61`	`bot: botHarness.bot,`
`62`		`- ...params.registerOverrides,`
`63`	`62`	`}),`
	`63`	`+ ...params.registerOverrides,`
`64`	`64`	`});`
`65`	`65`	`const handler = botHarness.commandHandlers.get("plug");`
`66`	`66`	`if (!handler) {`
`@@ -371,6 +371,7 @@ describe("registerTelegramNativeCommands", () => {`
`371`	`371`	`});`
`372`	`372`
`373`	`373`	`it("passes agent-scoped media roots for plugin command replies with media", async () => {`
	`374`	`+const mediaMaxBytes = 50 * 1024 * 1024;`
`374`	`375`	`const cfg: OpenClawConfig = {`
`375`	`376`	`agents: {`
`376`	`377`	`list: [{ id: "main", default: true }, { id: "work" }],`
`@@ -384,11 +385,15 @@ describe("registerTelegramNativeCommands", () => {`
`384`	`385`	`text: "with media",`
`385`	`386`	`mediaUrl: "/tmp/workspace-work/render.png",`
`386`	`387`	`},`
	`388`	`+registerOverrides: {`
	`389`	`+ mediaMaxBytes,`
	`390`	`+} as Partial<Parameters<typeof registerTelegramNativeCommands>[0]>,`
`387`	`391`	`});`
`388`	`392`
`389`	`393`	`await handler(createPrivateCommandContext());`
`390`	`394`
`391`	`395`	`const deliverParams = firstDeliverRepliesParams();`
	`396`	`+expect(deliverParams.mediaMaxBytes).toBe(mediaMaxBytes);`
`392`	`397`	`const mediaLocalRoots = deliverParams.mediaLocalRoots as Array<string> \| undefined;`
`393`	`398`	`expect(mediaLocalRoots?.some((root) => /[\\/]\.openclaw[\\/]workspace-work$/.test(root))).toBe(`
`394`	`399`	`true,`

Original file line number	Diff line number	Diff line change
`@@ -467,6 +467,7 @@ export type RegisterTelegramNativeCommandsParams = {`
`467`	`467`	`groupAllowFrom?: Array<string \| number>;`
`468`	`468`	`replyToMode: ReplyToMode;`
`469`	`469`	`textLimit: number;`
	`470`	`+mediaMaxBytes?: number;`
`470`	`471`	`useAccessGroups: boolean;`
`471`	`472`	`nativeEnabled: boolean;`
`472`	`473`	`nativeSkillsEnabled: boolean;`
`@@ -693,6 +694,7 @@ export const registerTelegramNativeCommands = ({`
`693`	`694`	`groupAllowFrom,`
`694`	`695`	`replyToMode,`
`695`	`696`	`textLimit,`
	`697`	`+ mediaMaxBytes,`
`696`	`698`	`useAccessGroups,`
`697`	`699`	`nativeEnabled,`
`698`	`700`	`nativeSkillsEnabled,`
`@@ -933,6 +935,7 @@ export const registerTelegramNativeCommands = ({`
`933`	`935`	`runtime,`
`934`	`936`	`bot,`
`935`	`937`	`mediaLocalRoots: params.mediaLocalRoots,`
	`938`	`+ mediaMaxBytes,`
`936`	`939`	`replyToMode,`
`937`	`940`	`textLimit,`
`938`	`941`	`thread: params.threadSpec,`

Original file line number	Diff line number	Diff line change
`@@ -331,6 +331,7 @@ async function deliverMediaReply(params: {`
`331`	`331`	`thread?: TelegramThreadSpec \| null;`
`332`	`332`	`tableMode?: MarkdownTableMode;`
`333`	`333`	`mediaLocalRoots?: readonly string[];`
	`334`	`+mediaMaxBytes?: number;`
`334`	`335`	`chunkText: ChunkTextFn;`
`335`	`336`	`mediaLoader: typeof loadWebMedia;`
`336`	`337`	`onVoiceRecording?: () => Promise<void> \| void;`
`@@ -353,7 +354,10 @@ async function deliverMediaReply(params: {`
`353`	`354`	`const isFirstMedia = first;`
`354`	`355`	`const media = await params.mediaLoader(`
`355`	`356`	`mediaUrl,`
`356`		`-buildOutboundMediaLoadOptions({ mediaLocalRoots: params.mediaLocalRoots }),`
	`357`	`+buildOutboundMediaLoadOptions({`
	`358`	`+mediaLocalRoots: params.mediaLocalRoots,`
	`359`	`+maxBytes: params.mediaMaxBytes,`
	`360`	`+}),`
`357`	`361`	`);`
`358`	`362`	`const kind = kindFromMime(media.contentType ?? undefined);`
`359`	`363`	`const isGif = isGifMedia({`
`@@ -693,6 +697,7 @@ export async function deliverReplies(params: {`
`693`	`697`	`runtime: RuntimeEnv;`
`694`	`698`	`bot: Bot;`
`695`	`699`	`mediaLocalRoots?: readonly string[];`
	`700`	`+mediaMaxBytes?: number;`
`696`	`701`	`replyToMode: ReplyToMode;`
`697`	`702`	`textLimit: number;`
`698`	`703`	`thread?: TelegramThreadSpec \| null;`
`@@ -879,6 +884,7 @@ export async function deliverReplies(params: {`
`879`	`884`	`thread: params.thread,`
`880`	`885`	`tableMode: params.tableMode,`
`881`	`886`	`mediaLocalRoots: params.mediaLocalRoots,`
	`887`	`+mediaMaxBytes: params.mediaMaxBytes,`
`882`	`888`	`chunkText,`
`883`	`889`	`mediaLoader,`
`884`	`890`	`onVoiceRecording: params.onVoiceRecording,`

Original file line number	Diff line number	Diff line change
`@@ -751,6 +751,33 @@ describe("deliverReplies", () => {`
`751`	`751`	`});`
`752`	`752`	`});`
`753`	`753`
	`754`	`+it("passes the configured media byte cap to media loading", async () => {`
	`755`	`+const runtime = createRuntime();`
	`756`	`+const sendPhoto = vi.fn().mockResolvedValue({`
	`757`	`+message_id: 13,`
	`758`	`+chat: { id: "123" },`
	`759`	`+});`
	`760`	`+const bot = createBot({ sendPhoto });`
	`761`	`+const mediaMaxBytes = 50 * 1024 * 1024;`
	`762`	`+`
	`763`	`+mockMediaLoad("photo.jpg", "image/jpeg", "image");`
	`764`	`+`
	`765`	`+await deliverReplies({`
	`766`	`+replies: [{ mediaUrl: "https://example.com/photo.jpg" }],`
	`767`	`+chatId: "123",`
	`768`	`+token: "tok",`
	`769`	`+ runtime,`
	`770`	`+ bot,`
	`771`	`+replyToMode: "off",`
	`772`	`+textLimit: 4000,`
	`773`	`+ mediaMaxBytes,`
	`774`	`+});`
	`775`	`+`
	`776`	`+expect(loadWebMedia).toHaveBeenCalledWith("https://example.com/photo.jpg", {`
	`777`	`+maxBytes: mediaMaxBytes,`
	`778`	`+});`
	`779`	`+});`
	`780`	`+`
`754`	`781`	`it("includes link_preview_options when linkPreview is false", async () => {`
`755`	`782`	`const runtime = createRuntime();`
`756`	`783`	`const sendMessage = vi.fn().mockResolvedValue({`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main