From 74d0c1cffa54717726f88c15a27b53896dfa3961 Mon Sep 17 00:00:00 2001
From: blam <ben@blam.sh>
Date: Thu, 21 Nov 2024 12:52:47 +0100
Subject: [PATCH] chore: wire up new events Signed-off-by: blam <ben@blam.sh>

---
 .../src/module/WrapperProviders.ts                           | 5 ++---
 .../catalogModuleIncrementalIngestionEntityProvider.ts       | 1 +
 2 files changed, 3 insertions(+), 3 deletions(-)

diff --git a/plugins/catalog-backend-module-incremental-ingestion/src/module/WrapperProviders.ts b/plugins/catalog-backend-module-incremental-ingestion/src/module/WrapperProviders.ts
index b510eb2ead..0c0f1361cf 100644
--- a/plugins/catalog-backend-module-incremental-ingestion/src/module/WrapperProviders.ts
+++ b/plugins/catalog-backend-module-incremental-ingestion/src/module/WrapperProviders.ts
@@ -66,7 +66,7 @@ export class WrapperProviders {
     return {
       getProviderName: () => provider.getProviderName(),
       connect: async connection => {
-        await this.startProvider(provider, options, connection, events);
+        await this.startProvider(provider, options, connection);
         this.numberOfProvidersToConnect -= 1;
         if (this.numberOfProvidersToConnect === 0) {
           this.readySignal.resolve();
@@ -86,7 +86,6 @@ export class WrapperProviders {
     provider: IncrementalEntityProvider<unknown, unknown>,
     providerOptions: IncrementalEntityProviderOptions,
     connection: EntityProviderConnection,
-    events: EventsService,
   ) {
     const logger = this.options.logger.child({
       entityProvider: provider.getProviderName(),
@@ -139,7 +138,7 @@ export class WrapperProviders {
         logger.info(
           `Provider ${provider.getProviderName()} subscribing to events for topics: ${topics.join()}`,
         );
-        await events.subscribe({
+        await this.options.events.subscribe({
           topics,
           id: provider.getProviderName(),
           onEvent: evt => engine.onEvent(evt),
diff --git a/plugins/catalog-backend-module-incremental-ingestion/src/module/catalogModuleIncrementalIngestionEntityProvider.ts b/plugins/catalog-backend-module-incremental-ingestion/src/module/catalogModuleIncrementalIngestionEntityProvider.ts
index 74244402a6..25ff33d6ba 100644
--- a/plugins/catalog-backend-module-incremental-ingestion/src/module/catalogModuleIncrementalIngestionEntityProvider.ts
+++ b/plugins/catalog-backend-module-incremental-ingestion/src/module/catalogModuleIncrementalIngestionEntityProvider.ts
@@ -116,6 +116,7 @@ export const catalogModuleIncrementalIngestionEntityProvider =
           httpRouter,
           logger,
           scheduler,
+          events,
         }) {
           const client = await database.getClient();