cqrs-eventdenormalizer - npm Package Compare versions

Comparing version 0.3.3 to 0.3.4

lib/bases/eventExtenderBase.js

@@ -54,2 +54,9 @@ var _ = require('lodash')
 
+        if (evt.head &&
+            evt.head.version !== null &&
+            evt.head.version !== undefined &&
+            this[fnName + '_' + evt.head.version]) {
+            fnName = fnName + '_' + evt.head.version;
+        }
+
         if(this[fnName]) {
@@ -56,0 +63,0 @@ // Call the event handler found by map-reduce.

lib/bases/viewBuilderBase.js

@@ -75,3 +75,16 @@ var _ = require('lodash'),
           return item;
-        } else if (item.event && item.event === evt.event && item.method) {
+        } else if (evt.head &&
+                   evt.head.version !== null &&
+                   evt.head.version !== undefined &&
+                   item.event === evt.event &&
+                   item.version === evt.head.version) {
+
+          if (item.method) {
+            return item.method;
+          } else {
+            return item.event + '_' + evt.head.version;
+          }
+        }
+
+        if (item.event && item.event === evt.event && item.method) {
           return item.method;
@@ -96,10 +109,24 @@ } else if (item.event && item.event == evt.event) {
       var vmIdPath = 'payload.id',
-          payload = 'payload';
+          payload = 'payload',
+          settings = null;
 
-      var settings = _.find(this.events, function(item) {
-        if (item.event && item.event === evt.event) {
-          return item;
-        }
-      });
+      if (evt.head &&
+          evt.head.version !== null &&
+          evt.head.version !== undefined) {
+        settings = _.find(this.events, function(item) {
+          if (item.event && item.event === evt.event &&
+            evt.head.version === item.version) {
+            return item;
+          }
+        });
+      }
 
+      if (!settings) {
+        settings = _.find(this.events, function(item) {
+          if (item.event && item.event === evt.event) {
+            return item;
+          }
+        });
+      }
+
       if (settings && settings.viewModelId) {
@@ -106,0 +133,0 @@ vmIdPath = settings.viewModelId;

lib/loaders/eventExtenderLoader.js

@@ -58,3 +58,3 @@ var existsSync = require('fs').existsSync || require('path').existsSync
             function action(evt) {
-                eventExtender.handle(evt); 
+                eventExtender.handle(evt);
             }
@@ -61,0 +61,0 @@

package.json

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

README.md

@@ -76,16 +76,29 @@ # Introduction
             'dummySpezi',
-            'somethingFlushed'
+            'somethingFlushed',
+            {
+                event: 'versioned'
+            },
+            {
+                event: 'versioned'
+                version: 1
+            }
         ],
 
-      collectionName: 'dummies',
+        collectionName: 'dummies',
 
-      dummied: function(data, vm, evt) {
-      },
+        dummied: function(data, vm, evt) {
+        },
+  
+        dummySpezi: function(data, vm, evt) {
+          vm.otherValue = 'value';
+        },
+  
+        somethingFlushed: function(data, vm, evt) {
+        },
 
-      dummySpezi: function(data, vm, evt) {
-        vm.otherValue = 'value';
-      },
+        versioned: function(data, vm, evt) {
+        },
 
-      somethingFlushed: function(data, vm, evt) {
-      }
+        versioned_1: function(data, vm, evt) {
+        }
 
@@ -123,2 +136,6 @@ });
 
+## v0.3.4
+
+- handle versioned events
+
 ## v0.3.3
@@ -125,0 +142,0 @@

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

47100

increased by2.91%

Lines of code

1169

increased by2.63%

Number of lines in readme file

189

increased by9.88%

No dependency changes