✨ Add list and list-entry resources to Affinity Node (#1387)

packages/nodes-base/nodes/Affinity/Affinity.node.ts

@@ -1,6 +1,7 @@
 import {
 	IExecuteFunctions,
 } from 'n8n-core';
+
 import {
 	IDataObject,
 	ILoadOptionsFunctions,
@@ -9,27 +10,40 @@ import {
 	INodeType,
 	INodeTypeDescription,
 } from 'n8n-workflow';
+
 import {
 	affinityApiRequest,
 	affinityApiRequestAllItems,
 } from './GenericFunctions';
+
 import {
 	organizationFields,
 	organizationOperations,
 } from './OrganizationDescription';
+
 import {
 	personFields,
 	personOperations,
 } from './PersonDescription';
+
+import {
+	listFields,
+	listOperations,
+} from './ListDescription';
+
+import {
+	listEntryFields,
+	listEntryOperations,
+} from './ListEntryDescription';
+
 import {
 	IOrganization,
 } from './OrganizationInterface';
+
 import {
 	IPerson,
 } from './PersonInterface';
 
-import { snakeCase } from 'change-case';
-
 export class Affinity implements INodeType {
 	description: INodeTypeDescription = {
 		displayName: 'Affinity',
@@ -57,6 +71,14 @@ export class Affinity implements INodeType {
 				name: 'resource',
 				type: 'options',
 				options: [
+					{
+						name: 'List',
+						value: 'list',
+					},
+					{
+						name: 'List Entry',
+						value: 'listEntry',
+					},
 					{
 						name: 'Organization',
 						value: 'organization',
@@ -69,6 +91,10 @@ export class Affinity implements INodeType {
 				default: 'organization',
 				description: 'Resource to consume.',
 			},
+			...listOperations,
+			...listFields,
+			...listEntryOperations,
+			...listEntryFields,
 			...organizationOperations,
 			...organizationFields,
 			...personOperations,
@@ -101,7 +127,7 @@ export class Affinity implements INodeType {
 				for (const person of persons) {
 					let personName = `${person.first_name} ${person.last_name}`;
 					if (person.primary_email !== null) {
-						personName+= ` (${person.primary_email})`;
+						personName += ` (${person.primary_email})`;
 					}
 					const personId = person.id;
 					returnData.push({
@@ -111,6 +137,19 @@ export class Affinity implements INodeType {
 				}
 				return returnData;
 			},
+			// Get all the available lists to display them to user so that he can
+			// select them easily
+			async getLists(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
+				const returnData: INodePropertyOptions[] = [];
+				const lists = await affinityApiRequest.call(this, 'GET', `/lists`);
+				for (const list of lists) {
+					returnData.push({
+						name: list.name,
+						value: list.id,
+					});
+				}
+				return returnData;
+			},
 		},
 	};
 
@@ -123,6 +162,59 @@ export class Affinity implements INodeType {
 		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 === 'list') {
+				//https://api-docs.affinity.co/#get-a-specific-list
+				if (operation === 'get') {
+					const listId = this.getNodeParameter('listId', i) as string;
+					responseData = await affinityApiRequest.call(this, 'GET', `/lists/${listId}`, {}, qs);
+				}
+				//https://api-docs.affinity.co/#get-all-lists
+				if (operation === 'getAll') {
+					const returnAll = this.getNodeParameter('returnAll', i) as boolean;
+					responseData = await affinityApiRequest.call(this, 'GET', `/lists`, {}, qs);
+					if (returnAll === false) {
+						const limit = this.getNodeParameter('limit', i) as number;
+						responseData = responseData.splice(0, limit);
+					}
+				}
+			}
+			if (resource === 'listEntry') {
+				//https://api-docs.affinity.co/#create-a-new-list-entry
+				if (operation === 'create') {
+					const listId = this.getNodeParameter('listId', i) as string;
+					const entityId = this.getNodeParameter('entityId', i) as string;
+					const additionalFields = this.getNodeParameter('additionalFields', i) as IDataObject;
+					const body: IDataObject = {
+						entity_id: parseInt(entityId, 10),
+					};
+					Object.assign(body, additionalFields);
+					responseData = await affinityApiRequest.call(this, 'POST', `/lists/${listId}/list-entries`, body);
+				}
+				//https://api-docs.affinity.co/#get-a-specific-list-entry
+				if (operation === 'get') {
+					const listId = this.getNodeParameter('listId', i) as string;
+					const listEntryId = this.getNodeParameter('listEntryId', i) as string;
+					responseData = await affinityApiRequest.call(this, 'GET', `/lists/${listId}/list-entries/${listEntryId}`, {}, qs);
+				}
+				//https://api-docs.affinity.co/#get-all-list-entries
+				if (operation === 'getAll') {
+					const returnAll = this.getNodeParameter('returnAll', i) as boolean;
+					const listId = this.getNodeParameter('listId', i) as string;
+					if (returnAll === true) {
+						responseData = await affinityApiRequestAllItems.call(this, 'list_entries', 'GET', `/lists/${listId}/list-entries`, {}, qs);
+					} else {
+						qs.page_size = this.getNodeParameter('limit', i) as number;
+						responseData = await affinityApiRequest.call(this, 'GET', `/lists/${listId}/list-entries`, {}, qs);
+						responseData = responseData.list_entries;
+					}
+				}
+				//https://api-docs.affinity.co/#delete-a-specific-list-entry
+				if (operation === 'delete') {
+					const listId = this.getNodeParameter('listId', i) as string;
+					const listEntryId = this.getNodeParameter('listEntryId', i) as string;
+					responseData = await affinityApiRequest.call(this, 'DELETE', `/lists/${listId}/list-entries/${listEntryId}`, {}, qs);
+				}
+			}
 			if (resource === 'person') {
 				//https://api-docs.affinity.co/#create-a-new-person
 				if (operation === 'create') {
@@ -166,7 +258,7 @@ export class Affinity implements INodeType {
 					if (options.withInteractionDates) {
 						qs.with_interaction_dates = options.withInteractionDates as boolean;
 					}
-					responseData = await affinityApiRequest.call(this,'GET', `/persons/${personId}`, {}, qs);
+					responseData = await affinityApiRequest.call(this, 'GET', `/persons/${personId}`, {}, qs);
 				}
 				//https://api-docs.affinity.co/#search-for-persons
 				if (operation === 'getAll') {
@@ -230,7 +322,7 @@ export class Affinity implements INodeType {
 					if (options.withInteractionDates) {
 						qs.with_interaction_dates = options.withInteractionDates as boolean;
 					}
-					responseData = await affinityApiRequest.call(this,'GET', `/organizations/${organizationId}`, {}, qs);
+					responseData = await affinityApiRequest.call(this, 'GET', `/organizations/${organizationId}`, {}, qs);
 				}
 				//https://api-docs.affinity.co/#search-for-organizations
 				if (operation === 'getAll') {