git ssb

1
var pull = require('pull-stream')
2
var Cat = require('pull-cat')
3
var sort = require('ssb-sort')
4
var ref = require('ssb-ref')
5
var h = require('hyperscript')
6
var u = require('patchbay/util')
7
var Scroller = require('pull-scroll')
8
9
10
function once (cont) {
11
  var ended = false
12
  return function (abort, cb) {
13
    if(abort) return cb(abort)
14
    else if (ended) return cb(ended)
15
    else
16
      cont(function (err, data) {
17
        if(err) return cb(ended = err)
18
        ended = true
19
        cb(null, data)
20
      })
21
  }
22
}
23
24
var plugs = require('patchbay/plugs')
25
26
var message_render = plugs.first(exports.message_render = [])
27
var message_name = plugs.first(exports.message_name = [])
28
var message_compose = plugs.first(exports.message_compose = [])
29
var message_unbox = plugs.first(exports.message_unbox = [])
30
31
var sbot_get = plugs.first(exports.sbot_get = [])
32
var sbot_links = plugs.first(exports.sbot_links = [])
33
var get_id = plugs.first(exports.get_id = [])
34
35
function getThread (root, cb) {
36
  //in this case, it's inconvienent that panel only takes
37
  //a stream. maybe it would be better to accept an array?
38
39
  sbot_get(root, function (err, value) {
40
    var msg = {key: root, value: value}
41
//    if(value.content.root) return getThread(value.content.root, cb)
42
43
    pull(
44
      sbot_links({rel: 'root', dest: root, values: true, keys: true}),
45
      pull.collect(function (err, ary) {
46
        if(err) return cb(err)
47
        ary.unshift(msg)
48
        cb(null, ary)
49
      })
50
    )
51
  })
52
53
}
54
55
exports.screen_view = function (id) {
56
  if(ref.isMsg(id)) {
57
    var meta = {
58
      type: 'post',
59
      root: id,
60
      branch: id //mutated when thread is loaded.
61
    }
62
63
    var previousId = id
64
    var content = h('div.column.scroller__content')
65
    var div = h('div.column.scroller',
66
      {style: {'overflow-y': 'auto'}},
67
      h('div.scroller__wrapper',
68
        content,
69
        message_compose(meta, {shrink: false, placeholder: 'Write a reply'})
70
      )
71
    )
72
73
    message_name(id, function (err, name) {
74
      div.title = name
75
    })
76
77
    pull(
78
      sbot_links({
79
        rel: 'root', dest: id, keys: true, old: false
80
      }),
81
      pull.drain(function (msg) {
82
        loadThread() //redraw thread
83
      }, function () {} )
84
    )
85
86
87
    function loadThread () {
88
      getThread(id, function (err, thread) {
89
        //would probably be better keep an id for each message element
90
        //(i.e. message key) and then update it if necessary.
91
        //also, it may have moved (say, if you received a missing message)
92
        content.innerHTML = ''
93
        //decrypt
94
        thread = thread.map(function (msg) {
95
          return 'string' === typeof msg.value.content ? message_unbox(msg) : msg
96
        })
97
98
        if(err) return content.appendChild(h('pre', err.stack))
99
        sort(thread).map((msg) => {
100
          var result = message_render(msg, {inContext: true, previousId})
101
          previousId = msg.key
102
          return result
103
        }).filter(Boolean).forEach(function (el) {
104
          content.appendChild(el)
105
        })
106
107
        var branches = sort.heads(thread)
108
        meta.branch = branches.length > 1 ? branches : branches[0]
109
        meta.root = thread[0].value.content.root || thread[0].key
110
        meta.channel = thread[0].value.content.channel
111
112
        var recps = thread[0].value.content.recps
113
        var private = thread[0].value.private
114
        if(private) {
115
          if(recps)
116
            meta.recps = recps
117
          else
118
            meta.recps = [thread[0].value.author, get_id()]
119
        }
120
      })
121
    }
122
123
    loadThread()
124
    return div
125
  }
126
}
127