Method getStreamMetadata

src/node/services/streamManager.ts:925–966

(
    streamInfo: WorkspaceStreamInfo,
    timeoutMs = 1000
  )

  }

  private async getStreamMetadata(
    streamInfo: WorkspaceStreamInfo,
    timeoutMs = 1000
  ): Promise<{
    totalUsage?: LanguageModelV2Usage;
    contextUsage?: LanguageModelV2Usage;
    contextProviderMetadata?: Record<string, unknown>;
    finishReason?: string;
    duration: number;
  }> {
    // Helper: wrap promise with independent timeout + error handling
    // Each promise resolves independently - one failure doesn't mask others
    const withTimeout = <T>(promise: PromiseLike<T>): Promise<T | undefined> =>
      Promise.race([
        promise,
        new Promise<undefined>((resolve) => setTimeout(() => resolve(undefined), timeoutMs)),
      ]).catch(() => undefined);

    // Fetch all metadata in parallel with independent timeouts
    // - totalUsage: sum of all steps (for cost calculation)
    // - contextUsage: last step only (for context window display)
    // - contextProviderMetadata: last step (for context window cache display)
    const streamResultWithFinishReason = streamInfo.streamResult as {
      finishReason?: PromiseLike<string>;
    };
    const [totalUsage, contextUsage, contextProviderMetadata, finishReason] = await Promise.all([
      withTimeout(streamInfo.streamResult.totalUsage),
      withTimeout(streamInfo.streamResult.usage),
      withTimeout(streamInfo.streamResult.providerMetadata),
      streamResultWithFinishReason.finishReason
        ? withTimeout(streamResultWithFinishReason.finishReason)
        : Promise.resolve(undefined),
    ]);

    return {
      totalUsage,
      contextUsage,
      contextProviderMetadata,
      finishReason,
      duration: Date.now() - streamInfo.startTime,
    };
  }

  private resolveTotalUsageForStreamEnd(
    streamInfo: WorkspaceStreamInfo,