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 bitpay.ticker(fiatCode, cryptoCode) if (tickerName === 'mock-ticker') return mockTicker.ticker(fiatCode, cryptoCode) if (_.includes(fiatCode, _.keys(CURRENCY_PEGS_MISMATCH))) { return bitpay.ticker(CURRENCY_PEGS_MISMATCH[fiatCode], cryptoCode, tickerName) } return ccxt.ticker(fiatCode, cryptoCode, tickerName) } const getRates = mem(_getRates, { maxAge: FETCH_INTERVAL, cacheKey: (settings, fiatCode, cryptoCode) => JSON.stringify([fiatCode, cryptoCode]) }) module.exports = { getRates }