import type { Logger } from '@n8n/backend-common';
import type { ContextEstablishmentOptions } from '@n8n/decorators';
import { mock } from 'jest-mock-extended';
import type { Cipher } from 'n8n-core';
import type { INodeExecutionData } from 'n8n-workflow';

import { ChatHubExtractor } from '../chat-hub-extractor';

// Helper function to create trigger items
const createTriggerItem = (data: Record<string, unknown>): INodeExecutionData => ({
	json: {},
	...data,
	pairedItem: { item: 0 },
});

describe('ChatHubExtractor', () => {
	let extractor: ChatHubExtractor;
	let mockLogger: jest.Mocked<Logger>;
	let mockCipher: jest.Mocked<Cipher>;

	beforeEach(() => {
		mockLogger = mock<Logger>();
		mockLogger.scoped.mockReturnValue(mockLogger);
		mockCipher = mock<Cipher>();
		extractor = new ChatHubExtractor(mockLogger, mockCipher);
	});

	describe('execute', () => {
		it('should throw error when no trigger items', async () => {
			const options = {
				triggerItems: [],
			} as unknown as ContextEstablishmentOptions;

			await expect(extractor.execute(options)).rejects.toThrow(
				'No trigger items found, skipping ChatHubExtractor hook.',
			);
			expect(mockLogger.debug).toHaveBeenCalledWith(
				'No trigger items found, skipping ChatHubExtractor hook.',
			);
		});

		it('should throw error when triggerItems is null', async () => {
			const options = {
				triggerItems: null,
			} as unknown as ContextEstablishmentOptions;

			await expect(extractor.execute(options)).rejects.toThrow(
				'No trigger items found, skipping ChatHubExtractor hook.',
			);
			expect(mockLogger.debug).toHaveBeenCalledWith(
				'No trigger items found, skipping ChatHubExtractor hook.',
			);
		});

		it('should decrypt and extract authToken and browserId successfully', async () => {
			const metadata = {
				authToken: 'test-auth-token-123',
				browserId: 'browser-id-456',
				method: 'POST',
				endpoint: '/api/test',
			};
			const encryptedData = 'encrypted-string';

			mockCipher.decryptV2.mockResolvedValue(JSON.stringify(metadata));

			const triggerItem = createTriggerItem({
				encryptedMetadata: encryptedData,
				json: { otherField: 'value' },
			});
			const options = {
				triggerItems: [triggerItem],
			} as ContextEstablishmentOptions;

			const result = await extractor.execute(options);

			expect(mockCipher.decryptV2).toHaveBeenCalledWith(encryptedData);
			expect(result).toEqual({
				triggerItems: [triggerItem],
				contextUpdate: {
					credentials: {
						version: 1,
						identity: 'test-auth-token-123',
						metadata: {
							source: 'chat-hub-injected',
							browserId: 'browser-id-456',
							method: 'POST',
							endpoint: '/api/test',
						},
					},
				},
			});
		});

		it('should extract authToken without browserId', async () => {
			const metadata = {
				authToken: 'test-auth-token-123',
				method: 'POST',
				endpoint: '/api/test',
			};
			mockCipher.decryptV2.mockResolvedValue(JSON.stringify(metadata));

			const triggerItem = createTriggerItem({
				encryptedMetadata: 'encrypted',
				json: { otherField: 'value' },
			});
			const options = {
				triggerItems: [triggerItem],
			} as ContextEstablishmentOptions;

			const result = await extractor.execute(options);

			expect(result).toEqual({
				triggerItems: [triggerItem],
				contextUpdate: {
					credentials: {
						version: 1,
						identity: 'test-auth-token-123',
						metadata: {
							source: 'chat-hub-injected',
							browserId: undefined,
							method: 'POST',
							endpoint: '/api/test',
						},
					},
				},
			});
		});

		it('should delete encryptedMetadata from trigger item', async () => {
			const metadata = {
				authToken: 'test-auth-token-123',
				browserId: 'browser-id-456',
				method: 'POST',
				endpoint: '/api/test',
			};
			mockCipher.decryptV2.mockResolvedValue(JSON.stringify(metadata));

			const triggerItem = createTriggerItem({
				encryptedMetadata: 'encrypted',
				json: { otherField: 'value' },
			});
			const options = {
				triggerItems: [triggerItem],
			} as ContextEstablishmentOptions;

			await extractor.execute(options);

			// Verify encryptedMetadata is removed
			expect(triggerItem).not.toHaveProperty('encryptedMetadata');
			expect(triggerItem.json).toHaveProperty('otherField', 'value');
		});

		it('should throw error when decryption fails', async () => {
			mockCipher.decryptV2.mockImplementation(async () => {
				throw new Error('Decryption failed');
			});

			const triggerItem = createTriggerItem({
				encryptedMetadata: 'invalid-encrypted',
			});
			const options = {
				triggerItems: [triggerItem],
			} as ContextEstablishmentOptions;

			await expect(extractor.execute(options)).rejects.toThrow(
				'No valid Chat Hub authentication metadata could be extracted.',
			);
			expect(mockLogger.error).toHaveBeenCalledWith(
				'Failed to decrypt/parse encrypted chat metadata',
				expect.objectContaining({
					error: expect.objectContaining({ message: 'Decryption failed' }),
				}),
			);
		});

		it('should throw error when JSON parsing fails', async () => {
			mockCipher.decryptV2.mockResolvedValue('invalid-json{]');

			const triggerItem = createTriggerItem({
				encryptedMetadata: 'encrypted',
			});
			const options = {
				triggerItems: [triggerItem],
			} as ContextEstablishmentOptions;

			await expect(extractor.execute(options)).rejects.toThrow(
				'No valid Chat Hub authentication metadata could be extracted.',
			);
			expect(mockLogger.error).toHaveBeenCalled();
		});

		it('should throw error when authToken is missing in decrypted data', async () => {
			mockCipher.decryptV2.mockResolvedValue(JSON.stringify({ browserId: 'browser-id-456' }));

			const triggerItem = createTriggerItem({
				encryptedMetadata: 'encrypted',
			});
			const options = {
				triggerItems: [triggerItem],
			} as ContextEstablishmentOptions;

			await expect(extractor.execute(options)).rejects.toThrow(
				'No valid Chat Hub authentication metadata could be extracted.',
			);
			expect(mockLogger.warn).toHaveBeenCalledWith(
				'Invalid format for encryptedMetadata in chathub extractor',
				expect.objectContaining({
					errors: expect.any(Array),
				}),
			);
		});

		it('should always delete encryptedMetadata even on error', async () => {
			mockCipher.decryptV2.mockImplementation(async () => {
				throw new Error('fail');
			});

			const triggerItem = createTriggerItem({
				encryptedMetadata: 'encrypted',
			});
			const options = {
				triggerItems: [triggerItem],
			} as ContextEstablishmentOptions;

			await expect(extractor.execute(options)).rejects.toThrow(
				'No valid Chat Hub authentication metadata could be extracted.',
			);

			expect(triggerItem).not.toHaveProperty('encryptedMetadata');
		});

		it('should throw error when no encryptedMetadata field', async () => {
			const triggerItem = createTriggerItem({
				json: { someField: 'value' },
			});
			const options = {
				triggerItems: [triggerItem],
			} as ContextEstablishmentOptions;

			await expect(extractor.execute(options)).rejects.toThrow(
				'No valid Chat Hub authentication metadata could be extracted.',
			);
			expect(mockCipher.decryptV2).not.toHaveBeenCalled();
		});
	});

	describe('isApplicableToTriggerNode', () => {
		it('should always return false', () => {
			expect(extractor.isApplicableToTriggerNode('any-node-type')).toBe(false);
		});
	});

	describe('hookDescription', () => {
		it('should have correct metadata', () => {
			expect(extractor.hookDescription).toEqual({
				name: 'ChatHubExtractor',
				displayName: 'Chat Hub Extractor',
				options: [],
			});
		});
	});
});