app.js

var mongoose = require('mongoose')
  , express  = require('express')
  , app      = express()
  , server   = require('http').createServer(app)
  , io       = require('socket.io').listen(server, { origins: '*:*', log: !!process.env.SOCKET_IO_LOG })
  , debug    = require('debug')('lelylan');


// *************
// Express app

app.configure(function() {
  app.use(express.static(__dirname + '/app/assets/javascripts'))
  app.use(express.static(__dirname + '/app/assets'))
});

// index test page
app.get('/', function(req, res) {
  res.sendfile(__dirname + '/index.html')
});

// websocket fire test page
app.put('/test', function(request, response) {
  io.sockets.in('token-1').emit('update', { data: require('./test/fixtures/device.json') });
  response.json({});
});


// ***************
// Websockets app

io.set('origins', '*:*' );

io.sockets.on('connection', function(socket) {
  socket.on('subscribe', function(room) {
    debug('Subscribing room', room);
    socket.join(room); // a room is equivalent to an access token
  });

  socket.emit('connected');
});

server.listen(process.env.PORT, function() {
  debug('Websocket worker up and running on port', process.env.PORT);

  // if run as root, downgrade to the owner of this file
  if (process.getuid() === 0)
    require('fs').stat(__filename, function(err, stats) {
      if (err) return console.log(err)
      process.setuid(stats.uid);
    });
});

server.listen(process.env.PORT);


// ***************
// Realtime loop

var _loop = require('./lib/loop');
_loop.execute(io);


// ***************
// App interface

module.export = { io: io, app: app };