mirror of
https://github.com/n8n-io/n8n.git
synced 2024-11-10 22:54:05 -08:00
88 lines
2.5 KiB
TypeScript
88 lines
2.5 KiB
TypeScript
import {
|
|
IExecuteFunctions,
|
|
IHookFunctions,
|
|
ILoadOptionsFunctions,
|
|
} from 'n8n-core';
|
|
|
|
import {
|
|
OptionsWithUri,
|
|
} from 'request';
|
|
|
|
import {
|
|
IDataObject,
|
|
} from 'n8n-workflow';
|
|
|
|
import {
|
|
get,
|
|
} from 'lodash';
|
|
|
|
export async function customerIoApiRequest(this: IHookFunctions | IExecuteFunctions | ILoadOptionsFunctions, method: string, endpoint: string, body: object, baseApi?: string, query?: IDataObject): Promise<any> { // tslint:disable-line:no-any
|
|
const credentials = this.getCredentials('customerIoApi');
|
|
|
|
if (credentials === undefined) {
|
|
throw new Error('No credentials got returned!');
|
|
}
|
|
|
|
query = query || {};
|
|
|
|
const options: OptionsWithUri = {
|
|
headers: {
|
|
'Content-Type': 'application/json',
|
|
},
|
|
method,
|
|
body,
|
|
uri: '',
|
|
json: true,
|
|
};
|
|
|
|
if (baseApi === 'tracking') {
|
|
options.uri = `https://track.customer.io/api/v1${endpoint}`;
|
|
const basicAuthKey = Buffer.from(`${credentials.trackingSiteId}:${credentials.trackingApiKey}`).toString('base64');
|
|
Object.assign(options.headers, { 'Authorization': `Basic ${basicAuthKey}` });
|
|
} else if (baseApi === 'api') {
|
|
options.uri = `https://api.customer.io/v1/api${endpoint}`;
|
|
const basicAuthKey = Buffer.from(`${credentials.trackingSiteId}:${credentials.trackingApiKey}`).toString('base64');
|
|
Object.assign(options.headers, { 'Authorization': `Basic ${basicAuthKey}` });
|
|
} else if (baseApi === 'beta') {
|
|
options.uri = `https://beta-api.customer.io/v1/api${endpoint}`;
|
|
Object.assign(options.headers, { 'Authorization': `Bearer ${credentials.appApiKey as string}` });
|
|
}
|
|
|
|
try {
|
|
return await this.helpers.request!(options);
|
|
} catch (error) {
|
|
if (error.statusCode === 401) {
|
|
// Return a clear error
|
|
throw new Error('The Customer.io credentials are not valid!');
|
|
}
|
|
|
|
if (error.response && error.response.body && error.response.body.error_code) {
|
|
// Try to return the error prettier
|
|
const errorBody = error.response.body;
|
|
throw new Error(`Customer.io error response [${errorBody.error_code}]: ${errorBody.description}`);
|
|
}
|
|
|
|
// Expected error data did not get returned so throw the actual error
|
|
throw error;
|
|
}
|
|
}
|
|
|
|
export function eventExists(currentEvents: string[], webhookEvents: IDataObject) {
|
|
for (const currentEvent of currentEvents) {
|
|
if (get(webhookEvents, `${currentEvent.split('.')[0]}.${currentEvent.split('.')[1]}`) !== true) {
|
|
return false;
|
|
}
|
|
}
|
|
return true;
|
|
}
|
|
|
|
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;
|
|
}
|