git ssb

1
const pull = require('pull-stream')
2
const pullCat = require('pull-cat')
3
4
module.exports = function (sbot) {
5
  return {
6
    stream: function ({ live = null, since = null } = {}) {
7
      return pullCat([
8
        pull(
9
          sbot.createFeedStream({ reverse: true, gt: since }),
10
          pull.map(msg => msg.value.author),
11
          pull.unique()
12
        ),
13
14
        // live
15
        live ? pull.values([{ sync: true }]) : pull.empty(),
16
        live ? pull(
17
          sbot.createFeedStream({ old: false }),
18
          pull.map(msg => msg.value.author)
19
        ) : pull.empty()
20
      ])
21
    }
22
  }
23
}
24