import { closeCodexAppServerTransport, type CodexAppServerTransport } from "./transport.js";

export const MIN_CODEX_APP_SERVER_VERSION = "0.118.0";

const CODEX_APP_SERVER_PARSE_LOG_MAX = 500;

type PendingRequest = {

method: string;

try {

parsed = JSON.parse(trimmed);

} catch (error) {

embeddedAgentLog.warn("failed to parse codex app-server message", { error });

embeddedAgentLog.warn("failed to parse codex app-server message", {

error,

linePreview: redactCodexAppServerLinePreview(trimmed),

});

return;

}

if (!parsed || typeof parsed !== "object") {

.map((part) => (Number.isFinite(part) ? part : 0));

}

function redactCodexAppServerLinePreview(value: string): string {

const compact = value.replace(/\s+/g, " ").trim();

const redacted = compact

.replace(/(Bearer\s+)[A-Za-z0-9._~+/-]+/gi, "$1<redacted>")

.replace(

/("(?:api_?key|authorization|token|access_token|refresh_token)"\s*:\s*")([^"]+)(")/gi,

"$1<redacted>$3",

);

return redacted.length > CODEX_APP_SERVER_PARSE_LOG_MAX

? `${redacted.slice(0, CODEX_APP_SERVER_PARSE_LOG_MAX)}...`

: redacted;

}

const CODEX_APP_SERVER_APPROVAL_REQUEST_METHODS = new Set([

"item/commandExecution/requestApproval",

"item/fileChange/requestApproval",

export const __testing = {

closeCodexAppServerTransport,

redactCodexAppServerLinePreview,

} as const;