Function parseSseText

test/providers/codex/native_api_server.test.ts:18–33

(text: string)

}

function parseSseText(text: string): Array<{ event: string; data: any }> {
  const blocks = text.split('\n\n').map((entry) => entry.trim()).filter(Boolean);
  const parsed: Array<{ event: string; data: any }> = [];
  for (const block of blocks) {
    const eventLine = block.split('\n').find((line) => line.startsWith('event: '));
    const dataLine = block.split('\n').find((line) => line.startsWith('data: '));
    if (!eventLine || !dataLine || dataLine === 'data: [DONE]') {
      continue;
    }
    parsed.push({
      event: eventLine.slice(7).trim(),
      data: JSON.parse(dataLine.slice(6)),
    });
  }
  return parsed;
}

function parseSseDataText(text: string): any[] {
  const blocks = text.split('\n\n').map((entry) => entry.trim()).filter(Boolean);