Method ensureThreadForGoal

cli/src/codex/codexRemoteLauncher.ts:2731–2793

(mode: EnhancedMode)

        };

        const ensureThreadForGoal = async (mode: EnhancedMode): Promise<string | null> => {
            if (this.currentThreadId && this.currentThreadId !== invalidThreadId) {
                hasThread = true;
                return this.currentThreadId;
            }

            const resumeCandidate = session.sessionId && session.sessionId !== invalidThreadId
                ? session.sessionId
                : null;
            if (resumeCandidate) {
                const threadParams = buildThreadStartParams({
                    cwd: session.path,
                    mode,
                    mcpServers,
                    cliOverrides: session.codexCliOverrides
                });
                try {
                    const resumeResponse = await appServerClient.resumeThread({
                        threadId: resumeCandidate,
                        ...threadParams
                    }, {
                        signal: this.abortController.signal
                    });
                    const resumeRecord = asRecord(resumeResponse);
                    const resumeThread = resumeRecord ? asRecord(resumeRecord.thread) : null;
                    const threadId = asString(resumeThread?.id) ?? resumeCandidate;
                    applyResolvedModel(resumeRecord?.model);
                    this.currentThreadId = threadId;
                    session.onSessionFound(threadId);
                    hasThread = true;
                    return threadId;
                } catch (error) {
                    logger.warn(`[Codex] Failed to resume app-server thread ${resumeCandidate} for /goal`, error);
                    sendVisibleStatus(`Goal failed: Codex conversation ${resumeCandidate} could not be resumed`);
                    return null;
                }
            }

            if (!hasThread) {
                const threadParams = buildThreadStartParams({
                    cwd: session.path,
                    mode,
                    mcpServers,
                    cliOverrides: session.codexCliOverrides
                });
                const threadResponse = await appServerClient.startThread(threadParams, {
                    signal: this.abortController.signal
                });
                const threadRecord = asRecord(threadResponse);
                const thread = threadRecord ? asRecord(threadRecord.thread) : null;
                const threadId = asString(thread?.id);
                applyResolvedModel(threadRecord?.model);
                if (!threadId) {
                    throw new Error('app-server thread/start did not return thread.id');
                }
                this.currentThreadId = threadId;
                session.onSessionFound(threadId);
                hasThread = true;