feat: Add Outlook Trigger Node (#8656)

Co-authored-by: Jonathan Bennetts <[email protected]>

packages/nodes-base/nodes/Microsoft/Outlook/MicrosoftOutlookTrigger.node.json

@@ -0,0 +1,19 @@
+{
+	"node": "n8n-nodes-base.microsoftOutlookTrigger",
+	"nodeVersion": "1.0",
+	"codexVersion": "1.0",
+	"categories": ["Communication"],
+	"resources": {
+		"credentialDocumentation": [
+			{
+				"url": "https://docs.n8n.io/credentials/microsoft"
+			}
+		],
+		"primaryDocumentation": [
+			{
+				"url": "https://docs.n8n.io/integrations/builtin/trigger-nodes/n8n-nodes-base.microsoftOutlookTrigger/"
+			}
+		]
+	},
+	"alias": ["email"]
+}

packages/nodes-base/nodes/Microsoft/Outlook/MicrosoftOutlookTrigger.node.ts

@@ -0,0 +1,97 @@
+import type {
+	IPollFunctions,
+	INodeExecutionData,
+	INodeType,
+	INodeTypeDescription,
+} from 'n8n-workflow';
+
+import { DateTime } from 'luxon';
+
+import { properties as messageProperties } from './trigger/MessageDescription';
+
+import { getPollResponse } from './trigger/GenericFunctions';
+import { loadOptions } from './v2/methods';
+
+export class MicrosoftOutlookTrigger implements INodeType {
+	description: INodeTypeDescription = {
+		displayName: 'Microsoft Outlook Trigger',
+		name: 'microsoftOutlookTrigger',
+		icon: 'file:outlook.svg',
+		group: ['trigger'],
+		version: 1,
+		description:
+			'Fetches emails from Microsoft Outlook and starts the workflow on specified polling intervals.',
+		subtitle: '={{"Microsoft Outlook Trigger"}}',
+		defaults: {
+			name: 'Microsoft Outlook Trigger',
+		},
+		credentials: [
+			{
+				name: 'microsoftOutlookOAuth2Api',
+				required: true,
+			},
+		],
+		polling: true,
+		inputs: [],
+		outputs: ['main'],
+		properties: [
+			{
+				displayName: 'Event',
+				name: 'event',
+				type: 'options',
+				default: 'messageReceived',
+				options: [
+					{
+						name: 'Message Received',
+						value: 'messageReceived',
+					},
+				],
+			},
+			...messageProperties,
+		],
+	};
+
+	methods = { loadOptions };
+
+	async poll(this: IPollFunctions): Promise<INodeExecutionData[][] | null> {
+		const webhookData = this.getWorkflowStaticData('node');
+		let responseData;
+
+		const now = DateTime.now().toISO();
+		const startDate = (webhookData.lastTimeChecked as string) || now;
+		const endDate = now;
+		try {
+			const pollStartDate = startDate;
+			const pollEndDate = endDate;
+
+			responseData = await getPollResponse.call(this, pollStartDate, pollEndDate);
+
+			if (!responseData?.length) {
+				webhookData.lastTimeChecked = endDate;
+				return null;
+			}
+		} catch (error) {
+			if (this.getMode() === 'manual' || !webhookData.lastTimeChecked) {
+				throw error;
+			}
+			const workflow = this.getWorkflow();
+			const node = this.getNode();
+			this.logger.error(
+				`There was a problem in '${node.name}' node in workflow '${workflow.id}': '${error.description}'`,
+				{
+					node: node.name,
+					workflowId: workflow.id,
+					error,
+				},
+			);
+		}
+
+		webhookData.lastTimeChecked = endDate;
+
+		if (Array.isArray(responseData) && responseData.length) {
+			return [responseData];
+		}
+
+		return null;
+	}
+}

packages/nodes-base/nodes/Microsoft/Outlook/trigger/GenericFunctions.ts

@@ -0,0 +1,85 @@
+import { NodeApiError } from 'n8n-workflow';
+import type { JsonObject, IDataObject, INodeExecutionData, IPollFunctions } from 'n8n-workflow';
+
+import {
+	downloadAttachments,
+	microsoftApiRequest,
+	microsoftApiRequestAllItems,
+} from '../v2/transport';
+
+import { prepareFilterString, simplifyOutputMessages } from '../v2/helpers/utils';
+
+export async function getPollResponse(
+	this: IPollFunctions,
+	pollStartDate: string,
+	pollEndDate: string,
+) {
+	let responseData;
+	const qs = {} as IDataObject;
+	try {
+		const filters = this.getNodeParameter('filters', {}) as IDataObject;
+		const options = this.getNodeParameter('options', {}) as IDataObject;
+		const output = this.getNodeParameter('output') as string;
+		if (output === 'fields') {
+			const fields = this.getNodeParameter('fields') as string[];
+
+			if (options.downloadAttachments) {
+				fields.push('hasAttachments');
+			}
+
+			qs.$select = fields.join(',');
+		}
+
+		if (output === 'simple') {
+			qs.$select =
+				'id,conversationId,subject,bodyPreview,from,toRecipients,categories,hasAttachments';
+		}
+
+		const filterString = prepareFilterString({ filters });
+
+		if (filterString) {
+			qs.$filter = filterString;
+		}
+
+		const endpoint = '/messages';
+		if (this.getMode() !== 'manual') {
+			if (qs.$filter) {
+				qs.$filter = `${qs.$filter} and receivedDateTime ge ${pollStartDate} and receivedDateTime lt ${pollEndDate}`;
+			} else {
+				qs.$filter = `receivedDateTime ge ${pollStartDate} and receivedDateTime lt ${pollEndDate}`;
+			}
+			responseData = await microsoftApiRequestAllItems.call(
+				this,
+				'value',
+				'GET',
+				endpoint,
+				undefined,
+				qs,
+			);
+		} else {
+			qs.$top = 1;
+			responseData = await microsoftApiRequest.call(this, 'GET', endpoint, undefined, qs);
+			responseData = responseData.value;
+		}
+
+		if (output === 'simple') {
+			responseData = simplifyOutputMessages(responseData as IDataObject[]);
+		}
+
+		let executionData: INodeExecutionData[] = [];
+
+		if (options.downloadAttachments) {
+			const prefix = (options.attachmentsPrefix as string) || 'attachment_';
+			executionData = await downloadAttachments.call(this, responseData as IDataObject[], prefix);
+		} else {
+			executionData = this.helpers.returnJsonArray(responseData as IDataObject[]);
+		}
+
+		return executionData;
+	} catch (error) {
+		throw new NodeApiError(this.getNode(), error as JsonObject, {
+			message: error.message,
+			description: error.description,
+		});
+	}
+}

packages/nodes-base/nodes/Microsoft/Outlook/trigger/MessageDescription.ts

@@ -0,0 +1,139 @@
+import type { INodeProperties } from 'n8n-workflow';
+import { messageFields } from '../v2/helpers/utils';
+
+export const properties: INodeProperties[] = [
+	{
+		displayName: 'Output',
+		name: 'output',
+		type: 'options',
+		default: 'simple',
+		options: [
+			{
+				name: 'Simplified',
+				value: 'simple',
+			},
+			{
+				name: 'Raw',
+				value: 'raw',
+			},
+			{
+				name: 'Select Included Fields',
+				value: 'fields',
+			},
+		],
+	},
+	{
+		displayName: 'Fields',
+		name: 'fields',
+		type: 'multiOptions',
+		description: 'The fields to add to the output',
+		displayOptions: {
+			show: {
+				output: ['fields'],
+			},
+		},
+		options: messageFields,
+		default: [],
+	},
+	{
+		displayName: 'Filters',
+		name: 'filters',
+		type: 'collection',
+		placeholder: 'Add Filter',
+		default: {},
+		options: [
+			{
+				displayName: 'Filter Query',
+				name: 'custom',
+				type: 'string',
+				default: '',
+				placeholder: 'e.g. isRead eq false',
+				hint: 'Search query to filter messages. <a href="https://learn.microsoft.com/en-us/graph/filter-query-parameter">More info</a>.',
+			},
+			{
+				displayName: 'Has Attachments',
+				name: 'hasAttachments',
+				type: 'boolean',
+				default: false,
+			},
+			{
+				displayName: 'Folders to Exclude',
+				name: 'foldersToExclude',
+				type: 'multiOptions',
+				typeOptions: {
+					loadOptionsMethod: 'getFolders',
+				},
+				default: [],
+				description:
+					'Choose from the list, or specify IDs using an <a href="https://docs.n8n.io/code-examples/expressions/">expression</a>',
+			},
+			{
+				displayName: 'Folders to Include',
+				name: 'foldersToInclude',
+				type: 'multiOptions',
+				typeOptions: {
+					loadOptionsMethod: 'getFolders',
+				},
+				default: [],
+				description:
+					'Choose from the list, or specify IDs using an <a href="https://docs.n8n.io/code-examples/expressions/">expression</a>',
+			},
+			{
+				displayName: 'Read Status',
+				name: 'readStatus',
+				type: 'options',
+				default: 'unread',
+				hint: 'Filter messages by whether they have been read or not',
+				options: [
+					{
+						// eslint-disable-next-line n8n-nodes-base/node-param-display-name-miscased
+						name: 'Unread and read messages',
+						value: 'both',
+					},
+					{
+						// eslint-disable-next-line n8n-nodes-base/node-param-display-name-miscased
+						name: 'Unread messages only',
+						value: 'unread',
+					},
+					{
+						// eslint-disable-next-line n8n-nodes-base/node-param-display-name-miscased
+						name: 'Read messages only',
+						value: 'read',
+					},
+				],
+			},
+			{
+				displayName: 'Sender',
+				name: 'sender',
+				type: 'string',
+				default: '',
+				description: 'Sender name or email to filter by',
+			},
+		],
+	},
+	{
+		displayName: 'Options',
+		name: 'options',
+		type: 'collection',
+		placeholder: 'Add Option',
+		default: {},
+		options: [
+			{
+				displayName: 'Attachments Prefix',
+				name: 'attachmentsPrefix',
+				type: 'string',
+				default: 'attachment_',
+				description:
+					'Prefix for name of the output fields to put the binary files data in. An index starting from 0 will be added. So if name is "attachment_" the first attachment is saved to "attachment_0".',
+			},
+			{
+				displayName: 'Download Attachments',
+				name: 'downloadAttachments',
+				type: 'boolean',
+				default: false,
+				description:
+					"Whether the message's attachments will be downloaded and included in the output",
+			},
+		],
+	},
+];

packages/nodes-base/nodes/Microsoft/Outlook/v2/helpers/utils.ts

@@ -3,6 +3,7 @@ import type {
 	IExecuteFunctions,
 	IExecuteSingleFunctions,
 	ILoadOptionsFunctions,
+	IPollFunctions,
 	JsonObject,
 } from 'n8n-workflow';
 import { ApplicationError, jsonParse, NodeApiError } from 'n8n-workflow';
@@ -278,7 +279,7 @@ export function prepareFilterString(filters: IDataObject) {
 }
 
 export function prepareApiError(
-	this: IExecuteFunctions | IExecuteSingleFunctions | ILoadOptionsFunctions,
+	this: IExecuteFunctions | IExecuteSingleFunctions | ILoadOptionsFunctions | IPollFunctions,
 	error: IDataObject,
 	itemIndex = 0,
 ) {