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

Returned to refactored state

Browse Source
This commit is contained in:
Kasper Rynning-Tønnesen
2017-09-18 14:47:24 +02:00
parent 52c7552b67
commit 77c374f9b7
11 changed files with 534 additions and 2299 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
server/handlers/chat.js
View File

@@ -6,9 +6,9 @@ function chat(msg, guid, offline, socket) {
} }
var coll = msg.channel; var coll = msg.channel;
db.collection(coll).find({views:{$exists:true}}, function(err, docs){ db.collection(coll).find({views:{$exists:true}}, function(err, docs){
if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == decrypt_string(socket.zoff_id, msg.pass)))) { if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == Functions.decrypt_string(socket.zoff_id, msg.pass)))) {
var data = msg.data; var data = msg.data;
check_inlist(coll, guid, socket, offline); Functions.check_inlist(coll, guid, socket, offline);
if(data !== "" && data !== undefined && data !== null && if(data !== "" && data !== undefined && data !== null &&
data.length < 151 && data.replace(/\s/g, '').length){ data.length < 151 && data.replace(/\s/g, '').length){
db.collection("user_names").find({"guid": guid}, function(err, docs) { db.collection("user_names").find({"guid": guid}, function(err, docs) {
@@ -33,7 +33,7 @@ function all_chat(msg, guid, offline, socket) {
var coll = msg.channel; var coll = msg.channel;
var data = msg.data; var data = msg.data;
check_inlist(coll, guid, socket, offline); Functions.check_inlist(coll, guid, socket, offline);
if(data !== "" && data !== undefined && data !== null && if(data !== "" && data !== undefined && data !== null &&
data.length < 151 && data.replace(/\s/g, '').length){ data.length < 151 && data.replace(/\s/g, '').length){
db.collection("user_names").find({"guid": guid}, function(err, docs) { db.collection("user_names").find({"guid": guid}, function(err, docs) {
@@ -92,7 +92,7 @@ function removename(guid, coll) {
} }
function generate_name(guid, announce_payload) { function generate_name(guid, announce_payload) {
var tmp_name = rndName(guid, 8); var tmp_name = Functions.rndName(guid, 8);
db.collection("user_names").update({"_id": "all_names"}, {$addToSet: {names: tmp_name}}, {upsert: true}, function(err, updated) { db.collection("user_names").update({"_id": "all_names"}, {$addToSet: {names: tmp_name}}, {upsert: true}, function(err, updated) {
if(updated.nModified == 1 || (updated.hasOwnProperty("upserted") && n == 1)) { if(updated.nModified == 1 || (updated.hasOwnProperty("upserted") && n == 1)) {
db.collection("user_names").update({"guid": guid}, {$set: {name: tmp_name}}, {upsert: true}, function(err, update){ db.collection("user_names").update({"guid": guid}, {$set: {name: tmp_name}}, {upsert: true}, function(err, update){
@@ -107,7 +107,7 @@ function generate_name(guid, announce_payload) {
} }
}); });
} else { } else {
generate_name(tmp_name, announce_payload); Chat.generate_name(tmp_name, announce_payload);
} }
}) })
} }
@@ -115,9 +115,16 @@ function generate_name(guid, announce_payload) {
function get_name(guid, announce_payload) { function get_name(guid, announce_payload) {
db.collection("user_names").find({"guid": guid}, function(err, docs) { db.collection("user_names").find({"guid": guid}, function(err, docs) {
if(docs.length == 0) { if(docs.length == 0) {
generate_name(guid, announce_payload); Chat.generate_name(guid, announce_payload);
} else { } else {
name = docs[0].name; name = docs[0].name;
} }
}) })
} }
module.exports.chat = chat;
module.exports.all_chat = all_chat;
module.exports.namechange = namechange;
module.exports.removename = removename;
module.exports.generate_name = generate_name;
module.exports.get_name = get_name;

2
server/handlers/db.js
View File

@@ -9,3 +9,5 @@ db.on('connected', function(err) {
db.on('error',function(err) { db.on('error',function(err) {
console.log("\n" + new Date().toString() + "\n Database error: ", err); console.log("\n" + new Date().toString() + "\n Database error: ", err);
}); });
module.exports = db;

13
server/handlers/frontpage.js
View File

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

13
server/handlers/functions.js
View File

@@ -10,7 +10,7 @@ function remove_name_from_db(guid, name) {
} }
function remove_from_array(array, element){ function remove_from_array(array, element){
if(contains(array, element)){ if(Functions.contains(array, element)){
var index = array.indexOf(element); var index = array.indexOf(element);
if(index != -1) if(index != -1)
array.splice(index, 1); array.splice(index, 1);
@@ -120,3 +120,14 @@ function contains(a, obj) {
function hash_pass(adminpass) { function hash_pass(adminpass) {
return crypto.createHash('sha256').update(adminpass).digest('base64'); return crypto.createHash('sha256').update(adminpass).digest('base64');
} }
module.exports.remove_unique_id = remove_unique_id;
module.exports.remove_name_from_db = remove_name_from_db;
module.exports.remove_from_array = remove_from_array;
module.exports.get_short_id = get_short_id;
module.exports.check_inlist = check_inlist;
module.exports.rndName = rndName;
module.exports.decrypt_string = decrypt_string;
module.exports.get_time = get_time;
module.exports.contains = contains;
module.exports.hash_pass = hash_pass;

729
server/handlers/io.js
View File

@@ -1,386 +1,373 @@
io.on('connection', function(socket){ module.exports = function() {
socket.zoff_id = socket.id; io.on('connection', function(socket){
socket.emit("get_list"); socket.zoff_id = socket.id;
socket.emit("get_list");
var guid = hash_pass(socket.handshake.headers["user-agent"] + socket.handshake.address + socket.handshake.headers["accept-language"]); var guid = Functions.hash_pass(socket.handshake.headers["user-agent"] + socket.handshake.address + socket.handshake.headers["accept-language"]);
socket.on('close', function() { socket.on('close', function() {
console.log("closing socket"); });
});
socket.on('pinging', function() { socket.on('pinging', function() {
socket.emit("ok"); socket.emit("ok");
}); });
var ping_timeout; var ping_timeout;
var socketid = socket.zoff_id; var socketid = socket.zoff_id;
var coll; var coll;
var in_list = false; var in_list = false;
var name = ""; var name = "";
var short_id; var short_id;
get_name(guid, {announce: false}); Chat.get_name(guid, {announce: false});
var offline = false; var offline = false;
var chromecast_object = false; var chromecast_object = false;
socket.emit("guid", guid); socket.emit("guid", guid);
socket.on('self_ping', function(msg) { socket.on('self_ping', function(msg) {
var channel = msg.channel; var channel = msg.channel;
if(offline) { if(offline) {
db.collection("connected_users").update({"_id": "offline_users"}, {$addToSet: {users: guid}}, {upsert: true}, function(err, docs){}); db.collection("connected_users").update({"_id": "offline_users"}, {$addToSet: {users: guid}}, {upsert: true}, function(err, docs){});
} else { } else {
db.collection("connected_users").update({"_id": channel}, {$addToSet: {users: guid}}, {upsert: true}, function(err, docs){ db.collection("connected_users").update({"_id": channel}, {$addToSet: {users: guid}}, {upsert: true}, function(err, docs){
db.collection("frontpage_lists").update({"_id": channel}, {$inc: {viewers: 1}}, {upsert: true}, function(){}); db.collection("frontpage_lists").update({"_id": channel}, {$inc: {viewers: 1}}, {upsert: true}, function(){});
});
}
/*if(name != "") {
db.collection("user_names").update({"_id": "all_names"}, {$addToSet: {names: name}}, {upsert: true}, function(err, updated) {
if(updated.nModified == 1) {
db.collection("user_names").update({"guid": guid}, {$set: {name: name}}, {upsert:true}, function(err, update){});
}
});
}*/
db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: 1}}, {upsert: true}, function(err, docs){});
});
socket.on('chromecast', function(msg) {
try {
if(typeof(msg) == "object" && msg.hasOwnProperty("guid") && msg.hasOwnProperty("socket_id") && msg.hasOwnProperty("channel")) {
db.collection("connected_users").find({"_id": msg.channel}, function(err, connected_users_channel) {
if(connected_users_channel.length > 0 && connected_users_channel[0].users.indexOf(msg.guid) > -1) {
guid = msg.guid;
socketid = msg.socket_id;
socket.zoff_id = socketid;
coll = msg.channel;
in_list = true;
chromecast_object = true;
socket.join(coll);
}
});
}
} catch(e) {
return;
}
});
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) {
db.collection("connected_users").find({"_id": {$ne: "total_users"}, "_id": {$ne: "offline_users"}}, function(err, users_list) {
if(tot.length > 0 && off.length == 0) {
socket.emit("spread_listeners", {offline: 0, total: tot[0].total_users, online_users: users_list});
} else if(tot.length > 0 && off.length > 0){
socket.emit("spread_listeners", {offline: off[0].users.length, total: tot[0].total_users, online_users: users_list});
}
});
});
}); });
} });
/*if(name != "") {
db.collection("user_names").update({"_id": "all_names"}, {$addToSet: {names: name}}, {upsert: true}, function(err, updated) { socket.on('suggest_thumbnail', function(msg){
if(updated.nModified == 1) { Suggestions.thumbnail(msg, coll, guid, offline, socket);
db.collection("user_names").update({"guid": guid}, {$set: {name: name}}, {upsert:true}, function(err, update){}); });
socket.on('suggest_description', function(msg){
Suggestions.description(msg, coll, guid, offline, socket);
});
socket.on("offline", function(msg){
if(!msg.hasOwnProperty('status') && !msg.hasOwnProperty('channel')) {
socket.emit("update_required");
return;
}
var status = msg.status;
var channel = msg.channel;
if(status){
in_list = false;
offline = true;
if(channel != "") coll = channel;
if(coll !== undefined) {
db.collection("connected_users").findAndModify({
query: {"_id": coll},
update: {$pull: {users: guid}},
upsert: true,
}, function(err, updated) {
if(updated.nModified > 0) {
io.to(coll).emit("viewers", updated.users);
db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: -1}}, function(err, docs){});
}
Functions.remove_name_from_db(guid, name);
});
}
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 {
offline = false;
db.collection("connected_users").update({"_id": "offline_users"}, {$pull: {users: guid}}, function(err, docs) {
Functions.check_inlist(coll, guid, socket, offline);
});
}
});
/*socket.on('namechange', function(msg)
{
if(coll == undefined) {
coll = msg.channel;
}
Chat.namechange(msg.name, guid, coll, function(new_name) {
name = new_name;
});
});
socket.on('removename', function()
{
Chat.removename(guid, coll);
name = "";
});*/
socket.on('chat', function (msg) {
Chat.chat(msg, guid, offline, socket);
});
socket.on("all,chat", function(data)
{
Chat.all_chat(data, guid, offline, socket);
});
socket.on('frontpage_lists', function(msg)
{
Frontpage.frontpage_lists(msg, socket);
});
socket.on('now_playing', function(list, fn)
{
List.now_playing(list, fn, socket);
});
socket.on('id', function(arr)
{
if(typeof(arr) == 'object')
io.to(arr.id).emit(arr.id.toLowerCase(), {type: arr.type, value: arr.value});
});
socket.on('list', function(msg)
{
try {
var _list = msg.channel;
if(_list.length == 0) return;
coll = emojiStrip(_list).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
List.list(msg, guid, coll, offline, socket);
Functions.get_short_id(socket);
});
socket.on('end', function(obj)
{
if(coll === undefined) {
try {
coll = obj.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
List.end(obj, coll, guid, offline, socket);
});
socket.on('add', function(arr)
{
if(coll !== undefined) {
try {
coll = arr.list;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
ListChange.add_function(arr, coll, guid, offline, socket);
});
socket.on('delete_all', function(msg) {
if(coll !== undefined) {
try {
coll = msg.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
ListChange.delete_all(msg, coll, guid, offline, socket);
});
socket.on('vote', function(msg)
{
if(coll !== undefined) {
try {
coll = msg.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
ListChange.voteUndecided(msg, coll, guid, offline, socket);
});
socket.on('password', function(inp)
{
ListSettings.password(inp, coll, guid, offline, socket);
});
socket.on('skip', function(list)
{
if(coll !== undefined) {
try {
coll = list.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
List.skip(list, guid, coll, offline, socket);
});
socket.on('conf', function(params)
{
ListSettings.conf_function(params, coll, guid, offline, socket);
});
socket.on('shuffle', function(msg)
{
if(coll !== undefined) {
try {
coll = msg.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
ListChange.shuffle(msg, coll, guid, offline, socket);
});
socket.on('change_channel', function(obj)
{
if(coll === undefined && obj !== undefined && obj.channel !== undefined){
try {
coll = obj.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
List.left_channel(coll, guid, short_id, in_list, socket, true);
in_list = false;
});
socket.on('disconnect', function()
{
List.left_channel(coll, guid, short_id, in_list, socket, false);
});
socket.on('disconnected', function()
{
List.left_channel(coll, guid, short_id, in_list, socket, false);
});
socket.on('reconnect_failed', function()
{
List.left_channel(coll, guid, short_id, in_list, socket, false);
});
socket.on('connect_timeout', function()
{
List.left_channel(coll, guid, short_id, in_list, socket, false);
});
socket.on('error', function()
{
List.left_channel(coll, guid, short_id, in_list, socket, false);
});
socket.on('pos', function(obj)
{
if(coll !== undefined) {
try {
coll = obj.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
if(coll == "" || coll == undefined || coll == null) {
socket.emit("update_required");
return;
}
db.collection(coll).find({views: {$exists: true}}, function(err, docs) {
if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (obj.hasOwnProperty('pass') && docs[0].userpass == Functions.decrypt_string(socketid, obj.pass)))) {
Functions.check_inlist(coll, guid, socket, offline);
List.send_play(coll, socket);
} else {
socket.emit("auth_required");
} }
}); });
}*/
db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: 1}}, {upsert: true}, function(err, docs){});
});
socket.on('chromecast', function(msg) {
try {
if(typeof(msg) == "object" && msg.hasOwnProperty("guid") && msg.hasOwnProperty("socket_id") && msg.hasOwnProperty("channel")) {
db.collection("connected_users").find({"_id": msg.channel}, function(err, connected_users_channel) {
if(connected_users_channel.length > 0 && connected_users_channel[0].users.indexOf(msg.guid) > -1) {
guid = msg.guid;
socketid = msg.socket_id;
socket.zoff_id = socketid;
coll = msg.channel;
in_list = true;
chromecast_object = true;
socket.join(coll);
}
});
}
} catch(e) {
return;
}
});
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) {
db.collection("connected_users").find({"_id": {$ne: "total_users"}, "_id": {$ne: "offline_users"}}, function(err, users_list) {
if(tot.length > 0 && off.length == 0) {
socket.emit("spread_listeners", {offline: 0, total: tot[0].total_users, online_users: users_list});
} else if(tot.length > 0 && off.length > 0){
socket.emit("spread_listeners", {offline: off[0].users.length, total: tot[0].total_users, online_users: users_list});
}
});
});
}); });
}); });
socket.on('suggest_thumbnail', function(msg){ send_ping();
thumbnail(msg, coll, guid, offline, socket); }
});
socket.on('suggest_description', function(msg){
description(msg, coll, guid, offline, socket);
});
socket.on("offline", function(msg){
if(!msg.hasOwnProperty('status') && !msg.hasOwnProperty('channel')) {
socket.emit("update_required");
return;
}
var status = msg.status;
var channel = msg.channel;
if(status){
in_list = false;
offline = true;
if(channel != "") coll = channel;
if(coll !== undefined) {
db.collection("connected_users").findAndModify({
query: {"_id": coll},
update: {$pull: {users: guid}},
upsert: true,
}, function(err, updated) {
if(updated.nModified > 0) {
io.to(coll).emit("viewers", updated.users);
db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: -1}}, function(err, docs){});
}
remove_name_from_db(guid, name);
});
}
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 {
offline = false;
db.collection("connected_users").update({"_id": "offline_users"}, {$pull: {users: guid}}, function(err, docs) {
check_inlist(coll, guid, socket, offline);
});
}
});
/*socket.on('namechange', function(msg)
{
if(coll == undefined) {
coll = msg.channel;
}
namechange(msg.name, guid, coll, function(new_name) {
name = new_name;
});
});
socket.on('removename', function()
{
removename(guid, coll);
name = "";
});*/
socket.on('chat', function (msg) {
chat(msg, guid, offline, socket);
});
socket.on("all,chat", function(data)
{
all_chat(data, guid, offline, socket);
});
socket.on('frontpage_lists', function(msg)
{
console.log("First gotten", get_time());
/*Frontpage.frontpage_lists(msg, socket);*/
if(!msg.hasOwnProperty('version') || msg.version != VERSION || msg.version == undefined) {
socket.emit("update_required");
}
console.log("gotten second ", get_time());
db.collection("frontpage_lists").find({frontpage:true}, function(err, docs){
console.log("gotten third ", get_time());
db.collection("connected_users").find({"_id": "total_users"}, function(err, tot){
console.log("sending frontpage ", get_time());
socket.compress(true).emit("playlists", {channels: docs, viewers: tot[0].total_users});
console.log("sent frontpage ", get_time());
});
});
});
socket.on('now_playing', function(list, fn)
{
now_playing(list, fn, socket);
});
socket.on('id', function(arr)
{
if(typeof(arr) == 'object')
io.to(arr.id).emit(arr.id.toLowerCase(), {type: arr.type, value: arr.value});
});
socket.on('list', function(msg)
{
try {
var _list = msg.channel;
if(_list.length == 0) return;
coll = emojiStrip(_list).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
list(msg, guid, coll, offline, socket);
get_short_id(socket);
});
socket.on('end', function(obj)
{
if(coll === undefined) {
try {
coll = obj.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
end(obj, coll, guid, offline, socket);
});
socket.on('add', function(arr)
{
if(coll !== undefined) {
try {
coll = arr.list;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
add_function(arr, coll, guid, offline, socket);
});
socket.on('delete_all', function(msg) {
if(coll !== undefined) {
try {
coll = msg.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
delete_all(msg, coll, guid, offline, socket);
});
socket.on('vote', function(msg)
{
if(coll !== undefined) {
try {
coll = msg.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
voteUndecided(msg, coll, guid, offline, socket);
});
socket.on('password', function(inp)
{
password(inp, coll, guid, offline, socket);
});
socket.on('skip', function(list)
{
if(coll !== undefined) {
try {
coll = list.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
skip(list, guid, coll, offline, socket);
});
socket.on('conf', function(params)
{
conf_function(params, coll, guid, offline, socket);
});
socket.on('shuffle', function(msg)
{
if(coll !== undefined) {
try {
coll = msg.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
shuffle(msg, coll, guid, offline, socket);
});
socket.on('change_channel', function(obj)
{
if(coll === undefined && obj !== undefined && obj.channel !== undefined){
try {
coll = obj.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
left_channel(coll, guid, short_id, in_list, socket, true);
in_list = false;
});
socket.on('disconnect', function()
{
left_channel(coll, guid, short_id, in_list, socket, false);
});
socket.on('disconnected', function()
{
left_channel(coll, guid, short_id, in_list, socket, false);
});
socket.on('reconnect_failed', function()
{
left_channel(coll, guid, short_id, in_list, socket, false);
});
socket.on('connect_timeout', function()
{
left_channel(coll, guid, short_id, in_list, socket, false);
});
socket.on('error', function()
{
left_channel(coll, guid, short_id, in_list, socket, false);
});
socket.on('pos', function(obj)
{
if(coll !== undefined) {
try {
coll = obj.channel;
if(coll.length == 0) return;
coll = emojiStrip(coll).toLowerCase();
coll = coll.replace("_", "");
coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll);
} catch(e) {
return;
}
}
if(coll == "" || coll == undefined || coll == null) {
socket.emit("update_required");
return;
}
db.collection(coll).find({views: {$exists: true}}, function(err, docs) {
if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (obj.hasOwnProperty('pass') && docs[0].userpass == decrypt_string(socketid, obj.pass)))) {
check_inlist(coll, guid, socket, offline);
send_play(coll, socket);
} else {
socket.emit("auth_required");
}
});
});
});
send_ping();
function send_ping() { function send_ping() {
db.collection("connected_users").update({users: {$exists: true}}, {$set: {users: []}}, {multi: true}, function(err, docs){ db.collection("connected_users").update({users: {$exists: true}}, {$set: {users: []}}, {multi: true}, function(err, docs){

107
server/handlers/list.js
View File

@@ -28,7 +28,7 @@ function list(msg, guid, coll, offline, socket) {
socket.emit("update_required"); socket.emit("update_required");
return; return;
} }
var pass = decrypt_string(socketid, msg.pass); var pass = Functions.decrypt_string(socketid, msg.pass);
db.collection('frontpage_lists').find({"_id": coll}, function(err, frontpage_lists){ db.collection('frontpage_lists').find({"_id": coll}, function(err, frontpage_lists){
if(frontpage_lists.length == 1) if(frontpage_lists.length == 1)
{ {
@@ -39,7 +39,7 @@ function list(msg, guid, coll, offline, socket) {
} }
in_list = true; in_list = true;
socket.join(coll); socket.join(coll);
check_inlist(coll, guid, socket, offline); Functions.check_inlist(coll, guid, socket, offline);
if(frontpage_lists.viewers != undefined){ if(frontpage_lists.viewers != undefined){
io.to(coll).emit("viewers", frontpage_lists.viewers); io.to(coll).emit("viewers", frontpage_lists.viewers);
@@ -47,7 +47,7 @@ function list(msg, guid, coll, offline, socket) {
io.to(coll).emit("viewers", 1); io.to(coll).emit("viewers", 1);
} }
send_list(coll, socket, true, false, true); List.send_list(coll, socket, true, false, true);
} else { } else {
socket.emit("auth_required"); socket.emit("auth_required");
@@ -55,9 +55,9 @@ function list(msg, guid, coll, offline, socket) {
}); });
} else{ } else{
db.createCollection(coll, function(err, docs){ db.createCollection(coll, function(err, docs){
db.collection(coll).insert({"addsongs":false, "adminpass":"", "allvideos":true, "frontpage":true, "longsongs":false, "removeplay": false, "shuffle": true, "skip": false, "skips": [], "startTime":get_time(), "views": [], "vote": false, "desc": ""}, function(err, docs){ db.collection(coll).insert({"addsongs":false, "adminpass":"", "allvideos":true, "frontpage":true, "longsongs":false, "removeplay": false, "shuffle": true, "skip": false, "skips": [], "startTime":Functions.get_time(), "views": [], "vote": false, "desc": ""}, function(err, docs){
send_list(coll, socket, true, false, true); List.send_list(coll, socket, true, false, true);
db.collection("frontpage_lists").insert({"_id": coll, "count" : 0, "frontpage": true, "accessed": get_time()}); db.collection("frontpage_lists").insert({"_id": coll, "count" : 0, "frontpage": true, "accessed": Functions.get_time()});
}); });
}); });
} }
@@ -78,9 +78,9 @@ function skip(list, guid, coll, offline, socket) {
} }
db.collection(coll).find({views:{$exists:true}}, function(err, docs){ db.collection(coll).find({views:{$exists:true}}, function(err, docs){
if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (list.hasOwnProperty('userpass') && docs[0].userpass == decrypt_string(socketid, list.userpass)))) { if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (list.hasOwnProperty('userpass') && docs[0].userpass == Functions.decrypt_string(socketid, list.userpass)))) {
check_inlist(coll, guid, socket, offline); Functions.check_inlist(coll, guid, socket, offline);
adminpass = ""; adminpass = "";
video_id = list.id; video_id = list.id;
@@ -95,7 +95,7 @@ function skip(list, guid, coll, offline, socket) {
} }
if(adminpass !== undefined && adminpass !== null && adminpass !== "") if(adminpass !== undefined && adminpass !== null && adminpass !== "")
hash = hash_pass(decrypt_string(socketid, adminpass)); hash = Functions.hash_pass(Functions.decrypt_string(socketid, adminpass));
else else
hash = ""; hash = "";
@@ -106,14 +106,14 @@ function skip(list, guid, coll, offline, socket) {
if(!docs[0].skip || (docs[0].adminpass == hash && docs[0].adminpass !== "") || error) if(!docs[0].skip || (docs[0].adminpass == hash && docs[0].adminpass !== "") || error)
{ {
db.collection("frontpage_lists").find({"_id": coll}, function(err, frontpage_viewers){ db.collection("frontpage_lists").find({"_id": coll}, function(err, frontpage_viewers){
if((frontpage_viewers[0].viewers/2 <= docs[0].skips.length+1 && !contains(docs[0].skips, guid) && frontpage_viewers[0].viewers != 2) || if((frontpage_viewers[0].viewers/2 <= docs[0].skips.length+1 && !Functions.contains(docs[0].skips, guid) && frontpage_viewers[0].viewers != 2) ||
(frontpage_viewers[0].viewers == 2 && docs[0].skips.length+1 == 2 && !contains(docs[0].skips, guid)) || (frontpage_viewers[0].viewers == 2 && docs[0].skips.length+1 == 2 && !Functions.contains(docs[0].skips, guid)) ||
(docs[0].adminpass == hash && docs[0].adminpass !== "" && docs[0].skip)) (docs[0].adminpass == hash && docs[0].adminpass !== "" && docs[0].skip))
{ {
change_song(coll, error, video_id); List.change_song(coll, error, video_id);
socket.emit("toast", "skip"); socket.emit("toast", "skip");
io.to(coll).emit('chat', {from: name, msg: " skipped"}); io.to(coll).emit('chat', {from: name, msg: " skipped"});
}else if(!contains(docs[0].skips, guid)){ }else if(!Functions.contains(docs[0].skips, guid)){
db.collection(coll).update({views:{$exists:true}}, {$push:{skips:guid}}, function(err, d){ db.collection(coll).update({views:{$exists:true}}, {$push:{skips:guid}}, function(err, d){
if(frontpage_viewers[0].viewers == 2) if(frontpage_viewers[0].viewers == 2)
to_skip = 1; to_skip = 1;
@@ -170,13 +170,13 @@ function change_song(coll, error, id) {
db.collection(coll).remove({now_playing:true, id:id}, function(err, docs){ db.collection(coll).remove({now_playing:true, id:id}, function(err, docs){
var next_song; var next_song;
if(now_playing_doc.length == 2) next_song = now_playing_doc[1].id; if(now_playing_doc.length == 2) next_song = now_playing_doc[1].id;
change_song_post(coll, next_song); List.change_song_post(coll, next_song);
io.to(coll).emit("channel", {type: "deleted", value: now_playing_doc[0].id, removed: true}); io.to(coll).emit("channel", {type: "deleted", value: now_playing_doc[0].id, removed: true});
db.collection("frontpage_lists").update({_id: coll}, {$inc: {count: -1}, $set:{accessed: get_time()}}, {upsert: true}, function(err, docs){}); db.collection("frontpage_lists").update({_id: coll}, {$inc: {count: -1}, $set:{accessed: Functions.get_time()}}, {upsert: true}, function(err, docs){});
}); });
} else { } else {
if((docs[0].skipped_time != undefined && docs[0].skipped_time != get_time()) || docs[0].skipped_time == undefined) { if((docs[0].skipped_time != undefined && docs[0].skipped_time != Functions.get_time()) || docs[0].skipped_time == undefined) {
db.collection(coll).update({views: {$exists: true}}, {$set: {skipped_time: get_time()}}, function(err, updated){ db.collection(coll).update({views: {$exists: true}}, {$set: {skipped_time: Functions.get_time()}}, function(err, updated){
db.collection(coll).update({now_playing:true, id:id}, { db.collection(coll).update({now_playing:true, id:id}, {
$set:{ $set:{
now_playing:false, now_playing:false,
@@ -186,7 +186,7 @@ function change_song(coll, error, id) {
},{multi:true}, function(err, docs){ },{multi:true}, function(err, docs){
var next_song; var next_song;
if(now_playing_doc.length == 2) next_song = now_playing_doc[1].id; if(now_playing_doc.length == 2) next_song = now_playing_doc[1].id;
if(docs.n >= 1) change_song_post(coll, next_song); if(docs.n >= 1) List.change_song_post(coll, next_song);
}); });
}); });
} }
@@ -197,12 +197,12 @@ function change_song(coll, error, id) {
db.collection(coll).remove({now_playing:true, id:id}, function(err, docs){ db.collection(coll).remove({now_playing:true, id:id}, function(err, docs){
var next_song; var next_song;
if(now_playing_doc.length == 2) next_song = now_playing_doc[1].id; if(now_playing_doc.length == 2) next_song = now_playing_doc[1].id;
change_song_post(coll, next_song); List.change_song_post(coll, next_song);
io.to(coll).emit("channel", {type: "deleted", value: now_playing_doc[0].id, removed: true}); io.to(coll).emit("channel", {type: "deleted", value: now_playing_doc[0].id, removed: true});
db.collection("frontpage_lists").update({_id: coll}, {$inc: {count: -1}, $set:{accessed: get_time()}}, {upsert: true}, function(err, docs){}); db.collection("frontpage_lists").update({_id: coll}, {$inc: {count: -1}, $set:{accessed: Functions.get_time()}}, {upsert: true}, function(err, docs){});
}); });
} else { } else {
if((docs[0].skipped_time != undefined && docs[0].skipped_time != get_time()) || docs[0].skipped_time == undefined) { if((docs[0].skipped_time != undefined && docs[0].skipped_time != Functions.get_time()) || docs[0].skipped_time == undefined) {
db.collection(coll).update({now_playing:true, id:id}, { db.collection(coll).update({now_playing:true, id:id}, {
$set:{ $set:{
now_playing:false, now_playing:false,
@@ -212,7 +212,7 @@ function change_song(coll, error, id) {
},{multi:true}, function(err, docs){ },{multi:true}, function(err, docs){
var next_song; var next_song;
if(now_playing_doc.length == 2) next_song = now_playing_doc[1].id; if(now_playing_doc.length == 2) next_song = now_playing_doc[1].id;
change_song_post(coll, next_song); List.change_song_post(coll, next_song);
}); });
} }
} }
@@ -256,19 +256,19 @@ function change_song_post(coll, next_song)
now_playing:true, now_playing:true,
votes:0, votes:0,
guids:[], guids:[],
added:get_time() added:Functions.get_time()
} }
}, function(err, returnDocs){ }, function(err, returnDocs){
db.collection(coll).update({views:{$exists:true}},{ db.collection(coll).update({views:{$exists:true}},{
$set:{ $set:{
startTime:get_time(), startTime:Functions.get_time(),
skips:[] skips:[]
} }
}, function(err, returnDocs){ }, function(err, returnDocs){
db.collection(coll).find({views:{$exists:true}}, function(err, conf){ db.collection(coll).find({views:{$exists:true}}, function(err, conf){
io.to(coll).emit("channel", {type: "song_change", time: get_time(), remove: conf[0].removeplay}); io.to(coll).emit("channel", {type: "song_change", time: Functions.get_time(), remove: conf[0].removeplay});
send_play(coll); List.send_play(coll);
update_frontpage(coll, docs[0].id, docs[0].title); Frontpage.update_frontpage(coll, docs[0].id, docs[0].title);
}); });
}); });
}); });
@@ -309,17 +309,17 @@ function send_list(coll, socket, send, list_send, configs, shuffled)
now_playing:true, now_playing:true,
votes:0, votes:0,
guids:[], guids:[],
added:get_time() added:Functions.get_time()
} }
}, function(err, returnDocs){ }, function(err, returnDocs){
db.collection(coll).update({views:{$exists:true}}, { db.collection(coll).update({views:{$exists:true}}, {
$set:{ $set:{
startTime: get_time(), startTime: Functions.get_time(),
skips:[] skips:[]
} }
}, function(err, returnDocs){ }, function(err, returnDocs){
update_frontpage(coll, now_playing_doc[0].id, now_playing_doc[0].title); Frontpage.update_frontpage(coll, now_playing_doc[0].id, now_playing_doc[0].title);
send_list(coll, socket, send, list_send, configs, shuffled); List.send_list(coll, socket, send, list_send, configs, shuffled);
}); });
}); });
} }
@@ -331,9 +331,9 @@ function send_list(coll, socket, send, list_send, configs, shuffled)
socket.emit("channel", {type: "list", playlist: docs, shuffled: shuffled}); socket.emit("channel", {type: "list", playlist: docs, shuffled: shuffled});
} }
if(socket === undefined && send) { if(socket === undefined && send) {
send_play(coll); List.send_play(coll);
} else if(send) { } else if(send) {
send_play(coll, socket); List.send_play(coll, socket);
} }
} }
}); });
@@ -344,9 +344,9 @@ function send_list(coll, socket, send, list_send, configs, shuffled)
socket.emit("channel", {type: "list", playlist: docs, shuffled: shuffled}); socket.emit("channel", {type: "list", playlist: docs, shuffled: shuffled});
} }
if(socket === undefined && send) { if(socket === undefined && send) {
send_play(coll); List.send_play(coll);
} else if(send) { } else if(send) {
send_play(coll, socket); List.send_play(coll, socket);
} }
} }
}); });
@@ -380,24 +380,24 @@ function end(obj, coll, guid, offline, socket) {
} }
db.collection(coll).find({views:{$exists:true}}, function(err, docs){ db.collection(coll).find({views:{$exists:true}}, function(err, docs){
if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (obj.hasOwnProperty('pass') && docs[0].userpass == decrypt_string(socketid, obj.pass)))) { if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (obj.hasOwnProperty('pass') && docs[0].userpass == Functions.decrypt_string(socketid, obj.pass)))) {
check_inlist(coll, guid, socket, offline); Functions.check_inlist(coll, guid, socket, offline);
db.collection(coll).find({now_playing:true}, function(err, np){ db.collection(coll).find({now_playing:true}, function(err, np){
if(err !== null) console.log(err); if(err !== null) console.log(err);
if(np !== null && np !== undefined && np.length == 1 && np[0].id == id){ if(np !== null && np !== undefined && np.length == 1 && np[0].id == id){
db.collection(coll).find({views:{$exists:true}}, function(err, docs){ db.collection(coll).find({views:{$exists:true}}, function(err, docs){
var startTime = docs[0].startTime; var startTime = docs[0].startTime;
if(docs[0].removeplay === true && startTime+parseInt(np[0].duration)<=get_time()+5) if(docs[0].removeplay === true && startTime+parseInt(np[0].duration)<=Functions.get_time()+5)
{ {
db.collection(coll).remove({now_playing:true}, function(err, docs){ db.collection(coll).remove({now_playing:true}, function(err, docs){
change_song_post(coll); List.change_song_post(coll);
db.collection("frontpage_lists").update({_id:coll}, {$inc:{count:-1}, $set:{accessed: get_time()}}, {upsert:true}, function(err, docs){}); db.collection("frontpage_lists").update({_id:coll}, {$inc:{count:-1}, $set:{accessed: Functions.get_time()}}, {upsert:true}, function(err, docs){});
}); });
}else{ }else{
if(startTime+parseInt(np[0].duration)<=get_time()+5) if(startTime+parseInt(np[0].duration)<=Functions.get_time()+5)
{ {
change_song(coll, false, id); List.change_song(coll, false, id);
} }
} }
}); });
@@ -418,17 +418,17 @@ function send_play(coll, socket)
db.collection(coll).find({views:{$exists:true}}, function(err, conf){ db.collection(coll).find({views:{$exists:true}}, function(err, conf){
if(err !== null) console.log(err); if(err !== null) console.log(err);
try{ try{
if(get_time()-conf[0].startTime > np[0].duration){ if(Functions.get_time()-conf[0].startTime > np[0].duration){
change_song(coll, false, np[0].id); List.change_song(coll, false, np[0].id);
}else if(conf !== null && conf !== undefined && conf.length !== 0) }else if(conf !== null && conf !== undefined && conf.length !== 0)
{ {
if(conf[0].adminpass !== "") conf[0].adminpass = true; if(conf[0].adminpass !== "") conf[0].adminpass = true;
if(conf[0].hasOwnProperty("userpass") && conf[0].userpass != "") conf[0].userpass = true; if(conf[0].hasOwnProperty("userpass") && conf[0].userpass != "") conf[0].userpass = true;
else conf[0].userpass = false; else conf[0].userpass = false;
toSend = {np: np, conf: conf, time: get_time()}; toSend = {np: np, conf: conf, time: Functions.get_time()};
if(socket === undefined) { if(socket === undefined) {
io.to(coll).emit("np", toSend); io.to(coll).emit("np", toSend);
getNextSong(coll) List.getNextSong(coll)
} else { } else {
socket.emit("np", toSend); socket.emit("np", toSend);
} }
@@ -488,10 +488,21 @@ function left_channel(coll, guid, short_id, in_list, socket, change)
db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: -1}}, function(err, updated){}); db.collection("connected_users").update({"_id": "total_users"}, {$inc: {total_users: -1}}, function(err, updated){});
if(!change) { if(!change) {
remove_name_from_db(guid, name); Functions.remove_name_from_db(guid, name);
} }
}); });
} }
}); });
remove_unique_id(short_id); Functions.remove_unique_id(short_id);
} }
module.exports.now_playing = now_playing;
module.exports.list = list;
module.exports.skip = skip;
module.exports.change_song = change_song;
module.exports.change_song_post = change_song_post;
module.exports.send_list = send_list;
module.exports.end = end;
module.exports.send_play = send_play;
module.exports.getNextSong = getNextSong;
module.exports.left_channel = left_channel;

77
server/handlers/list_change.js
View File

@@ -9,13 +9,13 @@ function add_function(arr, coll, guid, offline, socket) {
} }
db.collection(coll).find({views:{$exists:true}}, function(err, docs){ db.collection(coll).find({views:{$exists:true}}, function(err, docs){
if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (arr.hasOwnProperty('pass') && docs[0].userpass == decrypt_string(socketid, arr.pass)))) { if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (arr.hasOwnProperty('pass') && docs[0].userpass == Functions.decrypt_string(socketid, arr.pass)))) {
check_inlist(coll, guid, socket, offline); Functions.check_inlist(coll, guid, socket, offline);
var id = arr.id; var id = arr.id;
var title = arr.title; var title = arr.title;
var hash = hash_pass(decrypt_string(socketid, arr.adminpass)); var hash = Functions.hash_pass(Functions.decrypt_string(socketid, arr.adminpass));
var duration = parseInt(arr.duration); var duration = parseInt(arr.duration);
var full_list = arr.playlist; var full_list = arr.playlist;
var last = arr.num == arr.total - 1; var last = arr.num == arr.total - 1;
@@ -34,7 +34,7 @@ function add_function(arr, coll, guid, offline, socket) {
var votes; var votes;
var added; var added;
if(full_list) { if(full_list) {
var time = get_time()-total; var time = Functions.get_time()-total;
time = time.toString(); time = time.toString();
var total_len = total.toString().length; var total_len = total.toString().length;
var now_len = num.toString().length; var now_len = num.toString().length;
@@ -49,7 +49,7 @@ function add_function(arr, coll, guid, offline, socket) {
added = time; added = time;
votes = 0; votes = 0;
} else { } else {
added = get_time(); added = Functions.get_time();
votes = 1; votes = 1;
} }
@@ -81,15 +81,15 @@ function add_function(arr, coll, guid, offline, socket) {
db.collection(coll).update({id: id}, {"added": added,"guids":guids,"id":id,"now_playing":np,"title":title,"votes":votes, "duration":duration}, {upsert: true}, function(err, docs){ db.collection(coll).update({id: id}, {"added": added,"guids":guids,"id":id,"now_playing":np,"title":title,"votes":votes, "duration":duration}, {upsert: true}, function(err, docs){
if(np) if(np)
{ {
send_list(coll, undefined, false, true, false); List.send_list(coll, undefined, false, true, false);
db.collection(coll).update({views:{$exists:true}}, {$set:{startTime: get_time()}}); db.collection(coll).update({views:{$exists:true}}, {$set:{startTime: Functions.get_time()}});
send_play(coll, undefined); List.send_play(coll, undefined);
update_frontpage(coll, id, title); Frontpage.update_frontpage(coll, id, title);
} else { } else {
io.to(coll).emit("channel", {type: "added", value: {"_id": "asd", "added":added,"guids":guids,"id":id,"now_playing":np,"title":title,"votes":votes, "duration":duration}}); io.to(coll).emit("channel", {type: "added", value: {"_id": "asd", "added":added,"guids":guids,"id":id,"now_playing":np,"title":title,"votes":votes, "duration":duration}});
} }
db.collection("frontpage_lists").update({_id:coll}, {$inc:{count:1}, $set:{accessed: get_time()}}, {upsert:true}, function(err, docs){}); db.collection("frontpage_lists").update({_id:coll}, {$inc:{count:1}, $set:{accessed: Functions.get_time()}}, {upsert:true}, function(err, docs){});
getNextSong(coll); List.getNextSong(coll);
}); });
if(!full_list) { if(!full_list) {
socket.emit("toast", "addedsong"); socket.emit("toast", "addedsong");
@@ -98,7 +98,7 @@ function add_function(arr, coll, guid, offline, socket) {
} }
}); });
} else if(!full_list) { } else if(!full_list) {
vote(coll, id, guid, socket, full_list, last); ListChange.vote(coll, id, guid, socket, full_list, last);
if(full_list && last) { if(full_list && last) {
socket.emit("toast", "addedplaylist"); socket.emit("toast", "addedplaylist");
} }
@@ -110,7 +110,7 @@ function add_function(arr, coll, guid, offline, socket) {
db.collection(coll).find({id: id}, function(err, docs) { db.collection(coll).find({id: id}, function(err, docs) {
if(docs.length === 0) { if(docs.length === 0) {
db.collection(coll).update({id: id}, {$set:{ db.collection(coll).update({id: id}, {$set:{
"added":get_time(), "added":Functions.get_time(),
"guids": [guid], "guids": [guid],
"id":id, "id":id,
"now_playing": false, "now_playing": false,
@@ -126,7 +126,7 @@ function add_function(arr, coll, guid, offline, socket) {
} else if(docs[0].now_playing === true){ } else if(docs[0].now_playing === true){
socket.emit("toast", "alreadyplay"); socket.emit("toast", "alreadyplay");
} else{ } else{
if(conf[0].vote === false) vote(coll, id, guid, socket, full_list, last); if(conf[0].vote === false) ListChange.vote(coll, id, guid, socket, full_list, last);
else socket.emit("toast", "listhaspass"); else socket.emit("toast", "listhaspass");
} }
}); });
@@ -155,21 +155,21 @@ function voteUndecided(msg, coll, guid, offline, socket) {
} }
db.collection(coll).find({views:{$exists:true}}, function(err, docs){ db.collection(coll).find({views:{$exists:true}}, function(err, docs){
if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == decrypt_string(socketid, msg.pass)))) { if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == Functions.decrypt_string(socketid, msg.pass)))) {
check_inlist(coll, guid, socket, offline); Functions.check_inlist(coll, guid, socket, offline);
if(msg.type == "del") if(msg.type == "del")
del(msg, socket, socketid); ListChange.del(msg, socket, socketid);
else else
{ {
var id = msg.id; var id = msg.id;
var hash = hash_pass(decrypt_string(socketid, msg.adminpass)); var hash = Functions.hash_pass(Functions.decrypt_string(socketid, msg.adminpass));
db.collection(coll).find({views:{$exists:true}}, function(err, docs){ db.collection(coll).find({views:{$exists:true}}, function(err, docs){
if(docs !== null && docs.length !== 0 && ((docs[0].vote === true && (hash == docs[0].adminpass || docs[0].adminpass === "")) || if(docs !== null && docs.length !== 0 && ((docs[0].vote === true && (hash == docs[0].adminpass || docs[0].adminpass === "")) ||
docs[0].vote === false)) docs[0].vote === false))
{ {
vote(coll, id, guid, socket, false, false); ListChange.vote(coll, id, guid, socket, false, false);
}else{ }else{
socket.emit("toast", "listhaspass"); socket.emit("toast", "listhaspass");
} }
@@ -193,17 +193,17 @@ function shuffle(msg, coll, guid, offline, socket) {
return; return;
} }
check_inlist(coll, guid, socket, offline); Functions.check_inlist(coll, guid, socket, offline);
var hash; var hash;
if(msg.adminpass === "") hash = msg.adminpass; if(msg.adminpass === "") hash = msg.adminpass;
else hash = hash_pass(decrypt_string(socketid, msg.adminpass)); else hash = Functions.hash_pass(Functions.decrypt_string(socketid, msg.adminpass));
db.collection(coll).find({views:{$exists:true}}, function(err, docs){ db.collection(coll).find({views:{$exists:true}}, function(err, docs){
if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == decrypt_string(socketid, msg.pass)))) { if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == Functions.decrypt_string(socketid, msg.pass)))) {
if(docs !== null && docs.length !== 0 && ((docs[0].adminpass == hash || docs[0].adminpass === "") || docs[0].shuffle === false)) if(docs !== null && docs.length !== 0 && ((docs[0].adminpass == hash || docs[0].adminpass === "") || docs[0].shuffle === false))
{ {
db.collection(coll).find({now_playing:false}).forEach(function(err, docs){ db.collection(coll).find({now_playing:false}).forEach(function(err, docs){
if(!docs){ if(!docs){
send_list(coll, undefined, false, true, false, true); List.send_list(coll, undefined, false, true, false, true);
socket.emit("toast", "shuffled"); socket.emit("toast", "shuffled");
return; return;
@@ -222,8 +222,8 @@ function shuffle(msg, coll, guid, offline, socket) {
var complete = function(tot, curr){ var complete = function(tot, curr){
if(tot == curr) if(tot == curr)
{ {
send_list(coll, undefined, false, true, false); List.send_list(coll, undefined, false, true, false);
getNextSong(coll); List.getNextSong(coll);
} }
}; };
@@ -238,7 +238,7 @@ function del(params, socket, socketid) {
coll = encodeURIComponent(coll).replace(/\W/g, ''); coll = encodeURIComponent(coll).replace(/\W/g, '');
coll = filter.clean(coll); coll = filter.clean(coll);
db.collection(coll).find({views:{$exists:true}}, function(err, docs){ db.collection(coll).find({views:{$exists:true}}, function(err, docs){
if(docs !== null && docs.length !== 0 && docs[0].adminpass == hash_pass(decrypt_string(socketid, params.adminpass))) if(docs !== null && docs.length !== 0 && docs[0].adminpass == Functions.hash_pass(Functions.decrypt_string(socketid, params.adminpass)))
{ {
db.collection(coll).find({id:params.id}, function(err, docs){ db.collection(coll).find({id:params.id}, function(err, docs){
dont_increment = true; dont_increment = true;
@@ -249,7 +249,7 @@ function del(params, socket, socketid) {
db.collection(coll).remove({id:params.id}, function(err, docs){ db.collection(coll).remove({id:params.id}, function(err, docs){
socket.emit("toast", "deletesong"); socket.emit("toast", "deletesong");
io.to(coll).emit("channel", {type:"deleted", value: params.id}); io.to(coll).emit("channel", {type:"deleted", value: params.id});
if(dont_increment) db.collection("frontpage_lists").update({_id: coll}, {$inc: {count: -1}, $set:{accessed: get_time()}}, {upsert: true}, function(err, docs){}); if(dont_increment) db.collection("frontpage_lists").update({_id: coll}, {$inc: {count: -1}, $set:{accessed: Functions.get_time()}}, {upsert: true}, function(err, docs){});
}); });
} }
}); });
@@ -262,16 +262,16 @@ function del(params, socket, socketid) {
function delete_all(msg, coll, guid, offline, socket) { function delete_all(msg, coll, guid, offline, socket) {
var socketid = socket.zoff_id; var socketid = socket.zoff_id;
if(typeof(msg) == 'object' && msg.hasOwnProperty('channel') && msg.hasOwnProperty('adminpass') && msg.hasOwnProperty('pass')) { if(typeof(msg) == 'object' && msg.hasOwnProperty('channel') && msg.hasOwnProperty('adminpass') && msg.hasOwnProperty('pass')) {
var hash = hash_pass(decrypt_string(socketid, msg.adminpass)); var hash = Functions.hash_pass(Functions.decrypt_string(socketid, msg.adminpass));
var hash_userpass = decrypt_string(socketid, msg.pass); var hash_userpass = Functions.decrypt_string(socketid, msg.pass);
db.collection(coll).find({views: {$exists: true}}, function(err, conf) { db.collection(coll).find({views: {$exists: true}}, function(err, conf) {
if(conf.length == 1 && conf) { if(conf.length == 1 && conf) {
conf = conf[0]; conf = conf[0];
if(conf.adminpass == hash && conf.adminpass != "" && (conf.userpass == "" || conf.userpass == undefined || (conf.userpass != "" && conf.userpass != undefined && conf.pass == hash_userpass))) { if(conf.adminpass == hash && conf.adminpass != "" && (conf.userpass == "" || conf.userpass == undefined || (conf.userpass != "" && conf.userpass != undefined && conf.pass == hash_userpass))) {
db.collection(coll).remove({views: {$exists: false}}, {multi: true}, function(err, succ) { db.collection(coll).remove({views: {$exists: false}}, {multi: true}, function(err, succ) {
send_list(coll, false, true, true, true); List.send_list(coll, false, true, true, true);
db.collection("frontpage_lists").update({_id: coll}, {$set: {count: 0, accessed: get_time()}}, {upsert: true}, function(err, docs) {}); db.collection("frontpage_lists").update({_id: coll}, {$set: {count: 0, accessed: Functions.get_time()}}, {upsert: true}, function(err, docs) {});
socket.emit("toast", "deleted_songs"); socket.emit("toast", "deleted_songs");
}); });
} else { } else {
@@ -287,15 +287,15 @@ function delete_all(msg, coll, guid, offline, socket) {
function vote(coll, id, guid, socket, full_list, last) { function vote(coll, id, guid, socket, full_list, last) {
db.collection(coll).find({id:id, now_playing: false}, function(err, docs){ db.collection(coll).find({id:id, now_playing: false}, function(err, docs){
if(docs !== null && docs.length > 0 && !contains(docs[0].guids, guid)) if(docs !== null && docs.length > 0 && !Functions.contains(docs[0].guids, guid))
{ {
db.collection(coll).update({id:id}, {$inc:{votes:1}, $set:{added:get_time()}, $push :{guids: guid}}, function(err, docs) db.collection(coll).update({id:id}, {$inc:{votes:1}, $set:{added:Functions.get_time()}, $push :{guids: guid}}, function(err, docs)
{ {
if((full_list && last) || (!full_list)) if((full_list && last) || (!full_list))
socket.emit("toast", "voted"); socket.emit("toast", "voted");
io.to(coll).emit("channel", {type: "vote", value: id, time: get_time()}); io.to(coll).emit("channel", {type: "vote", value: id, time: Functions.get_time()});
getNextSong(coll); List.getNextSong(coll);
}); });
}else }else
{ {
@@ -303,3 +303,10 @@ function vote(coll, id, guid, socket, full_list, last) {
} }
}); });
} }
module.exports.add_function = add_function;
module.exports.voteUndecided = voteUndecided;
module.exports.shuffle = shuffle;
module.exports.del = del;
module.exports.delete_all = delete_all;
module.exports.vote = vote;

21
server/handlers/list_settings.js
View File

@@ -20,22 +20,22 @@ function password(inp, coll, guid, offline, socket) {
} }
uncrypted = pw; uncrypted = pw;
pw = decrypt_string(socket.zoff_id, pw); pw = Functions.decrypt_string(socket.zoff_id, pw);
check_inlist(coll, guid, socket, offline); Functions.check_inlist(coll, guid, socket, offline);
if(inp.oldpass) if(inp.oldpass)
{ {
opw = inp.oldpass; opw = inp.oldpass;
} }
opw = decrypt_string(socket.zoff_id, opw); opw = Functions.decrypt_string(socket.zoff_id, opw);
db.collection(coll).find({views:{$exists:true}}, function(err, docs){ db.collection(coll).find({views:{$exists:true}}, function(err, docs){
if(docs !== null && docs.length !== 0) if(docs !== null && docs.length !== 0)
{ {
if(docs[0].adminpass === "" || docs[0].adminpass == hash_pass(opw)) if(docs[0].adminpass === "" || docs[0].adminpass == Functions.hash_pass(opw))
{ {
db.collection(coll).update({views:{$exists:true}}, {$set:{adminpass:hash_pass(pw)}}, function(err, docs){ db.collection(coll).update({views:{$exists:true}}, {$set:{adminpass:Functions.hash_pass(pw)}}, function(err, docs){
if(inp.oldpass) if(inp.oldpass)
socket.emit("toast", "changedpass"); socket.emit("toast", "changedpass");
else else
@@ -82,7 +82,7 @@ function conf_function(params, coll, guid, offline, socket) {
return; return;
} }
check_inlist(coll, guid, socket, offline); Functions.check_inlist(coll, guid, socket, offline);
var voting = params.voting; var voting = params.voting;
var addsongs = params.addsongs; var addsongs = params.addsongs;
@@ -93,7 +93,7 @@ function conf_function(params, coll, guid, offline, socket) {
var adminpass = params.adminpass; var adminpass = params.adminpass;
var skipping = params.skipping; var skipping = params.skipping;
var shuffling = params.shuffling; var shuffling = params.shuffling;
var userpass = decrypt_string(socket.zoff_id, params.userpass); var userpass = Functions.decrypt_string(socket.zoff_id, params.userpass);
if((!params.userpass_changed && frontpage) || (params.userpass_changed && userpass == "")) { if((!params.userpass_changed && frontpage) || (params.userpass_changed && userpass == "")) {
userpass = ""; userpass = "";
@@ -105,7 +105,7 @@ function conf_function(params, coll, guid, offline, socket) {
if(params.description) description = params.description; if(params.description) description = params.description;
if(adminpass !== "") { if(adminpass !== "") {
hash = hash_pass(decrypt_string(socket.zoff_id, adminpass)); hash = Functions.hash_pass(Functions.decrypt_string(socket.zoff_id, adminpass));
} else { } else {
hash = adminpass; hash = adminpass;
} }
@@ -139,7 +139,7 @@ function conf_function(params, coll, guid, offline, socket) {
socket.emit("toast", "savedsettings"); socket.emit("toast", "savedsettings");
db.collection("frontpage_lists").update({_id: coll}, {$set:{ db.collection("frontpage_lists").update({_id: coll}, {$set:{
frontpage:frontpage, accessed: get_time()} frontpage:frontpage, accessed: Functions.get_time()}
}, },
{upsert:true}, function(err, docs){}); {upsert:true}, function(err, docs){});
}); });
@@ -152,3 +152,6 @@ function conf_function(params, coll, guid, offline, socket) {
socket.emit('update_required'); socket.emit('update_required');
} }
} }
module.exports.password = password;
module.exports.conf_function = conf_function;

125
server/handlers/server.js
View File

@@ -1,125 +0,0 @@
VERSION = 3;
var server;
var add = "";
const path = require('path');
const publicPath = path.join(__dirname, 'public');
pathThumbnails = __dirname;
var express = require('express');
var app = express();
var exphbs = require('express-handlebars');
var hbs = exphbs.create({
defaultLayout: publicPath + '/layouts/main',
layoutsDir: publicPath + '/layouts',
partialsDir: publicPath + '/partials'
});
var uniqid = require('uniqid');
var mongo_db_cred = {config: 'mydb'};
app.engine('handlebars', hbs.engine);
//hbs.loadPartials(publicPath + "/layouts/");
app.set('view engine', 'handlebars');
//app.enable('view cache');
app.set('views', publicPath);
try{
var fs = require('fs');
var privateKey = fs.readFileSync('/etc/letsencrypt/live/zoff.me-0002/privkey.pem').toString();
var certificate = fs.readFileSync('/etc/letsencrypt/live/zoff.me-0002/cert.pem').toString();
var ca = fs.readFileSync('/etc/letsencrypt/live/zoff.me-0002/chain.pem').toString();
var credentials = {
key: privateKey,
cert: certificate,
ca: ca
};
var https = require('https');
server = https.Server(credentials, app);
var cors_proxy = require('cors-anywhere');
cors_proxy.createServer({
requireHeader: ['origin', 'x-requested-with'],
removeHeaders: ['cookie', 'cookie2'],
httpsOptions: credentials
}).listen(8081, function() {
console.log('Running CORS Anywhere on :' + 8081);
});
}
catch(err){
console.log("Starting without https (probably on localhost)");
if(err.errno != 34)console.log(err);
var cors_proxy = require('cors-anywhere');
cors_proxy.createServer({
requireHeader: ['origin', 'x-requested-with'],
removeHeaders: ['cookie', 'cookie2'],
}).listen(8081, function() {
console.log('Running CORS Anywhere on :' + 8081);
});
var http = require('http');
server = http.Server(app);
add = ",http://localhost:80*,http://localhost:8080*,localhost:8080*, localhost:8082*,http://zoff.dev:80*,http://zoff.dev:8080*,zoff.dev:8080*, zoff.dev:8082*";
}
var bodyParser = require('body-parser');
var cookieParser = require('cookie-parser')
app.use( bodyParser.json() ); // to support JSON-encoded bodies
app.use(bodyParser.urlencoded({ // to support URL-encoded bodies
extended: true
}));
app.use(cookieParser());
/* Starting DB and socketio */
var io = require('socket.io')(server, {
pingTimeout: 25000,
}); //, "origins": ("https://zoff.me:443*,https://zoff.me:8080*,zoff.me:8080*,https://remote.zoff.me:443*,https://remote.zoff.me:8080*,https://fb.zoff.me:443*,https://fb.zoff.me:8080*,https://admin.zoff.me:443*,https://admin.zoff.me:8080*" + add)});
var request = require('request');
var uniqid = require('uniqid');
var crypto = require('crypto');
var node_cryptojs = require('node-cryptojs-aes');
var CryptoJS = node_cryptojs.CryptoJS;
var emojiStrip = require('emoji-strip');
var Filter = require('bad-words');
var filter = new Filter({ placeHolder: 'x'});
var router = require('./routing/router.js');
var port = 8080;
server.listen(port, function () {
console.log('Server listening at port %d', port);
});
app.get('/robots.txt', function (req, res) {
res.type('text/plain');
res.send("User-agent: *\nAllow: /$\nDisallow: /");
});
app.use(function (req, res, next) {
var cookie = req.cookies._uI;
if (cookie === undefined) {
var user_name = rndName(uniqid.time(), 15);
res.cookie('_uI',user_name, { maxAge: 365 * 10000 * 3600000 });
}
next();
});
app.use('/service-worker.js', function(req, res) {
res.sendFile(publicPath + '/service-worker.js');
});
app.use('/', router);
app.use('/assets', express.static(publicPath + '/assets'));
db.on('error',function(err) {
console.log("\n" + new Date().toString() + "\n Database error: ", err);
});
/* Resetting usernames, and connected users */
db.collection("unique_ids").update({"_id": "unique_ids"}, {$set: {unique_ids: []}}, {multi: true, upsert: true}, function(err, docs){});
db.collection("user_names").remove({"guid": {$exists: true}}, {multi: true, upsert: true}, function(err, docs){});
db.collection("user_names").update({"_id": "all_names"}, {$set: {names: []}}, {multi: true, upsert: true}, function(err, docs){});
db.collection("connected_users").update({users: {$exists: true}}, {$set: {users: []}}, {multi: true, upsert: true}, function(err, docs){});
db.collection("connected_users").update({"_id": "total_users"}, {$set: {total_users: 0}}, {multi: true, upsert: true}, function(err, docs) {});
db.collection("frontpage_lists").update({viewers: {$ne: 0}}, {$set: {"viewers": 0}}, {multi: true, upsert: true}, function(err, docs) {});

11
server/handlers/suggestions.js
View File

@@ -3,9 +3,9 @@ function thumbnail(msg, coll, guid, offline, socket) {
msg.thumbnail = msg.thumbnail.replace(/^https?\:\/\//i, ""); msg.thumbnail = msg.thumbnail.replace(/^https?\:\/\//i, "");
if(msg.thumbnail.substring(0,2) != "//") msg.thumbnail = "//" + msg.thumbnail; if(msg.thumbnail.substring(0,2) != "//") msg.thumbnail = "//" + msg.thumbnail;
var channel = msg.channel.toLowerCase(); var channel = msg.channel.toLowerCase();
var hash = hash_pass(decrypt_string(socket.zoff_id, msg.adminpass)); var hash = Functions.hash_pass(Functions.decrypt_string(socket.zoff_id, msg.adminpass));
db.collection(channel).find({views:{$exists:true}}, function(err, docs){ db.collection(channel).find({views:{$exists:true}}, function(err, docs){
if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == decrypt_string(socketid, msg.pass)))) { if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == Functions.decrypt_string(socketid, msg.pass)))) {
if(docs !== null && docs.length !== 0 && docs[0].adminpass !== "" && docs[0].adminpass == hash){ if(docs !== null && docs.length !== 0 && docs[0].adminpass !== "" && docs[0].adminpass == hash){
db.collection("suggested_thumbnails").update({channel: channel}, {$set:{thumbnail: msg.thumbnail}}, {upsert:true}, function(err, docs){ db.collection("suggested_thumbnails").update({channel: channel}, {$set:{thumbnail: msg.thumbnail}}, {upsert:true}, function(err, docs){
socket.emit("toast", "suggested_thumbnail"); socket.emit("toast", "suggested_thumbnail");
@@ -23,9 +23,9 @@ function thumbnail(msg, coll, guid, offline, socket) {
function description(msg, coll, guid, offline, socket) { function description(msg, coll, guid, offline, socket) {
if(msg.description && msg.channel && msg.adminpass && msg.description.length < 100){ if(msg.description && msg.channel && msg.adminpass && msg.description.length < 100){
var channel = msg.channel.toLowerCase(); var channel = msg.channel.toLowerCase();
var hash = hash_pass(decrypt_string(socket.zoff_id, msg.adminpass)); var hash = Functions.hash_pass(Functions.decrypt_string(socket.zoff_id, msg.adminpass));
db.collection(channel).find({views:{$exists:true}}, function(err, docs){ db.collection(channel).find({views:{$exists:true}}, function(err, docs){
if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == decrypt_string(socketid, msg.pass)))) { if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == Functions.decrypt_string(socketid, msg.pass)))) {
if(docs !== null && docs.length !== 0 && docs[0].adminpass !== "" && docs[0].adminpass == hash){ if(docs !== null && docs.length !== 0 && docs[0].adminpass !== "" && docs[0].adminpass == hash){
db.collection("suggested_descriptions").update({channel: channel}, {$set:{description: msg.description}}, {upsert:true}, function(err, docs){ db.collection("suggested_descriptions").update({channel: channel}, {$set:{description: msg.description}}, {upsert:true}, function(err, docs){
socket.emit("toast", "suggested_description"); socket.emit("toast", "suggested_description");
@@ -39,3 +39,6 @@ function description(msg, coll, guid, offline, socket) {
socket.emit("toast", "description_denied"); socket.emit("toast", "description_denied");
} }
} }
module.exports.thumbnail = thumbnail;
module.exports.description = description;

1716
server/index.js Normal file → Executable file
View File

File diff suppressed because it is too large Load Diff