feat(client/v2): add support for pubkey

client/v2/autocli/flag/builder.go

@@ -28,6 +28,7 @@ const (
 	AddressStringScalarType          = "cosmos.AddressString"
 	ValidatorAddressStringScalarType = "cosmos.ValidatorAddressString"
 	ConsensusAddressStringScalarType = "cosmos.ConsensusAddressString"
+	PubkeyScalarType                 = "cosmos.Pubkey"
 )
 
 // Builder manages options for building pflag flags for protobuf messages.
@@ -71,6 +72,7 @@ func (b *Builder) init() {
 		b.scalarFlagTypes[AddressStringScalarType] = addressStringType{}
 		b.scalarFlagTypes[ValidatorAddressStringScalarType] = validatorAddressStringType{}
 		b.scalarFlagTypes[ConsensusAddressStringScalarType] = consensusAddressStringType{}
+		b.scalarFlagTypes[PubkeyScalarType] = pubkeyType{}
 	}
 }
 

client/v2/autocli/flag/pubkey.go

@@ -0,0 +1,64 @@
+package flag
+
+import (
+	"context"
+	"fmt"
+
+	"github.com/cosmos/cosmos-sdk/codec"
+	"github.com/cosmos/cosmos-sdk/codec/types"
+	cryptocodec "github.com/cosmos/cosmos-sdk/crypto/codec"
+	cryptotypes "github.com/cosmos/cosmos-sdk/crypto/types"
+	"google.golang.org/protobuf/reflect/protoreflect"
+)
+
+type pubkeyType struct{}
+
+func (a pubkeyType) NewValue(_ context.Context, _ *Builder) Value {
+	return pubkeyValue{}
+}
+
+func (a pubkeyType) DefaultValue() string {
+	return ""
+}
+
+type pubkeyValue struct {
+	value *types.Any
+}
+
+func (a pubkeyValue) Get(protoreflect.Value) (protoreflect.Value, error) {
+	return protoreflect.ValueOf(a.value), nil
+}
+
+func (a pubkeyValue) String() string {
+	return a.value.String()
+}
+
+func (a pubkeyValue) Set(s string) error {
+	// fallback to pubkey parsing
+	registry := types.NewInterfaceRegistry()
+	cryptocodec.RegisterInterfaces(registry)
+	cdc := codec.NewProtoCodec(registry)
+
+	var pk cryptotypes.PubKey
+	err2 := cdc.UnmarshalInterfaceJSON([]byte(s), &pk)
+	if err2 != nil {
+		return fmt.Errorf("input isn't a pubkey, or is an invalid account address: %w", err2)
+	}
+
+	any, err := types.NewAnyWithValue(pk)
+	if err != nil {
+		return fmt.Errorf("error converting to any type")
+	}
+	a.value = any
+
+	// a.value, err = a.addressCodec.BytesToString(pk.Address())
+	// if err != nil {
+	// 	return fmt.Errorf("invalid pubkey address: %w", err)
+	// }
+
+	return nil
+}
+
+func (a pubkeyValue) Type() string {
+	return "pubkey"
+}

proto/cosmos/staking/v1beta1/tx.proto

@@ -221,7 +221,7 @@ message MsgRotateConsPubKey {
   option (gogoproto.equal)           = false;
 
   string              validator_address = 1 [(cosmos_proto.scalar) = "cosmos.ValidatorAddressString"];
-  google.protobuf.Any new_pubkey        = 2 [(cosmos_proto.accepts_interface) = "cosmos.crypto.PubKey"];
+  google.protobuf.Any new_pubkey        = 2 [(cosmos_proto.scalar) = "cosmos.PubKey"];
 }
 
 // MsgRotateConsPubKeyResponse defines the response structure for executing a

x/staking/autocli.go

@@ -173,6 +173,13 @@ func (am AppModule) AutoCLIOptions() *autocliv1.ModuleOptions {
 					Example:        fmt.Sprintf(`%s tx staking cancel-unbond cosmosvaloper... 100stake 2 --from mykey`, version.AppName),
 					PositionalArgs: []*autocliv1.PositionalArgDescriptor{{ProtoField: "validator_address"}, {ProtoField: "amount"}, {ProtoField: "creation_height"}},
 				},
+				{
+					RpcMethod:      "RotateConsPubKey",
+					Use:            "rotate-cons-pubkey [validator-address] [new-pubkey]",
+					Short:          "rotate validator consensus pub key. Note: you have to replace the `~/.simapp/config/priv_validator_key.json` with new key and restart the node after rotating the key ",
+					Example:        fmt.Sprintf(`%s tx staking rotate-cons-pubkey myvalidator {"@type":"/cosmos.crypto.ed25519.PubKey","key":"oWg2ISpLF405Jcm2vXV+2v4fnjodh6aafuIdeoW+rUw="}`, version.AppName),
+					PositionalArgs: []*autocliv1.PositionalArgDescriptor{{ProtoField: "validator_address"}, {ProtoField: "new_pubkey"}},
+				},
 				{
 					RpcMethod:      "UpdateParams",
 					Use:            "update-params-proposal [params]",