import { OptionsWithUri, } from 'request'; import { IExecuteFunctions, IExecuteSingleFunctions, IHookFunctions, ILoadOptionsFunctions, IWebhookFunctions, } from 'n8n-core'; import { IDataObject, } from 'n8n-workflow'; export async function clickupApiRequest(this: IHookFunctions | IExecuteFunctions | IExecuteSingleFunctions | ILoadOptionsFunctions | IWebhookFunctions, method: string, resource: string, body: any = {}, qs: IDataObject = {}, uri?: string, option: IDataObject = {}): Promise { // tslint:disable-line:no-any const credentials = this.getCredentials('clickUpApi'); if (credentials === undefined) { throw new Error('No credentials got returned!'); } const options: OptionsWithUri = { headers: { Authorization: credentials.accessToken, 'Content-Type': 'application/json', }, method, qs, body, uri: uri ||`https://api.clickup.com/api/v2${resource}`, json: true }; try { return await this.helpers.request!(options); } catch (error) { let errorMessage = error; if (error.err) { errorMessage = error.err; } throw new Error('ClickUp Error: ' + errorMessage); } } export async function clickupApiRequestAllItems(this: IHookFunctions | IExecuteFunctions| ILoadOptionsFunctions, propertyName: string ,method: string, resource: string, body: any = {}, query: IDataObject = {}): Promise { // tslint:disable-line:no-any const returnData: IDataObject[] = []; let responseData; query.page = 0; do { responseData = await clickupApiRequest.call(this, method, resource, body, query); returnData.push.apply(returnData, responseData[propertyName]); query.page++; if (query.limit && query.limit <= returnData.length) { return returnData; } } while ( responseData[propertyName] && responseData[propertyName].length !== 0 ); return returnData; } export function validateJSON(json: string | undefined): any { // tslint:disable-line:no-any let result; try { result = JSON.parse(json!); } catch (exception) { result = undefined; } return result; }