Comments (5)
adrai
commented on June 25, 2024
I think this has nothing to do with eventstore...
but, without knowing how this is set up, I can't really help you. :-(
from node-eventstore.
sameer-convergentappworks
commented on June 25, 2024
Possibly. I am using Mongo for store.
After few trials, looks like it could be due to the JSON with empty arrays or nested object with array.
Will keep you posted..
from node-eventstore.
sameer-convergentappworks
commented on June 25, 2024
Sorry for not giving you a proper test for reproducing, but I think this seems to fix the issue.
For arrays properties I have to check if they exist and have elements
for other properties
if (data.peps !== undefined && data.peps.length > 0) {
vm.set("peps", data.peps);
}
and because I pick out array properties for setting I have to repeat the following for other non array properties.
if (data.existingClient !== undefined) {
vm.set("existingClient", data.existingClient);
}
Need to dig deep in code for vm.set for Mongo store.
from node-eventstore.
sameer-convergentappworks
commented on June 25, 2024
hi adrai,
I have got better logs now. I use mongo store.
The logs show error in loop. I have to kill the process to stop. Does it help ?
myprojectname.eventDenormalizer eventDenormalizer -- denormalize event +121ms {
"event": "detailsUpdated",
"payload": {
"_id": "56b84db219adf8c8224f5952",
"id": "56b84db219adf8c8224f5952",
"peps": [],
"createdBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"tempTicketId": "cikdp9eq0001b64kgrti6hiak",
"status": "draft",
"auditTrail": [
{
"state": "draft",
"changedBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"timeChanged": "2016-02-08T08:11:30.223Z"
}
],
"commitStamp": 1454919090224,
"_hash": "56b84db2cd9b7b6c2ec4c56a"
},
"head": {
"revision": 4
},
"commandId": "msg1",
"aggregate": {
"name": "..removed..
},
"id": "d78966fa-39aa-46f0-88cb-4c8b4ea63510"
}
denormalizer:revisionGuard no revision in store => retry [concatenatedId]=approval56b84db219adf8c8224f5952, [revInStore]=null, [revInEvt]=4 +4s
denormalizer:revisionGuard no revision in store => retry [concatenatedId]=approval56b84db219adf8c8224f5952, [revInStore]=null, [revInEvt]=4 +723ms
denormalizer:revisionGuard no revision in store => retry [concatenatedId]=approval56b84db219adf8c8224f5952, [revInStore]=null, [revInEvt]=4 +324ms
denormalizer:revisionGuard finished loops for retry => proceed [concatenatedId]=approval56b84db219adf8c8224f5952, [revInStore]=null, [revInEvt]=4 +699ms
denormalizer:revisionGuard first revision to store [concatenatedId]=approval56b84db219adf8c8224f5952, [revInStore]=null, [revInEvt]=4 +3ms
denormalizer:eventDispatcher no version found, handling as version: 0 +4ms
denormalizer:eventDispatcher no context found +2ms
denormalizer:viewBuilder [detailsUpdated] found viewmodel id in event +8ms
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 call denormalizer function +15ms
myprojectname.viewBuilder saving detailsUpdated +3s {
"_id": "56b84db219adf8c8224f5952",
"id": "56b84db219adf8c8224f5952",
"peps": [],
"createdBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"tempTicketId": "cikdp9eq0001b64kgrti6hiak",
"status": "draft",
"auditTrail": [
{
"state": "draft",
"changedBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"timeChanged": "2016-02-08T08:11:30.223Z"
}
],
"commitStamp": 1454919090224,
"_hash": "56b84db2cd9b7b6c2ec4c56a"
}
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 generate new id for notification +20ms
denormalizer:viewBuilder ConcurrencyError
at C:\Temp\myprojectpath\node_modules\cqrs-eventdenormalizer\node_modules\viewmodel\lib\databases\mongodb.js:213:31
at C:\Temp\myprojectpath\node_modules\mongodb\lib\utils.js:96:12
at C:\Temp\myprojectpath\node_modules\mongodb\lib\collection.js:987:5
at C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:780:13
at [object Object].emit (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:95:3)
at [object Object].messageHandler (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:249:23)
at Socket.<anonymous> (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\connection\connection.js:265:22)
at Socket.emit (events.js:95:17)
at Socket.<anonymous> (_stream_readable.js:764:14)
at Socket.emit (events.js:92:17)
at emitReadable_ (_stream_readable.js:426:10)
at emitReadable (_stream_readable.js:422:5)
at readableAddChunk (_stream_readable.js:165:9)
at Socket.push (_stream_readable.js:127:10)
at TCP.onread (net.js:528:21) +6ms
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 retry in 38ms +9ms
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 call denormalizer function +46ms
myprojectname.viewBuilder saving detailsUpdated +78ms {
"_id": "56b84db219adf8c8224f5952",
"id": "56b84db219adf8c8224f5952",
"peps": [],
"createdBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"tempTicketId": "cikdp9eq0001b64kgrti6hiak",
"status": "draft",
"auditTrail": [
{
"state": "draft",
"changedBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"timeChanged": "2016-02-08T08:11:30.223Z"
}
],
"commitStamp": 1454919090224,
"_hash": "56b84db2cd9b7b6c2ec4c56a"
}
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 generate new id for notification +10ms
denormalizer:viewBuilder ConcurrencyError
at C:\Temp\myprojectpath\node_modules\cqrs-eventdenormalizer\node_modules\viewmodel\lib\databases\mongodb.js:213:31
at C:\Temp\myprojectpath\node_modules\mongodb\lib\utils.js:96:12
at C:\Temp\myprojectpath\node_modules\mongodb\lib\collection.js:987:5
at C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:780:13
at [object Object].emit (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:95:3)
at [object Object].messageHandler (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:249:23)
at Socket.<anonymous> (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\connection\connection.js:265:22)
at Socket.emit (events.js:95:17)
at Socket.<anonymous> (_stream_readable.js:764:14)
at Socket.emit (events.js:92:17)
at emitReadable_ (_stream_readable.js:426:10)
at emitReadable (_stream_readable.js:422:5)
at readableAddChunk (_stream_readable.js:165:9)
at Socket.push (_stream_readable.js:127:10)
at TCP.onread (net.js:528:21) +2ms
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 retry in 159ms +7ms
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 call denormalizer function +166ms
myprojectname.viewBuilder saving detailsUpdated +185ms {
"_id": "56b84db219adf8c8224f5952",
"id": "56b84db219adf8c8224f5952",
"peps": [],
"createdBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"tempTicketId": "cikdp9eq0001b64kgrti6hiak",
"status": "draft",
"auditTrail": [
{
"state": "draft",
"changedBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"timeChanged": "2016-02-08T08:11:30.223Z"
}
],
"commitStamp": 1454919090224,
"_hash": "56b84db2cd9b7b6c2ec4c56a"
}
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 generate new id for notification +11ms
denormalizer:viewBuilder ConcurrencyError
at C:\Temp\myprojectpath\node_modules\cqrs-eventdenormalizer\node_modules\viewmodel\lib\databases\mongodb.js:213:31
at C:\Temp\myprojectpath\node_modules\mongodb\lib\utils.js:96:12
at C:\Temp\myprojectpath\node_modules\mongodb\lib\collection.js:987:5
at C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:780:13
at [object Object].emit (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:95:3)
at [object Object].messageHandler (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:249:23)
at Socket.<anonymous> (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\connection\connection.js:265:22)
at Socket.emit (events.js:95:17)
at Socket.<anonymous> (_stream_readable.js:764:14)
at Socket.emit (events.js:92:17)
at emitReadable_ (_stream_readable.js:426:10)
at emitReadable (_stream_readable.js:422:5)
at readableAddChunk (_stream_readable.js:165:9)
at Socket.push (_stream_readable.js:127:10)
at TCP.onread (net.js:528:21) +1ms
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 retry in 583ms +6ms
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 call denormalizer function +590ms
myprojectname.viewBuilder saving detailsUpdated +610ms {
"_id": "56b84db219adf8c8224f5952",
"id": "56b84db219adf8c8224f5952",
"peps": [],
"createdBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"tempTicketId": "cikdp9eq0001b64kgrti6hiak",
"status": "draft",
"auditTrail": [
{
"state": "draft",
"changedBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"timeChanged": "2016-02-08T08:11:30.223Z"
}
],
"commitStamp": 1454919090224,
"_hash": "56b84db2cd9b7b6c2ec4c56a"
}
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 generate new id for notification +25ms
denormalizer:viewBuilder ConcurrencyError
at C:\Temp\myprojectpath\node_modules\cqrs-eventdenormalizer\node_modules\viewmodel\lib\databases\mongodb.js:213:31
at C:\Temp\myprojectpath\node_modules\mongodb\lib\utils.js:96:12
at C:\Temp\myprojectpath\node_modules\mongodb\lib\collection.js:987:5
at C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:780:13
at [object Object].emit (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:95:3)
at [object Object].messageHandler (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:249:23)
at Socket.<anonymous> (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\connection\connection.js:265:22)
at Socket.emit (events.js:95:17)
at Socket.<anonymous> (_stream_readable.js:764:14)
at Socket.emit (events.js:92:17)
at emitReadable_ (_stream_readable.js:426:10)
at emitReadable (_stream_readable.js:422:5)
at readableAddChunk (_stream_readable.js:165:9)
at Socket.push (_stream_readable.js:127:10)
at TCP.onread (net.js:528:21) +2ms
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 retry in 391ms +10ms
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 call denormalizer function +399ms
myprojectname.viewBuilder saving detailsUpdated +439ms {
"_id": "56b84db219adf8c8224f5952",
"id": "56b84db219adf8c8224f5952",
"peps": [],
"createdBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"tempTicketId": "cikdp9eq0001b64kgrti6hiak",
"status": "draft",
"auditTrail": [
{
"state": "draft",
"changedBy": {
"userid": "..removed..",
"id": "54dbab9f5cc06d449ca25cc6",
"name": "..removed.."
},
"timeChanged": "2016-02-08T08:11:30.223Z"
}
],
"commitStamp": 1454919090224,
"_hash": "56b84db2cd9b7b6c2ec4c56a"
}
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 generate new id for notification +29ms
denormalizer:viewBuilder ConcurrencyError
at C:\Temp\myprojectpath\node_modules\cqrs-eventdenormalizer\node_modules\viewmodel\lib\databases\mongodb.js:213:31
at C:\Temp\myprojectpath\node_modules\mongodb\lib\utils.js:96:12
at C:\Temp\myprojectpath\node_modules\mongodb\lib\collection.js:987:5
at C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:780:13
at [object Object].emit (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:95:3)
at [object Object].messageHandler (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\topologies\server.js:249:23)
at Socket.<anonymous> (C:\Temp\myprojectpath\node_modules\mongodb\node_modules\mongodb-core\lib\connection\connection.js:265:22)
at Socket.emit (events.js:95:17)
at Socket.<anonymous> (_stream_readable.js:764:14)
at Socket.emit (events.js:92:17)
at emitReadable_ (_stream_readable.js:426:10)
at emitReadable (_stream_readable.js:422:5)
at readableAddChunk (_stream_readable.js:165:9)
at Socket.push (_stream_readable.js:127:10)
at TCP.onread (net.js:528:21) +4ms
denormalizer:viewBuilder [detailsUpdated], [eventId]=d78966fa-39aa-46f0-88cb-4c8b4ea63510 retry in 741ms +11ms
from node-eventstore.
sameer-convergentappworks
commented on June 25, 2024
Not an issue. closing.
This was happening on the page where a command was fired twice. I wasn't pulling the latest state before the second command was fired. So _hash value used for second request was stale.
As a result the framework raised concurrency error which is correct.
from node-eventstore.
Related Issues (20)
- Mongo URL parser deprecated. HOT 2
- PostgreSQL data store HOT 4
- override commitStamp ? HOT 3
- Replaying events to rebuild aggregates HOT 2
- Release a new version with new lodash HOT 2
- Auto-reconnect MongoDB HOT 2
- Calling `es.init()` multiple times causes multiple `connect` & `disconnect` listeners to be added HOT 2
- When using tingodb, no more events are published after restarting app HOT 4
- Flag for dropping existing data when initializing? HOT 3
- Method for testing if there are any or how many events are stored? HOT 5
- MongoDB connection fails with current default options HOT 14
- DeprecationWarning: current Server Discovery and Monitoring engine is deprecated HOT 3
- User Interface HOT 1
- Question: Can I query snapshots by date? HOT 3
- MongoDB: "revision" field type should be casted to number when createSnapshot HOT 4
- [MongoDB] BUG: streamEventsByRevision omits first event and repeats last event. HOT 1
- Opposite of getEventsSince
- npm audit fail on dotty HOT 1
- Azure table is deprecated HOT 1
- batch workflows HOT 1
Recommend Projects
-
React
A declarative, efficient, and flexible JavaScript library for building user interfaces.
-
Vue.js
🖖 Vue.js is a progressive, incrementally-adoptable JavaScript framework for building UI on the web.
-
Typescript
TypeScript is a superset of JavaScript that compiles to clean JavaScript output.
-
TensorFlow
An Open Source Machine Learning Framework for Everyone
-
Django
The Web framework for perfectionists with deadlines.
-
Laravel
A PHP framework for web artisans
-
D3
Bring data to life with SVG, Canvas and HTML. 📊📈🎉
-
Recommend Topics
-
javascript
JavaScript (JS) is a lightweight interpreted programming language with first-class functions.
-
web
Some thing interesting about web. New door for the world.
-
server
A server is a program made to process requests and deliver data to clients.
-
Machine learning
Machine learning is a way of modeling and interpreting data that allows a piece of software to respond intelligently.
-
Visualization
Some thing interesting about visualization, use data art
-
Game
Some thing interesting about game, make everyone happy.
Recommend Org
-
Facebook
We are working to build community through open source technology. NB: members must have two-factor auth.
-
Microsoft
Open source projects and samples from Microsoft.
-
Google
Google ❤️ Open Source for everyone.
-
Alibaba
Alibaba Open Source for everyone
-
D3
Data-Driven Documents codes.
-
Tencent
China tencent open source team.
from node-eventstore.