222 lines
7.0 KiB
JavaScript
222 lines
7.0 KiB
JavaScript
const sinon = require('sinon')
|
|
const chai = require('chai')
|
|
const chaiAsPromised = require('chai-as-promised')
|
|
const BigNumber = require('bignumber.js')
|
|
const proxyquire = require('proxyquire')
|
|
const {
|
|
addExtraGas,
|
|
applyMinGasFeeBump,
|
|
chooseGasPriceOptions,
|
|
syncForEach,
|
|
promiseAny
|
|
} = require('../src/utils/utils')
|
|
|
|
chai.use(chaiAsPromised)
|
|
chai.should()
|
|
const { expect } = chai
|
|
|
|
describe('utils', () => {
|
|
describe('addExtraGas', () => {
|
|
it('should return a BigNumber', () => {
|
|
const result = addExtraGas(100, 0.25)
|
|
|
|
expect(BigNumber.isBigNumber(result)).to.equal(true)
|
|
})
|
|
|
|
it('should work with numbers', () => {
|
|
const result = addExtraGas(100, 0.25)
|
|
|
|
expect(result.toString()).to.equal('125')
|
|
})
|
|
|
|
it('should work with BigNumbers', () => {
|
|
const result = addExtraGas(new BigNumber(100), 0.25)
|
|
|
|
expect(result.toString()).to.equal('125')
|
|
})
|
|
|
|
it('should accept factors bigger than 1', () => {
|
|
const result = addExtraGas(new BigNumber(100), 1.25)
|
|
|
|
expect(result.toString()).to.equal('225')
|
|
})
|
|
|
|
it('should handle maxGasLimit', () => {
|
|
const result1 = addExtraGas(new BigNumber(100), 0.25, 110)
|
|
const result2 = addExtraGas(new BigNumber(100), 0.25, 150)
|
|
|
|
expect(result1.toString()).to.equal('110')
|
|
expect(result2.toString()).to.equal('125')
|
|
})
|
|
})
|
|
|
|
describe('checkHTTPS', () => {
|
|
let utils
|
|
const logger = { warn: sinon.stub() }
|
|
beforeEach(() => {
|
|
logger.warn.reset()
|
|
utils = proxyquire('../src/utils/utils', { '../services/logger': logger })
|
|
})
|
|
|
|
it('should do nothing if HTTP is allowed and the URL is https', () => {
|
|
utils.checkHTTPS('yes', logger)('home')('https://www.google.com')
|
|
expect(logger.warn.called).to.equal(false)
|
|
})
|
|
|
|
it('should emit a warning if HTTP is allowed and the URL is http', () => {
|
|
utils.checkHTTPS('yes', logger)('home')('http://www.google.com')
|
|
expect(logger.warn.called).to.equal(true)
|
|
})
|
|
|
|
it('should do nothing if HTTP is not allowed and the URL is https', () => {
|
|
utils.checkHTTPS('no', logger)('home')('https://www.google.com')
|
|
expect(logger.warn.called).to.equal(false)
|
|
})
|
|
|
|
it('should throw an error if HTTP is not allowed and the URL is http', () => {
|
|
expect(() => utils.checkHTTPS('no', logger)('home')('http://www.google.com')).to.throw()
|
|
})
|
|
})
|
|
|
|
describe('syncForEach', () => {
|
|
it('should execute callback sequentially', async () => {
|
|
const xs = []
|
|
await syncForEach(
|
|
[1, 2, 3],
|
|
x =>
|
|
new Promise(resolve => {
|
|
xs.push(x)
|
|
resolve()
|
|
})
|
|
)
|
|
|
|
expect(xs).to.deep.equal([1, 2, 3])
|
|
})
|
|
|
|
it('should receive the index and the full array', async () => {
|
|
const xs = []
|
|
const is = []
|
|
const arrays = []
|
|
await syncForEach(
|
|
[1, 2, 3],
|
|
(x, i, array) =>
|
|
new Promise(resolve => {
|
|
xs.push(x)
|
|
is.push(i)
|
|
arrays.push(array)
|
|
resolve()
|
|
})
|
|
)
|
|
|
|
expect(xs).to.deep.equal([1, 2, 3])
|
|
expect(is).to.deep.equal([0, 1, 2])
|
|
expect(arrays).to.deep.equal([[1, 2, 3], [1, 2, 3], [1, 2, 3]])
|
|
})
|
|
|
|
it('should fail and stop when the callback fails', () => {
|
|
const xs = []
|
|
const promise = syncForEach(
|
|
[1, 2, 3],
|
|
x =>
|
|
new Promise((resolve, reject) => {
|
|
if (x === 2) {
|
|
return reject()
|
|
}
|
|
|
|
xs.push(x)
|
|
return resolve()
|
|
})
|
|
)
|
|
|
|
return expect(promise).to.be.rejected.then(() => {
|
|
expect(xs).to.deep.equal([1])
|
|
})
|
|
})
|
|
|
|
it('should work with an empty array', () => {
|
|
const xs = []
|
|
const promise = syncForEach(
|
|
[],
|
|
x =>
|
|
new Promise(resolve => {
|
|
xs.push(x)
|
|
return resolve()
|
|
})
|
|
)
|
|
|
|
return expect(promise).to.be.fulfilled.then(() => {
|
|
expect(xs).to.deep.equal([])
|
|
})
|
|
})
|
|
})
|
|
|
|
describe('promiseAny', () => {
|
|
const f = x => new Promise((res, rej) => setTimeout(() => (x > 0 ? res : rej)(x), 10 * x))
|
|
|
|
it('should return first obtained result', async () => {
|
|
const array = [2, 1, 3]
|
|
const result = await promiseAny(array.map(f))
|
|
|
|
expect(result).to.equal(1)
|
|
})
|
|
|
|
it('should return first obtained result with one reject', async () => {
|
|
const array = [2, -1, 3]
|
|
const result = await promiseAny(array.map(f))
|
|
|
|
expect(result).to.equal(2)
|
|
})
|
|
|
|
it('should return first obtained result with several rejects', async () => {
|
|
const array = [2, -1, -3]
|
|
const result = await promiseAny(array.map(f))
|
|
|
|
expect(result).to.equal(2)
|
|
})
|
|
|
|
it('should reject if all functions failed', async () => {
|
|
const array = [-2, -1, -3]
|
|
await promiseAny(array.map(f)).should.be.rejected
|
|
})
|
|
})
|
|
|
|
describe('applyMinGasFeeBump', () => {
|
|
it('should bump pre-eip1559 fee', () => {
|
|
const job = { gasPriceOptions: { gasPrice: '100000000000' } }
|
|
const newJob = applyMinGasFeeBump(job)
|
|
expect(newJob.gasPriceOptions.gasPrice).to.be.equal('110000000000')
|
|
})
|
|
|
|
it('should bump eip1559 fee', () => {
|
|
const job = { gasPriceOptions: { maxFeePerGas: '100000000000', maxPriorityFeePerGas: '20000000000' } }
|
|
const newJob = applyMinGasFeeBump(job)
|
|
expect(newJob.gasPriceOptions.maxFeePerGas).to.be.equal('110000000000')
|
|
expect(newJob.gasPriceOptions.maxPriorityFeePerGas).to.be.equal('22000000000')
|
|
})
|
|
})
|
|
|
|
describe('chooseGasPriceOptions', () => {
|
|
it('should choose max pre-eip1559 fee', () => {
|
|
const opts1 = { gasPrice: '100000000000' }
|
|
const opts2 = { gasPrice: '101000000000' }
|
|
expect(chooseGasPriceOptions(opts1, opts2).gasPrice).to.be.equal('101000000000')
|
|
expect(chooseGasPriceOptions(opts2, opts1).gasPrice).to.be.equal('101000000000')
|
|
expect(chooseGasPriceOptions(opts2, undefined).gasPrice).to.be.equal('101000000000')
|
|
expect(chooseGasPriceOptions(undefined, opts2).gasPrice).to.be.equal('101000000000')
|
|
})
|
|
|
|
it('should choose max eip1559 fee', () => {
|
|
const opts1 = { maxFeePerGas: '100000000000', maxPriorityFeePerGas: '21000000000' }
|
|
const opts2 = { maxFeePerGas: '101000000000', maxPriorityFeePerGas: '20000000000' }
|
|
expect(chooseGasPriceOptions(opts1, opts2).maxFeePerGas).to.be.equal('101000000000')
|
|
expect(chooseGasPriceOptions(opts1, opts2).maxPriorityFeePerGas).to.be.equal('21000000000')
|
|
expect(chooseGasPriceOptions(opts2, opts1).maxFeePerGas).to.be.equal('101000000000')
|
|
expect(chooseGasPriceOptions(opts2, opts1).maxPriorityFeePerGas).to.be.equal('21000000000')
|
|
expect(chooseGasPriceOptions(opts2, undefined).maxFeePerGas).to.be.equal('101000000000')
|
|
expect(chooseGasPriceOptions(opts2, undefined).maxPriorityFeePerGas).to.be.equal('20000000000')
|
|
expect(chooseGasPriceOptions(undefined, opts2).maxFeePerGas).to.be.equal('101000000000')
|
|
expect(chooseGasPriceOptions(undefined, opts2).maxPriorityFeePerGas).to.be.equal('20000000000')
|
|
})
|
|
})
|
|
})
|