server.js

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

// Accès au dossier 'public'
app.use('/', express.static(__dirname + '/public'));

// Liste des utilisateurs connectés
var users = [];
// Historique des messages
var messages = [];
// Liste des utilisateurs en train de saisir un message
var typingUsers = [];

// Gestion utilisateur connecté à la socket
io.on('connection', function (socket) {
  var loggedUser;
  // Emission d'un événement "user-login" pour chaque utilisateur connecté
  for (i = 0; i < users.length; i++) {
    socket.emit('user-login', users[i]);
  }
  // Emission d'un événement "chat-message" pour chaque message de l'historique
  for (i = 0; i < messages.length; i++) {
    if (messages[i].username !== undefined) {
      socket.emit('chat-message', messages[i]);
    } else {
      socket.emit('service-message', messages[i]);
    }
  }
  // Déconnexion d'un utilisateur
  socket.on('disconnect', function () {
    if (loggedUser !== undefined) {
      // Broadcast d'un 'service-message'
      var serviceMessage = {
        text: 'User "' + loggedUser.username + '" disconnected',
        type: 'logout'
      };
      socket.broadcast.emit('service-message', serviceMessage);
      // Suppression de la liste des connectés
      var userIndex = users.indexOf(loggedUser);
      if (userIndex !== -1) {
        users.splice(userIndex, 1);
      }
      // Ajout du message à l'historique
      messages.push(serviceMessage);
      // Emission d'un 'user-logout' contenant le user
      io.emit('user-logout', loggedUser);
      // Si jamais il était en train de saisir un texte, on l'enlève de la liste
      var typingUserIndex = typingUsers.indexOf(loggedUser);
      if (typingUserIndex !== -1) {
        typingUsers.splice(typingUserIndex, 1);
      }
   }
});
  // Connexion d'un utilisateur via le formulaire :
  socket.on('user-login', function (user, callback) {
    // Vérification que l'utilisateur à son propre pseudo
    var userIndex = -1;
    for (i = 0; i < users.length; i++) {
      if (users[i].username === user.username) {
        userIndex = i;
      }
    }
    if (user !== undefined && userIndex === -1) { // S'il est bien nouveau
      // Sauvegarde de l'utilisateur et ajout à la liste des connectés
      loggedUser = user;
      users.push(loggedUser);
      // Envoi et sauvegarde des messages de service
      var userServiceMessage = {
        text: 'You logged in as "' + loggedUser.username + '"',
        type: 'login'
      };
      var broadcastedServiceMessage = {
        text: 'User "' + loggedUser.username + '" logged in',
        type: 'login'
      };
      socket.emit('service-message', userServiceMessage);
      socket.broadcast.emit('service-message', broadcastedServiceMessage);
      messages.push(broadcastedServiceMessage);
      // Emission de 'user-login' et appel du callback
      io.emit('user-login', loggedUser);
      callback(true);
    } else {
      callback(false);
    }
});

    // Réception de l'événement 'chat-message' et réémission vers tous les utilisateurs
    socket.on('chat-message', function (message) {
      // On ajoute le username au message et on émet l'événement
      message.username = loggedUser.username;
      io.emit('chat-message', message);
      // Sauvegarde du message
      messages.push(message);
      if (messages.length > 150) {
        messages.splice(0, 1);
      }
    });

    /*
     Réception de l'événement 'start-typing'
     L'utilisateur commence à saisir son message
    */
    socket.on('start-typing', function () {
      // Ajout du user à la liste des utilisateurs en cours de saisie
      if (typingUsers.indexOf(loggedUser) === -1) {
        typingUsers.push(loggedUser);
      }
      io.emit('update-typing', typingUsers);
    });

    /*
      Réception de l'événement 'stop-typing'
      L'utilisateur a arrêter de saisir son message
    */
    socket.on('stop-typing', function () {
      var typingUserIndex = typingUsers.indexOf(loggedUser);
      if (typingUserIndex !== -1) {
        typingUsers.splice(typingUserIndex, 1);
      }
      io.emit('update-typing', typingUsers);
    });
});

// Lancement du serveur en écoutant les connexions arrivant sur le port 3000
http.listen(3000, function () {
  console.log('Server is listening on *:3000');
});