[Node.js] Utilisation de Socket.IO

Code :
var http = require('http');

 

var app = http.createServer(function(req, res) {});

app.listen(8080);

 

var io = require('socket.io');

var io = io.listen(app);



var mysql = require('mysql');

var db = 'bdd';



var client = mysql.createClient({

    user : 'root',

    password : ''

});



client.query('USE '+db);



// maintenance

var trois_jours = 60*60*24*3;

client.query('DELETE FROM chat WHERE UNIX_TIMESTAMP() - UNIX_TIMESTAMP(date) > '+ trois_jours);



var sept_jours = 60*60*24*7;

client.query('DELETE FROM evenement WHERE UNIX_TIMESTAMP() - UNIX_TIMESTAMP(date) > '+ sept_jours);



function newFormatDateSQL() {

    var date = new Date();

    var year = date.getFullYear();

    var month = parseInt(date.getMonth())+1;

    if(month < 10) month = '0' + month;

    var day = date.getDate();

    if(day < 10) day = '0' + day;

    var hours = date.getHours();

    if(hours < 10) hours = '0' + hours;

    var minutes = date.getMinutes();

    if(minutes < 10) minutes = '0' + minutes;

    var seconds = date.getSeconds();

    if (seconds < 10) seconds = '0' + seconds;

    var formatDate = year + '-' + month + '-' + day + ' ' + hours + '-' + minutes + '-' + seconds;

    return formatDate;

}



var noFlood = true;



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



    socket.on('init', function (map, pseudo) {



        var html = '';

        client.query(

            "SELECT pseudo, message, DATE_FORMAT(date, '%H:%i') AS date2 FROM chat WHERE nomMap = '"+ map +"' ORDER by date DESC LIMIT 30",

            function selectCb(err, results, fields) {

                if (err) {

                  throw err;

                }

                for (var i = 0, l = results.length; i < l; ++i) {

                    var r = results[i];

                    if(r['pseudo'] == '__root') html += "<span style='color:#888'><b>" + r['message'] + "</b></span><br />";

                    else html += "<b>" + r['pseudo'] + "</b> (" + r['date2'] + ") : " + r['message'] + "<br />";

                }

                socket.emit('showMsgsChat', html);

            }

        );

        

        var html2 = '';

        client.query(

            "SELECT evenement, DATE_FORMAT(date, '%d %b %H:%i') AS date2 FROM evenement WHERE pseudo = '"+ pseudo +"' ORDER by date DESC LIMIT 30",

            function selectCb(err, results, fields) {

                if (err) {

                  throw err;

                }

                for (var i = 0, l = results.length; i < l; ++i) {

                    var r = results[i];

                    html2 += "<b>" + r['date2'] + "</b> : " + r['evenement'] + "<br />";

                }

                socket.emit('showEvents', html2);

            }

        );

    });



    socket.on('newMsgChat', function (message, pseudo, map) {



        if(message.length == 0) {

            var errorMsg = "<span style='color:#888'><b>< Veuillez entrer un message ></b></span><br />";

            socket.emit('errorChat', errorMsg);

        }

        else if(message.length > 30) {

            var errorMsg = "<span style='color:#888'><b>< Votre message est trop long (30 caractères max) ></b></span><br />";

            socket.emit('errorChat', errorMsg);

        }

        else if(noFlood == false) {

            var errorMsg = "<span style='color:#888'><b>< Vous devez atteindre une minute avant de pouvoir reposter ></b></span><br />";

            socket.emit('errorChat', errorMsg);

        }

        else {



            client.query(

                'INSERT INTO chat(nomMap, pseudo, message, date) VALUES (?, ?, ?, ?)',

                [map, pseudo, message, newFormatDateSQL()]

            );



            // contrôle du flood

            noFlood = false;

            setTimeout(function() { noFlood = true; }, 60000);

            

            var html = '';

            client.query(

                "SELECT pseudo, message, DATE_FORMAT(date, '%H:%i') AS date2 FROM chat WHERE nomMap = '"+ map +"' ORDER by date DESC LIMIT 30",

                function selectCb(err, results, fields) {

                    if (err) {

                      throw err;

                    }

                    for (var i = 0, l = results.length; i < l; ++i) {

                        var r = results[i];

                        if(r['pseudo'] == '__root') html += "<span style='color:#888'><b>" + r['message'] + "</b></span><br />";

                        else html += "<b>" + r['pseudo'] + "</b> (" + r['date2'] + ") : " + r['message'] + "<br />";

                    }

                    socket.emit('showMsgsChat', html);

                    socket.broadcast.emit('showMsgsChat', html);

                }

            );

        }

    });

});



//client.end();