/* eslint-disable n8n-nodes-base/node-filename-against-convention */ import { IExecuteFunctions } from 'n8n-core'; import { IDataObject, ILoadOptionsFunctions, INodeExecutionData, INodePropertyOptions, INodeType, INodeTypeDescription, NodeOperationError, } from 'n8n-workflow'; import { documentFields, documentOperations } from './DocumentDescription'; import { erpNextApiRequest, erpNextApiRequestAllItems } from './GenericFunctions'; import { DocumentProperties, processNames, toSQL } from './utils'; export class ERPNext implements INodeType { description: INodeTypeDescription = { displayName: 'ERPNext', name: 'erpNext', icon: 'file:erpnext.svg', group: ['output'], version: 1, subtitle: '={{$parameter["resource"] + ": " + $parameter["operation"]}}', description: 'Consume ERPNext API', defaults: { name: 'ERPNext', }, inputs: ['main'], outputs: ['main'], credentials: [ { name: 'erpNextApi', required: true, }, ], properties: [ { displayName: 'Resource', name: 'resource', type: 'options', noDataExpression: true, options: [ { name: 'Document', value: 'document', }, ], default: 'document', }, ...documentOperations, ...documentFields, ], }; methods = { loadOptions: { async getDocTypes(this: ILoadOptionsFunctions): Promise { const data = await erpNextApiRequestAllItems.call( this, 'data', 'GET', '/api/resource/DocType', {}, ); const docTypes = data.map(({ name }: { name: string }) => { return { name, value: encodeURI(name) }; }); return processNames(docTypes); }, async getDocFilters(this: ILoadOptionsFunctions): Promise { const docType = this.getCurrentNodeParameter('docType') as string; const { data } = await erpNextApiRequest.call( this, 'GET', `/api/resource/DocType/${docType}`, {}, ); const docFields = data.fields.map( ({ label, fieldname }: { label: string; fieldname: string }) => { return { name: label, value: fieldname }; }, ); docFields.unshift({ name: '*', value: '*' }); return processNames(docFields); }, async getDocFields(this: ILoadOptionsFunctions): Promise { const docType = this.getCurrentNodeParameter('docType') as string; const { data } = await erpNextApiRequest.call( this, 'GET', `/api/resource/DocType/${docType}`, {}, ); const docFields = data.fields.map( ({ label, fieldname }: { label: string; fieldname: string }) => { return { name: label, value: fieldname }; }, ); return processNames(docFields); }, }, }; async execute(this: IExecuteFunctions): Promise { const items = this.getInputData(); const returnData: INodeExecutionData[] = []; let responseData; const body: IDataObject = {}; const qs: IDataObject = {}; const resource = this.getNodeParameter('resource', 0) as string; const operation = this.getNodeParameter('operation', 0) as string; for (let i = 0; i < items.length; i++) { // https://app.swaggerhub.com/apis-docs/alyf.de/ERPNext/11#/Resources/post_api_resource_Webhook // https://frappeframework.com/docs/user/en/guides/integration/rest_api/manipulating_documents if (resource === 'document') { // ********************************************************************* // document // ********************************************************************* if (operation === 'get') { // ---------------------------------- // document: get // ---------------------------------- // https://app.swaggerhub.com/apis-docs/alyf.de/ERPNext/11#/General/get_api_resource__DocType___DocumentName_ const docType = this.getNodeParameter('docType', i) as string; const documentName = this.getNodeParameter('documentName', i) as string; responseData = await erpNextApiRequest.call( this, 'GET', `/api/resource/${docType}/${documentName}`, ); responseData = responseData.data; } if (operation === 'getAll') { // ---------------------------------- // document: getAll // ---------------------------------- // https://app.swaggerhub.com/apis-docs/alyf.de/ERPNext/11#/General/get_api_resource__DocType_ const docType = this.getNodeParameter('docType', i) as string; const endpoint = `/api/resource/${docType}`; const { fields, filters } = this.getNodeParameter('options', i) as { fields: string[]; filters: { customProperty: Array<{ field: string; operator: string; value: string }>; }; }; // fields=["test", "example", "hi"] if (fields) { if (fields.includes('*')) { qs.fields = JSON.stringify(['*']); } else { qs.fields = JSON.stringify(fields); } } // filters=[["Person","first_name","=","Jane"]] // TODO: filters not working if (filters) { qs.filters = JSON.stringify( filters.customProperty.map((filter) => { return [docType, filter.field, toSQL(filter.operator), filter.value]; }), ); } const returnAll = this.getNodeParameter('returnAll', i); if (!returnAll) { const limit = this.getNodeParameter('limit', i); qs.limit_page_length = limit; qs.limit_start = 0; responseData = await erpNextApiRequest.call(this, 'GET', endpoint, {}, qs); responseData = responseData.data; } else { responseData = await erpNextApiRequestAllItems.call( this, 'data', 'GET', endpoint, {}, qs, ); } } else if (operation === 'create') { // ---------------------------------- // document: create // ---------------------------------- // https://app.swaggerhub.com/apis-docs/alyf.de/ERPNext/11#/General/post_api_resource__DocType_ const properties = this.getNodeParameter('properties', i) as DocumentProperties; if (!properties.customProperty.length) { throw new NodeOperationError( this.getNode(), 'Please enter at least one property for the document to create.', { itemIndex: i }, ); } properties.customProperty.forEach((property) => { body[property.field] = property.value; }); const docType = this.getNodeParameter('docType', i) as string; responseData = await erpNextApiRequest.call( this, 'POST', `/api/resource/${docType}`, body, ); responseData = responseData.data; } else if (operation === 'delete') { // ---------------------------------- // document: delete // ---------------------------------- // https://app.swaggerhub.com/apis-docs/alyf.de/ERPNext/11#/General/delete_api_resource__DocType___DocumentName_ const docType = this.getNodeParameter('docType', i) as string; const documentName = this.getNodeParameter('documentName', i) as string; responseData = await erpNextApiRequest.call( this, 'DELETE', `/api/resource/${docType}/${documentName}`, ); } else if (operation === 'update') { // ---------------------------------- // document: update // ---------------------------------- // https://app.swaggerhub.com/apis-docs/alyf.de/ERPNext/11#/General/put_api_resource__DocType___DocumentName_ const properties = this.getNodeParameter('properties', i) as DocumentProperties; if (!properties.customProperty.length) { throw new NodeOperationError( this.getNode(), 'Please enter at least one property for the document to update.', { itemIndex: i }, ); } properties.customProperty.forEach((property) => { body[property.field] = property.value; }); const docType = this.getNodeParameter('docType', i) as string; const documentName = this.getNodeParameter('documentName', i) as string; responseData = await erpNextApiRequest.call( this, 'PUT', `/api/resource/${docType}/${documentName}`, body, ); responseData = responseData.data; } } const executionData = this.helpers.constructExecutionMetaData( this.helpers.returnJsonArray(responseData), { itemData: { item: i } }, ); returnData.push(...executionData); } return this.prepareOutputData(returnData); } }