mirror of
https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git
synced 2025-12-17 18:12:04 +00:00
✨ Add ERPNext node (#1604)
* 🚧 Integrated with access token OAuth2 still needs work * 🚧 Removed OAuth2 for now * ⚡ Improvements * ⚡ Improvements * ⚡ Refactor ERPNext node * 🔥 Remove PNG icon * 🔥 Remove leftover comments * 🔨 Catch unavailable resource error * ⚡ Reposition docType for filters * ⚡ Improvements * ⚡ Cleanup Co-authored-by: Rupenieks <ronaldsupenieks96@gmail.com> Co-authored-by: ricardo <ricardoespinoza105@gmail.com> Co-authored-by: Jan Oberhauser <jan.oberhauser@gmail.com>
This commit is contained in:
Iván Ovejero
268
packages/nodes-base/nodes/ERPNext/ERPNext.node.ts
Normal file
268
packages/nodes-base/nodes/ERPNext/ERPNext.node.ts
Normal file
@@ -0,0 +1,268 @@
|
||||
import {
|
||||
IExecuteFunctions,
|
||||
} from 'n8n-core';
|
||||
|
||||
import {
|
||||
IDataObject,
|
||||
ILoadOptionsFunctions,
|
||||
INodeExecutionData,
|
||||
INodePropertyOptions,
|
||||
INodeType,
|
||||
INodeTypeDescription,
|
||||
} 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',
|
||||
color: '#7574ff',
|
||||
},
|
||||
inputs: ['main'],
|
||||
outputs: ['main'],
|
||||
credentials: [
|
||||
{
|
||||
name: 'erpNextApi',
|
||||
required: true,
|
||||
},
|
||||
],
|
||||
properties: [
|
||||
{
|
||||
displayName: 'Resource',
|
||||
name: 'resource',
|
||||
type: 'options',
|
||||
options: [
|
||||
{
|
||||
name: 'Document',
|
||||
value: 'document',
|
||||
},
|
||||
],
|
||||
default: 'document',
|
||||
description: 'Resource to consume.',
|
||||
},
|
||||
...documentOperations,
|
||||
...documentFields,
|
||||
],
|
||||
};
|
||||
|
||||
methods = {
|
||||
loadOptions: {
|
||||
async getDocTypes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
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<INodePropertyOptions[]> {
|
||||
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<INodePropertyOptions[]> {
|
||||
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<INodeExecutionData[][]> {
|
||||
const items = this.getInputData();
|
||||
|
||||
const returnData: IDataObject[] = [];
|
||||
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) as boolean;
|
||||
|
||||
if (!returnAll) {
|
||||
const limit = this.getNodeParameter('limit', i) as number;
|
||||
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 Error('Please enter at least one property for the document to create.');
|
||||
}
|
||||
|
||||
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 Error('Please enter at least one property for the document to update.');
|
||||
}
|
||||
|
||||
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;
|
||||
|
||||
}
|
||||
}
|
||||
|
||||
Array.isArray(responseData)
|
||||
? returnData.push(...responseData)
|
||||
: returnData.push(responseData);
|
||||
|
||||
}
|
||||
return [this.helpers.returnJsonArray(returnData)];
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user