expect(result).toEqual(Buffer.from("mp3"));

expect(fetchMock).toHaveBeenCalledOnce();

const [url, init] = fetchMock.mock.calls[0] as [string, RequestInit];

const [url, init] = fetchMock.mock.calls.at(0) as [string, RequestInit];

expect(url).toBe("https://eastus.tts.speech.microsoft.com/cognitiveservices/v1");

expect(init.method).toBe("POST");

const headers = new Headers(init.headers);

});

expect(fetchMock).toHaveBeenCalledOnce();

const [url, init] = fetchMock.mock.calls[0] as [string, RequestInit];

const [url, init] = fetchMock.mock.calls.at(0) as [string, RequestInit];

expect(url).toBe("https://custom.example.com/cognitiveservices/voices/list");

expect(new Headers(init.headers).get("Ocp-Apim-Subscription-Key")).toBe("speech-key");

expect(init.signal).toBeInstanceOf(AbortSignal);

expect(runtime.channel.turn.runPrepared).not.toHaveBeenCalled();

expect(runtime.agent.runEmbeddedPiAgent).not.toHaveBeenCalled();

const completionRequest = (runtime.llm.complete as LlmCompleteMock).mock.calls[0]?.[0];

const completionRequest = (runtime.llm.complete as LlmCompleteMock).mock.calls.at(0)?.[0];

expect(completionRequest?.agentId).toBe("service-bot");

expect(completionRequest?.model).toBe("openai/gpt-5.4-mini");

expect(completionRequest?.maxTokens).toBe(96);

expect(completionRequest?.purpose).toBe("clickclack bot reply");

expect(completionRequest?.messages).toEqual([{ role: "user", content: "hello bot" }]);

const sendRequest = sendClickClackTextMock.mock.calls[0]?.[0];

const sendRequest = sendClickClackTextMock.mock.calls.at(0)?.[0];

expect(sendRequest?.accountId).toBe("service");

expect(sendRequest?.to).toBe("channel:chn_1");

expect(sendRequest?.text).toBe("service bot online");

harness.process.stdout.write('{"token":"secret-value"} trailing\n');

await vi.waitFor(() => expect(warn).toHaveBeenCalledTimes(1));

expect(warn.mock.calls[0]?.[0]).toBe("failed to parse codex app-server message");

const metadata = warn.mock.calls[0]?.[1] as

expect(warn.mock.calls.at(0)?.[0]).toBe("failed to parse codex app-server message");

const metadata = warn.mock.calls.at(0)?.[1] as

| {

error?: unknown;

errorMessage?: string;

expect(nativeDetails?.details?.backend).toBe("codex-app-server");

expect(nativeDetails?.details?.threadId).toBe("thread-1");

expect(compact).toHaveBeenCalledTimes(1);

const [compactCall] = compact.mock.calls[0] ?? [];

const [compactCall] = compact.mock.calls.at(0) ?? [];

expect(compactCall).toStrictEqual({

sessionId: "session-1",

sessionKey: "agent:main:session-1",

runtimeContext: { workspaceDir: tempDir, provider: "codex" },

});

expect(maintain).toHaveBeenCalledTimes(1);

const [maintainCall] = maintain.mock.calls[0] ?? [];

const [maintainCall] = maintain.mock.calls.at(0) ?? [];

const maintainParams = maintainCall as

| {

sessionId?: string;

progressSummary: "Codex native subagent started.",

}),

);

expect(vi.mocked(runtime.createRunningTaskRun).mock.calls[0]?.[0]).not.toHaveProperty(

expect(vi.mocked(runtime.createRunningTaskRun).mock.calls.at(0)?.[0]).not.toHaveProperty(

"childSessionKey",

);

expect(runtime.recordTaskRunProgressByRunId).toHaveBeenCalledWith(

deliveryStatus: "not_applicable",

}),

);

expect(vi.mocked(runtime.createRunningTaskRun).mock.calls[0]?.[0]).not.toHaveProperty(

expect(vi.mocked(runtime.createRunningTaskRun).mock.calls.at(0)?.[0]).not.toHaveProperty(

"childSessionKey",

);

expect(runtime.recordTaskRunProgressByRunId).toHaveBeenCalledWith(

);

expect(registerTool).toHaveBeenCalledTimes(1);

const tool = registerTool.mock.calls[0]?.[0];

const tool = registerTool.mock.calls.at(0)?.[0];

expect(tool?.name).toBe("feishu_chat");

chatGetMock.mockResolvedValueOnce({

}),

);

const tool = registerTool.mock.calls[0]?.[0];

const tool = registerTool.mock.calls.at(0)?.[0];

contactUserGetMock.mockRejectedValueOnce(

Object.assign(new Error("Request failed with status code 400"), {

response: {

await docToolB.execute("call-b", { action: "list_blocks", doc_token: "d" });

expect(createFeishuClientMock).toHaveBeenCalledTimes(2);

expect(createFeishuClientMock.mock.calls[0]?.[0]?.appId).toBe("app-a");

expect(createFeishuClientMock.mock.calls[1]?.[0]?.appId).toBe("app-b");

expect(createFeishuClientMock.mock.calls.at(0)?.[0]?.appId).toBe("app-a");

expect(createFeishuClientMock.mock.calls.at(1)?.[0]?.appId).toBe("app-b");

});

test("explicit accountId param overrides agentAccountId context", async () => {

});

expect(blockDescendantCreateMock).toHaveBeenCalledTimes(1);

const call = blockDescendantCreateMock.mock.calls[0]?.[0];

const call = blockDescendantCreateMock.mock.calls.at(0)?.[0];

expect(call?.data.children_id).toEqual(["h1", "t1", "h2"]);

for (const block of blocks) {

expect(call?.data.descendants).toContainEqual(block);

content: "tree reorder",

});

const call = blockDescendantCreateMock.mock.calls[0]?.[0];

const call = blockDescendantCreateMock.mock.calls.at(0)?.[0];

expect(call?.data.children_id).toEqual(["h1", "p1", "h2", "list1"]);

expect((call?.data.descendants as Array<{ block_id: string }>).map((b) => b.block_id)).toEqual([

"h1",

await onComment(makeDriveCommentEvent());

expect(handleFeishuCommentEventMock).toHaveBeenCalledTimes(1);

const handleArgs = handleFeishuCommentEventMock.mock.calls[0]?.[0] as

const handleArgs = handleFeishuCommentEventMock.mock.calls.at(0)?.[0] as

| {

accountId?: string;

botOpenId?: string;

);

});

const [recordedMessageId, recordedNamespace, recordedLogger] =

(dedup.recordProcessedFeishuMessage as ReturnType<typeof vi.fn>).mock.calls[0] ?? [];

(dedup.recordProcessedFeishuMessage as ReturnType<typeof vi.fn>).mock.calls.at(0) ?? [];

expect(recordedMessageId).toBe("drive-comment:10d9d60b990db39f96a4c2fd357fb877");

expect(recordedNamespace).toBe("default");

expect(typeof recordedLogger).toBe("function");

await tool.execute("call-ctx", { url: "invalid-url" });

await tool.execute("call-override", { url: "invalid-url", accountId: "a" });

expect(createFeishuClientMock.mock.calls[0]?.[0]?.appId).toBe("app-b");

expect(createFeishuClientMock.mock.calls[1]?.[0]?.appId).toBe("app-a");

expect(createFeishuClientMock.mock.calls.at(0)?.[0]?.appId).toBe("app-b");

expect(createFeishuClientMock.mock.calls.at(1)?.[0]?.appId).toBe("app-a");

});

test("falls back to the configured Feishu default selection when agentAccountId is not a real account", async () => {