Merge pull request #9 from parse-server-modules/feature/disable-fan-out

Add option for disabling fan out

Author: ranhsd

lib/index.js

@@ -39,8 +39,9 @@ class Publisher {
 
 class Subscriber extends events.EventEmitter {
 
-  constructor() {
+  constructor(options) {
     super();
+    this.disableFanOut = options.disableFanOut || false;
   }
 
   subscribe(channel) {
@@ -72,27 +73,32 @@ class Subscriber extends events.EventEmitter {
   }
 
   _createSubscription(topic, channel) {
-
-    const subscriptionUUID = uuid.v1();
-    var subscriptionName = `${namePrefix}-${channel}-${subscriptionUUID}`;
+    let subscriptionName;
+    if (!this.disableFanOut) {
+      const subscriptionUUID = uuid.v1();
+      subscriptionName = `${namePrefix}-${channel}-${subscriptionUUID}`;
+    } else {
+      subscriptionName = `${namePrefix}-${channel}`;
+    }
 
     topic.subscribe(subscriptionName, (err, subscription) => {
-
       if (err) {
         console.error(`Failed to create subscription ${err}`);
         return;
       }
 
       console.log(`Subscription ${subscription.name} created.`);
 
-      function deleteSubscription() {
+      const deleteSubscription = () => {
         removeListeners();
-        console.log('Subscriber: Signal received, deleting subscription');
-        subscription.delete().then(() => {
-          console.log('Subscriber: subscription deleted...');
-        }, (err) => {
-          console.error(`Subscriber: Error deleting subscription`, err);
-        });
+        if (!this.disableFanOut) {
+          console.log('Subscriber: Signal received, deleting subscription');
+          subscription.delete().then(() => {
+            console.log('Subscriber: subscription deleted...');
+          }, (err) => {
+            console.error(`Subscriber: Error deleting subscription`, err);
+          });
+        }
       }
 
       function messageHandler(message) {
@@ -121,6 +127,7 @@ class Subscriber extends events.EventEmitter {
       function removeListeners() {
         subscription.removeListener('message', onMessage);
         subscription.removeListener('error', onError);
+
         process.removeListener('SIGTERM', deleteSubscription);
         process.removeListener('SIGINT', deleteSubscription);
       }
@@ -140,8 +147,8 @@ function createPublisher() {
   return new Publisher(emitter);
 }
 
-function createSubscriber() {
-  return new Subscriber();
+function createSubscriber(options) {
+  return new Subscriber(options);
 }
 
 module.exports = {

package.json

@@ -1,6 +1,6 @@
 {
   "name": "parse-server-gcloud-pubsub",
-  "version": "2.0.1",
+  "version": "2.1.0",
   "description": "google cloud pub/sub adapter for parse-server",
   "main": "lib/index.js",
   "engines": {