Function createFetchStreamObserver

inject.js:360–471

(options)

  const streamsCreatingAsyncIterator = new WeakSet();

  function createFetchStreamObserver(options) {
    const { connectionId, isSSE, isNDJSON, getNextMessageId } = options;
    const decoder = new TextDecoder();
    let buffer = '';
    let closed = false;
    let activeStream = null;

    const emitMessage = (eventType, data, lastEventId = '') => {
      postToContentScript({
        type: 'stream-message',
        connectionId: connectionId,
        messageId: getNextMessageId(),
        eventType: eventType,
        data: data,
        lastEventId: lastEventId,
        timestamp: Date.now()
      });
    };

    const reportError = (error) => {
      postToContentScript({
        type: 'stream-error',
        connectionId: connectionId,
        timestamp: Date.now(),
        error: error?.message || String(error)
      });
    };

    const flushBuffer = () => {
      if (!buffer.trim()) {
        buffer = '';
        return;
      }

      if (isSSE) {
        const events = parseSSEEvents(buffer + '\n\n');
        for (const event of events) {
          emitMessage(event.event, event.data, event.id);
        }
      } else if (isNDJSON) {
        const lines = buffer.split(/\r?\n/).filter(line => line.trim());
        for (const line of lines) {
          emitMessage('message', line);
        }
      }
      buffer = '';
    };

    const shouldObserveStream = (stream) => {
      if (!activeStream) {
        activeStream = stream;
        return true;
      }
      return activeStream === stream;
    };

    const closeConnection = (stream) => {
      if (activeStream && activeStream !== stream) return;