Lint fix

kibertoad · Jul 26, 2024 · 4bba4c2 · 4bba4c2
1 parent 677d24a
commit 4bba4c2
Show file tree

Hide file tree

Showing 5 changed files with 37 additions and 43 deletions.
diff --git a/packages/core/lib/events/DomainEventEmitter.spec.ts b/packages/core/lib/events/DomainEventEmitter.spec.ts
@@ -162,10 +162,10 @@ describe('AutopilotEventEmitter', () => {
     expect(emitResult.message).toEqual({
       id: expect.any(String),
       metadata: {
-        "correlationId": createdEventPayload.metadata!.correlationId!,
-        "originatedFrom": "service",
-        "producedBy": undefined,
-        "schemaVersion": "1",
+        correlationId: createdEventPayload.metadata!.correlationId!,
+        originatedFrom: 'service',
+        producedBy: undefined,
+        schemaVersion: '1',
       },
       payload: {
         message: 'msg',

diff --git a/packages/core/lib/events/fakes/FakeListener.ts b/packages/core/lib/events/fakes/FakeListener.ts
@@ -9,9 +9,7 @@ export class FakeListener<SupportedEvents extends CommonEventDefinition[]>
     this.receivedEvents = []
   }
 
-  handleEvent(
-    event: SupportedEvents[number]['publisherSchema']['_output'],
-  ): void | Promise<void> {
+  handleEvent(event: SupportedEvents[number]['publisherSchema']['_output']): void | Promise<void> {
     this.receivedEvents.push(event)
   }
 }
diff --git a/packages/core/lib/messages/MetadataFiller.ts b/packages/core/lib/messages/MetadataFiller.ts
@@ -59,9 +59,7 @@ export class CommonMetadataFiller implements MetadataFiller {
     return {
       producedBy: this.serviceId,
       originatedFrom: precedingMessageMetadata?.originatedFrom ?? this.serviceId,
-      schemaVersion:
-        eventDefinition.schemaVersion ??
-        this.defaultVersion,
+      schemaVersion: eventDefinition.schemaVersion ?? this.defaultVersion,
       correlationId: precedingMessageMetadata?.correlationId ?? this.produceId(),
     }
   }

diff --git a/packages/schemas/lib/events/baseEventSchemas.ts b/packages/schemas/lib/events/baseEventSchemas.ts
@@ -3,38 +3,38 @@ import { z } from 'zod'
 
 // External message metadata that describe the context in which the message was created, primarily used for debugging purposes
 export const PUBLISHER_MESSAGE_METADATA_SCHEMA = z
-    .object({
-      schemaVersion: z.optional(z.string().min(1).describe('message schema version')),
-      // this is always set to a service that created the message
-      producedBy: z.optional(z.string().min(1).describe('app/service that produced the message')),
-      // this is always propagated within the message chain. For the first message in the chain it is equal to "producedBy"
-      originatedFrom: z.optional(
-          z
-              .string()
-              .min(1)
-              .describe('app/service that initiated entire workflow that led to creating this message'),
-      ),
-      // this is always propagated within the message chain.
-      correlationId: z.optional(
-          z.string().describe('unique identifier passed to all events in workflow chain'),
-      ),
-    })
-    .describe('external message metadata')
+  .object({
+    schemaVersion: z.optional(z.string().min(1).describe('message schema version')),
+    // this is always set to a service that created the message
+    producedBy: z.optional(z.string().min(1).describe('app/service that produced the message')),
+    // this is always propagated within the message chain. For the first message in the chain it is equal to "producedBy"
+    originatedFrom: z.optional(
+      z
+        .string()
+        .min(1)
+        .describe('app/service that initiated entire workflow that led to creating this message'),
+    ),
+    // this is always propagated within the message chain.
+    correlationId: z.optional(
+      z.string().describe('unique identifier passed to all events in workflow chain'),
+    ),
+  })
+  .describe('external message metadata')
 
 export const CONSUMER_MESSAGE_METADATA_SCHEMA = z
-    .object({
-      schemaVersion: z.string().min(1).describe('message schema version'),
-      // this is always set to a service that created the message
-      producedBy: z.string().min(1).describe('app/service that produced the message'),
-      // this is always propagated within the message chain. For the first message in the chain it is equal to "producedBy"
-      originatedFrom: z
-          .string()
-          .min(1)
-          .describe('app/service that initiated entire workflow that led to creating this message'),
-      // this is always propagated within the message chain.
-      correlationId: z.string().describe('unique identifier passed to all events in workflow chain'),
-    })
-    .describe('external message metadata')
+  .object({
+    schemaVersion: z.string().min(1).describe('message schema version'),
+    // this is always set to a service that created the message
+    producedBy: z.string().min(1).describe('app/service that produced the message'),
+    // this is always propagated within the message chain. For the first message in the chain it is equal to "producedBy"
+    originatedFrom: z
+      .string()
+      .min(1)
+      .describe('app/service that initiated entire workflow that led to creating this message'),
+    // this is always propagated within the message chain.
+    correlationId: z.string().describe('unique identifier passed to all events in workflow chain'),
+  })
+  .describe('external message metadata')
 
 // Base event fields that are typically autogenerated
 export const GENERATED_BASE_EVENT_SCHEMA = z.object({

diff --git a/packages/schemas/lib/events/eventTypes.ts b/packages/schemas/lib/events/eventTypes.ts
@@ -39,9 +39,7 @@ export type EventHandler<
   EventDefinitionSchema extends
     CommonEventDefinitionPublisherSchemaType<CommonEventDefinition> = CommonEventDefinitionPublisherSchemaType<CommonEventDefinition>,
 > = {
-  handleEvent(
-    event: EventDefinitionSchema
-  ): void | Promise<void>
+  handleEvent(event: EventDefinitionSchema): void | Promise<void>
 }
 
 export type AnyEventHandler<EventDefinitions extends CommonEventDefinition[]> = EventHandler<