mirror of
https://github.com/n8n-io/n8n.git
synced 2025-03-05 20:50:17 -08:00
feat(Freshworks CRM Node): Add Search + Lookup functionality (#3131)
* Add fields and Ops for Lookup Search * Adds Search (Search + Lookup) operations * 🔨 credentials update * 🔨 improvements * ⚡ clean up and linter fixes * ⚡ merged search and query, more hints * ⚡ Improvements * ⚡ Add generic type to authentication method Co-authored-by: Michael Kret <michael.k@radency.com> Co-authored-by: ricardo <ricardoespinoza105@gmail.com>
This commit is contained in:
parent
af45a07f21
commit
dbc02803db
|
@ -1,4 +1,6 @@
|
||||||
import {
|
import {
|
||||||
|
IAuthenticateGeneric,
|
||||||
|
ICredentialTestRequest,
|
||||||
ICredentialType,
|
ICredentialType,
|
||||||
INodeProperties,
|
INodeProperties,
|
||||||
} from 'n8n-workflow';
|
} from 'n8n-workflow';
|
||||||
|
@ -24,4 +26,19 @@ export class FreshworksCrmApi implements ICredentialType {
|
||||||
description: 'Domain in the Freshworks CRM org URL. For example, in <code>https://n8n-org.myfreshworks.com</code>, the domain is <code>n8n-org</code>.',
|
description: 'Domain in the Freshworks CRM org URL. For example, in <code>https://n8n-org.myfreshworks.com</code>, the domain is <code>n8n-org</code>.',
|
||||||
},
|
},
|
||||||
];
|
];
|
||||||
|
authenticate: IAuthenticateGeneric = {
|
||||||
|
type: 'generic',
|
||||||
|
properties: {
|
||||||
|
headers: {
|
||||||
|
'Authorization': '=Token token={{$credentials?.apiKey}}',
|
||||||
|
},
|
||||||
|
},
|
||||||
|
};
|
||||||
|
test: ICredentialTestRequest = {
|
||||||
|
request: {
|
||||||
|
baseURL: '=https://{{$credentials?.domain}}.myfreshworks.com/crm/sales/api',
|
||||||
|
url: '/tasks',
|
||||||
|
method: 'GET',
|
||||||
|
},
|
||||||
|
};
|
||||||
}
|
}
|
||||||
|
|
|
@ -34,6 +34,8 @@ import {
|
||||||
noteOperations,
|
noteOperations,
|
||||||
salesActivityFields,
|
salesActivityFields,
|
||||||
salesActivityOperations,
|
salesActivityOperations,
|
||||||
|
searchFields,
|
||||||
|
searchOperations,
|
||||||
taskFields,
|
taskFields,
|
||||||
taskOperations,
|
taskOperations,
|
||||||
} from './descriptions';
|
} from './descriptions';
|
||||||
|
@ -100,6 +102,10 @@ export class FreshworksCrm implements INodeType {
|
||||||
name: 'Sales Activity',
|
name: 'Sales Activity',
|
||||||
value: 'salesActivity',
|
value: 'salesActivity',
|
||||||
},
|
},
|
||||||
|
{
|
||||||
|
name: 'Search',
|
||||||
|
value: 'search',
|
||||||
|
},
|
||||||
{
|
{
|
||||||
name: 'Task',
|
name: 'Task',
|
||||||
value: 'task',
|
value: 'task',
|
||||||
|
@ -119,6 +125,8 @@ export class FreshworksCrm implements INodeType {
|
||||||
...noteFields,
|
...noteFields,
|
||||||
...salesActivityOperations,
|
...salesActivityOperations,
|
||||||
...salesActivityFields,
|
...salesActivityFields,
|
||||||
|
...searchOperations,
|
||||||
|
...searchFields,
|
||||||
...taskOperations,
|
...taskOperations,
|
||||||
...taskFields,
|
...taskFields,
|
||||||
],
|
],
|
||||||
|
@ -855,6 +863,58 @@ export class FreshworksCrm implements INodeType {
|
||||||
|
|
||||||
}
|
}
|
||||||
|
|
||||||
|
} else if (resource === 'search') {
|
||||||
|
|
||||||
|
// **********************************************************************
|
||||||
|
// search
|
||||||
|
// **********************************************************************
|
||||||
|
|
||||||
|
if (operation === 'query') {
|
||||||
|
// https://developers.freshworks.com/crm/api/#search
|
||||||
|
const query = this.getNodeParameter('query', i) as string;
|
||||||
|
let entities = this.getNodeParameter('entities', i);
|
||||||
|
const returnAll = this.getNodeParameter('returnAll', 0, false);
|
||||||
|
|
||||||
|
if (Array.isArray(entities)) {
|
||||||
|
entities = entities.join(',');
|
||||||
|
}
|
||||||
|
|
||||||
|
const qs: IDataObject = {
|
||||||
|
q: query,
|
||||||
|
include: entities,
|
||||||
|
per_page: 100,
|
||||||
|
};
|
||||||
|
|
||||||
|
responseData = await freshworksCrmApiRequest.call(this, 'GET', '/search', {}, qs);
|
||||||
|
|
||||||
|
if (!returnAll) {
|
||||||
|
const limit = this.getNodeParameter('limit', 0);
|
||||||
|
responseData = responseData.slice(0, limit);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
if (operation === 'lookup') {
|
||||||
|
// https://developers.freshworks.com/crm/api/#lookup_search
|
||||||
|
let searchField = this.getNodeParameter('searchField', i) as string;
|
||||||
|
let fieldValue = this.getNodeParameter('fieldValue', i, '') as string;
|
||||||
|
let entities = this.getNodeParameter('options.entities', i) as string;
|
||||||
|
if (Array.isArray(entities)) {
|
||||||
|
entities = entities.join(',');
|
||||||
|
}
|
||||||
|
|
||||||
|
if (searchField === 'customField') {
|
||||||
|
searchField = this.getNodeParameter('customFieldName', i) as string;
|
||||||
|
fieldValue = this.getNodeParameter('customFieldValue', i) as string;
|
||||||
|
}
|
||||||
|
|
||||||
|
const qs: IDataObject = {
|
||||||
|
q: fieldValue,
|
||||||
|
f: searchField,
|
||||||
|
entities,
|
||||||
|
};
|
||||||
|
|
||||||
|
responseData = await freshworksCrmApiRequest.call(this, 'GET', '/lookup', {}, qs);
|
||||||
|
}
|
||||||
} else if (resource === 'task') {
|
} else if (resource === 'task') {
|
||||||
|
|
||||||
// **********************************************************************
|
// **********************************************************************
|
||||||
|
|
|
@ -31,12 +31,9 @@ export async function freshworksCrmApiRequest(
|
||||||
body: IDataObject = {},
|
body: IDataObject = {},
|
||||||
qs: IDataObject = {},
|
qs: IDataObject = {},
|
||||||
) {
|
) {
|
||||||
const { apiKey, domain } = await this.getCredentials('freshworksCrmApi') as FreshworksCrmApiCredentials;
|
const { domain } = await this.getCredentials('freshworksCrmApi') as FreshworksCrmApiCredentials;
|
||||||
|
|
||||||
const options: OptionsWithUri = {
|
const options: OptionsWithUri = {
|
||||||
headers: {
|
|
||||||
Authorization: `Token token=${apiKey}`,
|
|
||||||
},
|
|
||||||
method,
|
method,
|
||||||
body,
|
body,
|
||||||
qs,
|
qs,
|
||||||
|
@ -52,7 +49,8 @@ export async function freshworksCrmApiRequest(
|
||||||
delete options.qs;
|
delete options.qs;
|
||||||
}
|
}
|
||||||
try {
|
try {
|
||||||
return await this.helpers.request!(options);
|
const credentialsType = 'freshworksCrmApi';
|
||||||
|
return await this.helpers.requestWithAuthentication.call(this, credentialsType, options);
|
||||||
} catch (error) {
|
} catch (error) {
|
||||||
throw new NodeApiError(this.getNode(), error);
|
throw new NodeApiError(this.getNode(), error);
|
||||||
}
|
}
|
||||||
|
|
|
@ -0,0 +1,267 @@
|
||||||
|
import {
|
||||||
|
INodeProperties,
|
||||||
|
} from 'n8n-workflow';
|
||||||
|
|
||||||
|
export const searchOperations: INodeProperties[] = [
|
||||||
|
{
|
||||||
|
displayName: 'Operation',
|
||||||
|
name: 'operation',
|
||||||
|
type: 'options',
|
||||||
|
noDataExpression: true,
|
||||||
|
displayOptions: {
|
||||||
|
show: {
|
||||||
|
resource: [
|
||||||
|
'search',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
options: [
|
||||||
|
{
|
||||||
|
name: 'Query',
|
||||||
|
value: 'query',
|
||||||
|
description: 'Search for records by entering search queries of your choice',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: 'Lookup',
|
||||||
|
value: 'lookup',
|
||||||
|
description: 'Search for the name or email address of records',
|
||||||
|
},
|
||||||
|
],
|
||||||
|
default: 'query',
|
||||||
|
},
|
||||||
|
];
|
||||||
|
|
||||||
|
export const searchFields: INodeProperties[] = [
|
||||||
|
// ----------------------------------------
|
||||||
|
// Search: query
|
||||||
|
// ----------------------------------------
|
||||||
|
{
|
||||||
|
displayName: 'Search Term',
|
||||||
|
name: 'query',
|
||||||
|
type: 'string',
|
||||||
|
required: true,
|
||||||
|
default: '',
|
||||||
|
displayOptions: {
|
||||||
|
show: {
|
||||||
|
resource: [
|
||||||
|
'search',
|
||||||
|
],
|
||||||
|
operation: [
|
||||||
|
'query',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
description: 'Enter a term that will be used for searching entities',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
displayName: 'Search on Entities',
|
||||||
|
name: 'entities',
|
||||||
|
type: 'multiOptions',
|
||||||
|
options: [
|
||||||
|
{
|
||||||
|
name: 'Contact',
|
||||||
|
value: 'contact',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: 'Deal',
|
||||||
|
value: 'deal',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: 'Sales Account',
|
||||||
|
value: 'sales_account',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: 'User',
|
||||||
|
value: 'user',
|
||||||
|
},
|
||||||
|
],
|
||||||
|
required: true,
|
||||||
|
default: [],
|
||||||
|
displayOptions: {
|
||||||
|
show: {
|
||||||
|
resource: [
|
||||||
|
'search',
|
||||||
|
],
|
||||||
|
operation: [
|
||||||
|
'query',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
description: 'Enter a term that will be used for searching entities',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
displayName: 'Return All',
|
||||||
|
name: 'returnAll',
|
||||||
|
type: 'boolean',
|
||||||
|
default: false,
|
||||||
|
displayOptions: {
|
||||||
|
show: {
|
||||||
|
resource: [
|
||||||
|
'search',
|
||||||
|
],
|
||||||
|
operation: [
|
||||||
|
'query',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
description: 'Whether to return all results or only up to a given limit',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
displayName: 'Limit',
|
||||||
|
name: 'limit',
|
||||||
|
type: 'number',
|
||||||
|
default: 25,
|
||||||
|
displayOptions: {
|
||||||
|
show: {
|
||||||
|
resource: [
|
||||||
|
'search',
|
||||||
|
],
|
||||||
|
operation: [
|
||||||
|
'query',
|
||||||
|
],
|
||||||
|
returnAll: [
|
||||||
|
false,
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
description: 'Max number of results to return',
|
||||||
|
},
|
||||||
|
// ----------------------------------------
|
||||||
|
// Search: lookup
|
||||||
|
// ----------------------------------------
|
||||||
|
{
|
||||||
|
displayName: 'Search Field',
|
||||||
|
name: 'searchField',
|
||||||
|
type: 'options',
|
||||||
|
options: [
|
||||||
|
{
|
||||||
|
name: 'Email',
|
||||||
|
value: 'email',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: 'Name',
|
||||||
|
value: 'name',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: 'Custom Field',
|
||||||
|
value: 'customField',
|
||||||
|
description: 'Only allowed custom fields of type "Text field", "Number", "Dropdown" or "Radio button"',
|
||||||
|
},
|
||||||
|
],
|
||||||
|
required: true,
|
||||||
|
default: '',
|
||||||
|
displayOptions: {
|
||||||
|
show: {
|
||||||
|
resource: [
|
||||||
|
'search',
|
||||||
|
],
|
||||||
|
operation: [
|
||||||
|
'lookup',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
description: 'Field against which the entities have to be searched',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
displayName: 'Custom Field Name',
|
||||||
|
name: 'customFieldName',
|
||||||
|
type: 'string',
|
||||||
|
required: true,
|
||||||
|
default: '',
|
||||||
|
displayOptions: {
|
||||||
|
show: {
|
||||||
|
resource: [
|
||||||
|
'search',
|
||||||
|
],
|
||||||
|
operation: [
|
||||||
|
'lookup',
|
||||||
|
],
|
||||||
|
searchField: [
|
||||||
|
'customField',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
displayName: 'Custom Field Value',
|
||||||
|
name: 'customFieldValue',
|
||||||
|
type: 'string',
|
||||||
|
required: true,
|
||||||
|
default: '',
|
||||||
|
displayOptions: {
|
||||||
|
show: {
|
||||||
|
resource: [
|
||||||
|
'search',
|
||||||
|
],
|
||||||
|
operation: [
|
||||||
|
'lookup',
|
||||||
|
],
|
||||||
|
searchField: [
|
||||||
|
'customField',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
displayName: 'Field Value',
|
||||||
|
name: 'fieldValue',
|
||||||
|
type: 'string',
|
||||||
|
required: true,
|
||||||
|
default: '',
|
||||||
|
displayOptions: {
|
||||||
|
show: {
|
||||||
|
resource: [
|
||||||
|
'search',
|
||||||
|
],
|
||||||
|
operation: [
|
||||||
|
'lookup',
|
||||||
|
],
|
||||||
|
searchField: [
|
||||||
|
'email',
|
||||||
|
'name',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
},
|
||||||
|
{
|
||||||
|
displayName: 'Options',
|
||||||
|
name: 'options',
|
||||||
|
type: 'collection',
|
||||||
|
placeholder: 'Add Option',
|
||||||
|
default: {},
|
||||||
|
displayOptions: {
|
||||||
|
show: {
|
||||||
|
resource: [
|
||||||
|
'search',
|
||||||
|
],
|
||||||
|
operation: [
|
||||||
|
'lookup',
|
||||||
|
],
|
||||||
|
},
|
||||||
|
},
|
||||||
|
options: [
|
||||||
|
{
|
||||||
|
displayName: 'Entities',
|
||||||
|
name: 'entities',
|
||||||
|
type: 'multiOptions',
|
||||||
|
default: [],
|
||||||
|
options: [
|
||||||
|
{
|
||||||
|
name: 'Contact',
|
||||||
|
value: 'contact',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: 'Deal',
|
||||||
|
value: 'deal',
|
||||||
|
},
|
||||||
|
{
|
||||||
|
name: 'Sales Account',
|
||||||
|
value: 'sales_account',
|
||||||
|
},
|
||||||
|
],
|
||||||
|
// eslint-disable-next-line n8n-nodes-base/node-param-description-unneeded-backticks
|
||||||
|
description: `Use 'entities' to query against related entities. You can include multiple entities at once, provided the field is available in both entities or else you'd receive an error response.`,
|
||||||
|
},
|
||||||
|
],
|
||||||
|
},
|
||||||
|
];
|
|
@ -4,4 +4,5 @@ export * from './ContactDescription';
|
||||||
export * from './DealDescription';
|
export * from './DealDescription';
|
||||||
export * from './NoteDescription';
|
export * from './NoteDescription';
|
||||||
export * from './SalesActivityDescription';
|
export * from './SalesActivityDescription';
|
||||||
|
export * from './SearchDescription';
|
||||||
export * from './TaskDescription';
|
export * from './TaskDescription';
|
||||||
|
|
Loading…
Reference in a new issue