const runCronIsolatedAgentTurn = await loadRunCronIsolatedAgentTurn();

function requireEmbeddedAgentCall(index: number): { prompt?: string } {

const call = runEmbeddedPiAgentMock.mock.calls[index]?.[0] as { prompt?: string } | undefined;

if (!call) {

throw new Error(`Expected embedded PI agent call ${index}`);

}

return call;

}

function requireDeliveryRequest(): {

skipHeartbeatDelivery?: boolean;

deliveryPayloads?: unknown;

} {

const request = dispatchCronDeliveryMock.mock.calls[0]?.[0] as

| {

skipHeartbeatDelivery?: boolean;

deliveryPayloads?: unknown;

}

| undefined;

if (!request) {

throw new Error("Expected cron delivery request");

}

return request;

}

describe("runCronIsolatedAgentTurn — interim ack retry", () => {

setupRunCronIsolatedAgentTurnSuite();

mockRunCronFallbackPassthrough();

await runTurnAndExpectOk(2, 2);

expect(runEmbeddedPiAgentMock.mock.calls[1]?.[0]?.prompt).toContain(

expect(requireEmbeddedAgentCall(1).prompt).toContain(

"previous response was only an acknowledgement",

);

});

expect(result.status).toBe("error");

expect(result.error).toBe("SYSTEM_RUN_DENIED: approval required");

const deliveryRequest = dispatchCronDeliveryMock.mock.calls[0]?.[0];

expect(deliveryRequest?.skipHeartbeatDelivery).toBe(false);

expect(deliveryRequest?.deliveryPayloads).toEqual([

const deliveryRequest = requireDeliveryRequest();

expect(deliveryRequest.skipHeartbeatDelivery).toBe(false);

expect(deliveryRequest.deliveryPayloads).toEqual([

{ text: "SYSTEM_RUN_DENIED: approval required", isError: true },

]);

});