var app = require('koa')(),
router = require('koa-router')(),
views = require('co-views'),
serve = require('koa-static');
var client = require('ssb-client');
var pull = require('pull-stream');
var moment = require('moment');
var fs = require('fs');
function getSbot () { client(function (err, sbot) {
if (err) {
throw err;
}
pull(sbot.createUserStream({
id: '@8Qee0I/DwI5DHSCi3p5fsl6FyLGArrnDz3ox9qZr5Qc=.ed25519',
limit: 1,
reverse: true
}),
pull.drain(function printMessage(msg) {
console.log(msg)
if (msg.value.content.type === 'post') {
var message = (msg.value.content.text + ' - ' + moment(msg.value.timestamp).fromNow() + '')
}
if (msg.value.content.type === 'vote') {
var message = ('I dug ' + msg.value.content.vote.link + ' - ' + moment(msg.value.timestamp).fromNow() + '')
}
if (msg.value.content.type === 'about') {
var message = ('I identified ' + msg.value.content.about + ' as ' + msg.value.content.name + ' - ' + moment(msg.value.timestamp).fromNow() + '')
}
else {
var message = ('I sent a private message - ' + moment(msg.value.timestamp).fromNow() + '')
}
fs.writeFileSync('message.md', message);
console.log(message);
}));
});
};
app.use(router.routes())
app.use(router.allowedMethods())
var render = views(__dirname + '/views', { ext: 'jade'});
router.get('/', function *(next) {
getSbot();
this.body = yield render('index', {title: 'sdash'});
});
app.listen('4000')