fix telegram partial progress coalescing · openclaw/openc...

Recent Commits to openclaw:main

2026-05-10 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -1032,6 +1032,31 @@ describe("dispatchTelegramMessage draft streaming", () => {`
`1032`	`1032`	`expect(deliverReplies).not.toHaveBeenCalled();`
`1033`	`1033`	`});`
`1034`	`1034`
	`1035`	`+it("does not coalesce answer partial fragments with tool progress drafts", async () => {`
	`1036`	`+const { answerDraftStream } = setupDraftStreams({ answerMessageId: 2001 });`
	`1037`	`+dispatchReplyWithBufferedBlockDispatcher.mockImplementation(`
	`1038`	`+async ({ dispatcherOptions, replyOptions }) => {`
	`1039`	`+await replyOptions?.onToolStart?.({ name: "exec", phase: "start" });`
	`1040`	`+await replyOptions?.onPartialReply?.({ text: "Done " });`
	`1041`	`+await replyOptions?.onPartialReply?.({ text: "answer" });`
	`1042`	`+await dispatcherOptions.deliver({ text: "Done answer." }, { kind: "final" });`
	`1043`	`+return { queuedFinal: true };`
	`1044`	`+},`
	`1045`	`+);`
	`1046`	`+`
	`1047`	`+await dispatchWithContext({`
	`1048`	`+context: createContext(),`
	`1049`	`+streamMode: "partial",`
	`1050`	`+telegramCfg: { streaming: { mode: "partial" } },`
	`1051`	`+});`
	`1052`	`+`
	`1053`	`+expect(answerDraftStream.update).toHaveBeenNthCalledWith(1, expect.stringMatching(/Exec/));`
	`1054`	`+expect(answerDraftStream.update).toHaveBeenNthCalledWith(2, "Done ");`
	`1055`	`+expect(answerDraftStream.update).toHaveBeenNthCalledWith(3, "Done answer");`
	`1056`	`+expect(answerDraftStream.update).toHaveBeenLastCalledWith("Done answer.");`
	`1057`	`+expect(deliverReplies).not.toHaveBeenCalled();`
	`1058`	`+});`
	`1059`	`+`
`1035`	`1060`	`it("rotates the answer stream only after a finalized assistant message", async () => {`
`1036`	`1061`	`const { answerDraftStream } = setupDraftStreams({ answerMessageId: 2001 });`
`1037`	`1062`	`dispatchReplyWithBufferedBlockDispatcher.mockImplementation(`

Original file line number	Diff line number	Diff line change
`@@ -613,6 +613,7 @@ export const dispatchTelegramMessage = async ({`
`613`	`613`	`Boolean(answerLane.stream) && resolveChannelStreamingPreviewToolProgress(telegramCfg);`
`614`	`614`	`let streamToolProgressSuppressed = false;`
`615`	`615`	`let streamToolProgressLines: string[] = [];`
	`616`	`+let lastAnswerPartialText = "";`
`616`	`617`	`const renderProgressDraft = async (options?: { flush?: boolean }) => {`
`617`	`618`	`if (!answerLane.stream \|\| streamMode !== "progress") {`
`618`	`619`	`return;`
`@@ -739,6 +740,9 @@ export const dispatchTelegramMessage = async ({`
`739`	`740`	`};`
`740`	`741`	`const resetDraftLaneState = (lane: DraftLaneState) => {`
`741`	`742`	`lane.lastPartialText = "";`
	`743`	`+if (lane === answerLane) {`
	`744`	`+lastAnswerPartialText = "";`
	`745`	`+}`
`742`	`746`	`lane.hasStreamedMessage = false;`
`743`	`747`	`lane.finalized = false;`
`744`	`748`	`};`
`@@ -762,7 +766,8 @@ export const dispatchTelegramMessage = async ({`
`762`	`766`	`if (!laneStream \|\| !text) {`
`763`	`767`	`return;`
`764`	`768`	`}`
`765`		`-const nextText = resolveDraftPartialText(lane.lastPartialText, text);`
	`769`	`+const previousText = lane === answerLane ? lastAnswerPartialText : lane.lastPartialText;`
	`770`	`+const nextText = resolveDraftPartialText(previousText, text);`
`766`	`771`	`if (!nextText) {`
`767`	`772`	`return;`
`768`	`773`	`}`
`@@ -775,6 +780,9 @@ export const dispatchTelegramMessage = async ({`
`775`	`780`	`}`
`776`	`781`	`lane.hasStreamedMessage = true;`
`777`	`782`	`lane.finalized = false;`
	`783`	`+if (lane === answerLane) {`
	`784`	`+lastAnswerPartialText = nextText;`
	`785`	`+}`
`778`	`786`	`lane.lastPartialText = nextText;`
`779`	`787`	`laneStream.update(nextText);`
`780`	`788`	`};`

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

推荐订阅源

Recent Commits to openclaw:main