From b71d64e8c31e785b5b1915776f8bf9c475f38487 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Bar=C4=B1=C5=9F=20Soner=20U=C5=9Fakl=C4=B1?= Date: Fri, 15 Jun 2018 14:17:09 -0400 Subject: [PATCH] remove fake pubsub --- src/pubsub.js | 31 ------------------------------- 1 file changed, 31 deletions(-) diff --git a/src/pubsub.js b/src/pubsub.js index 270ae37bf8..6b6f12d171 100644 --- a/src/pubsub.js +++ b/src/pubsub.js @@ -3,22 +3,6 @@ var nconf = require('nconf'); var real; -var fake = { - publishQueue: [], - publish: function (event, data) { - fake.publishQueue.push({ event: event, data: data }); - }, - listenQueue: {}, - on: function (event, callback) { - if (!Object.prototype.hasOwnProperty.call(fake.listenQueue, event)) { - fake.listenQueue[event] = []; - } - fake.listenQueue[event].push(callback); - }, - removeAllListeners: function (event) { - delete fake.listenQueue[event]; - }, -}; function get() { if (real) { @@ -37,22 +21,7 @@ function get() { pubsub = require('./database/mongo/pubsub'); } - if (!pubsub) { - return fake; - } - - Object.keys(fake.listenQueue).forEach(function (event) { - fake.listenQueue[event].forEach(function (callback) { - pubsub.on(event, callback); - }); - }); - - fake.publishQueue.forEach(function (msg) { - pubsub.publish(msg.event, msg.data); - }); - real = pubsub; - fake = null; return pubsub; }