admin/n8n-enterprise-unlocked
1
0
Fork 0
mirror of https://github.com/Abdulazizzn/n8n-enterprise-unlocked.git synced 2025-12-17 10:02:05 +00:00
Code Issues Packages Projects Releases Wiki Activity

OAuth2 support

Browse Source
This commit is contained in:
Rupenieks
2020-06-09 15:48:40 +02:00
parent 516a56ea32
commit 48765b7db6
5 changed files with 121 additions and 23 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
packages/nodes-base/nodes/Pipedrive/GenericFunctions.ts
View File

@@ -23,7 +23,6 @@ export interface ICustomProperties {
[key: string]: ICustomInterface;
}
/**
* Make an API request to Pipedrive
*
@@ -34,16 +33,7 @@ export interface ICustomProperties {
* @returns {Promise<any>}
*/
export async function pipedriveApiRequest(this: IHookFunctions | IExecuteFunctions, method: string, endpoint: string, body: IDataObject, query?: IDataObject, formData?: IDataObject, downloadFile?: boolean): Promise<any> { // tslint:disable-line:no-any
const credentials = this.getCredentials('pipedriveApi');
if (credentials === undefined) {
throw new Error('No credentials got returned!');
}
if (query === undefined) {
query = {};
}
query.api_token = credentials.apiToken;
const authenticationMethod = this.getNodeParameter('authentication', 0);
const options: OptionsWithUri = {
method,
@@ -65,8 +55,27 @@ export async function pipedriveApiRequest(this: IHookFunctions | IExecuteFunctio
options.formData = formData;
}
if (query === undefined) {
query = {};
}
let responseData;
try {
const responseData = await this.helpers.request(options);
if (authenticationMethod === 'accessToken') {
const credentials = this.getCredentials('pipedriveApi');
if (credentials === undefined) {
throw new Error('No credentials got returned!');
}
query.api_token = credentials.apiToken;
responseData = await this.helpers.request(options);
} else {
responseData = await this.helpers.requestOAuth2!.call(this, 'pipedriveOAuth2Api', options);
}
if (downloadFile === true) {
return {
@@ -82,7 +91,7 @@ export async function pipedriveApiRequest(this: IHookFunctions | IExecuteFunctio
additionalData: responseData.additional_data,
data: responseData.data,
};
} catch (error) {
} catch(error) {
if (error.statusCode === 401) {
// Return a clear error
throw new Error('The Pipedrive credentials are not valid!');
@@ -102,8 +111,6 @@ export async function pipedriveApiRequest(this: IHookFunctions | IExecuteFunctio
}
}
/**
* Make an API request to paginated Pipedrive endpoint
* and return all results