git ssb

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