From 6407e307ec02e51bd5f25a7d8b26d4faf5e2aa1d Mon Sep 17 00:00:00 2001 From: Vincent Vermersch Date: Fri, 10 Jan 2020 11:36:32 +0100 Subject: [PATCH] Add metadata, eventId, eventStream, event created date when calling initator --- src/event-store/eventstore-cqrs/event-store.bus.ts | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/src/event-store/eventstore-cqrs/event-store.bus.ts b/src/event-store/eventstore-cqrs/event-store.bus.ts index b2ef075..b083869 100644 --- a/src/event-store/eventstore-cqrs/event-store.bus.ts +++ b/src/event-store/eventstore-cqrs/event-store.bus.ts @@ -187,8 +187,9 @@ export class EventStoreBus { this.logger.error('Received event that could not be handled!'); return; } - const data = Object.values(JSON.parse(event.data.toString())); - this.subject$.next(this.eventHandlers[event.eventType](...data)); + const data = JSON.parse(event.data.toString()); + const metadata = JSON.parse(event.metadata.toString()); + this.subject$.next(this.eventHandlers[event.eventType](data, metadata, event.eventId, event.eventStreamId, new Date(event.created))); } onDropped(