git ssb

1
var client = require('ssb-client');
2
var pull = require('pull-stream');
3
var moment = require('moment');
4
var app = require('koa')();
5
var router = require('koa-router')();
6
var views = require('co-views');
7
8
var port = 4000;
9
var me = '@8Qee0I/DwI5DHSCi3p5fsl6FyLGArrnDz3ox9qZr5Qc=.ed25519'
10
var message = 'I said nothing';
11
var date = 'Today!';
12
13
app.use(router.routes())
14
app.use(router.allowedMethods())
15
16
var render = views(__dirname, { ext: 'jade'});
17
18
router.get('/', function *(next) {
19
  client(function (err, sbot) {
20
    if (err) {
21
      throw err;
22
    }
23
    pull(sbot.createUserStream({
24
      id: me,
25
      limit: 1,
26
      reverse: true
27
    }),
28
    pull.drain(function printMessage(msg) {
29
      date = moment(msg.value.timestamp).fromNow()
30
      if (msg.value.content.type === 'post') {
31
        message = (msg.value.content.text)
32
      }
33
      else if (msg.value.content.type === 'vote') {
34
        message = (' dug ' + msg.value.content.vote.link)
35
      }
36
      else if (msg.value.content.type === 'about') {
37
        message = (' identified ' + msg.value.content.about + ' as ' + msg.value.content.name)
38
      }
39
      else if (msg.value.content.type === 'git-update') {
40
        message = (' pushed a git commit ')
41
      }
42
      else {
43
        message = (' sent a private message ')
44
      }
45
      gotMessage();
46
    }));
47
  });
48
  function gotMessage() {
49
  }
50
  this.body = yield render('index', {title: 'sdash', message, date});
51
});
52
app.listen(port);
53
54