fix type errors in workflow, core, nodes-langchain, and nodes-base

packages/@n8n/nodes-langchain/nodes/agents/Agent/Agent.node.ts

@@ -46,7 +46,7 @@ function getInputs(
 			[NodeConnectionType.AiOutputParser]: 'Output Parser',
 		};
 
-		return inputs.map(({ type, filter, required }) => {
+		return inputs.map(({ type, filter }) => {
 			const input: INodeInputConfiguration = {
 				type,
 				displayName: type in displayNames ? displayNames[type] : undefined,
@@ -370,13 +370,13 @@ export class Agent implements INodeType {
 		if (agentType === 'conversationalAgent') {
 			return await conversationalAgentExecute.call(this, nodeVersion);
 		} else if (agentType === 'toolsAgent') {
-			return await toolsAgentExecute.call(this, nodeVersion);
+			return await toolsAgentExecute.call(this);
 		} else if (agentType === 'openAiFunctionsAgent') {
 			return await openAiFunctionsAgentExecute.call(this, nodeVersion);
 		} else if (agentType === 'reActAgent') {
 			return await reActAgentAgentExecute.call(this, nodeVersion);
 		} else if (agentType === 'sqlAgent') {
-			return await sqlAgentAgentExecute.call(this, nodeVersion);
+			return await sqlAgentAgentExecute.call(this);
 		} else if (agentType === 'planAndExecuteAgent') {
 			return await planAndExecuteAgentExecute.call(this, nodeVersion);
 		}

packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ConversationalAgent/execute.ts

@@ -120,5 +120,5 @@ export async function conversationalAgentExecute(
 		}
 	}
 
-	return await this.prepareOutputData(returnData);
+	return [returnData];
 }

packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/OpenAiFunctionsAgent/execute.ts

@@ -125,5 +125,5 @@ export async function openAiFunctionsAgentExecute(
 		}
 	}
 
-	return await this.prepareOutputData(returnData);
+	return [returnData];
 }

packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/PlanAndExecuteAgent/execute.ts

@@ -100,5 +100,5 @@ export async function planAndExecuteAgentExecute(
 		}
 	}
 
-	return await this.prepareOutputData(returnData);
+	return [returnData];
 }

packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ReActAgent/execute.ts

@@ -121,5 +121,5 @@ export async function reActAgentAgentExecute(
 		}
 	}
 
-	return await this.prepareOutputData(returnData);
+	return [returnData];
 }

packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/SqlAgent/execute.ts

@@ -28,7 +28,6 @@ const parseTablesString = (tablesString: string) =>
 
 export async function sqlAgentAgentExecute(
 	this: IExecuteFunctions,
-	nodeVersion: number,
 ): Promise<INodeExecutionData[][]> {
 	this.logger.verbose('Executing SQL Agent');
 
@@ -152,5 +151,5 @@ export async function sqlAgentAgentExecute(
 		}
 	}
 
-	return await this.prepareOutputData(returnData);
+	return [returnData];
 }

packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ToolsAgent/execute.ts

@@ -39,10 +39,7 @@ function getOutputParserSchema(outputParser: BaseOutputParser): ZodObject<any, a
 	return schema;
 }
 
-export async function toolsAgentExecute(
-	this: IExecuteFunctions,
-	nodeVersion: number,
-): Promise<INodeExecutionData[][]> {
+export async function toolsAgentExecute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
 	this.logger.verbose('Executing Tools Agent');
 	const model = await this.getInputConnectionData(NodeConnectionType.AiLanguageModel, 0);
 
@@ -185,5 +182,5 @@ export async function toolsAgentExecute(
 		}
 	}
 
-	return await this.prepareOutputData(returnData);
+	return [returnData];
 }

packages/@n8n/nodes-langchain/nodes/agents/OpenAiAssistant/OpenAiAssistant.node.ts

@@ -392,6 +392,6 @@ export class OpenAiAssistant implements INodeType {
 			}
 		}
 
-		return await this.prepareOutputData(returnData);
+		return [returnData];
 	}
 }

packages/@n8n/nodes-langchain/nodes/chains/ChainRetrievalQA/ChainRetrievalQa.node.ts

@@ -189,6 +189,6 @@ export class ChainRetrievalQa implements INodeType {
 				throw error;
 			}
 		}
-		return await this.prepareOutputData(returnData);
+		return [returnData];
 	}
 }

packages/@n8n/nodes-langchain/nodes/chains/ChainSummarization/V1/ChainSummarizationV1.node.ts

@@ -258,6 +258,6 @@ export class ChainSummarizationV1 implements INodeType {
 			returnData.push({ json: { response } });
 		}
 
-		return await this.prepareOutputData(returnData);
+		return [returnData];
 	}
 }

packages/@n8n/nodes-langchain/nodes/chains/ChainSummarization/V2/ChainSummarizationV2.node.ts

@@ -425,6 +425,6 @@ export class ChainSummarizationV2 implements INodeType {
 			}
 		}
 
-		return await this.prepareOutputData(returnData);
+		return [returnData];
 	}
 }

packages/@n8n/nodes-langchain/nodes/memory/MemoryChatRetriever/MemoryChatRetriever.node.ts

@@ -98,7 +98,7 @@ export class MemoryChatRetriever implements INodeType {
 		const messages = await memory?.chatHistory.getMessages();
 
 		if (simplifyOutput && messages) {
-			return await this.prepareOutputData(simplifyMessages(messages));
+			return [simplifyMessages(messages)];
 		}
 
 		const serializedMessages =
@@ -107,6 +107,6 @@ export class MemoryChatRetriever implements INodeType {
 				return { json: serializedMessage as unknown as IDataObject };
 			}) ?? [];
 
-		return await this.prepareOutputData(serializedMessages);
+		return [serializedMessages];
 	}
 }

packages/@n8n/nodes-langchain/nodes/output_parser/OutputParserStructured/test/OutputParserStructured.node.test.ts

@@ -1,4 +1,4 @@
-import type { IExecuteFunctions, IWorkflowDataProxyData } from 'n8n-workflow';
+import type { IExecuteFunctions, INode, IWorkflowDataProxyData } from 'n8n-workflow';
 import { mock } from 'jest-mock-extended';
 import { normalizeItems } from 'n8n-core';
 import type { z } from 'zod';
@@ -12,7 +12,7 @@ describe('OutputParserStructured', () => {
 	});
 	const workflowDataProxy = mock<IWorkflowDataProxyData>({ $input: mock() });
 	thisArg.getWorkflowDataProxy.mockReturnValue(workflowDataProxy);
-	thisArg.getNode.mockReturnValue({ typeVersion: 1.1 });
+	thisArg.getNode.mockReturnValue(mock<INode>({ typeVersion: 1.1 }));
 	thisArg.addInputData.mockReturnValue({ index: 0 });
 	thisArg.addOutputData.mockReturnValue();
 

packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreInMemoryInsert/VectorStoreInMemoryInsert.node.ts

@@ -108,6 +108,6 @@ export class VectorStoreInMemoryInsert implements INodeType {
 			clearStore,
 		);
 
-		return await this.prepareOutputData(serializedDocuments);
+		return [serializedDocuments];
 	}
 }

packages/@n8n/nodes-langchain/nodes/vector_store/VectorStorePineconeInsert/VectorStorePineconeInsert.node.ts

@@ -134,6 +134,6 @@ export class VectorStorePineconeInsert implements INodeType {
 			pineconeIndex,
 		});
 
-		return await this.prepareOutputData(serializedDocuments);
+		return [serializedDocuments];
 	}
 }

packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreQdrant/VectorStoreQdrant.node.ts

@@ -46,7 +46,7 @@ export const VectorStoreQdrant = createVectorStoreNode({
 	methods: { listSearch: { qdrantCollectionsSearch } },
 	insertFields,
 	sharedFields,
-	async getVectorStoreClient(context, filter, embeddings, itemIndex) {
+	async getVectorStoreClient(context, _, embeddings, itemIndex) {
 		const collection = context.getNodeParameter('qdrantCollection', itemIndex, '', {
 			extractValue: true,
 		}) as string;

packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreSupabaseInsert/VectorStoreSupabaseInsert.node.ts

@@ -122,6 +122,6 @@ export class VectorStoreSupabaseInsert implements INodeType {
 			queryName,
 		});
 
-		return await this.prepareOutputData(serializedDocuments);
+		return [serializedDocuments];
 	}
 }

packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreZepInsert/VectorStoreZepInsert.node.ts

@@ -139,6 +139,6 @@ export class VectorStoreZepInsert implements INodeType {
 
 		await ZepVectorStore.fromDocuments(processedDocuments, embeddings, zepConfig);
 
-		return await this.prepareOutputData(serializedDocuments);
+		return [serializedDocuments];
 	}
 }

packages/@n8n/nodes-langchain/nodes/vector_store/shared/createVectorStoreNode.ts

@@ -240,7 +240,7 @@ export const createVectorStoreNode = (args: VectorStoreNodeConstructorArgs) =>
 					void logAiEvent(this, 'n8n.ai.vector.store.searched', { query: prompt });
 				}
 
-				return await this.prepareOutputData(resultData);
+				return [resultData];
 			}
 
 			if (mode === 'insert') {
@@ -270,7 +270,7 @@ export const createVectorStoreNode = (args: VectorStoreNodeConstructorArgs) =>
 					}
 				}
 
-				return await this.prepareOutputData(resultData);
+				return [resultData];
 			}
 
 			throw new NodeOperationError(

packages/core/src/Secrets.ts

@@ -3,7 +3,7 @@ import { ExpressionError } from 'n8n-workflow';
 
 function buildSecretsValueProxy(value: IDataObject): unknown {
 	return new Proxy(value, {
-		get(target, valueName) {
+		get(_target, valueName) {
 			if (typeof valueName !== 'string') {
 				return;
 			}
@@ -27,15 +27,15 @@ export function getSecretsProxy(additionalData: IWorkflowExecuteAdditionalData):
 	return new Proxy(
 		{},
 		{
-			get(target, providerName) {
+			get(_target, providerName) {
 				if (typeof providerName !== 'string') {
 					return {};
 				}
 				if (secretsHelpers.hasProvider(providerName)) {
 					return new Proxy(
 						{},
 						{
-							get(target2, secretName) {
+							get(_target2, secretName) {
 								if (typeof secretName !== 'string') {
 									return;
 								}

packages/core/test/ObjectStore.manager.test.ts

@@ -1,7 +1,9 @@
 import fs from 'node:fs/promises';
+import { mock } from 'jest-mock-extended';
 import { ObjectStoreManager } from '@/BinaryData/ObjectStore.manager';
 import { ObjectStoreService } from '@/ObjectStore/ObjectStore.service.ee';
 import { isStream } from '@/ObjectStore/utils';
+import type { MetadataResponseHeaders } from '@/ObjectStore/types';
 import { mockInstance, toFileId, toStream } from './utils';
 
 jest.mock('fs/promises');
@@ -74,11 +76,13 @@ describe('getMetadata()', () => {
 		const mimeType = 'text/plain';
 		const fileName = 'file.txt';
 
-		objectStoreService.getMetadata.mockResolvedValue({
-			'content-length': '1',
-			'content-type': mimeType,
-			'x-amz-meta-filename': fileName,
-		});
+		objectStoreService.getMetadata.mockResolvedValue(
+			mock<MetadataResponseHeaders>({
+				'content-length': '1',
+				'content-type': mimeType,
+				'x-amz-meta-filename': fileName,
+			}),
+		);
 
 		const metadata = await objectStoreManager.getMetadata(fileId);
 

packages/nodes-base/nodes/AgileCrm/GenericFunctions.ts

@@ -96,7 +96,7 @@ export async function agileCrmApiRequestAllItems(
 export async function agileCrmApiRequestUpdate(
 	this: IHookFunctions | IExecuteFunctions | ILoadOptionsFunctions,
 	method: IHttpRequestMethods = 'PUT',
-	endpoint?: string,
+	_endpoint?: string,
 	body: any = {},
 	_query: IDataObject = {},
 	uri?: string,

packages/nodes-base/nodes/Clockify/GenericFunctions.ts

@@ -14,7 +14,7 @@ export async function clockifyApiRequest(
 
 	body: any = {},
 	qs: IDataObject = {},
-	uri?: string,
+	_uri?: string,
 	_option: IDataObject = {},
 ): Promise<any> {
 	const BASE_URL = 'https://api.clockify.me/api/v1';

packages/nodes-base/nodes/Cloudflare/GenericFunctions.ts

@@ -15,7 +15,7 @@ export async function cloudflareApiRequest(
 	resource: string,
 	body = {},
 	qs: IDataObject = {},
-	uri?: string,
+	_uri?: string,
 	headers: IDataObject = {},
 ): Promise<any> {
 	const options: IRequestOptions = {

packages/nodes-base/nodes/Code/test/Code.node.test.ts

@@ -1,7 +1,7 @@
 import { anyNumber, mock } from 'jest-mock-extended';
 import { NodeVM } from '@n8n/vm2';
 import type { IExecuteFunctions, IWorkflowDataProxyData } from 'n8n-workflow';
-import { ApplicationError, NodeHelpers } from 'n8n-workflow';
+import { ApplicationError } from 'n8n-workflow';
 import { normalizeItems } from 'n8n-core';
 import { Code } from '../Code.node';
 import { ValidationError } from '../ValidationError';
@@ -22,7 +22,6 @@ describe('Code Node unit test', () => {
 	const thisArg = mock<IExecuteFunctions>({
 		getNode: () => mock(),
 		helpers: { normalizeItems },
-		prepareOutputData: NodeHelpers.prepareOutputData,
 	});
 	const workflowDataProxy = mock<IWorkflowDataProxyData>({ $input: mock() });
 	thisArg.getWorkflowDataProxy.mockReturnValue(workflowDataProxy);

packages/nodes-base/nodes/Discord/test/v2/node/channel/create.test.ts

@@ -7,7 +7,7 @@ import { executeWorkflow } from '@test/nodes/ExecuteWorkflow';
 
 const discordApiRequestSpy = jest.spyOn(transport, 'discordApiRequest');
 
-discordApiRequestSpy.mockImplementation(async (method: string, endpoint) => {
+discordApiRequestSpy.mockImplementation(async (method: string) => {
 	if (method === 'POST') {
 		return {
 			id: '1168528323006181417',

packages/nodes-base/nodes/Discord/test/v2/node/channel/deleteChannel.test.ts

@@ -7,7 +7,7 @@ import { executeWorkflow } from '@test/nodes/ExecuteWorkflow';
 
 const discordApiRequestSpy = jest.spyOn(transport, 'discordApiRequest');
 
-discordApiRequestSpy.mockImplementation(async (method: string, endpoint) => {
+discordApiRequestSpy.mockImplementation(async (method: string) => {
 	if (method === 'DELETE') {
 		return {
 			id: '1168528323006181417',

packages/nodes-base/nodes/Discord/test/v2/node/channel/get.test.ts

@@ -5,10 +5,11 @@ import { getResultNodeData, setup, workflowToTests } from '@test/nodes/Helpers';
 import type { WorkflowTestData } from '@test/nodes/types';
 import { executeWorkflow } from '@test/nodes/ExecuteWorkflow';
 
+// TODO: use nock
 const requestApiSpy = jest.spyOn(transport, 'requestApi');
 
 requestApiSpy.mockImplementation(
-	async (options: IRequestOptions, credentialType: string, endpoint: string) => {
+	async (_options: IRequestOptions, _credentialType: string, endpoint: string) => {
 		if (endpoint === '/users/@me/guilds') {
 			return {
 				headers: {},

packages/nodes-base/nodes/Discord/test/v2/node/channel/getAll.test.ts

@@ -7,7 +7,7 @@ import { executeWorkflow } from '@test/nodes/ExecuteWorkflow';
 
 const discordApiRequestSpy = jest.spyOn(transport, 'discordApiRequest');
 
-discordApiRequestSpy.mockImplementation(async (method: string, endpoint) => {
+discordApiRequestSpy.mockImplementation(async (method: string) => {
 	if (method === 'GET') {
 		return [
 			{

packages/nodes-base/nodes/Discord/test/v2/node/channel/update.test.ts

@@ -7,7 +7,7 @@ import { executeWorkflow } from '@test/nodes/ExecuteWorkflow';
 
 const discordApiRequestSpy = jest.spyOn(transport, 'discordApiRequest');
 
-discordApiRequestSpy.mockImplementation(async (method: string, endpoint) => {
+discordApiRequestSpy.mockImplementation(async (method: string, _) => {
 	if (method === 'PATCH') {
 		return {
 			id: '1168516240332034067',

packages/nodes-base/nodes/Discord/test/v2/node/member/getAll.test.ts

@@ -7,7 +7,7 @@ import { executeWorkflow } from '@test/nodes/ExecuteWorkflow';
 
 const discordApiRequestSpy = jest.spyOn(transport, 'discordApiRequest');
 
-discordApiRequestSpy.mockImplementation(async (method: string, endpoint) => {
+discordApiRequestSpy.mockImplementation(async (method: string) => {
 	if (method === 'GET') {
 		return [
 			{

packages/nodes-base/nodes/Discord/test/v2/node/member/roleAdd.test.ts

@@ -7,7 +7,7 @@ import { executeWorkflow } from '@test/nodes/ExecuteWorkflow';
 
 const discordApiRequestSpy = jest.spyOn(transport, 'discordApiRequest');
 
-discordApiRequestSpy.mockImplementation(async (method: string, endpoint) => {
+discordApiRequestSpy.mockImplementation(async (method: string) => {
 	if (method === 'PUT') {
 		return {
 			success: true,

packages/nodes-base/nodes/Discord/test/v2/node/member/roleRemove.test.ts

@@ -7,7 +7,7 @@ import { executeWorkflow } from '@test/nodes/ExecuteWorkflow';
 
 const discordApiRequestSpy = jest.spyOn(transport, 'discordApiRequest');
 
-discordApiRequestSpy.mockImplementation(async (method: string, endpoint) => {
+discordApiRequestSpy.mockImplementation(async (method: string) => {
 	if (method === 'DELETE') {
 		return {
 			success: true,

packages/nodes-base/nodes/Discord/test/v2/node/message/deleteMessage.test.ts

@@ -7,7 +7,7 @@ import { executeWorkflow } from '@test/nodes/ExecuteWorkflow';
 
 const discordApiRequestSpy = jest.spyOn(transport, 'discordApiRequest');
 
-discordApiRequestSpy.mockImplementation(async (method: string, endpoint) => {
+discordApiRequestSpy.mockImplementation(async (method: string) => {
 	if (method === 'DELETE') {
 		return {
 			success: true,