✨ Add Emelia nodes (#1455)

* Emelia node added

* Minor improvements on Emelia nodes

* Fix nodes and credentials listing

* Fix multi-line imports

* Apply cosmetic changes to node description

* Apply cosmetic changes to node execute method

* Fix linting details

* Apply cosmetic changes to trigger node

* Replace PNG with SVG icon

* Bring generic functions in line with codebase

* Refactor resources and add operations

* Fix typo in GraphQL call function

* Add campaign description

* Add contact list description

* ⚡ Improvements

* ⚡ Minor improvements to Emelia Nodes

Co-authored-by: Charles LECALIER <clecalie@student.42.fr>
Co-authored-by: ricardo <ricardoespinoza105@gmail.com>
Co-authored-by: Jan Oberhauser <jan.oberhauser@gmail.com>

packages/nodes-base/nodes/Emelia/EmeliaTrigger.node.ts

@@ -0,0 +1,180 @@
+import {
+	IHookFunctions,
+	ILoadOptionsFunctions,
+	INodePropertyOptions,
+	INodeType,
+	INodeTypeDescription,
+	IWebhookFunctions,
+	IWebhookResponseData,
+} from 'n8n-workflow';
+
+import {
+	emeliaApiRequest,
+	emeliaGraphqlRequest,
+} from './GenericFunctions';
+
+interface Campaign {
+	_id: string;
+	name: string;
+}
+
+export class EmeliaTrigger implements INodeType {
+	description: INodeTypeDescription = {
+		displayName: 'Emelia Trigger',
+		name: 'emeliaTrigger',
+		icon: 'file:emelia.svg',
+		group: ['trigger'],
+		version: 1,
+		description: 'Handle Emelia campaign activity events via webhooks',
+		defaults: {
+			name: 'Emelia Trigger',
+			color: '#e18063',
+		},
+		inputs: [],
+		outputs: ['main'],
+		credentials: [
+			{
+				name: 'emeliaApi',
+				required: true,
+			},
+		],
+		webhooks: [
+			{
+				name: 'default',
+				httpMethod: 'POST',
+				responseMode: 'onReceived',
+				path: 'webhook',
+			},
+		],
+		properties: [
+			{
+				displayName: 'Campaign',
+				name: 'campaignId',
+				type: 'options',
+				typeOptions: {
+					loadOptionsMethod: 'getCampaigns',
+				},
+				required: true,
+				default: '',
+			},
+			{
+				displayName: 'Events',
+				name: 'events',
+				type: 'multiOptions',
+				required: true,
+				default: [],
+				options: [
+					{
+						name: 'Email Bounced',
+						value: 'bounced',
+					},
+					{
+						name: 'Email Opened',
+						value: 'opened',
+					},
+					{
+						name: 'Email Replied',
+						value: 'replied',
+					},
+					{
+						name: 'Email Sent',
+						value: 'sent',
+					},
+					{
+						name: 'Link Clicked',
+						value: 'clicked',
+					},
+					{
+						name: 'Unsubscribed Contact',
+						value: 'unsubscribed',
+					},
+				],
+			},
+		],
+	};
+
+	methods = {
+		loadOptions: {
+			async getCampaigns(this: ILoadOptionsFunctions): Promise<INodePropertyOptions[]> {
+				const responseData = await emeliaGraphqlRequest.call(this, {
+					query: `
+					query GetCampaigns {
+						campaigns {
+							_id
+							name
+						}
+					}`,
+					operationName: 'GetCampaigns',
+					variables: '{}',
+				});
+
+				return responseData.data.campaigns.map(
+					(campaign: Campaign) => ({
+						name: campaign.name,
+						value: campaign._id,
+					}),
+				);
+			},
+		},
+	};
+
+	webhookMethods = {
+		default: {
+			async checkExists(this: IHookFunctions): Promise<boolean> {
+				const webhookUrl = this.getNodeWebhookUrl('default') as string;
+				const campaignId = this.getNodeParameter('campaignId') as string;
+				const { webhooks } = await emeliaApiRequest.call(this, 'GET', '/webhook');
+				for (const webhook of webhooks) {
+					if (webhook.url === webhookUrl && webhook.campaignId === campaignId) {
+						return true;
+					}
+				}
+
+				return false;
+			},
+			async create(this: IHookFunctions): Promise<boolean> {
+				const webhookUrl = this.getNodeWebhookUrl('default') as string;
+				const webhookData = this.getWorkflowStaticData('node');
+				const events = this.getNodeParameter('events') as string[];
+
+				const campaignId = this.getNodeParameter('campaignId') as string;
+				const body = {
+					hookUrl: webhookUrl,
+					events: events.map(e => e.toUpperCase()),
+					campaignId,
+				};
+
+				const { webhookId } = await emeliaApiRequest.call(this, 'POST', '/webhook/webhook', body);
+				webhookData.webhookId = webhookId;
+				return true;
+			},
+			async delete(this: IHookFunctions): Promise<boolean> {
+				const webhookData = this.getWorkflowStaticData('node');
+				const webhookUrl = this.getNodeWebhookUrl('default') as string;
+				const campaignId = this.getNodeParameter('campaignId') as string;
+
+				try {
+					const body = {
+						hookUrl: webhookUrl,
+						campaignId,
+					};
+					await emeliaApiRequest.call(this, 'DELETE', '/webhook/webhook', body);
+				} catch (error) {
+					return false;
+				}
+
+				delete webhookData.webhookId;
+				return true;
+			},
+		},
+	};
+
+	async webhook(this: IWebhookFunctions): Promise<IWebhookResponseData> {
+		const req = this.getRequestObject();
+		return {
+			workflowData: [
+				this.helpers.returnJsonArray(req.body),
+			],
+		};
+	}
+}