end of gov refactoring
This commit is contained in:
parent
e266c40ce1
commit
eba38af83d
|
@ -10,7 +10,6 @@ import (
|
||||||
"github.com/cosmos/cosmos-sdk/simapp"
|
"github.com/cosmos/cosmos-sdk/simapp"
|
||||||
sdk "github.com/cosmos/cosmos-sdk/types"
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
||||||
"github.com/cosmos/cosmos-sdk/x/gov"
|
"github.com/cosmos/cosmos-sdk/x/gov"
|
||||||
keep "github.com/cosmos/cosmos-sdk/x/gov/keeper"
|
|
||||||
"github.com/cosmos/cosmos-sdk/x/staking"
|
"github.com/cosmos/cosmos-sdk/x/staking"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
@ -212,7 +211,7 @@ func TestTickPassedVotingPeriod(t *testing.T) {
|
||||||
activeQueue.Close()
|
activeQueue.Close()
|
||||||
|
|
||||||
proposalCoins := sdk.Coins{sdk.NewCoin(sdk.DefaultBondDenom, sdk.TokensFromConsensusPower(5))}
|
proposalCoins := sdk.Coins{sdk.NewCoin(sdk.DefaultBondDenom, sdk.TokensFromConsensusPower(5))}
|
||||||
newProposalMsg := gov.NewMsgSubmitProposal(keep.TestProposal, proposalCoins, addrs[0])
|
newProposalMsg := gov.NewMsgSubmitProposal(TestProposal, proposalCoins, addrs[0])
|
||||||
|
|
||||||
res, err := govHandler(ctx, newProposalMsg)
|
res, err := govHandler(ctx, newProposalMsg)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
@ -277,7 +276,7 @@ func TestProposalPassedEndblocker(t *testing.T) {
|
||||||
require.NotNil(t, macc)
|
require.NotNil(t, macc)
|
||||||
initialModuleAccCoins := app.BankKeeper.GetAllBalances(ctx, macc.GetAddress())
|
initialModuleAccCoins := app.BankKeeper.GetAllBalances(ctx, macc.GetAddress())
|
||||||
|
|
||||||
proposal, err := app.GovKeeper.SubmitProposal(ctx, keep.TestProposal)
|
proposal, err := app.GovKeeper.SubmitProposal(ctx, TestProposal)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
proposalCoins := sdk.Coins{sdk.NewCoin(sdk.DefaultBondDenom, sdk.TokensFromConsensusPower(10))}
|
proposalCoins := sdk.Coins{sdk.NewCoin(sdk.DefaultBondDenom, sdk.TokensFromConsensusPower(10))}
|
||||||
|
@ -329,7 +328,7 @@ func TestEndBlockerProposalHandlerFailed(t *testing.T) {
|
||||||
// Create a proposal where the handler will pass for the test proposal
|
// Create a proposal where the handler will pass for the test proposal
|
||||||
// because the value of contextKeyBadProposal is true.
|
// because the value of contextKeyBadProposal is true.
|
||||||
ctx = ctx.WithValue(contextKeyBadProposal, true)
|
ctx = ctx.WithValue(contextKeyBadProposal, true)
|
||||||
proposal, err := app.GovKeeper.SubmitProposal(ctx, keep.TestProposal)
|
proposal, err := app.GovKeeper.SubmitProposal(ctx, TestProposal)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
proposalCoins := sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdk.TokensFromConsensusPower(10)))
|
proposalCoins := sdk.NewCoins(sdk.NewCoin(sdk.DefaultBondDenom, sdk.TokensFromConsensusPower(10)))
|
||||||
|
|
|
@ -11,12 +11,15 @@ import (
|
||||||
"github.com/tendermint/tendermint/crypto/ed25519"
|
"github.com/tendermint/tendermint/crypto/ed25519"
|
||||||
|
|
||||||
sdk "github.com/cosmos/cosmos-sdk/types"
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
||||||
keep "github.com/cosmos/cosmos-sdk/x/gov/keeper"
|
"github.com/cosmos/cosmos-sdk/x/gov/types"
|
||||||
"github.com/cosmos/cosmos-sdk/x/staking"
|
"github.com/cosmos/cosmos-sdk/x/staking"
|
||||||
)
|
)
|
||||||
|
|
||||||
var (
|
var (
|
||||||
valTokens = sdk.TokensFromConsensusPower(42)
|
valTokens = sdk.TokensFromConsensusPower(42)
|
||||||
|
TestProposal = types.NewTextProposal("Test", "description")
|
||||||
|
TestDescription = staking.NewDescription("T", "E", "S", "T", "Z")
|
||||||
|
TestCommissionRates = staking.NewCommissionRates(sdk.ZeroDec(), sdk.ZeroDec(), sdk.ZeroDec())
|
||||||
)
|
)
|
||||||
|
|
||||||
// SortAddresses - Sorts Addresses
|
// SortAddresses - Sorts Addresses
|
||||||
|
@ -83,7 +86,7 @@ func createValidators(t *testing.T, stakingHandler sdk.Handler, ctx sdk.Context,
|
||||||
valTokens := sdk.TokensFromConsensusPower(powerAmt[i])
|
valTokens := sdk.TokensFromConsensusPower(powerAmt[i])
|
||||||
valCreateMsg := staking.NewMsgCreateValidator(
|
valCreateMsg := staking.NewMsgCreateValidator(
|
||||||
addrs[i], pubkeys[i], sdk.NewCoin(sdk.DefaultBondDenom, valTokens),
|
addrs[i], pubkeys[i], sdk.NewCoin(sdk.DefaultBondDenom, valTokens),
|
||||||
keep.TestDescription, keep.TestCommissionRates, sdk.OneInt(),
|
TestDescription, TestCommissionRates, sdk.OneInt(),
|
||||||
)
|
)
|
||||||
|
|
||||||
res, err := stakingHandler(ctx, valCreateMsg)
|
res, err := stakingHandler(ctx, valCreateMsg)
|
||||||
|
@ -91,3 +94,9 @@ func createValidators(t *testing.T, stakingHandler sdk.Handler, ctx sdk.Context,
|
||||||
require.NotNil(t, res)
|
require.NotNil(t, res)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// ProposalEqual checks if two proposals are equal (note: slow, for tests only)
|
||||||
|
func ProposalEqual(proposalA types.Proposal, proposalB types.Proposal) bool {
|
||||||
|
return bytes.Equal(types.ModuleCdc.MustMarshalBinaryBare(proposalA),
|
||||||
|
types.ModuleCdc.MustMarshalBinaryBare(proposalB))
|
||||||
|
}
|
||||||
|
|
|
@ -12,7 +12,6 @@ import (
|
||||||
"github.com/cosmos/cosmos-sdk/simapp"
|
"github.com/cosmos/cosmos-sdk/simapp"
|
||||||
"github.com/cosmos/cosmos-sdk/x/auth"
|
"github.com/cosmos/cosmos-sdk/x/auth"
|
||||||
"github.com/cosmos/cosmos-sdk/x/gov"
|
"github.com/cosmos/cosmos-sdk/x/gov"
|
||||||
keep "github.com/cosmos/cosmos-sdk/x/gov/keeper"
|
|
||||||
)
|
)
|
||||||
|
|
||||||
func TestImportExportQueues(t *testing.T) {
|
func TestImportExportQueues(t *testing.T) {
|
||||||
|
@ -28,7 +27,7 @@ func TestImportExportQueues(t *testing.T) {
|
||||||
ctx = app.BaseApp.NewContext(false, abci.Header{})
|
ctx = app.BaseApp.NewContext(false, abci.Header{})
|
||||||
|
|
||||||
// Create two proposals, put the second into the voting period
|
// Create two proposals, put the second into the voting period
|
||||||
proposal := keep.TestProposal
|
proposal := TestProposal
|
||||||
proposal1, err := app.GovKeeper.SubmitProposal(ctx, proposal)
|
proposal1, err := app.GovKeeper.SubmitProposal(ctx, proposal)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
proposalID1 := proposal1.ProposalID
|
proposalID1 := proposal1.ProposalID
|
||||||
|
@ -116,7 +115,7 @@ func TestEqualProposals(t *testing.T) {
|
||||||
app.BeginBlock(abci.RequestBeginBlock{Header: header})
|
app.BeginBlock(abci.RequestBeginBlock{Header: header})
|
||||||
|
|
||||||
// Submit two proposals
|
// Submit two proposals
|
||||||
proposal := keep.TestProposal
|
proposal := TestProposal
|
||||||
proposal1, err := app.GovKeeper.SubmitProposal(ctx, proposal)
|
proposal1, err := app.GovKeeper.SubmitProposal(ctx, proposal)
|
||||||
require.NoError(t, err)
|
require.NoError(t, err)
|
||||||
|
|
||||||
|
@ -125,7 +124,7 @@ func TestEqualProposals(t *testing.T) {
|
||||||
|
|
||||||
// They are similar but their IDs should be different
|
// They are similar but their IDs should be different
|
||||||
require.NotEqual(t, proposal1, proposal2)
|
require.NotEqual(t, proposal1, proposal2)
|
||||||
require.False(t, keep.ProposalEqual(proposal1, proposal2))
|
require.False(t, ProposalEqual(proposal1, proposal2))
|
||||||
|
|
||||||
// Now create two genesis blocks
|
// Now create two genesis blocks
|
||||||
state1 := gov.GenesisState{Proposals: []gov.Proposal{proposal1}}
|
state1 := gov.GenesisState{Proposals: []gov.Proposal{proposal1}}
|
||||||
|
@ -137,7 +136,7 @@ func TestEqualProposals(t *testing.T) {
|
||||||
proposal1.ProposalID = 55
|
proposal1.ProposalID = 55
|
||||||
proposal2.ProposalID = 55
|
proposal2.ProposalID = 55
|
||||||
require.Equal(t, proposal1, proposal1)
|
require.Equal(t, proposal1, proposal1)
|
||||||
require.True(t, keep.ProposalEqual(proposal1, proposal2))
|
require.True(t, ProposalEqual(proposal1, proposal2))
|
||||||
|
|
||||||
// Reassign proposals into state
|
// Reassign proposals into state
|
||||||
state1.Proposals[0] = proposal1
|
state1.Proposals[0] = proposal1
|
||||||
|
|
|
@ -1,211 +0,0 @@
|
||||||
package keeper
|
|
||||||
|
|
||||||
// noalias
|
|
||||||
// nolint
|
|
||||||
// DONTCOVER
|
|
||||||
|
|
||||||
import (
|
|
||||||
"bytes"
|
|
||||||
"encoding/hex"
|
|
||||||
"testing"
|
|
||||||
|
|
||||||
"github.com/stretchr/testify/require"
|
|
||||||
abci "github.com/tendermint/tendermint/abci/types"
|
|
||||||
"github.com/tendermint/tendermint/crypto"
|
|
||||||
"github.com/tendermint/tendermint/crypto/ed25519"
|
|
||||||
"github.com/tendermint/tendermint/libs/log"
|
|
||||||
tmtypes "github.com/tendermint/tendermint/types"
|
|
||||||
dbm "github.com/tendermint/tm-db"
|
|
||||||
|
|
||||||
"github.com/cosmos/cosmos-sdk/codec"
|
|
||||||
simappcodec "github.com/cosmos/cosmos-sdk/simapp/codec"
|
|
||||||
"github.com/cosmos/cosmos-sdk/store"
|
|
||||||
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
||||||
"github.com/cosmos/cosmos-sdk/x/auth"
|
|
||||||
"github.com/cosmos/cosmos-sdk/x/bank"
|
|
||||||
"github.com/cosmos/cosmos-sdk/x/gov/types"
|
|
||||||
"github.com/cosmos/cosmos-sdk/x/params/keeper"
|
|
||||||
paramtypes "github.com/cosmos/cosmos-sdk/x/params/types"
|
|
||||||
"github.com/cosmos/cosmos-sdk/x/staking"
|
|
||||||
"github.com/cosmos/cosmos-sdk/x/supply"
|
|
||||||
)
|
|
||||||
|
|
||||||
// dummy addresses used for testing
|
|
||||||
var (
|
|
||||||
delPk1 = newPubKey("0B485CFC0EECC619440448436F8FC9DF40566F2369E72400281454CB552AFB51")
|
|
||||||
delPk2 = newPubKey("0B485CFC0EECC619440448436F8FC9DF40566F2369E72400281454CB552AFB50")
|
|
||||||
delPk3 = newPubKey("0B485CFC0EECC619440448436F8FC9DF40566F2369E72400281454CB552AFB52")
|
|
||||||
delAddr1 = sdk.AccAddress(delPk1.Address())
|
|
||||||
delAddr2 = sdk.AccAddress(delPk2.Address())
|
|
||||||
delAddr3 = sdk.AccAddress(delPk3.Address())
|
|
||||||
|
|
||||||
valOpPk1 = newPubKey("0B485CFC0EECC619440448436F8FC9DF40566F2369E72400281454CB552AFB53")
|
|
||||||
valOpPk2 = newPubKey("0B485CFC0EECC619440448436F8FC9DF40566F2369E72400281454CB552AFB54")
|
|
||||||
valOpPk3 = newPubKey("0B485CFC0EECC619440448436F8FC9DF40566F2369E72400281454CB552AFB55")
|
|
||||||
valOpAddr1 = sdk.ValAddress(valOpPk1.Address())
|
|
||||||
valOpAddr2 = sdk.ValAddress(valOpPk2.Address())
|
|
||||||
valOpAddr3 = sdk.ValAddress(valOpPk3.Address())
|
|
||||||
valAccAddr1 = sdk.AccAddress(valOpPk1.Address())
|
|
||||||
valAccAddr2 = sdk.AccAddress(valOpPk2.Address())
|
|
||||||
valAccAddr3 = sdk.AccAddress(valOpPk3.Address())
|
|
||||||
|
|
||||||
TestAddrs = []sdk.AccAddress{
|
|
||||||
delAddr1, delAddr2, delAddr3,
|
|
||||||
valAccAddr1, valAccAddr2, valAccAddr3,
|
|
||||||
}
|
|
||||||
pubkeys = []crypto.PubKey{
|
|
||||||
delPk1, delPk2, delPk3, valOpPk1, valOpPk2, valOpPk3,
|
|
||||||
}
|
|
||||||
)
|
|
||||||
|
|
||||||
// TODO: remove dependency with staking
|
|
||||||
var (
|
|
||||||
TestProposal = types.NewTextProposal("Test", "description")
|
|
||||||
TestDescription = staking.NewDescription("T", "E", "S", "T", "Z")
|
|
||||||
TestCommissionRates = staking.NewCommissionRates(sdk.ZeroDec(), sdk.ZeroDec(), sdk.ZeroDec())
|
|
||||||
)
|
|
||||||
|
|
||||||
// TODO move to common testing framework
|
|
||||||
func newPubKey(pk string) (res crypto.PubKey) {
|
|
||||||
pkBytes, err := hex.DecodeString(pk)
|
|
||||||
if err != nil {
|
|
||||||
panic(err)
|
|
||||||
}
|
|
||||||
var pkEd ed25519.PubKeyEd25519
|
|
||||||
copy(pkEd[:], pkBytes)
|
|
||||||
return pkEd
|
|
||||||
}
|
|
||||||
|
|
||||||
func makeTestCodec() *codec.Codec {
|
|
||||||
var cdc = codec.New()
|
|
||||||
auth.RegisterCodec(cdc)
|
|
||||||
types.RegisterCodec(cdc)
|
|
||||||
supply.RegisterCodec(cdc)
|
|
||||||
staking.RegisterCodec(cdc)
|
|
||||||
sdk.RegisterCodec(cdc)
|
|
||||||
codec.RegisterCrypto(cdc)
|
|
||||||
|
|
||||||
return cdc
|
|
||||||
}
|
|
||||||
|
|
||||||
func createTestInput(
|
|
||||||
t *testing.T, isCheckTx bool, initPower int64,
|
|
||||||
) (sdk.Context, auth.AccountKeeper, bank.Keeper, Keeper, staking.Keeper, types.SupplyKeeper,
|
|
||||||
) {
|
|
||||||
|
|
||||||
initTokens := sdk.TokensFromConsensusPower(initPower)
|
|
||||||
keyAcc := sdk.NewKVStoreKey(auth.StoreKey)
|
|
||||||
keyBank := sdk.NewKVStoreKey(bank.StoreKey)
|
|
||||||
keyGov := sdk.NewKVStoreKey(types.StoreKey)
|
|
||||||
keyStaking := sdk.NewKVStoreKey(staking.StoreKey)
|
|
||||||
keySupply := sdk.NewKVStoreKey(supply.StoreKey)
|
|
||||||
keyParams := sdk.NewKVStoreKey(paramtypes.StoreKey)
|
|
||||||
tkeyParams := sdk.NewTransientStoreKey(paramtypes.TStoreKey)
|
|
||||||
|
|
||||||
db := dbm.NewMemDB()
|
|
||||||
ms := store.NewCommitMultiStore(db)
|
|
||||||
|
|
||||||
ms.MountStoreWithDB(keyAcc, sdk.StoreTypeIAVL, db)
|
|
||||||
ms.MountStoreWithDB(keySupply, sdk.StoreTypeIAVL, db)
|
|
||||||
ms.MountStoreWithDB(keyBank, sdk.StoreTypeIAVL, db)
|
|
||||||
ms.MountStoreWithDB(keyGov, sdk.StoreTypeIAVL, db)
|
|
||||||
ms.MountStoreWithDB(keyStaking, sdk.StoreTypeIAVL, db)
|
|
||||||
ms.MountStoreWithDB(keyParams, sdk.StoreTypeIAVL, db)
|
|
||||||
ms.MountStoreWithDB(tkeyParams, sdk.StoreTypeTransient, db)
|
|
||||||
require.Nil(t, ms.LoadLatestVersion())
|
|
||||||
|
|
||||||
ctx := sdk.NewContext(ms, abci.Header{ChainID: "gov-chain"}, isCheckTx, log.NewNopLogger())
|
|
||||||
ctx = ctx.WithConsensusParams(
|
|
||||||
&abci.ConsensusParams{
|
|
||||||
Validator: &abci.ValidatorParams{
|
|
||||||
PubKeyTypes: []string{tmtypes.ABCIPubKeyTypeEd25519},
|
|
||||||
},
|
|
||||||
},
|
|
||||||
)
|
|
||||||
|
|
||||||
cdc := makeTestCodec()
|
|
||||||
appCodec := simappcodec.NewAppCodec(cdc)
|
|
||||||
|
|
||||||
maccPerms := map[string][]string{
|
|
||||||
auth.FeeCollectorName: nil,
|
|
||||||
types.ModuleName: nil,
|
|
||||||
staking.NotBondedPoolName: {supply.Burner, supply.Staking},
|
|
||||||
staking.BondedPoolName: {supply.Burner, supply.Staking},
|
|
||||||
}
|
|
||||||
|
|
||||||
// create module accounts
|
|
||||||
feeCollectorAcc := supply.NewEmptyModuleAccount(auth.FeeCollectorName)
|
|
||||||
govAcc := supply.NewEmptyModuleAccount(types.ModuleName, supply.Burner)
|
|
||||||
notBondedPool := supply.NewEmptyModuleAccount(staking.NotBondedPoolName, supply.Burner, supply.Staking)
|
|
||||||
bondPool := supply.NewEmptyModuleAccount(staking.BondedPoolName, supply.Burner, supply.Staking)
|
|
||||||
|
|
||||||
blacklistedAddrs := make(map[string]bool)
|
|
||||||
blacklistedAddrs[feeCollectorAcc.GetAddress().String()] = true
|
|
||||||
blacklistedAddrs[govAcc.GetAddress().String()] = true
|
|
||||||
blacklistedAddrs[notBondedPool.GetAddress().String()] = true
|
|
||||||
blacklistedAddrs[bondPool.GetAddress().String()] = true
|
|
||||||
|
|
||||||
pk := keeper.NewKeeper(appCodec, keyParams, tkeyParams)
|
|
||||||
accountKeeper := auth.NewAccountKeeper(appCodec, keyAcc, pk.Subspace(auth.DefaultParamspace), auth.ProtoBaseAccount)
|
|
||||||
bankKeeper := bank.NewBaseKeeper(appCodec, keyBank, accountKeeper, pk.Subspace(bank.DefaultParamspace), blacklistedAddrs)
|
|
||||||
supplyKeeper := supply.NewKeeper(appCodec, keySupply, accountKeeper, bankKeeper, maccPerms)
|
|
||||||
|
|
||||||
sk := staking.NewKeeper(staking.ModuleCdc, keyStaking, bankKeeper, supplyKeeper, pk.Subspace(staking.DefaultParamspace))
|
|
||||||
sk.SetParams(ctx, staking.DefaultParams())
|
|
||||||
|
|
||||||
rtr := types.NewRouter().
|
|
||||||
AddRoute(types.RouterKey, types.ProposalHandler)
|
|
||||||
|
|
||||||
keeper := NewKeeper(
|
|
||||||
cdc, keyGov, pk.Subspace(types.DefaultParamspace).WithKeyTable(types.ParamKeyTable()), supplyKeeper, sk, rtr,
|
|
||||||
)
|
|
||||||
|
|
||||||
keeper.SetProposalID(ctx, types.DefaultStartingProposalID)
|
|
||||||
keeper.SetDepositParams(ctx, types.DefaultDepositParams())
|
|
||||||
keeper.SetVotingParams(ctx, types.DefaultVotingParams())
|
|
||||||
keeper.SetTallyParams(ctx, types.DefaultTallyParams())
|
|
||||||
|
|
||||||
initCoins := sdk.NewCoins(sdk.NewCoin(sk.BondDenom(ctx), initTokens))
|
|
||||||
totalSupply := sdk.NewCoins(sdk.NewCoin(sk.BondDenom(ctx), initTokens.MulRaw(int64(len(TestAddrs)))))
|
|
||||||
supplyKeeper.SetSupply(ctx, supply.NewSupply(totalSupply))
|
|
||||||
|
|
||||||
for i, addr := range TestAddrs {
|
|
||||||
accountKeeper.SetAccount(ctx, auth.NewBaseAccount(addr, pubkeys[i], uint64(i), 0))
|
|
||||||
require.NoError(t, bankKeeper.SetBalances(ctx, addr, initCoins))
|
|
||||||
}
|
|
||||||
|
|
||||||
keeper.supplyKeeper.SetModuleAccount(ctx, feeCollectorAcc)
|
|
||||||
keeper.supplyKeeper.SetModuleAccount(ctx, govAcc)
|
|
||||||
keeper.supplyKeeper.SetModuleAccount(ctx, bondPool)
|
|
||||||
keeper.supplyKeeper.SetModuleAccount(ctx, notBondedPool)
|
|
||||||
|
|
||||||
return ctx, accountKeeper, bankKeeper, keeper, sk, supplyKeeper
|
|
||||||
}
|
|
||||||
|
|
||||||
// ProposalEqual checks if two proposals are equal (note: slow, for tests only)
|
|
||||||
func ProposalEqual(proposalA types.Proposal, proposalB types.Proposal) bool {
|
|
||||||
return bytes.Equal(types.ModuleCdc.MustMarshalBinaryBare(proposalA),
|
|
||||||
types.ModuleCdc.MustMarshalBinaryBare(proposalB))
|
|
||||||
}
|
|
||||||
|
|
||||||
func createValidators(ctx sdk.Context, sk staking.Keeper, powers []int64) {
|
|
||||||
val1 := staking.NewValidator(valOpAddr1, valOpPk1, staking.Description{})
|
|
||||||
val2 := staking.NewValidator(valOpAddr2, valOpPk2, staking.Description{})
|
|
||||||
val3 := staking.NewValidator(valOpAddr3, valOpPk3, staking.Description{})
|
|
||||||
|
|
||||||
sk.SetValidator(ctx, val1)
|
|
||||||
sk.SetValidator(ctx, val2)
|
|
||||||
sk.SetValidator(ctx, val3)
|
|
||||||
sk.SetValidatorByConsAddr(ctx, val1)
|
|
||||||
sk.SetValidatorByConsAddr(ctx, val2)
|
|
||||||
sk.SetValidatorByConsAddr(ctx, val3)
|
|
||||||
sk.SetNewValidatorByPowerIndex(ctx, val1)
|
|
||||||
sk.SetNewValidatorByPowerIndex(ctx, val2)
|
|
||||||
sk.SetNewValidatorByPowerIndex(ctx, val3)
|
|
||||||
|
|
||||||
_, _ = sk.Delegate(ctx, valAccAddr1, sdk.TokensFromConsensusPower(powers[0]), sdk.Unbonded, val1, true)
|
|
||||||
_, _ = sk.Delegate(ctx, valAccAddr2, sdk.TokensFromConsensusPower(powers[1]), sdk.Unbonded, val2, true)
|
|
||||||
_, _ = sk.Delegate(ctx, valAccAddr3, sdk.TokensFromConsensusPower(powers[2]), sdk.Unbonded, val3, true)
|
|
||||||
|
|
||||||
_ = staking.EndBlocker(ctx, sk)
|
|
||||||
}
|
|
Loading…
Reference in New Issue