feat: set validator consensus address

pkg/converter/converter.go

@@ -7,6 +7,7 @@ import (
 	"github.com/cosmos/cosmos-sdk/codec"
 	codecTyped "github.com/cosmos/cosmos-sdk/codec/types"
 	"github.com/cosmos/cosmos-sdk/std"
+	sdkTypes "github.com/cosmos/cosmos-sdk/types"
 	slashingTypes "github.com/cosmos/cosmos-sdk/x/slashing/types"
 	stakingTypes "github.com/cosmos/cosmos-sdk/x/staking/types"
 )
@@ -82,3 +83,24 @@ func (c *Converter) ValidatorFromCosmosValidator(
 		SigningInfo:             valSigningInfo,
 	}
 }
+
+func (c *Converter) SetValidatorConsumerConsensusAddr(validator *types.Validator, consumerKey string) error {
+	consAddress, err := sdkTypes.ConsAddressFromBech32(consumerKey)
+	if err != nil {
+		return err
+	}
+
+	validator.ConsensusAddressValcons = consAddress.String()
+	validator.ConsensusAddressHex = fmt.Sprintf("%x", consAddress)
+
+	return nil
+}
+
+func (c *Converter) GetConsKeyFromBech32(addr string) (string, error) {
+	consAddress, err := sdkTypes.ConsAddressFromBech32(addr)
+	if err != nil {
+		return "", err
+	}
+
+	return consAddress.String(), nil
+}

pkg/data/manager.go

@@ -230,6 +230,9 @@ func (m *Manager) GetValidatorsAndSigningInfoForConsumerChain(height int64) (typ
 			}
 
 			validator := m.converter.ValidatorFromCosmosValidator(validatorRaw, &signingInfo)
+			if err := m.converter.SetValidatorConsumerConsensusAddr(validator, consensusAddr); err != nil {
+				m.logger.Warn().Err(err).Msg("Could not set validator consumer consensus address")
+			}
 
 			mutex.Lock()
 			validators[index] = validator