expectRecordFields(result, { text }, "reply result");

}

type MockCallSource = {

mock: {

calls: ReadonlyArray<ReadonlyArray<unknown>>;

};

};

function firstMockCallArg(mock: MockCallSource, label: string): unknown {

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

if (!call) {

throw new Error(`expected ${label} to have at least one call`);

}

return call[0];

}

beforeEach(() => {

clearRuntimeConfigSnapshot();

resetDiagnosticEventsForTest();

});

expect(onBlockReply).toHaveBeenCalledTimes(1);

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

expect((firstMockCallArg(onBlockReply, "block reply") as { text?: string }).text).toBe("Hello");

expect(result).toBeUndefined();

});

expect(runEmbeddedPiAgentMock).not.toHaveBeenCalled();

expectRecordFields(

runCliAgentMock.mock.calls.at(0)?.[0],

firstMockCallArg(runCliAgentMock, "CLI run params"),

{ provider: "claude-cli" },

"CLI run params",

);

await createRun();

const call = runEmbeddedPiAgentMock.mock.calls.at(0)?.[0] as EmbeddedPiAgentParams | undefined;

expect(call?.enforceFinalTag).toBe(true);

const call = firstMockCallArg(runEmbeddedPiAgentMock, "PI run params") as EmbeddedPiAgentParams;

expect(call.enforceFinalTag).toBe(true);

});

it("enforces <final> during memory flush on fallback providers", async () => {