expect(mockedGlobalHookRunner.runBeforeAgentReply).toHaveBeenCalledTimes(1);

const [hookPayload, hookContext] =

mockedGlobalHookRunner.runBeforeAgentReply.mock.calls[0] ?? [];

mockedGlobalHookRunner.runBeforeAgentReply.mock.calls.at(0) ?? [];

expect(hookPayload).toEqual({

cleanedBody: "__openclaw_memory_core_short_term_promotion_dream__",

});

promptMode: "none",

});

const [attemptParams] = (mockedRunEmbeddedAttempt.mock.calls[0] ?? []) as [

const [attemptParams] = (mockedRunEmbeddedAttempt.mock.calls.at(0) ?? []) as [

{ modelRun?: boolean; promptMode?: string }?,

];

expect(attemptParams?.modelRun).toBe(true);

expect(ctx.emitToolOutput).toHaveBeenCalledTimes(1);

const emitToolOutput = vi.mocked(ctx.emitToolOutput);

const [toolName, summary, output, options] = emitToolOutput.mock.calls[0] ?? [];

const [toolName, summary, output, options] = emitToolOutput.mock.calls.at(0) ?? [];

expect(toolName).toBe("tts");

expect(summary).toBeUndefined();

expect(output).toBe("remote tool output");

expect(ctx.emitToolOutput).toHaveBeenCalledTimes(1);

const emitToolOutput = vi.mocked(ctx.emitToolOutput);

const [calledToolName, summary, output, options] = emitToolOutput.mock.calls[0] ?? [];

const [calledToolName, summary, output, options] = emitToolOutput.mock.calls.at(0) ?? [];

expect(calledToolName).toBe(toolName);

expect(summary).toBeUndefined();

expect(output).toBe(providerInventoryText);

await Promise.resolve();

expect(onBlockReply).toHaveBeenCalledTimes(1);

expect(onBlockReply.mock.calls[0]?.[0]?.text).toBe("Short chunk.");

expect(onBlockReply.mock.calls.at(0)?.[0]?.text).toBe("Short chunk.");

expect(onBlockReplyFlush).toHaveBeenCalledTimes(1);

});

await Promise.resolve();

expect(onBlockReply).toHaveBeenCalledTimes(1);

expect(onBlockReply.mock.calls[0]?.[0]?.text).toBe("Final reply before lifecycle end.");

expect(onBlockReply.mock.calls.at(0)?.[0]?.text).toBe("Final reply before lifecycle end.");

expect(onBlockReplyFlush).toHaveBeenCalledTimes(1);

});

await def.execute("call-edit-1", { path: "notes.txt" }, undefined, undefined, extensionContext);

expect(vi.mocked(logError).mock.calls[0]?.[0]).toContain(

expect(vi.mocked(logError).mock.calls.at(0)?.[0]).toContain(

'[tools] edit failed: Missing required parameter: edits (received: path). Supply correct parameters before retrying. raw_params={"path":"notes.txt"}',

);

});

expect(details?.status).toBe("error");

expect(details?.tool).toBe("web_search");

expect(details?.error).toBe("This operation was aborted");

expect(vi.mocked(logError).mock.calls[0]?.[0]).toContain(

expect(vi.mocked(logError).mock.calls.at(0)?.[0]).toContain(

"[tools] web_search failed: This operation was aborted",

);

});

expect(result.blocked).toBe(false);

expect(mockCallGateway).toHaveBeenCalledTimes(2);

const requestCall = mockCallGateway.mock.calls[0];

const requestCall = mockCallGateway.mock.calls.at(0);

expect(requestCall?.[0]).toBe("plugin.approval.request");

requireRecord(requestCall?.[1], "approval request gateway client");

expect(requireRecord(requestCall?.[2], "approval request params").twoPhase).toBe(true);

expect(requestCall?.[3]).toEqual({ expectFinal: false });

const waitCall = mockCallGateway.mock.calls[1];

const waitCall = mockCallGateway.mock.calls.at(1);

expect(waitCall?.[0]).toBe("plugin.approval.waitDecision");

requireRecord(waitCall?.[1], "approval wait gateway client");

expect(waitCall?.[2]).toEqual({ id: "server-id-1" });

}

}

recordToolCall(

sessionState,

toolName,

params,

args.toolCallId,

args.ctx.loopDetection,

loopScope,

);

if (args.ctx.loopDetection?.enabled !== false) {

recordToolCall(

sessionState,

toolName,

params,

args.toolCallId,

args.ctx.loopDetection,

loopScope,

);

}

}

const hookRunner = getGlobalHookRunner();