const CODEX_TURN_TERMINAL_IDLE_TIMEOUT_MS = 30 * 60_000;

const CODEX_NATIVE_HOOK_RELAY_MIN_TTL_MS = 30 * 60_000;

const CODEX_NATIVE_HOOK_RELAY_TTL_GRACE_MS = 5 * 60_000;

const CODEX_NATIVE_HOOK_RELAY_RENEW_INTERVAL_MS = 60_000;

const CODEX_STEER_ALL_DEBOUNCE_MS = 500;

const LOG_FIELD_MAX_LENGTH = 160;

const CODEX_NATIVE_PROJECT_DOC_BASENAMES = new Set(["agents.md"]);

let turnAttemptLastProgressAt = Date.now();

let turnAttemptLastProgressReason = "startup";

let turnAttemptLastProgressDetails: Record<string, unknown> | undefined;

let nativeHookRelayLastRenewedAt = 0;

let activeAppServerTurnRequests = 0;

const activeOpenClawDynamicToolCallIds = new Set<string>();

const activeTurnItemIds = new Set<string>();

};

const fireTurnAttemptIdleTimeout = () => {

if (

completed ||

runAbortController.signal.aborted ||

!turnAttemptIdleWatchArmed ||

activeAppServerTurnRequests > 0

) {

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

return;

}

const idleMs = Math.max(0, Date.now() - turnAttemptLastProgressAt);

function scheduleTurnAttemptIdleWatch() {

clearTurnAttemptIdleTimer();

if (

completed ||

runAbortController.signal.aborted ||

!turnAttemptIdleWatchArmed ||

activeAppServerTurnRequests > 0

) {

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

return;

}

const elapsedMs = Math.max(0, Date.now() - turnAttemptLastProgressAt);

scheduleTurnTerminalIdleWatch();

}

const renewNativeHookRelayForTurnProgress = () => {

if (!nativeHookRelay || options.nativeHookRelay?.ttlMs !== undefined) {

return;

}

const now = Date.now();

const renewsRecently =

now - nativeHookRelayLastRenewedAt < CODEX_NATIVE_HOOK_RELAY_RENEW_INTERVAL_MS;

const expiresSoon = now >= nativeHookRelay.expiresAtMs - CODEX_NATIVE_HOOK_RELAY_TTL_GRACE_MS;

if (renewsRecently && !expiresSoon) {

return;

}

nativeHookRelayLastRenewedAt = now;

nativeHookRelay.renew(

resolveCodexNativeHookRelayTtlMs({

explicitTtlMs: undefined,

attemptTimeoutMs: turnAttemptIdleTimeoutMs,

startupTimeoutMs,

turnStartTimeoutMs: params.timeoutMs,

}),

);

};

const touchTurnCompletionActivity = (

reason: string,

options?: { arm?: boolean; details?: Record<string, unknown>; attemptProgress?: boolean },

turnAttemptLastProgressAt = turnCompletionLastActivityAt;

turnAttemptLastProgressReason = reason;

turnAttemptLastProgressDetails = options.details;

renewNativeHookRelayForTurnProgress();

}

emitTrustedDiagnosticEvent({

type: "run.progress",

const notificationCleanup = client.addNotificationHandler(enqueueNotification);

const requestCleanup = client.addRequestHandler(async (request) => {

activeAppServerTurnRequests += 1;

clearTurnCompletionIdleTimer();

disarmTurnAssistantCompletionIdleWatch();

let armCompletionWatchOnResponse = false;

let requestCountsAsTurnActivity = false;

const markCurrentTurnRequestProgress = () => {

activeAppServerTurnRequests += 1;

clearTurnCompletionIdleTimer();

disarmTurnAssistantCompletionIdleWatch();

requestCountsAsTurnActivity = true;

touchTurnCompletionActivity(`request:${request.method}:start`, {

attemptProgress: true,

});

};

try {

if (request.method === "account/chatgptAuthTokens/refresh") {

return refreshCodexAppServerAuthTokens({

if (request.method === "mcpServer/elicitation/request") {

if (isCurrentThreadOptionalTurnRequestParams(request.params, thread.threadId, turnId)) {

armCompletionWatchOnResponse = true;

requestCountsAsTurnActivity = true;

markCurrentTurnRequestProgress();

}

return handleCodexAppServerElicitationRequest({

requestParams: request.params,

if (request.method === "item/tool/requestUserInput") {

if (isCurrentThreadTurnRequestParams(request.params, thread.threadId, turnId)) {

armCompletionWatchOnResponse = true;

requestCountsAsTurnActivity = true;

markCurrentTurnRequestProgress();

}

return userInputBridge?.handleRequest({

id: request.id,

if (isCodexAppServerApprovalRequest(request.method)) {

if (isCurrentApprovalTurnRequestParams(request.params, thread.threadId, turnId)) {

armCompletionWatchOnResponse = true;

requestCountsAsTurnActivity = true;

markCurrentTurnRequestProgress();

}

return handleApprovalRequest({

method: request.method,

return undefined;

}

armCompletionWatchOnResponse = true;

requestCountsAsTurnActivity = true;

markCurrentTurnRequestProgress();

turnCrossedToolHandoff = true;

activeOpenClawDynamicToolCallIds.add(call.callId);

trajectoryRecorder?.recordEvent("tool.call", {

});

return response as JsonValue;

} finally {

activeAppServerTurnRequests = Math.max(0, activeAppServerTurnRequests - 1);

if (requestCountsAsTurnActivity) {

activeAppServerTurnRequests = Math.max(0, activeAppServerTurnRequests - 1);

touchTurnCompletionActivity(`request:${request.method}:response`, {

arm: armCompletionWatchOnResponse,

attemptProgress: true,