import { IExecuteFunctions, IHookFunctions, } from 'n8n-core'; import { IDataObject, NodeApiError, NodeOperationError, } from 'n8n-workflow'; import { OptionsWithUri, } from 'request'; /** * Make an authenticated or unauthenticated API request to Reddit. */ export async function redditApiRequest( this: IHookFunctions | IExecuteFunctions, method: string, endpoint: string, qs: IDataObject, ): Promise { // tslint:disable-line:no-any const resource = this.getNodeParameter('resource', 0) as string; const authRequired = ['profile', 'post', 'postComment'].includes(resource); qs.api_type = 'json'; const options: OptionsWithUri = { headers: { 'user-agent': 'n8n', }, method, uri: authRequired ? `https://oauth.reddit.com/${endpoint}` : `https://www.reddit.com/${endpoint}`, qs, json: true, }; if (!Object.keys(qs).length) { delete options.qs; } if (authRequired) { try { return await this.helpers.requestOAuth2.call(this, 'redditOAuth2Api', options); } catch (error) { throw new NodeApiError(this.getNode(), error); } } else { try { return await this.helpers.request.call(this, options); } catch (error) { throw new NodeApiError(this.getNode(), error); } } } /** * Make an unauthenticated API request to Reddit and return all results. */ export async function redditApiRequestAllItems( this: IHookFunctions | IExecuteFunctions, method: string, endpoint: string, qs: IDataObject, ): Promise { // tslint:disable-line:no-any let responseData; const returnData: IDataObject[] = []; const resource = this.getNodeParameter('resource', 0) as string; const operation = this.getNodeParameter('operation', 0) as string; const returnAll = this.getNodeParameter('returnAll', 0, false) as boolean; qs.limit = 100; do { responseData = await redditApiRequest.call(this, method, endpoint, qs); if (!Array.isArray(responseData)) { qs.after = responseData.data.after; } if (endpoint === 'api/search_subreddits.json') { responseData.subreddits.forEach((child: any) => returnData.push(child)); // tslint:disable-line:no-any } else if (resource === 'postComment' && operation === 'getAll') { responseData[1].data.children.forEach((child: any) => returnData.push(child.data)); // tslint:disable-line:no-any } else { responseData.data.children.forEach((child: any) => returnData.push(child.data)); // tslint:disable-line:no-any } if (qs.limit && returnData.length >= qs.limit && returnAll === false) { return returnData; } } while (responseData.data && responseData.data.after); return returnData; } /** * Handles a large Reddit listing by returning all items or up to a limit. */ export async function handleListing( this: IExecuteFunctions, i: number, endpoint: string, qs: IDataObject = {}, requestMethod: 'GET' | 'POST' = 'GET', ): Promise { // tslint:disable-line:no-any let responseData; const returnAll = this.getNodeParameter('returnAll', i); if (returnAll) { responseData = await redditApiRequestAllItems.call(this, requestMethod, endpoint, qs); } else { const limit = this.getNodeParameter('limit', i); qs.limit = limit; responseData = await redditApiRequestAllItems.call(this, requestMethod, endpoint, qs); responseData = responseData.slice(0, limit); } return responseData; }