N8N-4126 credentials injection and testing on specific nodes

packages/nodes-base/credentials/Aws.credentials.ts

@@ -1,4 +1,6 @@
-import { ICredentialType, INodeProperties } from 'n8n-workflow';
+import {Request, sign } from 'aws4';
+import { IHttpRequestMethods } from 'n8n-workflow';
+import { ICredentialDataDecryptedObject, ICredentialType, IDataObject, IHttpRequestOptions, INodeProperties } from 'n8n-workflow';
 
 export const regions = [
 	{
@@ -259,4 +261,64 @@ export class Aws implements ICredentialType {
 			placeholder: 'https://s3.{region}.amazonaws.com',
 		},
 	];
+
+
+	async authenticate(credentials: ICredentialDataDecryptedObject, requestOptions: IHttpRequestOptions): Promise<IHttpRequestOptions> {
+		let endpoint;
+		const service = requestOptions.qs?.service;
+		let path = requestOptions.qs?.path;
+		const method = requestOptions.method;
+		const body = requestOptions.body;
+		const region = credentials.region;
+		const query = requestOptions.qs?.query as IDataObject;
+
+		if (service === 'lambda' && credentials.lambdaEndpoint) {
+			endpoint = credentials.lambdaEndpoint;
+		} else if (service === 'sns' && credentials.snsEndpoint) {
+			endpoint = credentials.snsEndpoint;
+		} else if (service === 'sqs' && credentials.sqsEndpoint) {
+			endpoint = credentials.sqsEndpoint;
+		} else if (service === 's3' && credentials.s3Endpoint) {
+			endpoint = credentials.s3Endpoint;
+		}
+		else if (service === 'ses' && credentials.sesEndpoint) {
+			endpoint = credentials.sesEndpoint;
+		}
+		else if (service === 'rekognition' && credentials.rekognitionEndpoint) {
+			endpoint = credentials.rekognitionEndpoint;
+		}
+		else if (service === 'sqs' && credentials.sqsEndpoint) {
+			endpoint = credentials.sqsEndpoint;
+		}
+		else {
+			console.log('ERROR SQS ', service);
+			endpoint = `https://${service}.${credentials.region}.amazonaws.com`;
+		}
+		endpoint = new URL((endpoint as string).replace('{region}', credentials.region as string));
+
+	if(service === 's3' && credentials.s3Endpoint) {
+		 path = `${endpoint.pathname}?${queryToString(query).replace(/\+/g, '%2B')}`;
+	}
+	const signOpts = { headers: requestOptions.headers, host: endpoint.host, method, path, body, region} as Request;
+	const securityHeaders = {
+		accessKeyId: `${credentials.accessKeyId}`.trim(),
+		secretAccessKey: `${credentials.secretAccessKey}`.trim(),
+		sessionToken: credentials.temporaryCredentials ? `${credentials.sessionToken}`.trim() : undefined,
+	};
+
+	sign(signOpts, securityHeaders);
+	const options: IHttpRequestOptions = {
+		headers: signOpts.headers,
+		method,
+		url: endpoint.href + path,
+		body: signOpts.body,
+	};
+		return options;
+	}
+}
+
+function queryToString(params: IDataObject) {
+	return Object.keys(params)
+		.map((key) => key + '=' + params[key])
+		.join('&');
 }

packages/nodes-base/credentials/DropcontactApi.credentials.ts

@@ -1,4 +1,9 @@
-import { ICredentialType, NodePropertyTypes } from 'n8n-workflow';
+import {
+	IAuthenticateGeneric,
+	ICredentialTestRequest,
+	ICredentialType,
+	NodePropertyTypes,
+} from 'n8n-workflow';
 
 export class DropcontactApi implements ICredentialType {
 	name = 'dropcontactApi';
@@ -12,4 +17,23 @@ export class DropcontactApi implements ICredentialType {
 			default: '',
 		},
 	];
+	authenticate: IAuthenticateGeneric = {
+		type: 'generic',
+		properties: {
+			headers: {
+				'user-agent': 'n8n',
+				'X-Access-Token': '={{$credentials.apiKey}}',
+			},
+		},
+	};
+	test: ICredentialTestRequest = {
+		request: {
+			baseURL: 'https://api.dropcontact.io',
+			url: '/batch',
+			method: 'POST',
+			body: {
+				data: [{ email: '' }],
+			},
+		},
+	};
 }

packages/nodes-base/credentials/LemlistApi.credentials.ts

@@ -1,4 +1,10 @@
-import { ICredentialType, INodeProperties } from 'n8n-workflow';
+import {
+	ICredentialDataDecryptedObject,
+	ICredentialTestRequest,
+	ICredentialType,
+	IHttpRequestOptions,
+	INodeProperties,
+} from 'n8n-workflow';
 
 export class LemlistApi implements ICredentialType {
 	name = 'lemlistApi';
@@ -12,4 +18,19 @@ export class LemlistApi implements ICredentialType {
 			default: '',
 		},
 	];
+	async authenticate(
+		credentials: ICredentialDataDecryptedObject,
+		requestOptions: IHttpRequestOptions,
+	): Promise<IHttpRequestOptions> {
+		const encodedApiKey = Buffer.from(':' + credentials.apiKey).toString('base64');
+		requestOptions.headers!['Authorization'] = `Basic ${encodedApiKey}`;
+		requestOptions.headers!['user-agent'] = 'n8n';
+		return requestOptions;
+	}
+	test: ICredentialTestRequest = {
+		request: {
+			baseURL: 'https://api.lemlist.com/api',
+			url: '/campaigns',
+		},
+	};
 }

packages/nodes-base/credentials/MailgunApi.credentials.ts

@@ -1,4 +1,9 @@
-import { ICredentialType, INodeProperties } from 'n8n-workflow';
+import {
+	IAuthenticateGeneric,
+	ICredentialTestRequest,
+	ICredentialType,
+	INodeProperties,
+} from 'n8n-workflow';
 
 export class MailgunApi implements ICredentialType {
 	name = 'mailgunApi';
@@ -35,4 +40,19 @@ export class MailgunApi implements ICredentialType {
 			default: '',
 		},
 	];
+	authenticate: IAuthenticateGeneric = {
+		type: 'generic',
+		properties: {
+			auth: {
+				username: 'api',
+				password: '={{$credentials.apiKey}}',
+			},
+		},
+	};
+	test: ICredentialTestRequest = {
+		request: {
+			baseURL: '=https://{{$credentials.apiDomain}}/v3',
+			url: '/domains',
+		},
+	};
 }

packages/nodes-base/credentials/PhantombusterApi.credentials.ts

@@ -1,4 +1,9 @@
-import { ICredentialType, INodeProperties } from 'n8n-workflow';
+import {
+	IAuthenticateGeneric,
+	ICredentialTestRequest,
+	ICredentialType,
+	INodeProperties,
+} from 'n8n-workflow';
 
 export class PhantombusterApi implements ICredentialType {
 	name = 'phantombusterApi';
@@ -12,4 +17,18 @@ export class PhantombusterApi implements ICredentialType {
 			default: '',
 		},
 	];
+	authenticate: IAuthenticateGeneric = {
+		type: 'generic',
+		properties: {
+			headers: {
+				'X-Phantombuster-Key': '={{$credentials.apiKey}}',
+			},
+		},
+	};
+	test: ICredentialTestRequest = {
+		request: {
+			baseURL: 'https://api.phantombuster.com/api/v2',
+			url: '/agents/fetch-all',
+		},
+	};
 }

packages/nodes-base/credentials/SegmentApi.credentials.ts

@@ -1,4 +1,9 @@
-import { ICredentialType, INodeProperties } from 'n8n-workflow';
+import {
+	ICredentialDataDecryptedObject,
+	ICredentialType,
+	IHttpRequestOptions,
+	INodeProperties,
+} from 'n8n-workflow';
 
 export class SegmentApi implements ICredentialType {
 	name = 'segmentApi';
@@ -12,4 +17,12 @@ export class SegmentApi implements ICredentialType {
 			default: '',
 		},
 	];
+	async authenticate(
+		credentials: ICredentialDataDecryptedObject,
+		requestOptions: IHttpRequestOptions,
+	): Promise<IHttpRequestOptions> {
+		const base64Key = Buffer.from(`${credentials.writekey}:`).toString('base64');
+		requestOptions.headers!['Authorization'] = `Basic ${base64Key}`;
+		return requestOptions;
+	}
 }

packages/nodes-base/credentials/SupabaseApi.credentials.ts

@@ -1,4 +1,9 @@
-import { ICredentialType, INodeProperties } from 'n8n-workflow';
+import {
+	IAuthenticateGeneric,
+	ICredentialTestRequest,
+	ICredentialType,
+	INodeProperties,
+} from 'n8n-workflow';
 
 export class SupabaseApi implements ICredentialType {
 	name = 'supabaseApi';
@@ -19,4 +24,22 @@ export class SupabaseApi implements ICredentialType {
 			default: '',
 		},
 	];
+	authenticate: IAuthenticateGeneric = {
+		type: 'generic',
+		properties: {
+			headers: {
+				apikey: '={{$credentials.serviceRole}}',
+				Authorization: '=Bearer {{$credentials.serviceRole}}',
+			},
+		},
+	};
+	test: ICredentialTestRequest = {
+		request: {
+			baseURL: '={{$credentials.host}}/rest/v1',
+			headers: {
+				Prefer: 'return=representation',
+			},
+			url: '/',
+		},
+	};
 }

packages/nodes-base/credentials/UProcApi.credentials.ts

@@ -1,4 +1,10 @@
-import { ICredentialType, INodeProperties } from 'n8n-workflow';
+import {
+	ICredentialDataDecryptedObject,
+	ICredentialTestRequest,
+	ICredentialType,
+	IHttpRequestOptions,
+	INodeProperties,
+} from 'n8n-workflow';
 
 export class UProcApi implements ICredentialType {
 	name = 'uprocApi';
@@ -19,4 +25,18 @@ export class UProcApi implements ICredentialType {
 			default: '',
 		},
 	];
+	async authenticate(
+		credentials: ICredentialDataDecryptedObject,
+		requestOptions: IHttpRequestOptions,
+	): Promise<IHttpRequestOptions> {
+		const token = Buffer.from(`${credentials.email}:${credentials.apiKey}`).toString('base64');
+		requestOptions.headers!['Authorization'] = `Basic ${token}`;
+		return requestOptions;
+	}
+	test: ICredentialTestRequest = {
+		request: {
+			baseURL: 'https://api.uproc.io/api/v2/process',
+			url: '/me',
+		},
+	};
 }

packages/nodes-base/nodes/Aws/DynamoDB/GenericFunctions.ts

@@ -1,15 +1,16 @@
-import { URL } from 'url';
-
-import { sign } from 'aws4';
-
 import {
 	IExecuteFunctions,
 	IHookFunctions,
 	ILoadOptionsFunctions,
 	IWebhookFunctions,
 } from 'n8n-core';
 
-import { ICredentialDataDecryptedObject, IDataObject, INodeExecutionData } from 'n8n-workflow';
+import {
+	ICredentialDataDecryptedObject,
+	IDataObject,
+	IHttpRequestOptions,
+	INodeExecutionData,
+} from 'n8n-workflow';
 
 import { IRequestBody } from './types';
 
@@ -38,32 +39,22 @@ export async function awsApiRequest(
 	// tslint:disable-next-line:no-any
 ): Promise<any> {
 	const credentials = await this.getCredentials('aws');
-
-	// Concatenate path and instantiate URL object so it parses correctly query strings
-	const endpoint = new URL(getEndpointForService(service, credentials) + path);
-	const securityHeaders = {
-		accessKeyId: `${credentials.accessKeyId}`.trim(),
-		secretAccessKey: `${credentials.secretAccessKey}`.trim(),
-		sessionToken: credentials.temporaryCredentials
-			? `${credentials.sessionToken}`.trim()
-			: undefined,
-	};
-	const options = sign(
-		{
-			// @ts-ignore
-			uri: endpoint,
+	const requestOptions = {
+		qs: {
 			service,
-			region: credentials.region as string,
-			method,
-			path: '/',
-			headers: { ...headers },
-			body: JSON.stringify(body),
+			path,
 		},
-		securityHeaders,
-	);
+		method,
+		body: JSON.stringify(body),
+		url: '',
+		headers,
+		region: credentials?.region as string,
+	} as IHttpRequestOptions;
 
 	try {
-		return JSON.parse(await this.helpers.request!(options));
+		return JSON.parse(
+			await this.helpers.requestWithAuthentication.call(this, 'aws', requestOptions),
+		);
 	} catch (error) {
 		const errorMessage =
 			(error.response && error.response.body && error.response.body.message) ||