Function parseOpenAIResponsePayloads

ai/ai.ts:2182–2207

(raw: string)

const parseOpenAIResponsePayloads = (raw: string): any[] => {
  const payloads: any[] = [];
  let sawDataLine = false;

  for (const line of raw.split(/\r?\n/)) {
    const trimmed = line.trim();
    if (!trimmed.startsWith("data:")) continue;
    sawDataLine = true;

    const body = trimmed.slice(5).trim();
    if (!body || body === "[DONE]") continue;

    try {
      payloads.push(JSON.parse(body));
    } catch {}
  }

  if (payloads.length > 0 || sawDataLine) return payloads;

  try {
    const parsed = JSON.parse(raw);
    return Array.isArray(parsed) ? parsed : [parsed];
  } catch {
    return [];
  }
};

const parseOpenAIResponseData = async (
  data: any,
): Promise<{