eventstore - npm Package Compare versions

Comparing version 1.0.5 to 1.1.0

lib/databases/mongodb.js

@@ -88,2 +88,17 @@ 'use strict';
 
+        self.events.ensureIndex({ aggregateId: 1, aggregate: 1, context: 1 },
+          function (err) { if (err) { debug(err); } });
+
+        self.events.ensureIndex({ aggregateId: 1, aggregate: 1 },
+          function (err) { if (err) { debug(err); } });
+
+        self.events.ensureIndex({ aggregateId: 1 },
+          function (err) { if (err) { debug(err); } });
+
+        self.events.ensureIndex({ streamId: 1 },
+          function (err) { if (err) { debug(err); } });
+
+        self.events.ensureIndex({ dispatched: 1 },
+          function (err) { if (err) { debug(err); } });
+        
         self.events.ensureIndex({ commitStamp: 1, streamRevision: 1, commitSequence: 1 },
@@ -96,2 +111,17 @@ function (err) { if (err) { debug(err); } });
         
+        self.snapshots.ensureIndex({ revision: -1, version: -1, commitStamp: -1 },
+          function (err) { if (err) { debug(err); } });
+
+        self.snapshots.ensureIndex({ aggregateId: 1, aggregate: 1, context: 1 },
+          function (err) { if (err) { debug(err); } });
+
+        self.snapshots.ensureIndex({ aggregateId: 1, aggregate: 1 },
+          function (err) { if (err) { debug(err); } });
+
+        self.snapshots.ensureIndex({ aggregateId: 1 },
+          function (err) { if (err) { debug(err); } });
+
+        self.snapshots.ensureIndex({ streamId: 1 },
+          function (err) { if (err) { debug(err); } });
+
         self.transactions = new mongo.Collection(client, options.transactionsCollectionName);
@@ -98,0 +128,0 @@

lib/databases/tingodb.js

@@ -43,2 +43,17 @@ 'use strict';
 
+    this.events.ensureIndex({ aggregateId: 1, aggregate: 1, context: 1 },
+      function (err) { if (err) { debug(err); } });
+
+    this.events.ensureIndex({ aggregateId: 1, aggregate: 1 },
+      function (err) { if (err) { debug(err); } });
+
+    this.events.ensureIndex({ aggregateId: 1 },
+      function (err) { if (err) { debug(err); } });
+
+    this.events.ensureIndex({ streamId: 1 },
+      function (err) { if (err) { debug(err); } });
+
+    this.events.ensureIndex({ dispatched: 1 },
+      function (err) { if (err) { debug(err); } });
+    
     this.events.ensureIndex({ commitStamp: 1, streamRevision: 1, commitSequence: 1 },
@@ -51,2 +66,17 @@ function (err) { if (err) { debug(err); } });
 
+    this.snapshots.ensureIndex({ revision: -1, version: -1, commitStamp: -1 },
+      function (err) { if (err) { debug(err); } });
+
+    this.snapshots.ensureIndex({ aggregateId: 1, aggregate: 1, context: 1 },
+      function (err) { if (err) { debug(err); } });
+
+    this.snapshots.ensureIndex({ aggregateId: 1, aggregate: 1 },
+      function (err) { if (err) { debug(err); } });
+
+    this.snapshots.ensureIndex({ aggregateId: 1 },
+      function (err) { if (err) { debug(err); } });
+
+    this.snapshots.ensureIndex({ streamId: 1 },
+      function (err) { if (err) { debug(err); } });
+
     this.transactions = this.db.collection(options.transactionsCollectionName + '.tingo');
@@ -53,0 +83,0 @@

package.json

 {
   "author": "adrai",
   "name": "eventstore",
-  "version": "1.0.5",
+  "version": "1.1.0",
   "contributors": [
@@ -53,3 +53,4 @@ {
     "redis": ">= 0.10.1",
-    "tingodb": ">= 0.0.1"
+    "tingodb": ">= 0.0.1",
+    "azure-storage": ">= 0.3.0"
   },
@@ -56,0 +57,0 @@ "scripts": {

README.md

@@ -9,3 +9,3 @@ # Introduction
 - event dispatching to your publisher (optional)
-- supported Dbs (inmemory, mongodb, redis, tingodb)
+- supported Dbs (inmemory, mongodb, redis, tingodb, azuretable)
 - snapshot support
@@ -77,2 +77,14 @@ - query your events
     });
+
+example with azuretable:
+
+    var es = require('eventstore')({
+      type: 'azuretable',
+      storageAccount: 'nodeeventstore',
+      storageAccessKey: 'aXJaod96t980AbNwG9Vh6T3ewPQnvMWAn289Wft9RTv+heXQBxLsY3Z4w66CI7NN12+1HUnHM8S3sUbcI5zctg==',
+      storageTableHost: 'https://nodeeventstore.table.core.windows.net/',
+      eventsTableName: 'events',             // optional
+      snapshotsTableName: 'snapshots',       // optional
+      timeout: 10000                              // optional
+    });
     
@@ -361,2 +373,3 @@
 4. tingodb ([tingodb](https://github.com/sergeyksv/tingodb))
+5. azuretable ([azure-storage](https://github.com/Azure/azure-storage-node))
 
@@ -363,0 +376,0 @@ ## own db implementation

releasenotes.md

@@ -0,1 +1,4 @@
+#### v1.1.0
+- added azure-table support [#21](https://github.com/adrai/node-eventstore/pull/21) thanks to [sbiaudet](https://github.com/sbiaudet)
+
 #### v1.0.5
@@ -26,3 +29,2 @@ - mongodb get all events fix [#20](https://github.com/adrai/node-eventstore/pull/20) thanks to [nikolaylukyanchuk](https://github.com/nikolaylukyanchuk)
 #### v0.7.0
-
 - make using of eventDispatcher configurable
@@ -32,11 +34,8 @@ - map getUndispatchedEvents and setEventToDispatched to eventstore
 #### v0.6.2
-
 - optimized storage initialization
 
 #### v0.6.1
-
 - forking of event dispatching is configurable now
 
 #### v0.6.0
-
 - removed couchDb implementation
@@ -47,3 +46,2 @@ - rewritten tests in mocha and expect.js
 #### v0.5.0
-
 - simplified API for storage usage
@@ -54,3 +52,2 @@ - if possible fork dispatching to own childprocess
 #### v0.3.0
-
 - eventstreams
@@ -60,2 +57,2 @@ - snapshoting
 - console.logger
-- db implementations for mongoDb, couchDb, redis
+- db implementations for mongoDb, couchDb, redis

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

94122

increased by21.68%

Number of package files

19

increased by11.76%

Lines of code

2322

increased by21.57%

Number of lines in readme file

424

increased by3.16%

Worsened metrics

Dev dependency count

7

increased by16.67%

No dependency changes