fix(core): Fix init for AuditEventRelay (n8n-io#9839)

netroy · Jun 24, 2024 · 16d3083 · 16d3083
1 parent b807e67
commit 16d3083
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 1 deletion.
diff --git 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
@@ -10,7 +10,9 @@ export class AuditEventRelay {
 	constructor(
 		private readonly eventRelay: EventRelay,
 		private readonly eventBus: MessageEventBus,
-	) {
+	) {}
+
+	init() {
 		this.setupHandlers();
 	}