fix: event listeners are not registered (#4)

* chore: add prepare script

* fix: move listener services to own module

* fix: call explore methods in constructors instead of onModuleInit hooks

Co-authored-by: Myroslav Kiurchev <[email protected]>

Author: madeindjs

package.json

@@ -16,6 +16,7 @@
   "main": "dist/index.js",
   "types": "dist/index.d.ts",
   "scripts": {
+    "prepare": "npm run build",
     "prebuild": "rimraf dist",
     "build": "nest build",
     "sample": "nodemon",

src/services/listener-explorer.service.ts

@@ -11,7 +11,7 @@ import { MetadataAccessorService } from './metadata-accessor.service';
  * Heavily inspired from [`BullExplorer`](https://github.com/nestjs/bull/blob/c230eab1dc26fb743a3428e61043167866b1e377/lib/bull.explorer.ts)
  */
 @Injectable()
-export class ListenerExplorerService implements OnModuleInit {
+export class ListenerExplorerService {
   private readonly logger = new Logger(ListenerExplorerService.name);
 
   public readonly listeners: { event: WorkerEventName; callback: Function }[] =
@@ -21,9 +21,7 @@ export class ListenerExplorerService implements OnModuleInit {
     private readonly discoveryService: DiscoveryService,
     private readonly metadataAccessor: MetadataAccessorService,
     private readonly metadataScanner: MetadataScanner,
-  ) {}
-
-  onModuleInit() {
+  ) {
     this.explore();
   }
 

src/services/task-explorer.service.ts

@@ -11,7 +11,7 @@ import { MetadataAccessorService } from './metadata-accessor.service';
  * Heavily inspired from [`BullExplorer`](https://github.com/nestjs/bull/blob/c230eab1dc26fb743a3428e61043167866b1e377/lib/bull.explorer.ts)
  */
 @Injectable()
-export class TaskExplorerService implements OnModuleInit {
+export class TaskExplorerService {
   private readonly logger = new Logger(TaskExplorerService.name);
 
   public readonly taskList: TaskList = {};
@@ -20,9 +20,7 @@ export class TaskExplorerService implements OnModuleInit {
     private readonly discoveryService: DiscoveryService,
     private readonly metadataAccessor: MetadataAccessorService,
     private readonly metadataScanner: MetadataScanner,
-  ) {}
-
-  onModuleInit() {
+  ) {
     this.explore();
   }
 

src/services/worker.service.ts

@@ -101,7 +101,7 @@ export class WorkerService {
     for (const event of uniq(events)) {
       this.options.events.on(event, (...args: any[]) => {
         this.listenerExplorerService.listeners
-          .filter(({ event }) => event === event)
+          .filter((listener) => listener.event === event)
           .forEach(({ callback }) => callback(...args));
       });
     }