git ssb

1
const nest = require('depnest')
2
const MutantPullReduce = require('mutant-pull-reduce')
3
4
exports.needs = nest({
5
  'sbot.pull.stream': 'first'
6
})
7
8
exports.gives = nest('channel.obs.subscribers')
9
10
exports.create = function (api) {
11
  return nest('channel.obs.subscribers', function (channel) {
12
    const stream = api.sbot.pull.stream(sbot => sbot.patchwork.subscriptions({ live: true, channel }))
13
    return MutantPullReduce(stream, (state, msg) => {
14
      if (msg.value) {
15
        if (!state.includes(msg.from)) {
16
          state.push(msg.from)
17
        }
18
      } else {
19
        const index = state.indexOf(msg.from)
20
        if (index >= 0) {
21
          state.splice(index, 1)
22
        }
23
      }
24
      return state
25
    }, {
26
      startValue: [],
27
      nextTick: true,
28
      sync: true
29
    })
30
  })
31
}
32