function addFromOtherList(arr, guid, offline, socket) { var socketid = socket.zoff_id; if(typeof(arr) == "object") { if(!arr.hasOwnProperty("channel") || !arr.hasOwnProperty("new_channel") || typeof(arr.channel) != "string" || typeof(arr.new_channel) != "string") { var result = { channel: { expected: "string", got: arr.hasOwnProperty("channel") ? typeof(arr.channel) : undefined }, new_channel: { expected: "string", got: arr.hasOwnProperty("new_channel") ? typeof(arr.new_channel) : undefined } }; socket.emit('update_required', result); return; } var channel = arr.channel.replace(/ /g,'').toLowerCase(); var new_channel = arr.new_channel.replace(/ /g, '').toLowerCase(); db.collection("frontpage_lists").find({_id: new_channel}, function(err, fp) { if(fp.length == 0) { socket.emit("toast", "nolist"); return; } Functions.getSessionAdminUser(Functions.getSession(socket), channel, function(userpass, adminpass) { if(userpass != "" || arr.userpass == undefined) { arr.userpass = userpass; } if(adminpass != "" || arr.adminpass == undefined) { arr.adminpass = adminpass; } Functions.getSessionAdminUser(Functions.getSession(socket), new_channel, function(userpass) { var otheruser = ""; if(userpass != "") { otheruser = userpass; } db.collection(channel).find({now_playing: true}, function(e, np) { var project_object = { "id": 1, "added": 1, "guids": { "$literal": [] }, "now_playing": 1, "title": 1, "votes": { "$literal": 0 }, "start": 1, "duration": 1, "end": 1, "type": 1 }; var to_set_np = true; if(np.length > 0) { project_object.now_playing = { "$literal": false }; to_set_np = false; } db.collection(new_channel + "_settings").find({id: "config"}, function(e, new_conf) { if(new_conf.length > 0 && (new_conf[0].userpass == "" || !new_conf[0].userpass || new_conf[0].userpass == crypto.createHash('sha256').update(Functions.decrypt_string(socketid, otheruser)).digest("base64"))) { db.collection(channel + "_settings").find({id: "config"}, function(e, this_conf) { var hash = Functions.hash_pass(Functions.hash_pass(Functions.decrypt_string(socketid, arr.adminpass), true)); if((this_conf[0].userpass == "" || !this_conf[0].userpass || this_conf[0].userpass == crypto.createHash('sha256').update(Functions.decrypt_string(socketid, arr.userpass)).digest("base64"))) { if(((this_conf[0].addsongs === true && (hash == this_conf[0].adminpass || this_conf[0].adminpass === "")) || this_conf[0].addsongs === false)) { db.collection(new_channel).aggregate([ { "$match": { type: "video" } }, { "$project": project_object } ], function(e, docs) { var path = require('path'); var mongo_config = require(path.join(path.join(__dirname, '../config/'), 'mongo_config.js')); var MongoClient = require('mongodb').MongoClient; var url = "mongodb://" + mongo_config.host + ":" + mongo_config.port + "/"; MongoClient.connect(url, function(err, _db) { var dbo = _db.db(mongo_config.config); dbo.collection(channel).insertMany(docs, {ordered: false}, function(err, res) { db.collection(channel + "_settings").update({id: "config"}, {$set: {startTime: Functions.get_time()}}, function(e,d) { if(to_set_np) { var to_change = { _id: channel, count: res.nInserted != undefined ? res.nInserted : res.insertedCount, frontpage: true, accessed: Functions.get_time(), } db.collection(channel).find({now_playing: true}, function(e, np_docs) { to_change.id = np_docs[0].id; to_change.title = np_docs[0].title; db.collection("frontpage_lists").update({_id: channel}, {$set: to_change}, function(e, d) { List.send_list(channel, undefined, false, true, false); List.send_play(channel, undefined); socket.emit("toast", "addedplaylist"); _db.close(); }); }); } else { db.collection("frontpage_lists").update({_id: channel}, {$inc: {count: res.nInserted != undefined ? res.nInserted : res.insertedCount}}, function(e, d) { List.send_list(channel, undefined, false, true, false); List.send_play(channel, undefined); socket.emit("toast", "addedplaylist"); _db.close(); }) } }); }); }); }); } else { socket.emit("toast", "listhaspass"); return; } } else { socket.emit("auth_required"); return; } }) } else { socket.emit("toast", "other_list_pass"); return; } }) }); }); }); }); } } function addPlaylist(arr, guid, offline, socket) { var socketid = socket.zoff_id; if(typeof(arr) == "object") { if(!arr.hasOwnProperty("channel") || !arr.hasOwnProperty("songs") || typeof(arr.channel) != "string" || typeof(arr.songs) != "object") { var result = { channel: { expected: "string", got: arr.hasOwnProperty("channel") ? typeof(arr.channel) : undefined }, songs: { expected: "object", got: arr.hasOwnProperty("songs") ? typeof(arr.songs) : undefined } }; socket.emit('update_required', result); return; } var channel = arr.channel.replace(/ /g,'').toLowerCase(); db.collection("frontpage_lists").find({_id: channel}, function(err, fp) { if(fp.length == 0) { socket.emit("toast", "nolist"); return; } Functions.getSessionAdminUser(Functions.getSession(socket), channel, function(userpass, adminpass) { if(userpass != "" || arr.userpass == undefined) { arr.userpass = userpass; } if(adminpass != "" || arr.adminpass == undefined) { arr.adminpass = adminpass; } db.collection(channel).find({now_playing: true}, function(e, np) { var now_playing = false; if(np.length == 0) now_playing = true; db.collection(channel + "_settings").find({id: "config"}, function(e, conf) { if(conf.length > 0) { var hash = Functions.hash_pass(Functions.hash_pass(Functions.decrypt_string(socketid, arr.adminpass), true)); if((conf[0].userpass == "" || !conf[0].userpass || conf[0].userpass == crypto.createHash('sha256').update(Functions.decrypt_string(socketid, arr.userpass)).digest("base64"))) { if(((conf[0].addsongs === true && (hash == conf[0].adminpass || conf[0].adminpass === "")) || conf[0].addsongs === false)) { var path = require('path'); var mongo_config = require(path.join(path.join(__dirname, '../config/'), 'mongo_config.js')); var MongoClient = require('mongodb').MongoClient; var url = "mongodb://" + mongo_config.host + ":" + mongo_config.port + "/"; MongoClient.connect(url, function(err, _db) { var dbo = _db.db(mongo_config.config); var number_elements = arr.songs.length + 1; var time = Functions.get_time() - number_elements; var to_set_np = now_playing; var bulk = dbo.collection(channel).initializeUnorderedBulkOp({useLegacyOps: true}); for(var i = 0; i < arr.songs.length; i++) { var this_element = arr.songs[i]; if(!this_element.hasOwnProperty("duration") || !this_element.hasOwnProperty("id") || !this_element.hasOwnProperty("title")) { continue; } this_element.added = time; this_element.now_playing = now_playing; this_element.votes = 0; this_element.guids = []; if(!this_element.hasOwnProperty("start")) this_element.start = 0; if(!this_element.hasOwnProperty("end")) this_element.end = this_element.duration; this_element.start = parseInt(this_element.start); this_element.end = parseInt(this_element.end); this_element.duration = parseInt(this_element.duration); if(this_element.start > this_element.end) { this_element.start = 0; } if(now_playing) { now_playing = false; } bulk.insert(this_element); } bulk.execute(function(err, results) { db.collection(channel + "_settings").update({id: "config"}, {$set: {startTime: Functions.get_time()}}, function(e,d) { if(to_set_np) { var to_change = { _id: channel, count: results.nInserted, frontpage: true, accessed: Functions.get_time(), } db.collection(channel).find({now_playing: true}, function(e, np_docs) { to_change.id = np_docs[0].id; to_change.title = np_docs[0].title; db.collection("frontpage_lists").update({_id: channel}, {$set: to_change}, function(e, d) { List.send_list(channel, undefined, false, true, false); List.send_play(channel, undefined); socket.emit("toast", "addedplaylist"); _db.close(); }); }); } else { db.collection("frontpage_lists").update({_id: channel}, {$inc: {count: results.nInserted != undefined ? results.nInserted : results.insertedCount}}, function(e, d) { List.send_list(channel, undefined, false, true, false); List.send_play(channel, undefined); socket.emit("toast", "addedplaylist"); _db.close(); }) } }); }); }); } else { socket.emit("toast", "listhaspass"); return; } } else { socket.emit("auth_required"); return; } } else { socket.emit("toast", "nolist"); return; } }) }); }); }); } } function add_function(arr, coll, guid, offline, socket) { var socketid = socket.zoff_id; if(typeof(arr) === 'object' && arr !== undefined && arr !== null && arr !== "" && !isNaN(parseInt(arr.duration))) { if(coll == "" || coll == undefined || coll == null || !arr.hasOwnProperty("start") || !arr.hasOwnProperty("end")) { var result = { start: { expected: "number or string that can be cast to int", got: arr.hasOwnProperty("start") ? typeof(arr.start) : undefined }, end: { expected: "number or string that can be cast to int", got: arr.hasOwnProperty("end") ? typeof(arr.end) : undefined } }; socket.emit('update_required', result); return; } try { var start = parseInt(arr.start); var end = parseInt(arr.end); if(start < 0) { socket.emit("toast", "faulty_start_end"); return; } if(end < 0) { socket.emit("toast", "faulty_start_end"); return; } if(start >= end) { start = 0; arr.duration = end - start; } } catch(e) { return; } if(typeof(arr.id) != "string" || typeof(arr.start) != "number" || typeof(arr.end) != "number" || typeof(arr.title) != "string" || typeof(arr.list) != "string" || typeof(arr.duration) != "number") { var result = { start: { expected: "number or string that can be cast to int", got: arr.hasOwnProperty("start") ? typeof(arr.start) : undefined }, end: { expected: "number or string that can be cast to int", got: arr.hasOwnProperty("end") ? typeof(arr.end) : undefined }, title: { expected: "string", got: arr.hasOwnProperty("title") ? typeof(arr.title) : undefined }, list: { expected: "string", got: arr.hasOwnProperty("list") ? typeof(arr.list) : undefined }, duration: { expected: "number or string that can be cast to int", got: arr.hasOwnProperty("duration") ? typeof(arr.duration) : undefined }, pass: { expected: "string", got: arr.hasOwnProperty("pass") ? typeof(arr.pass) : undefined }, adminpass: { expected: "string", got: arr.hasOwnProperty("adminpass") ? typeof(arr.adminpass) : undefined } }; socket.emit('update_required', result); return; } coll = coll.replace(/ /g,''); Functions.getSessionAdminUser(Functions.getSession(socket), coll, function(userpass, adminpass) { if(adminpass != "" || arr.adminpass == undefined) { arr.adminpass = adminpass; } if(userpass != "" || arr.userpass == undefined) { arr.userpass = userpass; } db.collection(coll + "_settings").find(function(err, docs){ if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (arr.hasOwnProperty('pass') && docs[0].userpass == crypto.createHash('sha256').update(Functions.decrypt_string(socketid, arr.pass)).digest("base64")))) { Functions.check_inlist(coll, guid, socket, offline); var id = arr.id; var title = arr.title; var hash = Functions.hash_pass(Functions.hash_pass(Functions.decrypt_string(socketid, arr.adminpass), true)); var duration = parseInt(arr.duration); /*db.collection(coll + "_settings").find(function(err, docs) {*/ conf = docs; if(docs !== null && docs.length !== 0 && ((docs[0].addsongs === true && (hash == docs[0].adminpass || docs[0].adminpass === "")) || docs[0].addsongs === false)) { db.collection(coll).find({id:id, type:{$ne:"suggested"}}, function(err, docs){ if(docs !== null && docs.length === 0) { var guids = [guid]; var added = Functions.get_time(); var votes = 1; db.collection(coll).find({now_playing:true}, function(err, docs){ if((docs !== null && docs.length === 0)){ np = true; } else { np = false; } var new_song = {"added": added,"guids":guids,"id":id,"now_playing":np,"title":title,"votes":votes, "duration":duration, "start": parseInt(start), "end": parseInt(end), "type": "video"}; db.collection(coll).update({id: id}, new_song, {upsert: true}, function(err, docs){ new_song._id = "asd"; if(np) { List.send_list(coll, undefined, false, true, false); db.collection(coll + "_settings").update({ id: "config" }, {$set:{startTime: Functions.get_time()}}); List.send_play(coll, undefined); Frontpage.update_frontpage(coll, id, title); Search.get_correct_info(new_song, coll, false); } else { io.to(coll).emit("channel", {type: "added", value: new_song}); Search.get_correct_info(new_song, coll, true); } db.collection("frontpage_lists").update({_id:coll}, {$inc:{count:1}, $set:{accessed: Functions.get_time()}}, {upsert:true}, function(err, docs){}); List.getNextSong(coll); }); socket.emit("toast", "addedsong"); }); } else { ListChange.vote(coll, id, guid, socket); } }); } else { db.collection(coll).find({id: id}, function(err, docs) { if(docs.length === 0) { db.collection(coll).update({id: id}, {$set:{ "added":Functions.get_time(), "guids": [guid], "id":id, "now_playing": false, "title":title, "votes":1, "duration":duration, "start": start, "end": end, "type":"suggested"} }, {upsert:true}, function(err, docs){ socket.emit("toast", "suggested"); io.to(coll).emit("suggested", {id: id, title: title, duration: duration}); }); } else if(docs[0].now_playing === true){ socket.emit("toast", "alreadyplay"); } else{ if(conf[0].vote === false) ListChange.vote(coll, id, guid, socket); else socket.emit("toast", "listhaspass"); } }); } //}); } else { socket.emit("auth_required"); } }); }); } else { var result = { arr: { expected: "object", got: typeof(arr) }, duration: { expected: "number or string that can be cast to int", got: arr.hasOwnProperty("duration") ? typeof(arr.duration) : undefined, } }; socket.emit('update_required', result); } } function voteUndecided(msg, coll, guid, offline, socket) { var socketid = socket.zoff_id; if(typeof(msg) === 'object' && msg !== undefined && msg !== null){ if(!msg.hasOwnProperty("channel") || !msg.hasOwnProperty("id") || !msg.hasOwnProperty("type") || typeof(msg.channel) != "string" || typeof(msg.id) != "string" || typeof(msg.type) != "string") { var result = { channel: { expected: "string", got: msg.hasOwnProperty("channel") ? typeof(msg.channel) : undefined, }, id: { expected: "string", got: msg.hasOwnProperty("id") ? typeof(msg.id) : undefined, }, type: { expected: "string", got: msg.hasOwnProperty("type") ? typeof(msg.type) : undefined, }, adminpass: { expected: "adminpass", got: msg.hasOwnProperty("adminpass") ? typeof(msg.adminpass) : undefined, }, pass: { expected: "string", got: msg.hasOwnProperty("pass") ? typeof(msg.pass) : undefined, }, }; socket.emit('update_required', result); return; } coll = msg.channel.toLowerCase().replace(/ /g,''); Functions.getSessionAdminUser(Functions.getSession(socket), coll, function(userpass, adminpass) { if(adminpass != "" || msg.adminpass == undefined) { msg.adminpass = adminpass; } if(userpass != "" || msg.pass == undefined) { msg.pass = userpass; } db.collection(coll + "_settings").find({id: "config"}, function(err, docs){ if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == crypto.createHash('sha256').update(Functions.decrypt_string(socketid, msg.pass)).digest("base64")))) { Functions.check_inlist(coll, guid, socket, offline); if(msg.type == "del") { ListChange.del(msg, socket, socketid); } else { var id = msg.id; var hash = Functions.hash_pass(Functions.hash_pass(Functions.decrypt_string(socketid, msg.adminpass), true)); if(docs !== null && docs.length !== 0 && ((docs[0].vote === true && (hash == docs[0].adminpass || docs[0].adminpass === "")) || docs[0].vote === false)) { ListChange.vote(coll, id, guid, socket); } else { socket.emit("toast", "listhaspass"); } } } else { socket.emit("auth_required"); } }); }); } else { var result = { msg: { expected: "object", got: typeof(msg) } }; socket.emit('update_required', result); } } function shuffle(msg, coll, guid, offline, socket) { var socketid = socket.zoff_id; if(!msg.hasOwnProperty("channel") || typeof(msg.channel) != "string") { var result = { channel: { expected: "string", got: msg.hasOwnProperty("channel") ? typeof(msg.channel) : undefined, }, adminpass: { expected: "string", got: msg.hasOwnProperty("adminpass") ? typeof(msg.adminpass) : undefined, }, pass: { expected: "string", got: msg.hasOwnProperty("pass") ? typeof(msg.pass) : undefined, }, }; socket.emit('update_required', result); return; } coll = msg.channel.toLowerCase().replace(/ /g,''); Functions.getSessionAdminUser(Functions.getSession(socket), coll, function(userpass, adminpass) { if(adminpass != "" || msg.adminpass == undefined) { msg.adminpass = adminpass; } if(userpass != "" || msg.pass == undefined) { msg.pass = userpass; } db.collection("timeout_api").find({ type: "shuffle", guid: coll, }, function(err, docs) { if(docs.length > 0) { var date = new Date(docs[0].createdAt); date.setSeconds(date.getSeconds() + 5); var now = new Date(); var retry_in = (date.getTime() - now.getTime()) / 1000; if(retry_in > 0) { socket.emit("toast", "wait_longer"); return; } } var now_date = new Date(); db.collection("timeout_api").update({type: "shuffle", guid: coll}, { $set: { "createdAt": now_date, type: "shuffle", guid: coll, }, }, {upsert: true}, function(err, docs) { Functions.check_inlist(coll, guid, socket, offline); var hash; if(msg.adminpass === "") hash = msg.adminpass; else hash = Functions.hash_pass(Functions.hash_pass(Functions.decrypt_string(socketid, msg.adminpass),true)); db.collection(coll + "_settings").find(function(err, docs){ if(docs.length > 0 && (docs[0].userpass == undefined || docs[0].userpass == "" || (msg.hasOwnProperty('pass') && docs[0].userpass == crypto.createHash('sha256').update(Functions.decrypt_string(socketid, msg.pass)).digest("base64")))) { 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){ if(!docs){ List.send_list(coll, undefined, false, true, false, true); socket.emit("toast", "shuffled"); return; }else{ num = Math.floor(Math.random()*1000000); db.collection(coll).update({id:docs.id}, {$set:{added:num}}); } }); }else socket.emit("toast", "wrongpass"); } else { socket.emit("auth_required"); } }); var complete = function(tot, curr){ if(tot == curr) { List.send_list(coll, undefined, false, true, false); List.getNextSong(coll); } }; }); }); }); } function del(params, socket, socketid) { if(params.id){ var coll = emojiStrip(params.channel).toLowerCase(); coll = coll.replace("_", "").replace(/ /g,''); coll = encodeURIComponent(coll).replace(/\W/g, ''); coll = filter.clean(coll); db.collection(coll + "_settings").find(function(err, docs){ if(docs !== null && docs.length !== 0 && docs[0].adminpass == Functions.hash_pass(Functions.hash_pass(Functions.decrypt_string(socketid, params.adminpass),true))) { db.collection(coll).find({id:params.id}, function(err, docs){ var dont_increment = false; if(docs[0]){ if(docs[0].type == "suggested"){ dont_increment = true; } db.collection(coll).remove({id:params.id}, function(err, docs){ socket.emit("toast", "deletesong"); io.to(coll).emit("channel", {type:"deleted", value: params.id}); if(!dont_increment) db.collection("frontpage_lists").update({_id: coll, count: {$gt: 0}}, {$inc: {count: -1}, $set:{accessed: Functions.get_time()}}, {upsert: true}, function(err, docs){}); }); } }); } }); } } function delete_all(msg, coll, guid, offline, socket) { var socketid = socket.zoff_id; if(typeof(msg) == 'object' ) { if(!msg.hasOwnProperty('channel') || typeof(msg.channel) != "string") { var result = { channel: { expected: "string", got: msg.hasOwnProperty("channel") ? typeof(msg.channel) : undefined, }, adminpass: { expected: "adminpass", got: msg.hasOwnProperty("adminpass") ? typeof(msg.adminpass) : undefined, }, pass: { expected: "string", got: msg.hasOwnProperty("pass") ? typeof(msg.pass) : undefined, }, }; socket.emit('update_required', result); return; } coll = coll.replace(/ /g,''); Functions.getSessionAdminUser(Functions.getSession(socket), coll, function(userpass, adminpass, gotten) { if(adminpass != "" || msg.adminpass == undefined) { msg.adminpass = adminpass; } if(userpass != "" || msg.pass == undefined) { msg.pass = userpass; } var hash = Functions.hash_pass(Functions.hash_pass(Functions.decrypt_string(socketid, msg.adminpass),true)); var hash_userpass = crypto.createHash('sha256').update(Functions.decrypt_string(socketid, msg.pass)).digest("base64"); db.collection(coll + "_settings").find(function(err, conf) { if(conf.length == 1 && conf) { conf = conf[0]; 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) { List.send_list(coll, false, true, true, true); db.collection("frontpage_lists").update({_id: coll}, {$set: {count: 0, accessed: Functions.get_time()}}, {upsert: true}, function(err, docs) {}); socket.emit("toast", "deleted_songs"); }); } else { socket.emit("toast", "listhaspass"); } } }); }); } else { var result = { msg: { expected: "object", got: typeof(msg) }, }; socket.emit('update_required', result); return; } } function vote(coll, id, guid, socket) { coll = coll.replace(/ /g,''); db.collection(coll).find({id:id, now_playing: false, type:"video"}, function(err, docs){ if(docs !== null && docs.length > 0 && !Functions.contains(docs[0].guids, guid)) { db.collection(coll).update({id:id}, {$inc:{votes:1}, $set:{added:Functions.get_time()}, $push :{guids: guid}}, function(err, docs) { socket.emit("toast", "voted"); io.to(coll).emit("channel", {type: "vote", value: id, time: Functions.get_time()}); List.getNextSong(coll); }); }else { socket.emit("toast", "alreadyvoted"); } }); } module.exports.addPlaylist = addPlaylist; module.exports.addFromOtherList = addFromOtherList; 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;