Method runMainLoop

cli/src/codex/codexRemoteLauncher.ts:295–3160

()

    }

    protected async runMainLoop(): Promise<void> {
        const session = this.session;
        const messageBuffer = this.messageBuffer;
        const appServerClient = this.appServerClient;
        const appServerEventConverter = new AppServerEventConverter();

        const normalizeCommand = (value: unknown): string | undefined => {
            if (typeof value === 'string') {
                const trimmed = value.trim();
                return trimmed.length > 0 ? trimmed : undefined;
            }
            if (Array.isArray(value)) {
                const joined = value.filter((part): part is string => typeof part === 'string').join(' ');
                return joined.length > 0 ? joined : undefined;
            }
            return undefined;
        };

        const asRecord = (value: unknown): Record<string, unknown> | null => {
            if (!value || typeof value !== 'object') {
                return null;
            }
            return value as Record<string, unknown>;
        };

        const asString = (value: unknown): string | null => {
            return typeof value === 'string' && value.length > 0 ? value : null;
        };

        const errorMessage = (error: unknown): string => {
            return error instanceof Error ? error.message : String(error);
        };

        const extractSpawnAgentStartErrorFromStderr = (text: string): string | null => {
            const cleanText = stripAnsi(text);
            return cleanText.includes(CODEX_SPAWN_AGENT_FULL_HISTORY_ARGUMENT_ERROR)
                ? CODEX_SPAWN_AGENT_FULL_HISTORY_ARGUMENT_ERROR
                : null;
        };

        const isExitPlanModeTool = (toolName: string): boolean => {
            return toolName === 'exit_plan_mode' || toolName === 'ExitPlanMode';
        };

        const shouldRetryWithoutCollaborationMode = (error: unknown): boolean => {
            const message = errorMessage(error).toLowerCase();
            const mentionsCollaborationMode = message.includes('collaborationmode')
                || message.includes('collaboration_mode')
                || message.includes('collaboration mode');
            if (!mentionsCollaborationMode) {
                return false;
            }

            return message.includes('experimentalapi')
                || message.includes('unsupported')
                || message.includes('unknown')
                || message.includes('unrecognized')
                || message.includes('unexpected')