cryptalk/server.js

var express = require('express.io'),
    uuid = require('node-uuid');

app = express();app.http().io();

app.use(express.static(__dirname + '/public'));

app.io.route('room', {
    generate: function(req) {
      var room = uuid.v4();
      req.socket.emit('message:server', 'Room ' + room + ' generated');
      req.socket.emit('room:generated',room);
    },
    join: function(req) {
      if( req.data ) {
        req.socket.emit('room:joined',req.data);
        req.socket.join(req.data);
        req.socket.broadcast.to(req.data).emit('message:server', {msg:'person_joined'} );
        req.socket.current_room = req.data;
      } else {
        req.socket.emit('message:server', {msg:'command_failed'} );
      }
    },
    leave: function(req) {
      if( req.data ) {
        req.socket.emit('room:left');
        req.socket.leave(req.data);
        req.socket.broadcast.to(req.data).emit('message:server', {msg:'person_left'} );
        req.socket.current_room = undefined;
      } else {
        req.socket.emit('message:server', {msg:'command_failed'} );
      }
    },
    count: function(req) {
      if( req.socket.current_room !== undefined ) {
        // This will fail on socket.io >= 1.0
        var client_count = app.io.sockets.clients(req.socket.current_room).length;
        req.socket.emit('message:server', {msg:'person_count', payload: client_count } );
      } else {
        req.socket.emit('message:server', {msg:'command_failed'} );
      }
    }
});

app.io.route('message', {
    send: function(req) {
      if(req.data && req.data.room) req.socket.broadcast.to(req.data.room).emit('message:send', { msg: req.data.msg, nick: req.data.nick} );
      req.socket.emit('message:send', { msg: req.data.msg, nick: req.data.nick} );
    }
});

app.io.sockets.on('connection', function(socket) {
   socket.on('disconnect', function() {
      // Notify other users of the room
      if( socket.current_room !== undefined ) {
        socket.broadcast.to(socket.current_room).emit('message:server', {msg:'person_left'} );
      }
   });
});

app.listen(8080, function(){
  console.log('listening on *:8080');
});