You're Invited:Meet the Socket Team at BlackHat and DEF CON in Las Vegas, Aug 7-8.RSVP
Socket
Socket
Sign inDemoInstall

cqrs-eventdenormalizer

Package Overview
Dependencies
Maintainers
1
Versions
169
Alerts
File Explorer

Advanced tools

Install Socket

Detect and block malicious and high-risk dependencies

Install

Comparing version 0.3.4 to 0.3.5

16

lib/eventDenormalizer.js

@@ -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,

2

package.json
{
"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 @@

SocketSocket SOC 2 Logo

Product

  • Package Alerts
  • Integrations
  • Docs
  • Pricing
  • FAQ
  • Roadmap
  • Changelog

Packages

Stay in touch

Get open source security insights delivered straight into your inbox.


  • Terms
  • Privacy
  • Security

Made with ⚡️ by Socket Inc