git ssb

1
var h = require('hyperscript')
2
var pull = require('pull-stream')
3
var paramap = require('pull-paramap')
4
var human = require('human-time')
5
6
var plugs = require('../plugs')
7
var message_link = plugs.first(exports.message_link = [])
8
var sbot_links = plugs.first(exports.sbot_links = [])
9
var sbot_links2 = plugs.first(exports.sbot_links2 = [])
10
var sbot_get = plugs.first(exports.sbot_get = [])
11
var getAvatar = require('ssb-avatar')
12
var avatar_name = plugs.first(exports.avatar_name = [])
13
var markdown = plugs.first(exports.markdown = [])
14
15
var self_id = require('../keys').id
16
17
function shortRefName(ref) {
18
  return ref.replace(/^refs\/(heads|tags)\//, '')
19
}
20
21
function repoLink(id) {
22
  var el = h('a', {href: '#'+id}, id.substr(0, 10) + '…')
23
  getAvatar({links: sbot_links}, self_id, id, function (err, avatar) {
24
    if(err) return console.error(err)
25
    el.textContent = avatar.name
26
  })
27
  return el
28
}
29
30
function getIssueState(id, cb) {
31
  pull(
32
    sbot_links({dest: id, rel: 'issues', values: true, reverse: true}),
33
    pull.map(function (msg) {
34
      var issues = msg.value.content.issues
35
      if (!Array.isArray(issues)) return
36
      return issues.filter(function (issue) {
37
        return issue.link === id
38
      })
39
    }),
40
    pull.flatten(),
41
    pull.map(function (issue) {
42
      return issue.merged ? 'merged' : issue.open ? 'open' : 'closed'
43
    }),
44
    pull.take(1),
45
    pull.collect(function (err, updates) {
46
      cb(err, updates && updates[0] || 'open')
47
    })
48
  )
49
}
50
51
//todo: 
52
function messageTimestampLink(msg) {
53
  return h('a.timestamp', {
54
    timestamp: msg.value.timestamp,
55
    title: new Date(msg.value.timestamp),
56
    href: '#'+msg.key
57
  }, human(msg.value.timestamp))
58
}
59
60
function tableRows(headerRow) {
61
  var thead = h('thead'), tbody = h('tbody')
62
  var first = true
63
  var t = [thead, tbody]
64
  t.append = function (row) {
65
    if (first) {
66
      first = false
67
      thead.appendChild(headerRow)
68
    }
69
    tbody.appendChild(row)
70
  }
71
  return t
72
}
73
74
function repoName(id, link) {
75
  var el = link
76
    ? h('a', {href: '#'+id}, id.substr(0, 8) + '…')
77
    : h('ins', id.substr(0, 8) + '…')
78
  getAvatar({links: sbot_links}, self_id, id, function (err, avatar) {
79
    if(err) return console.error(err)
80
    el.textContent = avatar.name
81
  })
82
  return el
83
}
84
85
exports.message_content = function (msg, sbot) {
86
  var c = msg.value.content
87
88
  if(c.type === 'git-repo') {
89
    var branchesT, tagsT, openIssuesT, closedIssuesT, openPRsT, closedPRsT
90
    var forksT
91
    var div = h('div',
92
      h('p', 'git repo ', repoName(msg.key)),
93
      c.upstream ? h('p', 'fork of ', repoName(c.upstream, true)) : '',
94
      h('p', h('code', 'ssb://' + msg.key)),
95
      h('div.git-table-wrapper', {style: {'max-height': '12em'}},
96
        h('table',
97
          branchesT = tableRows(h('tr',
98
            h('th', 'branch'),
99
            h('th', 'commit'),
100
            h('th', 'last update'))),
101
          tagsT = tableRows(h('tr',
102
            h('th', 'tag'),
103
            h('th', 'commit'),
104
            h('th', 'last update'))))),
105
      h('div.git-table-wrapper', {style: {'max-height': '16em'}},
106
        h('table',
107
          openIssuesT = tableRows(h('tr',
108
            h('th', 'open issues'))),
109
          closedIssuesT = tableRows(h('tr',
110
            h('th', 'closed issues'))))),
111
      h('div.git-table-wrapper', {style: {'max-height': '16em'}},
112
        h('table',
113
          openPRsT = tableRows(h('tr',
114
            h('th', 'open pull requests'))),
115
          closedPRsT = tableRows(h('tr',
116
            h('th', 'closed pull requests'))))),
117
      h('div.git-table-wrapper',
118
        h('table',
119
          forksT = tableRows(h('tr',
120
            h('th', 'forks'))))))
121
122
    // compute refs
123
    var refs = {}
124
    pull(
125
      sbot_links({
126
        reverse: true,
127
        source: msg.value.author,
128
        dest: msg.key,
129
        rel: 'repo',
130
        values: true
131
      }),
132
      pull.drain(function (link) {
133
        var refUpdates = link.value.content.refs || {}
134
        Object.keys(refUpdates).reverse().filter(function (ref) {
135
          if (refs[ref]) return
136
          refs[ref] = true
137
          var rev = refUpdates[ref]
138
          if (!rev) return
139
          var parts = /^refs\/(heads|tags)\/(.*)$/.exec(ref) || []
140
          var t
141
          if (parts[1] === 'heads') t = branchesT
142
          else if (parts[1] === 'tags') t = tagsT
143
          if (t) t.append(h('tr',
144
            h('td', parts[2]),
145
            h('td', h('code', rev)),
146
            h('td', messageTimestampLink(link))))
147
        })
148
      }, function (err) {
149
        if (err) console.error(err)
150
      })
151
    )
152
153
    // list issues and pull requests
154
    pull(
155
      sbot_links({
156
        reverse: true,
157
        dest: msg.key,
158
        rel: 'project',
159
        values: true
160
      }),
161
      paramap(function (link, cb) {
162
        getIssueState(link.key, function (err, state) {
163
          if(err) return cb(err)
164
          link.state = state
165
          cb(null, link)
166
        })
167
      }),
168
      pull.drain(function (link) {
169
        var c = link.value.content
170
        var title = c.title || (c.text ? c.text.length > 70
171
          ? c.text.substr(0, 70) + '…'
172
          : c.text : link.key)
173
        var author = link.value.author
174
        var t = c.type === 'pull-request'
175
          ? link.state === 'open' ? openPRsT : closedPRsT
176
          : link.state === 'open' ? openIssuesT : closedIssuesT
177
        t.append(h('tr',
178
          h('td',
179
            h('a', {href: '#'+link.key}, title), h('br'),
180
            h('small',
181
              'opened ', messageTimestampLink(link),
182
              ' by ', h('a', {href: '#'+author}, avatar_name(author))))))
183
      }, function (err) {
184
        if (err) console.error(err)
185
      })
186
    )
187
188
    // list forks
189
    pull(
190
      sbot_links({
191
        reverse: true,
192
        dest: msg.key,
193
        rel: 'upstream'
194
      }),
195
      pull.drain(function (link) {
196
        forksT.append(h('tr', h('td',
197
          repoName(link.key, true),
198
          ' by ', h('a', {href: '#'+link.source}, avatar_name(link.source)))))
199
      }, function (err) {
200
        if (err) console.error(err)
201
      })
202
    )
203
204
    return div
205
  }
206
207
  if(c.type === 'git-update') {
208
    return h('p',
209
      'pushed to ',
210
      repoLink(c.repo),
211
      c.refs ? h('ul', Object.keys(c.refs).map(function (ref) {
212
        var rev = c.refs[ref]
213
        return h('li',
214
          shortRefName(ref) + ': ',
215
          rev ? h('code', rev) : h('em', 'deleted'))
216
      })) : null,
217
      Array.isArray(c.issues) ? c.issues.map(function (issue) {
218
        if (issue.merged === true)
219
          return ['Merged ', message_link(issue.link), ' in ',
220
            h('code', issue.object), ' ', h('q', issue.label)]
221
        if (issue.open === false)
222
          return ['Closed ', message_link(issue.link), ' in ',
223
            h('code', issue.object), ' ', h('q', issue.label)]
224
      }) : null
225
    )
226
  }
227
228
  if (c.type === 'issue') {
229
    return h('div',
230
      h('p', 'opened issue on ', repoLink(c.project)),
231
      c.title ? h('h4', c.title) : '',
232
      markdown(c)
233
    )
234
  }
235
236
  if (c.type === 'pull-request') {
237
    return h('div',
238
      h('p', 'opened pull-request ',
239
        'to ', repoLink(c.repo), ':', c.branch, ' ',
240
        'from ', repoLink(c.head_repo), ':', c.head_branch),
241
      c.title ? h('h4', c.title) : '',
242
      markdown(c)
243
    )
244
  }
245
}
246
247
exports.message_meta = function (msg, sbot) {
248
  var type = msg.value.content.type
249
  if (type == 'issue' || type == 'pull-request') {
250
    var el = h('em', '...')
251
    getIssueState(msg.key, function (err, state) {
252
      if (err) return console.error(err)
253
      el.textContent = state
254
    })
255
    return el
256
  }
257
}
258
259
260