Nemcio/NodeBB
1
0
Fork 0
mirror of https://github.com/NodeBB/NodeBB.git synced 2025-10-31 11:05:54 +01:00
Code Issues Packages Projects Releases Wiki Activity

closed #652

Browse Source
This commit is contained in:
Julian Lam
2013-12-11 16:10:08 -05:00
parent 69c1ec97c9
commit 64e87b761f
3 changed files with 17 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
public/src/app.js
View File

@@ -77,6 +77,8 @@ var socket,
} }
app.enterRoom(room, true); app.enterRoom(room, true);
socket.emit('reconnected');
setTimeout(function() { setTimeout(function() {
reconnectEl.removeClass('active'); reconnectEl.removeClass('active');
}, 3000); }, 3000);

1
src/user.js
View File

@@ -867,7 +867,6 @@ var bcrypt = require('bcrypt'),
User.pushNotifCount = function(uid) { User.pushNotifCount = function(uid) {
User.notifications.getUnreadCount(uid, function(err, count) { User.notifications.getUnreadCount(uid, function(err, count) {
console.log('unread count is', count);
if (!err) { if (!err) {
websockets.in('uid_' + uid).emit('event:notifications.updateCount', count); websockets.in('uid_' + uid).emit('event:notifications.updateCount', count);
} else { } else {

15
src/websockets.js
View File

@@ -135,6 +135,21 @@ websockets.init = function(io) {
} }
}); });
socket.on('reconnected', function() {
if (uid) {
topics.pushUnreadCount(uid);
user.pushNotifCount(uid);
}
if (process.env.NODE_ENV === 'development') {
if (uid) {
winston.info('[socket] uid ' + uid + ' (' + sessionID + ') has successfully reconnected.');
} else {
winston.info('[socket] An anonymous user (' + sessionID + ') has successfully reconnected.');
}
}
});
socket.on('api:get_all_rooms', function(data) { socket.on('api:get_all_rooms', function(data) {
socket.emit('api:get_all_rooms', io.sockets.manager.rooms); socket.emit('api:get_all_rooms', io.sockets.manager.rooms);
}); });