app

/*=====================Initialisation=====================*/
var app = require('express')();
var http = require('http').Server(app);
var io = require('socket.io')(http);
const httpd = require('https');
var fs = require('fs');
var mysql = require('mysql');
var password = require('password-hash-and-salt');

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




app.get('/', function(req, res){
    /*res.sendFile('app.js', { root: __dirname });*/
});

io.on('connection', function(socket){
    console.log('a user connected {' + socket.request.connection.remoteAddress + "}");
    var usermail;
    socket.on('disconnect', function(){
        console.log('user disconnected ' + socket.request.connection.remoteAddress);
    });

    /*........................REGISTER...................*/
    socket.on('New User', function(data){
        console.dir("new inscription incoming")
        password(data.password).hash(function(error, hash) {
            c.query('INSERT INTO Users (Email,Mdp,Date_creation,Date_modification) VALUES (?,?,NOW(),NOW())',
                [data.mail, hash],
                function(err, rows) {
                    if (err){
                        console.dir(err);
                        socket.emit('Insc KO');
                    }
                    else
                        socket.emit('Insc OK');
                });
        });
    });


    /*........................Login...................*/
    socket.on("Login", function (data) {
        console.log("new login incoming")
        c.query('SELECT * FROM Users WHERE Email = ?',[data.mail] ,function(err, rows) {
            if (err)
                throw err;
                    // ici voir si rows non null et donc si il peut se log
                    if(rows.info.numRows != 0){
                        console.log(socket.request.connection.remoteAddress + " user exist");
                        password(data.password).verifyAgainst(rows[0].Pass, function(error, verified) {
                            if(error){
                                throw new Error('Something went wrong!');
                                socket.emit("   " +socket.request.connection.remoteAddress + " Login-Fatal error");
                            }
                            if(!verified) {
                                socket.emit("Login-pass=false");
                                console.log("   " +socket.request.connection.remoteAddress + " wrong pass");
                            } else {
                                usermail = data.mail;
                                socket.emit("Login-succes");
                                console.log( "  " + socket.request.connection.remoteAddress + " right pass");
                            }
                        });
                    } else {
                        socket.emit("Login-User=false");
                        console.log(socket.request.connection.remoteAddress + " unknow user");
                    }
                });
    });

    /*........................push data...................*/
    socket.on('DataPush', function(data){
        c.query('INSERT INTO Data (Email,Text) VALUES (?,?)',
            [usermail, data],
            function(err, rows) {
                if (err){
                    console.dir(err);
                    socket.emit('DataPush-ko');
                }
                else
                    socket.emit('DataPush-ok');
            });

    });

    /*===================================================*/
});

/*======================Start========================*/
http.listen(3000, function(){
    console.log('listening on *:3000');
});
c.query('INSERT INTO Users (Email,Mdp,Date_creation,Date_modification) VALUES (?,?,NOW(),NOW())',
    ["test", "test"],
    function(err, rows) {
        if (err){
            console.dir(err);
        }
        else
        console.log('OK')
    });