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() + '') } if (msg.value.content.type === 'git-update') { var message = ('I pushed a git commit to gitmx.com - ' + 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')