git ssb

1
const Pushable = require('pull-pushable')
2
const deepEqual = require('deep-equal')
3
4
module.exports = function (ssb) {
5
  return {
6
    stream: function () {
7
      let lastValue = deepClone(ssb.progress())
8
9
      const timer = setInterval(() => {
10
        const newValue = ssb.progress()
11
        if (!deepEqual(newValue, lastValue)) {
12
          lastValue = deepClone(newValue)
13
          pushable.push(lastValue)
14
        }
15
      }, 200)
16
17
      const pushable = Pushable(() => {
18
        clearInterval(timer)
19
      })
20
21
      pushable.push(lastValue)
22
      return pushable
23
    }
24
  }
25
}
26
27
function deepClone (obj) {
28
  return JSON.parse(JSON.stringify(obj))
29
}
30