/* eslint-disable n8n-nodes-base/node-dirname-against-convention */ import { NodeConnectionType, type IExecuteFunctions, type INodeType, type INodeTypeDescription, type SupplyData, } from 'n8n-workflow'; import type { TextSplitter } from 'langchain/text_splitter'; import { logWrapper } from '../../../utils/logWrapper'; import { N8nJsonLoader } from '../../../utils/N8nJsonLoader'; import { getConnectionHintNoticeField, metadataFilterField } from '../../../utils/sharedFields'; export class DocumentJsonInputLoader implements INodeType { description: INodeTypeDescription = { // This node is deprecated and will be removed in the future. // The functionality was merged with the `DocumentBinaryInputLoader` to `DocumentDefaultDataLoader` hidden: true, displayName: 'JSON Input Loader', name: 'documentJsonInputLoader', icon: 'file:json.svg', group: ['transform'], version: 1, description: 'Use JSON data from a previous step in the workflow', defaults: { name: 'JSON Input Loader', }, codex: { categories: ['AI'], subcategories: { AI: ['Document Loaders'], }, resources: { primaryDocumentation: [ { url: 'https://docs.n8n.io/integrations/builtin/cluster-nodes/sub-nodes/n8n-nodes-langchain.documentdefaultdataloader/', }, ], }, }, // eslint-disable-next-line n8n-nodes-base/node-class-description-inputs-wrong-regular-node inputs: [ { displayName: 'Text Splitter', maxConnections: 1, type: NodeConnectionType.AiTextSplitter, }, ], inputNames: ['Text Splitter'], // eslint-disable-next-line n8n-nodes-base/node-class-description-outputs-wrong outputs: [NodeConnectionType.AiDocument], outputNames: ['Document'], properties: [ getConnectionHintNoticeField([NodeConnectionType.AiVectorStore]), { displayName: 'Pointers', name: 'pointers', type: 'string', default: '', description: 'Pointers to extract from JSON, e.g. "/text" or "/text, /meta/title"', }, { displayName: 'Options', name: 'options', type: 'collection', placeholder: 'Add Option', default: {}, options: [ { ...metadataFilterField, displayName: 'Metadata', description: 'Metadata to add to each document. Could be used for filtering during retrieval', placeholder: 'Add property', }, ], }, ], }; async supplyData(this: IExecuteFunctions): Promise { this.logger.verbose('Supply Data for JSON Input Loader'); const textSplitter = (await this.getInputConnectionData( NodeConnectionType.AiTextSplitter, 0, )) as TextSplitter | undefined; const processor = new N8nJsonLoader(this, undefined, textSplitter); return { response: logWrapper(processor, this), }; } }