From 05ce8923e6e4042fa115de10960b146f8e028d23 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Kasper=20Rynning-T=C3=B8nnesen?= Date: Mon, 11 Sep 2017 16:24:13 +0200 Subject: [PATCH] Fixed issue with infinate counter --- server/server.js | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/server/server.js b/server/server.js index b58ba250..4f0224c7 100755 --- a/server/server.js +++ b/server/server.js @@ -127,7 +127,7 @@ db.on('error',function(err) { console.log("\n" + new Date().toString() + "\n Database error: ", err); }); -db.collection("frontpage_lists").update({viewers: {$gt: 0}}, {$set: {"viewers": 0}}, function(err, docs) {}); +db.collection("frontpage_lists").update({viewers: {$gt: 0}}, {$set: {"viewers": 0}}, {multi: true}, function(err, docs) {}); io.on('connection', function(socket){ socket.emit("get_list"); @@ -168,7 +168,8 @@ io.on('connection', function(socket){ lists[channel] = []; } lists[channel].push(guid); - db.collection("frontpage_lists").update({"_id": channel}, {$inc: {viewers: 1}}, function(){}); + + db.collection("frontpage_lists").update({"_id": msg.channel}, {$inc: {viewers: 1}}, function(err, docs){}); } tot_view += 1 }); @@ -1204,7 +1205,7 @@ function send_ping() { lists = {}; offline_users = []; tot_view = 0; - db.collection("frontpage_lists").update({viewers: {$gt: 0}}, {$set: {"viewers": 0}}, function(err, docs) { + db.collection("frontpage_lists").update({viewers: {$ne: 0}}, {$set: {"viewers": 0}}, {multi: true}, function(err, docs) { io.emit("self_ping"); setTimeout(send_ping, 4000); });