diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ConversationalAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ConversationalAgent/execute.ts index 7693945a70..899fe57a74 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ConversationalAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ConversationalAgent/execute.ts @@ -19,7 +19,7 @@ export async function conversationalAgentExecute( this: IExecuteFunctions, nodeVersion: number, ): Promise { - this.logger.verbose('Executing Conversational Agent'); + this.logger.debug('Executing Conversational Agent'); const model = await this.getInputConnectionData(NodeConnectionType.AiLanguageModel, 0); if (!isChatInstance(model)) { diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/OpenAiFunctionsAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/OpenAiFunctionsAgent/execute.ts index 3c4ff28f06..072039259f 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/OpenAiFunctionsAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/OpenAiFunctionsAgent/execute.ts @@ -23,7 +23,7 @@ export async function openAiFunctionsAgentExecute( this: IExecuteFunctions, nodeVersion: number, ): Promise { - this.logger.verbose('Executing OpenAi Functions Agent'); + this.logger.debug('Executing OpenAi Functions Agent'); const model = (await this.getInputConnectionData( NodeConnectionType.AiLanguageModel, 0, diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/PlanAndExecuteAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/PlanAndExecuteAgent/execute.ts index 7aa22d8476..4c77a6a0aa 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/PlanAndExecuteAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/PlanAndExecuteAgent/execute.ts @@ -22,7 +22,7 @@ export async function planAndExecuteAgentExecute( this: IExecuteFunctions, nodeVersion: number, ): Promise { - this.logger.verbose('Executing PlanAndExecute Agent'); + this.logger.debug('Executing PlanAndExecute Agent'); const model = (await this.getInputConnectionData( NodeConnectionType.AiLanguageModel, 0, diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ReActAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ReActAgent/execute.ts index bc012c5201..1fdaafc290 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ReActAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ReActAgent/execute.ts @@ -24,7 +24,7 @@ export async function reActAgentAgentExecute( this: IExecuteFunctions, nodeVersion: number, ): Promise { - this.logger.verbose('Executing ReAct Agent'); + this.logger.debug('Executing ReAct Agent'); const model = (await this.getInputConnectionData(NodeConnectionType.AiLanguageModel, 0)) as | BaseLanguageModel diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/SqlAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/SqlAgent/execute.ts index 15ef523338..bd8868ad32 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/SqlAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/SqlAgent/execute.ts @@ -29,7 +29,7 @@ const parseTablesString = (tablesString: string) => export async function sqlAgentAgentExecute( this: IExecuteFunctions, ): Promise { - this.logger.verbose('Executing SQL Agent'); + this.logger.debug('Executing SQL Agent'); const model = (await this.getInputConnectionData( NodeConnectionType.AiLanguageModel, diff --git a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ToolsAgent/execute.ts b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ToolsAgent/execute.ts index e0da7f1e31..fc760cb928 100644 --- a/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ToolsAgent/execute.ts +++ b/packages/@n8n/nodes-langchain/nodes/agents/Agent/agents/ToolsAgent/execute.ts @@ -76,7 +76,7 @@ async function extractBinaryMessages(ctx: IExecuteFunctions) { } export async function toolsAgentExecute(this: IExecuteFunctions): Promise { - this.logger.verbose('Executing Tools Agent'); + this.logger.debug('Executing Tools Agent'); const model = await this.getInputConnectionData(NodeConnectionType.AiLanguageModel, 0); if (!isChatInstance(model) || !model.bindTools) { diff --git a/packages/@n8n/nodes-langchain/nodes/chains/ChainLLM/ChainLlm.node.ts b/packages/@n8n/nodes-langchain/nodes/chains/ChainLLM/ChainLlm.node.ts index 003c8eb7dd..02b91134e6 100644 --- a/packages/@n8n/nodes-langchain/nodes/chains/ChainLLM/ChainLlm.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/chains/ChainLLM/ChainLlm.node.ts @@ -517,7 +517,7 @@ export class ChainLlm implements INodeType { }; async execute(this: IExecuteFunctions): Promise { - this.logger.verbose('Executing LLM Chain'); + this.logger.debug('Executing LLM Chain'); const items = this.getInputData(); const returnData: INodeExecutionData[] = []; diff --git a/packages/@n8n/nodes-langchain/nodes/chains/ChainRetrievalQA/ChainRetrievalQa.node.ts b/packages/@n8n/nodes-langchain/nodes/chains/ChainRetrievalQA/ChainRetrievalQa.node.ts index 07bde01a6c..9f79372ebd 100644 --- a/packages/@n8n/nodes-langchain/nodes/chains/ChainRetrievalQA/ChainRetrievalQa.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/chains/ChainRetrievalQA/ChainRetrievalQa.node.ts @@ -141,7 +141,7 @@ export class ChainRetrievalQa implements INodeType { }; async execute(this: IExecuteFunctions): Promise { - this.logger.verbose('Executing Retrieval QA Chain'); + this.logger.debug('Executing Retrieval QA Chain'); const model = (await this.getInputConnectionData( NodeConnectionType.AiLanguageModel, diff --git a/packages/@n8n/nodes-langchain/nodes/chains/ChainSummarization/V1/ChainSummarizationV1.node.ts b/packages/@n8n/nodes-langchain/nodes/chains/ChainSummarization/V1/ChainSummarizationV1.node.ts index bc18739647..3e7b6997d6 100644 --- a/packages/@n8n/nodes-langchain/nodes/chains/ChainSummarization/V1/ChainSummarizationV1.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/chains/ChainSummarization/V1/ChainSummarizationV1.node.ts @@ -162,7 +162,7 @@ export class ChainSummarizationV1 implements INodeType { } async execute(this: IExecuteFunctions): Promise { - this.logger.verbose('Executing Vector Store QA Chain'); + this.logger.debug('Executing Vector Store QA Chain'); const type = this.getNodeParameter('type', 0) as 'map_reduce' | 'stuff' | 'refine'; const model = (await this.getInputConnectionData( diff --git a/packages/@n8n/nodes-langchain/nodes/chains/ChainSummarization/V2/ChainSummarizationV2.node.ts b/packages/@n8n/nodes-langchain/nodes/chains/ChainSummarization/V2/ChainSummarizationV2.node.ts index 3abf749cb0..7d79ce29af 100644 --- a/packages/@n8n/nodes-langchain/nodes/chains/ChainSummarization/V2/ChainSummarizationV2.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/chains/ChainSummarization/V2/ChainSummarizationV2.node.ts @@ -311,7 +311,7 @@ export class ChainSummarizationV2 implements INodeType { } async execute(this: IExecuteFunctions): Promise { - this.logger.verbose('Executing Summarization Chain V2'); + this.logger.debug('Executing Summarization Chain V2'); const operationMode = this.getNodeParameter('operationMode', 0, 'nodeInputJson') as | 'nodeInputJson' | 'nodeInputBinary' diff --git a/packages/@n8n/nodes-langchain/nodes/document_loaders/DocumentBinaryInputLoader/DocumentBinaryInputLoader.node.ts b/packages/@n8n/nodes-langchain/nodes/document_loaders/DocumentBinaryInputLoader/DocumentBinaryInputLoader.node.ts index 6fe6b30db5..783f12be9d 100644 --- a/packages/@n8n/nodes-langchain/nodes/document_loaders/DocumentBinaryInputLoader/DocumentBinaryInputLoader.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/document_loaders/DocumentBinaryInputLoader/DocumentBinaryInputLoader.node.ts @@ -178,7 +178,7 @@ export class DocumentBinaryInputLoader implements INodeType { }; async supplyData(this: IExecuteFunctions): Promise { - this.logger.verbose('Supply Data for Binary Input Loader'); + this.logger.debug('Supply Data for Binary Input Loader'); const textSplitter = (await this.getInputConnectionData( NodeConnectionType.AiTextSplitter, 0, diff --git a/packages/@n8n/nodes-langchain/nodes/document_loaders/DocumentJSONInputLoader/DocumentJsonInputLoader.node.ts b/packages/@n8n/nodes-langchain/nodes/document_loaders/DocumentJSONInputLoader/DocumentJsonInputLoader.node.ts index 403f215d23..3cb2c4bfdb 100644 --- a/packages/@n8n/nodes-langchain/nodes/document_loaders/DocumentJSONInputLoader/DocumentJsonInputLoader.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/document_loaders/DocumentJSONInputLoader/DocumentJsonInputLoader.node.ts @@ -80,7 +80,7 @@ export class DocumentJsonInputLoader implements INodeType { }; async supplyData(this: IExecuteFunctions): Promise { - this.logger.verbose('Supply Data for JSON Input Loader'); + this.logger.debug('Supply Data for JSON Input Loader'); const textSplitter = (await this.getInputConnectionData( NodeConnectionType.AiTextSplitter, 0, diff --git a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsAzureOpenAi/EmbeddingsAzureOpenAi.node.ts b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsAzureOpenAi/EmbeddingsAzureOpenAi.node.ts index 920263a893..46195be0d3 100644 --- a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsAzureOpenAi/EmbeddingsAzureOpenAi.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsAzureOpenAi/EmbeddingsAzureOpenAi.node.ts @@ -93,7 +93,7 @@ export class EmbeddingsAzureOpenAi implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply data for embeddings'); + this.logger.debug('Supply data for embeddings'); const credentials = await this.getCredentials<{ apiKey: string; resourceName: string; diff --git a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsCohere/EmbeddingsCohere.node.ts b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsCohere/EmbeddingsCohere.node.ts index aa6d6ab3c3..a6c246acb5 100644 --- a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsCohere/EmbeddingsCohere.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsCohere/EmbeddingsCohere.node.ts @@ -100,7 +100,7 @@ export class EmbeddingsCohere implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply data for embeddings Cohere'); + this.logger.debug('Supply data for embeddings Cohere'); const modelName = this.getNodeParameter('modelName', itemIndex, 'embed-english-v2.0') as string; const credentials = await this.getCredentials<{ apiKey: string }>('cohereApi'); const embeddings = new CohereEmbeddings({ diff --git a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsGoogleGemini/EmbeddingsGoogleGemini.node.ts b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsGoogleGemini/EmbeddingsGoogleGemini.node.ts index 7249b639f6..92882dfffa 100644 --- a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsGoogleGemini/EmbeddingsGoogleGemini.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsGoogleGemini/EmbeddingsGoogleGemini.node.ts @@ -117,7 +117,7 @@ export class EmbeddingsGoogleGemini implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply data for embeddings Google Gemini'); + this.logger.debug('Supply data for embeddings Google Gemini'); const modelName = this.getNodeParameter( 'modelName', itemIndex, diff --git a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsGooglePalm/EmbeddingsGooglePalm.node.ts b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsGooglePalm/EmbeddingsGooglePalm.node.ts index 32cbd8822d..0e31329f01 100644 --- a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsGooglePalm/EmbeddingsGooglePalm.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsGooglePalm/EmbeddingsGooglePalm.node.ts @@ -116,7 +116,7 @@ export class EmbeddingsGooglePalm implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply data for embeddings Google PaLM'); + this.logger.debug('Supply data for embeddings Google PaLM'); const modelName = this.getNodeParameter( 'modelName', itemIndex, diff --git a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsHuggingFaceInference/EmbeddingsHuggingFaceInference.node.ts b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsHuggingFaceInference/EmbeddingsHuggingFaceInference.node.ts index 4adc8d6014..93d751b9c4 100644 --- a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsHuggingFaceInference/EmbeddingsHuggingFaceInference.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsHuggingFaceInference/EmbeddingsHuggingFaceInference.node.ts @@ -82,7 +82,7 @@ export class EmbeddingsHuggingFaceInference implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply data for embeddings HF Inference'); + this.logger.debug('Supply data for embeddings HF Inference'); const model = this.getNodeParameter( 'modelName', itemIndex, diff --git a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsOllama/EmbeddingsOllama.node.ts b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsOllama/EmbeddingsOllama.node.ts index b0cf827771..c54bc2db68 100644 --- a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsOllama/EmbeddingsOllama.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsOllama/EmbeddingsOllama.node.ts @@ -45,7 +45,7 @@ export class EmbeddingsOllama implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply data for embeddings Ollama'); + this.logger.debug('Supply data for embeddings Ollama'); const modelName = this.getNodeParameter('model', itemIndex) as string; const credentials = await this.getCredentials('ollamaApi'); diff --git a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsOpenAI/EmbeddingsOpenAi.node.ts b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsOpenAI/EmbeddingsOpenAi.node.ts index 31180cd1e9..046f3e4f56 100644 --- a/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsOpenAI/EmbeddingsOpenAi.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/embeddings/EmbeddingsOpenAI/EmbeddingsOpenAi.node.ts @@ -171,7 +171,7 @@ export class EmbeddingsOpenAi implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply data for embeddings'); + this.logger.debug('Supply data for embeddings'); const credentials = await this.getCredentials('openAiApi'); const options = this.getNodeParameter('options', itemIndex, {}) as { diff --git a/packages/@n8n/nodes-langchain/nodes/memory/MemoryChatRetriever/MemoryChatRetriever.node.ts b/packages/@n8n/nodes-langchain/nodes/memory/MemoryChatRetriever/MemoryChatRetriever.node.ts index 6b9bf6203f..f2bb0f43b0 100644 --- a/packages/@n8n/nodes-langchain/nodes/memory/MemoryChatRetriever/MemoryChatRetriever.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/memory/MemoryChatRetriever/MemoryChatRetriever.node.ts @@ -88,7 +88,7 @@ export class MemoryChatRetriever implements INodeType { }; async execute(this: IExecuteFunctions): Promise { - this.logger.verbose('Executing Chat Memory Retriever'); + this.logger.debug('Executing Chat Memory Retriever'); const memory = (await this.getInputConnectionData(NodeConnectionType.AiMemory, 0)) as | BaseChatMemory diff --git a/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverContextualCompression/RetrieverContextualCompression.node.ts b/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverContextualCompression/RetrieverContextualCompression.node.ts index 2526ecb861..5b89a0bf26 100644 --- a/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverContextualCompression/RetrieverContextualCompression.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverContextualCompression/RetrieverContextualCompression.node.ts @@ -64,7 +64,7 @@ export class RetrieverContextualCompression implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supplying data for Contextual Compression Retriever'); + this.logger.debug('Supplying data for Contextual Compression Retriever'); const model = (await this.getInputConnectionData( NodeConnectionType.AiLanguageModel, diff --git a/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverMultiQuery/RetrieverMultiQuery.node.ts b/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverMultiQuery/RetrieverMultiQuery.node.ts index d594c3a285..3cb377d654 100644 --- a/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverMultiQuery/RetrieverMultiQuery.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverMultiQuery/RetrieverMultiQuery.node.ts @@ -83,7 +83,7 @@ export class RetrieverMultiQuery implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supplying data for MultiQuery Retriever'); + this.logger.debug('Supplying data for MultiQuery Retriever'); const options = this.getNodeParameter('options', itemIndex, {}) as { queryCount?: number }; diff --git a/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverVectorStore/RetrieverVectorStore.node.ts b/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverVectorStore/RetrieverVectorStore.node.ts index 9dd5dff58a..6543d061d4 100644 --- a/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverVectorStore/RetrieverVectorStore.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/retrievers/RetrieverVectorStore/RetrieverVectorStore.node.ts @@ -57,7 +57,7 @@ export class RetrieverVectorStore implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supplying data for Vector Store Retriever'); + this.logger.debug('Supplying data for Vector Store Retriever'); const topK = this.getNodeParameter('topK', itemIndex, 4) as number; const vectorStore = (await this.getInputConnectionData( diff --git a/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterCharacterTextSplitter/TextSplitterCharacterTextSplitter.node.ts b/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterCharacterTextSplitter/TextSplitterCharacterTextSplitter.node.ts index 9e7aa050f3..61e62def0f 100644 --- a/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterCharacterTextSplitter/TextSplitterCharacterTextSplitter.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterCharacterTextSplitter/TextSplitterCharacterTextSplitter.node.ts @@ -64,7 +64,7 @@ export class TextSplitterCharacterTextSplitter implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply Data for Text Splitter'); + this.logger.debug('Supply Data for Text Splitter'); const separator = this.getNodeParameter('separator', itemIndex) as string; const chunkSize = this.getNodeParameter('chunkSize', itemIndex) as number; diff --git a/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterRecursiveCharacterTextSplitter/TextSplitterRecursiveCharacterTextSplitter.node.ts b/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterRecursiveCharacterTextSplitter/TextSplitterRecursiveCharacterTextSplitter.node.ts index ec6f716627..4d2c5a6ec8 100644 --- a/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterRecursiveCharacterTextSplitter/TextSplitterRecursiveCharacterTextSplitter.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterRecursiveCharacterTextSplitter/TextSplitterRecursiveCharacterTextSplitter.node.ts @@ -95,7 +95,7 @@ export class TextSplitterRecursiveCharacterTextSplitter implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply Data for Text Splitter'); + this.logger.debug('Supply Data for Text Splitter'); const chunkSize = this.getNodeParameter('chunkSize', itemIndex) as number; const chunkOverlap = this.getNodeParameter('chunkOverlap', itemIndex) as number; diff --git a/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterTokenSplitter/TextSplitterTokenSplitter.node.ts b/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterTokenSplitter/TextSplitterTokenSplitter.node.ts index 65cb7ea213..c021aa1df7 100644 --- a/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterTokenSplitter/TextSplitterTokenSplitter.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/text_splitters/TextSplitterTokenSplitter/TextSplitterTokenSplitter.node.ts @@ -57,7 +57,7 @@ export class TextSplitterTokenSplitter implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply Data for Text Splitter'); + this.logger.debug('Supply Data for Text Splitter'); const chunkSize = this.getNodeParameter('chunkSize', itemIndex) as number; const chunkOverlap = this.getNodeParameter('chunkOverlap', itemIndex) as number; diff --git a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStorePineconeInsert/VectorStorePineconeInsert.node.ts b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStorePineconeInsert/VectorStorePineconeInsert.node.ts index 93e3e4d041..023b65be84 100644 --- a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStorePineconeInsert/VectorStorePineconeInsert.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStorePineconeInsert/VectorStorePineconeInsert.node.ts @@ -97,7 +97,7 @@ export class VectorStorePineconeInsert implements INodeType { async execute(this: IExecuteFunctions): Promise { const items = this.getInputData(0); - this.logger.verbose('Executing data for Pinecone Insert Vector Store'); + this.logger.debug('Executing data for Pinecone Insert Vector Store'); const namespace = this.getNodeParameter('pineconeNamespace', 0) as string; const index = this.getNodeParameter('pineconeIndex', 0, '', { extractValue: true }) as string; diff --git a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStorePineconeLoad/VectorStorePineconeLoad.node.ts b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStorePineconeLoad/VectorStorePineconeLoad.node.ts index c4ac6e3754..7cae9c9d85 100644 --- a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStorePineconeLoad/VectorStorePineconeLoad.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStorePineconeLoad/VectorStorePineconeLoad.node.ts @@ -85,7 +85,7 @@ export class VectorStorePineconeLoad implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supplying data for Pinecone Load Vector Store'); + this.logger.debug('Supplying data for Pinecone Load Vector Store'); const namespace = this.getNodeParameter('pineconeNamespace', itemIndex) as string; const index = this.getNodeParameter('pineconeIndex', itemIndex, '', { diff --git a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreSupabaseInsert/VectorStoreSupabaseInsert.node.ts b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreSupabaseInsert/VectorStoreSupabaseInsert.node.ts index 1eae86971a..44b3a6a397 100644 --- a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreSupabaseInsert/VectorStoreSupabaseInsert.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreSupabaseInsert/VectorStoreSupabaseInsert.node.ts @@ -94,7 +94,7 @@ export class VectorStoreSupabaseInsert implements INodeType { methods = { listSearch: { supabaseTableNameSearch } }; async execute(this: IExecuteFunctions): Promise { - this.logger.verbose('Executing data for Supabase Insert Vector Store'); + this.logger.debug('Executing data for Supabase Insert Vector Store'); const items = this.getInputData(0); const tableName = this.getNodeParameter('tableName', 0, '', { extractValue: true }) as string; diff --git a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreSupabaseLoad/VectorStoreSupabaseLoad.node.ts b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreSupabaseLoad/VectorStoreSupabaseLoad.node.ts index 267277b36e..bae6d0e1a9 100644 --- a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreSupabaseLoad/VectorStoreSupabaseLoad.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreSupabaseLoad/VectorStoreSupabaseLoad.node.ts @@ -82,7 +82,7 @@ export class VectorStoreSupabaseLoad implements INodeType { methods = { listSearch: { supabaseTableNameSearch } }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supply Supabase Load Vector Store'); + this.logger.debug('Supply Supabase Load Vector Store'); const tableName = this.getNodeParameter('tableName', itemIndex, '', { extractValue: true, diff --git a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreZepInsert/VectorStoreZepInsert.node.ts b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreZepInsert/VectorStoreZepInsert.node.ts index 71349b586b..3b40e07d65 100644 --- a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreZepInsert/VectorStoreZepInsert.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreZepInsert/VectorStoreZepInsert.node.ts @@ -101,7 +101,7 @@ export class VectorStoreZepInsert implements INodeType { }; async execute(this: IExecuteFunctions): Promise { - this.logger.verbose('Executing data for Zep Insert Vector Store'); + this.logger.debug('Executing data for Zep Insert Vector Store'); const items = this.getInputData(0); const collectionName = this.getNodeParameter('collectionName', 0) as string; const options = diff --git a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreZepLoad/VectorStoreZepLoad.node.ts b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreZepLoad/VectorStoreZepLoad.node.ts index ca5a743c15..244c0a9843 100644 --- a/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreZepLoad/VectorStoreZepLoad.node.ts +++ b/packages/@n8n/nodes-langchain/nodes/vector_store/VectorStoreZepLoad/VectorStoreZepLoad.node.ts @@ -84,7 +84,7 @@ export class VectorStoreZepLoad implements INodeType { }; async supplyData(this: IExecuteFunctions, itemIndex: number): Promise { - this.logger.verbose('Supplying data for Zep Load Vector Store'); + this.logger.debug('Supplying data for Zep Load Vector Store'); const collectionName = this.getNodeParameter('collectionName', itemIndex) as string; diff --git a/packages/cli/src/active-workflow-manager.ts b/packages/cli/src/active-workflow-manager.ts index 96df401950..358d2b514f 100644 --- a/packages/cli/src/active-workflow-manager.ts +++ b/packages/cli/src/active-workflow-manager.ts @@ -95,7 +95,7 @@ export class ActiveWorkflowManager { */ async removeAll() { let activeWorkflowIds: string[] = []; - this.logger.verbose('Call to remove all active workflows received (removeAll)'); + this.logger.debug('Call to remove all active workflows received (removeAll)'); activeWorkflowIds.push(...this.activeWorkflows.allActiveWorkflows()); @@ -437,7 +437,7 @@ export class ActiveWorkflowManager { }); if (wasActivated) { - this.logger.verbose(`Successfully started workflow ${dbWorkflow.display()}`, { + this.logger.debug(`Successfully started workflow ${dbWorkflow.display()}`, { workflowName: dbWorkflow.name, workflowId: dbWorkflow.id, }); @@ -469,7 +469,7 @@ export class ActiveWorkflowManager { } } - this.logger.verbose('Finished activating workflows (startup)'); + this.logger.debug('Finished activating workflows (startup)'); } async clearAllActivationErrors() { @@ -800,7 +800,7 @@ export class ActiveWorkflowManager { getPollFunctions, ); - this.logger.verbose(`Workflow ${dbWorkflow.display()} activated`, { + this.logger.debug(`Workflow ${dbWorkflow.display()} activated`, { workflowId: dbWorkflow.id, workflowName: dbWorkflow.name, }); diff --git a/packages/cli/src/controllers/oauth/oauth1-credential.controller.ts b/packages/cli/src/controllers/oauth/oauth1-credential.controller.ts index 8707fed7c3..5ec036a2aa 100644 --- a/packages/cli/src/controllers/oauth/oauth1-credential.controller.ts +++ b/packages/cli/src/controllers/oauth/oauth1-credential.controller.ts @@ -90,7 +90,7 @@ export class OAuth1CredentialController extends AbstractOAuthController { decryptedDataOriginal.csrfSecret = csrfSecret; await this.encryptAndSaveData(credential, decryptedDataOriginal); - this.logger.verbose('OAuth1 authorization successful for new credential', { + this.logger.debug('OAuth1 authorization successful for new credential', { userId: req.user.id, credentialId: credential.id, }); @@ -170,7 +170,7 @@ export class OAuth1CredentialController extends AbstractOAuthController { await this.encryptAndSaveData(credential, decryptedDataOriginal); - this.logger.verbose('OAuth1 callback successful for new credential', { + this.logger.debug('OAuth1 callback successful for new credential', { credentialId, }); return res.render('oauth-callback'); diff --git a/packages/cli/src/controllers/oauth/oauth2-credential.controller.ts b/packages/cli/src/controllers/oauth/oauth2-credential.controller.ts index 3ef4860a6f..5e2d3a0fb2 100644 --- a/packages/cli/src/controllers/oauth/oauth2-credential.controller.ts +++ b/packages/cli/src/controllers/oauth/oauth2-credential.controller.ts @@ -71,7 +71,7 @@ export class OAuth2CredentialController extends AbstractOAuthController { const oAuthObj = new ClientOAuth2(oAuthOptions); const returnUri = oAuthObj.code.getUri(); - this.logger.verbose('OAuth2 authorization url created for credential', { + this.logger.debug('OAuth2 authorization url created for credential', { userId: req.user.id, credentialId: credential.id, }); @@ -172,7 +172,7 @@ export class OAuth2CredentialController extends AbstractOAuthController { delete decryptedDataOriginal.csrfSecret; await this.encryptAndSaveData(credential, decryptedDataOriginal); - this.logger.verbose('OAuth2 callback successful for credential', { + this.logger.debug('OAuth2 callback successful for credential', { credentialId, }); diff --git a/packages/cli/src/controllers/workflow-statistics.controller.ts b/packages/cli/src/controllers/workflow-statistics.controller.ts index 623a1efe1d..6026b68bb5 100644 --- a/packages/cli/src/controllers/workflow-statistics.controller.ts +++ b/packages/cli/src/controllers/workflow-statistics.controller.ts @@ -40,7 +40,7 @@ export class WorkflowStatisticsController { if (workflow) { next(); } else { - this.logger.verbose('User attempted to read a workflow without permissions', { + this.logger.warn('User attempted to read a workflow without permissions', { workflowId, userId: user.id, }); diff --git a/packages/cli/src/credentials/credentials.controller.ts b/packages/cli/src/credentials/credentials.controller.ts index 636d804b75..eabeb39a48 100644 --- a/packages/cli/src/credentials/credentials.controller.ts +++ b/packages/cli/src/credentials/credentials.controller.ts @@ -218,7 +218,7 @@ export class CredentialsController { // Remove the encrypted data as it is not needed in the frontend const { data: _, ...rest } = responseData; - this.logger.verbose('Credential updated', { credentialId }); + this.logger.debug('Credential updated', { credentialId }); this.eventService.emit('credentials-updated', { user: req.user, diff --git a/packages/cli/src/credentials/credentials.service.ts b/packages/cli/src/credentials/credentials.service.ts index 72a6ddd91c..e9a88a9153 100644 --- a/packages/cli/src/credentials/credentials.service.ts +++ b/packages/cli/src/credentials/credentials.service.ts @@ -388,7 +388,7 @@ export class CredentialsService { return savedCredential; }); - this.logger.verbose('New credential created', { + this.logger.debug('New credential created', { credentialId: newCredential.id, ownerId: user.id, }); diff --git a/packages/cli/src/logger.ts b/packages/cli/src/logger.ts index dc23a6f347..4e105b3304 100644 --- a/packages/cli/src/logger.ts +++ b/packages/cli/src/logger.ts @@ -36,7 +36,7 @@ export class Logger { if (output.includes('console')) { let format: winston.Logform.Format; - if (['debug', 'verbose'].includes(level)) { + if (level === 'debug') { format = winston.format.combine( winston.format.metadata(), winston.format.timestamp(), @@ -115,8 +115,4 @@ export class Logger { debug(message: string, meta: object = {}): void { this.log('debug', message, meta); } - - verbose(message: string, meta: object = {}): void { - this.log('verbose', message, meta); - } } diff --git a/packages/cli/src/services/activeWorkflows.service.ts b/packages/cli/src/services/activeWorkflows.service.ts index b4312c16b3..e65ec1e434 100644 --- a/packages/cli/src/services/activeWorkflows.service.ts +++ b/packages/cli/src/services/activeWorkflows.service.ts @@ -41,7 +41,7 @@ export class ActiveWorkflowsService { 'workflow:read', ]); if (!workflow) { - this.logger.verbose('User attempted to access workflow errors without permissions', { + this.logger.warn('User attempted to access workflow errors without permissions', { workflowId, userId: user.id, }); diff --git a/packages/cli/src/services/workflow-statistics.service.ts b/packages/cli/src/services/workflow-statistics.service.ts index 4c9e23a578..37da22d757 100644 --- a/packages/cli/src/services/workflow-statistics.service.ts +++ b/packages/cli/src/services/workflow-statistics.service.ts @@ -90,7 +90,7 @@ export class WorkflowStatisticsService extends TypedEmitter node.type === errorTriggerType) ) { - logger.verbose('Start internal error workflow', { executionId, workflowId }); + logger.debug('Start internal error workflow', { executionId, workflowId }); void Container.get(OwnershipService) .getWorkflowProjectCached(workflowId) .then((project) => { diff --git a/packages/cli/src/workflow-runner.ts b/packages/cli/src/workflow-runner.ts index 4590bb5c3b..77c57397c7 100644 --- a/packages/cli/src/workflow-runner.ts +++ b/packages/cli/src/workflow-runner.ts @@ -238,7 +238,7 @@ export class WorkflowRunner { additionalData.executionId = executionId; - this.logger.verbose( + this.logger.debug( `Execution for workflow ${data.workflowData.name} was assigned id ${executionId}`, { executionId }, ); diff --git a/packages/cli/src/workflows/workflow.service.ee.ts b/packages/cli/src/workflows/workflow.service.ee.ts index be3ba3bca6..560942064a 100644 --- a/packages/cli/src/workflows/workflow.service.ee.ts +++ b/packages/cli/src/workflows/workflow.service.ee.ts @@ -194,7 +194,7 @@ export class EnterpriseWorkflowService { nodesWithCredentialsUserDoesNotHaveAccessTo.forEach((node) => { if (isTamperingAttempt(node.id)) { - this.logger.verbose('Blocked workflow update due to tampering attempt', { + this.logger.warn('Blocked workflow update due to tampering attempt', { nodeType: node.type, nodeName: node.name, nodeId: node.id, diff --git a/packages/cli/src/workflows/workflow.service.ts b/packages/cli/src/workflows/workflow.service.ts index 46f6438f9b..25943725ab 100644 --- a/packages/cli/src/workflows/workflow.service.ts +++ b/packages/cli/src/workflows/workflow.service.ts @@ -96,7 +96,7 @@ export class WorkflowService { ]); if (!workflow) { - this.logger.verbose('User attempted to update a workflow without permissions', { + this.logger.warn('User attempted to update a workflow without permissions', { workflowId, userId: user.id, }); @@ -120,7 +120,7 @@ export class WorkflowService { // Update the workflow's version when changing properties such as // `name`, `pinData`, `nodes`, `connections`, `settings` or `tags` workflowUpdateData.versionId = uuid(); - this.logger.verbose( + this.logger.debug( `Updating versionId for workflow ${workflowId} for user ${user.id} after saving`, { previousVersionId: workflow.versionId, diff --git a/packages/cli/src/workflows/workflows.controller.ts b/packages/cli/src/workflows/workflows.controller.ts index b3917e9633..deeecba045 100644 --- a/packages/cli/src/workflows/workflows.controller.ts +++ b/packages/cli/src/workflows/workflows.controller.ts @@ -309,7 +309,7 @@ export class WorkflowsController { ); if (!workflow) { - this.logger.verbose('User attempted to access a workflow without permissions', { + this.logger.warn('User attempted to access a workflow without permissions', { workflowId, userId: req.user.id, }); @@ -362,7 +362,7 @@ export class WorkflowsController { const workflow = await this.workflowService.delete(req.user, workflowId); if (!workflow) { - this.logger.verbose('User attempted to delete a workflow without permissions', { + this.logger.warn('User attempted to delete a workflow without permissions', { workflowId, userId: req.user.id, }); diff --git a/packages/core/src/NodeExecuteFunctions.ts b/packages/core/src/NodeExecuteFunctions.ts index 81d5a09f5f..e1f39c22ab 100644 --- a/packages/core/src/NodeExecuteFunctions.ts +++ b/packages/core/src/NodeExecuteFunctions.ts @@ -1954,7 +1954,7 @@ export function getAdditionalKeys( if (mode === 'manual') { throw e; } - Logger.verbose(e.message); + Logger.debug(e.message); } }, setAll(obj: Record): void { @@ -1964,7 +1964,7 @@ export function getAdditionalKeys( if (mode === 'manual') { throw e; } - Logger.verbose(e.message); + Logger.debug(e.message); } }, get(key: string): string { diff --git a/packages/core/src/WorkflowExecute.ts b/packages/core/src/WorkflowExecute.ts index 303b46b20a..24e4de3395 100644 --- a/packages/core/src/WorkflowExecute.ts +++ b/packages/core/src/WorkflowExecute.ts @@ -794,7 +794,7 @@ export class WorkflowExecute { // active executions anymore // eslint-disable-next-line @typescript-eslint/promise-function-async processRunExecutionData(workflow: Workflow): PCancelable { - Logger.verbose('Workflow execution started', { workflowId: workflow.id }); + Logger.debug('Workflow execution started', { workflowId: workflow.id }); const startedAt = new Date(); const forceInputNodeExecution = this.forceInputNodeExecution(workflow); @@ -1804,7 +1804,7 @@ export class WorkflowExecute { const fullRunData = this.getFullRunData(startedAt); if (executionError !== undefined) { - Logger.verbose('Workflow execution finished with error', { + Logger.debug('Workflow execution finished with error', { error: executionError, workflowId: workflow.id, }); @@ -1818,13 +1818,13 @@ export class WorkflowExecute { } } else if (this.runExecutionData.waitTill!) { // eslint-disable-next-line @typescript-eslint/restrict-template-expressions - Logger.verbose(`Workflow execution will wait until ${this.runExecutionData.waitTill}`, { + Logger.debug(`Workflow execution will wait until ${this.runExecutionData.waitTill}`, { workflowId: workflow.id, }); fullRunData.waitTill = this.runExecutionData.waitTill; fullRunData.status = 'waiting'; } else { - Logger.verbose('Workflow execution finished successfully', { workflowId: workflow.id }); + Logger.debug('Workflow execution finished successfully', { workflowId: workflow.id }); fullRunData.finished = true; fullRunData.status = 'success'; } diff --git a/packages/nodes-base/nodes/EmailReadImap/v1/EmailReadImapV1.node.ts b/packages/nodes-base/nodes/EmailReadImap/v1/EmailReadImapV1.node.ts index ae26d59caa..923ffe5832 100644 --- a/packages/nodes-base/nodes/EmailReadImap/v1/EmailReadImapV1.node.ts +++ b/packages/nodes-base/nodes/EmailReadImap/v1/EmailReadImapV1.node.ts @@ -589,7 +589,7 @@ export class EmailReadImapV1 implements INodeType { conn.on('error', async (error) => { const errorCode = error.code.toUpperCase(); if (['ECONNRESET', 'EPIPE'].includes(errorCode as string)) { - this.logger.verbose(`IMAP connection was reset (${errorCode}) - reconnecting.`, { + this.logger.debug(`IMAP connection was reset (${errorCode}) - reconnecting.`, { error, }); try { @@ -618,7 +618,7 @@ export class EmailReadImapV1 implements INodeType { if (options.forceReconnect !== undefined) { reconnectionInterval = setInterval( async () => { - this.logger.verbose('Forcing reconnection of IMAP node.'); + this.logger.debug('Forcing reconnection of IMAP node.'); connection.end(); connection = await establishConnection(); await connection.openBox(mailbox); diff --git a/packages/nodes-base/nodes/EmailReadImap/v2/EmailReadImapV2.node.ts b/packages/nodes-base/nodes/EmailReadImap/v2/EmailReadImapV2.node.ts index 5f46f63ce0..b3796263a7 100644 --- a/packages/nodes-base/nodes/EmailReadImap/v2/EmailReadImapV2.node.ts +++ b/packages/nodes-base/nodes/EmailReadImap/v2/EmailReadImapV2.node.ts @@ -598,7 +598,7 @@ export class EmailReadImapV2 implements INodeType { } }, onUpdate: async (seqNo: number, info) => { - this.logger.verbose(`Email Read Imap:update ${seqNo}`, info); + this.logger.debug(`Email Read Imap:update ${seqNo}`, info); }, }; @@ -631,7 +631,7 @@ export class EmailReadImapV2 implements INodeType { }); conn.on('error', async (error) => { const errorCode = ((error as JsonObject).code as string).toUpperCase(); - this.logger.verbose(`IMAP connection experienced an error: (${errorCode})`, { + this.logger.debug(`IMAP connection experienced an error: (${errorCode})`, { error: error as Error, }); this.emitError(error as Error); @@ -647,7 +647,7 @@ export class EmailReadImapV2 implements INodeType { let reconnectionInterval: NodeJS.Timeout | undefined; const handleReconnect = async () => { - this.logger.verbose('Forcing reconnect to IMAP server'); + this.logger.debug('Forcing reconnect to IMAP server'); try { isCurrentlyReconnecting = true; if (connection.closeBox) await connection.closeBox(false); diff --git a/packages/workflow/src/Constants.ts b/packages/workflow/src/Constants.ts index 48bd06e521..e55ad9fc77 100644 --- a/packages/workflow/src/Constants.ts +++ b/packages/workflow/src/Constants.ts @@ -8,7 +8,7 @@ export const ALPHABET = [DIGITS, UPPERCASE_LETTERS, LOWERCASE_LETTERS].join(''); export const BINARY_ENCODING = 'base64'; export const WAIT_TIME_UNLIMITED = '3000-01-01T00:00:00.000Z'; -export const LOG_LEVELS = ['silent', 'error', 'warn', 'info', 'debug', 'verbose'] as const; +export const LOG_LEVELS = ['silent', 'error', 'warn', 'info', 'debug'] as const; export const CODE_LANGUAGES = ['javaScript', 'python'] as const; export const CODE_EXECUTION_MODES = ['runOnceForAllItems', 'runOnceForEachItem'] as const; diff --git a/packages/workflow/src/LoggerProxy.ts b/packages/workflow/src/LoggerProxy.ts index cd6f1b1cb9..eebfd036b4 100644 --- a/packages/workflow/src/LoggerProxy.ts +++ b/packages/workflow/src/LoggerProxy.ts @@ -5,12 +5,10 @@ export let error: Logger['error'] = noOp; export let warn: Logger['warn'] = noOp; export let info: Logger['info'] = noOp; export let debug: Logger['debug'] = noOp; -export let verbose: Logger['verbose'] = noOp; export const init = (logger: Logger) => { error = (message, meta) => logger.error(message, meta); warn = (message, meta) => logger.warn(message, meta); info = (message, meta) => logger.info(message, meta); debug = (message, meta) => logger.debug(message, meta); - verbose = (message, meta) => logger.verbose(message, meta); };