diff --git a/packages/cli/src/Server.ts b/packages/cli/src/Server.ts index e99b7be07255c..133be8c8aa8af 100644 --- a/packages/cli/src/Server.ts +++ b/packages/cli/src/Server.ts @@ -66,6 +66,7 @@ import '@/ExternalSecrets/ExternalSecrets.controller.ee'; import '@/license/license.controller'; import '@/workflows/workflowHistory/workflowHistory.controller.ee'; import '@/workflows/workflows.controller'; +import { AuditEventRelay } from './eventbus/audit-event-relay.service'; const exec = promisify(callbackExec); @@ -252,6 +253,7 @@ export class Server extends AbstractServer { // ---------------------------------------- const eventBus = Container.get(MessageEventBus); await eventBus.initialize(); + Container.get(AuditEventRelay).init(); if (this.endpointPresetCredentials !== '') { // POST endpoint to set preset credentials diff --git a/packages/cli/src/eventbus/audit-event-relay.service.ts b/packages/cli/src/eventbus/audit-event-relay.service.ts index e4a9632a6cc3f..59efa0533f9db 100644 --- a/packages/cli/src/eventbus/audit-event-relay.service.ts +++ b/packages/cli/src/eventbus/audit-event-relay.service.ts @@ -10,7 +10,9 @@ export class AuditEventRelay { constructor( private readonly eventRelay: EventRelay, private readonly eventBus: MessageEventBus, - ) { + ) {} + + init() { this.setupHandlers(); }