53 lines
1.6 KiB
JavaScript
53 lines
1.6 KiB
JavaScript
const _ = require('lodash/fp')
|
|
const mem = require('mem')
|
|
const configManager = require('./new-config-manager')
|
|
const logger = require('./logger')
|
|
const lastRate = {}
|
|
|
|
const ccxt = require('./plugins/ticker/ccxt')
|
|
const mockTicker = require('./plugins/ticker/mock-ticker')
|
|
const bitpay = require('./plugins/ticker/bitpay')
|
|
|
|
const FETCH_INTERVAL = 60000
|
|
|
|
const CURRENCY_PEGS_MISMATCH = { NAD: 'ZAR' }
|
|
|
|
function _getRates (settings, fiatCode, cryptoCode) {
|
|
return Promise.resolve()
|
|
.then(() => {
|
|
const config = settings.config
|
|
const tickerName = configManager.getWalletSettings(cryptoCode, config).ticker
|
|
const market = [cryptoCode, fiatCode].join('-')
|
|
|
|
return buildTicker(fiatCode, cryptoCode, tickerName)
|
|
.then(r => ({
|
|
rates: r.rates,
|
|
timestamp: Date.now()
|
|
}))
|
|
.then(r => {
|
|
lastRate[market] = r
|
|
return r
|
|
})
|
|
.catch(err => {
|
|
logger.error(err)
|
|
return lastRate[market]
|
|
})
|
|
})
|
|
}
|
|
|
|
function buildTicker (fiatCode, cryptoCode, tickerName) {
|
|
if (tickerName === 'bitpay') {
|
|
return _.includes(fiatCode, _.keys(CURRENCY_PEGS_MISMATCH))
|
|
? bitpay.ticker(CURRENCY_PEGS_MISMATCH[fiatCode], cryptoCode)
|
|
: bitpay.ticker(fiatCode, cryptoCode)
|
|
}
|
|
if (tickerName === 'mock-ticker') return mockTicker.ticker(fiatCode, cryptoCode)
|
|
return ccxt.ticker(fiatCode, cryptoCode, tickerName)
|
|
}
|
|
|
|
const getRates = mem(_getRates, {
|
|
maxAge: FETCH_INTERVAL,
|
|
cacheKey: (settings, fiatCode, cryptoCode) => JSON.stringify([fiatCode, cryptoCode])
|
|
})
|
|
|
|
module.exports = { getRates }
|