diff --git a/feeder/priceprovider/sources/binance.go b/feeder/priceprovider/sources/binance.go index 28bb5da..0ddb7aa 100644 --- a/feeder/priceprovider/sources/binance.go +++ b/feeder/priceprovider/sources/binance.go @@ -55,6 +55,7 @@ func BinancePriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (r rawPrices = make(map[types.Symbol]float64) for _, ticker := range tickers { rawPrices[types.Symbol(ticker.Symbol)] = ticker.Price + logger.Debug().Msgf("fetched price for %s on data source %s: %f", ticker.Symbol, Binance, ticker.Price) } return rawPrices, nil diff --git a/feeder/priceprovider/sources/bitfinex.go b/feeder/priceprovider/sources/bitfinex.go index 9e613c6..d4e135a 100644 --- a/feeder/priceprovider/sources/bitfinex.go +++ b/feeder/priceprovider/sources/bitfinex.go @@ -59,6 +59,7 @@ func BitfinexPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) ( lastPrice := ticker[lastPriceIndex].(float64) rawPrices[symbol] = lastPrice + logger.Debug().Msg(fmt.Sprintf("fetched price for %s on data source %s: %f", symbol, Bitfinex, lastPrice)) } return rawPrices, nil diff --git a/feeder/priceprovider/sources/coingecko.go b/feeder/priceprovider/sources/coingecko.go index 7aa5d72..eed18b3 100644 --- a/feeder/priceprovider/sources/coingecko.go +++ b/feeder/priceprovider/sources/coingecko.go @@ -77,6 +77,7 @@ func extractPricesFromResponse(symbols set.Set[types.Symbol], response []byte, l for symbol := range symbols { if price, ok := result[string(symbol)]; ok { rawPrices[symbol] = price.Price + logger.Debug().Msg(fmt.Sprintf("fetched price for %s on data source %s: %f", symbol, Coingecko, price.Price)) } else { logger.Err(fmt.Errorf("failed to parse price for %s on data source %s", symbol, Coingecko)).Msg(string(response)) continue diff --git a/feeder/priceprovider/sources/coinmarketcap.go b/feeder/priceprovider/sources/coinmarketcap.go index e1d9504..f6dd8c3 100644 --- a/feeder/priceprovider/sources/coinmarketcap.go +++ b/feeder/priceprovider/sources/coinmarketcap.go @@ -101,6 +101,7 @@ func getPricesFromResponse(symbols set.Set[types.Symbol], response []byte, logge for symbol := range symbols { if price, ok := cmcPrice[string(symbol)]; ok { rawPrices[symbol] = price + logger.Debug().Msg(fmt.Sprintf("fetched price for %s on data source %s: %f", symbol, CoinMarketCap, price)) } else { logger.Err(err).Msg(fmt.Sprintf("failed to parse price for %s on data source %s", symbol, CoinMarketCap)) continue diff --git a/feeder/priceprovider/sources/gateio.go b/feeder/priceprovider/sources/gateio.go index a6e994c..9d8c85b 100644 --- a/feeder/priceprovider/sources/gateio.go +++ b/feeder/priceprovider/sources/gateio.go @@ -53,6 +53,7 @@ func GateIoPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (ra } rawPrices[symbol] = price + logger.Debug().Msg(fmt.Sprintf("fetched price for %s on data source %s: %f", symbol, GateIo, price)) } return rawPrices, nil diff --git a/feeder/priceprovider/sources/okex.go b/feeder/priceprovider/sources/okex.go index 4910fe5..3b9a40e 100644 --- a/feeder/priceprovider/sources/okex.go +++ b/feeder/priceprovider/sources/okex.go @@ -64,6 +64,7 @@ func OkexPriceUpdate(symbols set.Set[types.Symbol], logger zerolog.Logger) (rawP } rawPrices[symbol] = price + logger.Debug().Msg(fmt.Sprintf("fetched price for %s on data source %s: %f", symbol, Okex, price)) } return rawPrices, nil }