cqrs-eventdenormalizer - npm Package Compare versions

Comparing version 1.1.4 to 1.1.5

lib/definitions/viewBuilder.js

@@ -59,2 +59,9 @@ 'use strict';
   this.denormFn = denormFn;
+  
+  if (denormFn.length === 2) {
+    this.denormFn = function (evtData, vm, clb) {
+      denormFn(evtData, vm);
+      clb(null);
+    }
+  }
 
@@ -226,8 +233,3 @@ this.idGenerator(function () {
     debug('call denormalizer function');
-    this.denormFn(_.cloneDeep(payload), vm);
-
-    var notification = this.generateNotification(evt, vm);
-
-    debug('generate new id for notification');
-    this.getNewId(function (err, newId) {
+    this.denormFn(_.cloneDeep(payload), vm, function (err) {
       if (err) {
@@ -238,29 +240,40 @@ debug(err);
 
-      dotty.put(notification, self.definitions.notification.id, newId);
+      var notification = self.generateNotification(evt, vm);
 
-      self.saveViewModel(vm, function (err) {
+      debug('generate new id for notification');
+      self.getNewId(function (err, newId) {
         if (err) {
           debug(err);
+          return callback(err);
+        }
 
-          if (err instanceof ConcurrencyError) {
-            var retryIn = randomBetween(0, self.options.retryOnConcurrencyTimeout || 800);
-            debug('retry in ' + retryIn + 'ms');
-            setTimeout(function() {
-              self.loadViewModel(vm.id, function (err, vm) {
-                if (err) {
-                  debug(err);
-                  return callback(err);
-                }
+        dotty.put(notification, self.definitions.notification.id, newId);
 
-                self.handleOne(vm, evt, callback);
-              });
-            }, retryIn);
-            return;
+        self.saveViewModel(vm, function (err) {
+          if (err) {
+            debug(err);
+
+            if (err instanceof ConcurrencyError) {
+              var retryIn = randomBetween(0, self.options.retryOnConcurrencyTimeout || 800);
+              debug('retry in ' + retryIn + 'ms');
+              setTimeout(function() {
+                self.loadViewModel(vm.id, function (err, vm) {
+                  if (err) {
+                    debug(err);
+                    return callback(err);
+                  }
+
+                  self.handleOne(vm, evt, callback);
+                });
+              }, retryIn);
+              return;
+            }
+
+            return callback(err);
           }
 
-          return callback(err);
-        }
+          callback(null, notification);
+        });
+      });
 
-        callback(null, notification);
-      });
     });
@@ -267,0 +280,0 @@ },

package.json

 {
   "author": "adrai",
   "name": "cqrs-eventdenormalizer",
-  "version": "1.1.4",
+  "version": "1.1.5",
   "private": false,
@@ -6,0 +6,0 @@ "main": "index.js",

releasenotes.md

@@ -0,1 +1,4 @@
+## [v1.1.5](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.1.4...v1.1.5)
+- async viewBuilders
+
 ## [v1.1.4](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.1.3...v1.1.4)
@@ -2,0 +5,0 @@ - update viewmodel dependency

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

Lines of code

3097

increased by0.36%

Worsened metrics

Total package byte prevSize

173239

decreased by-1.88%

No dependency changes