fix(Monday.com Node): Migrate to api 2023-10

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

@@ -1,4 +1,9 @@
-import type { ICredentialType, INodeProperties } from 'n8n-workflow';
+import type {
+	IAuthenticateGeneric,
+	ICredentialTestRequest,
+	ICredentialType,
+	INodeProperties,
+} from 'n8n-workflow';
 
 export class MondayComApi implements ICredentialType {
 	name = 'mondayComApi';
@@ -16,4 +21,27 @@ export class MondayComApi implements ICredentialType {
 			default: '',
 		},
 	];
+
+	authenticate: IAuthenticateGeneric = {
+		type: 'generic',
+		properties: {
+			headers: {
+				Authorization: '=Bearer {{$credentials.apiToken}}',
+			},
+		},
+	};
+
+	test: ICredentialTestRequest = {
+		request: {
+			headers: {
+				'API-Version': '2023-10',
+				'Content-Type': 'application/json',
+			},
+			baseURL: 'https://api.monday.com/v2',
+			method: 'POST',
+			body: JSON.stringify({
+				query: 'query { me { name }}',
+			}),
+		},
+	};
 }

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

@@ -14,34 +14,31 @@ import get from 'lodash/get';
 
 export async function mondayComApiRequest(
 	this: IExecuteFunctions | IWebhookFunctions | IHookFunctions | ILoadOptionsFunctions,
-
 	body: any = {},
 	option: IDataObject = {},
 ): Promise<any> {
 	const authenticationMethod = this.getNodeParameter('authentication', 0) as string;
 
-	const endpoint = 'https://api.monday.com/v2/';
-
 	let options: OptionsWithUri = {
 		headers: {
+			'API-Version': '2023-10',
 			'Content-Type': 'application/json',
 		},
 		method: 'POST',
 		body,
-		uri: endpoint,
+		uri: 'https://api.monday.com/v2/',
 		json: true,
 	};
+
 	options = Object.assign({}, options, option);
-	try {
-		if (authenticationMethod === 'accessToken') {
-			const credentials = await this.getCredentials('mondayComApi');
 
-			options.headers = { Authorization: `Bearer ${credentials.apiToken}` };
+	try {
+		let credentialType = 'mondayComApi';
 
-			return await this.helpers.request(options);
-		} else {
-			return await this.helpers.requestOAuth2.call(this, 'mondayComOAuth2Api', options);
+		if (authenticationMethod === 'oAuth2') {
+			credentialType = 'mondayComOAuth2Api';
 		}
+		return await this.helpers.requestWithAuthentication.call(this, credentialType, options);
 	} catch (error) {
 		throw new NodeApiError(this.getNode(), error as JsonObject);
 	}
@@ -50,7 +47,6 @@ export async function mondayComApiRequest(
 export async function mondayComApiRequestAllItems(
 	this: IHookFunctions | IExecuteFunctions | ILoadOptionsFunctions,
 	propertyName: string,
-
 	body: any = {},
 ): Promise<any> {
 	const returnData: IDataObject[] = [];
@@ -66,3 +62,41 @@ export async function mondayComApiRequestAllItems(
 	} while (get(responseData, propertyName).length > 0);
 	return returnData;
 }
+
+export async function mondayComApiPaginatedRequest(
+	this: IHookFunctions | IExecuteFunctions | ILoadOptionsFunctions,
+	itemsPath: string,
+	fieldsToReturn: string,
+	body: IDataObject = {},
+) {
+	const returnData: IDataObject[] = [];
+
+	const initialResponse = await mondayComApiRequest.call(this, body);
+	const data = get(initialResponse, itemsPath) as IDataObject;
+
+	if (data) {
+		returnData.push.apply(returnData, data.items as IDataObject[]);
+
+		let cursor: null | string = data.cursor as string;
+
+		while (cursor) {
+			const responseData = (
+				(await mondayComApiRequest.call(this, {
+					query: `query ( $cursor: String!) { next_items_page (cursor: $cursor, limit: 100) { cursor items ${fieldsToReturn} } }`,
+					variables: {
+						cursor,
+					},
+				})) as IDataObject
+			).data as { next_items_page: { cursor: string; items: IDataObject[] } };
+
+			if (responseData && responseData.next_items_page) {
+				returnData.push.apply(returnData, responseData.next_items_page.items);
+				cursor = responseData.next_items_page.cursor;
+			} else {
+				cursor = null;
+			}
+		}
+	}
+
+	return returnData;
+}