applyAgentAutoCompactionGuard as applyAgentAutoCompactionGuardImpl,

resolveEffectiveCompactionMode,

} from "../agent-settings.js";

import { classifyCompactionReason } from "../embedded-agent-runner/compact-reasons.js";

import { buildEmbeddedCompactionRuntimeContext } from "../embedded-agent-runner/compaction-runtime-context.js";

import {

compactContextEngineWithSafetyTimeout,

import { maybeCompactAgentHarnessSession as maybeCompactAgentHarnessSessionImpl } from "../harness/selection.js";

import type { AgentMessage } from "../runtime/index.js";

import { SessionManager } from "../sessions/session-manager.js";

import { recordCliCompactionInStore as recordCliCompactionInStoreImpl } from "./session-store.js";

import {

clearCliSessionInStore as clearCliSessionInStoreImpl,

recordCliCompactionInStore as recordCliCompactionInStoreImpl,

} from "./session-store.js";

const CODEX_APP_SERVER_OWNS_AUTO_COMPACTION_REASON = "codex app-server owns automatic compaction";

runContextEngineMaintenance: typeof runContextEngineMaintenanceImpl;

ensureSelectedAgentHarnessPlugin: typeof ensureSelectedAgentHarnessPluginImpl;

maybeCompactAgentHarnessSession: typeof maybeCompactAgentHarnessSessionImpl;

clearCliSessionInStore: typeof clearCliSessionInStoreImpl;

recordCliCompactionInStore: typeof recordCliCompactionInStoreImpl;

};

type NativeHarnessCliCompactionOutcome = {

compacted: boolean;

result?: EmbeddedAgentCompactResult;

fallbackToContextEngine?: boolean;

clearCliSessionBinding?: boolean;

failureReason?: string;

};

type CliTranscriptCompactionOutcome = {

runContextEngineMaintenance: runContextEngineMaintenanceImpl,

ensureSelectedAgentHarnessPlugin: ensureSelectedAgentHarnessPluginImpl,

maybeCompactAgentHarnessSession: maybeCompactAgentHarnessSessionImpl,

clearCliSessionInStore: clearCliSessionInStoreImpl,

recordCliCompactionInStore: recordCliCompactionInStoreImpl,

};

runContextEngineMaintenance: runContextEngineMaintenanceImpl,

ensureSelectedAgentHarnessPlugin: ensureSelectedAgentHarnessPluginImpl,

maybeCompactAgentHarnessSession: maybeCompactAgentHarnessSessionImpl,

clearCliSessionInStore: clearCliSessionInStoreImpl,

recordCliCompactionInStore: recordCliCompactionInStoreImpl,

});

}

return result?.ok === false && result.failure?.reason === "unsupported_harness_compaction";

}

function isBelowCompactionTargetReason(reason: string | undefined): boolean {

return classifyCompactionReason(reason) === "below_threshold";

}

function isIntentionalNativeAutoCompactionSkip(

result: EmbeddedAgentCompactResult | undefined,

): boolean {

}

if (!compactResult.compacted) {

const reason = compactResult.reason ?? "nothing to compact";

if (isBelowCompactionTargetReason(reason)) {

log.info(

`CLI transcript compaction skipped for ${params.provider}/${params.model}: ${reason}`,

);

return { compacted: false };

}

log.warn(

`CLI transcript compaction did not reduce context for ${params.provider}/${params.model}: ${compactResult.reason ?? "nothing to compact"}`,

`CLI transcript compaction did not reduce context for ${params.provider}/${params.model}: ${reason}`,

);

return {

compacted: false,

}

if (!result?.compacted) {

const reason = result?.reason ?? "nothing to compact";

if (isBelowCompactionTargetReason(reason)) {

log.info(

`CLI native harness compaction skipped for ${params.provider}/${params.model}: ${reason}`,

);

return { compacted: false };

}

if (isIntentionalNativeAutoCompactionSkip(result)) {

return {

compacted: false,

fallbackToContextEngine: true,

failureReason: CODEX_APP_SERVER_OWNS_AUTO_COMPACTION_REASON,

};

}

const recoverableBindingFailure = isRecoverableNativeHarnessBindingFailure(result);

const fallbackToContextEngine =

isUnsupportedNativeHarnessCompaction(result) ||

isRecoverableNativeHarnessBindingFailure(result);

isUnsupportedNativeHarnessCompaction(result) || recoverableBindingFailure;

log.warn(

`CLI native harness compaction did not reduce context for ${params.provider}/${params.model}: ${result?.reason ?? "nothing to compact"}`,

`CLI native harness compaction did not reduce context for ${params.provider}/${params.model}: ${reason}`,

);

return {

compacted: false,

fallbackToContextEngine,

clearCliSessionBinding: recoverableBindingFailure,

failureReason: result?.reason ?? "native harness compaction did not reduce context",

};

}

let nativeCompactionResult: EmbeddedAgentCompactResult | undefined;

let useContextEngineCompaction = true;

let nativeFallbackToContextEngine = false;

let nativeFallbackNeedsBindingClear = false;

let resolvedContextEngine: ContextEngine | undefined;

let autoCompactionGuardApplied = false;

const applyAutoCompactionGuard = async (contextEngine: ContextEngine): Promise<void> => {

compacted = true;

nativeCompactionResult = nativeOutcome.result;

useContextEngineCompaction = false;

} else if (!nativeOutcome.fallbackToContextEngine) {

} else if (nativeOutcome.fallbackToContextEngine) {

nativeFallbackToContextEngine = true;

nativeFallbackNeedsBindingClear = nativeOutcome.clearCliSessionBinding === true;

} else if (nativeOutcome.failureReason) {

throw new Error(

`CLI native harness compaction failed for ${params.provider}/${params.model}: ${

nativeOutcome.failureReason ?? "compaction did not reduce context"

}`,

);

} else {

nativeFallbackToContextEngine = true;

useContextEngineCompaction = false;

}

}

bestEffortMaintenance: nativeFallbackToContextEngine,

});

compacted = contextOutcome.compacted;

if (!compacted) {

if (!compacted && contextOutcome.failureReason) {

throw new Error(

`CLI transcript compaction failed for ${params.provider}/${params.model}: ${

contextOutcome.failureReason ?? "compaction did not reduce context"

}

}

if (nativeFallbackNeedsBindingClear && !compacted && params.sessionStore && params.storePath) {

return (

(await cliCompactionDeps.clearCliSessionInStore({

provider: params.provider,

sessionKey: params.sessionKey,

sessionStore: params.sessionStore,

storePath: params.storePath,

})) ?? params.sessionEntry

);

}

if (!compacted || !params.sessionStore || !params.storePath) {

return params.sessionEntry;

}