refactor: migrate token params

modules/coinswap/module.go

@@ -23,6 +23,9 @@ import (
 	"github.com/irisnet/irismod/types/exported"
 )
 
+// ConsensusVersion defines the current coinswap module consensus version.
+const ConsensusVersion = 5
+
 var (
 	_ module.AppModule           = AppModule{}
 	_ module.AppModuleBasic      = AppModuleBasic{}
@@ -159,7 +162,7 @@ func (am AppModule) ExportGenesis(ctx sdk.Context, cdc codec.JSONCodec) json.Raw
 }
 
 // ConsensusVersion implements AppModule/ConsensusVersion.
-func (AppModule) ConsensusVersion() uint64 { return 5 }
+func (AppModule) ConsensusVersion() uint64 { return ConsensusVersion }
 
 // ____________________________________________________________________________
 

modules/farm/module.go

@@ -25,6 +25,9 @@ import (
 	"github.com/irisnet/irismod/types/exported"
 )
 
+// ConsensusVersion defines the current farm module consensus version.
+const ConsensusVersion = 3
+
 var (
 	_ module.AppModule           = AppModule{}
 	_ module.AppModuleBasic      = AppModuleBasic{}
@@ -161,7 +164,7 @@ func (am AppModule) ExportGenesis(ctx sdk.Context, cdc codec.JSONCodec) json.Raw
 }
 
 // ConsensusVersion implements AppModule/ConsensusVersion.
-func (AppModule) ConsensusVersion() uint64 { return 3 }
+func (AppModule) ConsensusVersion() uint64 { return ConsensusVersion }
 
 // BeginBlock performs a no-op.
 func (am AppModule) BeginBlock(ctx sdk.Context, _ abci.RequestBeginBlock) {}

modules/htlc/module.go

@@ -25,6 +25,9 @@ import (
 	"github.com/irisnet/irismod/types/exported"
 )
 
+// ConsensusVersion defines the current htlc module consensus version.
+const ConsensusVersion = 2
+
 var (
 	_ module.AppModule           = AppModule{}
 	_ module.AppModuleBasic      = AppModuleBasic{}
@@ -155,7 +158,7 @@ func (am AppModule) ExportGenesis(ctx sdk.Context, cdc codec.JSONCodec) json.Raw
 }
 
 // ConsensusVersion implements AppModule/ConsensusVersion.
-func (AppModule) ConsensusVersion() uint64 { return 2 }
+func (AppModule) ConsensusVersion() uint64 { return ConsensusVersion }
 
 // BeginBlock performs a no-op.
 func (am AppModule) BeginBlock(ctx sdk.Context, _ abci.RequestBeginBlock) {

modules/service/module.go

@@ -24,6 +24,9 @@ import (
 	"github.com/irisnet/irismod/types/exported"
 )
 
+// ConsensusVersion defines the current service module consensus version.
+const ConsensusVersion = 2
+
 var (
 	_ module.AppModule           = AppModule{}
 	_ module.AppModuleBasic      = AppModuleBasic{}
@@ -152,7 +155,7 @@ func (am AppModule) ExportGenesis(ctx sdk.Context, cdc codec.JSONCodec) json.Raw
 }
 
 // ConsensusVersion implements AppModule/ConsensusVersion.
-func (AppModule) ConsensusVersion() uint64 { return 2 }
+func (AppModule) ConsensusVersion() uint64 { return ConsensusVersion }
 
 // BeginBlock performs a no-op.
 func (am AppModule) BeginBlock(ctx sdk.Context, _ abci.RequestBeginBlock) {

modules/token/genesis.go

@@ -15,7 +15,9 @@ func InitGenesis(ctx sdk.Context, k keeper.Keeper, data v1.GenesisState) {
 		panic(err.Error())
 	}
 
-	k.SetParamSet(ctx, data.Params)
+	if err := k.SetParams(ctx, data.Params); err != nil {
+		panic(err.Error())
+	}
 
 	// init tokens
 	for _, token := range data.Tokens {
@@ -43,7 +45,7 @@ func ExportGenesis(ctx sdk.Context, k keeper.Keeper) *v1.GenesisState {
 		tokens = append(tokens, *t)
 	}
 	return &v1.GenesisState{
-		Params:      k.GetParamSet(ctx),
+		Params:      k.GetParams(ctx),
 		Tokens:      tokens,
 		BurnedCoins: k.GetAllBurnCoin(ctx),
 	}

modules/token/handler_test.go

@@ -54,10 +54,11 @@ func (suite *HandlerSuite) SetupTest() {
 	suite.bk = app.BankKeeper
 
 	// set params
-	suite.keeper.SetParamSet(suite.ctx, v1.DefaultParams())
+	err := suite.keeper.SetParams(suite.ctx, v1.DefaultParams())
+	suite.NoError(err)
 
 	// init tokens to addr
-	err := suite.bk.MintCoins(suite.ctx, types.ModuleName, initCoin)
+	err = suite.bk.MintCoins(suite.ctx, types.ModuleName, initCoin)
 	suite.NoError(err)
 	err = suite.bk.SendCoinsFromModuleToAccount(suite.ctx, types.ModuleName, owner, initCoin)
 	suite.NoError(err)

modules/token/keeper/fees.go

@@ -56,12 +56,14 @@ func (k Keeper) GetTokenMintFee(ctx sdk.Context, symbol string) (sdk.Coin, error
 	}
 
 	mintFee := sdk.NewDecFromInt(fee.Amount).Mul(params.MintTokenFeeRatio).TruncateInt()
-	return token.ToMinCoin(sdk.NewDecCoinFromDec(params.IssueTokenBaseFee.Denom, sdk.NewDecFromInt(mintFee)))
+	return token.ToMinCoin(
+		sdk.NewDecCoinFromDec(params.IssueTokenBaseFee.Denom, sdk.NewDecFromInt(mintFee)),
+	)
 }
 
 func (k Keeper) calcTokenIssueFee(ctx sdk.Context, symbol string) (sdk.Coin, v1.Params) {
 	// get params
-	params := k.GetParamSet(ctx)
+	params := k.GetParams(ctx)
 	issueTokenBaseFee := params.IssueTokenBaseFee
 
 	// compute the fee
@@ -74,7 +76,7 @@ func (k Keeper) calcTokenIssueFee(ctx sdk.Context, symbol string) (sdk.Coin, v1.
 
 // feeHandler handles the fee of token
 func feeHandler(ctx sdk.Context, k Keeper, feeAcc sdk.AccAddress, fee sdk.Coin) error {
-	params := k.GetParamSet(ctx)
+	params := k.GetParams(ctx)
 	tokenTaxRate := params.TokenTaxRate
 
 	// compute community tax and burned coin

modules/token/keeper/grpc_query.go

@@ -76,7 +76,7 @@ func (k Keeper) Tokens(
 		pageRes, err = query.Paginate(
 			tokenStore,
 			shapePageRequest(req.Pagination),
-			func(key []byte, value []byte) error {
+			func(_ []byte, value []byte) error {
 				var token v1.Token
 				k.cdc.MustUnmarshal(value, &token)
 				tokens = append(tokens, &token)
@@ -88,7 +88,7 @@ func (k Keeper) Tokens(
 		}
 	} else {
 		tokenStore := prefix.NewStore(store, types.KeyTokens(owner, ""))
-		pageRes, err = query.Paginate(tokenStore, shapePageRequest(req.Pagination), func(key []byte, value []byte) error {
+		pageRes, err = query.Paginate(tokenStore, shapePageRequest(req.Pagination), func(_ []byte, value []byte) error {
 			var symbol gogotypes.StringValue
 			k.cdc.MustUnmarshal(value, &symbol)
 			token, err := k.GetToken(ctx, symbol.Value)
@@ -151,7 +151,7 @@ func (k Keeper) Params(
 	req *v1.QueryParamsRequest,
 ) (*v1.QueryParamsResponse, error) {
 	ctx := sdk.UnwrapSDKContext(c)
-	params := k.GetParamSet(ctx)
+	params := k.GetParams(ctx)
 
 	return &v1.QueryParamsResponse{Params: params}, nil
 }

modules/token/keeper/grpc_query_test.go

@@ -22,11 +22,17 @@ func (suite *KeeperTestSuite) TestGRPCQueryToken() {
 	_ = suite.app.TokenKeeper.AddToken(ctx, token)
 
 	// Query token
-	tokenResp1, err := queryClient.Token(gocontext.Background(), &v1.QueryTokenRequest{Denom: "btc"})
+	tokenResp1, err := queryClient.Token(
+		gocontext.Background(),
+		&v1.QueryTokenRequest{Denom: "btc"},
+	)
 	suite.Require().NoError(err)
 	suite.Require().NotNil(tokenResp1)
 
-	tokenResp2, err := queryClient.Token(gocontext.Background(), &v1.QueryTokenRequest{Denom: "satoshi"})
+	tokenResp2, err := queryClient.Token(
+		gocontext.Background(),
+		&v1.QueryTokenRequest{Denom: "satoshi"},
+	)
 	suite.Require().NoError(err)
 	suite.Require().NotNil(tokenResp2)
 
@@ -56,7 +62,7 @@ func (suite *KeeperTestSuite) TestGRPCQueryParams() {
 	queryClient := v1.NewQueryClient(queryHelper)
 
 	paramsResp, err := queryClient.Params(gocontext.Background(), &v1.QueryParamsRequest{})
-	params := app.TokenKeeper.GetParamSet(ctx)
+	params := app.TokenKeeper.GetParams(ctx)
 	suite.Require().NoError(err)
 	suite.Equal(params, paramsResp.Params)
 }

modules/token/keeper/keeper.go

@@ -10,7 +10,6 @@ import (
 	storetypes "github.com/cosmos/cosmos-sdk/store/types"
 	sdk "github.com/cosmos/cosmos-sdk/types"
 	sdkerrors "github.com/cosmos/cosmos-sdk/types/errors"
-	paramstypes "github.com/cosmos/cosmos-sdk/x/params/types"
 
 	"github.com/irisnet/irismod/modules/token/types"
 	v1 "github.com/irisnet/irismod/modules/token/types/v1"
@@ -20,33 +19,28 @@ type Keeper struct {
 	storeKey         storetypes.StoreKey
 	cdc              codec.Codec
 	bankKeeper       types.BankKeeper
-	paramSpace       paramstypes.Subspace
 	blockedAddrs     map[string]bool
 	feeCollectorName string
+	authority        string
 	registry         v1.SwapRegistry
 }
 
 func NewKeeper(
 	cdc codec.Codec,
 	key storetypes.StoreKey,
-	paramSpace paramstypes.Subspace,
 	bankKeeper types.BankKeeper,
 	blockedAddrs map[string]bool,
 	feeCollectorName string,
+	authority string,
 ) Keeper {
-	// set KeyTable if it has not already been set
-	if !paramSpace.HasKeyTable() {
-		paramSpace = paramSpace.WithKeyTable(v1.ParamKeyTable())
-	}
-
 	return Keeper{
 		storeKey:         key,
 		cdc:              cdc,
-		paramSpace:       paramSpace,
 		bankKeeper:       bankKeeper,
 		feeCollectorName: feeCollectorName,
 		blockedAddrs:     blockedAddrs,
 		registry:         make(v1.SwapRegistry),
+		authority:        authority,
 	}
 }
 

modules/token/keeper/keeper_test.go

@@ -51,7 +51,7 @@ func (suite *KeeperTestSuite) SetupTest() {
 	suite.app = app
 
 	// set params
-	suite.keeper.SetParamSet(suite.ctx, v1.DefaultParams())
+	suite.keeper.SetParams(suite.ctx, v1.DefaultParams())
 
 	// init tokens to addr
 	err := suite.bk.MintCoins(suite.ctx, types.ModuleName, initCoin)

modules/token/keeper/migrations.go

@@ -0,0 +1,24 @@
+package keeper
+
+import (
+	sdk "github.com/cosmos/cosmos-sdk/types"
+
+	v2 "github.com/irisnet/irismod/modules/token/migrations/v2"
+	"github.com/irisnet/irismod/types/exported"
+)
+
+// Migrator is a struct for handling in-place store migrations.
+type Migrator struct {
+	k              Keeper
+	legacySubspace exported.Subspace
+}
+
+// NewMigrator returns a new Migrator.
+func NewMigrator(k Keeper, legacySubspace exported.Subspace) Migrator {
+	return Migrator{k: k, legacySubspace: legacySubspace}
+}
+
+// Migrate1to2 migrates from version 1 to 2.
+func (m Migrator) Migrate1to2(ctx sdk.Context) error {
+	return v2.Migrate(ctx, m.k, m.legacySubspace)
+}