mirror of
https://github.com/n8n-io/n8n.git
synced 2024-11-15 00:54:06 -08:00
376 lines
9.4 KiB
TypeScript
376 lines
9.4 KiB
TypeScript
import type {
|
|
IExecuteFunctions,
|
|
IDataObject,
|
|
INodeExecutionData,
|
|
INodeType,
|
|
INodeTypeDescription,
|
|
} from 'n8n-workflow';
|
|
import { NodeConnectionType, NodeApiError } from 'n8n-workflow';
|
|
|
|
import { dropcontactApiRequest, mapPairedItemsFrom } from './GenericFunction';
|
|
|
|
export class Dropcontact implements INodeType {
|
|
description: INodeTypeDescription = {
|
|
displayName: 'Dropcontact',
|
|
name: 'dropcontact',
|
|
icon: 'file:dropcontact.svg',
|
|
group: ['transform'],
|
|
version: 1,
|
|
description: 'Find B2B emails and enrich contacts',
|
|
subtitle: '={{$parameter["operation"] + ": " + $parameter["resource"]}}',
|
|
defaults: {
|
|
name: 'Dropcontact',
|
|
},
|
|
inputs: [NodeConnectionType.Main],
|
|
outputs: [NodeConnectionType.Main],
|
|
credentials: [
|
|
{
|
|
name: 'dropcontactApi',
|
|
required: true,
|
|
},
|
|
],
|
|
properties: [
|
|
{
|
|
displayName: 'Resource',
|
|
noDataExpression: true,
|
|
name: 'resource',
|
|
type: 'options',
|
|
options: [
|
|
{
|
|
name: 'Contact',
|
|
value: 'contact',
|
|
},
|
|
],
|
|
default: 'contact',
|
|
required: true,
|
|
},
|
|
{
|
|
displayName: 'Operation',
|
|
noDataExpression: true,
|
|
name: 'operation',
|
|
type: 'options',
|
|
options: [
|
|
{
|
|
name: 'Enrich',
|
|
value: 'enrich',
|
|
description: 'Find B2B emails and enrich your contact from his name and his website',
|
|
action: 'Find B2B emails',
|
|
},
|
|
{
|
|
name: 'Fetch Request',
|
|
value: 'fetchRequest',
|
|
},
|
|
],
|
|
default: 'enrich',
|
|
required: true,
|
|
},
|
|
{
|
|
displayName: 'Request ID',
|
|
name: 'requestId',
|
|
type: 'string',
|
|
required: true,
|
|
displayOptions: {
|
|
show: {
|
|
resource: ['contact'],
|
|
operation: ['fetchRequest'],
|
|
},
|
|
},
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'Email',
|
|
name: 'email',
|
|
type: 'string',
|
|
placeholder: 'name@email.com',
|
|
displayOptions: {
|
|
show: {
|
|
resource: ['contact'],
|
|
operation: ['enrich'],
|
|
},
|
|
},
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'Simplify Output (Faster)',
|
|
name: 'simplify',
|
|
type: 'boolean',
|
|
displayOptions: {
|
|
show: {
|
|
resource: ['contact'],
|
|
operation: ['enrich'],
|
|
},
|
|
},
|
|
default: false,
|
|
// eslint-disable-next-line n8n-nodes-base/node-param-description-boolean-without-whether
|
|
description:
|
|
'When off, waits for the contact data before completing. Waiting time can be adjusted with Extend Wait Time option. When on, returns a request_id that can be used later in the Fetch Request operation.',
|
|
},
|
|
{
|
|
displayName: 'Additional Fields',
|
|
name: 'additionalFields',
|
|
type: 'collection',
|
|
placeholder: 'Add Field',
|
|
default: {},
|
|
displayOptions: {
|
|
show: {
|
|
resource: ['contact'],
|
|
operation: ['enrich'],
|
|
},
|
|
},
|
|
options: [
|
|
{
|
|
displayName: 'Company SIREN Number',
|
|
name: 'num_siren',
|
|
type: 'string',
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'Company SIRET Code',
|
|
name: 'siret',
|
|
type: 'string',
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'Company Name',
|
|
name: 'company',
|
|
type: 'string',
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'Country',
|
|
name: 'country',
|
|
type: 'string',
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'First Name',
|
|
name: 'first_name',
|
|
type: 'string',
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'Full Name',
|
|
name: 'full_name',
|
|
type: 'string',
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'Last Name',
|
|
name: 'last_name',
|
|
type: 'string',
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'LinkedIn Profile',
|
|
name: 'linkedin',
|
|
type: 'string',
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'Phone Number',
|
|
name: 'phone',
|
|
type: 'string',
|
|
default: '',
|
|
},
|
|
{
|
|
displayName: 'Website',
|
|
name: 'website',
|
|
type: 'string',
|
|
default: '',
|
|
},
|
|
],
|
|
},
|
|
{
|
|
displayName: 'Options',
|
|
name: 'options',
|
|
type: 'collection',
|
|
displayOptions: {
|
|
show: {
|
|
resource: ['contact'],
|
|
operation: ['enrich'],
|
|
},
|
|
},
|
|
placeholder: 'Add option',
|
|
default: {},
|
|
options: [
|
|
{
|
|
displayName: 'Data Fetch Wait Time',
|
|
name: 'waitTime',
|
|
type: 'number',
|
|
typeOptions: {
|
|
minValue: 1,
|
|
},
|
|
displayOptions: {
|
|
show: {
|
|
'/simplify': [false],
|
|
},
|
|
},
|
|
default: 45,
|
|
description:
|
|
'When not simplifying the response, data will be fetched in two steps. This parameter controls how long to wait (in seconds) before trying the second step.',
|
|
},
|
|
{
|
|
displayName: 'French Company Enrich',
|
|
name: 'siren',
|
|
type: 'boolean',
|
|
default: false,
|
|
description:
|
|
'Whether you want the <a href="https://en.wikipedia.org/wiki/SIREN_code" target="_blank">SIREN number</a>, NAF code, TVA number, company address and informations about the company leader. Only applies to french companies.',
|
|
},
|
|
{
|
|
displayName: 'Language',
|
|
name: 'language',
|
|
type: 'options',
|
|
options: [
|
|
{
|
|
name: 'English',
|
|
value: 'en',
|
|
},
|
|
{
|
|
name: 'French',
|
|
value: 'fr',
|
|
},
|
|
],
|
|
default: 'en',
|
|
description: 'Whether the response is in English or French',
|
|
},
|
|
],
|
|
},
|
|
],
|
|
};
|
|
|
|
async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
|
|
const entryData = this.getInputData();
|
|
const resource = this.getNodeParameter('resource', 0);
|
|
const operation = this.getNodeParameter('operation', 0);
|
|
|
|
let responseData: any;
|
|
const returnData: INodeExecutionData[] = [];
|
|
|
|
if (resource === 'contact') {
|
|
if (operation === 'enrich') {
|
|
const options = this.getNodeParameter('options', 0);
|
|
const data = [];
|
|
const simplify = this.getNodeParameter('simplify', 0) as boolean;
|
|
|
|
const siren = options.siren === true ? true : false;
|
|
const language = options.language ? options.language : 'en';
|
|
|
|
for (let i = 0; i < entryData.length; i++) {
|
|
const email = this.getNodeParameter('email', i) as string;
|
|
const additionalFields = this.getNodeParameter('additionalFields', i);
|
|
const body: IDataObject = {};
|
|
if (email !== '') {
|
|
body.email = email;
|
|
}
|
|
Object.assign(body, additionalFields);
|
|
data.push(body);
|
|
}
|
|
|
|
responseData = (await dropcontactApiRequest.call(
|
|
this,
|
|
'POST',
|
|
'/batch',
|
|
{ data, siren, language },
|
|
{},
|
|
)) as { request_id: string; error: string; success: boolean };
|
|
|
|
if (!responseData.success) {
|
|
if (this.continueOnFail()) {
|
|
const executionData = this.helpers.constructExecutionMetaData(
|
|
this.helpers.returnJsonArray({ error: responseData.reason || 'invalid request' }),
|
|
{
|
|
itemData: mapPairedItemsFrom(entryData),
|
|
},
|
|
);
|
|
returnData.push(...executionData);
|
|
} else {
|
|
throw new NodeApiError(this.getNode(), {
|
|
error: responseData.reason || 'invalid request',
|
|
});
|
|
}
|
|
}
|
|
|
|
if (!simplify) {
|
|
const waitTime = this.getNodeParameter('options.waitTime', 0, 45) as number;
|
|
|
|
const delay = async (ms: any) => await new Promise((res) => setTimeout(res, ms * 1000));
|
|
await delay(waitTime);
|
|
responseData = await dropcontactApiRequest.call(
|
|
this,
|
|
'GET',
|
|
`/batch/${responseData.request_id}`,
|
|
{},
|
|
{},
|
|
);
|
|
if (!responseData.success) {
|
|
if (this.continueOnFail()) {
|
|
const executionData = this.helpers.constructExecutionMetaData(
|
|
this.helpers.returnJsonArray({ error: responseData.reason }),
|
|
{
|
|
itemData: mapPairedItemsFrom(entryData),
|
|
},
|
|
);
|
|
returnData.push(...executionData);
|
|
} else {
|
|
throw new NodeApiError(this.getNode(), {
|
|
error: responseData.reason,
|
|
description: 'Hint: Increase the Wait Time to avoid this error',
|
|
});
|
|
}
|
|
} else {
|
|
responseData.data.forEach((d: IDataObject, index: number) => {
|
|
const executionData = this.helpers.constructExecutionMetaData(
|
|
this.helpers.returnJsonArray(d),
|
|
{ itemData: { item: index } },
|
|
);
|
|
returnData.push(...executionData);
|
|
});
|
|
}
|
|
} else {
|
|
const executionData = this.helpers.constructExecutionMetaData(
|
|
this.helpers.returnJsonArray(responseData as IDataObject[]),
|
|
{
|
|
itemData: mapPairedItemsFrom(entryData),
|
|
},
|
|
);
|
|
returnData.push(...executionData);
|
|
}
|
|
}
|
|
|
|
if (operation === 'fetchRequest') {
|
|
for (let i = 0; i < entryData.length; i++) {
|
|
const requestId = this.getNodeParameter('requestId', i) as string;
|
|
responseData = (await dropcontactApiRequest.call(
|
|
this,
|
|
'GET',
|
|
`/batch/${requestId}`,
|
|
{},
|
|
{},
|
|
)) as { request_id: string; error: string; success: boolean };
|
|
if (!responseData.success) {
|
|
if (this.continueOnFail()) {
|
|
const executionData = this.helpers.constructExecutionMetaData(
|
|
this.helpers.returnJsonArray({ error: responseData.reason || 'invalid request' }),
|
|
{ itemData: { item: i } },
|
|
);
|
|
returnData.push(...executionData);
|
|
} else {
|
|
throw new NodeApiError(this.getNode(), {
|
|
error: responseData.reason || 'invalid request',
|
|
});
|
|
}
|
|
}
|
|
const executionData = this.helpers.constructExecutionMetaData(
|
|
this.helpers.returnJsonArray(responseData.data as IDataObject[]),
|
|
{ itemData: { item: i } },
|
|
);
|
|
returnData.push(...executionData);
|
|
}
|
|
}
|
|
}
|
|
|
|
return [returnData];
|
|
}
|
|
}
|