app.js

var koa = require('koa'),
    co = require('co'),
    fs = require('co-fs'),
    app = module.exports = koa(),
    url = require('url'),
    router = require('koa-route'),
    views = require('co-views'),
    ga = require('./lib/generateAvatar'),
    ft = require('./lib/fontStyle');

// custom 401 handling

require('fs').readFile('now.txt',function(err,data){
  global.reatime = {amount: parseInt(data.toString())};
});


app.use(function* (next){
  try {
    yield* next;
  } catch (err) {
    console.log(err.status)
    if (401 == err.status) {
      this.status = 401;
      this.body = 'cant haz that';
    } else {
      throw err;
    }
  }
});

// secret response


var server = require('http').createServer(app.callback());
var io = require('socket.io')(server);
io.on('connection', function(socket){ 
  io.emit('notify', { item: global.reatime});
  socket.on('disconnect', function(){});
});



var render= views(__dirname + '/views', { map: { html: 'swig' }});



function* avatar(name){ 
  var parseUrl = url.parse(decodeURI(this.request.url),true);
  var filename = yield ga(name.toString(),parseUrl.query.size,parseUrl.query.font);
  global.reatime.amount += 1;
  io.emit('notify', { item: global.reatime});
  this.type = 'image/png';
  this.body = yield fs.readFile(filename);
}


function* index(){
  this.body = yield render('index.jade', {fonts: ft.fonts, nowcount: global.reatime.amount});
}

app.use(router.get('/', index));
app.use(router.get('/avatar', avatar));
app.use(router.get('/avatar/:name', avatar));


setInterval(function(){
  fs.writeFile('now.txt',global.reatime.amount)
},60000)



server.listen(8080);

//if (!module.parent) app.listen(8080);