git ssb

1
const Client = require('ssb-client')
2
const pull = require('pull-stream')
3
const get = require('lodash/get')
4
5
Client((err, sbot) => {
6
  if (err) throw err
7
8
  var source = sbot.createFeedStream({ reverse: true, limit: 10 })
9
  var sink = pull.drain(renderMsg)
10
    
11
  function renderMsg (msg) {
12
    console.log(`author: ${get(msg, 'value.author')}`)
13
    console.log('type:', get(msg, 'value.content.type'))
14
    console.log('text:', get(msg, 'value.content.text'))
15
    console.log()
16
  }
17
18
  pull(
19
    source,
20
    sink
21
  )
22
})
23
24
25
// simple pull-stream example
26
//
27
// var source = pull.values([1,2,3,4,5,6])
28
// var double = pull.map(msg => msg*2)
29
// var filter = pull.filter(msg => msg >=6)
30
// var sink = pull.drain(msg => {
31
//   console.log('here is the next thing in the pull-stream', msg)
32
// })
33
34
// pull(
35
//   source,
36
//   double,
37
//   filter,
38
//   sink
39
// )
40