fix: Always register webhooks on startup (#8830)

packages/cli/src/services/orchestration.service.ts

@@ -128,7 +128,11 @@ export class OrchestrationService {
 	 * Whether this instance may add webhooks to the `webhook_entity` table.
 	 */
 	shouldAddWebhooks(activationMode: WorkflowActivateMode) {
-		if (activationMode === 'init') return false;
+		// Always try to populate the webhook entity table as well as register the webhooks
+		// to prevent issues with users upgrading from a version < 1.15, where the webhook entity
+		// was cleared on shutdown to anything past 1.28.0, where we stopped populating it on init,
+		// causing all webhooks to break
+		if (activationMode === 'init') return true;
 
 		if (activationMode === 'leadershipChange') return false;
 

packages/cli/test/unit/services/orchestration.service.test.ts

@@ -13,6 +13,7 @@ import { Logger } from '@/Logger';
 import { Push } from '@/push';
 import { ActiveWorkflowRunner } from '@/ActiveWorkflowRunner';
 import { mockInstance } from '../../shared/mocking';
+import type { WorkflowActivateMode } from 'n8n-workflow';
 
 const os = Container.get(OrchestrationService);
 const handler = Container.get(OrchestrationHandlerMainService);
@@ -149,4 +150,38 @@ describe('Orchestration Service', () => {
 		expect(res1!.payload).toBeUndefined();
 		expect(res2!.payload!.result).toEqual('debounced');
 	});
+
+	describe('shouldAddWebhooks', () => {
+		beforeEach(() => {
+			config.set('multiMainSetup.instanceType', 'leader');
+		});
+		test('should return true for init', () => {
+			// We want to ensure that webhooks are populated on init
+			// more https://github.com/n8n-io/n8n/pull/8830
+			const result = os.shouldAddWebhooks('init');
+			expect(result).toBe(true);
+		});
+
+		test('should return false for leadershipChange', () => {
+			const result = os.shouldAddWebhooks('leadershipChange');
+			expect(result).toBe(false);
+		});
+
+		test('should return true for update or activate when is leader', () => {
+			const modes = ['update', 'activate'] as WorkflowActivateMode[];
+			for (const mode of modes) {
+				const result = os.shouldAddWebhooks(mode);
+				expect(result).toBe(true);
+			}
+		});
+
+		test('should return false for update or activate when not leader', () => {
+			config.set('multiMainSetup.instanceType', 'follower');
+			const modes = ['update', 'activate'] as WorkflowActivateMode[];
+			for (const mode of modes) {
+				const result = os.shouldAddWebhooks(mode);
+				expect(result).toBe(false);
+			}
+		});
+	});
 });