import { Container } from '@n8n/di';
import { mock } from 'jest-mock-extended';
import type {
	Expression,
	INode,
	INodeType,
	INodeTypes,
	INodeExecutionData,
	IWorkflowExecuteAdditionalData,
	Workflow,
	WorkflowExecuteMode,
} from 'n8n-workflow';
import { CHAT_TRIGGER_NODE_TYPE, createRunExecutionData, NodeConnectionTypes } from 'n8n-workflow';

import { InstanceSettings } from '@/instance-settings';

import { NodeExecutionContext } from '../node-execution-context';

class TestContext extends NodeExecutionContext {}

describe('NodeExecutionContext', () => {
	const instanceSettings = mock<InstanceSettings>({
		instanceId: 'abc123',
		encryptionKey: 'testEncryptionKey',
		hmacSignatureSecret: 'testHmacSignatureSecret',
	});
	Container.set(InstanceSettings, instanceSettings);

	const node = mock<INode>();
	const nodeType = mock<INodeType>({ description: mock() });
	const nodeTypes = mock<INodeTypes>();
	const expression = mock<Expression>();
	const workflow = mock<Workflow>({
		id: '123',
		name: 'Test Workflow',
		active: true,
		nodeTypes,
		timezone: 'UTC',
		expression,
	});
	const additionalData = mock<IWorkflowExecuteAdditionalData>({
		credentialsHelper: mock(),
	});

	const mode: WorkflowExecuteMode = 'manual';
	let testContext: TestContext;

	beforeEach(() => {
		jest.clearAllMocks();
		testContext = new TestContext(workflow, node, additionalData, mode);
		nodeTypes.getByNameAndVersion.mockReturnValue(nodeType);
	});

	describe('getNode', () => {
		it('should return a deep copy of the node', () => {
			const result = testContext.getNode();
			expect(result).not.toBe(node);
			expect(JSON.stringify(result)).toEqual(JSON.stringify(node));
		});
	});

	describe('getWorkflow', () => {
		it('should return the id, name, and active properties of the workflow', () => {
			const result = testContext.getWorkflow();

			expect(result).toEqual({ id: '123', name: 'Test Workflow', active: true });
		});
	});

	describe('getMode', () => {
		it('should return the mode property', () => {
			const result = testContext.getMode();
			expect(result).toBe(mode);
		});
	});

	describe('getWorkflowStaticData', () => {
		it('should call getStaticData method of workflow', () => {
			testContext.getWorkflowStaticData('testType');
			expect(workflow.getStaticData).toHaveBeenCalledWith('testType', node);
		});
	});

	describe('getChildNodes', () => {
		it('should return an array of NodeTypeAndVersion objects for the child nodes of the given node', () => {
			const childNode1 = mock<INode>({ name: 'Child Node 1', type: 'testType1', typeVersion: 1 });
			const childNode2 = mock<INode>({ name: 'Child Node 2', type: 'testType2', typeVersion: 2 });
			workflow.getChildNodes.mockReturnValue(['Child Node 1', 'Child Node 2']);
			workflow.nodes = {
				'Child Node 1': childNode1,
				'Child Node 2': childNode2,
			};

			const result = testContext.getChildNodes('Test Node');

			expect(result).toMatchObject([
				{ name: 'Child Node 1', type: 'testType1', typeVersion: 1 },
				{ name: 'Child Node 2', type: 'testType2', typeVersion: 2 },
			]);
		});
	});

	describe('getParentNodes', () => {
		it('should return an array of NodeTypeAndVersion objects for the parent nodes of the given node', () => {
			const parentNode1 = mock<INode>({ name: 'Parent Node 1', type: 'testType1', typeVersion: 1 });
			const parentNode2 = mock<INode>({ name: 'Parent Node 2', type: 'testType2', typeVersion: 2 });
			workflow.getParentNodes.mockReturnValue(['Parent Node 1', 'Parent Node 2']);
			workflow.nodes = {
				'Parent Node 1': parentNode1,
				'Parent Node 2': parentNode2,
			};

			const result = testContext.getParentNodes('Test Node');

			expect(result).toMatchObject([
				{ name: 'Parent Node 1', type: 'testType1', typeVersion: 1 },
				{ name: 'Parent Node 2', type: 'testType2', typeVersion: 2 },
			]);
		});
	});

	describe('getChatTrigger', () => {
		it('should return a chat trigger node if it exists in the workflow', () => {
			const chatNode = mock<INode>({ name: 'Chat', type: CHAT_TRIGGER_NODE_TYPE });

			workflow.nodes = {
				Chat: chatNode,
			};

			const result = testContext.getChatTrigger();

			expect(result).toEqual(chatNode);
		});
		it('should return a null if there is no chat trigger node in the workflow', () => {
			const someNode = mock<INode>({ name: 'Some Node', type: 'someType' });

			workflow.nodes = {
				'Some Node': someNode,
			};

			const result = testContext.getChatTrigger();

			expect(result).toBeNull();
		});
	});

	describe('getKnownNodeTypes', () => {
		it('should call getKnownTypes method of nodeTypes', () => {
			testContext.getKnownNodeTypes();
			expect(nodeTypes.getKnownTypes).toHaveBeenCalled();
		});
	});

	describe('getRestApiUrl', () => {
		it('should return the restApiUrl property of additionalData', () => {
			additionalData.restApiUrl = 'https://example.com/api';

			const result = testContext.getRestApiUrl();

			expect(result).toBe('https://example.com/api');
		});
	});

	describe('getInstanceBaseUrl', () => {
		it('should return the instanceBaseUrl property of additionalData', () => {
			additionalData.instanceBaseUrl = 'https://example.com';

			const result = testContext.getInstanceBaseUrl();

			expect(result).toBe('https://example.com');
		});
	});

	describe('getInstanceId', () => {
		it('should return the instanceId property of instanceSettings', () => {
			const result = testContext.getInstanceId();

			expect(result).toBe('abc123');
		});
	});

	describe('getTimezone', () => {
		it('should return the timezone property of workflow', () => {
			const result = testContext.getTimezone();
			expect(result).toBe('UTC');
		});
	});

	describe('getCredentialsProperties', () => {
		it('should call getCredentialsProperties method of additionalData.credentialsHelper', () => {
			testContext.getCredentialsProperties('testType');
			expect(additionalData.credentialsHelper.getCredentialsProperties).toHaveBeenCalledWith(
				'testType',
			);
		});
	});

	describe('_getCredentials', () => {
		it('should set executionContext on additionalData before retrieving credentials', async () => {
			const credentialDetails = { id: 'cred123', name: 'Test Credential' };
			const testNode = mock<INode>({
				type: 'n8n-nodes-base.httpRequest',
			});
			testNode.credentials = { testCredential: credentialDetails };

			const runtimeData = {
				version: 1 as const,
				establishedAt: Date.now(),
				source: 'manual' as const,
			};
			const testRunExecutionData = createRunExecutionData({
				resultData: { runData: {} },
				executionData: { runtimeData },
			});

			let capturedExecutionContext: unknown;
			const mockCredentialsHelper = {
				getDecrypted: jest
					.fn()
					.mockImplementation(async (additionalData: IWorkflowExecuteAdditionalData) => {
						// Capture the executionContext value at the moment getDecrypted is called
						capturedExecutionContext = additionalData.executionContext;
						return { token: 'test-token' };
					}),
				getCredentialsProperties: jest.fn(),
			};

			const mockAdditionalData = mock<IWorkflowExecuteAdditionalData>({
				credentialsHelper: mockCredentialsHelper,
			});

			const contextWithCredentials = new TestContext(
				workflow,
				testNode,
				mockAdditionalData,
				mode,
				testRunExecutionData,
			);

			await contextWithCredentials['_getCredentials']('testCredential');

			// Assert that executionContext was already set when getDecrypted was called
			expect(capturedExecutionContext).toEqual(runtimeData);
			expect(mockCredentialsHelper.getDecrypted).toHaveBeenCalledWith(
				mockAdditionalData,
				credentialDetails,
				'testCredential',
				mode,
				undefined,
				false,
				undefined,
			);
		});
	});

	describe('prepareOutputData', () => {
		it('should return the input array wrapped in another array', async () => {
			const outputData = [mock<INodeExecutionData>(), mock<INodeExecutionData>()];

			const result = await testContext.prepareOutputData(outputData);

			expect(result).toEqual([outputData]);
		});
	});

	describe('getNodeInputs', () => {
		it('should return static inputs array when inputs is an array', () => {
			nodeType.description.inputs = [NodeConnectionTypes.Main, NodeConnectionTypes.AiLanguageModel];

			const result = testContext.getNodeInputs();

			expect(result).toEqual([
				{ type: NodeConnectionTypes.Main },
				{ type: NodeConnectionTypes.AiLanguageModel },
			]);
		});

		it('should return input objects when inputs contains configurations', () => {
			nodeType.description.inputs = [
				{ type: NodeConnectionTypes.Main },
				{ type: NodeConnectionTypes.AiLanguageModel, required: true },
			];

			const result = testContext.getNodeInputs();

			expect(result).toEqual([
				{ type: NodeConnectionTypes.Main },
				{ type: NodeConnectionTypes.AiLanguageModel, required: true },
			]);
		});

		it('should evaluate dynamic inputs when inputs is a function', () => {
			const inputsExpressions = '={{ ["main", "ai_languageModel"] }}';
			nodeType.description.inputs = inputsExpressions;
			expression.getSimpleParameterValue.mockReturnValue([
				NodeConnectionTypes.Main,
				NodeConnectionTypes.AiLanguageModel,
			]);

			const result = testContext.getNodeInputs();

			expect(result).toEqual([
				{ type: NodeConnectionTypes.Main },
				{ type: NodeConnectionTypes.AiLanguageModel },
			]);
			expect(expression.getSimpleParameterValue).toHaveBeenCalledWith(
				node,
				inputsExpressions,
				'internal',
				{},
			);
		});
	});

	describe('getNodeOutputs', () => {
		it('should return static outputs array when outputs is an array', () => {
			nodeType.description.outputs = [
				NodeConnectionTypes.Main,
				NodeConnectionTypes.AiLanguageModel,
			];

			const result = testContext.getNodeOutputs();

			expect(result).toEqual([
				{ type: NodeConnectionTypes.Main },
				{ type: NodeConnectionTypes.AiLanguageModel },
			]);
		});

		it('should return output objects when outputs contains configurations', () => {
			nodeType.description.outputs = [
				{ type: NodeConnectionTypes.Main },
				{ type: NodeConnectionTypes.AiLanguageModel, required: true },
			];

			const result = testContext.getNodeOutputs();

			expect(result).toEqual([
				{ type: NodeConnectionTypes.Main },
				{ type: NodeConnectionTypes.AiLanguageModel, required: true },
			]);
		});

		it('should evaluate dynamic outputs when outputs is a function', () => {
			const outputsExpressions = '={{ ["main", "ai_languageModel"] }}';
			nodeType.description.outputs = outputsExpressions;
			expression.getSimpleParameterValue.mockReturnValue([
				NodeConnectionTypes.Main,
				NodeConnectionTypes.AiLanguageModel,
			]);

			const result = testContext.getNodeOutputs();

			expect(result).toEqual([
				{ type: NodeConnectionTypes.Main },
				{ type: NodeConnectionTypes.AiLanguageModel },
			]);
			expect(expression.getSimpleParameterValue).toHaveBeenCalledWith(
				node,
				outputsExpressions,
				'internal',
				{},
			);
		});

		it('should add error output when node has continueOnFail error handling', () => {
			const nodeWithError = mock<INode>({ onError: 'continueErrorOutput' });
			const contextWithError = new TestContext(workflow, nodeWithError, additionalData, mode);
			nodeType.description.outputs = [NodeConnectionTypes.Main];

			const result = contextWithError.getNodeOutputs();

			expect(result).toEqual([
				{ type: NodeConnectionTypes.Main, displayName: 'Success' },
				{ type: NodeConnectionTypes.Main, displayName: 'Error', category: 'error' },
			]);
		});
	});

	describe('getConnectedNodes', () => {
		it('should return connected nodes of given type', () => {
			const node1 = mock<INode>({ name: 'Node 1', type: 'test', disabled: false });
			const node2 = mock<INode>({ name: 'Node 2', type: 'test', disabled: false });

			workflow.getParentNodes.mockReturnValue(['Node 1', 'Node 2']);
			workflow.getNode.mockImplementation((name) => {
				if (name === 'Node 1') return node1;
				if (name === 'Node 2') return node2;
				return null;
			});

			const result = testContext.getConnectedNodes(NodeConnectionTypes.Main);

			expect(result).toEqual([node1, node2]);
			expect(workflow.getParentNodes).toHaveBeenCalledWith(node.name, NodeConnectionTypes.Main, 1);
		});

		it('should filter out disabled nodes', () => {
			const node1 = mock<INode>({ name: 'Node 1', type: 'test', disabled: false });
			const node2 = mock<INode>({ name: 'Node 2', type: 'test', disabled: true });

			workflow.getParentNodes.mockReturnValue(['Node 1', 'Node 2']);
			workflow.getNode.mockImplementation((name) => {
				if (name === 'Node 1') return node1;
				if (name === 'Node 2') return node2;
				return null;
			});

			const result = testContext.getConnectedNodes(NodeConnectionTypes.Main);

			expect(result).toEqual([node1]);
		});

		it('should filter out non-existent nodes', () => {
			const node1 = mock<INode>({ name: 'Node 1', type: 'test', disabled: false });

			workflow.getParentNodes.mockReturnValue(['Node 1', 'NonExistent']);
			workflow.getNode.mockImplementation((name) => {
				if (name === 'Node 1') return node1;
				return null;
			});

			const result = testContext.getConnectedNodes(NodeConnectionTypes.Main);

			expect(result).toEqual([node1]);
		});
	});

	describe('getSignedResumeUrl', () => {
		beforeEach(() => {
			jest.clearAllMocks();
			testContext = new TestContext(
				workflow,
				mock<INode>({
					id: 'node456',
				}),
				mock<IWorkflowExecuteAdditionalData>({
					executionId: '123',
					webhookWaitingBaseUrl: 'http://localhost/waiting-webhook',
				}),
				mode,
				createRunExecutionData({
					validateSignature: true,
					resultData: { runData: {} },
				}),
			);
			nodeTypes.getByNameAndVersion.mockReturnValue(nodeType);
		});
		it('should return a signed resume URL with no query parameters', () => {
			const result = testContext.getSignedResumeUrl();

			expect(result).toBe(
				'http://localhost/waiting-webhook/123/node456?signature=8e48dfd1107c1a736f70e7399493ffc50a2e8edd44f389c5f9c058da961682e7',
			);
		});

		it('should return a signed resume URL with query parameters', () => {
			const result = testContext.getSignedResumeUrl({ approved: 'true' });

			expect(result).toBe(
				'http://localhost/waiting-webhook/123/node456?approved=true&signature=11c5efc97a0d6f2ea9045dba6e397596cba29dc24adb44a9ebd3d1272c991e9b',
			);
		});
	});

	describe('nodeFeatures', () => {
		it('should return empty object when features are not defined', () => {
			node.typeVersion = 2.4;
			nodeType.description.features = undefined;

			const result = testContext['nodeFeatures'];

			expect(result).toEqual({});
		});

		it('should return enabled features based on node version', () => {
			node.typeVersion = 2.4;
			nodeType.description.features = {
				useFeatureA: { '@version': [{ _cnd: { gte: 2.4 } }] },
				useFeatureB: { '@version': [{ _cnd: { lte: 2.1 } }] },
				useFeatureC: { '@version': [{ _cnd: { gte: 2.2 } }] },
			};

			const result = testContext['nodeFeatures'];

			expect(result).toEqual({
				useFeatureA: true,
				useFeatureB: false,
				useFeatureC: true,
			});
		});

		it('should return correct features for version 2.1', () => {
			node.typeVersion = 2.1;
			nodeType.description.features = {
				useFeatureA: { '@version': [{ _cnd: { gte: 2.4 } }] },
				useFeatureB: { '@version': [{ _cnd: { lte: 2.1 } }] },
				useFeatureC: { '@version': [{ _cnd: { gte: 2.2 } }] },
			};

			const result = testContext['nodeFeatures'];

			expect(result).toEqual({
				useFeatureA: false,
				useFeatureB: true,
				useFeatureC: false,
			});
		});

		it('should handle simple version number conditions', () => {
			node.typeVersion = 2;
			nodeType.description.features = {
				useFeatureD: { '@version': [2] },
				useFeatureE: { '@version': [{ _cnd: { lt: 2.3 } }] },
			};

			const result = testContext['nodeFeatures'];

			expect(result).toEqual({
				useFeatureD: true,
				useFeatureE: true,
			});
		});
	});

	describe('isNodeFeatureEnabled', () => {
		it('should return true when feature is enabled', () => {
			node.typeVersion = 2.4;
			nodeType.description.features = {
				useFeatureA: { '@version': [{ _cnd: { gte: 2.4 } }] },
			};

			const result = testContext.isNodeFeatureEnabled('useFeatureA');

			expect(result).toBe(true);
		});

		it('should return false when feature is disabled', () => {
			node.typeVersion = 2.3;
			nodeType.description.features = {
				useFeatureA: { '@version': [{ _cnd: { gte: 2.4 } }] },
			};

			const result = testContext.isNodeFeatureEnabled('useFeatureA');

			expect(result).toBe(false);
		});

		it('should return false when feature does not exist', () => {
			node.typeVersion = 2.4;
			nodeType.description.features = {
				useFeatureA: { '@version': [{ _cnd: { gte: 2.4 } }] },
			};

			const result = testContext.isNodeFeatureEnabled('nonExistentFeature');

			expect(result).toBe(false);
		});

		it('should return false when features are not defined', () => {
			node.typeVersion = 2.4;
			nodeType.description.features = undefined;

			const result = testContext.isNodeFeatureEnabled('useFeatureA');

			expect(result).toBe(false);
		});

		it('should handle multiple features correctly', () => {
			node.typeVersion = 2.4;
			nodeType.description.features = {
				useFeatureA: { '@version': [{ _cnd: { gte: 2.4 } }] },
				useFeatureB: { '@version': [{ _cnd: { lte: 2.1 } }] },
				useFeatureC: { '@version': [{ _cnd: { gte: 2.2 } }] },
			};

			expect(testContext.isNodeFeatureEnabled('useFeatureA')).toBe(true);
			expect(testContext.isNodeFeatureEnabled('useFeatureB')).toBe(false);
			expect(testContext.isNodeFeatureEnabled('useFeatureC')).toBe(true);
		});
	});
});