git ssb

1
const pull = require('pull-stream')
2
module.exports = function (ssb) {
3
  const subscriptions = new Set()
4
  return {
5
    subscribe: function (id) {
6
      subscriptions.add(id)
7
    },
8
    unsubscribe: function (id) {
9
      subscriptions.delete(id)
10
    },
11
    stream: function () {
12
      return pull(
13
        ssb.backlinks.read({ old: false, index: 'DTS' }),
14
        pull.filter(x => subscriptions.has(x.dest))
15
      )
16
    }
17
  }
18
}
19