it("aborts and drains embedded runs after an extended no-progress stall", () => {

const events: DiagnosticEventPayload[] = [];

const recoverStuckSession = vi.fn();

const stuckSessionWarnMs = 30_000;

const stuckSessionAbortMs = resolveStuckSessionAbortMs(undefined, stuckSessionWarnMs);

const unsubscribe = onDiagnosticEvent((event) => {

events.push(event);

});

{

diagnostics: {

enabled: true,

stuckSessionWarnMs: 30_000,

stuckSessionWarnMs,

},

},

{ recoverStuckSession },

);

logSessionStateChange({ sessionId: "s1", sessionKey: "main", state: "processing" });

markDiagnosticEmbeddedRunStarted({ sessionId: "s1", sessionKey: "main" });

vi.advanceTimersByTime(9 * 60_000);

vi.advanceTimersByTime(stuckSessionAbortMs - 30_000);

expect(recoverStuckSession).not.toHaveBeenCalled();

vi.advanceTimersByTime(2 * 60_000);

vi.advanceTimersByTime(30_000);

} finally {

unsubscribe();

}