import { mockInstance } from '@n8n/backend-test-utils';
import { GlobalConfig } from '@n8n/config';
import type { WorkflowRepository, LicenseMetricsRepository } from '@n8n/db';
import type express from 'express';
import promBundle from 'express-prom-bundle';
import { mock } from 'jest-mock-extended';
import type { InstanceSettings } from 'n8n-core';
import { EventMessageTypeNames } from 'n8n-workflow';
import promClient from 'prom-client';

import type { MessageEventBus } from '@/eventbus/message-event-bus/message-event-bus';
import type { EventService } from '@/events/event.service';

import { PrometheusMetricsService } from '../prometheus-metrics.service';

const mockMiddleware = (
	_req: express.Request,
	_res: express.Response,
	next: express.NextFunction,
) => next();

jest.mock('prom-client');
jest.mock('express-prom-bundle', () => jest.fn(() => mockMiddleware));

describe('PrometheusMetricsService', () => {
	let globalConfig: GlobalConfig;
	let app: express.Application;
	let eventBus: MessageEventBus;
	let eventService: EventService;
	let instanceSettings: InstanceSettings;
	let workflowRepository: WorkflowRepository;
	let licenseMetricsRepository: LicenseMetricsRepository;
	let prometheusMetricsService: PrometheusMetricsService;

	beforeEach(() => {
		globalConfig = mockInstance(GlobalConfig, {
			endpoints: {
				metrics: {
					prefix: 'n8n_',
					includeDefaultMetrics: false,
					includeApiEndpoints: false,
					includeCacheMetrics: false,
					includeMessageEventBusMetrics: false,
					includeCredentialTypeLabel: false,
					includeNodeTypeLabel: false,
					includeWorkflowIdLabel: false,
					includeApiPathLabel: false,
					includeApiMethodLabel: false,
					includeApiStatusCodeLabel: false,
					includeQueueMetrics: false,
					includeWorkflowNameLabel: false,
					includeWorkflowStatistics: false,
					activeWorkflowCountInterval: 30,
					workflowStatisticsInterval: 30,
				},
				rest: 'rest',
				form: 'form',
				formTest: 'form-test',
				formWaiting: 'form-waiting',
				webhook: 'webhook',
				webhookTest: 'webhook-test',
				webhookWaiting: 'webhook-waiting',
			},
			executions: {
				mode: 'regular',
			},
		});

		app = mock<express.Application>();
		eventBus = mock<MessageEventBus>();
		eventService = mock<EventService>();
		instanceSettings = mock<InstanceSettings>({ instanceType: 'main' });
		workflowRepository = mock<WorkflowRepository>();
		licenseMetricsRepository = mock<LicenseMetricsRepository>();

		prometheusMetricsService = new PrometheusMetricsService(
			mock(),
			eventBus,
			globalConfig,
			eventService,
			instanceSettings,
			workflowRepository,
			licenseMetricsRepository,
		);

		promClient.Counter.prototype.inc = jest.fn();
		(promClient.validateMetricName as jest.Mock).mockReturnValue(true);
	});

	afterEach(() => {
		jest.clearAllMocks();
		prometheusMetricsService.disableAllMetrics();
		prometheusMetricsService.disableAllLabels();
	});

	describe('constructor', () => {
		it('should enable metrics based on global config', async () => {
			const customGlobalConfig = { ...globalConfig };
			customGlobalConfig.endpoints.metrics.includeCacheMetrics = true;
			const customPrometheusMetricsService = new PrometheusMetricsService(
				mock(),
				mock(),
				customGlobalConfig,
				mock(),
				instanceSettings,
				mock(),
				mock(),
			);

			await customPrometheusMetricsService.init(app);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_cache_hits_total',
				help: 'Total number of cache hits.',
				labelNames: ['cache'],
			});
		});
	});

	describe('init', () => {
		it('should set up `n8n_version_info`', async () => {
			await prometheusMetricsService.init(app);

			expect(promClient.Gauge).toHaveBeenNthCalledWith(1, {
				name: 'n8n_version_info',
				help: 'n8n version info.',
				labelNames: ['version', 'major', 'minor', 'patch'],
			});
		});

		it('should set up default metrics collection with `prom-client`', async () => {
			prometheusMetricsService.enableMetric('default');
			await prometheusMetricsService.init(app);

			expect(promClient.collectDefaultMetrics).toHaveBeenCalled();
		});

		it('should set up `n8n_cache_hits_total`', async () => {
			prometheusMetricsService.enableMetric('cache');
			await prometheusMetricsService.init(app);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_cache_hits_total',
				help: 'Total number of cache hits.',
				labelNames: ['cache'],
			});
		});

		it('should set up `n8n_cache_misses_total`', async () => {
			prometheusMetricsService.enableMetric('cache');
			await prometheusMetricsService.init(app);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_cache_misses_total',
				help: 'Total number of cache misses.',
				labelNames: ['cache'],
			});
		});

		it('should set up `n8n_cache_updates_total`', async () => {
			prometheusMetricsService.enableMetric('cache');
			await prometheusMetricsService.init(app);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_cache_updates_total',
				help: 'Total number of cache updates.',
				labelNames: ['cache'],
			});
			// @ts-expect-error private field
			expect(prometheusMetricsService.counters.cacheUpdatesTotal?.inc).toHaveBeenCalledWith(0);
		});

		it('should set up route metrics with `express-prom-bundle`', async () => {
			prometheusMetricsService.enableMetric('routes');
			await prometheusMetricsService.init(app);

			expect(promBundle).toHaveBeenCalledWith({
				httpDurationMetricName: 'n8n_http_request_duration_seconds',
				autoregister: false,
				includeUp: false,
				includePath: false,
				includeMethod: false,
				includeStatusCode: false,
			});

			expect(promClient.Gauge).toHaveBeenNthCalledWith(3, {
				name: 'n8n_last_activity',
				help: 'last instance activity (backend request) in Unix time (seconds).',
			});

			expect(app.use).toHaveBeenCalledWith(
				[
					'/api/',
					'/rest/',
					'/webhook/',
					'/webhook-waiting/',
					'/webhook-test/',
					'/form/',
					'/form-waiting/',
					'/form-test/',
				],
				expect.any(Function),
			);
		});

		it('should set up event bus metrics', async () => {
			prometheusMetricsService.enableMetric('logs');
			await prometheusMetricsService.init(app);

			expect(eventBus.on).toHaveBeenCalledWith('metrics.eventBus.event', expect.any(Function));
		});

		it('should set up queue metrics if enabled', async () => {
			globalConfig.executions.mode = 'queue';
			prometheusMetricsService.enableMetric('queue');

			await prometheusMetricsService.init(app);

			// call 1 is for `n8n_version_info` (always enabled)

			expect(promClient.Gauge).toHaveBeenNthCalledWith(3, {
				name: 'n8n_scaling_mode_queue_jobs_waiting',
				help: 'Current number of enqueued jobs waiting for pickup in scaling mode.',
			});

			expect(promClient.Gauge).toHaveBeenNthCalledWith(4, {
				name: 'n8n_scaling_mode_queue_jobs_active',
				help: 'Current number of jobs being processed across all workers in scaling mode.',
			});

			expect(promClient.Counter).toHaveBeenNthCalledWith(1, {
				name: 'n8n_scaling_mode_queue_jobs_completed',
				help: 'Total number of jobs completed across all workers in scaling mode since instance start.',
			});

			expect(promClient.Counter).toHaveBeenNthCalledWith(2, {
				name: 'n8n_scaling_mode_queue_jobs_failed',
				help: 'Total number of jobs failed across all workers in scaling mode since instance start.',
			});

			expect(eventService.on).toHaveBeenCalledWith('job-counts-updated', expect.any(Function));
		});

		it('should not set up queue metrics if enabled but not on scaling mode', async () => {
			globalConfig.executions.mode = 'regular';
			prometheusMetricsService.enableMetric('queue');

			await prometheusMetricsService.init(app);

			expect(promClient.Gauge).toHaveBeenCalledTimes(3); // version metric + active workflow count metric + instance role metric
			expect(promClient.Counter).toHaveBeenCalledTimes(0); // cache metrics
			expect(eventService.on).not.toHaveBeenCalled();
		});

		it('should not set up queue metrics if enabled and on scaling mode but instance is not main', async () => {
			globalConfig.executions.mode = 'queue';
			prometheusMetricsService.enableMetric('queue');
			// @ts-expect-error private field
			instanceSettings.instanceType = 'worker';

			await prometheusMetricsService.init(app);

			expect(promClient.Gauge).toHaveBeenCalledTimes(2); // version metric + active workflow count metric
			expect(promClient.Counter).toHaveBeenCalledTimes(0); // cache metrics
			expect(eventService.on).not.toHaveBeenCalled();
		});

		it('should setup active workflow count metric', async () => {
			await prometheusMetricsService.init(app);

			// First call is n8n version metric
			expect(promClient.Gauge).toHaveBeenCalledTimes(3);

			expect(promClient.Gauge).toHaveBeenNthCalledWith(3, {
				name: 'n8n_active_workflow_count',
				help: 'Total number of active workflows.',
				collect: expect.any(Function),
			});
		});
	});

	describe('when event bus events are sent', () => {
		// Helper to find the event handler function registered by initEventBusMetrics
		const getEventHandler = () => {
			const eventBusOnCall = (eventBus.on as jest.Mock).mock.calls.find(
				(call) => call[0] === 'metrics.eventBus.event',
			);
			// The handler is the second argument in the .on(eventName, handler) call
			return eventBusOnCall ? eventBusOnCall[1] : undefined;
		};

		it('should create a counter with `credential_type` label for user credentials audit events', async () => {
			prometheusMetricsService.enableMetric('logs');
			prometheusMetricsService.enableLabels(['credentialsType']);

			await prometheusMetricsService.init(app);

			const eventHandler = getEventHandler();
			const mockEvent = {
				__type: EventMessageTypeNames.audit,
				eventName: 'n8n.audit.user.credentials.created',
				payload: { credentialType: 'n8n-nodes-base.googleApi' },
			};

			eventHandler(mockEvent);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_audit_user_credentials_created_total',
				help: 'Total number of n8n.audit.user.credentials.created events.',
				labelNames: ['credential_type'],
			});

			expect(promClient.Counter.prototype.inc).toHaveBeenCalledWith(
				{ credential_type: 'n8n-nodes-base_googleApi' },
				1,
			);
		});

		it('should create a counter with `workflow_id` label for workflow audit events', async () => {
			prometheusMetricsService.enableMetric('logs');
			prometheusMetricsService.enableLabels(['workflowId']);

			await prometheusMetricsService.init(app);

			const eventHandler = getEventHandler();
			const mockEvent = {
				__type: EventMessageTypeNames.audit,
				eventName: 'n8n.audit.workflow.created',
				payload: { workflowId: 'wf_123' },
			};
			eventHandler(mockEvent);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_audit_workflow_created_total',
				help: 'Total number of n8n.audit.workflow.created events.',
				labelNames: ['workflow_id'],
			});

			expect(promClient.Counter.prototype.inc).toHaveBeenCalledWith({ workflow_id: 'wf_123' }, 1);
		});

		it('should create a counter with `workflow_name` label for workflow audit events', async () => {
			prometheusMetricsService.enableMetric('logs');
			prometheusMetricsService.enableLabels(['workflowName']);

			await prometheusMetricsService.init(app);

			const eventHandler = getEventHandler();
			const mockEvent = {
				__type: EventMessageTypeNames.audit,
				eventName: 'n8n.audit.workflow.created',
				payload: { workflowName: 'Fake Workflow Name' },
			};
			eventHandler(mockEvent);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_audit_workflow_created_total',
				help: 'Total number of n8n.audit.workflow.created events.',
				labelNames: ['workflow_name'],
			});

			expect(promClient.Counter.prototype.inc).toHaveBeenCalledWith(
				{ workflow_name: 'Fake Workflow Name' },
				1,
			);
		});

		it('should create a counter with `node_type` label for node events', async () => {
			prometheusMetricsService.enableMetric('logs');
			prometheusMetricsService.enableLabels(['nodeType']);
			await prometheusMetricsService.init(app);

			const eventHandler = getEventHandler();
			const mockEvent = {
				__type: EventMessageTypeNames.node,
				eventName: 'n8n.node.execution.started',
				payload: { nodeType: 'n8n-nodes-base.if' },
			};

			eventHandler(mockEvent);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_node_execution_started_total',
				help: 'Total number of n8n.node.execution.started events.',
				labelNames: ['node_type'],
			});

			expect(promClient.Counter.prototype.inc).toHaveBeenCalledWith({ node_type: 'base_if' }, 1);
		});

		it('should create a counter with `workflow_id` label for node events', async () => {
			prometheusMetricsService.enableMetric('logs');
			prometheusMetricsService.enableLabels(['workflowId']);
			await prometheusMetricsService.init(app);

			const eventHandler = getEventHandler();
			const mockEvent = {
				__type: EventMessageTypeNames.node,
				eventName: 'n8n.node.execution.started',
				payload: { workflowId: 'wf_123' },
			};

			eventHandler(mockEvent);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_node_execution_started_total',
				help: 'Total number of n8n.node.execution.started events.',
				labelNames: ['workflow_id'],
			});

			expect(promClient.Counter.prototype.inc).toHaveBeenCalledWith({ workflow_id: 'wf_123' }, 1);
		});

		it('should create a counter with `workflow_name` label for node events', async () => {
			prometheusMetricsService.enableMetric('logs');
			prometheusMetricsService.enableLabels(['workflowName']);
			await prometheusMetricsService.init(app);

			const eventHandler = getEventHandler();
			const mockEvent = {
				__type: EventMessageTypeNames.node,
				eventName: 'n8n.node.execution.started',
				payload: { workflowName: 'Fake Workflow Name' },
			};

			eventHandler(mockEvent);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_node_execution_started_total',
				help: 'Total number of n8n.node.execution.started events.',
				labelNames: ['workflow_name'],
			});

			expect(promClient.Counter.prototype.inc).toHaveBeenCalledWith(
				{ workflow_name: 'Fake Workflow Name' },
				1,
			);
		});

		it('should create a counter with workflow and node type labels for node events', async () => {
			prometheusMetricsService.enableMetric('logs');
			prometheusMetricsService.enableLabels(['workflowId', 'workflowName', 'nodeType']);
			await prometheusMetricsService.init(app);

			const eventHandler = getEventHandler();
			const mockEvent = {
				__type: EventMessageTypeNames.node,
				eventName: 'n8n.node.execution.started',
				payload: {
					workflowId: 'wf_123',
					workflowName: 'Fake Workflow Name',
					nodeType: 'n8n-nodes-base.if',
				},
			};

			eventHandler(mockEvent);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_node_execution_started_total',
				help: 'Total number of n8n.node.execution.started events.',
				labelNames: ['workflow_id', 'workflow_name', 'node_type'],
			});

			expect(promClient.Counter.prototype.inc).toHaveBeenCalledWith(
				{
					workflow_id: 'wf_123',
					workflow_name: 'Fake Workflow Name',
					node_type: 'base_if',
				},
				1,
			);
		});

		it('should create a counter with `workflow_id` label for workflow events', async () => {
			prometheusMetricsService.enableMetric('logs');
			prometheusMetricsService.enableLabels(['workflowId']);
			await prometheusMetricsService.init(app);

			const eventHandler = getEventHandler();
			const mockEvent = {
				__type: EventMessageTypeNames.workflow,
				eventName: 'n8n.workflow.execution.finished',
				payload: { workflowId: 'wf_456' },
			};
			eventHandler(mockEvent);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_workflow_execution_finished_total',
				help: 'Total number of n8n.workflow.execution.finished events.',
				labelNames: ['workflow_id'],
			});

			expect(promClient.Counter.prototype.inc).toHaveBeenCalledWith({ workflow_id: 'wf_456' }, 1);
		});

		it('should create a counter with `workflow_name` label for workflow events', async () => {
			prometheusMetricsService.enableMetric('logs');
			prometheusMetricsService.enableLabels(['workflowName']);
			await prometheusMetricsService.init(app);

			const eventHandler = getEventHandler();
			const mockEvent = {
				__type: EventMessageTypeNames.workflow,
				eventName: 'n8n.workflow.execution.finished',
				payload: { workflowName: 'Fake Workflow Name' },
			};
			eventHandler(mockEvent);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_workflow_execution_finished_total',
				help: 'Total number of n8n.workflow.execution.finished events.',
				labelNames: ['workflow_name'],
			});

			expect(promClient.Counter.prototype.inc).toHaveBeenCalledWith(
				{ workflow_name: 'Fake Workflow Name' },
				1,
			);
		});

		it('should create a counter with no labels if the corresponding config is disabled', async () => {
			prometheusMetricsService.enableMetric('logs');
			await prometheusMetricsService.init(app);

			const eventHandler = getEventHandler();
			const mockEvent = {
				__type: EventMessageTypeNames.workflow,
				eventName: 'n8n.workflow.execution.finished',
				payload: { workflowId: 'wf_789' },
			};
			eventHandler(mockEvent);

			expect(promClient.Counter).toHaveBeenCalledWith({
				name: 'n8n_workflow_execution_finished_total',
				help: 'Total number of n8n.workflow.execution.finished events.',
				labelNames: [], // Expecting no labels
			});

			expect(promClient.Counter.prototype.inc).toHaveBeenCalledWith({}, 1);
		});
	});

	describe('instance role metric', () => {
		it('should set up instance role metric for main instance', async () => {
			// @ts-expect-error Private field
			instanceSettings.instanceType = 'main';

			await prometheusMetricsService.init(app);

			expect(promClient.Gauge).toHaveBeenCalledWith({
				name: 'n8n_instance_role_leader',
				help: 'Whether this main instance is the leader (1) or not (0).',
			});
		});

		it('should not set up instance role metric for worker instance', async () => {
			// @ts-expect-error Private field
			instanceSettings.instanceType = 'worker';

			await prometheusMetricsService.init(app);

			// Only version and active workflow count metrics should be created
			expect(promClient.Gauge).toHaveBeenCalledTimes(2);

			// Verify instance role metric was not created
			const calls = (promClient.Gauge as jest.Mock).mock.calls;
			const hasInstanceRoleMetric = calls.some(
				(call) => call[0]?.name === 'n8n_instance_role_leader',
			);
			expect(hasInstanceRoleMetric).toBe(false);
		});
	});
});