Fixing undefined schemaVersion on autofill + test (#196)

* Fixing undefined schemaVersion on autofill + test

* core patch release prepare

Author: CarlosGamero

packages/core/lib/events/DomainEventEmitter.spec.ts

@@ -114,6 +114,9 @@ describe('AutopilotEventEmitter', () => {
     })
     expect(fakeListener.receivedEvents[0].metadata).toMatchObject({
       correlationId: expect.any(String),
+      schemaVersion: '1.0.0',
+      producedBy: 'test',
+      originatedFrom: 'test',
     })
   })
 

packages/core/lib/events/DomainEventEmitter.ts

@@ -72,15 +72,12 @@ export class DomainEventEmitter<SupportedEvents extends CommonEventDefinition[]>
     }
 
     if (!data.metadata) {
-      data.metadata = precedingMessageMetadata
-        ? // @ts-ignore
-          this.metadataFiller.produceMetadata(data, supportedEvent, precedingMessageMetadata)
-        : {
-            correlationId: this.metadataFiller.produceId(),
-            schemaVersion: supportedEvent.schemaVersion,
-            producedBy: this.metadataFiller.produceCurrentServiceId(),
-            originatedFrom: this.metadataFiller.produceCurrentServiceId(),
-          }
+      data.metadata = this.metadataFiller.produceMetadata(
+        // @ts-ignore
+        data,
+        supportedEvent,
+        precedingMessageMetadata ?? {},
+      )
     }
 
     if (!data.metadata.correlationId) {

packages/core/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@message-queue-toolkit/core",
-  "version": "16.0.0",
+  "version": "16.0.1",
   "private": false,
   "license": "MIT",
   "description": "Useful utilities, interfaces and base classes for message queue handling. Supports AMQP and SQS with a common abstraction on top currently",