5 Commits

Author SHA1 Message Date
Danil Kovtonyuk
efd3cb3c7c fix test 2021-06-03 12:51:14 +03:00
Danil Kovtonyuk
88a757bb45 bump version 2021-06-03 12:46:36 +03:00
Danil Kovtonyuk
c30c7aed63 add binance 2021-06-03 12:46:36 +03:00
Alexey
ca24732a9b fix bug with extra precision 2020-10-20 18:11:07 +03:00
Alexey
a05a1e62d4 anyblock new oracle 2020-10-20 17:39:50 +03:00
7 changed files with 143 additions and 12 deletions

View File

@@ -1,6 +1,6 @@
{
"name": "gas-price-oracle",
"version": "0.2.0",
"version": "0.3.0",
"description": "Gas Price Oracle library for Ethereum dApps.",
"main": "lib/index.js",
"homepage": "https://github.com/peppersec/gas-price-oracle",

23
src/config/binance.ts Normal file
View File

@@ -0,0 +1,23 @@
import { OffChainOracle, OffChainOracles, OnChainOracles } from '../types';
const bscgas: OffChainOracle = {
name: 'bscgas',
url: 'https://bscgas.info/gas',
instantPropertyName: 'imediate',
fastPropertyName: 'fast',
standardPropertyName: 'standard',
lowPropertyName: 'slow',
denominator: 1,
additionalDataProperty: null,
};
export const offChainOracles: OffChainOracles = {
bscgas,
};
export const onChainOracles: OnChainOracles = {};
export default {
offChainOracles,
onChainOracles,
};

25
src/config/index.ts Normal file
View File

@@ -0,0 +1,25 @@
import { NetworkConfig } from '../types';
import {
onChainOracles as mainnetOnchainOracles,
offChainOracles as mainnetOffChainOracles,
} from './mainnet';
import {
onChainOracles as binanceOnchainOracles,
offChainOracles as binanceOffchainOracles,
} from './binance';
export enum ChainId {
MAINNET = 1,
BINANCE = 56,
}
export const networks: NetworkConfig = {
[ChainId.MAINNET]: {
onChainOracles: mainnetOnchainOracles,
offChainOracles: mainnetOffChainOracles,
},
[ChainId.BINANCE]: {
onChainOracles: binanceOnchainOracles,
offChainOracles: binanceOffchainOracles,
},
};

View File

@@ -1,4 +1,4 @@
import { OffChainOracle, OnChainOracle } from './types';
import { OffChainOracle, OnChainOracle, OffChainOracles, OnChainOracles } from '../types';
const ethgasstation: OffChainOracle = {
name: 'ethgasstation',
@@ -55,6 +55,17 @@ const gasNow: OffChainOracle = {
additionalDataProperty: 'data',
};
const anyblock: OffChainOracle = {
name: 'anyblock',
url: 'https://api.anyblock.tools/ethereum/latest-minimum-gasprice',
instantPropertyName: 'instant',
fastPropertyName: 'fast',
standardPropertyName: 'standard',
lowPropertyName: 'slow',
denominator: 1,
additionalDataProperty: null,
};
const chainlink: OnChainOracle = {
name: 'chainlink',
callData: '0x50d25bcd',
@@ -62,15 +73,16 @@ const chainlink: OnChainOracle = {
denominator: '1000000000',
};
export const offChainOracles: { [key: string]: OffChainOracle } = {
export const offChainOracles: OffChainOracles = {
ethgasstation,
anyblock,
gasNow,
poa,
etherchain,
zoltu,
};
export const onChainOracles: { [key: string]: OnChainOracle } = {
export const onChainOracles: OnChainOracles = {
chainlink,
};

View File

@@ -1,13 +1,23 @@
import axios from 'axios';
import config from './config';
import { GasPrice, OffChainOracle, OnChainOracle, Config, GasPriceKey, Options } from './types';
import { ChainId, networks } from './config';
import {
Config,
Options,
GasPrice,
GasPriceKey,
OffChainOracle,
OnChainOracle,
OnChainOracles,
OffChainOracles,
} from './types';
import BigNumber from 'bignumber.js';
export class GasPriceOracle {
lastGasPrice: GasPrice;
offChainOracles = { ...config.offChainOracles };
onChainOracles = { ...config.onChainOracles };
offChainOracles: OffChainOracles;
onChainOracles: OnChainOracles;
configuration: Config = {
chainId: ChainId.MAINNET,
defaultRpc: 'https://api.mycryptoapi.com/eth',
timeout: 10000,
};
@@ -16,6 +26,10 @@ export class GasPriceOracle {
if (options) {
Object.assign(this.configuration, options);
}
const { offChainOracles, onChainOracles } = networks[this.configuration.chainId];
this.offChainOracles = { ...offChainOracles };
this.onChainOracles = { ...onChainOracles };
}
async askOracle(oracle: OffChainOracle): Promise<GasPrice> {
@@ -41,7 +55,7 @@ export class GasPriceOracle {
standard: parseFloat(gas[standardPropertyName]) / denominator,
low: parseFloat(gas[lowPropertyName]) / denominator,
};
return gasPrices;
return this.normalize(gasPrices);
} else {
throw new Error(`Fetch gasPrice from ${name} oracle failed. Trying another one...`);
}
@@ -108,7 +122,25 @@ export class GasPriceOracle {
const middle = Math.floor(allPrices.length / 2);
medianGasPrice[type] = isEven ? (allPrices[middle - 1] + allPrices[middle]) / 2.0 : allPrices[middle];
}
return medianGasPrice;
return this.normalize(medianGasPrice);
}
/**
* Normalizes GasPrice values to Gwei. No more than 9 decimals basically
* @param GasPrice _gas
*/
normalize(_gas: GasPrice): GasPrice {
const format = {
decimalSeparator: '.',
groupSeparator: '',
};
const decimals = 9;
const gas: GasPrice = { ..._gas };
for (const type of Object.keys(gas) as Array<keyof GasPrice>) {
gas[type] = Number(new BigNumber(gas[type]).toFormat(decimals, format));
}
return gas;
}
async fetchGasPricesOnChain(): Promise<number> {

View File

@@ -9,6 +9,8 @@ export type OffChainOracle = {
additionalDataProperty: string | null;
};
export type OffChainOracles = { [key: string]: OffChainOracle };
export type OnChainOracle = {
name: string;
rpc?: string;
@@ -17,6 +19,8 @@ export type OnChainOracle = {
denominator: string;
};
export type OnChainOracles = { [key: string]: OnChainOracle };
export type GasPrice = {
[key in GasPriceKey]: number;
};
@@ -24,8 +28,16 @@ export type GasPrice = {
export type GasPriceKey = 'instant' | 'fast' | 'standard' | 'low';
export type Options = {
chainId?: number;
defaultRpc?: string;
timeout?: number;
};
export type Config = Required<Options>;
export type NetworkConfig = {
[key in number]: {
offChainOracles: OffChainOracles;
onChainOracles: OnChainOracles;
};
};

View File

@@ -1,14 +1,14 @@
/* eslint-disable @typescript-eslint/no-non-null-assertion */
/* eslint-disable @typescript-eslint/no-var-requires */
import { GasPrice } from '../src/types';
import { GasPrice, OffChainOracle } from '../src/types';
import mockery from 'mockery';
import chai from 'chai';
import { onChainOracles } from '../src/config';
import { GasPriceOracle } from '../src/index';
chai.use(require('chai-as-promised'));
chai.should();
let oracle = new GasPriceOracle();
let { onChainOracles, offChainOracles } = oracle;
before('before', function () {
const axiosMock = {
@@ -24,6 +24,7 @@ before('before', function () {
beforeEach('beforeEach', function () {
oracle = new GasPriceOracle();
({ onChainOracles, offChainOracles } = oracle);
});
describe('constructor', function () {
@@ -204,6 +205,32 @@ describe('fetchMedianGasPriceOffChain', function () {
});
});
describe('askOracle', function () {
it('all oracles should answer', async function () {
// TODO: remove after fix POA
delete offChainOracles['poa'];
for (const o of Object.values(offChainOracles) as Array<OffChainOracle>) {
try {
const gas: GasPrice = await oracle.askOracle(o);
gas.instant.should.be.a('number');
gas.fast.should.be.a('number');
gas.standard.should.be.a('number');
gas.low.should.be.a('number');
gas.instant.should.be.at.least(gas.fast); // greater than or equal to the given number.
gas.fast.should.be.at.least(gas.standard);
gas.standard.should.be.at.least(gas.low);
gas.low.should.not.be.equal(0);
} catch (e) {
console.error(`Failed to get data from ${o.name} oracle`);
throw new Error(e);
}
}
});
});
after('after', function () {
after(function () {
mockery.disable();