cqrs-eventdenormalizer
Advanced tools
Comparing version 1.16.54 to 1.16.55
@@ -412,2 +412,3 @@ var Definition = require('../definitionBase'), | ||
} | ||
this.repository.find(query, queryOptions, function (err, vms) { | ||
@@ -419,2 +420,5 @@ if (err) { | ||
vms.forEach(function (vm) { | ||
if (!localFoundVms[vm.id] && self.replayingVms[vm.id]) { | ||
localFoundVms[vm.id] = self.replayingVms[vm.id]; | ||
} | ||
if (localFoundVms[vm.id]) return; // optimize a bit | ||
@@ -478,7 +482,7 @@ | ||
function prepareVmsForBulkCommit (vms) { | ||
return _.map(_.filter(vms, function(vm) { return vm.actionOnCommitForReplay }), function (vm) { | ||
return _.map(_.filter(vms, function(vm) { return vm.actionOnCommitForReplay; }), function (vm) { | ||
vm.actionOnCommit = vm.actionOnCommitForReplay; | ||
delete vm.actionOnCommitForReplay; | ||
return vm; | ||
}) | ||
}); | ||
} | ||
@@ -485,0 +489,0 @@ |
@@ -32,2 +32,3 @@ var util = require('util'), | ||
defaultOpt.autoReconnect = false; | ||
defaultOpt.useNewUrlParser = true; | ||
_.defaults(options.options, defaultOpt); | ||
@@ -34,0 +35,0 @@ } else { |
{ | ||
"author": "adrai", | ||
"name": "cqrs-eventdenormalizer", | ||
"version": "1.16.54", | ||
"version": "1.16.55", | ||
"private": false, | ||
@@ -19,3 +19,3 @@ "main": "index.js", | ||
"jsondate": "0.0.1", | ||
"lodash": "4.17.11", | ||
"lodash": "4.17.15", | ||
"parent-require": "1.0.0", | ||
@@ -22,0 +22,0 @@ "sift": "5.0.0", |
@@ -917,3 +917,3 @@ # Introduction | ||
Copyright (c) 2018 Adriano Raiano | ||
Copyright (c) 2019 Adriano Raiano | ||
@@ -920,0 +920,0 @@ Permission is hereby granted, free of charge, to any person obtaining a copy |
@@ -0,1 +1,4 @@ | ||
## [v1.16.55](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.16.54...v1.16.55) | ||
- fix edge case during replay whe using query | ||
## [v1.16.54](https://github.com/adrai/node-cqrs-eventdenormalizer/compare/v1.16.52...v1.16.54) | ||
@@ -2,0 +5,0 @@ - update viewmodel |
Sorry, the diff of this file is not supported yet
208138
4724
+ Addedlodash@4.17.15(transitive)
Updatedlodash@4.17.15