server.js

var http = require('http'),
    url = require('url'),
    fs = require('fs'),
    qs = require('querystring'), 
    sio = require('socket.io');

var Router = require('./lib/router.js');
var router = new Router();

router.set('/', function(req, res, params, next) {
  fs.readFile('./public/index.html', function(err, data) {
    res.end(data);
  });
});
router.file('/favicon.ico', './public/favicon.ico');

router.directory(/\/(.*)/, './public/');

var server = http.createServer(function(req, res) {router.route(req, res);} );
server.listen(8080, 'localhost');
console.log('Server listening at port 8080');
var io = sio.listen(server);
io.set('log level', 0);

console.log('Server listening');

var Game = require('./lib/game.js').Game;
var Player = require('./lib/game.js').Player;
var games = [];
var players = [];

io.sockets.on('connection', function (socket) {
  console.log('Connection');
  
  // when connecting to the server
  socket.on('nick', function(nickname) {
    console.log('Receive nick ', nickname);
    var player = new Player(nickname, players.length);
    players.push(player);
    // send the player state
    console.log('send state for PLAYER', player);
    socket.emit('player', player);        
    // send the list of games 
    socket.emit('game_list', games);    
  });
  // when a new game is created
  socket.on('create', function(msg) {
    console.log('create new game', msg, games);
    games.push(new Game(msg.title, games.length));
    var game_id = games.length;
    socket.join('/game/'+game_id);
    console.log('broadcast games', games);
    socket.broadcast.emit('game_list', games);
    socket.emit('game_list', games);
    socket.emit('created', game_id);
  });
  
  // when a player joins a game
  socket.on('join', function(msg) {
    console.log('Join '+msg.game, players[msg.id]);
    socket.join('/game/'+msg.game);
    socket.broadcast.to('/game/'+msg.game).emit('new_player', players[msg.id]);  
    // add the player to the game
    games[msg.game].add(players[msg.id]);
    // sync players
    for(var i = 0; i < games[msg.game].players.length; i++) {
      socket.emit('new_player', games[msg.game].players[i]);       
    }
  });
  
  // when a game is configured 
  socket.on('configure', function(msg) {
    games[msg.game].move(msg.player, msg.order);
  });
  
  // when the game is started
  socket.on('start', function(msg) {    
    console.log('Game started', msg);
    var out = { 
      starting_player_id: games[msg.game].players[0].id, 
      players: games[msg.game].players
    };
    socket.broadcast.to('/game/'+msg.game).emit('game_start', out);
    socket.emit('game_start', out); 
  });
  
  // when the ball leaves the screen
  socket.on('screen', function(msg) {
    // tranlate player to the correct player
    if(msg.direction == 'left') {
      msg.id = games[msg.game].leftOf(msg.id);   
    } else {
      msg.id = games[msg.game].rightOf(msg.id);   
    }    
    console.log('Emitting screen', msg);
    socket.broadcast.emit('screen', msg);
    socket.emit('screen', msg);
  });
  
  // when the ball bounces
  socket.on('bounce', function(msg) {
    console.log('Emitting bounce', msg);
    socket.broadcast.emit('bounce', msg);
    socket.emit('bounce', msg); 
  });
  
  // when the ball drops
  socket.on('drop', function(msg) {
    console.log('Emitting drop', msg);
    socket.broadcast.emit('drop', msg);
    socket.emit('drop', msg); 
  });
  
  // respond to score change
  socket.on('score', function(msg) {
    var player = players[msg.id];
    player.score--;
    console.log('Emitting score', msg, player);
    socket.broadcast.to('/game/'+msg.game).emit('score', {id: player.id, score: player.score});
    socket.emit('score', {id: player.id, score: msg.score}); 
  });
  
  socket.on('disconnect', function() {
    console.log('Disconnected');
  });
});