var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
var port = (process.env.PORT || 5000);
var LOGBROADCAST = true;

//get port from commandline parameteres
if (process.argv.length == 3) {
    port = process.argv[2];
}

var que = [];
var pws = {};

app.get('/', function(req, res) {
    res.sendFile(__dirname + '/templates/index.html');
});
app.get('/adm', function(req, res) {
    res.sendFile(__dirname + '/templates/adm.html');
});
app.get('/log', function(req, res) {
    res.sendFile(__dirname + '/templates/log.html');
});
app.get('/list', function(req, res) {
    res.sendFile(__dirname + '/templates/list.html');
});

//route all paths beginning with /f/ to real files 
app.get('/f/*', function(req, res) {
    res.sendFile(__dirname + req.path.substring(2));
});


io.on('connection', function(socket) {
    var uid = Date.now();
    var pw = Math.random() * 10000000 + Math.random() * 10000000 - 1;
    pws[uid] = pw;


    socket.emit("userinfo", {
        "uid": uid,
        "pw": pw
    });

    socket.emit("quedata", que);
    socket.on("logsubscribe", function(data) {
        log("User " + data.uid + " has subscribed in logging");
        socket.join("log");
    });

    socket.on("queadd", function(data) {
        log("User " + data.name + " on row " + data.row + " added to queue");
        data.qid = Date.now();

        que.push(data);
        io.emit("quedata", que);
    });

    socket.on("quepopfirst", function(data) {
        var deleted = que.shift();
        log("admin deleted " + deleted.name + " from queue");
        io.emit("quedata", que);

    });

    socket.on("quedelete", function(data) {
        for (var i = 0; i < que.length; i++) {
            if (que[i].qid == data.qid) {
                if (data.pw != pws[que[i].uid]) {
                    socket.emit("err", {
                        "msg": "you're not allowed to remove this entry"
                    });
                    break;
                }
                log(que[i].name + " deleted himself from queue");
                que.splice(i, 1);
                io.emit("quedata", que);
                break;
            }
        }
    });
});

function getTimeString() {
    return Date().toLocaleString();
}

function log(msg) {
    var logmsg = getTimeString() + ": " + msg;
    console.log(logmsg);
    if (LOGBROADCAST) {
        io.to("log").emit("logmessage", logmsg);
    }
}
http.listen(port, function() {
    log('listening on port ' + port);
});