import type { IWebhookFunctions } from 'n8n-workflow';

import { TwilioTrigger } from '../TwilioTrigger.node';
import { verifySignature } from '../TwilioTriggerHelpers';
import type { Mock, Mocked } from 'vitest';

vi.mock('../TwilioTriggerHelpers');

describe('TwilioTrigger', () => {
	let trigger: TwilioTrigger;
	let mockWebhookFunctions: Pick<
		Mocked<IWebhookFunctions>,
		'getBodyData' | 'getResponseObject' | 'helpers'
	>;

	beforeEach(() => {
		vi.clearAllMocks();
		trigger = new TwilioTrigger();

		mockWebhookFunctions = {
			getBodyData: vi.fn(),
			getResponseObject: vi.fn(),
			helpers: {
				returnJsonArray: vi.fn((data) => data),
			} as any,
		};
	});

	describe('webhook', () => {
		it('should process the webhook when signature verification passes', async () => {
			const bodyData = [
				{ specversion: '1.0', type: 'com.twilio.messaging.inbound-message.received' },
			];

			(verifySignature as Mock).mockResolvedValue(true);
			mockWebhookFunctions.getBodyData.mockReturnValue(bodyData as any);

			const result = await trigger.webhook.call(
				mockWebhookFunctions as unknown as IWebhookFunctions,
			);

			expect(verifySignature).toHaveBeenCalled();
			expect(result.workflowData).toBeDefined();
			expect(mockWebhookFunctions.helpers.returnJsonArray).toHaveBeenCalledWith(bodyData);
		});

		it('should return 401 when signature verification fails', async () => {
			const mockResponse = {
				status: vi.fn().mockReturnThis(),
				send: vi.fn().mockReturnThis(),
				end: vi.fn(),
			};

			(verifySignature as Mock).mockResolvedValue(false);
			mockWebhookFunctions.getResponseObject.mockReturnValue(mockResponse as any);

			const result = await trigger.webhook.call(
				mockWebhookFunctions as unknown as IWebhookFunctions,
			);

			expect(verifySignature).toHaveBeenCalled();
			expect(mockResponse.status).toHaveBeenCalledWith(401);
			expect(mockResponse.send).toHaveBeenCalledWith('Unauthorized');
			expect(mockResponse.end).toHaveBeenCalled();
			expect(result).toEqual({ noWebhookResponse: true });
			expect(mockWebhookFunctions.getBodyData).not.toHaveBeenCalled();
		});

		it('should process the webhook when no auth token is configured (backward compat)', async () => {
			const bodyData = [
				{ specversion: '1.0', type: 'com.twilio.voice.insights.call-summary.complete' },
			];

			(verifySignature as Mock).mockResolvedValue(true);
			mockWebhookFunctions.getBodyData.mockReturnValue(bodyData as any);

			const result = await trigger.webhook.call(
				mockWebhookFunctions as unknown as IWebhookFunctions,
			);

			expect(result.workflowData).toBeDefined();
		});
	});
});