Function createLineDemuxer

src/security/sanitize.js:252–273

* Wrap a Readable stream with a single shared 'data' listener that demuxes * line-by-line into per-request callbacks. This avoids accumulating one * 'data' listener per in-flight request (which causes EventEmitter warnings * and cross-request data leakage when responses race). * * Returns { sen

(stream)

 * Returns { sendLine, registerHandler, unregister, close }
 */
function createLineDemuxer(stream) {
  const handlers = new Map(); // id → fn(line)
  let buffer = '';
  const onData = (chunk) => {
    buffer += chunk.toString('utf8');
    const lines = buffer.split('\n');
    buffer = lines.pop() || '';
    for (const line of lines) {
      if (!line.trim()) continue;
      for (const fn of handlers.values()) {
        try { fn(line); } catch { /* handler should never throw */ }
      }
    }
  };
  stream.on('data', onData);
  return {
    register(id, fn) { handlers.set(id, fn); },
    unregister(id) { handlers.delete(id); },
    close() { try { stream.off('data', onData); } catch {} handlers.clear(); },
    pendingCount() { return handlers.size; },
  };
}

module.exports = {
  redactString,