From e77a8d1373627f852835550a03b65683ad5a8a42 Mon Sep 17 00:00:00 2001
From: Pavel Karpy <carpawell@nspcc.ru>
Date: Mon, 17 Jul 2023 19:44:29 +0300
Subject: [PATCH] ir: Do not vote for the same validators list twice

Closes #2365.

Signed-off-by: Pavel Karpy <carpawell@nspcc.ru>
---
 CHANGELOG.md           |  1 +
 pkg/innerring/state.go | 36 +++++++++++++++++++++++++++++++++++-
 2 files changed, 36 insertions(+), 1 deletion(-)

diff --git a/CHANGELOG.md b/CHANGELOG.md
index 0b060a9daa0..a5449083f9f 100644
--- a/CHANGELOG.md
+++ b/CHANGELOG.md
@@ -11,6 +11,7 @@ Changelog for NeoFS Node
 ### Fixed
 - `neo-go` RPC connection loss handling (#1337)
 - Concurrent morph cache misses (#1248)
+- Double voting for validators on IR startup (#2365)
 
 ### Removed
 - Deprecated `morph.rpc_endpoint` SN and `morph.endpoint.client` IR config sections (#2400)
diff --git a/pkg/innerring/state.go b/pkg/innerring/state.go
index 153a620a7eb..6efbf636893 100644
--- a/pkg/innerring/state.go
+++ b/pkg/innerring/state.go
@@ -4,6 +4,7 @@ import (
 	"fmt"
 	"sort"
 
+	"github.com/nspcc-dev/neo-go/pkg/crypto/keys"
 	"github.com/nspcc-dev/neo-go/pkg/util"
 	"github.com/nspcc-dev/neofs-node/pkg/innerring/processors/governance"
 	auditClient "github.com/nspcc-dev/neofs-node/pkg/morph/client/audit"
@@ -108,13 +109,21 @@ func (s *Server) voteForSidechainValidator(prm governance.VoteValidatorPrm) erro
 		return nil
 	}
 
+	voted, err := s.alreadyVoted(validators)
+	if err != nil {
+		return fmt.Errorf("could not check validators state: %w", err)
+	}
+
+	if voted {
+		return nil
+	}
+
 	epoch := s.EpochCounter()
 
 	var (
 		nonce uint32 = 1
 		vub   uint32
 		vubP  *uint32
-		err   error
 	)
 
 	if prm.Hash != nil {
@@ -138,6 +147,31 @@ func (s *Server) voteForSidechainValidator(prm governance.VoteValidatorPrm) erro
 	return nil
 }
 
+func (s *Server) alreadyVoted(validatorsToVote keys.PublicKeys) (bool, error) {
+	currentValidator := make(map[keys.PublicKey]struct{}, len(s.contracts.alphabet))
+	for letter, contract := range s.contracts.alphabet {
+		validator, err := s.morphClient.VotesFor(contract)
+		if err != nil {
+			return false, fmt.Errorf("receiving %s's vote: %w", letter, err)
+		}
+
+		if validator == nil {
+			continue
+		}
+
+		currentValidator[*validator] = struct{}{}
+	}
+
+	for _, v := range validatorsToVote {
+		_, voted := currentValidator[*v]
+		if !voted {
+			return false, nil
+		}
+	}
+
+	return true, nil
+}
+
 // VoteForSidechainValidator calls vote method on alphabet contracts with
 // the provided list of keys.
 func (s *Server) VoteForSidechainValidator(prm governance.VoteValidatorPrm) error {