npmau-tweets/npm-maintainer-filter-stream.js at master · polyhack/npmau-tweets · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
const TransformStream  = require('stream').Transform
    , inherits         = require('util').inherits

function isMaintainer (maintainers, pkg) {
  if (!pkg || !maintainers.length)
    return false

  var v = pkg['dist-tags'] && pkg['dist-tags'].latest
    , i
  if (v && pkg.versions && pkg.versions[v] && Array.isArray(pkg.versions[v].maintainers)) {
    for (i = 0; i < pkg.versions[v].maintainers.length; i++) {
      if (pkg.versions[v].maintainers[i].name
          && maintainers.indexOf(pkg.versions[v].maintainers[i].name) > -1)
        return true
    }
  }
  return false
}

function NpmMaintainerFilterStream() {
  TransformStream.call(this, { objectMode: true })
  this._maintainers = []
}

inherits(NpmMaintainerFilterStream, TransformStream)

NpmMaintainerFilterStream.prototype._transform = function (chunk, encoding, callback) {
  if (isMaintainer(this._maintainers, chunk.doc))
    this.push(chunk)
  callback()
}

NpmMaintainerFilterStream.prototype.setMaintainers = function (maintainers) {
  this._maintainers = maintainers
}

module.exports = NpmMaintainerFilterStream