chore: log exchange errors on getMarkets
This commit is contained in:
parent
278a53732d
commit
5c2046e6d0
1 changed files with 9 additions and 5 deletions
|
|
@ -1,6 +1,7 @@
|
||||||
const _ = require('lodash/fp')
|
const _ = require('lodash/fp')
|
||||||
const { ALL_CRYPTOS } = require('@lamassu/coins')
|
const { ALL_CRYPTOS } = require('@lamassu/coins')
|
||||||
|
|
||||||
|
const logger = require('./logger')
|
||||||
const configManager = require('./new-config-manager')
|
const configManager = require('./new-config-manager')
|
||||||
const ccxt = require('./plugins/exchange/ccxt')
|
const ccxt = require('./plugins/exchange/ccxt')
|
||||||
const mockExchange = require('./plugins/exchange/mock-exchange')
|
const mockExchange = require('./plugins/exchange/mock-exchange')
|
||||||
|
|
@ -64,11 +65,14 @@ function getMarkets() {
|
||||||
ccxt
|
ccxt
|
||||||
.getMarkets(exchange, ALL_CRYPTOS)
|
.getMarkets(exchange, ALL_CRYPTOS)
|
||||||
.then(markets => ({ exchange, markets }))
|
.then(markets => ({ exchange, markets }))
|
||||||
.catch(error => ({
|
.catch(error => {
|
||||||
|
logger.error(`Error fetching markets for ${exchange}:`, error)
|
||||||
|
return {
|
||||||
exchange,
|
exchange,
|
||||||
markets: [],
|
markets: [],
|
||||||
error: error.message,
|
error: error.message,
|
||||||
}))
|
}
|
||||||
|
})
|
||||||
|
|
||||||
const transformToObject = _.reduce(
|
const transformToObject = _.reduce(
|
||||||
(acc, { exchange, markets }) => ({
|
(acc, { exchange, markets }) => ({
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue