Function parseSSEEvents

inject.js:33–73

(text)

  // Parse complete SSE event blocks. The caller is responsible for buffering
  // incomplete trailing data between chunks.
  function parseSSEEvents(text) {
    const events = [];
    const lines = text.replace(/\r\n/g, '\n').replace(/\r/g, '\n').split('\n');
    let currentEvent = { data: '', event: 'message', id: '' };

    for (const line of lines) {
      if (line === '') {
        if (currentEvent.data !== '') {
          events.push({
            ...currentEvent,
            data: currentEvent.data.endsWith('\n')
              ? currentEvent.data.slice(0, -1)
              : currentEvent.data
          });
        }
        currentEvent = { data: '', event: 'message', id: '' };
        continue;
      }

      if (line.startsWith(':')) {
        continue;
      }

      const colonIndex = line.indexOf(':');
      const field = colonIndex === -1 ? line : line.slice(0, colonIndex);
      let value = colonIndex === -1 ? '' : line.slice(colonIndex + 1);
      if (value.startsWith(' ')) {
        value = value.slice(1);
      }

      if (field === 'data') {
        currentEvent.data += value + '\n';
      } else if (field === 'event') {
        currentEvent.event = value || 'message';
      } else if (field === 'id') {
        currentEvent.id = value;
      }
    }

    return events;
  }

  function findCompleteSSEBoundary(buffer) {
    const normalized = buffer.replace(/\r\n/g, '\n').replace(/\r/g, '\n');