cqrs-eventdenormalizer - npm Package Compare versions

Comparing version 1.8.5 to 1.9.0

lib/definitions/viewBuilder.js

@@ -80,2 +80,4 @@ 'use strict';
   });
+
+  this.onAfterCommit(function (evt, vm) {});
 }
@@ -316,2 +318,12 @@
             retry(arguments[0], arguments[1]);
+          },
+
+          toRemember: null,
+
+          remindMe: function (memories) {
+            denormThis.toRemember = memories;
+          },
+
+          getReminder: function (memories) {
+            return denormThis.toRemember;
           }
@@ -349,3 +361,9 @@ };
 
-              callback(null, notification);
+              self.handleAfterCommit.call(denormThis, evt, vm, function (err) {
+                if (err) {
+                  debug(err);
+                  return callback(err);
+                }
+                callback(null, notification);
+              });
             });
@@ -595,2 +613,26 @@ });
     return this;
+  },
+
+  /**
+   * Inject onAfterCommit function.
+   * @param   {Function}  fn      The function to be injected.
+   * @returns {ViewBuilder} to be able to chain...
+   */
+  onAfterCommit: function (fn) {
+    if (!fn || !_.isFunction(fn)) {
+      var err = new Error('Please pass a valid function!');
+      debug(err);
+      throw err;
+    }
+
+    if (fn.length === 3) {
+      this.handleAfterCommit = fn;
+      return this;
+    }
+
+    this.handleAfterCommit = function (evt, vm, callback) {
+      callback(null, fn(evt, vm));
+    };
+
+    return this;
   }
@@ -597,0 +639,0 @@

package.json

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

README.md

@@ -562,2 +562,4 @@ # Introduction
 	  vm.set('lastname', data.lastname);
+	  //this.remindMe({ that: 'important value' });
+	  //this.retry();
 	});
@@ -589,2 +591,16 @@ // optional define a function that returns a query that will be used as query to find the viewmodels (but do not define the query in the options)
 	//});
+	// 
+	// optional define a function that checks if an event should be handled
+	//.onAfterCommit(function (evt, vm) {
+	//  //var memories = this.getReminder();
+	//  //console.log(memories.that); // 'important value'
+	//  //doSomethingStrange()
+	//});
+	// or
+	//.onAfterCommit(function (evt, vm, callback) {
+	//  var memories = this.getReminder();
+	//  //console.log(memories.that); // 'important value'
+	//  // doSomethingStrange(callback)
+	//  callback(memories.that === 'important value' ? null : new Error('important value not set'));
+	//});
 
@@ -591,0 +607,0 @@ ## EventExtender

releasenotes.md

@@ -0,1 +1,4 @@
+## [v1.9.0](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.8.5...v1.9.0)
+- viewbuilder: introduce onAfterCommit function
+
 ## [v1.8.5](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.8.4...v1.8.5)
@@ -2,0 +5,0 @@ - fix defaultPayload stuff for viewbuilder

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

157897

increased by1.15%

Lines of code

3680

increased by0.93%

Number of lines in readme file

816

increased by2%

No dependency changes