params: StuckSessionRecoveryRequest,

) => void | StuckSessionRecoveryOutcome | Promise<void | StuckSessionRecoveryOutcome>;

export type RequestStuckSessionRecoveryParams = {

type RequestStuckSessionRecoveryParams = {

recover: RecoverStuckSession;

request: StuckSessionRecoveryRequest;

classification: SessionAttentionClassification;

DiagnosticSessionState,

} from "../infra/diagnostic-events.js";

export type DiagnosticSessionRecoverySkipReason =

type DiagnosticSessionRecoverySkipReason =

| "active_embedded_run"

| "active_reply_work"

| "active_lane_task"

| "already_in_flight"

| "missing_session_ref"

| "stale_session_state";

export type DiagnosticSessionRecoveryNoopReason = "no_active_work";

type DiagnosticSessionRecoveryNoopReason = "no_active_work";

export type StuckSessionRecoveryRequest = {

sessionId?: string;

const recoveriesInFlight = new Set<string>();

/** Request parameters accepted by the stuck-session recovery runtime. */

export type StuckSessionRecoveryParams = StuckSessionRecoveryRequest;

type StuckSessionRecoveryParams = StuckSessionRecoveryRequest;

function resolveStaleActiveProgressAbortMs(params: StuckSessionRecoveryParams): number {

const configured = params.staleActiveProgressAbortMs;