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
                else {
32
		  var message = ('I sent a private message - <span class="date">' +  moment(msg.value.timestamp).fromNow() + '</span>')
33
                }
34
                fs.writeFileSync('message.md', message);
35
                console.log(message);
36
        }));
37
});
38
};
39
40
41
app.use(router.routes())
42
app.use(router.allowedMethods())
43
44
var render = views(__dirname + '/views', { ext: 'jade'});
45
46
router.get('/', function *(next) {
47
  getSbot();  
48
  this.body = yield render('index', {title: 'sdash'});
49
});
50
51
app.listen('4000')
52
53