feat: add module options

Author: onhate

src/bus.spec.ts

@@ -1,6 +1,6 @@
 import { Injectable, Scope } from '@nestjs/common';
 import { Test } from '@nestjs/testing';
-import { DefaultEventEmitter, Emitter, EventBus, EventBusModule, From, On } from './index';
+import { DefaultEventEmitter, Emitter, EventBus, EventBusModule, EventBusModuleOptions, From, On } from './index';
 
 @Emitter('mocked')
 class MockEmitter extends DefaultEventEmitter {}
@@ -59,12 +59,17 @@ class MockOn {
   onTestFromMocked(payload: any) {
     this.calls('mocked', payload);
   }
+
+  @On('test.*')
+  onTestWildcard(payload: any) {
+    this.calls('test.*', payload);
+  }
 }
 
 describe('Module Tests', () => {
-  async function setup() {
+  async function setup(config?: EventBusModuleOptions) {
     const module = Test.createTestingModule({
-      imports: [EventBusModule.forRoot()],
+      imports: [EventBusModule.forRoot(config)],
       providers: [MockEmitter, MockOn, MockOnRequest]
     });
     return module.compile().then(module => module.init());
@@ -126,4 +131,19 @@ describe('Module Tests', () => {
     const actual = module.get(EventBus).emitAsync('rethrow', { _: 'error' });
     await expect(actual).rejects.toThrow('rethrow');
   });
+
+  it('should work with evementemitter2 options (wildcard)', async () => {
+    const module = await setup({
+      wildcard: true,
+      delimiter: '.'
+    });
+
+    await module.get(EventBus).emitAsync('test.one', { _: '1' });
+    await module.get(EventBus).emitAsync('test.two', { _: '2' });
+
+    const actual = module.get(MockOn).calls;
+    expect(actual).toBeCalledTimes(2);
+    expect(actual).toBeCalledWith('test.*', { _: '1' });
+    expect(actual).toBeCalledWith('test.*', { _: '2' });
+  });
 });

src/definitions.ts

@@ -1,4 +1,11 @@
-import { EventEmitter2 } from 'eventemitter2';
+import { Inject, Optional } from '@nestjs/common';
+import { ConstructorOptions, EventEmitter2 } from 'eventemitter2';
 
 export type IEventEmitter = Pick<EventEmitter2, 'emitAsync' | 'on' | 'off'>;
-export { EventEmitter2 as DefaultEventEmitter };
+
+
+export class DefaultEventEmitter extends EventEmitter2 implements IEventEmitter {
+  constructor(@Optional() @Inject('Options') options?: ConstructorOptions) {
+    super(options);
+  }
+}

src/module.ts

@@ -1,17 +1,33 @@
 import { DynamicModule, Module } from '@nestjs/common';
 import { DiscoveryModule } from '@nestjs/core';
+import { ConstructorOptions } from 'eventemitter2';
 import { DefaultEventEmitter } from './definitions';
 import { EventBus } from './eventbus';
 import { EventBusInitializer } from './initializer';
 
+export interface EventBusModuleOptions extends ConstructorOptions {
+  /**
+   * If "true", registers `EventEmitterModule` as a global module.
+   * See: https://docs.nestjs.com/modules#global-modules
+   *
+   * @default true
+   */
+  global?: boolean;
+}
+
 @Module({})
 export class EventBusModule {
-  static forRoot(options?: any): DynamicModule {
+  static forRoot(options?: EventBusModuleOptions): DynamicModule {
     return {
       global: options?.global ?? true,
       module: EventBusModule,
       imports: [DiscoveryModule],
-      providers: [EventBusInitializer, EventBus, DefaultEventEmitter],
+      providers: [
+        { provide: 'Options', useValue: options },
+        EventBusInitializer,
+        EventBus,
+        DefaultEventEmitter
+      ],
       exports: [EventBus, DefaultEventEmitter]
     };
   }