return fetchMock;

}

async function expectDownloadToRejectForResponse(response: Response, expected = /max bytes/i) {

async function expectDownloadToRejectForResponse(

response: Response,

expected: string | RegExp = /max bytes/i,

) {

vi.stubGlobal("fetch", vi.fn().mockResolvedValue(response));

await expect(

downloadGoogleChatMedia({ account, resourceName: "media/123", maxBytes: 10 }),

"content-type": "application/octet-stream",

}),

arrayBuffer,

} as Response;

} as unknown as Response;

await expectDownloadToRejectForResponse(response, "invalid content-length header: 0x3");

expect(arrayBuffer).not.toHaveBeenCalled();

status: 200,

headers: new Headers({ "content-length": "0x3" }),

arrayBuffer,

}) as Response,

}) as unknown as Response,

),

);

allowNameMatching: false,

});

expect(result.threadHistoryBody).toContain("malformed timestamp follow-up");

expect(result.threadHistoryBody).toContain("[slack message id: 0x65 channel: C123]");

expect(result.threadHistoryBody).not.toContain("1970-01-01");

const malformedHistoryEntry = result.threadHistoryBody

?.split("\n\n")

.find((entry) => entry.includes("malformed timestamp follow-up"));

expect(malformedHistoryEntry).toContain("[slack message id: 0x65 channel: C123]");

expect(malformedHistoryEntry).not.toContain("1970-01-01");

});

it("includes self-authored starter (identified by bot user id) for a new thread session (default)", async () => {