fix: fix vote metrics when proposal is passed (#49)

kilnfi · Dec 19, 2023 · 2262ad9 · 2262ad9
1 parent 2956a5b
commit 2262ad9
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/pkg/watcher/votes_v1.go b/pkg/watcher/votes_v1.go
@@ -73,6 +73,8 @@ func (w *VotesV1Watcher) fetchProposals(ctx context.Context, node *rpc.Node) err
 				ProposalId: proposal.Id,
 				Voter:      voter,
 			})
+
+			w.metrics.Vote.Reset()
 			if isInvalidArgumentError(err) {
 				w.handleVote(chainID, validator, proposal.Id, nil)
 			} else if err != nil {

diff --git a/pkg/watcher/votes_v1beta1.go b/pkg/watcher/votes_v1beta1.go
@@ -75,6 +75,8 @@ func (w *VotesV1Beta1Watcher) fetchProposals(ctx context.Context, node *rpc.Node
 				ProposalId: proposal.ProposalId,
 				Voter:      voter,
 			})
+
+			w.metrics.Vote.Reset()
 			if isInvalidArgumentError(err) {
 				w.handleVote(chainID, validator, proposal.ProposalId, nil)
 			} else if err != nil {