Method resetStreamStateForRetry

src/node/services/streamManager.ts:3282–3326

(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    options?: { preserveParts?: boolean; preserveUsage?: boolean; workspaceLog?: Logger }
  )

  }

  private async resetStreamStateForRetry(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    options?: { preserveParts?: boolean; preserveUsage?: boolean; workspaceLog?: Logger }
  ): Promise<void> {
    const preserveParts = options?.preserveParts ?? false;
    const preserveUsage = options?.preserveUsage ?? false;

    if (streamInfo.partialWriteTimer) {
      clearTimeout(streamInfo.partialWriteTimer);
      streamInfo.partialWriteTimer = undefined;
    }

    await this.awaitPendingPartialWrite(streamInfo);
    streamInfo.partialWritePromise = undefined;

    if (!preserveParts) {
      streamInfo.parts = [];
    }
    if (!preserveParts) {
      streamInfo.reasoningBackfillStartIndex = undefined;
    }
    streamInfo.receivedTerminalEvent = false;
    streamInfo.terminalFinishReason = undefined;
    streamInfo.terminalRawFinishReason = undefined;
    streamInfo.lastPartialWriteTime = 0;

    if (!preserveUsage) {
      streamInfo.cumulativeUsage = { inputTokens: 0, outputTokens: 0, totalTokens: 0 };
      streamInfo.cumulativeProviderMetadata = undefined;
      streamInfo.terminalRefusalUsage = undefined;
      streamInfo.terminalRefusalProviderMetadata = undefined;
      streamInfo.lastStepUsage = undefined;
      streamInfo.lastStepProviderMetadata = undefined;
    }

    if (!preserveParts) {
      try {
        await this.historyService.deletePartial(workspaceId as string);
      } catch (deleteError) {
        const logger = options?.workspaceLog ?? this.getWorkspaceLogger(workspaceId, streamInfo);
        logger.warn("Failed to clear partial state before retry", { error: deleteError });
      }
    }
  }

  private async retryStreamWithoutPreviousResponseId(
    workspaceId: WorkspaceId,