Socket.io config

sockets.js

/* app/server/config/sockets.js */

var config = require('./environment');
var redis = require('redis');

var initialized = false;
var ioEmitter;

var redisClient = redis.createClient(config.redis.url, {return_buffers: true});
var pub = redis.createClient(config.redis.url);
var sub = redis.createClient(config.redis.url, {return_buffers: true});


module.exports = {

  init: function (server) {

    if (initialized) return ioEmitter;

    var io = require('socket.io')(server, {
      serveClient: true
    });

    io.adapter(require('socket.io-redis')({key: '', pubClient: pub, subClient: sub}));

    ioEmitter = require('socket.io-emitter')(redisClient);

    io.on('connection', function (socket) {
      /* quand le client se connect ça se passe ici */ 
    });

    initialized = true;
    return ioEmitter;
  },

  broadcast: function (event, payload) {
    ioEmitter.of('/').emit(event, payload);
  },

  emit: function (to, event, payload) {
    ioEmitter.of('/').to(to).emit(event, payload);
  }
  
};