Method cleanupAbortedStream

src/node/services/streamManager.ts:1295–1350

(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    abortReason: StreamAbortReason,
    abandonPartial?: boolean
  )

  }

  private async cleanupAbortedStream(
    workspaceId: WorkspaceId,
    streamInfo: WorkspaceStreamInfo,
    abortReason: StreamAbortReason,
    abandonPartial?: boolean
  ): Promise<void> {
    // CRITICAL: Wait for processing to fully complete before cleanup
    // This prevents race conditions where the old stream is still running
    // while a new stream starts (e.g., old stream writing to partial.json)
    await streamInfo.processingPromise;

    // For aborts, use our tracked cumulativeUsage directly instead of AI SDK's totalUsage.
    // cumulativeUsage is updated on each finish-step event (before tool execution),
    // so it has accurate data even when the stream is interrupted mid-tool-call.
    // AI SDK's totalUsage may return zeros or stale data when aborted.
    const duration = Date.now() - streamInfo.startTime;
    const usage = hasTokenUsage(streamInfo.cumulativeUsage)
      ? streamInfo.cumulativeUsage
      : undefined;
    await this.backfillReasoningTokensFromParts(streamInfo, usage);

    // For context window display, use last step's usage (inputTokens = current context size)
    const contextUsage = streamInfo.lastStepUsage;
    const contextProviderMetadata = streamInfo.lastStepProviderMetadata;

    // Include provider metadata for accurate cost calculation
    const providerMetadata = markProviderMetadataCostsIncluded(
      streamInfo.cumulativeProviderMetadata,
      streamInfo.initialMetadata?.costsIncluded
    );

    // Record session usage for aborted streams (mirrors stream-end path)
    // This ensures tokens consumed before abort are tracked for cost display
    await this.recordSessionUsage(
      workspaceId,
      streamInfo.model,
      usage,
      providerMetadata,
      "Failed to record session usage on abort",
      "error",
      streamInfo
    );

    // Emit abort event with usage if available
    this.emitStreamAbort(
      workspaceId,
      streamInfo.messageId,
      { usage, contextUsage, duration, providerMetadata, contextProviderMetadata },
      abortReason,
      abandonPartial,
      streamInfo.initialMetadata?.acpPromptId
    );

    // Clean up immediately
    this.workspaceStreams.delete(workspaceId);
  }

  private async recordSessionUsage(