git ssb

1
var h = require('hyperscript')
2
var pull = require('pull-stream')
3
4
var plugs = require('../plugs')
5
var message_link = plugs.first(exports.message_link = [])
6
var sbot_links = plugs.first(exports.sbot_links = [])
7
8
function getIssueState(id, cb) {
9
  pull(
10
    sbot_links({dest: id, rel: 'issues', values: true}),
11
    pull.map(function (msg) {
12
      var issues = msg.value.content.issues
13
      if (!Array.isArray(issues)) return
14
      return issues.filter(function (issue) {
15
        return issue.link === id
16
      }).map(function (issue) {
17
        return {
18
          ts: msg.value.timestamp,
19
          open: issue.open,
20
          merged: issue.merged,
21
        }
22
      })
23
    }),
24
    pull.flatten(),
25
    pull.collect(function (err, updates) {
26
      if (err) return cb(err)
27
      var open = true, merged = false
28
      updates.sort(function (a, b) {
29
        return b.ts - a.ts
30
      }).forEach(function (update) {
31
        if (update.open != null)
32
          open = update.open
33
        if (update.merged != null)
34
          merged = update.merged
35
      })
36
      cb(null, open ? 'open' : merged ? 'merged' : 'closed')
37
    })
38
  )
39
}
40
41
exports.message_content = function (msg, sbot) {
42
  var c = msg.value.content
43
44
  if(c.type === 'git-repo') {
45
    return h('p', 'git repo')
46
  }
47
48
  if(c.type === 'git-update') {
49
    return h('p',
50
      'git-pushed to ',
51
      message_link(c.repo),
52
      c.refs ? h('ul', Object.keys(c.refs).map(function (ref) {
53
        var rev = c.refs[ref]
54
        var shortName = ref.replace(/^refs\/(heads|tags)\//, '')
55
        return h('li',
56
          shortName + ': ',
57
          rev ? h('code', rev) : h('em', 'deleted'))
58
      })) : null,
59
      Array.isArray(c.issues) ? c.issues.map(function (issue) {
60
        if (issue.merged === true)
61
          return ['Merged ', message_link(issue.link), ' in ',
62
            h('code', issue.object), ' ', h('q', issue.label)]
63
        if (issue.open === false)
64
          return ['Closed ', message_link(issue.link), ' in ',
65
            h('code', issue.object), ' ', h('q', issue.label)]
66
      }) : null
67
    )
68
  }
69
}
70
71
exports.message_meta = function (msg, sbot) {
72
  var type = msg.value.content.type
73
  if (type == 'issue' || type == 'pull-request') {
74
    var el = h('em', '...')
75
    getIssueState(msg.key, function (err, state) {
76
      if (err) return console.error(err)
77
      el.textContent = state
78
    })
79
    return el
80
  }
81
}
82