chat multi-salas funcionando

Author: ramalho

chat/multi/lib/chat_server.js

@@ -0,0 +1,115 @@
+var socketio = require('socket.io')
+  , guestNumber = 1
+  , nickNames = {}
+  , namesUsed = []
+  , currentRoom = {};
+
+exports.listen = function(server) {
+  io = socketio.listen(server);
+  io.set('log level', 1);
+
+  io.sockets.on('connection', function (socket) {
+    guestNumber = assignGuestName(socket, guestNumber, nickNames, namesUsed);
+    joinRoom(socket, 'Lobby');
+
+    handleMessageBroadcasting(socket, nickNames);
+    handleNameChangeAttempts(socket, nickNames, namesUsed);
+    handleRoomJoining(socket);
+
+    socket.on('rooms', function() {
+      socket.emit('rooms', io.sockets.manager.rooms);
+    });
+
+    handleClientDisconnection(socket, nickNames, namesUsed);
+  });
+};
+
+function assignGuestName(socket, guestNumber, nickNames, namesUsed) {
+  var name = 'Guest' + guestNumber;
+  nickNames[socket.id] = name;
+  socket.emit('nameResult', {
+    success: true,
+    name: name
+  });
+  namesUsed.push(name);
+  return guestNumber + 1;
+}
+
+function joinRoom(socket, room) {
+  socket.join(room);
+  currentRoom[socket.id] = room;
+  socket.emit('joinResult', {room: room});
+  socket.broadcast.to(room).emit('message', {
+    text: nickNames[socket.id] + ' has joined ' + room + '.'
+  });
+
+  var usersInRoom = io.sockets.clients(room);
+  if (usersInRoom.length > 1) {
+    var usersInRoomSummary = 'Users currently in ' + room + ': ';
+    for (var index in usersInRoom) {
+      var userSocketId = usersInRoom[index].id;
+      if (userSocketId != socket.id) {
+        if (index > 0) {
+          usersInRoomSummary += ', ';
+        }
+        usersInRoomSummary += nickNames[userSocketId];
+      }
+    }
+    usersInRoomSummary += '.';
+    socket.emit('message', {text: usersInRoomSummary});
+  }
+}
+
+function handleMessageBroadcasting(socket, nickNames) {
+  socket.on('message', function (message) {
+    socket.broadcast.to(message.room).emit('message', {
+      text: nickNames[socket.id] + ': ' + message.text
+    });
+  });
+}
+
+function handleNameChangeAttempts(socket, nickNames, namesUsed) {
+  socket.on('nameAttempt', function(name) {
+    if (name.indexOf('Guest') == 0) {
+      socket.emit('nameResult', {
+        success: false,
+        message: 'Names cannot begin with "Guest".'
+      });
+    } else {
+      if (namesUsed.indexOf(name) == -1) {
+        var previousName = nickNames[socket.id];
+        var previousNameIndex = namesUsed.indexOf(previousName);
+        namesUsed.push(name);
+        nickNames[socket.id] = name;
+        delete namesUsed[previousNameIndex];
+        socket.emit('nameResult', {
+          success: true,
+          name: name
+        });
+        socket.broadcast.to(currentRoom[socket.id]).emit('message', {
+          text: previousName + ' is now known as ' + name + '.'
+        });
+      } else {
+        socket.emit('nameResult', {
+          success: false,
+          message: 'That name is already in use.'
+        });
+      }
+    }
+  });
+}
+
+function handleRoomJoining(socket) {
+  socket.on('join', function(room) {
+    socket.leave(currentRoom[socket.id]);
+    joinRoom(socket, room.newRoom);
+  });
+}
+
+function handleClientDisconnection(socket, nickNames, namesUsed) {
+  socket.on('disconnect', function() {
+    var nameIndex = namesUsed.indexOf(nickNames[socket.id]);
+    delete namesUsed[nameIndex];
+    delete nickNames[socket.id];
+  });
+}

chat/multi/public/favicon.ico

@@ -55,8 +55,8 @@ server.listen(3000, function() {
   console.log("Server listening on port 3000.");
 });
 
-//var chatServer = require('./lib/chat_server');
-//chatServer.listen(server);
+var chatServer = require('./lib/chat_server');
+chatServer.listen(server);