Function processXHRChunk

inject.js:701–728

(contentType, chunk)

    }

    function processXHRChunk(contentType, chunk) {
      if (!chunk) return;

      parseBuffer += chunk;
      log('XHR received chunk, length:', chunk.length);

      if (contentType.includes('text/event-stream')) {
        const boundaryIndex = findCompleteSSEBoundary(parseBuffer);
        if (boundaryIndex === null) return;

        const completeData = parseBuffer.substring(0, boundaryIndex);
        parseBuffer = parseBuffer.substring(boundaryIndex);

        const events = parseSSEEvents(completeData);
        for (const event of events) {
          emitXHRMessage(event.event, event.data, event.id);
        }
      } else if (contentType.includes('application/x-ndjson') || contentType.includes('application/jsonlines')) {
        const lines = parseBuffer.split(/\r?\n/);
        parseBuffer = lines.pop() || '';

        for (const line of lines) {
          if (line.trim()) {
            emitXHRMessage('message', line);
          }
        }
      }
    }

    function flushXHRBuffer(contentType) {
      if (!parseBuffer.trim()) {