fix: await events to be registered (#11)

Author: MarcK98

src/services/listener-explorer.service.ts

@@ -17,6 +17,8 @@ export class ListenerExplorerService implements OnModuleInit {
   public readonly listeners: { event: WorkerEventName; callback: Function }[] =
     [];
 
+  private resolveInitialized: () => void;
+
   constructor(
     private readonly discoveryService: DiscoveryService,
     private readonly metadataAccessor: MetadataAccessorService,
@@ -27,6 +29,12 @@ export class ListenerExplorerService implements OnModuleInit {
     this.explore();
   }
 
+  async ensureInitialized(): Promise<void> {
+    return new Promise((resolve) => {
+      this.resolveInitialized = resolve;
+    });
+  }
+
   explore() {
     const providers: InstanceWrapper[] = this.discoveryService
       .getProviders()
@@ -59,6 +67,8 @@ export class ListenerExplorerService implements OnModuleInit {
           }
         },
       );
+
+      this.resolveInitialized();
     });
   }
 }

src/services/worker.service.ts

@@ -93,7 +93,8 @@ export class WorkerService {
     this.isMigrationDone = true;
   }
 
-  private hookEvents() {
+  private async hookEvents() {
+    await this.listenerExplorerService.ensureInitialized();
     const events = this.listenerExplorerService.listeners.map(
       ({ event }) => event,
     );