createSequencedTestDraftStream,

createTestDraftStream,

} from "./draft-stream.test-helpers.js";

import { renderTelegramHtmlText } from "./format.js";

type DispatchReplyWithBufferedBlockDispatcherArgs = Parameters<

TelegramBotDeps["dispatchReplyWithBufferedBlockDispatcher"]

createTelegramDraftStream.mockReturnValue(draftStream);

dispatchReplyWithBufferedBlockDispatcher.mockImplementation(async ({ replyOptions }) => {

await replyOptions?.onToolStart?.({ name: "exec", phase: "start" });

await replyOptions?.onItemEvent?.({ progressText: "read [label](tg://user?id=123)" });

return { queuedFinal: false };

});

telegramCfg: { streaming: { preview: { toolProgress: true } } },

});

expect(draftStream.update).toHaveBeenCalledWith("Working…\n• tool: exec");

const lastPreviewText = draftStream.update.mock.calls.at(-1)?.[0];

expect(lastPreviewText).toBe("Working…\n• `tool: exec`\n• `read [label](tg://user?id=123)`");

expect(renderTelegramHtmlText(lastPreviewText ?? "")).not.toContain("<a ");

expect(dispatchReplyWithBufferedBlockDispatcher).toHaveBeenCalledWith(

expect.objectContaining({

replyOptions: expect.objectContaining({

return "off";

}

function formatProgressAsMarkdownCode(text: string): string {

const maxBacktickRun = Math.max(

0,

...Array.from(text.matchAll(/`+/g), (match) => match[0].length),

);

const fence = "`".repeat(maxBacktickRun + 1);

return `${fence}${text}${fence}`;

}

export const dispatchTelegramMessage = async ({

context,

bot,

return;

}

previewToolProgressLines = [...previewToolProgressLines, normalized].slice(-8);

const previewText = ["Working…", ...previewToolProgressLines.map((entry) => `• ${entry}`)].join(

"\n",

);

const previewText = [

"Working…",

...previewToolProgressLines.map((entry) => `• ${formatProgressAsMarkdownCode(entry)}`),

].join("\n");

answerLane.lastPartialText = previewText;

answerLane.stream.update(previewText);

};

expect(dispatcher.sendFinalReply).toHaveBeenCalledWith({ text: "done" });

});

it("delivers deterministic exec approval tool payloads for native commands", async () => {

it("delivers deterministic exec approval tool payloads for native commands with progress suppression", async () => {

setNoAbort();

const cfg = emptyConfig;

const dispatcher = createDispatcher();

return { text: "NO_REPLY" } satisfies ReplyPayload;

};

await dispatchReplyFromConfig({ ctx, cfg, dispatcher, replyResolver });

await dispatchReplyFromConfig({

ctx,

cfg,

dispatcher,

replyResolver,

replyOptions: { suppressDefaultToolProgressMessages: true },

});

expect(dispatcher.sendToolResult).toHaveBeenCalledTimes(1);

expect(firstToolResultPayload(dispatcher)).toEqual(