} from "./protocol.js";

import { createStdioTransport } from "./transport-stdio.js";

import { createWebSocketTransport } from "./transport-websocket.js";

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

import {

closeCodexAppServerTransport,

closeCodexAppServerTransportAndWait,

type CodexAppServerTransport,

} from "./transport.js";

export const MIN_CODEX_APP_SERVER_VERSION = "0.125.0";

const CODEX_APP_SERVER_PARSE_LOG_MAX = 500;

}

close(): void {

if (this.closed) {

if (!this.markClosed(new Error("codex app-server client is closed"))) {

return;

}

this.closed = true;

this.lines.close();

this.rejectPendingRequests(new Error("codex app-server client is closed"));

closeCodexAppServerTransport(this.child);

}

async closeAndWait(options?: {

exitTimeoutMs?: number;

forceKillDelayMs?: number;

}): Promise<void> {

this.markClosed(new Error("codex app-server client is closed"));

await closeCodexAppServerTransportAndWait(this.child, options);

}

private writeMessage(message: RpcRequest | RpcResponse): void {

if (this.closed) {

return;

}

private closeWithError(error: Error): void {

if (this.markClosed(error)) {

closeCodexAppServerTransport(this.child);

}

}

private markClosed(error: Error): boolean {

if (this.closed) {

return;

return false;

}

this.closed = true;

this.lines.close();

this.rejectPendingRequests(error);

closeCodexAppServerTransport(this.child);

return true;

}

private rejectPendingRequests(error: Error): void {

export const __testing = {

closeCodexAppServerTransport,

closeCodexAppServerTransportAndWait,

redactCodexAppServerLinePreview,

} as const;