let timedOut = false;

let turnCompletionIdleTimedOut = false;

let turnCompletionIdleTimeoutMessage: string | undefined;

let clientClosedPromptError: string | undefined;

let lifecycleStarted = false;

let lifecycleTerminalEmitted = false;

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

}

}

});

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

const forceContextEngineCompactionForCodexOverflow = async (error: unknown): Promise<boolean> => {

if (!activeContextEngine?.info.ownsCompaction) {

nativePostToolUseRelayEnabled:

nativeHookRelay?.allowedEvents.includes("post_tool_use") === true,

});

closeCleanup = (

client as {

addCloseHandler?: (handler: (client: CodexAppServerClient) => void) => () => void;

}

).addCloseHandler?.(() => {

if (completed || runAbortController.signal.aborted) {

return;

}

clientClosedPromptError = "codex app-server client closed before turn completed";

trajectoryRecorder?.recordEvent("turn.client_closed", {

threadId: thread.threadId,

turnId: activeTurnId,

});

embeddedAgentLog.warn("codex app-server client closed before turn completed", {

threadId: thread.threadId,

turnId: activeTurnId,

});

completed = true;

clearTurnAttemptIdleTimer();

clearTurnCompletionIdleTimer();

clearTurnAssistantCompletionIdleTimer();

clearTurnTerminalIdleTimer();

resolveCompletion?.();

});

emitLifecycleStart();

const activeProjector = projector;

turnTerminalIdleWatchArmed = true;

await completion;

const result = activeProjector.buildResult(toolBridge.telemetry, { yieldDetected });

const finalAborted = result.aborted || runAbortController.signal.aborted;

let finalPromptError = turnCompletionIdleTimedOut

? turnCompletionIdleTimeoutMessage

: timedOut

? "codex app-server attempt timed out"

: result.promptError;

let finalPromptError =

clientClosedPromptError ??

(turnCompletionIdleTimedOut

? turnCompletionIdleTimeoutMessage

: timedOut

? "codex app-server attempt timed out"

: result.promptError);

const finalPromptErrorMessage =

typeof finalPromptError === "string"

? finalPromptError

signal: runAbortController.signal,

});

}

const finalPromptErrorSource = timedOut ? "prompt" : result.promptErrorSource;

const finalPromptErrorSource =

timedOut || clientClosedPromptError ? "prompt" : result.promptErrorSource;

recordCodexTrajectoryCompletion(trajectoryRecorder, {

attempt: params,

result,

clearTurnTerminalIdleTimer();

notificationCleanup();

requestCleanup();

closeCleanup?.();

nativeHookRelay?.unregister();

runAbortController.signal.removeEventListener("abort", abortListener);

params.abortSignal?.removeEventListener("abort", abortFromUpstream);