Add CoinGecko-Node

* Add CoinGecko node

* CoinGecko improvements and add events

*  Small improvements

*  Improvements to CoinGecko-Node

Co-authored-by: Dokime <jnau5@yahoo.com>
Co-authored-by: ricardo <ricardoespinoza105@gmail.com>
This commit is contained in:
Jan
2020-10-03 11:50:57 +02:00
committed by GitHub
parent 383ee9533f
commit 7c51964bd2
6 changed files with 1475 additions and 0 deletions

View File

@@ -0,0 +1,67 @@
import {
OptionsWithUri,
} from 'request';
import {
IExecuteFunctions,
IExecuteSingleFunctions,
ILoadOptionsFunctions,
} from 'n8n-core';
import {
IDataObject,
} from 'n8n-workflow';
export async function coinGeckoApiRequest(this: IExecuteFunctions | IExecuteSingleFunctions | ILoadOptionsFunctions, method: string,
endpoint: string, body: any = {}, qs: IDataObject = {}, uri?: string, option: IDataObject = {}): Promise<any> { // tslint:disable-line:no-any
let options: OptionsWithUri = {
headers: {
'Accept': 'application/json',
'Content-Type': 'application/json',
},
method,
body,
qs,
uri: uri || `https://api.coingecko.com/api/v3${endpoint}`,
json: true,
};
options = Object.assign({}, options, option);
try {
if (Object.keys(body).length === 0) {
delete options.body;
}
//@ts-ignore
return await this.helpers.request.call(this, options);
} catch (error) {
throw error;
}
}
export async function coinGeckoRequestAllItems(this: IExecuteFunctions | ILoadOptionsFunctions, propertyName: string, method: string, endpoint: string, body: any = {}, query: IDataObject = {}): Promise<any> { // tslint:disable-line:no-any
const returnData: IDataObject[] = [];
let responseData;
let respData;
query.per_page = 250;
query.page = 1;
do {
responseData = await coinGeckoApiRequest.call(this, method, endpoint, body, query);
query.page++;
respData = responseData;
if (propertyName !== '') {
respData = responseData[propertyName];
}
returnData.push.apply(returnData, respData);
} while (
respData.length !== 0
);
return returnData;
}