burger-quizz/web/multi/server/server.js

var io = require('socket.io'); // Chargement du module pour mettre en place les websockets
var http = require('http');
var fs = require('fs'), cfgFilePath = '';
var httpHost = 'localhost', httpPath = '/burger-quizz/web/api/', nodePort = 8000;

// Lecture du fichier de configuration
if(process.argv.length > 2) {
  cfgFilePath = process.argv[2];
} else {
  cfgFilePath = '../../params.cfg';
}

var params = fs.readFileSync(cfgFilePath).toString();

if(params === "") {
  console.error("Fichier params.cfg introuvable.");
  process.exit(1);
}

var httpHost = params.match(/http_host: (.+)/)[1];
var httpPath = params.match(/http_path: (.+)/)[1];
var nodePort = params.match(/node_port: (.+)/)[1];

console.log("Serveur initialisé sur l'URL "+httpHost+":"+nodePort+httpPath);

var json;
// Variables
var server; // Le socket

var lobby = [];
var games = [];
// Gestion des evenements
// Attend l'évènement "connection"
// Le client génère cet évènement lorsque la connexion est établie avec le serveur (voir l'établissement de connexion côté client)
// En cas de connexion appel à la fonctione onSocketConnection
// Un paramètre est envoyé en paramètre de l'évènement "connection" : ce paramètre représente le client
var setEventHandlers = function() {
    server.sockets.on("connection", onSocketConnection);
};

// Fonction prenant en paramètre le client (voir ci-dessus)
// Réception ou envoi d'évènement à partir de cet objet : client
function onSocketConnection(client) {

    // Attente de l'évènement "new"
    // Dans cet exemple l'évènement "new" est envoyé avec un paramètre "pseudo"
    client.on('nouveau', function(pseudo) {
        // Log pour debug
        console.log('Nouveau joueur : '+ pseudo +' !');
        // Envoi d'un message au client
        //client.emit('message', 'bien reçu !!');

        if(lobby.length > 0) {
          games.push({joueur1: lobby[0], joueur2: {login: pseudo, socket: client, over: false, score: 0}, idGame: games.length, json: ''});
          games[games.length-1].joueur1.socket.emit("game", [games[games.length-1].joueur2.login, games[games.length-1].idGame]);
          games[games.length-1].joueur2.socket.emit("game", [games[games.length-1].joueur1.login, games[games.length-1].idGame]);
          lobby = [];
        } else {
          lobby.push({login: pseudo, socket: client, over: false, score: 0});
        }
        // Envoi d'un message aux autres clients connectés
        //client.broadcast.emit('autres', pseudo);
    });
    client.on('error', function(err) {
      console.log(err);
    });
    client.on('start', function(gameID) {
      http.get("http://"+httpHost+httpPath+"/api/", function(res) {
        var data = "";
        res.on("data", function(returned) {
          data += returned;
        })
        res.on("error", function(err) {
          console.log(err);
        });
        res.on("end", function() {
          if(!games[gameID].json) {
            games[gameID].json = JSON.parse(data.toString());
          }
          client.emit('questions', games[gameID].json);
        })
      });
    });

    client.on('findugame', function(options) {
      if(games[options[0]].joueur1.socket.id === client.id) {
        games[options[0]].joueur1.over = true;
        games[options[0]].joueur1.score = options[1];
        console.log("Joueur 1 ("+games[options[0]].joueur1.login+") a fini.");
      } else if(games[options[0]].joueur2.socket.id === client.id) {
        games[options[0]].joueur2.over = true;
        games[options[0]].joueur2.score = options[1];
        console.log("Joueur 2 ("+games[options[0]].joueur2.login+") a fini.");
      }
      if(games[options[0]].joueur1.over && games[options[0]].joueur2.over) {
        console.log("Partie terminée.");
        games[options[0]].joueur1.socket.emit('end', games[options[0]].joueur2.score);
        games[options[0]].joueur2.socket.emit('end', games[options[0]].joueur1.score);
        games.splice(options[0], 1);
        console.log(games);
      }
    });

    client.on('disconnect', function() {
      games.forEach(function(row) {
        if(row.joueur1.socket.id === client.id) {
          console.log("Joueur déconnecté ("+row.joueur1.login+") ; socket id : "+client.id);
          row.joueur2.socket.emit('lolheded');
        } else if(row.joueur2.socket.id === client.id) {
          console.log("Joueur déconnecté ("+row.joueur2.login+") ; socket id : "+client.id);
          row.joueur1.socket.emit('lolheded');
        }
      });
    });

    client.on('nextQuestion', function(isRight) {
      games.forEach(function(row) {
        if(row.joueur1.socket.id === client.id) {
          row.joueur2.socket.emit('qpass', !isRight);
        } else if(row.joueur2.socket.id === client.id) {
          row.joueur1.socket.emit('qpass', !isRight);
        }
      });
    })
};

// Initialisation
function init() {
    // Le server temps réel écoute sur le port 8000
    server = io.listen(nodePort);

    // Gestion des évènements
    setEventHandlers();

};

// Lance l'initialisation
init();