import { test } from '../../../../fixtures/base';
import { benchConfig } from '../../../../playwright-projects';
import { setupWebhook } from '../../../../utils/benchmark/webhook-driver';
import { runWebhookThroughputTest } from '../harness/webhook-throughput-harness';

// 2 mains + 2 workers fits within the CI runner's CPU budget while still
// exercising multi-main HA. Pair with `webhook-queue-baseline.spec.ts`
// (1m + 1w queue mode) — NOT `webhook-single-instance.spec.ts` (1m + 0w
// direct mode) — to read the main-scaling factor cleanly. Comparing against
// the direct-mode spec would conflate "adding a main" with "switching from
// direct to queue execution" since the architectures differ.
//
// Multi-main HA requires N8N_MULTI_MAIN_SETUP_ENABLED and a license cert
// (picked up from N8N_LICENSE_ACTIVATION_KEY / N8N_LICENSE_CERT in the host
// env). `benchConfig()` enables the env var automatically when `mains > 1`.

const MAINS = 2;
const WORKERS = 2;
const CONNECTIONS = 200;
const DURATION_SECONDS = 180;

test.use({ capability: benchConfig('webhook-main-scaling', { mains: MAINS, workers: WORKERS }) });

test.describe(
	'Does webhook ingestion scale linearly with main count?',
	{
		tag: '@bench:webhook',
		annotation: [
			{ type: 'owner', description: 'Catalysts' },
			{ type: 'question', description: 'webhook-main-scaling' },
		],
	},
	() => {
		// Async webhook so HTTP req/s = ingestion ACK rate (independent of worker drain).
		// Baseline (1m + 1w queue mode): see webhook-queue-baseline.spec.ts.
		// At N mains, holding worker count proportional: should be ~N× baseline if
		// load distributes evenly. Sub-linear means LB or shared resource
		// contention; super-linear is impossible.
		test(`Async webhook + 1 noop, 1KB payload, ${CONNECTIONS} connections × ${DURATION_SECONDS}s (${MAINS} mains + ${WORKERS} workers)`, async ({
			api,
			services,
			backendUrl,
		}, testInfo) => {
			const handle = setupWebhook({
				scenario: {
					nodeCount: 1,
					payloadSize: '1KB',
					nodeOutputSize: 'noop',
					responseMode: 'onReceived',
				},
			});
			await runWebhookThroughputTest({
				handle,
				api,
				services,
				testInfo,
				baseUrl: backendUrl,
				connections: CONNECTIONS,
				durationSeconds: DURATION_SECONDS,
				timeoutMs: (DURATION_SECONDS + 60) * 1000,
			});

			console.log(
				`\n[MAIN SCALING] mains=${MAINS}, workers=${WORKERS} | Compare HTTP req/s vs webhook-queue-baseline (1m+1w).\n` +
					'  Linear scaling = ingestion req/s grows ~N× with mains.\n' +
					'  Sub-linear = load balancer / shared resource bottleneck.',
			);
		});
	},
);