mirror of
https://github.com/n8n-io/n8n.git
synced 2024-11-10 14:44:05 -08:00
82a254a8d9
* support for customer.io tracking api endpoint region selection If your account is based in our EU region use the EU endpoints (track-eu.customer.io) for US (other than EU) tracking endpoints (track.customer.io). * Changed name to keep constistency with other nodes * Switched to credentials injection * Add throwing error when unknow way of authenticating * Fixed url for http request * Add hint to region field about being omited with http node * Fix bug for credentials working with http node * Improve IF by deduplicating code Co-authored-by: h4ux <alon@h4ux.com> Co-authored-by: Omar Ajoue <krynble@gmail.com>
73 lines
1.9 KiB
TypeScript
73 lines
1.9 KiB
TypeScript
import {
|
|
ICredentialDataDecryptedObject,
|
|
ICredentialType,
|
|
IHttpRequestOptions,
|
|
INodeProperties,
|
|
} from 'n8n-workflow';
|
|
|
|
|
|
export class CustomerIoApi implements ICredentialType {
|
|
name = 'customerIoApi';
|
|
displayName = 'Customer.io API';
|
|
documentationUrl = 'customerIo';
|
|
properties: INodeProperties[] = [
|
|
{
|
|
displayName: 'Tracking API Key',
|
|
name: 'trackingApiKey',
|
|
type: 'string',
|
|
default: '',
|
|
description: 'Required for tracking API',
|
|
required: true,
|
|
},
|
|
{
|
|
displayName: 'Region',
|
|
name: 'region',
|
|
type: 'options',
|
|
options: [
|
|
{
|
|
name: 'EU region',
|
|
value: 'track-eu.customer.io',
|
|
},
|
|
{
|
|
name: 'Global region',
|
|
value: 'track.customer.io',
|
|
},
|
|
],
|
|
default: 'track.customer.io',
|
|
description: 'Should be set based on your account region',
|
|
hint: 'The region will be omited when being used with the HTTP node',
|
|
required: true,
|
|
},
|
|
{
|
|
displayName: 'Tracking Site ID',
|
|
name: 'trackingSiteId',
|
|
type: 'string',
|
|
default: '',
|
|
description: 'Required for tracking API',
|
|
},
|
|
{
|
|
displayName: 'App API Key',
|
|
name: 'appApiKey',
|
|
type: 'string',
|
|
default: '',
|
|
description: 'Required for App API',
|
|
},
|
|
];
|
|
async authenticate(credentials: ICredentialDataDecryptedObject, requestOptions: IHttpRequestOptions): Promise<IHttpRequestOptions> {
|
|
// @ts-ignore
|
|
const url = requestOptions.url ? requestOptions.url : requestOptions.uri;
|
|
if (url.includes('track') || url.includes('api.customer.io')) {
|
|
const basicAuthKey = Buffer.from(`${credentials.trackingSiteId}:${credentials.trackingApiKey}`).toString('base64');
|
|
// @ts-ignore
|
|
Object.assign(requestOptions.headers, { 'Authorization': `Basic ${basicAuthKey}` });
|
|
} else if (url.includes('beta-api.customer.io')) {
|
|
// @ts-ignore
|
|
Object.assign(requestOptions.headers, { 'Authorization': `Bearer ${credentials.appApiKey as string}` });
|
|
} else {
|
|
throw new Error('Unknown way of authenticating');
|
|
}
|
|
|
|
return requestOptions;
|
|
}
|
|
}
|