socket.send(JSON.stringify({ id, result }));

}

function countMatching<T>(items: readonly T[], predicate: (item: T) => boolean): number {

let count = 0;

for (const item of items) {

if (predicate(item)) {

count += 1;

}

}

return count;

}

function replyToPageEnable(msg: CdpMockMessage, socket: WebSocket): boolean {

if (msg.method !== "Page.enable") {

return false;

}

if (msg.method === "Runtime.evaluate") {

// Pre-capture viewport probe + post-capture probe.

const isPre = events.filter((m) => m === "Runtime.evaluate").length === 1;

const isPre = countMatching(events, (m) => m === "Runtime.evaluate") === 1;

socket.send(

JSON.stringify({

id: msg.id,

const proveReplyThread = async () => {

mocks.sendMessageMatrix.mockClear();

const result = await adapter.send.text({

const result = await sendText({

cfg,

to: "room:!room:example",

text: "threaded",

type TelegramChunk = ReturnType<typeof markdownToTelegramChunks>[number];

function expectHtmlChunkLengthsAtMost(chunks: TelegramChunk[], limit: number) {

expect(

chunks

.map((chunk, index) => ({ index, htmlLength: chunk.html.length, text: chunk.text }))

.filter((chunk) => chunk.htmlLength > limit),

).toEqual([]);

expect(chunks.some((chunk) => chunk.html.length > limit)).toBe(false);

}

function expectNonBlankTextChunks(chunks: TelegramChunk[]) {

expect(

chunks

.map((chunk, index) => ({ index, text: chunk.text }))

.filter((chunk) => chunk.text.trim().length === 0),

).toEqual([]);

expect(chunks.some((chunk) => chunk.text.trim().length === 0)).toBe(false);

}

function expectHtmlChunksWrappedWith(chunks: TelegramChunk[], prefix: string, suffix: string) {

expect(

chunks

.map((chunk, index) => ({ index, html: chunk.html }))

.filter((chunk) => !chunk.html.startsWith(prefix) || !chunk.html.endsWith(suffix)),

).toEqual([]);

chunks.every((chunk) => chunk.html.startsWith(prefix) && chunk.html.endsWith(suffix)),

).toBe(true);

}

describe("wrapFileReferencesInHtml", () => {