Example Nes Redis Adapter

nes-redis.js

// Load modules
var Util = require('util');
var EventEmitter = require('events').EventEmitter;
var Redis = require('redis');

// Declare internals

var internals = {};

exports = module.exports = internals.Adapter = function () {

    var self = this;

    EventEmitter.call(this);

    this._pub = Redis.createClient.apply(null, arguments);
    this._sub = Redis.createClient.apply(null, arguments);

    this._pub.on('error', function(err) {

      self.emit('error', err);
    });

    this._sub.on('error', function(err) {

      self.emit('error', err);
    });

    this._sub.psubscribe('nes:*', function(err) {

      if (err) {
        self.emit(err);
      }
    });

    this._sub.on('pmessage', function(pattern, channel, message) {

      var parsed = JSON.parse(message);

      if (channel === 'nes:publish') {
        self.emit('publish', parsed.path, parsed.message);
      } else if (channel === 'nes:broadcast') {
        self.emit('broadcast', parsed.message);
      }
    });

};

Util.inherits(internals.Adapter, EventEmitter);


internals.Adapter.prototype.broadcast = function (update) {

    this._pub.publish('nes:broadcast', JSON.stringify({
      message : update
    }));
};

internals.Adapter.prototype.publish = function (path, message) {

    this._pub.publish('nes:publish', JSON.stringify({
      path : path,
      message : message
    }));
};

internals.Adapter.prototype.stop = function () {

    this._pub.end();
    this._sub.end();
};