cqrs-eventdenormalizer
Advanced tools
Comparing version 0.3.4 to 0.3.5
@@ -120,2 +120,18 @@ var viewBuilderLoader = require('./loaders/viewBuilderLoader'), | ||
denormalize: function(evt, callback) { | ||
if (evt.event === 'commandRejected' && | ||
evt.payload && evt.payload.reason && | ||
evt.payload.reason.name === 'AggregateDestroyed') { | ||
if (revisionGuard && revisionGuard.store) { | ||
revisionGuard.store.getRevision(evt.payload.reason.aggregateId, function(err, entry) { | ||
if (entry.revision - 1 < evt.payload.reason.aggregateRevision) { | ||
evtDen.emit('eventMissing', evt.payload.reason.aggregateId, entry.revision, evt.payload.reason.aggregateRevision, evt); | ||
} | ||
}); | ||
} else { | ||
evtDen.emit('eventMissing', evt.payload.reason.aggregateId, 0, evt.payload.reason.aggregateRevision, evt); | ||
} | ||
} | ||
var entry = { | ||
@@ -122,0 +138,0 @@ // workers: eventEmitter.listeners('denormalize:' + evt.event).length, |
{ | ||
"author": "adrai", | ||
"name": "cqrs-eventdenormalizer", | ||
"version": "0.3.4", | ||
"version": "0.3.5", | ||
"private": false, | ||
@@ -6,0 +6,0 @@ "main": "index.js", |
@@ -135,2 +135,6 @@ # Introduction | ||
## v0.3.5 | ||
- emit missingEvent if commandRejected and revision not in sync | ||
## v0.3.4 | ||
@@ -137,0 +141,0 @@ |
47853
1182
193