Function parseOpenAIResponseData

ai/ai.ts:2209–2245

(
  data: any,
)

const parseOpenAIResponseData = async (
  data: any,
): Promise<{
  text: string;
  images: AIImage[];
  sources: Array<{ url: string; title?: string }>;
}> => {
  if (
    data &&
    typeof data === "object" &&
    !Buffer.isBuffer(data) &&
    !(data instanceof Uint8Array) &&
    !isAsyncIterable(data)
  ) {
    if (data?.object === "response") {
      return aggregateResponsesApiPayloads([data]);
    }
    return aggregateOpenAIResponses([data]);
  }

  const raw = await readResponseBodyAsText(data);
  const payloads = parseOpenAIResponsePayloads(raw);
  if (payloads.length > 0) {
    const hasResponsesPayload = payloads.some(
      (payload) =>
        payload?.object === "response" ||
        payload?.response?.object === "response" ||
        (typeof payload?.type === "string" &&
          payload.type.startsWith("response.")),
    );
    return hasResponsesPayload
      ? aggregateResponsesApiPayloads(payloads)
      : aggregateOpenAIResponses(payloads);
  }

  return { text: raw.trim() || "AI 回复为空", images: [], sources: [] };
};

const buildDoubaoVideoUrl = (data: any): string | null => {
  return (
    data?.data?.result?.video_url ||