restream/build/index.js

const { Transform } = require('stream');

/**
 * Create a Transform stream which will maintain a buffer with data received from a Readable stream and write data when the buffer can be matched against the regex. It will push the whole match object (or objects when the g flag is used) returned by `/regex/.exec(buffer)`.
 * @param {!RegExp} regex The regular expression to execute.
 */
               function createRegexTransformStream(regex) {
  let buffer = ''

  /** @suppress {checkTypes} */
  const ts = new Transform({
    transform(chunk, encoding, next) {
      let lastMatch
      let match
      buffer += chunk.toString()

      // thx stream-snitch
      // https://github.com/dmotz/stream-snitch/blob/master/index.js#L52
      // eslint-disable-next-line no-cond-assign
      while (match = regex.exec(buffer)) {
        ts.push(match)
        lastMatch = match
        if (!regex.global) break
      }
      if (lastMatch) {
        buffer = buffer.slice(lastMatch.index + lastMatch[0].length)
      }
      next()
    },
    objectMode: true,
  })

  return ts
}





const $_lib_markers = require('./lib/markers');

const $_Replaceable = require('./Replaceable');
const $_SyncReplaceable = require('./SyncReplaceable');

/* documentary types/rules.xml */
/**
 * @suppress {nonStandardJsDocs}
 * @typedef {_restream.Replacer} Replacer
 */
/**
 * @suppress {nonStandardJsDocs}
 * @typedef {function(this:!_restream.ReplaceableInterface, ...string): string} _restream.Replacer
 */
/**
 * @suppress {nonStandardJsDocs}
 * @typedef {_restream.AsyncReplacer} AsyncReplacer
 */
/**
 * @suppress {nonStandardJsDocs}
 * @typedef {function(this:!_restream.ReplaceableInterface, ...string): !Promise<string>} _restream.AsyncReplacer
 */
/**
 * @suppress {nonStandardJsDocs}
 * @typedef {_restream.Rule} Rule A replacement rule.
 */
/**
 * @suppress {nonStandardJsDocs}
 * @typedef {Object} _restream.Rule A replacement rule.
 * @prop {!RegExp} re The regular expression to match input against.
 * @prop {!(string|_restream.Replacer|_restream.AsyncReplacer)} replacement The replacement string, or the replacer function.
 */
/**
 * @suppress {nonStandardJsDocs}
 * @typedef {_restream.ReplaceableInterface} ReplaceableInterface An interface for the context accessible via this in replacer functions.
 */
/**
 * @suppress {nonStandardJsDocs}
 * @typedef {Object} _restream.ReplaceableInterface An interface for the context accessible via this in replacer functions.
 * @prop {function()} brake After calling this method, the following rules and matches within the same rule won't be able to make any more changes.
 * @prop {function(string, !Object<string, *>?): !Promise<string>} replace Creates a new _Replaceable_ by copying all rules, assigns the context to it and replaces the data. The `this` won't be shared by rules, but the context will be updated: `const context = { test: this.test }; content = await this.replace(content, context); this.test = context.test`.
 */


module.exports = createRegexTransformStream
module.exports.makeMarkers = $_lib_markers.makeMarkers
module.exports.makeCutRule = $_lib_markers.makeCutRule
module.exports.makePasteRule = $_lib_markers.makePasteRule
module.exports.Replaceable = $_Replaceable
module.exports.SerialAsyncReplaceable = $_Replaceable.SerialAsyncReplaceable
module.exports.SyncReplaceable = $_SyncReplaceable