nodebb/src/pubsub.js

'use strict';

var nconf = require('nconf');
var util = require('util');
var winston = require('winston');
var EventEmitter = require('events').EventEmitter;

var channelName;

var PubSub = function () {
	var self = this;
	if (nconf.get('redis')) {
		var redis = require('./database/redis');
		var subClient = redis.connect();
		this.pubClient = redis.connect();

		channelName = 'db:' + nconf.get('redis:database') + 'pubsub_channel';
		subClient.subscribe(channelName);

		subClient.on('message', function (channel, message) {
			if (channel !== channelName) {
				return;
			}

			try {
				var msg = JSON.parse(message);
				self.emit(msg.event, msg.data);
			} catch (err) {
				winston.error(err.stack);
			}
		});
	}
};

util.inherits(PubSub, EventEmitter);

PubSub.prototype.publish = function (event, data) {
	if (this.pubClient) {
		this.pubClient.publish(channelName, JSON.stringify({ event: event, data: data }));
	} else {
		this.emit(event, data);
	}
};

var pubsub = new PubSub();

module.exports = pubsub;