var app = require('express')();
var sha1 = require('sha1');
var mysql = require('mysql');
var http = require('http').Server(app);
var io = require('socket.io')(http);

app.get('/', function(req, res){
    res.sendfile('client/index.html');
});

var connection = mysql.createConnection({
    host: 'localhost',
    user: 'root',
    password: '',
    database: 'demo'
});

connection.connect(function(err){
    if(err){
        console.error('Impossible de se connecter ', err);
    }
});

var username;


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


    function GetUserInfo () {
        connection.query('SELECT * FROM users WHERE username = ?', [username], function (err, rows) {

            var userinfos = [];

            for (k in rows) {
                var row = rows[k];
                var user = {
                    id: row.id,
                    username: row.username,
                    balance: row.balance
                };
                userinfos.push(user)

            }

            console.log(userinfos);

        });
    }


    socket.on('register', function(data){
       username = data.username;
        password = data.password;
        var query2 = "INSERT INTO users(username,password) VALUES('" + username + "','" + sha1(password) + "')";
        connection.query(query2);
    });

    socket.on('login', function(data){
        username = data.username;
        password = data.password;

        connection.query("SELECT username, password FROM users WHERE username = ? AND password = ?",[username,sha1(password)],function(err, rows, fields) {
            if (err) throw err;
            if (rows.length == 0) {
                socket.emit('login', {message: 'Wrong login or password'})
            } else {
                socket.emit('login', {message: 'success', session: username});
                GetUserInfo();

            }
        });
    });


    socket.on('disconnect', function(){

    });

});

http.listen(3000, function(){
    console.log('listening on *:3000');
});