✨ Airtable Trigger

packages/nodes-base/nodes/Airtable/AirtableTrigger.node.ts

@@ -0,0 +1,148 @@
+import {
+	IPollFunctions,
+} from 'n8n-core';
+
+import {
+	IDataObject,
+	INodeExecutionData,
+	INodeType,
+	INodeTypeDescription,
+} from 'n8n-workflow';
+
+import {
+	apiRequestAllItems,
+} from './GenericFunctions';
+
+import * as moment from 'moment';
+
+export class AirtableTrigger implements INodeType {
+	description: INodeTypeDescription = {
+		displayName: 'Airtable Trigger',
+		name: 'airtableTrigger',
+		icon: 'file:airtable.png',
+		group: ['trigger'],
+		version: 1,
+		description: 'Starts the workflow when Airtable events occur',
+		subtitle: '={{$parameter["event"]}}',
+		defaults: {
+			name: 'Airtable Trigger',
+			color: '#445599',
+		},
+		credentials: [
+			{
+				name: 'airtableApi',
+				required: true,
+			},
+		],
+		polling: true,
+		inputs: [],
+		outputs: ['main'],
+		properties: [
+			{
+				displayName: 'Base ID',
+				name: 'baseId',
+				type: 'string',
+				default: '',
+				required: true,
+			},
+			{
+				displayName: 'Table ID',
+				name: 'tableId',
+				type: 'string',
+				default: '',
+				required: true,
+			},			{
+				displayName: 'Trigger Field',
+				name: 'triggerField',
+				type: 'string',
+				default: '',
+				description: `A Created Time or Last Modified Time field that will be used to sort records. <br>
+				If you do not have a Created Time or Last Modified Time field in your schema, please create one,<br>
+				because without this field trigger will not work correctly.`,
+				required: true,
+			},
+			{
+				displayName: 'Additional Fields',
+				name: 'additionalFields',
+				type: 'collection',
+				placeholder: 'Add Field',
+				default: {},
+				options: [
+					{
+						displayName: 'Fields',
+						name: 'fields',
+						type: 'string',
+						default: '',
+						description: `Fields to be included in the response.<br>
+						Multiple ones can be set separated by comma. Example: name,id.<br>
+						By default just the trigger field will be included.`,
+					},
+					{
+						displayName: 'Formula',
+						name: 'formula',
+						type: 'string',
+						default: '',
+						description: '',
+					},
+					{
+						displayName: 'View ID',
+						name: 'viewId',
+						type: 'string',
+						default: '',
+						description: '',
+					},
+				],
+			},
+		],
+	};
+
+	async poll(this: IPollFunctions): Promise<INodeExecutionData[][] | null> {
+
+		const webhookData = this.getWorkflowStaticData('node');
+
+		const qs: IDataObject = {};
+
+		const additionalFields = this.getNodeParameter('additionalFields') as IDataObject;
+
+		const base = this.getNodeParameter('baseId') as string;
+
+		const table = this.getNodeParameter('tableId') as string;
+
+		const triggerField = this.getNodeParameter('triggerField') as string;
+
+		const endpoint = `${base}/${table}`;
+
+		const now = moment().utc().format();
+
+		const startDate = webhookData.lastTimeChecked as string || now;
+
+		const endDate = now;
+
+		qs['fields[]'] = [triggerField];
+
+		if (additionalFields.viewId) {
+			qs.view = additionalFields.viewId;
+		}
+
+		if (additionalFields.fields) {
+			qs['fields[]'] = (additionalFields.fields as string).split(',');
+		}
+
+		qs.filterByFormula = `IS_AFTER({${triggerField}}, DATETIME_PARSE("${startDate}", "YYYY-MM-DD HH:mm:ss"))`;
+
+		if (additionalFields.formula) {
+			qs.filterByFormula = `AND(${qs.filterByFormula}, ${additionalFields.formula})`;
+		}
+
+		const { records } = await apiRequestAllItems.call(this, 'GET', endpoint, {}, qs);
+
+		webhookData.lastTimeChecked = endDate;
+
+		if (Array.isArray(records) && records.length) {
+
+			return [this.helpers.returnJsonArray(records)];
+		}
+
+		return null;
+	}
+}

packages/nodes-base/nodes/Airtable/GenericFunctions.ts

@@ -5,7 +5,7 @@ import {
 } from 'n8n-core';
 
 import { OptionsWithUri } from 'request';
-import { IDataObject } from 'n8n-workflow';
+import { IDataObject, IPollFunctions } from 'n8n-workflow';
 
 
 /**
@@ -17,7 +17,7 @@ import { IDataObject } from 'n8n-workflow';
  * @param {object} body
  * @returns {Promise<any>}
  */
-export async function apiRequest(this: IHookFunctions | IExecuteFunctions | ILoadOptionsFunctions, method: string, endpoint: string, body: object, query?: IDataObject): Promise<any> { // tslint:disable-line:no-any
+export async function apiRequest(this: IHookFunctions | IExecuteFunctions | ILoadOptionsFunctions | IPollFunctions, method: string, endpoint: string, body: object, query?: IDataObject): Promise<any> { // tslint:disable-line:no-any
 	const credentials = this.getCredentials('airtableApi');
 
 	if (credentials === undefined) {
@@ -77,7 +77,7 @@ export async function apiRequest(this: IHookFunctions | IExecuteFunctions | ILoa
  * @param {IDataObject} [query]
  * @returns {Promise<any>}
  */
-export async function apiRequestAllItems(this: IHookFunctions | IExecuteFunctions, method: string, endpoint: string, body: IDataObject, query?: IDataObject): Promise<any> { // tslint:disable-line:no-any
+export async function apiRequestAllItems(this: IHookFunctions | IExecuteFunctions | IPollFunctions, method: string, endpoint: string, body: IDataObject, query?: IDataObject): Promise<any> { // tslint:disable-line:no-any
 
 	if (query === undefined) {
 		query = {};

packages/nodes-base/package.json

@@ -215,6 +215,7 @@
       "dist/nodes/ActiveCampaign/ActiveCampaignTrigger.node.js",
       "dist/nodes/AgileCrm/AgileCrm.node.js",
       "dist/nodes/Airtable/Airtable.node.js",
+      "dist/nodes/Airtable/AirtableTrigger.node.js",
       "dist/nodes/AcuityScheduling/AcuitySchedulingTrigger.node.js",
       "dist/nodes/Amqp/Amqp.node.js",
       "dist/nodes/Amqp/AmqpTrigger.node.js",