Function aggregateResponsesApiPayloads

ai/ai.ts:2104–2180

(
  payloads: any[],
)

const aggregateResponsesApiPayloads = (
  payloads: any[],
): {
  text: string;
  images: AIImage[];
  sources: Array<{ url: string; title?: string }>;
} => {
  const deltaTexts: string[] = [];
  let fallbackText = "";
  let fallbackImages: AIImage[] = [];
  const sources: Array<{ url: string; title?: string }> = [];
  const seenSources = new Set<string>();

  const appendSources = (entries: Array<{ url: string; title?: string }>) => {
    for (const entry of entries) {
      if (seenSources.has(entry.url)) continue;
      seenSources.add(entry.url);
      sources.push(entry);
    }
  };

  const appendItem = (item: any) => {
    const parsed = parseResponsesOutputContent(item);
    if (parsed.text) fallbackText = parsed.text;
    if (parsed.images.length > 0) fallbackImages = parsed.images;
    appendSources(parsed.sources);
  };

  for (const payload of payloads) {
    if (
      payload?.type === "response.output_text.delta" &&
      typeof payload.delta === "string"
    ) {
      deltaTexts.push(payload.delta);
    }

    if (
      payload?.type === "response.output_text.done" &&
      typeof payload.text === "string" &&
      deltaTexts.length === 0
    ) {
      fallbackText = payload.text.trim();
    }

    if (payload?.type === "response.content_part.done") {
      appendSources(
        collectResponsesSources({
          type: "message",
          content: [payload.part],
        }),
      );
    }

    if (payload?.item) appendItem(payload.item);

    const response =
      payload?.response?.object === "response"
        ? payload.response
        : payload?.object === "response"