👌 disable event store emits by default

Author: bobbytes

README.md

@@ -44,19 +44,20 @@ example with mongodb:
 
     var es = require('eventstore')({
       type: 'mongodb',
-      host: 'localhost',                          // optional
-      port: 27017,                                // optional
-      dbName: 'eventstore',                       // optional
-      eventsCollectionName: 'events',             // optional
-      snapshotsCollectionName: 'snapshots',       // optional
-      transactionsCollectionName: 'transactions', // optional
-      timeout: 10000                              // optional
+      host: 'localhost',                             // optional
+      port: 27017,                                   // optional
+      dbName: 'eventstore',                          // optional
+      eventsCollectionName: 'events',                // optional
+      snapshotsCollectionName: 'snapshots',          // optional
+      transactionsCollectionName: 'transactions',    // optional
+      timeout: 10000,                                // optional
+      emitStoreEvents: true                          // optional, by default no store events are emitted
       // maxSnapshotsCount: 3                        // optional, defaultly will keep all snapshots
-      // authSource: 'authedicationDatabase',        // optional
-      // username: 'technicalDbUser',                // optional
+      // authSource: 'authedicationDatabase'         // optional
+      // username: 'technicalDbUser'                 // optional
       // password: 'secret'                          // optional
       // url: 'mongodb://user:pass@host:port/db?opts // optional
-      // positionsCollectionName: 'positions' // optioanl, defaultly wont keep position
+      // positionsCollectionName: 'positions'        // optional, defaultly wont keep position
     });
 
 example with redis:
@@ -69,9 +70,10 @@ example with redis:
       prefix: 'eventstore',                       // optional
       eventsCollectionName: 'events',             // optional
       snapshotsCollectionName: 'snapshots',       // optional
+      emitStoreEvents: true,                      // optional, by default no store events are emitted
       timeout: 10000                              // optional
-      // maxSnapshotsCount: 3                        // optional, defaultly will keep all snapshots
-      // password: 'secret'                          // optional
+      // maxSnapshotsCount: 3                     // optional, defaultly will keep all snapshots
+      // password: 'secret'                       // optional
     });
 
 example with tingodb:
@@ -82,8 +84,9 @@ example with tingodb:
       eventsCollectionName: 'events',             // optional
       snapshotsCollectionName: 'snapshots',       // optional
       transactionsCollectionName: 'transactions', // optional
-      timeout: 10000                              // optional
-      // maxSnapshotsCount: 3                        // optional, defaultly will keep all snapshots
+      timeout: 10000,                             // optional
+      emitStoreEvents: true                       // optional, by default no store events are emitted
+      // maxSnapshotsCount: 3                     // optional, defaultly will keep all snapshots
     });
 
 example with elasticsearch:
@@ -95,8 +98,9 @@ example with elasticsearch:
       eventsTypeName: 'events',                   // optional
       snapshotsTypeName: 'snapshots',             // optional
       log: 'warning',                             // optional
-      maxSearchResults: 10000                     // optional
-      // maxSnapshotsCount: 3                        // optional, defaultly will keep all snapshots
+      maxSearchResults: 10000,                    // optional
+      emitStoreEvents: true                       // optional, by default no store events are emitted
+      // maxSnapshotsCount: 3                     // optional, defaultly will keep all snapshots
     });
 
 example with custom elasticsearch client (e.g. with AWS ElasticSearch client. Note ``` http-aws-es ``` package usage in this example):
@@ -130,9 +134,10 @@ example with azuretable:
       storageAccount: 'nodeeventstore',
       storageAccessKey: 'aXJaod96t980AbNwG9Vh6T3ewPQnvMWAn289Wft9RTv+heXQBxLsY3Z4w66CI7NN12+1HUnHM8S3sUbcI5zctg==',
       storageTableHost: 'https://nodeeventstore.table.core.windows.net/',
-      eventsTableName: 'events',             // optional
-      snapshotsTableName: 'snapshots',       // optional
-      timeout: 10000                              // optional
+      eventsTableName: 'events',               // optional
+      snapshotsTableName: 'snapshots',         // optional
+      timeout: 10000,                          // optional
+      emitStoreEvents: true                    // optional, by default no store events are emitted
     });
 
 example with dynamodb:
@@ -150,7 +155,8 @@ example with dynamodb:
         UndispatchedEventsReadCapacityUnits: 1,     // optional
         useUndispatchedEventsTable: true            // optional
         eventsTableStreamEnabled: false             // optional
-        eventsTableStreamViewType: 'NEW_IMAGE'      // optional
+        eventsTableStreamViewType: 'NEW_IMAGE',     // optional
+        emitStoreEvents: true                       // optional, by default no store events are emitted
     });
 
 DynamoDB credentials are obtained by eventstore either from environment vars or credentials file. For setup see [AWS Javascript SDK](http://docs.aws.amazon.com/AWSJavaScriptSDK/guide/node-configuring.html).

index.js

@@ -72,8 +72,10 @@ module.exports = function(options) {
 
   var eventstore = new Eventstore(options, new Store(options));
 
-  var storeEventEmitter = new StoreEventEmitter(eventstore);
-  storeEventEmitter.addEventEmitter();
+  if (options.emitStoreEvents) {
+    var storeEventEmitter = new StoreEventEmitter(eventstore);
+    storeEventEmitter.addEventEmitter();
+  }
 
   return eventstore;
 };

lib/storeEventEmitter.js

@@ -1,5 +1,4 @@
 var _ = require('lodash');
-var uuid = require('uuid').v4;
 var Eventstore = require('./eventstore');
 
 /**
@@ -285,5 +284,4 @@ function StoreEventEmitter(eventstore) {
   };
 }
 
-
 module.exports = StoreEventEmitter;