Socket.io Server messaging using Binary Mode

server-binary-mode.js

/**
 * Redis => Server => Socket.io
 */

function onRedisMessage(channel, message) {
  var json;
  try {
    json = JSON.parse(message);
  }
  catch (err) {
    // ...
  }

  // ... some filtering

  this.messages.push(message);
  this.jsons.push(json);
}

function getPayload() {
  // super-cheap JSON Array construction
  return new Buffer([ '[', this.messages.join(','), ']' ].join(''));
}

function emitInterval(io) {
  var payload = this.getPayload();

  var redis_channel_id = this.redis_channel_id;
  this.sockets.forEach(function(socket) {
    io.to(socket).emit(redis_channel_id, payload);
  });

  this.clearPayload();
}