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
15
var render = views(__dirname, { ext: 'jade'});
16
17
router.get('/', function *(next) {
18
  client(function (err, sbot) {
19
    if (err) {
20
      throw err;
21
    }
22
    pull(sbot.createUserStream({
23
      id: me,
24
      limit: 1,
25
      reverse: true
26
    }),
27
    pull.drain(function (msg) {
28
      date = moment(msg.value.timestamp).fromNow()
29
      if (msg.value.content.type === 'post') {
30
        message = (msg.value.content.text)
31
      }
32
      else if (msg.value.content.type === 'vote') {
33
        message = (' dug ' + msg.value.content.vote.link)
34
      }
35
      else if (msg.value.content.type === 'about') {
36
        message = (' identified ' + msg.value.content.about + ' as ' + msg.value.content.name)
37
      }
38
      else if (msg.value.content.type === 'git-update') {
39
        message = (' pushed a git commit ')
40
      }
41
      else {
42
        message = (' sent a private message ')
43
      }
44
      gotMessage();
45
    }));
46
  });
47
  function gotMessage() {
48
  }
49
  this.body = yield render('index', {title: 'sdash', message, date});
50
});
51
app.listen(port);
52
53