Method getAggregatedProviderMetadata

src/node/services/streamManager.ts:1050–1101

* Aggregate provider metadata across all steps. * * CRITICAL: For multi-step tool calls, cache creation tokens are reported per-step. * streamResult.providerMetadata only contains the LAST step's metadata, missing * cache creation tokens from earlier steps. We must sum across all steps.

(
    streamInfo: WorkspaceStreamInfo,
    timeoutMs = 1000
  )

   * cache creation tokens from earlier steps. We must sum across all steps.
   */
  private async getAggregatedProviderMetadata(
    streamInfo: WorkspaceStreamInfo,
    timeoutMs = 1000
  ): Promise<Record<string, unknown> | undefined> {
    try {
      const steps = await Promise.race([
        streamInfo.streamResult.steps,
        new Promise<undefined>((resolve) => setTimeout(() => resolve(undefined), timeoutMs)),
      ]);

      if (!steps || steps.length === 0) {
        // Fall back to last step's provider metadata
        return await streamInfo.streamResult.providerMetadata;
      }

      // If only one step, no aggregation needed
      if (steps.length === 1) {
        return steps[0].providerMetadata;
      }

      // Aggregate cache creation tokens across all steps
      let totalCacheCreationTokens = 0;
      let lastStepMetadata: Record<string, unknown> | undefined;

      for (const step of steps) {
        lastStepMetadata = step.providerMetadata;
        const anthropicMeta = step.providerMetadata?.anthropic as
          | { cacheCreationInputTokens?: number }
          | undefined;
        if (anthropicMeta?.cacheCreationInputTokens) {
          totalCacheCreationTokens += anthropicMeta.cacheCreationInputTokens;
        }
      }

      // If no cache creation tokens found, just return last step's metadata
      if (totalCacheCreationTokens === 0) {
        return lastStepMetadata;
      }

      // Merge aggregated cache creation tokens into the last step's metadata
      return {
        ...lastStepMetadata,
        anthropic: {
          ...(lastStepMetadata?.anthropic as Record<string, unknown> | undefined),
          cacheCreationInputTokens: totalCacheCreationTokens,
        },
      };
    } catch (error) {
      log.debug("Could not aggregate provider metadata:", error);
      return undefined;
    }
  }

  /**
   * Safely cancels an existing stream with proper cleanup