KevinMidboe/zoff
1
0
Fork 0
mirror of https://github.com/KevinMidboe/zoff.git synced 2025-10-29 18:00:23 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fixed local issue with infinite users

Browse Source
This commit is contained in:
Kasper Rynning-Tønnesen
2017-10-09 08:42:07 +02:00
parent 2339327a6e
commit f88d53b132
1 changed files with 8 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

13
server/handlers/io.js
View File

@@ -98,16 +98,19 @@ module.exports = function() {
}, function(err, updated) { }, function(err, updated) {
if(updated.nModified > 0) { if(updated.nModified > 0) {
io.to(coll).emit("viewers", updated.users); io.to(coll).emit("viewers", updated.users);
db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: -1}}, function(err, docs){}); db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: -1}}, function(err, docs){
db.collection("connected_users").update({"_id": "offline_users"}, {$addToSet: {users: guid}}, function(err, docs) {
if(docs.nModified == 1) {
db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: 1}}, function(err, docs) {});
}
});
});
} }
Functions.remove_name_from_db(guid, name); Functions.remove_name_from_db(guid, name);
}); });
} }
Functions.remove_unique_id(short_id); Functions.remove_unique_id(short_id);
db.collection("connected_users").update({"_id": "offline_users"}, {$addToSet: {users: guid}}, function(err, docs) {});
db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: 1}}, function(err, docs) {});
} else { } else {
offline = false; offline = false;
db.collection("connected_users").update({"_id": "offline_users"}, {$pull: {users: guid}}, function(err, docs) { db.collection("connected_users").update({"_id": "offline_users"}, {$pull: {users: guid}}, function(err, docs) {
@@ -115,7 +118,7 @@ module.exports = function() {
}); });
} }
}); });
socket.on('chat', function (msg) { socket.on('chat', function (msg) {
Chat.chat(msg, guid, offline, socket); Chat.chat(msg, guid, offline, socket);
}); });