✨ Shopify node

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

@@ -1,4 +1,6 @@
-import { OptionsWithUri } from 'request';
+import {
+	OptionsWithUri,
+ } from 'request';
 
 import {
 	IExecuteFunctions,
@@ -12,7 +14,11 @@ import {
 	IDataObject,
 } from 'n8n-workflow';
 
-export async function shopifyApiRequest(this: IHookFunctions | IExecuteFunctions | IExecuteSingleFunctions | ILoadOptionsFunctions, method: string, resource: string, body: any = {}, query?: IDataObject, uri?: string): Promise<any> { // tslint:disable-line:no-any
+import {
+	snakeCase,
+} from 'change-case';
+
+export async function shopifyApiRequest(this: IHookFunctions | IExecuteFunctions | IExecuteSingleFunctions | ILoadOptionsFunctions, method: string, resource: string, body: any = {}, query: IDataObject = {}, uri?: string, option: IDataObject = {}): Promise<any> { // tslint:disable-line:no-any
 	const credentials = this.getCredentials('shopifyApi');
 	if (credentials === undefined) {
 		throw new Error('No credentials got returned!');
@@ -28,15 +34,71 @@ export async function shopifyApiRequest(this: IHookFunctions | IExecuteFunctions
 		body,
 		json: true
 	};
-
+	if (Object.keys(option).length !== 0) {
+		Object.assign(options, option);
+	}
+	if (Object.keys(body).length ===  0) {
+		delete options.body;
+	}
+	if (Object.keys(query).length ===  0) {
+		delete options.qs;
+	}
 	try {
 		return await this.helpers.request!(options);
 	} catch (error) {
-		const errorMessage = error.response.body.message || error.response.body.Message;
-
-		if (errorMessage !== undefined) {
-			throw errorMessage;
+		if (error.response.body && error.response.body.errors) {
+			let message = '';
+			if (typeof error.response.body.errors === 'object') {
+				for (const key of Object.keys(error.response.body.errors)) {
+					message+= error.response.body.errors[key];
+				}
+			} else {
+				message = `${error.response.body.errors} |`;
+			}
+			const errorMessage = `Shopify error response [${error.statusCode}]: ${message}`;
+			throw new Error(errorMessage);
 		}
-		throw error.response.body;
+
+		throw error;
 	}
 }
+
+
+export async function shopifyApiRequestAllItems(this: IHookFunctions | IExecuteFunctions| ILoadOptionsFunctions, propertyName: string, method: string, resource: string, body: any = {}, query: IDataObject = {}): Promise<any> { // tslint:disable-line:no-any
+
+	const returnData: IDataObject[] = [];
+
+	let responseData;
+
+	let uri: string | undefined;
+
+	do {
+		responseData = await shopifyApiRequest.call(this, method, resource, body, query, uri, { resolveWithFullResponse: true });
+		if (responseData.headers.link) {
+			uri = responseData.headers['link'].split(';')[0].replace('<', '').replace('>','');
+		}
+		returnData.push.apply(returnData, responseData.body[propertyName]);
+	} while (
+		responseData.headers['link'] !== undefined &&
+		responseData.headers['link'].includes('rel="next"')
+	);
+	return returnData;
+}
+
+export function keysToSnakeCase(elements: IDataObject[] | IDataObject) : IDataObject[] {
+	if (elements === undefined) {
+		return [];
+	}
+	if (!Array.isArray(elements)) {
+		elements = [elements];
+	}
+	for (const element of elements) {
+		for (const key of Object.keys(element)) {
+			if (key !== snakeCase(key)) {
+				element[snakeCase(key)] = element[key];
+				delete element[key];
+			}
+		}
+	}
+	return elements;
+}