86 lines
2.4 KiB
Go
86 lines
2.4 KiB
Go
package keeper
|
|
|
|
import (
|
|
"context"
|
|
|
|
"cosmossdk.io/collections"
|
|
"cosmossdk.io/core/event"
|
|
storetypes "cosmossdk.io/core/store"
|
|
"cosmossdk.io/errors"
|
|
cmtproto "github.com/cometbft/cometbft/proto/tendermint/types"
|
|
cmttypes "github.com/cometbft/cometbft/types"
|
|
"google.golang.org/grpc/codes"
|
|
"google.golang.org/grpc/status"
|
|
|
|
"github.com/cosmos/cosmos-sdk/codec"
|
|
"github.com/cosmos/cosmos-sdk/x/consensus/types"
|
|
govtypes "github.com/cosmos/cosmos-sdk/x/gov/types"
|
|
)
|
|
|
|
var StoreKey = "Consensus"
|
|
|
|
type Keeper struct {
|
|
storeService storetypes.KVStoreService
|
|
event event.Service
|
|
|
|
authority string
|
|
ParamsStore collections.Item[cmtproto.ConsensusParams]
|
|
}
|
|
|
|
func NewKeeper(cdc codec.BinaryCodec, storeService storetypes.KVStoreService, authority string, em event.Service) Keeper {
|
|
sb := collections.NewSchemaBuilder(storeService)
|
|
return Keeper{
|
|
storeService: storeService,
|
|
authority: authority,
|
|
event: em,
|
|
ParamsStore: collections.NewItem(sb, collections.NewPrefix("Consensus"), "params", codec.CollValue[cmtproto.ConsensusParams](cdc)),
|
|
}
|
|
}
|
|
|
|
func (k *Keeper) GetAuthority() string {
|
|
return k.authority
|
|
}
|
|
|
|
// Querier
|
|
|
|
var _ types.QueryServer = Keeper{}
|
|
|
|
// Params queries params of consensus module
|
|
func (k Keeper) Params(ctx context.Context, _ *types.QueryParamsRequest) (*types.QueryParamsResponse, error) {
|
|
params, err := k.ParamsStore.Get(ctx)
|
|
if err != nil {
|
|
return nil, status.Error(codes.Internal, err.Error())
|
|
}
|
|
|
|
return &types.QueryParamsResponse{Params: ¶ms}, nil
|
|
}
|
|
|
|
// MsgServer
|
|
|
|
var _ types.MsgServer = Keeper{}
|
|
|
|
func (k Keeper) UpdateParams(ctx context.Context, msg *types.MsgUpdateParams) (*types.MsgUpdateParamsResponse, error) {
|
|
if k.GetAuthority() != msg.Authority {
|
|
return nil, errors.Wrapf(govtypes.ErrInvalidSigner, "invalid authority; expected %s, got %s", k.GetAuthority(), msg.Authority)
|
|
}
|
|
|
|
consensusParams := msg.ToProtoConsensusParams()
|
|
if err := cmttypes.ConsensusParamsFromProto(consensusParams).ValidateBasic(); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
if err := k.ParamsStore.Set(ctx, consensusParams); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
if err := k.event.EventManager(ctx).EmitKV(
|
|
ctx,
|
|
"update_consensus_params",
|
|
event.Attribute{Key: "authority", Value: msg.Authority},
|
|
event.Attribute{Key: "parameters", Value: consensusParams.String()}); err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
return &types.MsgUpdateParamsResponse{}, nil
|
|
}
|