applyMediaUnderstanding: vi.fn(async (_params: unknown) => undefined),

}));

const diagnosticMocks = vi.hoisted(() => ({

markDiagnosticSessionProgress: vi.fn(),

}));

const sessionMetaMocks = vi.hoisted(() => ({

readAcpSessionEntry: vi.fn<

(params: { sessionKey: string; cfg?: OpenClawConfig }) => AcpSessionStoreEntry | null

sessionMetaMocks.readAcpSessionEntry(params),

}));

vi.mock("../../logging/diagnostic.js", () => ({

markDiagnosticSessionProgress: diagnosticMocks.markDiagnosticSessionProgress,

}));

vi.mock("./dispatch-acp-transcript.runtime.js", () => ({

persistAcpDispatchTranscript: (params: unknown) =>

transcriptMocks.persistAcpDispatchTranscript(params),

ttsMocks.resolveTtsConfig.mockReturnValue({ mode: "final" });

mediaUnderstandingMocks.applyMediaUnderstanding.mockReset();

mediaUnderstandingMocks.applyMediaUnderstanding.mockResolvedValue(undefined);

diagnosticMocks.markDiagnosticSessionProgress.mockReset();

sessionMetaMocks.readAcpSessionEntry.mockReset();

sessionMetaMocks.readAcpSessionEntry.mockReturnValue(null);

transcriptMocks.persistAcpDispatchTranscript.mockClear();

expect(onReplyStart).toHaveBeenCalledTimes(1);

});

it("does not mark ACP diagnostic progress when diagnostics are disabled", async () => {

setReadyAcpResolution();

mockVisibleTextTurn();

await runDispatch({

bodyForAgent: "visible",

cfg: createAcpTestConfig({ diagnostics: { enabled: false } }),

});

expect(diagnosticMocks.markDiagnosticSessionProgress).not.toHaveBeenCalled();

});

it("does not start reply lifecycle for empty ACP prompt", async () => {

setReadyAcpResolution();

const onReplyStart = vi.fn();