);

expect(registerProviderMock).toHaveBeenCalledTimes(1);

return registerProviderMock.mock.calls[0]?.[0];

return registerProviderMock.mock.calls.at(0)?.[0];

}

function requireRecord(value: unknown, label: string): Record<string, unknown> {

}

function requireConfiguredStreamParams(): Record<string, unknown> {

return requireRecord(createConfiguredOllamaStreamFnMock.mock.calls[0]?.[0], "stream params");

return requireRecord(createConfiguredOllamaStreamFnMock.mock.calls.at(0)?.[0], "stream params");

}

function captureWrappedOllamaPayload(

],

});

const body = postJsonRequestMock.mock.calls[0]?.[0].body as {

const body = postJsonRequestMock.mock.calls.at(0)?.[0].body as {

input: Array<{ content: Array<Record<string, string>> }>;

};

expect(body.input[0]?.content).toEqual([

});

expect(postJsonRequestMock).toHaveBeenCalledTimes(2);

const firstBody = postJsonRequestMock.mock.calls[0]?.[0].body as {

const firstBody = postJsonRequestMock.mock.calls.at(0)?.[0].body as {

tools: Array<Record<string, unknown>>;

};

expect(firstBody.tools[0]).toEqual({

});

expect(startQaProviderServer).toHaveBeenCalledWith("mock-openai");

const [gatewayOptions] = startQaGatewayChild.mock.calls[0] ?? [];

const [gatewayOptions] = startQaGatewayChild.mock.calls.at(0) ?? [];

expect(gatewayOptions?.repoRoot).toBe("/tmp/openclaw-repo");

expect(gatewayOptions?.providerMode).toBe("mock-openai");

expect(gatewayOptions?.providerBaseUrl).toBe("http://127.0.0.1:44080/v1");

repoRoot: "/tmp/openclaw-repo",

embeddedGateway: "disabled",

});

const [gatewayOptions] = startQaGatewayChild.mock.calls[0] ?? [];

const [gatewayOptions] = startQaGatewayChild.mock.calls.at(0) ?? [];

expect(gatewayOptions?.providerMode).toBe("live-frontier");

expect(gatewayOptions?.providerBaseUrl).toBeUndefined();

expect(result.reply).toBe("Protocol note: mock reply.");

time: "5m",

});

const addCall = callGatewayToolMock.mock.calls[0];

const addCall = callGatewayToolMock.mock.calls.at(0);

const addPayload = addCall?.[2] as CronAddToolPayload | undefined;

expect(addCall?.[0]).toBe("cron.add");

expect(addCall?.[1]).toEqual({ timeoutMs: 60_000 });

time: "5m",

});

const cronParams = callCron.mock.calls[0]?.[0] as RemindCronAction | undefined;

const cronParams = callCron.mock.calls.at(0)?.[0] as RemindCronAction | undefined;

expect(cronParams?.action).toBe("add");

if (cronParams?.action !== "add") {

throw new Error("Expected add reminder cron params");

await getImageSizeFromUrl("https://cdn.example.com/photo.png");

expect(adapterMocks.fetchMedia).toHaveBeenCalledOnce();

const opts = adapterMocks.fetchMedia.mock.calls[0][0];

const opts = adapterMocks.fetchMedia.mock.calls.at(0)?.[0];

expect(opts.url).toBe("https://cdn.example.com/photo.png");

expect(opts.maxBytes).toBe(65_536);

await getImageSizeFromUrl("https://cdn.example.com/img.png", 3000);

const opts = adapterMocks.fetchMedia.mock.calls[0][0];

const opts = adapterMocks.fetchMedia.mock.calls.at(0)?.[0];

expect(opts.requestInit.signal).toBeInstanceOf(AbortSignal);

});

});

});

expect(postJsonRequestMock).toHaveBeenCalledTimes(1);

expectPostJsonRequest(postJsonRequestMock.mock.calls[0]?.[0], {

expectPostJsonRequest(postJsonRequestMock.mock.calls.at(0)?.[0], {

url: "https://dashscope-intl.aliyuncs.com/api/v1/services/aigc/video-generation/video-synthesis",

body: {

model: "wan2.6-r2v-flash",

});

expect(postJsonRequestMock).toHaveBeenCalledTimes(1);

expectPostJsonRequest(postJsonRequestMock.mock.calls[0]?.[0], {

expectPostJsonRequest(postJsonRequestMock.mock.calls.at(0)?.[0], {

url: "https://coding-intl.dashscope.aliyuncs.com/api/v1/services/aigc/video-generation/video-synthesis",

body: {

model: "wan2.6-t2v",

await vi.waitFor(() => {

expect(sendMock).toHaveBeenCalledTimes(1);

});

expect(sendMock.mock.calls[0][1]).toBe("PFX final reply");

expect(sendMock.mock.calls.at(0)?.[1]).toBe("PFX final reply");

});

it("replies with pairing code when dmPolicy is pairing and no allowFrom is set", async () => {

expect(replyMock).not.toHaveBeenCalled();

expect(upsertPairingRequestMock).toHaveBeenCalled();

expect(sendMock).toHaveBeenCalledTimes(1);

expectPairingReplyText(String(sendMock.mock.calls[0]?.[1] ?? ""), {

expectPairingReplyText(String(sendMock.mock.calls.at(0)?.[1] ?? ""), {

channel: "signal",

idLine: "Your Signal number: +15550001111",

code: "PAIRCODE",

});

expect(handleSlackMessage).toHaveBeenCalledTimes(1);

const call = handleSlackMessage.mock.calls[0] as unknown as

const call = handleSlackMessage.mock.calls.at(0) as unknown as

| [{ subtype?: string; channel?: string; user?: string }, { source?: string }]

| undefined;

expect(call?.[0]?.subtype).toBe("thread_broadcast");

});

expect(handleSlackMessage).toHaveBeenCalledTimes(1);

const call = handleSlackMessage.mock.calls[0] as unknown as

const call = handleSlackMessage.mock.calls.at(0) as unknown as

| [

{

channel?: string;

await runTavilySearch({ query: "test query" });

expect(postTrustedWebToolsJson).toHaveBeenCalledOnce();

const params = postTrustedWebToolsJson.mock.calls[0][0];

const params = postTrustedWebToolsJson.mock.calls.at(0)?.[0];

expect(params.extraHeaders).toEqual({ "X-Client-Source": "openclaw" });

});

it("runTavilyExtract sends X-Client-Source: openclaw", async () => {

await runTavilyExtract({ urls: ["https://example.com"] });

expect(postTrustedWebToolsJson).toHaveBeenCalledOnce();

const params = postTrustedWebToolsJson.mock.calls[0][0];

const params = postTrustedWebToolsJson.mock.calls.at(0)?.[0];

expect(params.extraHeaders).toEqual({ "X-Client-Source": "openclaw" });

});

});

expect(cachedSticker?.setName).toBe("NewSet");

expect(media?.stickerMetadata?.fileId).toBe("new_file_id");

expect(media?.stickerMetadata?.cachedDescription).toBe("Cached description");

const [fetchUrl, fetchOptions] = proxyFetch.mock.calls[0] ?? [];

const [fetchUrl, fetchOptions] = proxyFetch.mock.calls.at(0) ?? [];

expect(fetchUrl).toBe("https://api.telegram.org/file/bottok/stickers/sticker.webp");

expect(fetchOptions?.redirect).toBe("manual");

},

await flushScheduledTimerForDelay(setTimeoutSpy, TELEGRAM_TEST_TIMINGS.textFragmentGapMs);

expect(replySpy).toHaveBeenCalledTimes(1);

const payload = replySpy.mock.calls[0][0] as { RawBody?: string };

const payload = replySpy.mock.calls.at(0)?.[0] as { RawBody?: string };

expect(payload.RawBody).toContain(part1.slice(0, 32));

expect(payload.RawBody).toContain(part2.slice(0, 32));

} finally {