Method processStreamWithCleanup

src/node/services/streamManager.ts:2406–3059

* Processes a stream with guaranteed cleanup, regardless of success or failure

(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    historySequence: number
  )

   * Processes a stream with guaranteed cleanup, regardless of success or failure
   */
  private async processStreamWithCleanup(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    historySequence: number
  ): Promise<void> {
    this.mcpServerManager?.acquireLease(workspaceId as string);

    try {
      // Update state to streaming
      streamInfo.state = StreamState.STREAMING;

      // Emit stream start event (include mode from initialMetadata if available)
      this.emitStreamStart(workspaceId, streamInfo, historySequence);

      // Initialize token tracker for this model
      await this.tokenTracker.setModel(streamInfo.model, streamInfo.metadataModel);

      let didRetryPreviousResponseId = false;
      let emptyStreamRecoveryAttempts = 0;
      const workspaceLog = this.getWorkspaceLogger(workspaceId, streamInfo);
      let orphanToolResultCount = 0;

      while (true) {
        // Use fullStream to capture all events including tool calls
        const toolCalls: ToolCallMap = new Map();

        try {
          for await (const part of streamInfo.streamResult.fullStream) {
            // Check if stream was cancelled BEFORE processing any parts
            // This improves interruption responsiveness by catching aborts earlier
            if (streamInfo.abortController.signal.aborted) {
              break;
            }

            // Log all stream parts to debug reasoning (commented out - too spammy)
            // console.log("[DEBUG streamManager]: Stream part", {
            //   type: part.type,
            //   hasText: "text" in part,
            //   preview: "text" in part ? (part as StreamPartWithText).text?.substring(0, 50) : undefined,
            // });

            switch (part.type) {
              case "start-step": {
                streamInfo.currentStepStartIndex = streamInfo.parts.length;
                break;
              }

              case "text-delta": {
                // Providers/SDKs may stream text deltas under different keys.
                const textDeltaPart = part as Record<string, unknown>;

                const deltaText = extractChunkDeltaText(textDeltaPart, [
                  "text",
                  "delta",
                  "textDelta",
                ]);

                if (deltaText.length === 0) {