✨ Added Adalo node using declarative API.

packages/nodes-base/credentials/AdaloApi.credentials.ts

@@ -0,0 +1,32 @@
+import {
+	IAuthenticateBearer,
+	ICredentialType,
+	INodeProperties,
+} from 'n8n-workflow';
+
+export class AdaloApi implements ICredentialType {
+	name = 'adaloApi';
+	displayName = 'Adalo API';
+	documentationUrl = 'adalo';
+	properties: INodeProperties[] = [
+		{
+			displayName: 'API Token',
+			name: 'apiToken',
+			type: 'string',
+			default: '',
+		},
+		{
+			displayName: 'Application ID',
+			name: 'appId',
+			type: 'string',
+			default: '',
+		},
+	];
+
+	authenticate = {
+		type: 'bearer',
+		properties: {
+			tokenPropertyName: 'apiToken',
+		},
+	} as IAuthenticateBearer;
+}

packages/nodes-base/nodes/Adalo/Adalo.node.json

@@ -0,0 +1,20 @@
+{
+	"node": "n8n-nodes-base.adalo",
+	"nodeVersion": "1.0",
+	"codexVersion": "1.0",
+	"categories": [
+		"Data & Storage"
+	],
+	"resources": {
+		"credentialDocumentation": [
+			{
+				"url": "https://docs.n8n.io/credentials/adalo"
+			}
+		],
+		"primaryDocumentation": [
+			{
+				"url": "https://docs.n8n.io/nodes/n8n-nodes-base.adalo/"
+			}
+		]
+	}
+}

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

@@ -0,0 +1,198 @@
+import {
+	IDataObject,
+	IExecuteSingleFunctions,
+	IHttpRequestOptions,
+	IN8nHttpFullResponse,
+	INodeExecutionData,
+	INodeType,
+	INodeTypeDescription,
+} from 'n8n-workflow';
+import {operationFields} from './OperationDescription';
+import {FieldsUiValues} from './types';
+
+export class Adalo implements INodeType {
+	async presendCreateUpdate (this: IExecuteSingleFunctions, requestOptions: IHttpRequestOptions): Promise<IHttpRequestOptions>  {
+		const dataToSend = this.getNodeParameter('dataToSend', 0) as 'defineBelow' | 'autoMapInputData';
+
+		requestOptions.body = {};
+
+		if (dataToSend === 'autoMapInputData') {
+			const inputData = this.getInputData();
+			const rawInputsToIgnore = this.getNodeParameter('inputsToIgnore') as string;
+
+			const inputKeysToIgnore = rawInputsToIgnore.split(',').map(c => c.trim());
+			const inputKeys = Object.keys(inputData.json)
+				.filter((key) => !inputKeysToIgnore.includes(key));
+
+			for (const key of inputKeys) {
+				(requestOptions.body as IDataObject)[key] = inputData.json[key];
+			}
+		} else {
+			const fields = this.getNodeParameter('fieldsUi.fieldValues') as FieldsUiValues;
+
+			for (const field of fields) {
+				(requestOptions.body as IDataObject)[field.fieldId] = field.fieldValue;
+			}
+		}
+
+		return requestOptions;
+	}
+
+	description: INodeTypeDescription = {
+		displayName: 'Adalo',
+		name: 'adalo',
+		icon: 'file:adalo.svg',
+		group: ['transform'],
+		version: 1,
+		subtitle: '={{$parameter["operation"] + ": " + $parameter["resource"]}}',
+		description: 'Consume Adalo API',
+		defaults: {
+			name: 'Adalo',
+			color: '#4f44d7',
+		},
+		inputs: ['main'],
+		outputs: ['main'],
+		credentials: [
+			{
+				name: 'adaloApi',
+				required: true,
+
+				// @TODO FInd a proper way to test credentials
+				testedBy: {
+					request: {
+						method: 'GET',
+						url: '/',
+					},
+					rules: [
+						{
+							type: 'responseCode',
+							properties: {
+								value: 403,
+								message: 'Does not exist.',
+							},
+						},
+					],
+				},
+			},
+		],
+		requestDefaults: {
+			baseURL: '=https://api.adalo.com/v0/apps/{{$credentials.appId}}',
+		},
+		requestOperations: {
+			pagination: {
+				type: 'offset',
+				properties: {
+					limitParameter: 'limit',
+					offsetParameter: 'offset',
+					pageSize: 100,
+					rootProperty: '',
+					type: 'query',
+				},
+			},
+		},
+		properties: [
+			{
+				displayName: 'Resource',
+				name: 'resource',
+				type: 'string',
+				required: true,
+				default: '',
+				description: 'Your Adalo collection ID',
+			},
+			{
+				displayName: 'Operation',
+				name: 'operation',
+				type: 'options',
+				options: [
+					{
+						name: 'Create',
+						value: 'create',
+						description: 'Create a row',
+						routing: {
+							send: {
+								preSend: [
+									this.presendCreateUpdate,
+								],
+							},
+							request: {
+								method: 'POST',
+								url: '=/collections/{{$parameter["resource"]}}',
+							},
+						},
+					},
+					{
+						name: 'Delete',
+						value: 'delete',
+						description: 'Delete a row',
+						routing: {
+							request: {
+								method: 'DELETE',
+								url: '=/collections/{{$parameter["resource"]}}/{{$parameter["rowId"]}}',
+							},
+							output: {
+								postReceive: [
+									{
+										type: 'set',
+										properties: {
+											value: '={{ { "success": true } }}',
+										},
+									},
+								],
+							},
+						},
+					},
+					{
+						name: 'Get',
+						value: 'get',
+						description: 'Retrieve a row',
+						routing: {
+							request: {
+								method: 'GET',
+								url: '=/collections/{{$parameter["resource"]}}/{{$parameter["rowId"]}}',
+							},
+						},
+					},
+					{
+						name: 'Get All',
+						value: 'getAll',
+						description: 'Retrieve all rows',
+						routing: {
+							request: {
+								method: 'GET',
+								url: '=/collections/{{$parameter["resource"]}}',
+							},
+							output: {
+								postReceive: [
+									async function (this: IExecuteSingleFunctions, items: INodeExecutionData[], response: IN8nHttpFullResponse,): Promise<INodeExecutionData[]> {
+										const { records } = response.body as { records: IDataObject[] };
+
+										return [...records.map((json) => ({ json }))];
+									},
+								],
+							},
+						},
+					},
+					{
+						name: 'Update',
+						value: 'update',
+						description: 'Update a row',
+						routing: {
+							send: {
+								preSend: [
+									this.presendCreateUpdate,
+								],
+							},
+							request: {
+								method: 'PUT',
+								url: '=/collections/{{$parameter["resource"]}}/{{$parameter["rowId"]}}',
+							},
+						},
+					},
+				],
+				default: 'getAll',
+			},
+			...operationFields,
+		],
+	};
+
+}