fix: use correct event manager for actor methods (#49)

packages/apify/src/actor.ts

@@ -168,8 +168,6 @@ export class Actor<Data extends Dictionary = Dictionary> {
         // reset global config instance to respect APIFY_ prefixed env vars
         CoreConfiguration.globalConfig = Configuration.getGlobalConfig();
 
-        await this.eventManager.init();
-
         if (this.isAtHome()) {
             this.config.set('availableMemoryRatio', 1);
             this.config.set('disableBrowserSandbox', true); // for browser launcher, adds `--no-sandbox` to args
@@ -179,6 +177,9 @@ export class Actor<Data extends Dictionary = Dictionary> {
             this.config.useStorageClient(options.storage);
         }
 
+        // Init the event manager the config uses
+        await this.config.getEventManager().init();
+
         await purgeDefaultStorages(this.config);
         Configuration.storage.enterWith(this.config);
     }
@@ -193,15 +194,15 @@ export class Actor<Data extends Dictionary = Dictionary> {
         options.timeoutSecs ??= 30;
 
         // Close the event manager and emit the final PERSIST_STATE event
-        await this.eventManager.close();
+        await this.config.getEventManager().close();
 
         // Emit the exit event
-        this.eventManager.emit(EventType.EXIT, options);
+        this.config.getEventManager().emit(EventType.EXIT, options);
 
         // Wait for all event listeners to be processed
         log.debug(`Waiting for all event listeners to complete their execution (with ${options.timeoutSecs} seconds timeout)`);
         await addTimeoutToPromise(
-            () => this.eventManager.waitForAllListenersToComplete(),
+            () => this.config.getEventManager().waitForAllListenersToComplete(),
             options.timeoutSecs * 1000,
             `Waiting for all event listeners to complete their execution timed out after ${options.timeoutSecs} seconds`,
         );
@@ -245,14 +246,14 @@ export class Actor<Data extends Dictionary = Dictionary> {
      * @ignore
      */
     on(event: EventTypeName, listener: (...args: any[]) => any): void {
-        this.eventManager.on(event, listener);
+        this.config.getEventManager().on(event, listener);
     }
 
     /**
      * @ignore
      */
     off(event: EventTypeName, listener?: (...args: any[]) => any): void {
-        this.eventManager.off(event, listener);
+        this.config.getEventManager().off(event, listener);
     }
 
     /**