fix(price-feeder): Parse multiple candles from OsmosisV2 response (#1615

)

Parse an array of candle responses from osmosisV2 api

price-feeder/CHANGELOG.md

@@ -46,6 +46,10 @@ Ref: https://keepachangelog.com/en/1.0.0/
 
 ## [Unreleased]
 
+### Bugs
+
+- [1615](https://github.com/umee-network/umee/pull/1615) Parse multiple candles from OsmosisV2 response
+
 ### Improvements
 
 - [1602](https://github.com/umee-network/umee/pull/1602) Remove FTX provider.

price-feeder/oracle/provider/osmosisv2.go

@@ -200,7 +200,7 @@ func (p *OsmosisV2Provider) messageReceived(messageType int, bz []byte) {
 		messageErr  error
 		tickerResp  OsmosisV2Ticker
 		tickerErr   error
-		candleResp  OsmosisV2Candle
+		candleResp  []OsmosisV2Candle
 		candleErr   error
 	)
 
@@ -242,7 +242,7 @@ func (p *OsmosisV2Provider) messageReceived(messageType int, bz []byte) {
 				if len(v) == 0 {
 					continue
 				}
-				candleString, _ := json.Marshal(v[len(v)-1].(map[string]interface{}))
+				candleString, _ := json.Marshal(v)
 				candleErr = json.Unmarshal(candleString, &candleResp)
 				if candleErr != nil {
 					p.logger.Error().
@@ -251,10 +251,12 @@ func (p *OsmosisV2Provider) messageReceived(messageType int, bz []byte) {
 						Msg("Error on receive message")
 					continue
 				}
-				p.setCandlePair(
-					osmosisV2Pair,
-					candleResp,
-				)
+				for _, singleCandle := range candleResp {
+					p.setCandlePair(
+						osmosisV2Pair,
+						singleCandle,
+					)
+				}
 				telemetryWebsocketMessage(ProviderOsmosisV2, MessageTypeCandle)
 				continue
 			}