mirror of
https://github.com/KevinMidboe/zoff.git
synced 2025-10-29 18:00:23 +00:00
770 lines
23 KiB
JavaScript
Executable File
770 lines
23 KiB
JavaScript
Executable File
var server;
|
||
/******
|
||
|
||
This if for the localhost running
|
||
|
||
******/
|
||
localhost = false;
|
||
|
||
//https server
|
||
if(localhost)
|
||
{
|
||
var http = require('http');
|
||
server = http.createServer(app);
|
||
}else
|
||
{
|
||
var fs = require('fs');
|
||
var privateKey = fs.readFileSync('/etc/apache2/ssl/private.key', 'utf8');
|
||
var certificate = fs.readFileSync('/etc/apache2/ssl/ssl.crt', 'utf8');
|
||
var credentials = {key: privateKey, cert: certificate};
|
||
var https = require('https');
|
||
server = https.createServer(credentials, app);
|
||
}
|
||
|
||
var express = require('express');
|
||
var app = express();
|
||
//var server = require('http').createServer(app);
|
||
var io = require('socket.io')(server);
|
||
var shortid = require('shortid');
|
||
|
||
//db
|
||
var mongojs = require('mongojs');
|
||
var db = mongojs.connect('mydb');
|
||
|
||
//crypto
|
||
var crypto = require('crypto');
|
||
|
||
var port = 3000;
|
||
var lists = [];
|
||
|
||
server.listen(port, function () {
|
||
console.log('Server listening at port %d', port);
|
||
});
|
||
|
||
process.on('uncaughtException', function(e){
|
||
console.log("\n" + new Date().toString() + "\n", e.stack || e);
|
||
process.exit(1);
|
||
})
|
||
|
||
db.on('error',function(err) {
|
||
console.log("\n" + new Date().toString() + "\n Database error: ", err);
|
||
});
|
||
|
||
io.on('connection', function(socket){
|
||
socket.emit("get_list");
|
||
|
||
var guid = hash_pass(socket.handshake.headers["user-agent"] + socket.handshake.address + socket.handshake.headers["accept-language"]).substring(0,8);
|
||
|
||
socket.on('ping', function() {
|
||
socket.emit("ok");
|
||
});
|
||
|
||
var coll;
|
||
//var guid;
|
||
var tot_lists = [];
|
||
var in_list = false;
|
||
var name = rndName(guid,8);
|
||
var short_id = shortid.generate();
|
||
|
||
socket.on('namechange', function(data)
|
||
{
|
||
if(name.length < 9 && name.indexOf(" ") == -1)
|
||
{
|
||
io.to(coll).emit('chat', [name, " changed name to " + data]);
|
||
io.sockets.emit('chat.all', [name ," changed name to " + data, coll]);
|
||
name = data;
|
||
}
|
||
});
|
||
|
||
socket.on('chat', function (data) {
|
||
check_inlist(coll, guid, socket, name);
|
||
if(data != "" && data !== undefined && data !== null && data.length < 151 && data.replace(/\s/g, '').length)
|
||
io.to(coll).emit('chat', [name, ": " + data]);
|
||
});
|
||
|
||
socket.on("all,chat", function(data)
|
||
{
|
||
check_inlist(coll, guid, socket, name);
|
||
if(data != "" && data !== undefined && data !== null && data.length < 151 && data.replace(/\s/g, '').length)
|
||
io.sockets.emit('chat.all', [name, ": " + data, coll]);
|
||
});
|
||
|
||
socket.on('frontpage_lists', function()
|
||
{
|
||
var playlists_to_send = [];
|
||
var i = 0;
|
||
var playlists_to_send = [];
|
||
in_list = false;
|
||
|
||
db.getCollectionNames(function(err, colNames){
|
||
colNames.forEach(function(name){
|
||
if(name != "system.indexes")
|
||
{
|
||
db.collection(name).find({views:{$exists:true}}, function(err, conf){
|
||
db.collection(name).count(function(err, num){
|
||
db.collection(name).find({now_playing:true}, function(err, np){
|
||
complete(np, i, colNames.length-2, name, num-1, conf);
|
||
i++;
|
||
});
|
||
});
|
||
});
|
||
}
|
||
});
|
||
});
|
||
|
||
var complete = function(list, curr, tot, name, count, conf)
|
||
{
|
||
if(list.length > 0)
|
||
{
|
||
var id = list[0]["id"];
|
||
var title = list[0]["title"];
|
||
try{
|
||
var viewers = lists[name].length;
|
||
}catch(err){var viewers = 0;}
|
||
var to_push = [viewers, id, title, name, count];
|
||
if(conf[0]["frontpage"])
|
||
playlists_to_send.push(to_push);
|
||
}
|
||
if(curr == tot)
|
||
{
|
||
socket.emit("playlists", playlists_to_send);
|
||
}
|
||
}
|
||
});
|
||
|
||
socket.on('now_playing', function(list)
|
||
{
|
||
db.collection(list).find({now_playing:true}, function(err, docs)
|
||
{
|
||
var title = docs[0]["title"];
|
||
socket.emit("title", title);
|
||
});
|
||
});
|
||
|
||
socket.on('id', function(arr)
|
||
{
|
||
|
||
if(arr.length == 3)
|
||
io.to(arr[0]).emit(arr[0], [arr[1], arr[2]]);
|
||
});
|
||
|
||
socket.on('list', function(list)
|
||
{
|
||
if(list !== undefined && list !== null && list != "")
|
||
{
|
||
in_list = true;
|
||
list = list.split(',');
|
||
coll = list[0].toLowerCase();
|
||
socket.join(coll);
|
||
socket.join(short_id);
|
||
socket.emit("id", short_id);
|
||
|
||
//console.log(name + " joined list " + coll);
|
||
|
||
check_inlist(coll, guid, socket, name);
|
||
|
||
//io.sockets.emit(coll+",viewers", lists[coll].length);
|
||
io.to(coll).emit("viewers", lists[coll].length);
|
||
|
||
db.getCollectionNames(function(err, docs){
|
||
|
||
if(contains(docs, coll))
|
||
{
|
||
send_list(coll, socket, true, false);
|
||
}else
|
||
{
|
||
db.createCollection(coll, function(err, docs){
|
||
db.collection(coll).insert({"addsongs":false, "adminpass":"", "allvideos":false, "frontpage":true, "longsongs":false, "removeplay": false, "shuffle": true, "skip": false, "skips": [], "startTime":get_time(), "views": [], "vote": false}, function(err, docs)
|
||
{
|
||
send_list(coll, socket, true, false);
|
||
/*db.collection(coll).find().sort({votes:-1}, function(err, docs) {
|
||
socket.emit(coll, docs);
|
||
//send_play(coll, socket);
|
||
});*/
|
||
});
|
||
});
|
||
}
|
||
});
|
||
}
|
||
});
|
||
|
||
socket.on('end', function(id)
|
||
{
|
||
if(id !== undefined && id !== null && id != "")
|
||
{
|
||
check_inlist(coll, guid, socket, name);
|
||
|
||
db.collection(coll).find({now_playing:true}, function(err, np){
|
||
//console.log(docs);
|
||
if(err !== null) console.log(err);
|
||
//console.log(docs.length);
|
||
if(np !== null && np !== undefined && np.length == 1 && np[0]["id"] == id){
|
||
db.collection(coll).find({views:{$exists:true}}, function(err, docs){
|
||
var startTime = docs[0]["startTime"];
|
||
if(docs[0]["removeplay"] == true)
|
||
{
|
||
db.collection(coll).remove({now_playing:true}, function(err, docs)
|
||
{
|
||
change_song_post(coll);
|
||
})
|
||
}else
|
||
{
|
||
//console.log(np[0]["title"] + " before if");
|
||
if(startTime+parseInt(np[0]["duration"])<=get_time()+2)
|
||
{
|
||
//console.log(np[0]["title"] + " after if");
|
||
db.collection(coll).update({now_playing:true, id:id},
|
||
{$set:{
|
||
now_playing:false,
|
||
votes:0,
|
||
guids:[]
|
||
}}, function(err, docs)
|
||
{
|
||
//console.log(err);
|
||
//console.log(docs["n"]);
|
||
if(docs["n"] == 1)
|
||
{
|
||
db.collection(coll).aggregate([
|
||
{$match:{now_playing:false}},
|
||
{$sort:{votes:-1, added:1}},
|
||
{$limit:1}], function(err, docs){
|
||
if(docs !== null && docs.length > 0){
|
||
db.collection(coll).update({id:docs[0]["id"]},
|
||
{$set:{
|
||
now_playing:true,
|
||
votes:0,
|
||
guids:[],
|
||
added:get_time()}}, function(err, docs){
|
||
db.collection(coll).update({views:{$exists:true}},
|
||
{$set:{startTime:get_time(), skips:[]}}, function(err, docs){
|
||
//io.sockets.emit(coll, ["song_change", get_time()]);
|
||
io.to(coll).emit(coll, ["song_change", get_time()]);
|
||
send_play(coll);
|
||
});
|
||
});
|
||
}
|
||
});
|
||
}
|
||
|
||
});
|
||
|
||
}
|
||
}
|
||
});
|
||
}
|
||
});
|
||
}
|
||
});
|
||
|
||
socket.on('add', function(arr)
|
||
{
|
||
if(arr !== undefined && arr !== null && arr != "")
|
||
{
|
||
if(arr.length == 5) coll = arr[4];
|
||
else check_inlist(coll, guid, socket, name);
|
||
|
||
var id = arr[0];
|
||
var title = arr[1];
|
||
var hash = hash_pass(arr[2]);
|
||
var duration = parseInt(arr[3]);
|
||
db.collection(coll).find({views:{$exists:true}}, function(err, 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}, function(err, docs){
|
||
if(docs !== null && docs.length == 0)
|
||
{
|
||
var guids = [guid];
|
||
var votes = 1;
|
||
//var guids = [];
|
||
//var votes = 0;
|
||
db.collection(coll).find({now_playing:true}, function(err, docs){
|
||
if(docs !== null && docs.length == 0)
|
||
np = true;
|
||
else
|
||
np = false;
|
||
db.collection(coll).insert({"added":get_time(),"guids":guids,"id":id,"now_playing":np,"title":title,"votes":votes, "duration":duration}, function(err, docs){
|
||
//io.sockets.emit(coll, ["added", {"_id": "asd", "added":get_time(),"guids":guids,"id":id,"now_playing":np,"title":title,"votes":votes, "duration":duration}]);
|
||
//io.sockets.emit(coll, ["added", {"_id": "asd", "added":get_time(),"guids":guids,"id":id,"now_playing":np,"title":title,"votes":votes, "duration":duration}]);
|
||
io.to(coll).emit(coll, ["added", {"_id": "asd", "added":get_time(),"guids":guids,"id":id,"now_playing":np,"title":title,"votes":votes, "duration":duration}]);
|
||
|
||
if(np)
|
||
{
|
||
send_play(coll, undefined);
|
||
//io.sockets.emit(coll, ["song_change", get_time()]);
|
||
io.to(coll).emit(coll, ["song_change", get_time()]);
|
||
}
|
||
//sort_list(coll, undefined, np, true);
|
||
});
|
||
});
|
||
}else{
|
||
vote(coll, id, guid, socket);
|
||
}
|
||
});
|
||
}else
|
||
socket.emit("toast", "listhaspass");
|
||
});
|
||
}
|
||
});
|
||
|
||
socket.on('vote', function(msg)
|
||
{
|
||
if(msg !== undefined && msg !== null)
|
||
{
|
||
check_inlist(coll, guid, socket, name);
|
||
|
||
if(msg[2] == "del")
|
||
del(msg, socket);
|
||
else
|
||
{
|
||
var id = msg[1];
|
||
//guid = msg[3];
|
||
var hash = hash_pass(msg[4]);
|
||
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"] == ""))
|
||
|| docs[0]["vote"] == false))
|
||
{
|
||
vote(coll, id, guid, socket);
|
||
}else{
|
||
socket.emit("toast", "listhaspass");
|
||
}
|
||
});
|
||
}
|
||
}
|
||
});
|
||
|
||
socket.on('password', function(inp)
|
||
{
|
||
if(inp !== undefined && inp !== null && inp != "" && inp.length == 3)
|
||
{
|
||
pw = inp[0];
|
||
coll = inp[1];
|
||
//guid = inp[2];
|
||
check_inlist(coll, guid, socket, name);
|
||
|
||
//console.log(coll);
|
||
db.collection(coll).find({views:{$exists:true}}, function(err, docs){
|
||
//console.log(docs);
|
||
//console.log(docs + " yy here?");
|
||
if(docs !== null && docs.length != 0)
|
||
{
|
||
if(docs[0]["adminpass"] == "" || docs[0]["adminpass"] == hash_pass(pw))
|
||
{
|
||
db.collection(coll).update({views:{$exists:true}}, {$set:{adminpass:hash_pass(pw)}}, function(err, docs)
|
||
{
|
||
socket.emit("pw", pw);
|
||
})
|
||
}else
|
||
socket.emit("toast", "wrongpass");
|
||
}
|
||
});
|
||
}
|
||
});
|
||
|
||
socket.on('skip', function(list)
|
||
{
|
||
if(list !== undefined && list !== null && list != "")
|
||
{
|
||
check_inlist(coll, guid, socket, name);
|
||
|
||
adminpass = "";
|
||
|
||
var error = false;
|
||
if(list != "5" && list != "100" && list != "101" && list != "150" && list !== undefined)
|
||
{
|
||
adminpass = list[2];
|
||
}else if(list == "5" || list == "100" || list == "101" || list == "150"){
|
||
error = true;
|
||
}
|
||
|
||
//console.log(adminpass);
|
||
|
||
if(adminpass !== undefined && adminpass !== null && adminpass != "")
|
||
var hash = hash_pass(adminpass);
|
||
else
|
||
var hash = "";
|
||
|
||
db.collection(coll).find({views: {$exists:true}}, function(err, docs){
|
||
//console.log(adminpass);
|
||
//console.log(docs[0]["adminpass"]);
|
||
//console.log(error);
|
||
if(docs !== null && docs.length != 0)
|
||
{
|
||
if(!docs[0]["skip"] || (docs[0]["adminpass"] == hash && docs[0]["adminpass"] != "") || error)
|
||
{
|
||
if((lists[coll].length/2 <= docs[0]["skips"].length+1 && !contains(docs[0]["skips"], guid) && lists[coll].length != 2)
|
||
|| (lists[coll].length == 2 && docs[0]["skips"].length+1 == 2 && !contains(docs[0]["skips"], guid))
|
||
|| (docs[0]["adminpass"] == hash && docs[0]["adminpass"] != "" && docs[0]["skip"]))
|
||
{
|
||
change_song(coll);
|
||
socket.emit("toast", "skip");
|
||
//io.sockets.emit('chat,'+coll, [name, " skipped"]);
|
||
io.to(coll).emit('chat', [name, " skipped"]);
|
||
}/*else if(get_time() - docs[0]["startTime"] < 10 && lists[coll].length == 2 && !error)
|
||
{
|
||
socket.emit("toast", "notyetskip");
|
||
}*/else if(!contains(docs[0]["skips"], guid)){
|
||
db.collection(coll).update({views:{$exists:true}}, {$push:{skips:guid}}, function(err, d){
|
||
if(lists[coll].length == 2)
|
||
to_skip = 1;
|
||
else
|
||
to_skip = (Math.ceil(lists[coll].length/2) - docs[0]["skips"].length-1);
|
||
socket.emit("toast", to_skip + " more are needed to skip!");
|
||
socket.broadcast.to(coll).emit('chat', [name, " voted to skip"]);
|
||
});
|
||
}else{
|
||
socket.emit("toast", "alreadyskip");
|
||
}
|
||
}else
|
||
socket.emit("toast", "noskip");
|
||
}
|
||
});
|
||
}
|
||
});
|
||
|
||
socket.on('conf', function(params)
|
||
{
|
||
if(params !== undefined && params !== null && params != "")
|
||
{
|
||
check_inlist(coll, guid, socket,name);
|
||
|
||
var voting = params[0];
|
||
var addsongs = params[1];
|
||
var longsongs = params[2];
|
||
var frontpage = params[3];
|
||
var allvideos = params[4];
|
||
var removeplay = params[5];
|
||
var adminpass = params[6];
|
||
var skipping = params[7];
|
||
var shuffling = params[8];
|
||
|
||
if(adminpass != "")
|
||
var hash = hash_pass(adminpass);
|
||
else
|
||
var hash = adminpass;
|
||
|
||
db.collection(coll).find({views:{$exists:true}}, function(err, docs){
|
||
if(docs !== null && docs.length != 0 && docs[0]["adminpass"] == "" || docs[0]["adminpass"] == hash)
|
||
{
|
||
db.collection(coll).update({views:{$exists:true}}, {
|
||
$set:{addsongs:addsongs,
|
||
allvideos:allvideos,
|
||
frontpage:frontpage,
|
||
skip:skipping,
|
||
vote:voting,
|
||
removeplay:removeplay,
|
||
shuffle:shuffling,
|
||
longsongs:longsongs,
|
||
adminpass:hash}}, function(err, docs){
|
||
db.collection(coll).find({views:{$exists:true}}, function(err, docs)
|
||
{
|
||
//io.sockets.emit(coll+",conf", docs);
|
||
io.to(coll).emit("conf", docs);
|
||
socket.emit("toast", "savedsettings");
|
||
});
|
||
});
|
||
|
||
}else
|
||
{
|
||
socket.emit("toast", "wrongpass");
|
||
}
|
||
});
|
||
}
|
||
});
|
||
|
||
socket.on('shuffle', function(pass)
|
||
{
|
||
if(pass !== undefined && pass !== null)
|
||
{
|
||
check_inlist(coll, guid, socket, name);
|
||
|
||
if(pass == "") var hash = pass;
|
||
else var hash = hash_pass(pass);
|
||
db.collection(coll).find({views:{$exists:true}}, function(err, docs){
|
||
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){
|
||
send_list(coll, undefined, 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");
|
||
});
|
||
|
||
var complete = function(tot, curr){
|
||
if(tot == curr)
|
||
{
|
||
send_list(coll, undefined, false, true);
|
||
}
|
||
};
|
||
}else
|
||
socket.emit("toast", "wrongpass");
|
||
});
|
||
|
||
socket.on('change_channel', function()
|
||
{
|
||
if(in_list)
|
||
{
|
||
if(contains(lists[coll], guid))
|
||
{
|
||
//console.log(name + " left list " + coll);
|
||
var index = lists[coll].indexOf(guid);
|
||
lists[coll].splice(index, 1);
|
||
//io.sockets.emit(coll+",viewers", lists[coll].length);
|
||
//io.sockets.emit('chat,'+coll, [name, " left"]);
|
||
io.to(coll).emit("viewers", lists[coll].length);
|
||
io.to(coll).emit('chat', [name, " left"]);
|
||
|
||
}
|
||
|
||
}
|
||
});
|
||
|
||
socket.on('disconnect', function()
|
||
{
|
||
if(in_list)
|
||
{
|
||
if(contains(lists[coll], guid))
|
||
{
|
||
//console.log(name + " left list " + coll);
|
||
var index = lists[coll].indexOf(guid);
|
||
lists[coll].splice(index, 1);
|
||
//io.sockets.emit(coll+",viewers", lists[coll].length);
|
||
//io.sockets.emit('chat,'+coll, [name, " left"]);
|
||
io.to(coll).emit("viewers", lists[coll].length);
|
||
io.to(coll).emit('chat', [name, " left"]);
|
||
}
|
||
|
||
}
|
||
});
|
||
|
||
socket.on('reconnect_failed', function()
|
||
{
|
||
if(in_list)
|
||
{
|
||
if(contains(lists[coll], guid))
|
||
{
|
||
//console.log(name + " left list " + coll);
|
||
var index = lists[coll].indexOf(guid);
|
||
lists[coll].splice(index, 1);
|
||
//io.sockets.emit(coll+",viewers", lists[coll].length);
|
||
//io.sockets.emit('chat,'+coll, [name, " left"]);
|
||
io.to(coll).emit("viewers", lists[coll].length);
|
||
io.to(coll).emit('chat', [name, " left"]);
|
||
}
|
||
|
||
}
|
||
});
|
||
|
||
socket.on('connect_timeout', function()
|
||
{
|
||
if(in_list)
|
||
{
|
||
if(contains(lists[coll], guid))
|
||
{
|
||
//console.log(name + " left list " + coll);
|
||
var index = lists[coll].indexOf(guid);
|
||
lists[coll].splice(index, 1);
|
||
//io.sockets.emit(coll+",viewers", lists[coll].length);
|
||
//io.sockets.emit('chat,'+coll, [name, " left"]);
|
||
io.to(coll).emit("viewers", lists[coll].length);
|
||
io.to(coll).emit('chat', [name, " left"]);
|
||
}
|
||
|
||
}
|
||
});
|
||
|
||
socket.on('pos', function()
|
||
{
|
||
check_inlist(coll, guid, socket, name);
|
||
send_play(coll, socket);
|
||
});
|
||
});
|
||
|
||
function del(params, socket)
|
||
{
|
||
var coll = params[0].toLowerCase();
|
||
db.collection(coll).find({views:{$exists:true}}, function(err, docs){
|
||
if(docs !== null && docs.length != 0 && docs[0]["adminpass"] == hash_pass(params[4]))
|
||
{
|
||
db.collection(coll).remove({id:params[1]}, function(err, docs){
|
||
socket.emit("toast", "deletesong");
|
||
//io.sockets.emit(coll, ["deleted", params[1]]);
|
||
io.to(coll).emit(coll, ["deleted", params[1]]);
|
||
});
|
||
}
|
||
});
|
||
}
|
||
|
||
function check_inlist(coll, guid, socket, name)
|
||
{
|
||
if(lists[coll] == undefined)
|
||
{
|
||
lists[coll] = [];
|
||
lists[coll].push(guid);
|
||
//io.sockets.emit(coll+",viewers", lists[coll].length);
|
||
io.to(coll).emit("viewers", lists[coll].length);
|
||
socket.broadcast.to(coll).emit('chat', [name, " joined"]);
|
||
}else if(!contains(lists[coll], guid))
|
||
{
|
||
lists[coll].push(guid);
|
||
//io.sockets.emit(coll+",viewers", lists[coll].length);
|
||
io.to(coll).emit("viewers", lists[coll].length);
|
||
socket.broadcast.to(coll).emit('chat', [name, " joined"]);
|
||
}
|
||
}
|
||
|
||
function hash_pass(adminpass)
|
||
{
|
||
return crypto.createHash('sha256').update(adminpass).digest('base64');
|
||
}
|
||
|
||
function vote(coll, id, guid, socket)
|
||
{
|
||
db.collection(coll).find({id:id}, function(err, docs){
|
||
if(docs !== null && docs.length > 0 && !contains(docs[0]["guids"], guid))
|
||
{
|
||
db.collection(coll).update({id:id}, {$inc:{votes:1}, $set:{added:get_time()}, $push :{guids: guid}}, function(err, docs)
|
||
{
|
||
socket.emit("toast", "voted");
|
||
//io.sockets.emit(coll, ["vote", id, get_time()]);
|
||
io.to(coll).emit(coll, ["vote", id, get_time()]);
|
||
//sort_list(coll, undefined, false, true);
|
||
//sort_list(coll, undefined, false);
|
||
});
|
||
}else
|
||
{
|
||
socket.emit("toast", "alreadyvoted");
|
||
}
|
||
});
|
||
}
|
||
|
||
|
||
function change_song(coll, id, np_id)
|
||
{
|
||
db.collection(coll).find({views:{$exists:true}}, function(err, docs){
|
||
var startTime = docs[0]["startTime"];
|
||
if(docs !== null && docs.length != 0)
|
||
{
|
||
if(docs[0]["removeplay"] == true)
|
||
{
|
||
db.collection(coll).remove({now_playing:true}, function(err, docs)
|
||
{
|
||
change_song_post(coll);
|
||
})
|
||
}else
|
||
{
|
||
//console.log("undef");
|
||
db.collection(coll).update({now_playing:true},
|
||
{$set:{
|
||
now_playing:false,
|
||
votes:0,
|
||
guids:[]
|
||
}},{multi:true}, function(err, docs)
|
||
{
|
||
change_song_post(coll);
|
||
});
|
||
}
|
||
}
|
||
});
|
||
}
|
||
|
||
function change_song_post(coll)
|
||
{
|
||
db.collection(coll).aggregate([
|
||
{$match:{now_playing:false}},
|
||
{$sort:{votes:-1, added:1}},
|
||
{$limit:1}], function(err, docs){
|
||
if(docs !== null && docs.length > 0){
|
||
db.collection(coll).update({id:docs[0]["id"]},
|
||
{$set:{
|
||
now_playing:true,
|
||
votes:0,
|
||
guids:[],
|
||
added:get_time()}}, function(err, docs){
|
||
db.collection(coll).update({views:{$exists:true}},
|
||
{$set:{startTime:get_time(), skips:[]}}, function(err, docs){
|
||
//io.sockets.emit(coll, ["song_change", get_time()]);
|
||
io.to(coll).emit(coll, ["song_change", get_time()]);
|
||
send_play(coll);
|
||
});
|
||
|
||
});
|
||
}
|
||
});
|
||
}
|
||
|
||
function send_list(coll, socket, send, list_send)
|
||
{
|
||
db.collection(coll).find(function(err, docs)
|
||
{
|
||
//io.sockets.emit(coll, docs);
|
||
if(list_send)
|
||
io.to(coll).emit(coll, ["list", docs]);
|
||
else if(!list_send)
|
||
socket.emit(coll,["list", docs]);
|
||
if(socket === undefined && send)
|
||
send_play(coll);
|
||
else if(send)
|
||
send_play(coll, socket);
|
||
});
|
||
}
|
||
|
||
function send_play(coll, socket)
|
||
{
|
||
db.collection(coll).find({now_playing:true}, function(err, np){
|
||
db.collection(coll).find({views:{$exists:true}}, function(err, conf){
|
||
if(err !== null) console.log(err);
|
||
if(conf !== null && conf !== undefined && conf.length != 0)
|
||
{
|
||
toSend = [np,conf,get_time()];
|
||
if(socket === undefined)
|
||
io.to(coll).emit("np", toSend);
|
||
else
|
||
socket.emit("np", toSend);
|
||
}
|
||
});
|
||
});
|
||
}
|
||
|
||
function get_time()
|
||
{
|
||
var d = new Date();
|
||
var time = Math.floor(d.getTime() / 1000);
|
||
return time;
|
||
}
|
||
|
||
function contains(a, obj) {
|
||
var i = a.length;
|
||
while (i--) {
|
||
if (a[i] === obj) {
|
||
return true;
|
||
}
|
||
}
|
||
return false;
|
||
}
|
||
|
||
function rndName(seed, endlen) {
|
||
var vowels = ['a', 'e', 'i', 'o', 'u', 'ö'];
|
||
consts = ['b', 'c', 'd', 'f', 'g', 'h', 'j', 'k', 'l', 'm', 'n', 'p', 'r', 's', 't', 'v', 'w', 'x', 'y', 'z', 'tt', 'ch', 'sh'];
|
||
len = 8;
|
||
word = '';
|
||
is_vowel = false;
|
||
var arr;
|
||
for (var i = 0; i < len; i++) {
|
||
if (is_vowel) arr = vowels
|
||
else arr = consts
|
||
is_vowel = !is_vowel;
|
||
word += arr[(seed[i%seed.length].charCodeAt()+i) % arr.length-1];
|
||
}
|
||
return word.substring(0,endlen)
|
||
}
|