add debug log statements for price updates

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

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

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

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

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

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
 }