Method interruptActiveTurns

cli/src/codex/codexRemoteLauncher.ts:199–237

(reason: string)

    }

    private async interruptActiveTurns(reason: string): Promise<void> {
        const turnsToInterrupt = [
            ...(this.currentThreadId && this.currentTurnId
                ? [{ threadId: this.currentThreadId, turnId: this.currentTurnId, role: 'parent' as const }]
                : []),
            ...Array.from(this.activeChildTurns, ([threadId, turnId]) => ({
                threadId,
                turnId,
                role: 'child' as const
            }))
        ];

        if (turnsToInterrupt.length === 0) {
            return;
        }

        const results = await Promise.allSettled(
            turnsToInterrupt.map((target) => this.appServerClient.interruptTurn({
                threadId: target.threadId,
                turnId: target.turnId
            }))
        );

        results.forEach((result, index) => {
            const target = turnsToInterrupt[index];
            if (result.status === 'fulfilled') {
                if (target.role === 'child') {
                    this.activeChildTurns.delete(target.threadId);
                }
                return;
            }

            logger.debug(
                `[Codex] Error interrupting ${target.role} app-server turn ` +
                `for ${reason}; threadId=${target.threadId} turnId=${target.turnId}:`,
                result.reason
            );
        });
    }

    private async handleAbort(): Promise<void> {
        logger.debug('[Codex] Abort requested - stopping current task');