var _ = require('lodash');
var server = require('http').Server();
var io = require('socket.io')(server);
var mysql = require('mysql');
var request = require("request");


var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: '!@#$matiseba!@#$',
    database: 'poprawka'
});

server.listen(4555);

var timeleft;
var winnerNumber = 99;
var gameTime = 45;
//var end_at = 0;


var end_at = (new Date).getTime() + 45000;


io.on('connection', function (socket) {

    getLatestColors(socket);

    //emitujemy timer do nowo polaczonych graczy
    socket.emit('startTimer', (new Date).getTime(), end_at);


    setInterval(function () {
        if (winnerNumber != 99) {
            socket.emit('clearGame', winnerNumber);
            setTimeout(function () {
                winnerNumber = 99;
                socket.emit('clearWinner', true);
            }, 5000);
            return;
        }
        if (timeleft < 1) {
            socket.emit('counter', 45);
        } else {
            socket.emit('counter', timeleft);
        }
    }, 1000);
});


connection.connect(function (err) {
    if (err) {
        console.error('error connecting: ' + err.stack);
        return;
    }
});
////////////////// CSBOX.pl Bot v0.0.1

/*
 setInterval(function () {
 CheckTimer();
 }, 1000);
 */
function CheckTimer() {
    // aktualnie brak timera
    if (end_at <= (new Date).getTime()) {

        // pobieramy uzytkownikow z aktualnej gry
        connection.query('SELECT count(*) as cnt,(SELECT id FROM roulette_history ORDER BY id DESC LIMIT 1) as gameid, (SELECT endTime FROM roulette_history ORDER BY id DESC LIMIT 1) as endTime FROM placed_bets WHERE gameID = (SELECT id FROM roulette_history ORDER BY id DESC LIMIT 1)', function (err, rows) {
            var users = rows[0]['cnt'];
            var endTime = rows[0]['cnt'];
            var roundId = rows[0]['gameid'];
            if (users > 0 && endTime == 0) {
                var unixTime = parseInt(new Date().getTime() / 1000, 10);
                connection.query('UPDATE roulette_history SET endTime="' + unixTime + '" WHERE id= (SELECT id FROM roulette_history ORDER BY id DESC LIMIT 1)', function (err, rows) {
                    if (err) {
                        console.log('Wystąpił błąd');
                    } else {
                        //zwyciezcy starej gry
                        //proceedWinners(roundId);
                        console.log('zwyciezcy starej gry');
                        //puszczamy nowy timer/gre
                        end_at = endTime;
                        io.on('connection', function (socket) {
                            socket.emit('startTimer', (new Date).getTime(), end_at);
                        });
                    }
                });
                return;
            }
        });

    } else {
        //aktualnie mamy timerek

    }

    /*
     // handleOffers();
     var unixTime = parseInt(new Date().getTime() / 1000, 10);
     connection.query('SELECT id,endTime FROM roulette_history ORDER BY id DESC limit 1', function (err, rows) {
     if (err) return;
     var roundID = rows[0]['id'];
     var endTime = rows[0]['endTime'];

     connection.query('SELECT count(*) as cnt FROM placed_bets WHERE gameID="' + roundID + '"', function (err, rows) {
     var Users = rows[0]['cnt'];
     if (endTime == 0 && Users != 0) {
     connection.query('UPDATE roulette_history SET endTime="' + unixTime + '" WHERE id="' + roundID + '"', function (err, rows) {
     if (err) {
     console.log('Wystąpił błąd');
     } else {
     //console.log('Zaczynam rundę');
     }
     });
     return;
     }

     if (Users != 0) {
     timeleft = endTime + gameTime - unixTime;
     if (timeleft < 6 && timeleft > 0) {
     //console.log('Pozostały czas rundy:' + timeleft);
     }
     if (timeleft == 0) {
     proceedWinners(roundID);
     return;
     }
     }

     }
     )
     ;
     });

     */

}

function getLatestColors(socket) {
    connection.query("SELECT * FROM roulette_history WHERE numberWon != '99' ORDER BY id DESC LIMIT 10", function (err, rows) {
        socket.emit('lastColors', rows);
    });
};


/*
 function proceedWinners(roundID) {
 request({
 url: 'http://csgourban.com/getWinningColor98475983457xkjhas82',
 json: true
 }, function (error, response, body) {
 console.log(body['number']);
 winnerNumber = body['number'];
 });
 proceeded = false;
 } */