feat: allow to overwrite event id strategy

src/event-bus.ts

@@ -5,12 +5,10 @@ import { catchError, filter, mergeMap } from 'rxjs/operators';
 import { CommandBus } from './command-bus';
 import { EVENTS_HANDLER_METADATA, SAGA_METADATA } from './decorators/constants';
 import { InvalidSagaException } from './exceptions';
-import {
-  defaultGetEventId,
-  defaultReflectEventId,
-} from './helpers/default-get-event-id';
+import { defaultEventIdProvider } from './helpers/default-event-id-provider';
 import { DefaultPubSub } from './helpers/default-pubsub';
 import {
+  EventIdProvider,
   ICommand,
   IEvent,
   IEventBus,
@@ -31,7 +29,7 @@ export class EventBus<EventBase extends IEvent = IEvent>
   extends ObservableBus<EventBase>
   implements IEventBus<EventBase>, OnModuleDestroy
 {
-  protected getEventId: (event: EventBase) => string | null;
+  public eventIdProvider: EventIdProvider<EventBase>;
   protected readonly subscriptions: Subscription[];
 
   private _publisher: IEventPublisher<EventBase>;
@@ -44,7 +42,7 @@ export class EventBus<EventBase extends IEvent = IEvent>
   ) {
     super();
     this.subscriptions = [];
-    this.getEventId = defaultGetEventId;
+    this.eventIdProvider = defaultEventIdProvider;
     this.useDefaultPublisher();
   }
 
@@ -146,13 +144,15 @@ export class EventBus<EventBase extends IEvent = IEvent>
     events.map((event) =>
       this.bind(
         instance as IEventHandler<EventBase>,
-        defaultReflectEventId(event),
+        this.eventIdProvider.reflectEventId(event),
       ),
     );
   }
 
   protected ofEventId(id: string) {
-    return this.subject$.pipe(filter((event) => this.getEventId(event) === id));
+    return this.subject$.pipe(
+      filter((event) => this.eventIdProvider.getEventId(event) === id),
+    );
   }
 
   protected registerSaga(saga: ISaga<EventBase>) {
@@ -191,7 +191,7 @@ export class EventBus<EventBase extends IEvent = IEvent>
 
   private reflectEvents(
     handler: EventHandlerType<EventBase>,
-  ): FunctionConstructor[] {
+  ): Array<Type<EventBase>> {
     return Reflect.getMetadata(EVENTS_HANDLER_METADATA, handler);
   }
 

src/helpers/default-event-id-provider.ts

@@ -0,0 +1,20 @@
+import { IEvent } from '../interfaces';
+import { EVENT_METADATA } from '../decorators/constants';
+import { Type } from '@nestjs/common';
+import { EventIdProvider } from '../interfaces';
+
+class DefaultEventIdProvider<EventBase extends IEvent = IEvent>
+  implements EventIdProvider<EventBase>
+{
+  getEventId(event: EventBase): string | null {
+    const { constructor } = Object.getPrototypeOf(event);
+
+    return this.reflectEventId(constructor);
+  }
+
+  reflectEventId(event: Type<EventBase>): string | null {
+    return Reflect.getMetadata(EVENT_METADATA, event)?.id ?? null;
+  }
+}
+
+export const defaultEventIdProvider = new DefaultEventIdProvider();

src/interfaces/events/event-id-provider.interface.ts

@@ -0,0 +1,10 @@
+import { IEvent } from './event.interface';
+import { Type } from '@nestjs/common';
+
+export interface EventIdProvider<EventBase extends IEvent = IEvent> {
+  /**
+   * Null if the published class is not connected to any handler
+   */
+  getEventId(event: EventBase): string | null;
+  reflectEventId(event: Type<EventBase>): string | null;
+}

src/interfaces/index.ts

@@ -7,6 +7,7 @@ export * from './events/event-handler.interface';
 export * from './events/event-publisher.interface';
 export * from './events/event.interface';
 export * from './events/message-source.interface';
+export * from './events/event-id-provider.interface';
 export * from './exceptions/unhandled-exception-info.interface';
 export * from './exceptions/unhandled-exception-publisher.interface';
 export * from './queries/query-bus.interface';