let userInputBridge: ReturnType<typeof createCodexUserInputBridge> | undefined;

let steeringQueue: ReturnType<typeof createCodexSteeringQueue> | undefined;

let completed = false;

let terminalTurnNotificationQueued = false;

let timedOut = false;

let turnCompletionIdleTimedOut = false;

let turnCompletionIdleTimeoutMessage: string | undefined;

isCurrentTurnNotification &&

isCodexTurnAbortMarkerNotification(notification, { currentPromptText: promptBuild.prompt });

const isTurnTerminal = isTurnCompletion || isTurnAbortMarker;

if (isTurnTerminal) {

terminalTurnNotificationQueued = true;

}

try {

await waitForCodexNotificationDispatchTurn();

await projector.handleNotification(notification);

pendingNotifications.push(notification);

return Promise.resolve();

}

const isCurrentTurnNotification = isTurnNotification(

notification.params,

thread.threadId,

turnId,

);

if (

isCurrentTurnNotification &&

(notification.method === "turn/completed" ||

isCodexTurnAbortMarkerNotification(notification, { currentPromptText: promptBuild.prompt }))

) {

terminalTurnNotificationQueued = true;

}

notificationQueue = notificationQueue.then(

() => handleNotification(notification),

() => handleNotification(notification),

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

}

).addCloseHandler?.(() => {

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

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

return;

}

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