Move gathereing price telemetry

x/oracle/abci/proposal.go

@@ -13,9 +13,11 @@ import (
 	"github.com/Team-Kujira/core/x/oracle/types"
 	abci "github.com/cometbft/cometbft/abci/types"
 	"github.com/cosmos/cosmos-sdk/baseapp"
+	"github.com/cosmos/cosmos-sdk/telemetry"
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	"github.com/cosmos/cosmos-sdk/types/mempool"
 	"github.com/cosmos/cosmos-sdk/types/module"
+	"github.com/hashicorp/go-metrics"
 )
 
 // StakeWeightedPrices defines the structure a proposer should use to calculate
@@ -264,6 +266,15 @@ func (h *ProposalHandler) GetBallotByDenom(ctx sdk.Context, ci abci.ExtendedComm
 					tmpPower = 0
 				}
 
+				telemetry.SetGaugeWithLabels(
+					[]string{"oracle", "price"},
+					float32(price.MustFloat64()),
+					[]metrics.Label{
+						telemetry.NewLabel("denom", base),
+						telemetry.NewLabel("validator", valAddr.String()),
+					},
+				)
+
 				votes[base] = append(votes[base],
 					types.NewVoteForTally(
 						price,

x/oracle/keeper/tally.go

@@ -62,12 +62,6 @@ func Tally(_ sdk.Context,
 		key := vote.Voter.String()
 		claim := validatorClaimMap[key]
 
-		telemetry.SetGaugeWithLabels(
-			[]string{"oracle", "price"},
-			float32(vote.ExchangeRate.MustFloat64()),
-			append(labels, telemetry.NewLabel("validator", key)),
-		)
-
 		// Filter ballot winners & abstain voters
 		if (vote.ExchangeRate.GTE(weightedMedian.Sub(spread)) &&
 			vote.ExchangeRate.LTE(weightedMedian.Add(spread))) ||