feat: Add consensus address to validator query response

x/staking/keeper/grpc_query.go

@@ -3,6 +3,7 @@ package keeper
 import (
 	"context"
 	"errors"
+	cryptotypes "github.com/cosmos/cosmos-sdk/crypto/types"
 	"strings"
 
 	"google.golang.org/grpc/codes"
@@ -48,6 +49,7 @@ func (k Querier) Validators(ctx context.Context, req *types.QueryValidatorsReque
 			return nil, nil
 		}
 
+		setConsensusAddress(val)
 		return val, nil
 	}, func() *types.Validator {
 		return &types.Validator{}
@@ -84,6 +86,7 @@ func (k Querier) Validator(ctx context.Context, req *types.QueryValidatorRequest
 		return nil, status.Errorf(codes.NotFound, "validator %s not found", req.ValidatorAddr)
 	}
 
+	setConsensusAddress(&validator)
 	return &types.QueryValidatorResponse{Validator: validator}, nil
 }
 
@@ -649,3 +652,17 @@ func redelegationsToRedelegationResponses(ctx context.Context, k *Keeper, redels
 
 	return resp, nil
 }
+
+// setConsensusAddress sets the ConsensusAddress field for the given validator
+func setConsensusAddress(validator *types.Validator) {
+	if validator == nil {
+		return
+	}
+
+	cpk, ok := validator.ConsensusPubkey.GetCachedValue().(cryptotypes.PubKey)
+	// Best-effort way
+	if ok {
+		consAddr := sdk.ConsAddress(cpk.Address())
+		validator.ConsensusAddress = consAddr.String()
+	}
+}

x/staking/proto/cosmos/staking/v1beta1/staking.proto

@@ -145,6 +145,9 @@ message Validator {
 
   // list of unbonding ids, each uniquely identifying an unbonding of this validator
   repeated uint64 unbonding_ids = 13;
+
+  // consensus_address defines the address of the validator's consensus
+  string consensus_address = 14 [(cosmos_proto.scalar) = "cosmos.AddressString"];
 }
 
 // BondStatus is the status of a validator.