cqrs-eventdenormalizer - npm Package Compare versions

Comparing version 1.13.1 to 1.14.0

lib/definitions/collection.js

@@ -475,7 +475,33 @@ var Definition = require('../definitionBase'),
 
+    function prepareVmsForBulkCommit (vms) {
+      return _.map(_.filter(vms, function(vm) { return vm.actionOnCommitForReplay }), function (vm) {
+        vm.actionOnCommit = vm.actionOnCommitForReplay;
+        delete vm.actionOnCommitForReplay;
+        return vm;
+      })
+    }
+
+    function bulkCommit (vms, callback) {
+      self.repository.bulkCommit(prepareVmsForBulkCommit(vms), function (err) {
+        if (err) {
+          debug(err);
+          debug(vm);
+        }
+        callback(err);
+      });
+    }
+
     async.series([
       function (callback) {
+        if (self.repository.bulkCommit) {
+          bulkCommit(replVmsToDelete, callback);
+          return;
+        }
         async.each(replVmsToDelete, commit, callback);
       },
       function (callback) {
+        if (self.repository.bulkCommit) {
+          bulkCommit(replVms, callback);
+          return;
+        }
         async.each(replVms, commit, callback);
@@ -482,0 +508,0 @@ }

package.json

 {
   "author": "adrai",
   "name": "cqrs-eventdenormalizer",
-  "version": "1.13.1",
+  "version": "1.14.0",
   "private": false,
@@ -24,3 +24,3 @@ "main": "index.js",
     "uuid": "3.1.0",
-    "viewmodel": "1.8.1"
+    "viewmodel": "1.9.0"
   },
@@ -27,0 +27,0 @@ "devDependencies": {

releasenotes.md

@@ -0,1 +1,4 @@
+## [v1.13.1](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.13.1...v1.13.0)
+- make use of optional bulkCommit for replay
+
 ## [v1.13.1](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.13.0...v1.13.1)
@@ -2,0 +5,0 @@ - remove deprecated option max_attempts from redis options

No alert changes

Improved metrics

Total package byte prevSize

197767

increased by0.45%

Lines of code

4572

increased by0.53%

Dependency changes

• + Addedviewmodel@1.9.0(transitive)

• - Removedviewmodel@1.8.1(transitive)

• Updatedviewmodel@1.9.0