Method handleStreamError

src/node/services/agentSession.ts:4411–4466

(data: StreamErrorPayload)

  }

  private async handleStreamError(data: StreamErrorPayload): Promise<void> {
    this.setTurnPhase(TurnPhase.COMPLETING);

    this.clearLiveUsageState();
    const hadCompactionRequest = this.activeCompactionRequest !== undefined;
    if (
      await this.maybeRetryCompactionOnContextExceeded({
        messageId: data.messageId,
        errorType: data.errorType,
      })
    ) {
      return; // retry set PREPARING
    }

    if (
      await this.maybeRetryWithoutPostCompactionOnContextExceeded({
        messageId: data.messageId,
        errorType: data.errorType,
      })
    ) {
      return; // retry set PREPARING
    }

    if (
      await this.maybeHardRestartExecSubagentOnContextExceeded({
        messageId: data.messageId,
        errorType: data.errorType,
      })
    ) {
      return; // retry set PREPARING
    }

    // Terminal error — no retry succeeded
    const failedUserMessageId = this.activeStreamUserMessageId;
    const failureType = data.errorType ?? "unknown";
    const streamErrorMessage = createStreamErrorMessage(data);
    this.setTerminalStreamLifecycle("failed");
    this.terminalStreamError = streamErrorMessage;
    await this.restoreGoalAccountingSnapshot();
    this.activeCompactionRequest = undefined;
    this.resetActiveStreamState();

    if (hadCompactionRequest && !this.disposed) {
      this.clearQueue();
    }

    await this.handleStreamFailureForAutoRetry({
      type: failureType,
      message: data.error,
    });
    await this.updateStartupAutoRetryAbandonFromFailure(failureType, failedUserMessageId);
    this.resolveStreamErrorRecoveryDecision();

    this.emitChatEvent(streamErrorMessage);
    this.setTurnPhase(TurnPhase.IDLE);
  }

  private attachAiListeners(): void {