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

Trying to improve frontpage fetching

Browse Source
This commit is contained in:
Kasper Rynning-Tønnesen
2017-09-17 11:33:01 +02:00
parent 5bbde84a7c
commit 850be93973
9 changed files with 28 additions and 59 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
server/handlers/frontpage.js
View File

@@ -3,19 +3,23 @@ var frontpage_lists = function(msg, socket) {
socket.emit("update_required");
}
db.collection("frontpage_lists").find({frontpage:true, count: {$gt: 0}}, function(err, docs){
db.collection("connected_users").find({"_id": "total_users"}, function(err, tot){
socket.emit("playlists", {channels: docs, viewers: tot[0].total_users});
});
console.log("gotten second ", Functions.get_time());
db.collection("frontpage_lists").find({frontpage:true, count: {$ne: 0}}, function(err, docs){
console.log("gotten third ", Functions.get_time());
db.collection("connected_users").find({"_id": "total_users"}, function(err, tot){
console.log("sending frontpage ", Functions.get_time());
socket.compress(true).emit("playlists", {channels: docs, viewers: tot[0].total_users});
console.log("sent frontpage ", Functions.get_time());
});
});
}
function update_frontpage(coll, id, title) {
db.collection("frontpage_lists").update({_id: coll}, {$set: {
id: id,
title: title,
accessed: Functions.get_time()}
},{upsert: true}, function(err, returnDocs){});
db.collection("frontpage_lists").update({_id: coll}, {$set: {
id: id,
title: title,
accessed: Functions.get_time()}
},{upsert: true}, function(err, returnDocs){});
}
module.exports.update_frontpage = update_frontpage;

39
server/handlers/io.js
View File

@@ -65,12 +65,6 @@ module.exports = function() {
}
});
socket.on("get_userlists", function(id) {
db.collection("frontpage_lists_" + id).find(function(err, docs) {
socket.emit("userlists", [docs]);
});
});
socket.on("get_spread", function(){
db.collection("connected_users").find({"_id": "total_users"}, function(err, tot) {
db.collection("connected_users").find({"_id": "offline_users"}, function(err, off) {
@@ -157,6 +151,7 @@ module.exports = function() {
socket.on('frontpage_lists', function(msg)
{
console.log("First gotten", Functions.get_time());
Frontpage.frontpage_lists(msg, socket);
});
@@ -371,38 +366,6 @@ module.exports = function() {
}
});
});
/*ping_timeout = setTimeout(function() {
send_ping(guid, coll, socket);
}, 3000);
var send_ping = function(guid, coll, socket) {
console.log(guid, coll);
if(coll == undefined) {
ping_timeout = setTimeout(function(){
send_ping(guid, coll, socket);
}, 3000);
} else {
db.collection("connected_users").update({"_id": coll}, {$pull: {users: guid}}, function(err, docs) {
db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: -1}}, function(err, docs) {
db.collection("frontpage_lists").update({"_id": coll, viewers: {$gt: 0}}, {$inc: {viewers: -1}}, function(err, docs) {
db.collection("user_names").find({"guid": guid}, function(err, user_name) {
if(user_name.length > 0) {
name = user_name[0].name;
db.collection("user_names").remove({"guid": guid}, function(err, docs) {
db.collection("user_names").update({"_id": "all_names"}, {$pull: {names: user_name[0].name}}, function(err, docs) {
socket.emit("self_ping");
ping_timeout = setTimeout(function(){
send_ping(guid, coll, socket);
}, 3000);
});
});
}
});
});
});
});
}
}*/
});
send_ping();