mirror of
https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git
synced 2025-12-17 18:12:04 +00:00
✨ Add Microsoft Dynamics CRM Node (#2292)
* ✨ Microsoft Dynamics CRM * ⚡ Improvements * ⚡ Improvements * ⚡ Minor improvements Co-authored-by: Jan Oberhauser <jan.oberhauser@gmail.com>
This commit is contained in:
Ricardo Espinoza
@@ -0,0 +1,249 @@
|
||||
import {
|
||||
IExecuteFunctions,
|
||||
} from 'n8n-core';
|
||||
|
||||
import {
|
||||
IDataObject,
|
||||
ILoadOptionsFunctions,
|
||||
INodeExecutionData,
|
||||
INodePropertyOptions,
|
||||
INodeType,
|
||||
INodeTypeDescription,
|
||||
} from 'n8n-workflow';
|
||||
|
||||
import {
|
||||
adjustAddresses,
|
||||
getEntityFields,
|
||||
getPicklistOptions,
|
||||
IField,
|
||||
microsoftApiRequest,
|
||||
microsoftApiRequestAllItems,
|
||||
sort,
|
||||
} from './GenericFunctions';
|
||||
|
||||
import {
|
||||
accountFields,
|
||||
accountOperations,
|
||||
} from './descriptions';
|
||||
|
||||
export class MicrosoftDynamicsCrm implements INodeType {
|
||||
description: INodeTypeDescription = {
|
||||
displayName: 'Microsoft Dynamics CRM',
|
||||
name: 'microsoftDynamicsCrm',
|
||||
icon: 'file:dynamicsCrm.svg',
|
||||
group: ['input'],
|
||||
version: 1,
|
||||
subtitle: '={{$parameter["operation"] + ": " + $parameter["resource"]}}',
|
||||
description: 'Consume Microsoft Dynamics CRM API',
|
||||
defaults: {
|
||||
name: 'Microsoft Dynamics CRM',
|
||||
color: '#000000',
|
||||
},
|
||||
inputs: ['main'],
|
||||
outputs: ['main'],
|
||||
credentials: [
|
||||
{
|
||||
name: 'microsoftDynamicsOAuth2Api',
|
||||
required: true,
|
||||
},
|
||||
],
|
||||
properties: [
|
||||
{
|
||||
displayName: 'Resource',
|
||||
name: 'resource',
|
||||
type: 'options',
|
||||
options: [
|
||||
{
|
||||
name: 'Account',
|
||||
value: 'account',
|
||||
},
|
||||
],
|
||||
default: 'account',
|
||||
description: 'The resource to operate on',
|
||||
},
|
||||
...accountOperations,
|
||||
...accountFields,
|
||||
],
|
||||
};
|
||||
|
||||
methods = {
|
||||
loadOptions: {
|
||||
async getAccountCategories(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'accountcategorycode');
|
||||
},
|
||||
async getAccountRatingCodes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'accountratingcode');
|
||||
},
|
||||
async getAddressTypes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'address1_addresstypecode');
|
||||
},
|
||||
async getBusinessTypes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'businesstypecode');
|
||||
},
|
||||
async getCustomerSizeCodes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'customersizecode');
|
||||
},
|
||||
async getCustomerTypeCodes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'customertypecode');
|
||||
},
|
||||
async getIndustryCodes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'industrycode');
|
||||
},
|
||||
async getPaymentTermsCodes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'paymenttermscode');
|
||||
},
|
||||
async getPreferredAppointmentDayCodes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'preferredappointmentdaycode');
|
||||
},
|
||||
async getPreferredAppointmentTimeCodes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'preferredappointmenttimecode');
|
||||
},
|
||||
async getPreferredContactMethodCodes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'preferredcontactmethodcode');
|
||||
},
|
||||
async getShippingMethodCodes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'shippingmethodcode');
|
||||
},
|
||||
async getTerritoryCodes(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
return await getPicklistOptions.call(this, 'account', 'territorycode');
|
||||
},
|
||||
async getAccountFields(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
const fields = await getEntityFields.call(this, 'account');
|
||||
const isSelectable = (field: IField) => (field.IsValidForRead && field.CanBeSecuredForRead && field.IsValidODataAttribute && field.LogicalName !== 'slaid');
|
||||
return fields.filter(isSelectable).filter(field => field.DisplayName.UserLocalizedLabel?.Label).map(field => ({ name: field.DisplayName.UserLocalizedLabel.Label, value: field.LogicalName })).sort(sort);
|
||||
},
|
||||
async getExpandableAccountFields(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
const fields = await getEntityFields.call(this, 'account');
|
||||
const isSelectable = (field: IField) => (field.IsValidForRead && field.CanBeSecuredForRead && field.IsValidODataAttribute && field.AttributeType === 'Lookup' && field.LogicalName !== 'slaid');
|
||||
return fields.filter(isSelectable).map(field => ({ name: field.DisplayName.UserLocalizedLabel.Label, value: field.LogicalName })).sort(sort);
|
||||
},
|
||||
},
|
||||
};
|
||||
|
||||
async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
|
||||
const items = this.getInputData();
|
||||
const returnData: IDataObject[] = [];
|
||||
const length = items.length as unknown as number;
|
||||
const qs: IDataObject = {};
|
||||
let responseData;
|
||||
const resource = this.getNodeParameter('resource', 0) as string;
|
||||
const operation = this.getNodeParameter('operation', 0) as string;
|
||||
|
||||
for (let i = 0; i < length; i++) {
|
||||
try {
|
||||
if (resource === 'account') {
|
||||
//https://docs.microsoft.com/en-us/powerapps/developer/data-platform/webapi/create-entity-web-api
|
||||
if (operation === 'create') {
|
||||
const name = this.getNodeParameter('name', i) as string;
|
||||
// tslint:disable-next-line: no-any
|
||||
const additionalFields = this.getNodeParameter('additionalFields', i) as { addresses: { address: [{ [key: string]: any }] } };
|
||||
const options = this.getNodeParameter('options', i) as { returnFields: string[] };
|
||||
|
||||
const body = {
|
||||
name,
|
||||
...additionalFields,
|
||||
};
|
||||
|
||||
if (body?.addresses?.address) {
|
||||
Object.assign(body, adjustAddresses(body.addresses.address));
|
||||
//@ts-ignore
|
||||
delete body?.addresses;
|
||||
}
|
||||
|
||||
if (options.returnFields) {
|
||||
options.returnFields.push('accountid');
|
||||
qs['$select'] = options.returnFields.join(',');
|
||||
} else {
|
||||
qs['$select'] = 'accountid';
|
||||
}
|
||||
|
||||
responseData = await microsoftApiRequest.call(this, 'POST', `/accounts`, body, qs);
|
||||
}
|
||||
|
||||
if (operation === 'delete') {
|
||||
//https://docs.microsoft.com/en-us/powerapps/developer/data-platform/webapi/update-delete-entities-using-web-api#basic-delete
|
||||
const accountId = this.getNodeParameter('accountId', i) as string;
|
||||
await microsoftApiRequest.call(this, 'DELETE', `/accounts(${accountId})`, {}, qs);
|
||||
responseData = { success: true };
|
||||
}
|
||||
|
||||
if (operation === 'get') {
|
||||
//https://docs.microsoft.com/en-us/powerapps/developer/data-platform/webapi/retrieve-entity-using-web-api
|
||||
const accountId = this.getNodeParameter('accountId', i) as string;
|
||||
const options = this.getNodeParameter('options', i) as IDataObject;
|
||||
if (options.returnFields) {
|
||||
qs['$select'] = (options.returnFields as string[]).join(',');
|
||||
}
|
||||
if (options.expandFields) {
|
||||
qs['$expand'] = (options.expandFields as string[]).join(',');
|
||||
}
|
||||
responseData = await microsoftApiRequest.call(this, 'GET', `/accounts(${accountId})`, {}, qs);
|
||||
}
|
||||
|
||||
if (operation === 'getAll') {
|
||||
//https://docs.microsoft.com/en-us/powerapps/developer/data-platform/webapi/query-data-web-api
|
||||
const returnAll = this.getNodeParameter('returnAll', i) as boolean;
|
||||
const options = this.getNodeParameter('options', i) as IDataObject;
|
||||
const filters = this.getNodeParameter('filters', i) as IDataObject;
|
||||
if (options.returnFields) {
|
||||
qs['$select'] = (options.returnFields as string[]).join(',');
|
||||
}
|
||||
if (options.expandFields) {
|
||||
qs['$expand'] = (options.expandFields as string[]).join(',');
|
||||
}
|
||||
if (filters.query) {
|
||||
qs['$filter'] = filters.query as string;
|
||||
}
|
||||
if (returnAll) {
|
||||
responseData = await microsoftApiRequestAllItems.call(this, 'value', 'GET', `/accounts`, {}, qs);
|
||||
} else {
|
||||
qs['$top'] = this.getNodeParameter('limit', 0) as number;
|
||||
responseData = await microsoftApiRequest.call(this, 'GET', `/accounts`, {}, qs);
|
||||
responseData = responseData.value;
|
||||
}
|
||||
}
|
||||
|
||||
if (operation === 'update') {
|
||||
const accountId = this.getNodeParameter('accountId', i) as string;
|
||||
// tslint:disable-next-line: no-any
|
||||
const updateFields = this.getNodeParameter('updateFields', i) as { addresses: { address: [{ [key: string]: any }] } };
|
||||
const options = this.getNodeParameter('options', i) as { returnFields: string[] };
|
||||
|
||||
const body = {
|
||||
...updateFields,
|
||||
};
|
||||
|
||||
if (body?.addresses?.address) {
|
||||
Object.assign(body, adjustAddresses(body.addresses.address));
|
||||
//@ts-ignore
|
||||
delete body?.addresses;
|
||||
}
|
||||
|
||||
if (options.returnFields) {
|
||||
options.returnFields.push('accountid');
|
||||
qs['$select'] = options.returnFields.join(',');
|
||||
} else {
|
||||
qs['$select'] = 'accountid';
|
||||
}
|
||||
|
||||
responseData = await microsoftApiRequest.call(this, 'PATCH', `/accounts(${accountId})`, body, qs);
|
||||
}
|
||||
}
|
||||
|
||||
if (Array.isArray(responseData)) {
|
||||
returnData.push(...responseData);
|
||||
} else {
|
||||
returnData.push(responseData as IDataObject);
|
||||
}
|
||||
} catch (error) {
|
||||
if (this.continueOnFail()) {
|
||||
returnData.push({ error: error.message });
|
||||
continue;
|
||||
}
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
return [this.helpers.returnJsonArray(returnData)];
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user