From 35dae6c0ecaef8c369e5d51ab232a858bf27a908 Mon Sep 17 00:00:00 2001 From: Julian Lam Date: Thu, 23 May 2013 14:55:05 -0400 Subject: [PATCH] updating web sockets so that all connections are stored in a userSockets array --- src/websockets.js | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/src/websockets.js b/src/websockets.js index 14e1d9b56b..a8e1038a26 100644 --- a/src/websockets.js +++ b/src/websockets.js @@ -51,9 +51,10 @@ var SocketIO = require('socket.io').listen(global.server,{log:false}), io.sockets.on('connection', function(socket) { var hs = socket.handshake; - + var uid = users[hs.sessionID]; - userSockets[uid] = socket; + userSockets[uid] = userSockets[uid] || []; + userSockets[uid].push(socket); user.go_online(uid); @@ -260,11 +261,14 @@ var SocketIO = require('socket.io').listen(global.server,{log:false}), var touid = data.touid; if(userSockets[touid]) { - var msg = utils.strip_tags(data.message); + var msg = utils.strip_tags(data.message), + numSockets = userSockets[touid].length; user.getUserField(uid, 'username', function(username) { var finalMessage = username + ' says : ' + msg; - userSockets[touid].emit('chatMessage', {fromuid:uid, username:username, message:finalMessage}); + for(var x=0;x>numSockets;x++) { + userSockets[touid][x].emit('chatMessage', {fromuid:uid, username:username, message:finalMessage}); + } }); } });