mirror of
https://github.com/n8n-io/n8n.git
synced 2024-12-25 04:34:06 -08:00
🔀 Merge branch 'RicardoE105-feature/affinity'
This commit is contained in:
commit
94b7743de1
17
packages/nodes-base/credentials/AffinityApi.credentials.ts
Normal file
17
packages/nodes-base/credentials/AffinityApi.credentials.ts
Normal file
|
@ -0,0 +1,17 @@
|
|||
import {
|
||||
ICredentialType,
|
||||
NodePropertyTypes,
|
||||
} from 'n8n-workflow';
|
||||
|
||||
export class AffinityApi implements ICredentialType {
|
||||
name = 'affinityApi';
|
||||
displayName = 'Affinity API';
|
||||
properties = [
|
||||
{
|
||||
displayName: 'API Key',
|
||||
name: 'apiKey',
|
||||
type: 'string' as NodePropertyTypes,
|
||||
default: '',
|
||||
},
|
||||
];
|
||||
}
|
267
packages/nodes-base/nodes/Affinity/Affinity.node.ts
Normal file
267
packages/nodes-base/nodes/Affinity/Affinity.node.ts
Normal file
|
@ -0,0 +1,267 @@
|
|||
import {
|
||||
IExecuteFunctions,
|
||||
} from 'n8n-core';
|
||||
import {
|
||||
IDataObject,
|
||||
ILoadOptionsFunctions,
|
||||
INodeTypeDescription,
|
||||
INodeExecutionData,
|
||||
INodeType,
|
||||
INodePropertyOptions,
|
||||
} from 'n8n-workflow';
|
||||
import {
|
||||
affinityApiRequest,
|
||||
affinityApiRequestAllItems,
|
||||
} from './GenericFunctions';
|
||||
import {
|
||||
organizationFields,
|
||||
organizationOperations,
|
||||
} from './OrganizationDescription';
|
||||
import {
|
||||
personFields,
|
||||
personOperations,
|
||||
} from './PersonDescription';
|
||||
import {
|
||||
IOrganization,
|
||||
} from './OrganizationInterface';
|
||||
import {
|
||||
IPerson,
|
||||
} from './PersonInterface';
|
||||
|
||||
import { snakeCase } from 'change-case';
|
||||
|
||||
export class Affinity implements INodeType {
|
||||
description: INodeTypeDescription = {
|
||||
displayName: 'Affinity',
|
||||
name: 'affinity',
|
||||
icon: 'file:affinity.png',
|
||||
group: ['output'],
|
||||
version: 1,
|
||||
subtitle: '={{$parameter["operation"] + ": " + $parameter["resource"]}}',
|
||||
description: 'Consume Affinity API',
|
||||
defaults: {
|
||||
name: 'Affinity',
|
||||
color: '#3343df',
|
||||
},
|
||||
inputs: ['main'],
|
||||
outputs: ['main'],
|
||||
credentials: [
|
||||
{
|
||||
name: 'affinityApi',
|
||||
required: true,
|
||||
}
|
||||
],
|
||||
properties: [
|
||||
{
|
||||
displayName: 'Resource',
|
||||
name: 'resource',
|
||||
type: 'options',
|
||||
options: [
|
||||
{
|
||||
name: 'Organization',
|
||||
value: 'organization',
|
||||
},
|
||||
{
|
||||
name: 'Person',
|
||||
value: 'person',
|
||||
},
|
||||
],
|
||||
default: 'organization',
|
||||
description: 'Resource to consume.',
|
||||
},
|
||||
...organizationOperations,
|
||||
...organizationFields,
|
||||
...personOperations,
|
||||
...personFields,
|
||||
],
|
||||
};
|
||||
|
||||
methods = {
|
||||
loadOptions: {
|
||||
// Get all the available organizations to display them to user so that he can
|
||||
// select them easily
|
||||
async getOrganizations(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
const returnData: INodePropertyOptions[] = [];
|
||||
const organizations = await affinityApiRequestAllItems.call(this, 'organizations', 'GET', '/organizations', {});
|
||||
for (const organization of organizations) {
|
||||
const organizationName = organization.name;
|
||||
const organizationId = organization.id;
|
||||
returnData.push({
|
||||
name: organizationName,
|
||||
value: organizationId,
|
||||
});
|
||||
}
|
||||
return returnData;
|
||||
},
|
||||
// Get all the available persons to display them to user so that he can
|
||||
// select them easily
|
||||
async getPersons(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
|
||||
const returnData: INodePropertyOptions[] = [];
|
||||
const persons = await affinityApiRequestAllItems.call(this, 'persons', 'GET', '/persons', {});
|
||||
for (const person of persons) {
|
||||
let personName = `${person.first_name} ${person.last_name}`;
|
||||
if (person.primary_email !== null) {
|
||||
personName+= ` (${person.primary_email})`;
|
||||
}
|
||||
const personId = person.id;
|
||||
returnData.push({
|
||||
name: personName,
|
||||
value: personId,
|
||||
});
|
||||
}
|
||||
return returnData;
|
||||
},
|
||||
},
|
||||
};
|
||||
|
||||
async execute(this: IExecuteFunctions): Promise<INodeExecutionData[][]> {
|
||||
const items = this.getInputData();
|
||||
const returnData: IDataObject[] = [];
|
||||
const length = items.length as unknown as number;
|
||||
let responseData;
|
||||
const qs: IDataObject = {};
|
||||
const resource = this.getNodeParameter('resource', 0) as string;
|
||||
const operation = this.getNodeParameter('operation', 0) as string;
|
||||
for (let i = 0; i < length; i++) {
|
||||
if (resource === 'person') {
|
||||
//https://api-docs.affinity.co/#create-a-new-person
|
||||
if (operation === 'create') {
|
||||
const firstName = this.getNodeParameter('firstName', i) as string;
|
||||
const lastName = this.getNodeParameter('lastName', i) as string;
|
||||
const emails = this.getNodeParameter('emails', i) as string[];
|
||||
const additionalFields = this.getNodeParameter('additionalFields', i) as IDataObject;
|
||||
const body: IPerson = {
|
||||
first_name: firstName,
|
||||
last_name: lastName,
|
||||
emails,
|
||||
};
|
||||
if (additionalFields.organizations) {
|
||||
body.organization_ids = additionalFields.organizations as number[];
|
||||
}
|
||||
responseData = await affinityApiRequest.call(this, 'POST', '/persons', body);
|
||||
}
|
||||
//https://api-docs.affinity.co/#update-a-person
|
||||
if (operation === 'update') {
|
||||
const personId = this.getNodeParameter('personId', i) as number;
|
||||
const updateFields = this.getNodeParameter('updateFields', i) as IDataObject;
|
||||
const emails = this.getNodeParameter('emails', i) as string[];
|
||||
const body: IPerson = {
|
||||
emails,
|
||||
};
|
||||
if (updateFields.firstName) {
|
||||
body.first_name = updateFields.firstName as string;
|
||||
}
|
||||
if (updateFields.lastName) {
|
||||
body.last_name = updateFields.lastName as string;
|
||||
}
|
||||
if (updateFields.organizations) {
|
||||
body.organization_ids = updateFields.organizations as number[];
|
||||
}
|
||||
responseData = await affinityApiRequest.call(this, 'PUT', `/persons/${personId}`, body);
|
||||
}
|
||||
//https://api-docs.affinity.co/#get-a-specific-person
|
||||
if (operation === 'get') {
|
||||
const personId = this.getNodeParameter('personId', i) as number;
|
||||
const options = this.getNodeParameter('options', i) as IDataObject;
|
||||
if (options.withInteractionDates) {
|
||||
qs.with_interaction_dates = options.withInteractionDates as boolean;
|
||||
}
|
||||
responseData = await affinityApiRequest.call(this,'GET', `/persons/${personId}`, {}, qs);
|
||||
}
|
||||
//https://api-docs.affinity.co/#search-for-persons
|
||||
if (operation === 'getAll') {
|
||||
const returnAll = this.getNodeParameter('returnAll', i) as boolean;
|
||||
const options = this.getNodeParameter('options', i) as IDataObject;
|
||||
if (options.term) {
|
||||
qs.term = options.term as string;
|
||||
}
|
||||
if (options.withInteractionDates) {
|
||||
qs.with_interaction_dates = options.withInteractionDates as boolean;
|
||||
}
|
||||
if (returnAll === true) {
|
||||
responseData = await affinityApiRequestAllItems.call(this, 'persons', 'GET', '/persons', {}, qs);
|
||||
} else {
|
||||
qs.page_size = this.getNodeParameter('limit', i) as number;
|
||||
responseData = await affinityApiRequest.call(this, 'GET', '/persons', {}, qs);
|
||||
responseData = responseData.persons;
|
||||
}
|
||||
}
|
||||
//https://api-docs.affinity.co/#delete-a-person
|
||||
if (operation === 'delete') {
|
||||
const personId = this.getNodeParameter('personId', i) as number;
|
||||
responseData = await affinityApiRequest.call(this, 'DELETE', `/persons/${personId}`, {}, qs);
|
||||
}
|
||||
}
|
||||
if (resource === 'organization') {
|
||||
//https://api-docs.affinity.co/#create-a-new-organization
|
||||
if (operation === 'create') {
|
||||
const name = this.getNodeParameter('name', i) as string;
|
||||
const domain = this.getNodeParameter('domain', i) as string;
|
||||
const additionalFields = this.getNodeParameter('additionalFields', i) as IDataObject;
|
||||
const body: IOrganization = {
|
||||
name,
|
||||
domain,
|
||||
};
|
||||
if (additionalFields.persons) {
|
||||
body.person_ids = additionalFields.persons as number[];
|
||||
}
|
||||
responseData = await affinityApiRequest.call(this, 'POST', '/organizations', body);
|
||||
}
|
||||
//https://api-docs.affinity.co/#update-an-organization
|
||||
if (operation === 'update') {
|
||||
const organizationId = this.getNodeParameter('organizationId', i) as number;
|
||||
const updateFields = this.getNodeParameter('updateFields', i) as IDataObject;
|
||||
const body: IOrganization = {};
|
||||
if (updateFields.name) {
|
||||
body.name = updateFields.name as string;
|
||||
}
|
||||
if (updateFields.domain) {
|
||||
body.domain = updateFields.domain as string;
|
||||
}
|
||||
if (updateFields.persons) {
|
||||
body.person_ids = updateFields.persons as number[];
|
||||
}
|
||||
responseData = await affinityApiRequest.call(this, 'PUT', `/organizations/${organizationId}`, body);
|
||||
}
|
||||
//https://api-docs.affinity.co/#get-a-specific-organization
|
||||
if (operation === 'get') {
|
||||
const organizationId = this.getNodeParameter('organizationId', i) as number;
|
||||
const options = this.getNodeParameter('options', i) as IDataObject;
|
||||
if (options.withInteractionDates) {
|
||||
qs.with_interaction_dates = options.withInteractionDates as boolean;
|
||||
}
|
||||
responseData = await affinityApiRequest.call(this,'GET', `/organizations/${organizationId}`, {}, qs);
|
||||
}
|
||||
//https://api-docs.affinity.co/#search-for-organizations
|
||||
if (operation === 'getAll') {
|
||||
const returnAll = this.getNodeParameter('returnAll', i) as boolean;
|
||||
const options = this.getNodeParameter('options', i) as IDataObject;
|
||||
if (options.term) {
|
||||
qs.term = options.term as string;
|
||||
}
|
||||
if (options.withInteractionDates) {
|
||||
qs.with_interaction_dates = options.withInteractionDates as boolean;
|
||||
}
|
||||
if (returnAll === true) {
|
||||
responseData = await affinityApiRequestAllItems.call(this, 'organizations', 'GET', '/organizations', {}, qs);
|
||||
} else {
|
||||
qs.page_size = this.getNodeParameter('limit', i) as number;
|
||||
responseData = await affinityApiRequest.call(this, 'GET', '/organizations', {}, qs);
|
||||
responseData = responseData.organizations;
|
||||
}
|
||||
}
|
||||
//https://api-docs.affinity.co/#delete-an-organization
|
||||
if (operation === 'delete') {
|
||||
const organizationId = this.getNodeParameter('organizationId', i) as number;
|
||||
responseData = await affinityApiRequest.call(this, 'DELETE', `/organizations/${organizationId}`, {}, qs);
|
||||
}
|
||||
}
|
||||
if (Array.isArray(responseData)) {
|
||||
returnData.push.apply(returnData, responseData as IDataObject[]);
|
||||
} else {
|
||||
returnData.push(responseData as IDataObject);
|
||||
}
|
||||
}
|
||||
return [this.helpers.returnJsonArray(returnData)];
|
||||
}
|
||||
}
|
252
packages/nodes-base/nodes/Affinity/AffinityTrigger.node.ts
Normal file
252
packages/nodes-base/nodes/Affinity/AffinityTrigger.node.ts
Normal file
|
@ -0,0 +1,252 @@
|
|||
import {
|
||||
IHookFunctions,
|
||||
IWebhookFunctions,
|
||||
} from 'n8n-core';
|
||||
|
||||
import {
|
||||
INodeTypeDescription,
|
||||
INodeType,
|
||||
IWebhookResponseData,
|
||||
IDataObject,
|
||||
} from 'n8n-workflow';
|
||||
|
||||
import {
|
||||
affinityApiRequest,
|
||||
eventsExist,
|
||||
mapResource,
|
||||
} from './GenericFunctions';
|
||||
|
||||
export class AffinityTrigger implements INodeType {
|
||||
description: INodeTypeDescription = {
|
||||
displayName: 'Affinity Trigger',
|
||||
name: 'affinityTrigger',
|
||||
icon: 'file:affinity.png',
|
||||
group: ['trigger'],
|
||||
version: 1,
|
||||
description: 'Handle Affinity events via webhooks',
|
||||
defaults: {
|
||||
name: 'Affinity Trigger',
|
||||
color: '#3343df',
|
||||
},
|
||||
inputs: [],
|
||||
outputs: ['main'],
|
||||
credentials: [
|
||||
{
|
||||
name: 'affinityApi',
|
||||
required: true,
|
||||
},
|
||||
],
|
||||
webhooks: [
|
||||
{
|
||||
name: 'default',
|
||||
httpMethod: 'POST',
|
||||
responseMode: 'onReceived',
|
||||
path: 'webhook',
|
||||
},
|
||||
],
|
||||
properties: [
|
||||
{
|
||||
displayName: 'Events',
|
||||
name: 'events',
|
||||
type: 'multiOptions',
|
||||
options: [
|
||||
{
|
||||
name: 'file.created',
|
||||
value: 'file.deleted',
|
||||
},
|
||||
{
|
||||
name: 'file.created',
|
||||
value: 'file.deleted',
|
||||
},
|
||||
{
|
||||
name: 'field_value.created',
|
||||
value: 'field_value.created',
|
||||
},
|
||||
{
|
||||
name: 'field_value.updated',
|
||||
value: 'field_value.updated',
|
||||
},
|
||||
{
|
||||
name: 'field_value.deleted',
|
||||
value: 'field_value.deleted',
|
||||
},
|
||||
{
|
||||
name: 'field.created',
|
||||
value: 'field.created',
|
||||
},
|
||||
{
|
||||
name: 'field.updated',
|
||||
value: 'field.updated',
|
||||
},
|
||||
{
|
||||
name: 'field.deleted',
|
||||
value: 'field.deleted',
|
||||
},
|
||||
{
|
||||
name: 'list.created',
|
||||
value: 'list.created',
|
||||
},
|
||||
{
|
||||
name: 'list.updated',
|
||||
value: 'list.updated',
|
||||
},
|
||||
{
|
||||
name: 'list.deleted',
|
||||
value: 'list.deleted',
|
||||
},
|
||||
{
|
||||
name: 'list_entry.created',
|
||||
value: 'list_entry.created',
|
||||
},
|
||||
{
|
||||
name: 'list_entry.deleted',
|
||||
value: 'list_entry.deleted',
|
||||
},
|
||||
{
|
||||
name: 'note.created',
|
||||
value: 'note.created',
|
||||
},
|
||||
{
|
||||
name: 'note.updated',
|
||||
value: 'note.updated',
|
||||
},
|
||||
{
|
||||
name: 'note.deleted',
|
||||
value: 'note.deleted',
|
||||
},
|
||||
{
|
||||
name: 'organization.created',
|
||||
value: 'organization.created',
|
||||
},
|
||||
{
|
||||
name: 'organization.updated',
|
||||
value: 'organization.updated',
|
||||
},
|
||||
{
|
||||
name: 'organization.deleted',
|
||||
value: 'organization.deleted',
|
||||
},
|
||||
{
|
||||
name: 'opportunity.created',
|
||||
value: 'opportunity.created',
|
||||
},
|
||||
{
|
||||
name: 'opportunity.updated',
|
||||
value: 'opportunity.updated',
|
||||
},
|
||||
{
|
||||
name: 'opportunity.deleted',
|
||||
value: 'organization.deleted',
|
||||
},
|
||||
{
|
||||
name: 'person.created',
|
||||
value: 'person.created',
|
||||
},
|
||||
{
|
||||
name: 'person.updated',
|
||||
value: 'person.updated',
|
||||
},
|
||||
{
|
||||
name: 'person.deleted',
|
||||
value: 'person.deleted',
|
||||
},
|
||||
],
|
||||
default: [],
|
||||
required: true,
|
||||
description: 'Webhook events that will be enabled for that endpoint.',
|
||||
},
|
||||
],
|
||||
|
||||
};
|
||||
|
||||
// @ts-ignore (because of request)
|
||||
webhookMethods = {
|
||||
default: {
|
||||
async checkExists(this: IHookFunctions): Promise<boolean> {
|
||||
// Check all the webhooks which exist already if it is identical to the
|
||||
// one that is supposed to get created.
|
||||
const endpoint = '/webhook';
|
||||
|
||||
const responseData = await affinityApiRequest.call(this, 'GET', endpoint, {});
|
||||
|
||||
const webhookUrl = this.getNodeWebhookUrl('default');
|
||||
|
||||
const events = this.getNodeParameter('events') as string[];
|
||||
|
||||
for (const webhook of responseData) {
|
||||
if (eventsExist(webhook.subscriptions, events) && webhook.webhook_url === webhookUrl) {
|
||||
// Set webhook-id to be sure that it can be deleted
|
||||
const webhookData = this.getWorkflowStaticData('node');
|
||||
webhookData.webhookId = webhook.id as string;
|
||||
return true;
|
||||
}
|
||||
}
|
||||
return false;
|
||||
},
|
||||
async create(this: IHookFunctions): Promise<boolean> {
|
||||
const webhookUrl = this.getNodeWebhookUrl('default');
|
||||
|
||||
const events = this.getNodeParameter('events') as string[];
|
||||
|
||||
const endpoint = '/webhook/subscribe';
|
||||
|
||||
const body = {
|
||||
webhook_url: webhookUrl,
|
||||
subscriptions: events,
|
||||
};
|
||||
|
||||
const responseData = await affinityApiRequest.call(this, 'POST', endpoint, body);
|
||||
|
||||
if (responseData.id === undefined) {
|
||||
// Required data is missing so was not successful
|
||||
return false;
|
||||
}
|
||||
|
||||
const webhookData = this.getWorkflowStaticData('node');
|
||||
webhookData.webhookId = responseData.id as string;
|
||||
return true;
|
||||
},
|
||||
async delete(this: IHookFunctions): Promise<boolean> {
|
||||
const webhookData = this.getWorkflowStaticData('node');
|
||||
if (webhookData.webhookId !== undefined) {
|
||||
|
||||
const endpoint = `/webhook/${webhookData.webhookId}`;
|
||||
|
||||
const responseData = await affinityApiRequest.call(this, 'DELETE', endpoint);
|
||||
|
||||
if (!responseData.success) {
|
||||
return false;
|
||||
}
|
||||
// Remove from the static workflow data so that it is clear
|
||||
// that no webhooks are registred anymore
|
||||
delete webhookData.webhookId;
|
||||
}
|
||||
return true;
|
||||
},
|
||||
},
|
||||
};
|
||||
|
||||
async webhook(this: IWebhookFunctions): Promise<IWebhookResponseData> {
|
||||
const bodyData = this.getBodyData();
|
||||
|
||||
if (bodyData.type === 'sample.webhook') {
|
||||
return {};
|
||||
}
|
||||
|
||||
let responseData: IDataObject = {};
|
||||
|
||||
if (bodyData.type && bodyData.body) {
|
||||
const resource = (bodyData.type as string).split('.')[0];
|
||||
//@ts-ignore
|
||||
const id = bodyData.body.id;
|
||||
responseData = await affinityApiRequest.call(this, 'GET', `/${mapResource(resource)}/${id}`);
|
||||
responseData.type = bodyData.type;
|
||||
}
|
||||
|
||||
return {
|
||||
workflowData: [
|
||||
this.helpers.returnJsonArray(responseData),
|
||||
],
|
||||
};
|
||||
}
|
||||
}
|
93
packages/nodes-base/nodes/Affinity/GenericFunctions.ts
Normal file
93
packages/nodes-base/nodes/Affinity/GenericFunctions.ts
Normal file
|
@ -0,0 +1,93 @@
|
|||
import { OptionsWithUri } from 'request';
|
||||
|
||||
import {
|
||||
IExecuteFunctions,
|
||||
ILoadOptionsFunctions,
|
||||
BINARY_ENCODING
|
||||
} from 'n8n-core';
|
||||
|
||||
import { IDataObject, IHookFunctions, IWebhookFunctions } from 'n8n-workflow';
|
||||
|
||||
export async function affinityApiRequest(this: IExecuteFunctions | IWebhookFunctions | IHookFunctions | ILoadOptionsFunctions, method: string, resource: string, body: any = {}, query: IDataObject = {}, uri?: string, option: IDataObject = {}): Promise<any> { // tslint:disable-line:no-any
|
||||
|
||||
const credentials = this.getCredentials('affinityApi');
|
||||
|
||||
if (credentials === undefined) {
|
||||
throw new Error('No credentials got returned!');
|
||||
}
|
||||
|
||||
const apiKey = `:${credentials.apiKey}`;
|
||||
|
||||
const endpoint = 'https://api.affinity.co';
|
||||
|
||||
let options: OptionsWithUri = {
|
||||
headers: {
|
||||
'Content-Type': 'application/json',
|
||||
Authorization: `Basic ${Buffer.from(apiKey).toString(BINARY_ENCODING)}`,
|
||||
},
|
||||
method,
|
||||
body,
|
||||
qs: query,
|
||||
uri: uri || `${endpoint}${resource}`,
|
||||
json: true
|
||||
};
|
||||
if (!Object.keys(body).length) {
|
||||
delete options.body;
|
||||
}
|
||||
if (!Object.keys(query).length) {
|
||||
delete options.qs;
|
||||
}
|
||||
options = Object.assign({}, options, option);
|
||||
try {
|
||||
return await this.helpers.request!(options);
|
||||
} catch (error) {
|
||||
if (error.response) {
|
||||
const errorMessage = error.response.body.message || error.response.body.description || error.message;
|
||||
throw new Error(`Affinity error response: ${errorMessage}`);
|
||||
}
|
||||
throw error;
|
||||
}
|
||||
}
|
||||
|
||||
export async function affinityApiRequestAllItems(this: IHookFunctions | ILoadOptionsFunctions | IExecuteFunctions, propertyName: string, method: string, resource: string, body: any = {}, query: IDataObject = {}): Promise<any> { // tslint:disable-line:no-any
|
||||
|
||||
const returnData: IDataObject[] = [];
|
||||
|
||||
let responseData;
|
||||
|
||||
query.page_size = 500;
|
||||
|
||||
do {
|
||||
responseData = await affinityApiRequest.call(this, method, resource, body, query);
|
||||
// @ts-ignore
|
||||
query.page_token = responseData.page_token;
|
||||
returnData.push.apply(returnData, responseData[propertyName]);
|
||||
} while (
|
||||
responseData.page_token !== undefined &&
|
||||
responseData.page_token !== null
|
||||
);
|
||||
|
||||
return returnData;
|
||||
}
|
||||
|
||||
export function eventsExist(subscriptions: string[], currentSubsriptions: string[]) {
|
||||
for (const subscription of currentSubsriptions) {
|
||||
if (!subscriptions.includes(subscription)) {
|
||||
return false;
|
||||
}
|
||||
}
|
||||
return true;
|
||||
}
|
||||
|
||||
export function mapResource(key: string) {
|
||||
//@ts-ignore
|
||||
return {
|
||||
person: 'persons',
|
||||
list: 'lists',
|
||||
note: 'notes',
|
||||
organization: 'organizatitons',
|
||||
list_entry: 'list-entries',
|
||||
field: 'fields',
|
||||
file: 'files',
|
||||
}[key];
|
||||
}
|
326
packages/nodes-base/nodes/Affinity/OrganizationDescription.ts
Normal file
326
packages/nodes-base/nodes/Affinity/OrganizationDescription.ts
Normal file
|
@ -0,0 +1,326 @@
|
|||
import { INodeProperties } from 'n8n-workflow';
|
||||
|
||||
export const organizationOperations = [
|
||||
{
|
||||
displayName: 'Operation',
|
||||
name: 'operation',
|
||||
type: 'options',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
},
|
||||
},
|
||||
options: [
|
||||
{
|
||||
name: 'Create',
|
||||
value: 'create',
|
||||
description: 'Create an organization',
|
||||
},
|
||||
{
|
||||
name: 'Delete',
|
||||
value: 'delete',
|
||||
description: 'Delete an organization',
|
||||
},
|
||||
{
|
||||
name: 'Get',
|
||||
value: 'get',
|
||||
description: 'Get an organization',
|
||||
},
|
||||
{
|
||||
name: 'Get All',
|
||||
value: 'getAll',
|
||||
description: 'Get all organizations',
|
||||
},
|
||||
{
|
||||
name: 'Update',
|
||||
value: 'update',
|
||||
description: 'Update an organization',
|
||||
},
|
||||
],
|
||||
default: 'create',
|
||||
description: 'The operation to perform.',
|
||||
},
|
||||
] as INodeProperties[];
|
||||
|
||||
export const organizationFields = [
|
||||
|
||||
/* -------------------------------------------------------------------------- */
|
||||
/* organization:create */
|
||||
/* -------------------------------------------------------------------------- */
|
||||
{
|
||||
displayName: 'Name',
|
||||
name: 'name',
|
||||
type: 'string',
|
||||
required: true,
|
||||
default: '',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'create',
|
||||
]
|
||||
},
|
||||
},
|
||||
description: 'The name of the organization.',
|
||||
},
|
||||
{
|
||||
displayName: 'Domain',
|
||||
name: 'domain',
|
||||
type: 'string',
|
||||
required: true,
|
||||
default: '',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'create',
|
||||
]
|
||||
},
|
||||
},
|
||||
description: 'The domain name of the organization.',
|
||||
},
|
||||
{
|
||||
displayName: 'Additional Fields',
|
||||
name: 'additionalFields',
|
||||
type: 'collection',
|
||||
placeholder: 'Add Field',
|
||||
default: {},
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'create',
|
||||
],
|
||||
},
|
||||
},
|
||||
options: [
|
||||
{
|
||||
displayName: 'Persons',
|
||||
name: 'persons',
|
||||
type: 'multiOptions',
|
||||
typeOptions: {
|
||||
loadOptionsMethod: 'getPersons',
|
||||
},
|
||||
default: [],
|
||||
description: 'Persons that the new organization will be associated with.',
|
||||
},
|
||||
],
|
||||
},
|
||||
/* -------------------------------------------------------------------------- */
|
||||
/* organization:update */
|
||||
/* -------------------------------------------------------------------------- */
|
||||
{
|
||||
displayName: 'Organization ID',
|
||||
name: 'organizationId',
|
||||
type: 'string',
|
||||
required: true,
|
||||
default: '',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'update',
|
||||
]
|
||||
},
|
||||
},
|
||||
description: 'Unique identifier for the organization.',
|
||||
},
|
||||
{
|
||||
displayName: 'Update Fields',
|
||||
name: 'updateFields',
|
||||
type: 'collection',
|
||||
placeholder: 'Add Field',
|
||||
default: {},
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'update',
|
||||
],
|
||||
},
|
||||
},
|
||||
options: [
|
||||
{
|
||||
displayName: 'Domain',
|
||||
name: 'domain',
|
||||
type: 'string',
|
||||
default: '',
|
||||
description: 'The domain name of the organization.',
|
||||
},
|
||||
{
|
||||
displayName: 'Name',
|
||||
name: 'name',
|
||||
type: 'string',
|
||||
default: '',
|
||||
description: 'The name of the organization.',
|
||||
},
|
||||
{
|
||||
displayName: 'Persons',
|
||||
name: 'persons',
|
||||
type: 'multiOptions',
|
||||
typeOptions: {
|
||||
loadOptionsMethod: 'getPersons',
|
||||
},
|
||||
default: [],
|
||||
description: 'Persons that the new organization will be associated with.',
|
||||
},
|
||||
]
|
||||
},
|
||||
/* -------------------------------------------------------------------------- */
|
||||
/* organization:get */
|
||||
/* -------------------------------------------------------------------------- */
|
||||
{
|
||||
displayName: 'Organization ID',
|
||||
name: 'organizationId',
|
||||
type: 'string',
|
||||
required: true,
|
||||
default: '',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'get',
|
||||
]
|
||||
},
|
||||
},
|
||||
description: 'Unique identifier for the organization.',
|
||||
},
|
||||
{
|
||||
displayName: 'Options',
|
||||
name: 'options',
|
||||
type: 'collection',
|
||||
placeholder: 'Add Option',
|
||||
default: {},
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'get',
|
||||
],
|
||||
},
|
||||
},
|
||||
options: [
|
||||
{
|
||||
displayName: 'With Interaction Dates',
|
||||
name: 'withInteractionDates',
|
||||
type: 'boolean',
|
||||
default: false,
|
||||
description: 'When true, interaction dates will be present on the returned resources.',
|
||||
},
|
||||
]
|
||||
},
|
||||
/* -------------------------------------------------------------------------- */
|
||||
/* organization:getAll */
|
||||
/* -------------------------------------------------------------------------- */
|
||||
{
|
||||
displayName: 'Return All',
|
||||
name: 'returnAll',
|
||||
type: 'boolean',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'getAll',
|
||||
],
|
||||
},
|
||||
},
|
||||
default: false,
|
||||
description: 'If all results should be returned or only up to a given limit.',
|
||||
},
|
||||
{
|
||||
displayName: 'Limit',
|
||||
name: 'limit',
|
||||
type: 'number',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'getAll',
|
||||
],
|
||||
returnAll: [
|
||||
false,
|
||||
],
|
||||
},
|
||||
},
|
||||
typeOptions: {
|
||||
minValue: 1,
|
||||
maxValue: 10,
|
||||
},
|
||||
default: 5,
|
||||
description: 'How many results to return.',
|
||||
},
|
||||
{
|
||||
displayName: 'Options',
|
||||
name: 'options',
|
||||
type: 'collection',
|
||||
placeholder: 'Add Option',
|
||||
default: {},
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'getAll',
|
||||
],
|
||||
},
|
||||
},
|
||||
options: [
|
||||
{
|
||||
displayName: 'Term',
|
||||
name: 'term',
|
||||
type: 'string',
|
||||
default: '',
|
||||
description: 'A string used to search all the organizations in your team’s address book. This could be an email address, a first name or a last name.',
|
||||
},
|
||||
{
|
||||
displayName: 'With Interaction Dates',
|
||||
name: 'withInteractionDates',
|
||||
type: 'boolean',
|
||||
default: false,
|
||||
description: 'When true, interaction dates will be present on the returned resources.',
|
||||
},
|
||||
]
|
||||
},
|
||||
/* -------------------------------------------------------------------------- */
|
||||
/* organization:delete */
|
||||
/* -------------------------------------------------------------------------- */
|
||||
{
|
||||
displayName: 'Organization ID',
|
||||
name: 'organizationId',
|
||||
type: 'string',
|
||||
required: true,
|
||||
default: '',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'organization',
|
||||
],
|
||||
operation: [
|
||||
'delete',
|
||||
]
|
||||
},
|
||||
},
|
||||
description: 'Unique identifier for the organization.',
|
||||
},
|
||||
] as INodeProperties[];
|
|
@ -0,0 +1,6 @@
|
|||
|
||||
export interface IOrganization {
|
||||
name?: string;
|
||||
domain?: string;
|
||||
person_ids?: number[];
|
||||
}
|
370
packages/nodes-base/nodes/Affinity/PersonDescription.ts
Normal file
370
packages/nodes-base/nodes/Affinity/PersonDescription.ts
Normal file
|
@ -0,0 +1,370 @@
|
|||
import { INodeProperties } from 'n8n-workflow';
|
||||
|
||||
export const personOperations = [
|
||||
{
|
||||
displayName: 'Operation',
|
||||
name: 'operation',
|
||||
type: 'options',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
},
|
||||
},
|
||||
options: [
|
||||
{
|
||||
name: 'Create',
|
||||
value: 'create',
|
||||
description: 'Create a person',
|
||||
},
|
||||
{
|
||||
name: 'Delete',
|
||||
value: 'delete',
|
||||
description: 'Delete a person',
|
||||
},
|
||||
{
|
||||
name: 'Get',
|
||||
value: 'get',
|
||||
description: 'Get a person',
|
||||
},
|
||||
{
|
||||
name: 'Get All',
|
||||
value: 'getAll',
|
||||
description: 'Get all persons',
|
||||
},
|
||||
{
|
||||
name: 'Update',
|
||||
value: 'update',
|
||||
description: 'Update a person',
|
||||
},
|
||||
],
|
||||
default: 'create',
|
||||
description: 'The operation to perform.',
|
||||
},
|
||||
] as INodeProperties[];
|
||||
|
||||
export const personFields = [
|
||||
|
||||
/* -------------------------------------------------------------------------- */
|
||||
/* person:create */
|
||||
/* -------------------------------------------------------------------------- */
|
||||
{
|
||||
displayName: 'Fist Name',
|
||||
name: 'firstName',
|
||||
type: 'string',
|
||||
required: true,
|
||||
default: '',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'create',
|
||||
]
|
||||
},
|
||||
},
|
||||
description: 'The first name of the person.',
|
||||
},
|
||||
{
|
||||
displayName: 'Last Name',
|
||||
name: 'lastName',
|
||||
type: 'string',
|
||||
required: true,
|
||||
default: '',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'create',
|
||||
]
|
||||
},
|
||||
},
|
||||
description: 'The last name of the person.',
|
||||
},
|
||||
{
|
||||
displayName: 'Additional Fields',
|
||||
name: 'additionalFields',
|
||||
type: 'collection',
|
||||
placeholder: 'Add Field',
|
||||
default: {},
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'create',
|
||||
],
|
||||
},
|
||||
},
|
||||
options: [
|
||||
{
|
||||
displayName: 'Organizations',
|
||||
name: 'organizations',
|
||||
type: 'multiOptions',
|
||||
typeOptions: {
|
||||
loadOptionsMethod: 'getOrganizations',
|
||||
},
|
||||
default: [],
|
||||
description: 'Organizations that the person is associated with.',
|
||||
},
|
||||
],
|
||||
},
|
||||
{
|
||||
displayName: 'Emails',
|
||||
name: 'emails',
|
||||
type: 'string',
|
||||
description: 'The email addresses of the person',
|
||||
typeOptions: {
|
||||
multipleValues: true,
|
||||
multipleValueButtonText: 'Add To Email',
|
||||
},
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'create',
|
||||
]
|
||||
},
|
||||
},
|
||||
placeholder: 'info@example.com',
|
||||
default: [],
|
||||
},
|
||||
/* -------------------------------------------------------------------------- */
|
||||
/* person:update */
|
||||
/* -------------------------------------------------------------------------- */
|
||||
{
|
||||
displayName: 'Person ID',
|
||||
name: 'personId',
|
||||
type: 'string',
|
||||
required: true,
|
||||
default: '',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'update',
|
||||
]
|
||||
},
|
||||
},
|
||||
description: 'Unique identifier for the person.',
|
||||
},
|
||||
{
|
||||
displayName: 'Update Fields',
|
||||
name: 'updateFields',
|
||||
type: 'collection',
|
||||
placeholder: 'Add Field',
|
||||
default: {},
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'update',
|
||||
],
|
||||
},
|
||||
},
|
||||
options: [
|
||||
{
|
||||
displayName: 'Fist Name',
|
||||
name: 'firstName',
|
||||
type: 'string',
|
||||
default: '',
|
||||
description: 'The first name of the person.',
|
||||
},
|
||||
{
|
||||
displayName: 'Last Name',
|
||||
name: 'lastName',
|
||||
type: 'string',
|
||||
default: '',
|
||||
description: 'The last name of the person.',
|
||||
},
|
||||
{
|
||||
displayName: 'Organizations',
|
||||
name: 'organizations',
|
||||
type: 'multiOptions',
|
||||
typeOptions: {
|
||||
loadOptionsMethod: 'getOrganizations',
|
||||
},
|
||||
default: [],
|
||||
description: 'Organizations that the person is associated with.',
|
||||
},
|
||||
]
|
||||
},
|
||||
{
|
||||
displayName: 'Emails',
|
||||
name: 'emails',
|
||||
type: 'string',
|
||||
description: 'The email addresses of the person',
|
||||
typeOptions: {
|
||||
multipleValues: true,
|
||||
multipleValueButtonText: 'Add To Email',
|
||||
},
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'update',
|
||||
]
|
||||
},
|
||||
},
|
||||
placeholder: 'info@example.com',
|
||||
default: [],
|
||||
},
|
||||
/* -------------------------------------------------------------------------- */
|
||||
/* person:get */
|
||||
/* -------------------------------------------------------------------------- */
|
||||
{
|
||||
displayName: 'Person ID',
|
||||
name: 'personId',
|
||||
type: 'string',
|
||||
required: true,
|
||||
default: '',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'get',
|
||||
]
|
||||
},
|
||||
},
|
||||
description: 'Unique identifier for the person.',
|
||||
},
|
||||
{
|
||||
displayName: 'Options',
|
||||
name: 'options',
|
||||
type: 'collection',
|
||||
placeholder: 'Add Option',
|
||||
default: {},
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'get',
|
||||
],
|
||||
},
|
||||
},
|
||||
options: [
|
||||
{
|
||||
displayName: 'With Interaction Dates',
|
||||
name: 'withInteractionDates',
|
||||
type: 'boolean',
|
||||
default: false,
|
||||
description: 'When true, interaction dates will be present on the returned resources.',
|
||||
},
|
||||
]
|
||||
},
|
||||
/* -------------------------------------------------------------------------- */
|
||||
/* person:getAll */
|
||||
/* -------------------------------------------------------------------------- */
|
||||
{
|
||||
displayName: 'Return All',
|
||||
name: 'returnAll',
|
||||
type: 'boolean',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'getAll',
|
||||
],
|
||||
},
|
||||
},
|
||||
default: false,
|
||||
description: 'If all results should be returned or only up to a given limit.',
|
||||
},
|
||||
{
|
||||
displayName: 'Limit',
|
||||
name: 'limit',
|
||||
type: 'number',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'getAll',
|
||||
],
|
||||
returnAll: [
|
||||
false,
|
||||
],
|
||||
},
|
||||
},
|
||||
typeOptions: {
|
||||
minValue: 1,
|
||||
maxValue: 10,
|
||||
},
|
||||
default: 5,
|
||||
description: 'How many results to return.',
|
||||
},
|
||||
{
|
||||
displayName: 'Options',
|
||||
name: 'options',
|
||||
type: 'collection',
|
||||
placeholder: 'Add Option',
|
||||
default: {},
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'getAll',
|
||||
],
|
||||
},
|
||||
},
|
||||
options: [
|
||||
{
|
||||
displayName: 'Term',
|
||||
name: 'term',
|
||||
type: 'string',
|
||||
default: '',
|
||||
description: 'A string used to search all the persons in your team’s address book. This could be an email address, a first name or a last name.',
|
||||
},
|
||||
{
|
||||
displayName: 'With Interaction Dates',
|
||||
name: 'withInteractionDates',
|
||||
type: 'boolean',
|
||||
default: false,
|
||||
description: 'When true, interaction dates will be present on the returned resources.',
|
||||
},
|
||||
]
|
||||
},
|
||||
/* -------------------------------------------------------------------------- */
|
||||
/* person:delete */
|
||||
/* -------------------------------------------------------------------------- */
|
||||
{
|
||||
displayName: 'Person ID',
|
||||
name: 'personId',
|
||||
type: 'string',
|
||||
required: true,
|
||||
default: '',
|
||||
displayOptions: {
|
||||
show: {
|
||||
resource: [
|
||||
'person',
|
||||
],
|
||||
operation: [
|
||||
'delete',
|
||||
]
|
||||
},
|
||||
},
|
||||
description: 'Unique identifier for the person.',
|
||||
},
|
||||
] as INodeProperties[];
|
7
packages/nodes-base/nodes/Affinity/PersonInterface.ts
Normal file
7
packages/nodes-base/nodes/Affinity/PersonInterface.ts
Normal file
|
@ -0,0 +1,7 @@
|
|||
|
||||
export interface IPerson {
|
||||
first_name?: string;
|
||||
last_name?: string;
|
||||
emails?: string[];
|
||||
organization_ids?: number[];
|
||||
}
|
BIN
packages/nodes-base/nodes/Affinity/affinity.png
Normal file
BIN
packages/nodes-base/nodes/Affinity/affinity.png
Normal file
Binary file not shown.
After Width: | Height: | Size: 6.3 KiB |
|
@ -32,6 +32,7 @@
|
|||
"dist/credentials/Amqp.credentials.js",
|
||||
"dist/credentials/AsanaApi.credentials.js",
|
||||
"dist/credentials/Aws.credentials.js",
|
||||
"dist/credentials/AffinityApi.credentials.js",
|
||||
"dist/credentials/BitbucketApi.credentials.js",
|
||||
"dist/credentials/BitlyApi.credentials.js",
|
||||
"dist/credentials/ChargebeeApi.credentials.js",
|
||||
|
@ -113,6 +114,8 @@
|
|||
"dist/nodes/Amqp/AmqpTrigger.node.js",
|
||||
"dist/nodes/Asana/Asana.node.js",
|
||||
"dist/nodes/Asana/AsanaTrigger.node.js",
|
||||
"dist/nodes/Affinity/Affinity.node.js",
|
||||
"dist/nodes/Affinity/AffinityTrigger.node.js",
|
||||
"dist/nodes/Aws/AwsLambda.node.js",
|
||||
"dist/nodes/Aws/AwsSes.node.js",
|
||||
"dist/nodes/Aws/AwsSns.node.js",
|
||||
|
@ -247,7 +250,7 @@
|
|||
"@types/moment-timezone": "^0.5.12",
|
||||
"@types/mongodb": "^3.3.6",
|
||||
"@types/node": "^10.10.1",
|
||||
"@types/nodemailer": "^4.6.5",
|
||||
"@types/nodemailer": "^4.6.5",
|
||||
"@types/redis": "^2.8.11",
|
||||
"@types/request-promise-native": "~1.0.15",
|
||||
"@types/uuid": "^3.4.6",
|
||||
|
|
Loading…
Reference in a new issue