import {
	type IDataObject,
	type IExecuteFunctions,
	type INodeExecutionData,
	type INodeProperties,
	NodeOperationError,
	accumulateTokenUsage,
	jsonParse,
	updateDisplayOptions,
	validateNodeParameters,
} from 'n8n-workflow';
import zodToJsonSchema from 'zod-to-json-schema';

import { getConnectedTools } from '@utils/helpers';

import type {
	GenerateContentRequest,
	GenerateContentResponse,
	Content,
	Tool,
	GenerateContentGenerationConfig,
	BuiltInTools,
	FunctionCallPart,
	TextPart,
} from '../../helpers/interfaces';
import { apiRequest } from '../../transport';
import { modelRLC } from '../descriptions';

const properties: INodeProperties[] = [
	{ ...modelRLC('modelSearch'), displayOptions: { show: { '@version': [{ _cnd: { lt: 1.2 } }] } } },
	{
		...modelRLC('modelSearch'),
		default: { mode: 'list', value: 'models/gemini-3-flash-preview' },
		displayOptions: { show: { '@version': [{ _cnd: { gte: 1.2 } }] } },
	},
	{
		displayName: 'Messages',
		name: 'messages',
		type: 'fixedCollection',
		typeOptions: {
			sortable: true,
			multipleValues: true,
		},
		placeholder: 'Add Message',
		default: { values: [{ content: '' }] },
		options: [
			{
				displayName: 'Values',
				name: 'values',
				values: [
					{
						displayName: 'Prompt',
						name: 'content',
						type: 'string',
						description: 'The content of the message to be send',
						default: '',
						placeholder: 'e.g. Hello, how can you help me?',
						typeOptions: {
							rows: 2,
						},
					},
					{
						displayName: 'Role',
						name: 'role',
						type: 'options',
						description:
							"Role in shaping the model's response, it tells the model how it should behave and interact with the user",
						options: [
							{
								name: 'User',
								value: 'user',
								description: 'Send a message as a user and get a response from the model',
							},
							{
								name: 'Model',
								value: 'model',
								description: 'Tell the model to adopt a specific tone or personality',
							},
						],
						default: 'user',
					},
				],
			},
		],
	},
	{
		displayName: 'Simplify Output',
		name: 'simplify',
		type: 'boolean',
		default: true,
		description: 'Whether to return a simplified version of the response instead of the raw data',
	},
	{
		displayName: 'Output Content as JSON',
		name: 'jsonOutput',
		type: 'boolean',
		description: 'Whether to attempt to return the response in JSON format',
		default: false,
	},
	{
		displayName: 'Built-in Tools',
		name: 'builtInTools',
		placeholder: 'Add Built-in Tool',
		type: 'collection',
		default: {},
		displayOptions: {
			show: {
				'@version': [{ _cnd: { gte: 1.1 } }],
			},
		},
		options: [
			{
				displayName: 'Google Search',
				name: 'googleSearch',
				type: 'boolean',
				default: true,
				description:
					'Whether to allow the model to search the web using Google Search to get real-time information',
			},
			{
				displayName: 'Google Maps',
				name: 'googleMaps',
				type: 'collection',
				default: { latitude: '', longitude: '' },
				options: [
					{
						displayName: 'Latitude',
						name: 'latitude',
						type: 'number',
						default: '',
						description: 'The latitude coordinate for location-based queries',
						typeOptions: {
							numberPrecision: 6,
						},
					},
					{
						displayName: 'Longitude',
						name: 'longitude',
						type: 'number',
						default: '',
						description: 'The longitude coordinate for location-based queries',
						typeOptions: {
							numberPrecision: 6,
						},
					},
				],
			},
			{
				displayName: 'URL Context',
				name: 'urlContext',
				type: 'boolean',
				default: true,
				description: 'Whether to allow the model to read and analyze content from specific URLs',
			},
			{
				displayName: 'File Search',
				name: 'fileSearch',
				type: 'collection',
				default: { fileSearchStoreNames: '[]' },
				options: [
					{
						displayName: 'File Search Store Names',
						name: 'fileSearchStoreNames',
						description:
							'The file search store names to use for the file search. File search stores are managed via Google AI Studio.',
						type: 'json',
						default: '[]',
						required: true,
					},
					{
						displayName: 'Metadata Filter',
						name: 'metadataFilter',
						type: 'string',
						default: '',
						description:
							'Use metadata filter to search within a subset of documents. Example: author="Robert Graves".',
						placeholder: 'e.g. author="John Doe"',
					},
				],
			},
			{
				displayName: 'Code Execution',
				name: 'codeExecution',
				type: 'boolean',
				default: true,
				description:
					'Whether to allow the model to execute code it generates to produce a response. Supported only by certain models.',
			},
		],
	},
	{
		displayName: 'Options',
		name: 'options',
		placeholder: 'Add Option',
		type: 'collection',
		default: {},
		options: [
			{
				displayName: 'Include Merged Response',
				name: 'includeMergedResponse',
				type: 'boolean',
				default: false,
				description:
					'Whether to include a single output string merging all text parts of the response',
				displayOptions: {
					show: {
						'@version': [{ _cnd: { gte: 1.1 } }],
					},
				},
			},
			{
				displayName: 'System Message',
				name: 'systemMessage',
				type: 'string',
				default: '',
				placeholder: 'e.g. You are a helpful assistant',
			},
			{
				displayName: 'Code Execution',
				name: 'codeExecution',
				type: 'boolean',
				default: false,
				description:
					'Whether to allow the model to execute code it generates to produce a response. Supported only by certain models.',
				displayOptions: {
					show: {
						'@version': [{ _cnd: { eq: 1 } }],
					},
				},
			},
			{
				displayName: 'Frequency Penalty',
				name: 'frequencyPenalty',
				default: 0,
				description:
					"Positive values penalize new tokens based on their existing frequency in the text so far, decreasing the model's likelihood to repeat the same line verbatim",
				type: 'number',
				typeOptions: {
					minValue: -2,
					maxValue: 2,
					numberPrecision: 1,
				},
			},
			{
				displayName: 'Maximum Number of Tokens',
				name: 'maxOutputTokens',
				default: 16,
				description: 'The maximum number of tokens to generate in the completion',
				type: 'number',
				typeOptions: {
					minValue: 1,
					numberPrecision: 0,
				},
			},
			{
				displayName: 'Number of Completions',
				name: 'candidateCount',
				default: 1,
				description: 'How many completions to generate for each prompt',
				type: 'number',
				typeOptions: {
					minValue: 1,
					maxValue: 8, // Google Gemini supports up to 8 candidates
					numberPrecision: 0,
				},
			},
			{
				displayName: 'Presence Penalty',
				name: 'presencePenalty',
				default: 0,
				description:
					"Positive values penalize new tokens based on whether they appear in the text so far, increasing the model's likelihood to talk about new topics",
				type: 'number',
				typeOptions: {
					minValue: -2,
					maxValue: 2,
					numberPrecision: 1,
				},
			},
			{
				displayName: 'Output Randomness (Temperature)',
				name: 'temperature',
				default: 1,
				description:
					'Controls the randomness of the output. Lowering results in less random completions. As the temperature approaches zero, the model will become deterministic and repetitive',
				type: 'number',
				typeOptions: {
					minValue: 0,
					maxValue: 2,
					numberPrecision: 1,
				},
			},
			{
				displayName: 'Output Randomness (Top P)',
				name: 'topP',
				default: 1,
				description: 'The maximum cumulative probability of tokens to consider when sampling',
				type: 'number',
				typeOptions: {
					minValue: 0,
					maxValue: 1,
					numberPrecision: 1,
				},
			},
			{
				displayName: 'Output Randomness (Top K)',
				name: 'topK',
				default: 1,
				description: 'The maximum number of tokens to consider when sampling',
				type: 'number',
				typeOptions: {
					minValue: 1,
					numberPrecision: 0,
				},
			},
			{
				displayName: 'Thinking Budget',
				name: 'thinkingBudget',
				type: 'number',
				default: -1,
				description:
					'Controls reasoning tokens for thinking models. Set to 0 to disable automatic thinking. Set to -1 for dynamic thinking (default).',
				typeOptions: {
					minValue: -1,
					numberPrecision: 0,
				},
			},
			{
				displayName: 'Max Tool Calls Iterations',
				name: 'maxToolsIterations',
				type: 'number',
				default: 15,
				description:
					'The maximum number of tool iteration cycles the LLM will run before stopping. A single iteration can contain multiple tool calls. Set to 0 for no limit',
				typeOptions: {
					minValue: 0,
					numberPrecision: 0,
				},
			},
		],
	},
];

const displayOptions = {
	show: {
		operation: ['message'],
		resource: ['text'],
	},
};

export const description = updateDisplayOptions(displayOptions, properties);

function isFunctionCallPart(part: unknown): part is FunctionCallPart {
	return !!part && typeof part === 'object' && 'functionCall' in part;
}

function isTextPart(part: unknown): part is TextPart {
	return !!part && typeof part === 'object' && 'text' in part;
}

function getToolCalls(response: GenerateContentResponse) {
	return response.candidates.flatMap((c) => c?.content?.parts ?? []).filter(isFunctionCallPart);
}

export async function execute(this: IExecuteFunctions, i: number): Promise<INodeExecutionData[]> {
	const model = this.getNodeParameter('modelId', i, '', { extractValue: true }) as string;
	const messages = this.getNodeParameter('messages.values', i, []) as Array<{
		content: string;
		role: string;
	}>;
	const simplify = this.getNodeParameter('simplify', i, true) as boolean;
	const jsonOutput = this.getNodeParameter('jsonOutput', i, false) as boolean;
	const options = this.getNodeParameter('options', i, {});
	const builtInTools = this.getNodeParameter('builtInTools', i, {}) as BuiltInTools;
	validateNodeParameters(
		options,
		{
			includeMergedResponse: { type: 'boolean', required: false },
			systemMessage: { type: 'string', required: false },
			codeExecution: { type: 'boolean', required: false },
			frequencyPenalty: { type: 'number', required: false },
			maxOutputTokens: { type: 'number', required: false },
			candidateCount: { type: 'number', required: false },
			presencePenalty: { type: 'number', required: false },
			temperature: { type: 'number', required: false },
			topP: { type: 'number', required: false },
			topK: { type: 'number', required: false },
			thinkingBudget: { type: 'number', required: false },
			maxToolsIterations: { type: 'number', required: false },
		},
		this.getNode(),
	);

	const generationConfig: GenerateContentGenerationConfig = {
		frequencyPenalty: options.frequencyPenalty,
		maxOutputTokens: options.maxOutputTokens,
		candidateCount: options.candidateCount,
		presencePenalty: options.presencePenalty,
		temperature: options.temperature,
		topP: options.topP,
		topK: options.topK,
		responseMimeType: jsonOutput ? 'application/json' : undefined,
	};

	// Add thinkingConfig if thinkingBudget is specified
	if (options.thinkingBudget !== undefined) {
		generationConfig.thinkingConfig = {
			thinkingBudget: options.thinkingBudget,
		};
	}

	const nodeInputs = this.getNodeInputs();
	const availableTools = nodeInputs.some((i) => i.type === 'ai_tool')
		? await getConnectedTools(this, true)
		: [];
	const tools: Tool[] = [
		{
			functionDeclarations: availableTools.map((t) => ({
				name: t.name,
				description: t.description,
				parameters: {
					...zodToJsonSchema(t.schema, { target: 'openApi3' }),
					// Google Gemini API throws an error if `additionalProperties` field is present
					additionalProperties: undefined,
				},
			})),
		},
	];
	if (!tools[0].functionDeclarations?.length) {
		tools.pop();
	}

	if (this.getNode().typeVersion === 1) {
		if (options.codeExecution) {
			tools.push({
				codeExecution: {},
			});
		}
	}

	// Add built-in tools and build toolConfig
	let toolConfig: GenerateContentRequest['toolConfig'];
	if (this.getNode().typeVersion >= 1.1) {
		if (builtInTools) {
			if (builtInTools.googleSearch) {
				tools.push({
					googleSearch: {},
				});
			}

			const googleMapsOptions = builtInTools.googleMaps;
			if (googleMapsOptions) {
				tools.push({
					googleMaps: {},
				});

				// Build toolConfig with retrievalConfig if latitude/longitude are provided
				const latitude = googleMapsOptions.latitude;
				const longitude = googleMapsOptions.longitude;
				if (
					latitude !== undefined &&
					latitude !== '' &&
					longitude !== undefined &&
					longitude !== ''
				) {
					toolConfig = {
						retrievalConfig: {
							latLng: {
								latitude: Number(latitude),
								longitude: Number(longitude),
							},
						},
					};
				}
			}

			if (builtInTools.urlContext) {
				tools.push({
					urlContext: {},
				});
			}

			const fileSearchOptions = builtInTools.fileSearch;
			if (fileSearchOptions) {
				const fileSearchStoreNamesRaw = fileSearchOptions.fileSearchStoreNames;
				const metadataFilter = fileSearchOptions.metadataFilter;
				let fileSearchStoreNames: string[] | undefined;
				if (fileSearchStoreNamesRaw) {
					const parsed = jsonParse(fileSearchStoreNamesRaw, {
						errorMessage: 'Failed to parse file search store names',
					});
					if (Array.isArray(parsed)) {
						fileSearchStoreNames = parsed;
					}
				}

				tools.push({
					fileSearch: {
						...(fileSearchStoreNames && { fileSearchStoreNames }),
						...(metadataFilter && { metadataFilter }),
					},
				});
			}

			if (builtInTools.codeExecution) {
				tools.push({
					codeExecution: {},
				});
			}
		}
	}

	const nonEmptyMessages = messages.filter((m) => m.content.trim() !== '');
	if (!nonEmptyMessages.length) {
		throw new NodeOperationError(this.getNode(), 'A non-empty prompt is required.', {
			itemIndex: i,
		});
	}
	const contents: Content[] = nonEmptyMessages.map((m) => ({
		parts: [{ text: m.content }],
		role: m.role,
	}));
	const body: GenerateContentRequest = {
		tools,
		contents,
		generationConfig,
		systemInstruction: options.systemMessage
			? { parts: [{ text: options.systemMessage }] }
			: undefined,
		...(toolConfig && { toolConfig }),
	};

	let response = (await apiRequest.call(this, 'POST', `/v1beta/${model}:generateContent`, {
		body,
	})) as GenerateContentResponse;

	const captureUsage = () => {
		const usageMetadata = (response as unknown as Record<string, unknown>).usageMetadata as
			| { promptTokenCount: number; candidatesTokenCount: number }
			| undefined;
		if (usageMetadata) {
			accumulateTokenUsage(
				this,
				usageMetadata.promptTokenCount,
				usageMetadata.candidatesTokenCount,
			);
		}
	};

	captureUsage();

	const maxToolsIterations = this.getNodeParameter('options.maxToolsIterations', i, 15) as number;
	const abortSignal = this.getExecutionCancelSignal();
	let currentIteration = 1;
	let toolCalls = getToolCalls(response);
	while (toolCalls.length) {
		if (
			(maxToolsIterations > 0 && currentIteration >= maxToolsIterations) ||
			abortSignal?.aborted
		) {
			break;
		}

		contents.push.apply(
			contents,
			response.candidates.map((c) => c.content),
		);

		for (const { functionCall } of toolCalls) {
			let toolResponse;
			for (const availableTool of availableTools) {
				if (availableTool.name === functionCall.name) {
					toolResponse = (await availableTool.invoke(functionCall.args)) as IDataObject;
				}
			}

			contents.push({
				parts: [
					{
						functionResponse: {
							id: functionCall.id,
							name: functionCall.name,
							response: {
								result: toolResponse,
							},
						},
					},
				],
				role: 'tool',
			});
		}

		response = (await apiRequest.call(this, 'POST', `/v1beta/${model}:generateContent`, {
			body,
		})) as GenerateContentResponse;
		captureUsage();
		toolCalls = getToolCalls(response);
		currentIteration++;
	}

	const candidates = options.includeMergedResponse
		? response.candidates.map((candidate) => ({
				...candidate,
				mergedResponse: (candidate?.content?.parts ?? [])
					.filter(isTextPart)
					.map((part) => part.text)
					.join(''),
			}))
		: response.candidates;

	if (simplify) {
		return candidates.map((candidate) => ({
			json: candidate,
			pairedItem: { item: i },
		}));
	}

	return [
		{
			json: {
				...response,
				candidates,
			},
			pairedItem: { item: i },
		},
	];
}