});

it("coalesces duplicate recovery attempts for the same session", async () => {

let resolveWait!: (value: boolean) => void;

let resolveWait: ((value: boolean) => void) | undefined;

const waitPromise = new Promise<boolean>((resolve) => {

resolveWait = resolve;

});

});

expect(mocks.abortEmbeddedPiRun).toHaveBeenCalledTimes(1);

if (!resolveWait) {

throw new Error("Expected diagnostic recovery wait resolver to be initialized");

}

resolveWait(true);

await first;

});

const warnSpy = vi.spyOn(diagnosticLogger, "warn").mockImplementation(() => undefined);

const events: DiagnosticEventPayload[] = [];

const unsubscribe = onDiagnosticEvent((event) => events.push(event));

let finishPhase!: () => void;

let finishPhase: (() => void) | undefined;

const phase = withDiagnosticPhase(

"startup.plugins.load",

() =>

new Promise<void>((resolve) => {

finishPhase = resolve;

}),

);

if (!finishPhase) {

throw new Error("Expected diagnostic phase finish callback to be initialized");

}

const completePhase = finishPhase;

try {

startDiagnosticHeartbeat(

logMessageQueued({ sessionId: "s1", sessionKey: "main", source: "telegram" });

vi.advanceTimersByTime(30_000);

} finally {

finishPhase();

completePhase();

await phase;

unsubscribe();

}