git ssb

Files: 6d3a8a6342ec134487fe48ba802ee255960dabf0 / index.js

90020 bytesRaw
1 var fs = require('fs')
2 var http = require('http')
3 var path = require('path')
4 var url = require('url')
5 var qs = require('querystring')
6 var util = require('util')
7 var ref = require('ssb-ref')
8 var pull = require('pull-stream')
9 var ssbGit = require('ssb-git-repo')
10 var toPull = require('stream-to-pull-stream')
11 var cat = require('pull-cat')
12 var Repo = require('pull-git-repo')
13 var ssbAbout = require('./about')
14 var ssbVotes = require('./votes')
15 var i18n = require('./i18n')
16 var marked = require('ssb-marked')
17 var asyncMemo = require('asyncmemo')
18 var multicb = require('multicb')
19 var schemas = require('ssb-msg-schemas')
20 var Issues = require('ssb-issues')
21 var PullRequests = require('ssb-pull-requests')
22 var paramap = require('pull-paramap')
23 var gitPack = require('pull-git-pack')
24 var Mentions = require('ssb-mentions')
25 var Highlight = require('highlight.js')
26 var JsDiff = require('diff')
27 var many = require('pull-many')
28 
29 var hlCssPath = path.resolve(require.resolve('highlight.js'), '../../styles')
30 
31 // render links to git objects and ssb objects
32 var blockRenderer = new marked.Renderer()
33 blockRenderer.urltransform = function (url) {
34   if (ref.isLink(url))
35     return encodeLink(url)
36   if (/^[0-9a-f]{40}$/.test(url) && this.options.repo)
37     return encodeLink([this.options.repo.id, 'commit', url])
38   return url
39 }
40 
41 blockRenderer.image = function (href, title, text) {
42   href = href.replace(/^&amp;/, '&')
43   var url
44   if (ref.isBlobId(href))
45     url = encodeLink(href)
46   else if (this.options.repo && this.options.rev && this.options.path)
47     url = path.join('/', encodeURIComponent(this.options.repo.id),
48       'raw', this.options.rev, this.options.path.join('/'), href)
49   else
50     return text
51   return '<img src="' + escapeHTML(url) + '" alt="' + text + '"' +
52     (title ? ' title="' + title + '"' : '') + '/>'
53 }
54 
55 function getExtension(filename) {
56   return (/\.([^.]+)$/.exec(filename) || [,filename])[1]
57 }
58 
59 function highlight(code, lang) {
60   try {
61     return lang
62       ? Highlight.highlight(lang, code).value
63       : Highlight.highlightAuto(code).value
64   } catch(e) {
65     if (/^Unknown language/.test(e.message))
66       return escapeHTML(code)
67     throw e
68   }
69 }
70 
71 marked.setOptions({
72   gfm: true,
73   mentions: true,
74   tables: true,
75   breaks: true,
76   pedantic: false,
77   sanitize: true,
78   smartLists: true,
79   smartypants: false,
80   highlight: highlight,
81   renderer: blockRenderer
82 })
83 
84 // hack to make git link mentions work
85 var mdRules = new marked.InlineLexer(1, marked.defaults).rules
86 mdRules.mention =
87   /^(\s)?([@%&][A-Za-z0-9\._\-+=\/]*[A-Za-z0-9_\-+=\/]|[0-9a-f]{40})/
88 mdRules.text = /^[\s\S]+?(?=[\\<!\[_*`]| {2,}\n| [@%&]|[0-9a-f]{40}|$)/
89 
90 function markdown(text, options, cb) {
91   if (!text) return ''
92   if (typeof text != 'string') text = String(text)
93   if (!options) options = {}
94   else if (options.id) options = {repo: options}
95   if (!options.rev) options.rev = 'HEAD'
96   if (!options.path) options.path = []
97 
98   return marked(text, options, cb)
99 }
100 
101 function ParamError(msg) {
102   var err = Error.call(this, msg)
103   err.name = ParamError.name
104   return err
105 }
106 util.inherits(ParamError, Error)
107 
108 function parseAddr(str, def) {
109   if (!str) return def
110   var i = str.lastIndexOf(':')
111   if (~i) return {host: str.substr(0, i), port: str.substr(i+1)}
112   if (isNaN(str)) return {host: str, port: def.port}
113   return {host: def.host, port: str}
114 }
115 
116 function isArray(arr) {
117   return Object.prototype.toString.call(arr) == '[object Array]'
118 }
119 
120 function encodeLink(url) {
121   if (!isArray(url)) url = [url]
122   return '/' + url.map(encodeURIComponent).join('/')
123 }
124 
125 function link(parts, text, raw, props) {
126   if (text == null) text = parts[parts.length-1]
127   if (!raw) text = escapeHTML(text)
128   return '<a href="' + encodeLink(parts) + '"' +
129     (props ? ' ' + props : '') +
130     '>' + text + '</a>'
131 }
132 
133 function linkify(text) {
134   // regex is from ssb-ref
135   return text.replace(/(@|%|&|&amp;)[A-Za-z0-9\/+]{43}=\.[\w\d]+/g, function (str) {
136     return '<a href="/' + encodeURIComponent(str) + '">' + str + '</a>'
137   })
138 }
139 
140 function timestamp(time, req) {
141   time = Number(time)
142   var d = new Date(time)
143   return '<span title="' + time + '">' +
144     d.toLocaleString(req._locale) + '</span>'
145 }
146 
147 function pre(text) {
148   return '<pre>' + escapeHTML(text) + '</pre>'
149 }
150 
151 function json(obj) {
152   return linkify(pre(JSON.stringify(obj, null, 2)))
153 }
154 
155 function escapeHTML(str) {
156   return String(str)
157     .replace(/&/g, '&amp;')
158     .replace(/</g, '&lt;')
159     .replace(/>/g, '&gt;')
160     .replace(/"/g, '&quot;')
161 }
162 
163 function table(props) {
164   return function (read) {
165     return cat([
166       pull.once('<table' + (props ? ' ' + props : '') + '>'),
167       pull(
168         read,
169         pull.map(function (row) {
170           return row ? '<tr>' + row.map(function (cell) {
171             return '<td>' + cell + '</td>'
172           }).join('') + '</tr>' : ''
173         })
174       ),
175       pull.once('</table>')
176     ])
177   }
178 }
179 
180 function ul(props) {
181   return function (read) {
182     return cat([
183       pull.once('<ul' + (props ? ' ' + props : '') + '>'),
184       pull(
185         read,
186         pull.map(function (li) {
187           return '<li>' + li + '</li>'
188         })
189       ),
190       pull.once('</ul>')
191     ])
192   }
193 }
194 
195 function nav(links, page, after) {
196   return ['<nav>'].concat(
197     links.map(function (link) {
198       var href = typeof link[0] == 'string' ? link[0] : encodeLink(link[0])
199       var props = link[2] == page ? ' class="active"' : ''
200       return '<a href="' + href + '"' + props + '>' + link[1] + '</a>'
201     }), after || '', '</nav>').join('')
202 }
203 
204 function renderNameForm(req, enabled, id, name, action, inputId, title, header) {
205   if (!inputId) inputId = action
206   return '<form class="petname" action="" method="post">' +
207     (enabled ?
208       '<input type="checkbox" class="name-checkbox" id="' + inputId + '" ' +
209         'onfocus="this.form.name.focus()" />' +
210       '<input name="name" class="name" value="' + escapeHTML(name) + '" ' +
211         'onkeyup="if (event.keyCode == 27) this.form.reset()" />' +
212       '<input type="hidden" name="action" value="' + action + '">' +
213       '<input type="hidden" name="id" value="' +
214         escapeHTML(id) + '">' +
215       '<label class="name-toggle" for="' + inputId + '" ' +
216         'title="' + title + '"><i>✍</i></label> ' +
217       '<input class="btn name-btn" type="submit" value="' +
218         req._t('Rename') + '">' +
219       header :
220       header + '<br clear="all"/>'
221     ) +
222   '</form>'
223 }
224 
225 function renderPostForm(req, repo, placeholder, rows) {
226   return '<input type="radio" class="tab-radio" id="tab1" name="tab" checked="checked"/>' +
227   '<input type="radio" class="tab-radio" id="tab2" name="tab"/>' +
228   '<div id="tab-links" class="tab-links" style="display:none">' +
229     '<label for="tab1" id="write-tab-link" class="tab1-link">' +
230       req._t('post.Write') + '</label>' +
231     '<label for="tab2" id="preview-tab-link" class="tab2-link">' +
232       req._t('post.Preview') + '</label>' +
233   '</div>' +
234   '<input type="hidden" id="repo-id" value="' + repo.id + '"/>' +
235   '<div id="write-tab" class="tab1">' +
236     '<textarea id="post-text" name="text" class="wide-input"' +
237     ' rows="' + (rows||4) + '" cols="77"' +
238     (placeholder ? ' placeholder="' + placeholder + '"' : '') +
239     '></textarea>' +
240   '</div>' +
241   '<div class="preview-text tab2" id="preview-tab"></div>' +
242   '<script>' + issueCommentScript + '</script>'
243 }
244 
245 function hiddenInputs(values) {
246   return Object.keys(values).map(function (key) {
247     return '<input type="hidden"' +
248       ' name="' + escapeHTML(key) + '"' +
249       ' value="' + escapeHTML(values[key]) + '"/>'
250   }).join('')
251 }
252 
253 function readNext(fn) {
254   var next
255   return function (end, cb) {
256     if (next) return next(end, cb)
257     fn(function (err, _next) {
258       if (err) return cb(err)
259       next = _next
260       next(null, cb)
261     })
262   }
263 }
264 
265 function readOnce(fn) {
266   var ended
267   return function (end, cb) {
268     fn(function (err, data) {
269       if (err || ended) return cb(err || ended)
270       ended = true
271       cb(null, data)
272     })
273   }
274 }
275 
276 function paginate(onFirst, through, onLast, onEmpty) {
277   var ended, last, first = true, queue = []
278   return function (read) {
279     var mappedRead = through(function (end, cb) {
280       if (ended = end) return read(ended, cb)
281       if (queue.length)
282         return cb(null, queue.shift())
283       read(null, function (end, data) {
284         if (end) return cb(end)
285         last = data
286         cb(null, data)
287       })
288     })
289     return function (end, cb) {
290       var tmp
291       if (ended) return cb(ended)
292       if (ended = end) return read(ended, cb)
293       if (first)
294         return read(null, function (end, data) {
295           if (ended = end) {
296             if (end === true && onEmpty)
297               return onEmpty(cb)
298             return cb(ended)
299           }
300           first = false
301           last = data
302           queue.push(data)
303           if (onFirst)
304             onFirst(data, cb)
305           else
306             mappedRead(null, cb)
307         })
308       mappedRead(null, function (end, data) {
309         if (ended = end) {
310           if (end === true && last)
311             return onLast(last, cb)
312         }
313         cb(end, data)
314       })
315     }
316   }
317 }
318 
319 function readObjectString(obj, cb) {
320   pull(obj.read, pull.collect(function (err, bufs) {
321     if (err) return cb(err)
322     cb(null, Buffer.concat(bufs, obj.length).toString('utf8'))
323   }))
324 }
325 
326 function getRepoObjectString(repo, id, cb) {
327   if (!id) return cb(null, '')
328   repo.getObjectFromAny(id, function (err, obj) {
329     if (err) return cb(err)
330     readObjectString(obj, cb)
331   })
332 }
333 
334 function compareMsgs(a, b) {
335   return (a.value.timestamp - b.value.timestamp) || (a.key - b.key)
336 }
337 
338 function pullSort(comparator) {
339   return function (read) {
340     return readNext(function (cb) {
341       pull(read, pull.collect(function (err, items) {
342         if (err) return cb(err)
343         items.sort(comparator)
344         cb(null, pull.values(items))
345       }))
346     })
347   }
348 }
349 
350 function sortMsgs() {
351   return pullSort(compareMsgs)
352 }
353 
354 function pullReverse() {
355   return function (read) {
356     return readNext(function (cb) {
357       pull(read, pull.collect(function (err, items) {
358         cb(err, items && pull.values(items.reverse()))
359       }))
360     })
361   }
362 }
363 
364 function tryDecodeURIComponent(str) {
365   if (!str || (str[0] == '%' && ref.isBlobId(str)))
366     return str
367   try {
368     str = decodeURIComponent(str)
369   } finally {
370     return str
371   }
372 }
373 
374 function getRepoName(about, ownerId, repoId, cb) {
375   about.getName({
376     owner: ownerId,
377     target: repoId,
378     toString: function () {
379       // hack to fit two parameters into asyncmemo
380       return ownerId + '/' + repoId
381     }
382   }, cb)
383 }
384 
385 function getRepoFullName(about, author, repoId, cb) {
386   var done = multicb({ pluck: 1, spread: true })
387   getRepoName(about, author, repoId, done())
388   about.getName(author, done())
389   done(cb)
390 }
391 
392 function addAuthorName(about) {
393   return paramap(function (msg, cb) {
394     var author = msg && msg.value && msg.value.author
395     if (!author) return cb(null, msg)
396     about.getName(author, function (err, authorName) {
397       msg.authorName = authorName
398       cb(err, msg)
399     })
400   }, 8)
401 }
402 
403 function getMention(msg, id) {
404   if (msg.key == id) return msg
405   var mentions = msg.value.content.mentions
406   if (mentions) for (var i = 0; i < mentions.length; i++) {
407     var mention = mentions[i]
408     if (mention.link == id)
409       return mention
410   }
411   return null
412 }
413 
414 var hasOwnProp = Object.prototype.hasOwnProperty
415 
416 function getContentType(filename) {
417   var ext = getExtension(filename)
418   return contentTypes[ext] || imgMimes[ext] || 'text/plain; charset=utf-8'
419 }
420 
421 var contentTypes = {
422   css: 'text/css'
423 }
424 
425 function readReqForm(req, cb) {
426   pull(
427     toPull(req),
428     pull.collect(function (err, bufs) {
429       if (err) return cb(err)
430       var data
431       try {
432         data = qs.parse(Buffer.concat(bufs).toString('ascii'))
433       } catch(e) {
434         return cb(e)
435       }
436       cb(null, data)
437     })
438   )
439 }
440 
441 var issueCommentScript = '(' + function () {
442   var $ = document.getElementById.bind(document)
443   $('tab-links').style.display = 'block'
444   $('preview-tab-link').onclick = function (e) {
445     with (new XMLHttpRequest()) {
446       open('POST', '', true)
447       onload = function() {
448         $('preview-tab').innerHTML = responseText
449       }
450       send('action=markdown' +
451         '&repo=' + encodeURIComponent($('repo-id').value) +
452         '&text=' + encodeURIComponent($('post-text').value))
453     }
454   }
455 }.toString() + ')()'
456 
457 var msgTypes = {
458   'git-repo': true,
459   'git-update': true,
460   'issue': true,
461   'pull-request': true
462 }
463 
464 var imgMimes = {
465   png: 'image/png',
466   jpeg: 'image/jpeg',
467   jpg: 'image/jpeg',
468   gif: 'image/gif',
469   tif: 'image/tiff',
470   svg: 'image/svg+xml',
471   bmp: 'image/bmp'
472 }
473 
474 module.exports = function (opts, cb) {
475   var ssb, reconnect, myId, getRepo, getVotes, getMsg, issues
476   var about = function (id, cb) { cb(null, {name: id}) }
477   var reqQueue = []
478   var isPublic = opts.public
479   var ssbAppname = opts.appname || 'ssb'
480 
481   var addr = parseAddr(opts.listenAddr, {host: 'localhost', port: 7718})
482   http.createServer(onRequest).listen(addr.port, addr.host, onListening)
483 
484   var server = {
485     setSSB: function (_ssb, _reconnect) {
486       _ssb.whoami(function (err, feed) {
487         if (err) throw err
488         ssb = _ssb
489         reconnect = _reconnect
490         myId = feed.id
491         about = ssbAbout(ssb, myId)
492         while (reqQueue.length)
493           onRequest.apply(this, reqQueue.shift())
494         getRepo = asyncMemo(function (id, cb) {
495           getMsg(id, function (err, msg) {
496             if (err) return cb(err)
497             ssbGit.getRepo(ssb, {key: id, value: msg}, {live: true}, cb)
498           })
499         })
500         getVotes = ssbVotes(ssb)
501         getMsg = asyncMemo(ssb.get)
502         issues = Issues.init(ssb)
503         pullReqs = PullRequests.init(ssb)
504       })
505     }
506   }
507 
508   function onListening() {
509     var host = ~addr.host.indexOf(':') ? '[' + addr.host + ']' : addr.host
510     console.log('Listening on http://' + host + ':' + addr.port + '/')
511     cb(null, server)
512   }
513 
514   /* Serving a request */
515 
516   function onRequest(req, res) {
517     console.log(req.method, req.url)
518     if (!ssb) return reqQueue.push(arguments)
519     req._u = url.parse(req.url, true)
520     var locale = req._u.query.locale ||
521       (/locale=([^;]*)/.exec(req.headers.cookie) || [])[1]
522     var reqLocales = req.headers['accept-language']
523     i18n.pickCatalog(reqLocales, locale, function (err, t) {
524       if (err) return pull(serveError(req, err, 500), serve(req, res))
525       req._t = t
526       req._locale = t.locale
527       pull(handleRequest(req), serve(req, res))
528     })
529   }
530 
531   function serve(req, res) {
532     return pull(
533       pull.filter(function (data) {
534         if (Array.isArray(data)) {
535           res.writeHead.apply(res, data)
536           return false
537         }
538         return true
539       }),
540       toPull(res)
541     )
542   }
543 
544   function handleRequest(req) {
545     var path = req._u.pathname.slice(1)
546     var dirs = ref.isLink(path) ? [path] :
547       path.split(/\/+/).map(tryDecodeURIComponent)
548     var dir = dirs[0]
549 
550     if (req.method == 'POST') {
551       if (isPublic)
552         return serveBuffer(405, req._t('error.POSTNotAllowed'))
553       return readNext(function (cb) {
554         readReqForm(req, function (err, data) {
555           if (err) return cb(null, serveError(req, err, 400))
556           if (!data) return cb(null, serveError(req,
557             new ParamError(req._t('error.MissingData')), 400))
558 
559           switch (data.action) {
560             case 'fork-prompt':
561               return cb(null, serveRedirect(req,
562                 encodeLink([data.id, 'fork'])))
563 
564             case 'fork':
565               if (!data.id)
566                 return cb(null, serveError(req,
567                   new ParamError(req._t('error.MissingId')), 400))
568               return ssbGit.createRepo(ssb, {upstream: data.id},
569                 function (err, repo) {
570                   if (err) return cb(null, serveError(req, err))
571                   cb(null, serveRedirect(req, encodeLink(repo.id)))
572                 })
573 
574             case 'vote':
575               var voteValue = +data.value || 0
576               if (!data.id)
577                 return cb(null, serveError(req,
578                   new ParamError(req._t('error.MissingId')), 400))
579               var msg = schemas.vote(data.id, voteValue)
580               return ssb.publish(msg, function (err) {
581                 if (err) return cb(null, serveError(req, err))
582                 cb(null, serveRedirect(req, req.url))
583               })
584 
585           case 'repo-name':
586             if (!data.id)
587               return cb(null, serveError(req,
588                 new ParamError(req._t('error.MissingId')), 400))
589             if (!data.name)
590               return cb(null, serveError(req,
591                 new ParamError(req._t('error.MissingName')), 400))
592             var msg = schemas.name(data.id, data.name)
593             return ssb.publish(msg, function (err) {
594               if (err) return cb(null, serveError(req, err))
595               cb(null, serveRedirect(req, req.url))
596             })
597 
598           case 'issue-title':
599             if (!data.id)
600               return cb(null, serveError(req,
601                 new ParamError(req._t('error.MissingId')), 400))
602             if (!data.name)
603               return cb(null, serveError(req,
604                 new ParamError(req._t('error.MissingName')), 400))
605             var msg = Issues.schemas.edit(data.id, {title: data.name})
606             return ssb.publish(msg, function (err) {
607               if (err) return cb(null, serveError(req, err))
608               cb(null, serveRedirect(req, req.url))
609             })
610 
611           case 'comment':
612             if (!data.id)
613               return cb(null, serveError(req,
614                 new ParamError(req._t('error.MissingId')), 400))
615             var msg = schemas.post(data.text, data.id, data.branch || data.id)
616             msg.issue = data.issue
617             msg.repo = data.repo
618             if (data.open != null)
619               Issues.schemas.opens(msg, data.id)
620             if (data.close != null)
621               Issues.schemas.closes(msg, data.id)
622             var mentions = Mentions(data.text)
623             if (mentions.length)
624               msg.mentions = mentions
625             return ssb.publish(msg, function (err) {
626               if (err) return cb(null, serveError(req, err))
627               cb(null, serveRedirect(req, req.url))
628             })
629 
630           case 'new-issue':
631             var msg = Issues.schemas.new(dir, data.title, data.text)
632             var mentions = Mentions(data.text)
633             if (mentions.length)
634               msg.mentions = mentions
635             return ssb.publish(msg, function (err, msg) {
636               if (err) return cb(null, serveError(req, err))
637               cb(null, serveRedirect(req, encodeLink(msg.key)))
638             })
639 
640           case 'new-pull':
641             var msg = PullRequests.schemas.new(dir, data.branch,
642               data.head_repo, data.head_branch, data.title, data.text)
643             var mentions = Mentions(data.text)
644             if (mentions.length)
645               msg.mentions = mentions
646             return ssb.publish(msg, function (err, msg) {
647               if (err) return cb(null, serveError(req, err))
648               cb(null, serveRedirect(req, encodeLink(msg.key)))
649             })
650 
651           case 'markdown':
652             return cb(null, serveMarkdown(data.text, {id: data.repo}))
653 
654           default:
655             cb(null, serveBuffer(400, req._t('error.UnknownAction', data)))
656           }
657         })
658       })
659     }
660 
661     if (dir == '')
662       return serveIndex(req)
663     else if (dir == 'search')
664       return serveSearch(req)
665     else if (ref.isBlobId(dir))
666       return serveBlob(req, dir)
667     else if (ref.isMsgId(dir))
668       return serveMessage(req, dir, dirs.slice(1))
669     else if (ref.isFeedId(dir))
670       return serveUserPage(req, dir, dirs.slice(1))
671     else if (dir == 'static')
672       return serveFile(req, dirs)
673     else if (dir == 'highlight')
674       return serveFile(req, [hlCssPath].concat(dirs.slice(1)), true)
675     else
676       return serve404(req)
677   }
678 
679   function serveFile(req, dirs, outside) {
680     var filename = path.resolve.apply(path, [__dirname].concat(dirs))
681     // prevent escaping base dir
682     if (!outside && filename.indexOf('../') === 0)
683       return serveBuffer(403, req._t("error.403Forbidden"))
684 
685     return readNext(function (cb) {
686       fs.stat(filename, function (err, stats) {
687         cb(null, err ?
688           err.code == 'ENOENT' ? serve404(req)
689           : serveBuffer(500, err.message)
690         : 'if-modified-since' in req.headers &&
691           new Date(req.headers['if-modified-since']) >= stats.mtime ?
692           pull.once([304])
693         : stats.isDirectory() ?
694           serveBuffer(403, req._t('error.DirectoryNotListable'))
695         : cat([
696           pull.once([200, {
697             'Content-Type': getContentType(filename),
698             'Content-Length': stats.size,
699             'Last-Modified': stats.mtime.toGMTString()
700           }]),
701           toPull(fs.createReadStream(filename))
702         ]))
703       })
704     })
705   }
706 
707   function servePlainError(code, msg) {
708     return pull.values([
709       [code, {
710         'Content-Length': Buffer.byteLength(msg),
711         'Content-Type': 'text/plain; charset=utf-8'
712       }],
713       msg
714     ])
715   }
716 
717   function serveBuffer(code, buf, contentType, headers) {
718     headers = headers || {}
719     headers['Content-Type'] = contentType || 'text/plain; charset=utf-8'
720     headers['Content-Length'] = Buffer.byteLength(buf)
721     return pull.values([
722       [code, headers],
723       buf
724     ])
725   }
726 
727   function serve404(req) {
728     return serveBuffer(404, req._t("error.404NotFound"))
729   }
730 
731   function serveRedirect(req, path) {
732     return serveBuffer(302,
733       '<!doctype><html><head>' +
734       '<title>' + req._t('Redirect') + '</title></head><body>' +
735       '<p><a href="' + escapeHTML(path) + '">' +
736         req._t('Continue') + '</a></p>' +
737       '</body></html>', 'text/html; charset=utf-8', {Location: path})
738   }
739 
740   function serveMarkdown(text, repo) {
741     return serveBuffer(200, markdown(text, repo), 'text/html; charset=utf-8')
742   }
743 
744   function renderError(err, tag) {
745     tag = tag || 'h3'
746     return '<' + tag + '>' + err.name + '</' + tag + '>' +
747       '<pre>' + escapeHTML(err.stack) + '</pre>'
748   }
749 
750   function renderTry(read) {
751     var ended
752     return function (end, cb) {
753       if (ended) return cb(ended)
754       read(end, function (err, data) {
755         if (err === true)
756           cb(true)
757         else if (err) {
758           ended = true
759           cb(null, renderError(err, 'h3'))
760         } else
761           cb(null, data)
762       })
763     }
764   }
765 
766   function serveTemplate(req, title, code, read) {
767     if (read === undefined) return serveTemplate.bind(this, req, title, code)
768     var q = req._u.query.q && escapeHTML(req._u.query.q) || ''
769     var app = 'git ssb'
770     if (req._t) app = req._t(app)
771     return cat([
772       pull.values([
773         [code || 200, {
774           'Content-Type': 'text/html'
775         }],
776         '<!doctype html><html><head><meta charset=utf-8>',
777         '<title>' + (title || app) + '</title>',
778         '<link rel=stylesheet href="/static/styles.css"/>',
779         '<link rel=stylesheet href="/highlight/github.css"/>',
780         '</head>\n',
781         '<body>',
782         '<header><form action="/search" method="get">' +
783         '<h1><a href="/">' + app + '' +
784           (ssbAppname != 'ssb' ? ' <sub>' + ssbAppname + '</sub>' : '') +
785         '</a> ' +
786         '<input class="search-bar" name="q" size="60"' +
787           ' placeholder="🔍" value="' + q + '" />' +
788         '</h1>',
789         '</form></header>',
790         '<article>']),
791       renderTry(read),
792       pull.once('<hr/></article></body></html>')
793     ])
794   }
795 
796   function serveError(req, err, status) {
797     if (err.message == 'stream is closed')
798       reconnect()
799     return pull(
800       pull.once(renderError(err, 'h2')),
801       serveTemplate(req, err.name, status || 500)
802     )
803   }
804 
805   function renderObjectData(obj, filename, repo, rev, path) {
806     var ext = getExtension(filename)
807     return readOnce(function (cb) {
808       readObjectString(obj, function (err, buf) {
809         buf = buf.toString('utf8')
810         if (err) return cb(err)
811         cb(null, (ext == 'md' || ext == 'markdown')
812           ? markdown(buf, {repo: repo, rev: rev, path: path})
813           : renderCodeTable(buf, ext))
814       })
815     })
816   }
817 
818   function renderCodeTable(buf, ext) {
819     return '<pre><table class="code">' +
820       highlight(buf, ext).split('\n').map(function (line, i) {
821         i++
822         return '<tr id="L' + i + '">' +
823           '<td class="code-linenum">' + '<a href="#L' + i + '">' + i + '</td>' +
824           '<td class="code-text">' + line + '</td></tr>'
825       }).join('') +
826       '</table></pre>'
827   }
828 
829   /* Feed */
830 
831   function renderFeed(req, feedId, filter) {
832     var query = req._u.query
833     var opts = {
834       reverse: !query.forwards,
835       lt: query.lt && +query.lt || Date.now(),
836       gt: query.gt && +query.gt,
837       id: feedId
838     }
839     return pull(
840       feedId ? ssb.createUserStream(opts) : ssb.createFeedStream(opts),
841       pull.filter(function (msg) {
842         return msg.value.content.type in msgTypes
843       }),
844       typeof filter == 'function' ? filter(opts) : filter,
845       pull.take(20),
846       addAuthorName(about),
847       query.forwards && pullReverse(),
848       paginate(
849         function (first, cb) {
850           if (!query.lt && !query.gt) return cb(null, '')
851           var gt = feedId ? first.value.sequence : first.value.timestamp + 1
852           query.gt = gt
853           query.forwards = 1
854           delete query.lt
855           cb(null, '<a href="?' + qs.stringify(query) + '">' +
856             req._t('Newer') + '</a>')
857         },
858         paramap(renderFeedItem.bind(null, req), 8),
859         function (last, cb) {
860           query.lt = feedId ? last.value.sequence : last.value.timestamp - 1
861           delete query.gt
862           delete query.forwards
863           cb(null, '<a href="?' + qs.stringify(query) + '">' +
864             req._t('Older') + '</a>')
865         },
866         function (cb) {
867           if (query.forwards) {
868             delete query.gt
869             delete query.forwards
870             query.lt = opts.gt + 1
871           } else {
872             delete query.lt
873             query.gt = opts.lt - 1
874             query.forwards = 1
875           }
876           cb(null, '<a href="?' + qs.stringify(query) + '">' +
877             req._t(query.forwards ? 'Older' : 'Newer') + '</a>')
878         }
879       )
880     )
881   }
882 
883   function renderFeedItem(req, msg, cb) {
884     var c = msg.value.content
885     var msgLink = link([msg.key],
886       new Date(msg.value.timestamp).toLocaleString(req._locale))
887     var author = msg.value.author
888     var authorLink = link([msg.value.author], msg.authorName)
889     switch (c.type) {
890       case 'git-repo':
891         var done = multicb({ pluck: 1, spread: true })
892         getRepoName(about, author, msg.key, done())
893         if (c.upstream) {
894           return getMsg(c.upstream, function (err, upstreamMsg) {
895             if (err) return cb(null, serveError(req, err))
896             getRepoName(about, upstreamMsg.author, c.upstream, done())
897             done(function (err, repoName, upstreamName) {
898               cb(null, '<section class="collapse">' + msgLink + '<br>' +
899                 req._t('Forked', {
900                   name: authorLink,
901                   upstream: link([c.upstream], upstreamName),
902                   repo: link([msg.key], repoName)
903                 }) + '</section>')
904             })
905           })
906         } else {
907           return done(function (err, repoName) {
908             if (err) return cb(err)
909             var repoLink = link([msg.key], repoName)
910             cb(null, '<section class="collapse">' + msgLink + '<br>' +
911               req._t('CreatedRepo', {
912                 name: authorLink,
913                 repo: repoLink
914               }) + '</section>')
915           })
916         }
917       case 'git-update':
918         return getRepoName(about, author, c.repo, function (err, repoName) {
919           if (err) return cb(err)
920           var repoLink = link([c.repo], repoName)
921           cb(null, '<section class="collapse">' + msgLink + '<br>' +
922             req._t('Pushed', {
923               name: authorLink,
924               repo: repoLink
925             }) + '</section>')
926         })
927       case 'issue':
928       case 'pull-request':
929         var issueLink = link([msg.key], c.title)
930         return getMsg(c.project, function (err, projectMsg) {
931           if (err) return cb(null, serveRepoNotFound(req, c.repo, err))
932           getRepoName(about, projectMsg.author, c.project,
933             function (err, repoName) {
934               if (err) return cb(err)
935               var repoLink = link([c.project], repoName)
936               cb(null, '<section class="collapse">' + msgLink + '<br>' +
937                 req._t('OpenedIssue', {
938                   name: authorLink,
939                   type: req._t(c.type == 'pull-request' ?
940                     'pull request' : 'issue.'),
941                   title: issueLink,
942                   project: repoLink
943                 }) + '</section>')
944             })
945         })
946       case 'about':
947         return cb(null, '<section class="collapse">' + msgLink + '<br>' +
948           req._t('Named', {
949             author: authorLink,
950             target: '<tt>' + escapeHTML(c.about) + '</tt>',
951             name: link([c.about], c.name)
952           }) + '</section>')
953       default:
954         return cb(null, json(msg))
955     }
956   }
957 
958   /* Index */
959 
960   function serveIndex(req) {
961     return serveTemplate(req)(renderFeed(req))
962   }
963 
964   function serveUserPage(req, feedId, dirs) {
965     switch (dirs[0]) {
966       case undefined:
967       case '':
968       case 'activity':
969         return serveUserActivity(req, feedId)
970       case 'repos':
971         return serveUserRepos(req, feedId)
972     }
973   }
974 
975   function renderUserPage(req, feedId, page, body) {
976     return serveTemplate(req, feedId)(cat([
977       readOnce(function (cb) {
978         about.getName(feedId, function (err, name) {
979           cb(null, '<h2>' + link([feedId], name) +
980           '<code class="user-id">' + feedId + '</code></h2>' +
981           nav([
982             [[feedId], req._t('Activity'), 'activity'],
983             [[feedId, 'repos'], req._t('Repos'), 'repos']
984           ], page))
985         })
986       }),
987       body,
988     ]))
989   }
990 
991   function serveUserActivity(req, feedId) {
992     return renderUserPage(req, feedId, 'activity', renderFeed(req, feedId))
993   }
994 
995   function serveUserRepos(req, feedId) {
996     return renderUserPage(req, feedId, 'repos', pull(
997       cat([
998         ssb.messagesByType({
999           type: 'git-update',
1000           reverse: true
1001         }),
1002         ssb.messagesByType({
1003           type: 'git-repo',
1004           reverse: true
1005         })
1006       ]),
1007       pull.filter(function (msg) {
1008         return msg.value.author == feedId
1009       }),
1010       pull.unique(function (msg) {
1011         return msg.value.content.repo || msg.key
1012       }),
1013       pull.take(20),
1014       paramap(function (msg, cb) {
1015         var repoId = msg.value.content.repo || msg.key
1016         var done = multicb({ pluck: 1, spread: true })
1017         getRepoName(about, feedId, repoId, done())
1018         getVotes(repoId, done())
1019         done(function (err, repoName, votes) {
1020           if (err) return cb(err)
1021           cb(null, '<section class="collapse">' +
1022             '<span class="right-bar">' +
1023             '<i>✌</i> ' +
1024             link([repoId, 'digs'], votes.upvotes, true,
1025               ' title="' + req._t('Digs') + '"') +
1026             '</span>' +
1027             '<strong>' + link([repoId], repoName) + '</strong>' +
1028             '<div class="date-info">' +
1029             req._t(msg.value.content.type == 'git-update' ?
1030               'UpdatedOnDate' : 'CreatedOnDate',
1031             {
1032               date: timestamp(msg.value.timestamp, req)
1033             }) + '</div>' +
1034           '</section>')
1035         })
1036       }, 8)
1037     ))
1038   }
1039 
1040   /* Message */
1041 
1042   function serveMessage(req, id, path) {
1043     return readNext(function (cb) {
1044       ssb.get(id, function (err, msg) {
1045         if (err) return cb(null, serveError(req, err))
1046         var c = msg.content || {}
1047         switch (c.type) {
1048           case 'git-repo':
1049             return getRepo(id, function (err, repo) {
1050               if (err) return cb(null, serveError(req, err))
1051               cb(null, serveRepoPage(req, Repo(repo), path))
1052             })
1053           case 'git-update':
1054             return getRepo(c.repo, function (err, repo) {
1055               if (err) return cb(null, serveRepoNotFound(req, c.repo, err))
1056               cb(null, serveRepoUpdate(req, Repo(repo), id, msg, path))
1057             })
1058           case 'issue':
1059             return getRepo(c.project, function (err, repo) {
1060               if (err) return cb(null, serveRepoNotFound(req, c.project, err))
1061               issues.get(id, function (err, issue) {
1062                 if (err) return cb(null, serveError(req, err))
1063                 cb(null, serveRepoIssue(req, Repo(repo), issue, path))
1064               })
1065             })
1066           case 'pull-request':
1067             return getRepo(c.repo, function (err, repo) {
1068               if (err) return cb(null, serveRepoNotFound(req, c.project, err))
1069               pullReqs.get(id, function (err, pr) {
1070                 if (err) return cb(null, serveError(req, err))
1071                 cb(null, serveRepoPullReq(req, Repo(repo), pr, path))
1072               })
1073             })
1074           case 'issue-edit':
1075             if (ref.isMsgId(c.issue)) {
1076               return pullReqs.get(c.issue, function (err, issue) {
1077                 if (err) return cb(err)
1078                 var serve = issue.msg.value.content.type == 'pull-request' ?
1079                   serveRepoPullReq : serveRepoIssue
1080                 getRepo(issue.project, function (err, repo) {
1081                   if (err) {
1082                     if (!repo) return cb(null,
1083                       serveRepoNotFound(req, c.repo, err))
1084                     return cb(null, serveError(req, err))
1085                   }
1086                   cb(null, serve(req, Repo(repo), issue, path, id))
1087                 })
1088               })
1089             }
1090             // fallthrough
1091           case 'post':
1092             if (ref.isMsgId(c.issue) && ref.isMsgId(c.repo)) {
1093               // comment on an issue
1094               var done = multicb({ pluck: 1, spread: true })
1095               getRepo(c.repo, done())
1096               pullReqs.get(c.issue, done())
1097               return done(function (err, repo, issue) {
1098                 if (err) {
1099                   if (!repo) return cb(null,
1100                     serveRepoNotFound(req, c.repo, err))
1101                   return cb(null, serveError(req, err))
1102                 }
1103                 var serve = issue.msg.value.content.type == 'pull-request' ?
1104                   serveRepoPullReq : serveRepoIssue
1105                 cb(null, serve(req, Repo(repo), issue, path, id))
1106               })
1107             } else if (ref.isMsgId(c.root)) {
1108               // comment on issue from patchwork?
1109               return getMsg(c.root, function (err, root) {
1110                 if (err) return cb(null, serveError(req, err))
1111                 var repoId = root.content.repo || root.content.project
1112                 if (!ref.isMsgId(repoId))
1113                   return cb(null, serveGenericMessage(req, id, msg, path))
1114                 getRepo(repoId, function (err, repo) {
1115                   if (err) return cb(null, serveError(req, err))
1116                   switch (root.content && root.content.type) {
1117                     case 'issue':
1118                       return issues.get(c.root, function (err, issue) {
1119                         if (err) return cb(null, serveError(req, err))
1120                         return cb(null,
1121                           serveRepoIssue(req, Repo(repo), issue, path, id))
1122                       })
1123                     case 'pull-request':
1124                       pullReqs.get(c.root, function (err, pr) {
1125                         if (err) return cb(null, serveError(req, err))
1126                         return cb(null,
1127                           serveRepoPullReq(req, Repo(repo), pr, path, id))
1128                       })
1129                   }
1130                 })
1131               })
1132             }
1133             // fallthrough
1134           default:
1135             if (ref.isMsgId(c.repo))
1136               return getRepo(c.repo, function (err, repo) {
1137                 if (err) return cb(null, serveRepoNotFound(req, c.repo, err))
1138                 cb(null, serveRepoSomething(req, Repo(repo), id, msg, path))
1139               })
1140             else
1141               return cb(null, serveGenericMessage(req, id, msg, path))
1142         }
1143       })
1144     })
1145   }
1146 
1147   function serveGenericMessage(req, id, msg, path) {
1148     return serveTemplate(req, id)(pull.once(
1149       '<section><h2>' + link([id]) + '</h2>' +
1150       json(msg) +
1151       '</section>'))
1152   }
1153 
1154   /* Repo */
1155 
1156   function serveRepoPage(req, repo, path) {
1157     var defaultBranch = 'master'
1158     var query = req._u.query
1159 
1160     if (query.rev != null) {
1161       // Allow navigating revs using GET query param.
1162       // Replace the branch in the path with the rev query value
1163       path[0] = path[0] || 'tree'
1164       path[1] = query.rev
1165       req._u.pathname = encodeLink([repo.id].concat(path))
1166       delete req._u.query.rev
1167       delete req._u.search
1168       return serveRedirect(req, url.format(req._u))
1169     }
1170 
1171     // get branch
1172     return path[1] ?
1173       serveRepoPage2(req, repo, path) :
1174       readNext(function (cb) {
1175         // TODO: handle this in pull-git-repo or ssb-git-repo
1176         repo.getSymRef('HEAD', true, function (err, ref) {
1177           if (err) return cb(err)
1178           repo.resolveRef(ref, function (err, rev) {
1179             path[1] = rev ? ref : null
1180             cb(null, serveRepoPage2(req, repo, path))
1181           })
1182         })
1183       })
1184   }
1185 
1186   function serveRepoPage2(req, repo, path) {
1187     var branch = path[1]
1188     var filePath = path.slice(2)
1189     switch (path[0]) {
1190       case undefined:
1191       case '':
1192         return serveRepoTree(req, repo, branch, [])
1193       case 'activity':
1194         return serveRepoActivity(req, repo, branch)
1195       case 'commits':
1196         return serveRepoCommits(req, repo, branch)
1197       case 'commit':
1198         return serveRepoCommit(req, repo, path[1])
1199       case 'tree':
1200         return serveRepoTree(req, repo, branch, filePath)
1201       case 'blob':
1202         return serveRepoBlob(req, repo, branch, filePath)
1203       case 'raw':
1204         return serveRepoRaw(req, repo, branch, filePath)
1205       case 'digs':
1206         return serveRepoDigs(req, repo)
1207       case 'fork':
1208         return serveRepoForkPrompt(req, repo)
1209       case 'forks':
1210         return serveRepoForks(req, repo)
1211       case 'issues':
1212         switch (path[1]) {
1213           case 'new':
1214             if (filePath.length == 0)
1215               return serveRepoNewIssue(req, repo)
1216             break
1217           default:
1218             return serveRepoIssues(req, repo, false)
1219         }
1220       case 'pulls':
1221         return serveRepoIssues(req, repo, true)
1222       case 'compare':
1223         return serveRepoCompare(req, repo)
1224       case 'comparing':
1225         return serveRepoComparing(req, repo)
1226       default:
1227         return serve404(req)
1228     }
1229   }
1230 
1231   function serveRepoNotFound(req, id, err) {
1232     return serveTemplate(req, req._t('error.RepoNotFound'), 404)(pull.values([
1233       '<h2>' + req._t('error.RepoNotFound') + '</h2>',
1234       '<p>' + req._t('error.RepoNameNotFound') + '</p>',
1235       '<pre>' + escapeHTML(err.stack) + '</pre>'
1236     ]))
1237   }
1238 
1239   function renderRepoPage(req, repo, page, branch, body) {
1240     var gitUrl = 'ssb://' + repo.id
1241     var gitLink = '<input class="clone-url" readonly="readonly" ' +
1242       'value="' + gitUrl + '" size="45" ' +
1243       'onclick="this.select()"/>'
1244     var digsPath = [repo.id, 'digs']
1245 
1246     var done = multicb({ pluck: 1, spread: true })
1247     getRepoName(about, repo.feed, repo.id, done())
1248     about.getName(repo.feed, done())
1249     getVotes(repo.id, done())
1250 
1251     if (repo.upstream) {
1252       getRepoName(about, repo.upstream.feed, repo.upstream.id, done())
1253       about.getName(repo.upstream.feed, done())
1254     }
1255 
1256     return readNext(function (cb) {
1257       done(function (err, repoName, authorName, votes,
1258           upstreamName, upstreamAuthorName) {
1259         if (err) return cb(null, serveError(req, err))
1260         var upvoted = votes.upvoters[myId] > 0
1261         var upstreamLink = !repo.upstream ? '' :
1262           link([repo.upstream])
1263         cb(null, serveTemplate(req, repo.id)(cat([
1264           pull.once(
1265             '<div class="repo-title">' +
1266             '<form class="right-bar" action="" method="post">' +
1267               '<button class="btn" name="action" value="vote" ' +
1268               (isPublic ? 'disabled="disabled"' : ' type="submit"') + '>' +
1269                 '<i>✌</i> ' + req._t(!isPublic && upvoted ? 'Undig' : 'Dig') +
1270                 '</button>' +
1271               (isPublic ? '' : '<input type="hidden" name="value" value="' +
1272                   (upvoted ? '0' : '1') + '">' +
1273                 '<input type="hidden" name="id" value="' +
1274                   escapeHTML(repo.id) + '">') + ' ' +
1275               '<strong>' + link(digsPath, votes.upvotes) + '</strong> ' +
1276               (isPublic ? '' : '<button class="btn" type="submit" ' +
1277                   ' name="action" value="fork-prompt">' +
1278                 '<i>⑂</i> ' + req._t('Fork') +
1279                 '</button>') + ' ' +
1280               link([repo.id, 'forks'], '+', false, ' title="' +
1281                 req._t('Forks') + '"') +
1282             '</form>' +
1283             renderNameForm(req, !isPublic, repo.id, repoName, 'repo-name',
1284               null, req._t('repo.Rename'),
1285               '<h2 class="bgslash">' + link([repo.feed], authorName) + ' / ' +
1286                 link([repo.id], repoName) + '</h2>') +
1287             '</div>' +
1288             (repo.upstream ? '<small class="bgslash">' + req._t('ForkedFrom', {
1289               repo: link([repo.upstream.feed], upstreamAuthorName) + '/' +
1290                 link([repo.upstream.id], upstreamName)
1291             }) + '</small>' : '') +
1292             nav([
1293               [[repo.id], req._t('Code'), 'code'],
1294               [[repo.id, 'activity'], req._t('Activity'), 'activity'],
1295               [[repo.id, 'commits', branch||''], req._t('Commits'), 'commits'],
1296               [[repo.id, 'issues'], req._t('Issues'), 'issues'],
1297               [[repo.id, 'pulls'], req._t('PullRequests'), 'pulls']
1298             ], page, gitLink)),
1299           body
1300         ])))
1301       })
1302     })
1303   }
1304 
1305   function serveEmptyRepo(req, repo) {
1306     if (repo.feed != myId)
1307       return renderRepoPage(req, repo, 'code', null, pull.once(
1308         '<section>' +
1309         '<h3>' + req._t('EmptyRepo') + '</h3>' +
1310         '</section>'))
1311 
1312     var gitUrl = 'ssb://' + repo.id
1313     return renderRepoPage(req, repo, 'code', null, pull.once(
1314       '<section>' +
1315       '<h3>' + req._t('initRepo.GettingStarted') + '</h3>' +
1316       '<h4>' + req._t('initRepo.CreateNew') + '</h4><pre>' +
1317       'touch ' + req._t('initRepo.README') + '.md\n' +
1318       'git init\n' +
1319       'git add ' + req._t('initRepo.README') + '.md\n' +
1320       'git commit -m "' + req._t('initRepo.InitialCommit') + '"\n' +
1321       'git remote add origin ' + gitUrl + '\n' +
1322       'git push -u origin master</pre>\n' +
1323       '<h4>' + req._t('initRepo.PushExisting') + '</h4>\n' +
1324       '<pre>git remote add origin ' + gitUrl + '\n' +
1325       'git push -u origin master</pre>' +
1326       '</section>'))
1327   }
1328 
1329   function serveRepoTree(req, repo, rev, path) {
1330     if (!rev) return serveEmptyRepo(req, repo)
1331     var type = repo.isCommitHash(rev) ? 'Tree' : 'Branch'
1332     return renderRepoPage(req, repo, 'code', rev, cat([
1333       pull.once('<section><form action="" method="get">' +
1334         '<h3>' + req._t(type) + ': ' + rev + ' '),
1335       revMenu(req, repo, rev),
1336       pull.once('</h3></form>'),
1337       type == 'Branch' && renderRepoLatest(req, repo, rev),
1338       pull.once('</section><section>'),
1339       renderRepoTree(req, repo, rev, path),
1340       pull.once('</section>'),
1341       renderRepoReadme(req, repo, rev, path)
1342     ]))
1343   }
1344 
1345   /* Search */
1346 
1347   function serveSearch(req) {
1348     var q = String(req._u.query.q || '')
1349     if (!q) return serveIndex(req)
1350     var qId = q.replace(/^ssb:\/*/, '')
1351     if (ref.type(qId))
1352       return serveRedirect(req, encodeURI(qId))
1353 
1354     var search = new RegExp(q, 'i')
1355     return serveTemplate(req, req._t('Search') + ' &middot; ' + q, 200)(
1356       renderFeed(req, null, function (opts) {
1357         opts.type == 'about'
1358         return function (read) {
1359           return pull(
1360             many([
1361               getRepoNames(opts),
1362               read
1363             ]),
1364             pull.filter(function (msg) {
1365               var c = msg.value.content
1366               return (
1367                 search.test(msg.key) ||
1368                 c.text && search.test(c.text) ||
1369                 c.name && search.test(c.name) ||
1370                 c.title && search.test(c.title))
1371             })
1372           )
1373         }
1374       })
1375     )
1376   }
1377 
1378   function getRepoNames(opts) {
1379     return pull(
1380       ssb.messagesByType({
1381         type: 'about',
1382         reverse: opts.reverse,
1383         lt: opts.lt,
1384         gt: opts.gt,
1385       }),
1386       pull.filter(function (msg) {
1387         return '%' == String(msg.value.content.about)[0]
1388           && msg.value.content.name
1389       })
1390     )
1391   }
1392 
1393   /* Repo activity */
1394 
1395   function serveRepoActivity(req, repo, branch) {
1396     return renderRepoPage(req, repo, 'activity', branch, cat([
1397       pull.once('<h3>' + req._t('Activity') + '</h3>'),
1398       pull(
1399         ssb.links({
1400           dest: repo.id,
1401           source: repo.feed,
1402           rel: 'repo',
1403           values: true,
1404           reverse: true
1405         }),
1406         pull.map(renderRepoUpdate.bind(this, req, repo))
1407       ),
1408       readOnce(function (cb) {
1409         var done = multicb({ pluck: 1, spread: true })
1410         about.getName(repo.feed, done())
1411         getMsg(repo.id, done())
1412         done(function (err, authorName, msg) {
1413           if (err) return cb(err)
1414           renderFeedItem(req, {
1415             key: repo.id,
1416             value: msg,
1417             authorName: authorName
1418           }, cb)
1419         })
1420       })
1421     ]))
1422   }
1423 
1424   function renderRepoUpdate(req, repo, msg, full) {
1425     var c = msg.value.content
1426 
1427     if (c.type != 'git-update') {
1428       return ''
1429       // return renderFeedItem(msg, cb)
1430       // TODO: render post, issue, pull-request
1431     }
1432 
1433     var refs = c.refs ? Object.keys(c.refs).map(function (ref) {
1434       return {name: ref, value: c.refs[ref]}
1435     }) : []
1436     var numObjects = c.objects ? Object.keys(c.objects).length : 0
1437 
1438     var dateStr = new Date(msg.value.timestamp).toLocaleString(req._locale)
1439     return '<section class="collapse">' +
1440       link([msg.key], dateStr) + '<br>' +
1441       (numObjects ? req._t('PushedObjects', numObjects) + '<br/>': '') +
1442       refs.map(function (update) {
1443         var name = escapeHTML(update.name)
1444         if (!update.value) {
1445           return req._t('DeletedBranch', {branch: name})
1446         } else {
1447           var commitLink = link([repo.id, 'commit', update.value])
1448           return name + ' &rarr; ' + commitLink
1449         }
1450       }).join('<br>') +
1451       '</section>'
1452   }
1453 
1454   /* Repo commits */
1455 
1456   function serveRepoCommits(req, repo, branch) {
1457     var query = req._u.query
1458     return renderRepoPage(req, repo, 'commits', branch, cat([
1459       pull.once('<h3>' + req._t('Commits') + '</h3>'),
1460       pull(
1461         repo.readLog(query.start || branch),
1462         pull.take(20),
1463         paramap(repo.getCommitParsed.bind(repo), 8),
1464         paginate(
1465           !query.start ? '' : function (first, cb) {
1466             cb(null, '&hellip;')
1467           },
1468           pull.map(renderCommit.bind(this, req, repo)),
1469           function (commit, cb) {
1470             cb(null, commit.parents && commit.parents[0] ?
1471               '<a href="?start=' + commit.id + '">' +
1472                 req._t('Older') + '</a>' : '')
1473           }
1474         )
1475       )
1476     ]))
1477   }
1478 
1479   function renderCommit(req, repo, commit) {
1480     var commitPath = [repo.id, 'commit', commit.id]
1481     var treePath = [repo.id, 'tree', commit.id]
1482     return '<section class="collapse">' +
1483       '<strong>' + link(commitPath, commit.title) + '</strong><br>' +
1484       '<tt>' + commit.id + '</tt> ' +
1485         link(treePath, req._t('Tree')) + '<br>' +
1486       escapeHTML(commit.author.name) + ' &middot; ' +
1487       commit.author.date.toLocaleString(req._locale) +
1488       (commit.separateAuthor ? '<br>' + req._t('CommittedOn', {
1489         name: escapeHTML(commit.committer.name),
1490         date: commit.committer.date.toLocaleString(req._locale)
1491       }) : '') +
1492       '</section>'
1493   }
1494 
1495   /* Branch menu */
1496 
1497   function formatRevOptions(currentName) {
1498     return function (name) {
1499       var htmlName = escapeHTML(name)
1500       return '<option value="' + htmlName + '"' +
1501         (name == currentName ? ' selected="selected"' : '') +
1502         '>' + htmlName + '</option>'
1503     }
1504   }
1505 
1506   function formatRevType(req, type) {
1507     return (
1508       type == 'heads' ? req._t('Branches') :
1509       type == 'tags' ? req._t('Tags') :
1510       type)
1511   }
1512 
1513   function revMenu(req, repo, currentName) {
1514     return readOnce(function (cb) {
1515       repo.getRefNames(function (err, refs) {
1516         if (err) return cb(err)
1517         cb(null, '<select name="rev" onchange="this.form.submit()">' +
1518           Object.keys(refs).map(function (group) {
1519             return '<optgroup label="' + formatRevType(req, group) + '">' +
1520               refs[group].map(formatRevOptions(currentName)).join('') +
1521               '</optgroup>'
1522           }).join('') +
1523           '</select><noscript> ' +
1524           '<input type="submit" value="' + req._t('Go') + '"/></noscript>')
1525       })
1526     })
1527   }
1528 
1529   function branchMenu(repo, name, currentName) {
1530     return cat([
1531       pull.once('<select name="' + name + '">'),
1532       pull(
1533         repo.refs(),
1534         pull.map(function (ref) {
1535           var m = ref.name.match(/^refs\/([^\/]*)\/(.*)$/) || [,, ref.name]
1536           return m[1] == 'heads' && m[2]
1537         }),
1538         pull.filter(Boolean),
1539         pullSort(),
1540         pull.map(formatRevOptions(currentName))
1541       ),
1542       pull.once('</select>')
1543     ])
1544   }
1545 
1546   /* Repo tree */
1547 
1548   function renderRepoLatest(req, repo, rev) {
1549     return readOnce(function (cb) {
1550       repo.getCommitParsed(rev, function (err, commit) {
1551         if (err) return cb(err)
1552         var commitPath = [repo.id, 'commit', commit.id]
1553         cb(null,
1554           req._t('Latest') + ': ' +
1555           '<strong>' + link(commitPath, commit.title) + '</strong><br/>' +
1556           '<tt>' + commit.id + '</tt><br/> ' +
1557           req._t('CommittedOn', {
1558             name: escapeHTML(commit.committer.name),
1559             date: commit.committer.date.toLocaleString(req._locale)
1560           }) +
1561           (commit.separateAuthor ? '<br/>' + req._t('AuthoredOn', {
1562             name: escapeHTML(commit.author.name),
1563             date: commit.author.date.toLocaleString(req._locale)
1564           }) : ''))
1565       })
1566     })
1567   }
1568 
1569   // breadcrumbs
1570   function linkPath(basePath, path) {
1571     path = path.slice()
1572     var last = path.pop()
1573     return path.map(function (dir, i) {
1574       return link(basePath.concat(path.slice(0, i+1)), dir)
1575     }).concat(last).join(' / ')
1576   }
1577 
1578   function renderRepoTree(req, repo, rev, path) {
1579     var pathLinks = path.length === 0 ? '' :
1580       ': ' + linkPath([repo.id, 'tree'], [rev].concat(path))
1581     return cat([
1582       pull.once('<h3>' + req._t('Files') + pathLinks + '</h3>'),
1583       pull(
1584         repo.readDir(rev, path),
1585         pull.map(function (file) {
1586           var type = (file.mode === 040000) ? 'tree' :
1587             (file.mode === 0160000) ? 'commit' : 'blob'
1588           if (type == 'commit')
1589             return [
1590               '<span title="' + req._t('gitCommitLink') + '">🖈</span>',
1591               '<span title="' + escapeHTML(file.id) + '">' +
1592                 escapeHTML(file.name) + '</span>']
1593           var filePath = [repo.id, type, rev].concat(path, file.name)
1594           return ['<i>' + (type == 'tree' ? '📁' : '📄') + '</i>',
1595             link(filePath, file.name)]
1596         }),
1597         table('class="files"')
1598       )
1599     ])
1600   }
1601 
1602   /* Repo readme */
1603 
1604   function renderRepoReadme(req, repo, branch, path) {
1605     return readNext(function (cb) {
1606       pull(
1607         repo.readDir(branch, path),
1608         pull.filter(function (file) {
1609           return /readme(\.|$)/i.test(file.name)
1610         }),
1611         pull.take(1),
1612         pull.collect(function (err, files) {
1613           if (err) return cb(null, pull.empty())
1614           var file = files[0]
1615           if (!file)
1616             return cb(null, pull.once(path.length ? '' :
1617               '<p>' + req._t('NoReadme') + '</p>'))
1618           repo.getObjectFromAny(file.id, function (err, obj) {
1619             if (err) return cb(err)
1620             cb(null, cat([
1621               pull.once('<section><h4><a name="readme">' +
1622                 escapeHTML(file.name) + '</a></h4><hr/>'),
1623               renderObjectData(obj, file.name, repo, branch, path),
1624               pull.once('</section>')
1625             ]))
1626           })
1627         })
1628       )
1629     })
1630   }
1631 
1632   /* Repo commit */
1633 
1634   function serveRepoCommit(req, repo, rev) {
1635     return renderRepoPage(req, repo, null, rev, cat([
1636       readNext(function (cb) {
1637         repo.getCommitParsed(rev, function (err, commit) {
1638           if (err) return cb(err)
1639           var commitPath = [repo.id, 'commit', commit.id]
1640           var treePath = [repo.id, 'tree', commit.id]
1641           cb(null, cat([pull.once(
1642             '<h3>' + link(commitPath,
1643               req._t('CommitRev', {rev: rev})) + '</h3>' +
1644             '<section class="collapse">' +
1645             '<div class="right-bar">' +
1646               link(treePath, req._t('BrowseFiles')) +
1647             '</div>' +
1648             '<h4>' + linkify(escapeHTML(commit.title)) + '</h4>' +
1649             (commit.body ? linkify(pre(commit.body)) : '') +
1650             (commit.separateAuthor ? req._t('AuthoredOn', {
1651               name: escapeHTML(commit.author.name),
1652               date: commit.author.date.toLocaleString(req._locale)
1653             }) + '<br/>' : '') +
1654             req._t('CommittedOn', {
1655               name: escapeHTML(commit.committer.name),
1656               date: commit.committer.date.toLocaleString(req._locale)
1657             }) + '<br/>' +
1658             commit.parents.map(function (id) {
1659               return req._t('Parent') + ': ' +
1660                 link([repo.id, 'commit', id], id)
1661             }).join('<br>') +
1662             '</section>' +
1663             '<section><h3>' + req._t('FilesChanged') + '</h3>'),
1664             // TODO: show diff from all parents (merge commits)
1665             renderDiffStat(req, [repo, repo], [commit.parents[0], commit.id]),
1666             pull.once('</section>')
1667           ]))
1668         })
1669       })
1670     ]))
1671   }
1672 
1673   /* Diff stat */
1674 
1675   function renderDiffStat(req, repos, treeIds) {
1676     if (treeIds.length == 0) treeIds = [null]
1677     var id = treeIds[0]
1678     var lastI = treeIds.length - 1
1679     var oldTree = treeIds[0]
1680     var changedFiles = []
1681     return cat([
1682       pull(
1683         Repo.diffTrees(repos, treeIds, true),
1684         pull.map(function (item) {
1685           var filename = escapeHTML(item.filename = item.path.join('/'))
1686           var oldId = item.id && item.id[0]
1687           var newId = item.id && item.id[lastI]
1688           var oldMode = item.mode && item.mode[0]
1689           var newMode = item.mode && item.mode[lastI]
1690           var action =
1691             !oldId && newId ? req._t('action.added') :
1692             oldId && !newId ? req._t('action.deleted') :
1693             oldMode != newMode ? req._t('action.changedMode', {
1694               old: oldMode.toString(8),
1695               new: newMode.toString(8)
1696             }) : req._t('changed')
1697           if (item.id)
1698             changedFiles.push(item)
1699           var blobsPath = item.id[1]
1700             ? [repos[1].id, 'blob', treeIds[1]]
1701             : [repos[0].id, 'blob', treeIds[0]]
1702           var rawsPath = item.id[1]
1703             ? [repos[1].id, 'raw', treeIds[1]]
1704             : [repos[0].id, 'raw', treeIds[0]]
1705           item.blobPath = blobsPath.concat(item.path)
1706           item.rawPath = rawsPath.concat(item.path)
1707           var fileHref = item.id ?
1708             '#' + encodeURIComponent(item.path.join('/')) :
1709             encodeLink(item.blobPath)
1710           return ['<a href="' + fileHref + '">' + filename + '</a>', action]
1711         }),
1712         table()
1713       ),
1714       pull(
1715         pull.values(changedFiles),
1716         paramap(function (item, cb) {
1717           var extension = getExtension(item.filename)
1718           if (extension in imgMimes) {
1719             var filename = escapeHTML(item.filename)
1720             return cb(null,
1721               '<pre><table class="code">' +
1722               '<tr><th id="' + escapeHTML(item.filename) + '">' +
1723                 filename + '</th></tr>' +
1724               '<tr><td><img src="' + encodeLink(item.rawPath) + '"' +
1725               ' alt="' + filename + '"/></td></tr>' +
1726               '</table></pre>')
1727           }
1728           var done = multicb({ pluck: 1, spread: true })
1729           getRepoObjectString(repos[0], item.id[0], done())
1730           getRepoObjectString(repos[1], item.id[lastI], done())
1731           done(function (err, strOld, strNew) {
1732             if (err) return cb(err)
1733             cb(null, htmlLineDiff(req, item.filename, item.filename,
1734               strOld, strNew,
1735               encodeLink(item.blobPath)))
1736           })
1737         }, 4)
1738       )
1739     ])
1740   }
1741 
1742   function htmlLineDiff(req, filename, anchor, oldStr, newStr, blobHref) {
1743     var diff = JsDiff.structuredPatch('', '', oldStr, newStr)
1744     var groups = diff.hunks.map(function (hunk) {
1745       var oldLine = hunk.oldStart
1746       var newLine = hunk.newStart
1747       var header = '<tr class="diff-hunk-header"><td colspan=2></td><td>' +
1748         '@@ -' + oldLine + ',' + hunk.oldLines + ' ' +
1749         '+' + newLine + ',' + hunk.newLines + ' @@' +
1750         '</td></tr>'
1751       return [header].concat(hunk.lines.map(function (line) {
1752         var s = line[0]
1753         if (s == '\\') return
1754         var html = highlight(line, getExtension(filename))
1755         var trClass = s == '+' ? 'diff-new' : s == '-' ? 'diff-old' : ''
1756         var lineNums = [s == '+' ? '' : oldLine++, s == '-' ? '' : newLine++]
1757         var id = [filename].concat(lineNums).join('-')
1758         return '<tr id="' + escapeHTML(id) + '" class="' + trClass + '">' +
1759           lineNums.map(function (num) {
1760             return '<td class="code-linenum">' +
1761               (num ? '<a href="#' + encodeURIComponent(id) + '">' +
1762                 num + '</a>' : '') + '</td>'
1763           }).join('') +
1764           '<td class="code-text">' + html + '</td></tr>'
1765       }))
1766     })
1767     return '<pre><table class="code">' +
1768       '<tr><th colspan=3 id="' + escapeHTML(anchor) + '">' + filename +
1769       '<span class="right-bar">' +
1770         '<a href="' + blobHref + '">' + req._t('View') + '</a> ' +
1771       '</span></th></tr>' +
1772       [].concat.apply([], groups).join('') +
1773       '</table></pre>'
1774   }
1775 
1776   /* An unknown message linking to a repo */
1777 
1778   function serveRepoSomething(req, repo, id, msg, path) {
1779     return renderRepoPage(req, repo, null, null,
1780       pull.once('<section><h3>' + link([id]) + '</h3>' +
1781         json(msg) + '</section>'))
1782   }
1783 
1784   /* Repo update */
1785 
1786   function objsArr(objs) {
1787     return Array.isArray(objs) ? objs :
1788       Object.keys(objs).map(function (sha1) {
1789         var obj = Object.create(objs[sha1])
1790         obj.sha1 = sha1
1791         return obj
1792       })
1793   }
1794 
1795   function serveRepoUpdate(req, repo, id, msg, path) {
1796     var raw = req._u.query.raw != null
1797 
1798     if (raw)
1799       return renderRepoPage(req, repo, 'activity', null, pull.once(
1800         '<a href="?" class="raw-link header-align">' +
1801           req._t('Info') + '</a>' +
1802         '<h3>' + req._t('Update') + '</h3>' +
1803         '<section class="collapse">' +
1804           json({key: id, value: msg}) + '</section>'))
1805 
1806     // convert packs to old single-object style
1807     if (msg.content.indexes) {
1808       for (var i = 0; i < msg.content.indexes.length; i++) {
1809         msg.content.packs[i] = {
1810           pack: {link: msg.content.packs[i].link},
1811           idx: msg.content.indexes[i]
1812         }
1813       }
1814     }
1815 
1816     return renderRepoPage(req, repo, 'activity', null, cat([
1817       pull.values([
1818         '<a href="?raw" class="raw-link header-align">' +
1819           req._t('Data') + '</a>',
1820         '<h3>' + req._t('Update') + '</h3>',
1821         renderRepoUpdate(req, repo, {key: id, value: msg}, true)
1822       ].concat(msg.content.objects ?
1823         ['<h3>' + req._t('Objects') + '</h3>'].concat(
1824           objsArr(msg.content.objects).map(renderObject.bind(null, req)))
1825       : [],
1826       msg.content.packs ? [
1827         '<h3>' + req._t('Packs') + '</h3>'
1828       ].concat(msg.content.packs.map(renderPack.bind(null, req)))
1829       : [])),
1830       msg.content.packs && cat([
1831         pull.once('<h3>' + req._t('Commits') + '</h3>'),
1832         pull(
1833           pull.values(msg.content.packs),
1834           pull.asyncMap(function (pack, cb) {
1835             var done = multicb({ pluck: 1, spread: true })
1836             getBlob(req, pack.pack.link, done())
1837             getBlob(req, pack.idx.link, done())
1838             done(function (err, readPack, readIdx) {
1839               if (err) return cb(renderError(err))
1840               cb(null, gitPack.decodeWithIndex(repo, readPack, readIdx))
1841             })
1842           }),
1843           pull.flatten(),
1844           pull.asyncMap(function (obj, cb) {
1845             if (obj.type == 'commit')
1846               Repo.getCommitParsed(obj, cb)
1847             else
1848               pull(obj.read, pull.drain(null, cb))
1849           }),
1850           pull.filter(),
1851           pull.map(function (commit) {
1852             return renderCommit(req, repo, commit)
1853           })
1854         )
1855       ])
1856     ]))
1857   }
1858 
1859   function renderObject(req, obj) {
1860     return '<section class="collapse">' +
1861       obj.type + ' ' + link([obj.link], obj.sha1) + '<br>' +
1862       req._t('NumBytes', obj.length) +
1863       '</section>'
1864   }
1865 
1866   function renderPack(req, info) {
1867     return '<section class="collapse">' +
1868       (info.pack ? req._t('Pack') + ': ' +
1869         link([info.pack.link]) + '<br>' : '') +
1870       (info.idx ? req._t('Index') + ': ' +
1871         link([info.idx.link]) : '') + '</section>'
1872   }
1873 
1874   /* Blob */
1875 
1876   function serveRepoBlob(req, repo, rev, path) {
1877     return readNext(function (cb) {
1878       repo.getFile(rev, path, function (err, object) {
1879         if (err) return cb(null, serveBlobNotFound(req, repo.id, err))
1880         var type = repo.isCommitHash(rev) ? 'Tree' : 'Branch'
1881         var pathLinks = path.length === 0 ? '' :
1882           ': ' + linkPath([repo.id, 'tree'], [rev].concat(path))
1883         var rawFilePath = [repo.id, 'raw', rev].concat(path)
1884         var dirPath = path.slice(0, path.length-1)
1885         var filename = path[path.length-1]
1886         var extension = getExtension(filename)
1887         cb(null, renderRepoPage(req, repo, 'code', rev, cat([
1888           pull.once('<section><form action="" method="get">' +
1889             '<h3>' + req._t(type) + ': ' + rev + ' '),
1890           revMenu(req, repo, rev),
1891           pull.once('</h3></form>'),
1892           type == 'Branch' && renderRepoLatest(req, repo, rev),
1893           pull.once('</section><section class="collapse">' +
1894             '<h3>' + req._t('Files') + pathLinks + '</h3>' +
1895             '<div>' + object.length + ' bytes' +
1896             '<span class="raw-link">' +
1897               link(rawFilePath, req._t('Raw')) + '</span>' +
1898             '</div></section>' +
1899             '<section>'),
1900           extension in imgMimes
1901           ? pull.once('<img src="' + encodeLink(rawFilePath) +
1902             '" alt="' + escapeHTML(filename) + '" />')
1903           : renderObjectData(object, filename, repo, rev, dirPath),
1904           pull.once('</section>')
1905         ])))
1906       })
1907     })
1908   }
1909 
1910   function serveBlobNotFound(req, repoId, err) {
1911     return serveTemplate(req, req._t('error.BlobNotFound'), 404)(pull.once(
1912       '<h2>' + req._t('error.BlobNotFound') + '</h2>' +
1913       '<p>' + req._t('error.BlobNotFoundInRepo', {
1914         repo: link([repoId])
1915       }) + '</p>' +
1916       '<pre>' + escapeHTML(err.stack) + '</pre>'
1917     ))
1918   }
1919 
1920   /* Raw blob */
1921 
1922   function serveRepoRaw(req, repo, branch, path) {
1923     return readNext(function (cb) {
1924       repo.getFile(branch, path, function (err, object) {
1925         if (err) return cb(null,
1926           serveBuffer(404, req._t('error.BlobNotFound')))
1927         var extension = getExtension(path[path.length-1])
1928         var contentType = imgMimes[extension]
1929         cb(null, pull(object.read, serveRaw(object.length, contentType)))
1930       })
1931     })
1932   }
1933 
1934   function serveRaw(length, contentType) {
1935     var headers = {
1936       'Content-Type': contentType || 'text/plain; charset=utf-8',
1937       'Cache-Control': 'max-age=31536000'
1938     }
1939     if (length != null)
1940       headers['Content-Length'] = length
1941     return function (read) {
1942       return cat([pull.once([200, headers]), read])
1943     }
1944   }
1945 
1946   function getBlob(req, key, cb) {
1947     ssb.blobs.want(key, function (err, got) {
1948       if (err) cb(err)
1949       else if (!got) cb(new Error(req._t('error.MissingBlob', {key: key})))
1950       else cb(null, ssb.blobs.get(key))
1951     })
1952   }
1953 
1954   function serveBlob(req, key) {
1955     return readNext(function (cb) {
1956       getBlob(req, key, function (err, read) {
1957         if (err) cb(null, serveError(req, err))
1958         else if (!read) cb(null, serve404(req))
1959         else cb(null, serveRaw()(read))
1960       })
1961     })
1962   }
1963 
1964   /* Digs */
1965 
1966   function serveRepoDigs(req, repo) {
1967     return readNext(function (cb) {
1968       getVotes(repo.id, function (err, votes) {
1969         cb(null, renderRepoPage(req, repo, null, null, cat([
1970           pull.once('<section><h3>' + req._t('Digs') + '</h3>' +
1971             '<div>' + req._t('Total') + ': ' + votes.upvotes + '</div>'),
1972           pull(
1973             pull.values(Object.keys(votes.upvoters)),
1974             paramap(function (feedId, cb) {
1975               about.getName(feedId, function (err, name) {
1976                 if (err) return cb(err)
1977                 cb(null, link([feedId], name))
1978               })
1979             }, 8),
1980             ul()
1981           ),
1982           pull.once('</section>')
1983         ])))
1984       })
1985     })
1986   }
1987 
1988   /* Forks */
1989 
1990   function getForks(repo, includeSelf) {
1991     return pull(
1992       cat([
1993         includeSelf && readOnce(function (cb) {
1994           getMsg(repo.id, function (err, value) {
1995             cb(err, value && {key: repo.id, value: value})
1996           })
1997         }),
1998         ssb.links({
1999           dest: repo.id,
2000           values: true,
2001           rel: 'upstream'
2002         })
2003       ]),
2004       pull.filter(function (msg) {
2005         return msg.value.content && msg.value.content.type == 'git-repo'
2006       }),
2007       paramap(function (msg, cb) {
2008         getRepoFullName(about, msg.value.author, msg.key,
2009             function (err, repoName, authorName) {
2010           if (err) return cb(err)
2011           cb(null, {
2012             key: msg.key,
2013             value: msg.value,
2014             repoName: repoName,
2015             authorName: authorName
2016           })
2017         })
2018       }, 8)
2019     )
2020   }
2021 
2022   function serveRepoForks(req, repo) {
2023     var hasForks
2024     return renderRepoPage(req, repo, null, null, cat([
2025       pull.once('<h3>' + req._t('Forks') + '</h3>'),
2026       pull(
2027         getForks(repo),
2028         pull.map(function (msg) {
2029           hasForks = true
2030           return '<section class="collapse">' +
2031             link([msg.value.author], msg.authorName) + ' / ' +
2032             link([msg.key], msg.repoName) +
2033             '<span class="right-bar">' +
2034             timestamp(msg.value.timestamp, req) +
2035             '</span></section>'
2036         })
2037       ),
2038       readOnce(function (cb) {
2039         cb(null, hasForks ? '' : req._t('NoForks'))
2040       })
2041     ]))
2042   }
2043 
2044   function serveRepoForkPrompt(req, repo) {
2045     return renderRepoPage(req, repo, null, null, pull.once(
2046       '<form action="" method="post" onreset="history.back()">' +
2047       '<h3>' + req._t('ForkRepoPrompt') + '</h3>' +
2048       '<p>' + hiddenInputs({ id: repo.id }) +
2049       '<button class="btn open" type="submit" name="action" value="fork">' +
2050         req._t('Fork') +
2051       '</button>' +
2052       ' <button class="btn" type="reset">' +
2053         req._t('Cancel') + '</button>' +
2054       '</p></form>'
2055     ))
2056   }
2057 
2058   /* Issues */
2059 
2060   function serveRepoIssues(req, repo, isPRs) {
2061     var count = 0
2062     var state = req._u.query.state || 'open'
2063     var newPath = isPRs ? [repo.id, 'compare'] : [repo.id, 'issues', 'new']
2064     return renderRepoPage(req, repo, isPRs ? 'pulls' : 'issues', null, cat([
2065       pull.once(
2066         (isPublic ? '' :
2067           '<form class="right-bar" method="get"' +
2068             ' action="' + encodeLink(newPath) + '">' +
2069             '<button class="btn">&plus; ' +
2070               req._t(isPRs ? 'pullRequest.New' : 'issue.New') +
2071             '</button>' +
2072           '</form>') +
2073         '<h3>' + req._t(isPRs ? 'PullRequests' : 'Issues') + '</h3>' +
2074         nav([
2075           ['?', req._t('issues.Open'), 'open'],
2076           ['?state=closed', req._t('issues.Closed'), 'closed'],
2077           ['?state=all', req._t('issues.All'), 'all']
2078         ], state)),
2079       pull(
2080         (isPRs ? pullReqs : issues).list({
2081           repo: repo.id,
2082           project: repo.id,
2083           open: {open: true, closed: false}[state]
2084         }),
2085         pull.map(function (issue) {
2086           count++
2087           var state = (issue.open ? 'open' : 'closed')
2088           var stateStr = req._t(issue.open ?
2089             'issue.state.Open' : 'issue.state.Closed')
2090           return '<section class="collapse">' +
2091             '<i class="issue-state issue-state-' + state + '"' +
2092               ' title="' + stateStr + '">◼</i> ' +
2093             '<a href="' + encodeLink(issue.id) + '">' +
2094               escapeHTML(issue.title) +
2095               '<span class="right-bar">' +
2096                 new Date(issue.created_at).toLocaleString(req._locale) +
2097               '</span>' +
2098             '</a>' +
2099             '</section>'
2100         })
2101       ),
2102       readOnce(function (cb) {
2103         cb(null, count > 0 ? '' :
2104           '<p>' + req._t(isPRs ? 'NoPullRequests' : 'NoIssues') + '</p>')
2105       })
2106     ]))
2107   }
2108 
2109   /* New Issue */
2110 
2111   function serveRepoNewIssue(req, repo, issueId, path) {
2112     return renderRepoPage(req, repo, 'issues', null, pull.once(
2113       '<h3>' + req._t('issue.New') + '</h3>' +
2114       '<section><form action="" method="post">' +
2115       '<input type="hidden" name="action" value="new-issue">' +
2116       '<p><input class="wide-input" name="title" placeholder="' +
2117         req._t('issue.Title') + '" size="77" /></p>' +
2118       renderPostForm(req, repo, req._t('Description'), 8) +
2119       '<button type="submit" class="btn">' + req._t('Create') + '</button>' +
2120       '</form></section>'))
2121   }
2122 
2123   /* Issue */
2124 
2125   function serveRepoIssue(req, repo, issue, path, postId) {
2126     var isAuthor = (myId == issue.author) || (myId == repo.feed)
2127     var newestMsg = {key: issue.id, value: {timestamp: issue.created_at}}
2128     return renderRepoPage(req, repo, 'issues', null, cat([
2129       pull.once(
2130         renderNameForm(req, !isPublic, issue.id, issue.title, 'issue-title',
2131           null, req._t('issue.Rename'),
2132           '<h3>' + link([issue.id], issue.title) + '</h3>') +
2133         '<code>' + issue.id + '</code>' +
2134         '<section class="collapse">' +
2135         (issue.open
2136           ? '<strong class="issue-status open">' +
2137             req._t('issue.state.Open') + '</strong>'
2138           : '<strong class="issue-status closed">' +
2139             req._t('issue.state.Closed') + '</strong>')),
2140       readOnce(function (cb) {
2141         about.getName(issue.author, function (err, authorName) {
2142           if (err) return cb(err)
2143           var authorLink = link([issue.author], authorName)
2144           cb(null, req._t('issue.Opened',
2145             {name: authorLink, datetime: timestamp(issue.created_at, req)}))
2146         })
2147       }),
2148       pull.once('<hr/>' + markdown(issue.text, repo) + '</section>'),
2149       // render posts and edits
2150       pull(
2151         ssb.links({
2152           dest: issue.id,
2153           values: true
2154         }),
2155         pull.unique('key'),
2156         addAuthorName(about),
2157         sortMsgs(),
2158         pull.through(function (msg) {
2159           if (msg.value.timestamp > newestMsg.value.timestamp)
2160             newestMsg = msg
2161         }),
2162         pull.map(renderIssueActivityMsg.bind(null, req, repo, issue,
2163           req._t('issue.'), postId))
2164       ),
2165       isPublic ? pull.empty() : readOnce(function (cb) {
2166         cb(null, renderIssueCommentForm(req, issue, repo, newestMsg.key,
2167           isAuthor, req._t('issue.')))
2168       })
2169     ]))
2170   }
2171 
2172   function renderIssueActivityMsg(req, repo, issue, type, postId, msg) {
2173     var authorLink = link([msg.value.author], msg.authorName)
2174     var msgHref = encodeLink(msg.key) + '#' + encodeURIComponent(msg.key)
2175     var msgTimeLink = '<a href="' + msgHref + '"' +
2176       ' name="' + escapeHTML(msg.key) + '">' +
2177       new Date(msg.value.timestamp).toLocaleString(req._locale) + '</a>'
2178     var c = msg.value.content
2179     switch (c.type) {
2180       case 'post':
2181         if (c.root == issue.id) {
2182           var changed = issues.isStatusChanged(msg, issue)
2183           return '<section class="collapse">' +
2184             (msg.key == postId ? '<div class="highlight">' : '') +
2185             '<tt class="right-bar item-id">' + msg.key + '</tt> ' +
2186             (changed == null ? authorLink : req._t(
2187               changed ? 'issue.Reopened' : 'issue.Closed',
2188               {name: authorLink, type: type})) +
2189             ' &middot; ' + msgTimeLink +
2190             (msg.key == postId ? '</div>' : '') +
2191             markdown(c.text, repo) +
2192             '</section>'
2193         } else {
2194           var text = c.text || (c.type + ' ' + msg.key)
2195           return '<section class="collapse mention-preview">' +
2196             req._t('issue.MentionedIn', {
2197               name: authorLink,
2198               type: type,
2199               post: '<a href="/' + msg.key + '#' + msg.key + '">' +
2200                 String(text).substr(0, 140) + '</a>'
2201             }) + '</section>'
2202         }
2203       case 'issue':
2204       case 'pull-request':
2205         return '<section class="collapse mention-preview">' +
2206           req._t('issue.MentionedIn', {
2207             name: authorLink,
2208             type: type,
2209             post: link([msg.key], String(c.title || msg.key).substr(0, 140))
2210           }) + '</section>'
2211       case 'issue-edit':
2212         return '<section class="collapse">' +
2213           (msg.key == postId ? '<div class="highlight">' : '') +
2214           (c.title == null ? '' : req._t('issue.Renamed', {
2215             name: authorLink,
2216             type: type,
2217             name: '<q>' + escapeHTML(c.title) + '</q>'
2218           })) + ' &middot; ' + msgTimeLink +
2219           (msg.key == postId ? '</div>' : '') +
2220           '</section>'
2221       case 'git-update':
2222         var mention = issues.getMention(msg, issue)
2223         if (mention) {
2224           var commitLink = link([repo.id, 'commit', mention.object],
2225             mention.label || mention.object)
2226           return '<section class="collapse">' +
2227             req._t(mention.open ? 'issue.Reopened' : 'issue.Closed', {
2228               name: authorLink,
2229               type: type
2230             }) + ' &middot; ' + msgTimeLink + '<br/>' +
2231             commitLink +
2232             '</section>'
2233         } else if ((mention = getMention(msg, issue.id))) {
2234           var commitLink = link(mention.object ?
2235             [repo.id, 'commit', mention.object] : [msg.key],
2236             mention.label || mention.object || msg.key)
2237           return '<section class="collapse">' +
2238             req._t('issue.Mentioned', {
2239               name: authorLink,
2240               type: type
2241             }) + ' &middot; ' + msgTimeLink + '<br/>' +
2242             commitLink +
2243             '</section>'
2244         } else {
2245           // fallthrough
2246         }
2247 
2248       default:
2249         return '<section class="collapse">' +
2250           authorLink +
2251           ' &middot; ' + msgTimeLink +
2252           json(c) +
2253           '</section>'
2254     }
2255   }
2256 
2257   function renderIssueCommentForm(req, issue, repo, branch, isAuthor, type) {
2258     return '<section><form action="" method="post">' +
2259       '<input type="hidden" name="action" value="comment">' +
2260       '<input type="hidden" name="id" value="' + issue.id + '">' +
2261       '<input type="hidden" name="issue" value="' + issue.id + '">' +
2262       '<input type="hidden" name="repo" value="' + repo.id + '">' +
2263       '<input type="hidden" name="branch" value="' + branch + '">' +
2264       renderPostForm(req, repo) +
2265       '<input type="submit" class="btn open" value="' +
2266         req._t('issue.Comment') + '" />' +
2267       (isAuthor ?
2268         '<input type="submit" class="btn"' +
2269         ' name="' + (issue.open ? 'close' : 'open') + '"' +
2270         ' value="' + req._t(
2271           issue.open ? 'issue.Close' : 'issue.Reopen', {type: type}
2272         ) + '"/>' : '') +
2273       '</form></section>'
2274   }
2275 
2276   /* Pull Request */
2277 
2278   function serveRepoPullReq(req, repo, pr, path, postId) {
2279     var headRepo, authorLink
2280     var page = path[0] || 'activity'
2281     return renderRepoPage(req, repo, 'pulls', null, cat([
2282       pull.once('<div class="pull-request">' +
2283         renderNameForm(req, !isPublic, pr.id, pr.title, 'issue-title', null,
2284           req._t('pullRequest.Rename'),
2285           '<h3>' + link([pr.id], pr.title) + '</h3>') +
2286         '<code>' + pr.id + '</code>'),
2287       readOnce(function (cb) {
2288         var done = multicb({ pluck: 1, spread: true })
2289         var gotHeadRepo = done()
2290         about.getName(pr.author, done())
2291         var sameRepo = (pr.headRepo == pr.baseRepo)
2292         getRepo(pr.headRepo, function (err, headRepo) {
2293           if (err) return cb(err)
2294           getRepoName(about, headRepo.feed, headRepo.id, done())
2295           about.getName(headRepo.feed, done())
2296           gotHeadRepo(null, Repo(headRepo))
2297         })
2298 
2299         done(function (err, _headRepo, issueAuthorName,
2300             headRepoName, headRepoAuthorName) {
2301           if (err) return cb(err)
2302           headRepo = _headRepo
2303           authorLink = link([pr.author], issueAuthorName)
2304           var repoLink = link([pr.headRepo], headRepoName)
2305           var headRepoAuthorLink = link([headRepo.feed], headRepoAuthorName)
2306           var headRepoLink = link([headRepo.id], headRepoName)
2307           var headBranchLink = link([headRepo.id, 'tree', pr.headBranch])
2308           var baseBranchLink = link([repo.id, 'tree', pr.baseBranch])
2309           cb(null, '<section class="collapse">' +
2310             '<strong class="issue-status ' +
2311             (pr.open ? 'open' : 'closed') + '">' +
2312             req._t(pr.open ? 'issue.state.Open' : 'issue.state.Closed') +
2313             '</strong> ' +
2314             req._t('pullRequest.WantToMerge', {
2315               name: authorLink,
2316               base: '<code>' + baseBranchLink + '</code>',
2317               head: (sameRepo ?
2318                 '<code>' + headBranchLink + '</code>' :
2319                 '<code class="bgslash">' +
2320                   headRepoAuthorLink + ' / ' +
2321                   headRepoLink + ' / ' +
2322                   headBranchLink + '</code>')
2323             }) + '</section>')
2324         })
2325       }),
2326       pull.once(
2327         nav([
2328           [[pr.id], req._t('Discussion'), 'activity'],
2329           [[pr.id, 'commits'], req._t('Commits'), 'commits'],
2330           [[pr.id, 'files'], req._t('Files'), 'files']
2331         ], page)),
2332       readNext(function (cb) {
2333         if (page == 'commits') cb(null,
2334           renderPullReqCommits(req, pr, repo, headRepo))
2335         else if (page == 'files') cb(null,
2336           renderPullReqFiles(req, pr, repo, headRepo))
2337         else cb(null,
2338           renderPullReqActivity(req, pr, repo, headRepo, authorLink, postId))
2339       })
2340     ]))
2341   }
2342 
2343   function renderPullReqCommits(req, pr, baseRepo, headRepo) {
2344     return cat([
2345       pull.once('<section>'),
2346       renderCommitLog(req, baseRepo, pr.baseBranch, headRepo, pr.headBranch),
2347       pull.once('</section>')
2348     ])
2349   }
2350 
2351   function renderPullReqFiles(req, pr, baseRepo, headRepo) {
2352     return cat([
2353       pull.once('<section>'),
2354       renderDiffStat(req,
2355         [baseRepo, headRepo], [pr.baseBranch, pr.headBranch]),
2356       pull.once('</section>')
2357     ])
2358   }
2359 
2360   function renderPullReqActivity(req, pr, repo, headRepo, authorLink, postId) {
2361     var msgTimeLink = link([pr.id],
2362       new Date(pr.created_at).toLocaleString(req._locale))
2363     var newestMsg = {key: pr.id, value: {timestamp: pr.created_at}}
2364     var isAuthor = (myId == pr.author) || (myId == repo.feed)
2365     return cat([
2366       readOnce(function (cb) {
2367         cb(null,
2368           '<section class="collapse">' +
2369             authorLink + ' &middot; ' + msgTimeLink +
2370             markdown(pr.text, repo) + '</section>')
2371       }),
2372       // render posts, edits, and updates
2373       pull(
2374         many([
2375           ssb.links({
2376             dest: pr.id,
2377             values: true
2378           }),
2379           readNext(function (cb) {
2380             cb(null, pull(
2381               ssb.links({
2382                 dest: headRepo.id,
2383                 source: headRepo.feed,
2384                 rel: 'repo',
2385                 values: true,
2386                 reverse: true
2387               }),
2388               pull.take(function (link) {
2389                 return link.value.timestamp > pr.created_at
2390               }),
2391               pull.filter(function (link) {
2392                 return link.value.content.type == 'git-update'
2393                   && ('refs/heads/' + pr.headBranch) in link.value.content.refs
2394               })
2395             ))
2396           })
2397         ]),
2398         addAuthorName(about),
2399         pull.unique('key'),
2400         pull.through(function (msg) {
2401           if (msg.value.timestamp > newestMsg.value.timestamp)
2402             newestMsg = msg
2403         }),
2404         sortMsgs(),
2405         pull.map(function (item) {
2406           if (item.value.content.type == 'git-update')
2407             return renderBranchUpdate(req, pr, item)
2408           return renderIssueActivityMsg(req, repo, pr,
2409             req._t('pull request'), postId, item)
2410         })
2411       ),
2412       !isPublic && isAuthor && pr.open && pull.once(
2413         '<section class="merge-instructions">' +
2414         '<input type="checkbox" class="toggle" id="merge-instructions"/>' +
2415         '<h4><label for="merge-instructions" class="toggle-link"><a>' +
2416         req._t('mergeInstructions.MergeViaCmdLine') +
2417         '</a></label></h4>' +
2418         '<div class="contents">' +
2419         '<p>' + req._t('mergeInstructions.CheckOut') + '</p>' +
2420         '<pre>' +
2421         'git fetch ssb://' + escapeHTML(pr.headRepo) + ' ' +
2422           escapeHTML(pr.headBranch) + '\n' +
2423         'git checkout -b ' + escapeHTML(pr.headBranch) + ' FETCH_HEAD' +
2424         '</pre>' +
2425         '<p>' + req._t('mergeInstructions.MergeAndPush') + '</p>' +
2426         '<pre>' +
2427         'git checkout ' + escapeHTML(pr.baseBranch) + '\n' +
2428         'git merge ' + escapeHTML(pr.headBranch) + '\n' +
2429         'git push ssb ' + escapeHTML(pr.baseBranch) +
2430         '</pre>' +
2431         '</div></section>'),
2432       !isPublic && readOnce(function (cb) {
2433         cb(null, renderIssueCommentForm(req, pr, repo, newestMsg.key, isAuthor,
2434           req._t('pull request')))
2435       })
2436     ])
2437   }
2438 
2439   function renderBranchUpdate(req, pr, msg) {
2440     var authorLink = link([msg.value.author], msg.authorName)
2441     var msgLink = link([msg.key],
2442       new Date(msg.value.timestamp).toLocaleString(req._locale))
2443     var rev = msg.value.content.refs['refs/heads/' + pr.headBranch]
2444     if (!rev)
2445       return '<section class="collapse">' +
2446         req._t('NameDeletedBranch', {
2447           name: authorLink,
2448           branch: '<code>' + pr.headBranch + '</code>'
2449         }) + ' &middot; ' + msgLink +
2450         '</section>'
2451 
2452     var revLink = link([pr.headRepo, 'commit', rev], rev.substr(0, 8))
2453     return '<section class="collapse">' +
2454       req._t('NameUpdatedBranch', {
2455         name: authorLink,
2456         rev: '<code>' + revLink + '</code>'
2457       }) + ' &middot; ' + msgLink +
2458       '</section>'
2459   }
2460 
2461   /* Compare changes */
2462 
2463   function serveRepoCompare(req, repo) {
2464     var query = req._u.query
2465     var base
2466     var count = 0
2467 
2468     return renderRepoPage(req, repo, 'pulls', null, cat([
2469       pull.once('<h3>' + req._t('CompareChanges') + '</h3>' +
2470         '<form action="' + encodeLink(repo.id) + '/comparing" method="get">' +
2471         '<section>'),
2472       pull.once(req._t('BaseBranch') + ': '),
2473       readNext(function (cb) {
2474         if (query.base) gotBase(null, query.base)
2475         else repo.getSymRef('HEAD', true, gotBase)
2476         function gotBase(err, ref) {
2477           if (err) return cb(err)
2478           cb(null, branchMenu(repo, 'base', base = ref || 'HEAD'))
2479         }
2480       }),
2481       pull.once('<br/>' + req._t('ComparisonRepoBranch') + ':'),
2482       pull(
2483         getForks(repo, true),
2484         pull.asyncMap(function (msg, cb) {
2485           getRepo(msg.key, function (err, repo) {
2486             if (err) return cb(err)
2487             cb(null, {
2488               msg: msg,
2489               repo: repo
2490             })
2491           })
2492         }),
2493         pull.map(renderFork),
2494         pull.flatten()
2495       ),
2496       pull.once('</section>'),
2497       readOnce(function (cb) {
2498         cb(null, count == 0 ? req._t('NoBranches') :
2499           '<button type="submit" class="btn">' +
2500           req._t('Compare') + '</button>')
2501       }),
2502       pull.once('</form>')
2503     ]))
2504 
2505     function renderFork(fork) {
2506       return pull(
2507         fork.repo.refs(),
2508         pull.map(function (ref) {
2509           var m = /^refs\/([^\/]*)\/(.*)$/.exec(ref.name) || [,ref.name]
2510           return {
2511             type: m[1],
2512             name: m[2],
2513             value: ref.value
2514           }
2515         }),
2516         pull.filter(function (ref) {
2517           return ref.type == 'heads'
2518             && !(ref.name == base && fork.msg.key == repo.id)
2519         }),
2520         pull.map(function (ref) {
2521           var branchLink = link([fork.msg.key, 'tree', ref.name], ref.name)
2522           var authorLink = link([fork.msg.value.author], fork.msg.authorName)
2523           var repoLink = link([fork.msg.key], fork.msg.repoName)
2524           var value = fork.msg.key + ':' + ref.name
2525           count++
2526           return '<div class="bgslash">' +
2527             '<input type="radio" name="head"' +
2528             ' value="' + escapeHTML(value) + '"' +
2529             (query.head == value ? ' checked="checked"' : '') + '> ' +
2530             authorLink + ' / ' + repoLink + ' / ' + branchLink + '</div>'
2531         })
2532       )
2533     }
2534   }
2535 
2536   function serveRepoComparing(req, repo) {
2537     var query = req._u.query
2538     var baseBranch = query.base
2539     var s = (query.head || '').split(':')
2540 
2541     if (!s || !baseBranch)
2542       return serveRedirect(req, encodeLink([repo.id, 'compare']))
2543 
2544     var headRepoId = s[0]
2545     var headBranch = s[1]
2546     var baseLink = link([repo.id, 'tree', baseBranch])
2547     var headBranchLink = link([headRepoId, 'tree', headBranch])
2548     var backHref = encodeLink([repo.id, 'compare']) + req._u.search
2549 
2550     return renderRepoPage(req, repo, 'pulls', null, cat([
2551       pull.once('<h3>' +
2552       req._t(query.expand ? 'OpenPullRequest': 'ComparingChanges') +
2553       '</h3>'),
2554       readNext(function (cb) {
2555         getRepo(headRepoId, function (err, headRepo) {
2556           if (err) return cb(err)
2557           getRepoFullName(about, headRepo.feed, headRepo.id,
2558             function (err, repoName, authorName) {
2559               if (err) return cb(err)
2560               cb(null, renderRepoInfo(Repo(headRepo), repoName, authorName))
2561             }
2562           )
2563         })
2564       })
2565     ]))
2566 
2567     function renderRepoInfo(headRepo, headRepoName, headRepoAuthorName) {
2568       var authorLink = link([headRepo.feed], headRepoAuthorName)
2569       var repoLink = link([headRepoId], headRepoName)
2570       return cat([
2571         pull.once('<section>' +
2572           req._t('Base') + ': ' + baseLink + '<br/>' +
2573           req._t('Head') + ': ' +
2574           '<span class="bgslash">' + authorLink + ' / ' + repoLink +
2575           ' / ' + headBranchLink + '</span>' +
2576           '</section>' +
2577           (query.expand ? '<section><form method="post" action="">' +
2578             hiddenInputs({
2579               action: 'new-pull',
2580               branch: baseBranch,
2581               head_repo: headRepoId,
2582               head_branch: headBranch
2583             }) +
2584             '<input class="wide-input" name="title"' +
2585             ' placeholder="' + req._t('Title') + '" size="77"/>' +
2586             renderPostForm(req, repo, req._t('Description'), 8) +
2587             '<button type="submit" class="btn open">' +
2588               req._t('Create') + '</button>' +
2589             '</form></section>'
2590           : '<section><form method="get" action="">' +
2591             hiddenInputs({
2592               base: baseBranch,
2593               head: query.head
2594             }) +
2595             '<button class="btn open" type="submit" name="expand" value="1">' +
2596               '<i>⎇</i> ' + req._t('CreatePullRequest') + '</button> ' +
2597             '<a href="' + backHref + '">' + req._t('Back') + '</a>' +
2598             '</form></section>') +
2599           '<div id="commits"></div>' +
2600           '<div class="tab-links">' +
2601             '<a href="#" id="files-link">' + req._t('FilesChanged') + '</a> ' +
2602             '<a href="#commits" id="commits-link">' +
2603               req._t('Commits') + '</a>' +
2604           '</div>' +
2605           '<section id="files-tab">'),
2606         renderDiffStat(req, [repo, headRepo], [baseBranch, headBranch]),
2607         pull.once('</section>' +
2608           '<section id="commits-tab">'),
2609         renderCommitLog(req, repo, baseBranch, headRepo, headBranch),
2610         pull.once('</section>')
2611       ])
2612     }
2613   }
2614 
2615   function renderCommitLog(req, baseRepo, baseBranch, headRepo, headBranch) {
2616     return cat([
2617       pull.once('<table class="compare-commits">'),
2618       readNext(function (cb) {
2619         baseRepo.resolveRef(baseBranch, function (err, baseBranchRev) {
2620           if (err) return cb(err)
2621           var currentDay
2622           return cb(null, pull(
2623             headRepo.readLog(headBranch),
2624             pull.take(function (rev) { return rev != baseBranchRev }),
2625             pullReverse(),
2626             paramap(headRepo.getCommitParsed.bind(headRepo), 8),
2627             pull.map(function (commit) {
2628               var commitPath = [headRepo.id, 'commit', commit.id]
2629               var commitIdShort = '<tt>' + commit.id.substr(0, 8) + '</tt>'
2630               var day = Math.floor(commit.author.date / 86400000)
2631               var dateRow = day == currentDay ? '' :
2632                 '<tr><th colspan=3 class="date-info">' +
2633                 commit.author.date.toLocaleDateString(req._locale) +
2634                 '</th><tr>'
2635               currentDay = day
2636               return dateRow + '<tr>' +
2637                 '<td>' + escapeHTML(commit.author.name) + '</td>' +
2638                 '<td>' + link(commitPath, commit.title) + '</td>' +
2639                 '<td>' + link(commitPath, commitIdShort, true) + '</td>' +
2640                 '</tr>'
2641             })
2642           ))
2643         })
2644       }),
2645       pull.once('</table>')
2646     ])
2647   }
2648 }
2649
Built with git-ssb-web
cel / git-ssb-web

Tree: 6d3a8a6342ec134487fe48ba802ee255960dabf0

Files: 6d3a8a6342ec134487fe48ba802ee255960dabf0 / index.js
