1347 lines
39 KiB
Go
1347 lines
39 KiB
Go
package testutil
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"strings"
|
|
"testing"
|
|
|
|
"github.com/gogo/protobuf/proto"
|
|
"github.com/stretchr/testify/suite"
|
|
tmcli "github.com/tendermint/tendermint/libs/cli"
|
|
"github.com/tendermint/tendermint/proto/tendermint/crypto"
|
|
"github.com/tendermint/tendermint/rpc/client/http"
|
|
|
|
"github.com/cosmos/cosmos-sdk/client/flags"
|
|
"github.com/cosmos/cosmos-sdk/crypto/hd"
|
|
"github.com/cosmos/cosmos-sdk/crypto/keyring"
|
|
"github.com/cosmos/cosmos-sdk/crypto/keys/ed25519"
|
|
clitestutil "github.com/cosmos/cosmos-sdk/testutil/cli"
|
|
"github.com/cosmos/cosmos-sdk/testutil/network"
|
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
"github.com/cosmos/cosmos-sdk/types/query"
|
|
banktestutil "github.com/cosmos/cosmos-sdk/x/bank/client/testutil"
|
|
"github.com/cosmos/cosmos-sdk/x/staking/client/cli"
|
|
"github.com/cosmos/cosmos-sdk/x/staking/types"
|
|
)
|
|
|
|
type IntegrationTestSuite struct {
|
|
suite.Suite
|
|
|
|
cfg network.Config
|
|
network *network.Network
|
|
}
|
|
|
|
func NewIntegrationTestSuite(cfg network.Config) *IntegrationTestSuite {
|
|
return &IntegrationTestSuite{cfg: cfg}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) SetupSuite() {
|
|
s.T().Log("setting up integration test suite")
|
|
|
|
if testing.Short() {
|
|
s.T().Skip("skipping test in unit-tests mode.")
|
|
}
|
|
|
|
s.network = network.New(s.T(), s.cfg)
|
|
|
|
_, err := s.network.WaitForHeight(1)
|
|
s.Require().NoError(err)
|
|
|
|
unbond, err := sdk.ParseCoinNormalized("10stake")
|
|
s.Require().NoError(err)
|
|
|
|
val := s.network.Validators[0]
|
|
val2 := s.network.Validators[1]
|
|
|
|
// redelegate
|
|
_, err = MsgRedelegateExec(
|
|
val.ClientCtx,
|
|
val.Address,
|
|
val.ValAddress,
|
|
val2.ValAddress,
|
|
unbond,
|
|
fmt.Sprintf("--%s=%d", flags.FlagGas, 202954), // 202954 is the required
|
|
)
|
|
s.Require().NoError(err)
|
|
_, err = s.network.WaitForHeight(1)
|
|
s.Require().NoError(err)
|
|
// unbonding
|
|
_, err = MsgUnbondExec(val.ClientCtx, val.Address, val.ValAddress, unbond)
|
|
s.Require().NoError(err)
|
|
_, err = s.network.WaitForHeight(1)
|
|
s.Require().NoError(err)
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TearDownSuite() {
|
|
s.T().Log("tearing down integration test suite")
|
|
s.network.Cleanup()
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestNewCreateValidatorCmd() {
|
|
require := s.Require()
|
|
val := s.network.Validators[0]
|
|
|
|
consPrivKey := ed25519.GenPrivKey()
|
|
consPubKeyBz, err := s.cfg.Codec.MarshalInterfaceJSON(consPrivKey.PubKey())
|
|
require.NoError(err)
|
|
require.NotNil(consPubKeyBz)
|
|
|
|
info, _, err := val.ClientCtx.Keyring.NewMnemonic("NewValidator", keyring.English, sdk.FullFundraiserPath, keyring.DefaultBIP39Passphrase, hd.Secp256k1)
|
|
require.NoError(err)
|
|
|
|
newAddr := sdk.AccAddress(info.GetPubKey().Address())
|
|
_, err = banktestutil.MsgSendExec(
|
|
val.ClientCtx,
|
|
val.Address,
|
|
newAddr,
|
|
sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(200))), fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
)
|
|
require.NoError(err)
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expectErr bool
|
|
expectedCode uint32
|
|
respType proto.Message
|
|
}{
|
|
{
|
|
"invalid transaction (missing amount)",
|
|
[]string{
|
|
fmt.Sprintf("--%s=AFAF00C4", cli.FlagIdentity),
|
|
fmt.Sprintf("--%s=https://newvalidator.io", cli.FlagWebsite),
|
|
fmt.Sprintf("--%s=contact@newvalidator.io", cli.FlagSecurityContact),
|
|
fmt.Sprintf("--%s='Hey, I am a new validator. Please delegate!'", cli.FlagDetails),
|
|
fmt.Sprintf("--%s=0.5", cli.FlagCommissionRate),
|
|
fmt.Sprintf("--%s=1.0", cli.FlagCommissionMaxRate),
|
|
fmt.Sprintf("--%s=0.1", cli.FlagCommissionMaxChangeRate),
|
|
fmt.Sprintf("--%s=1", cli.FlagMinSelfDelegation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, newAddr),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
true, 0, nil,
|
|
},
|
|
{
|
|
"invalid transaction (missing pubkey)",
|
|
[]string{
|
|
fmt.Sprintf("--%s=%dstake", cli.FlagAmount, 100),
|
|
fmt.Sprintf("--%s=AFAF00C4", cli.FlagIdentity),
|
|
fmt.Sprintf("--%s=https://newvalidator.io", cli.FlagWebsite),
|
|
fmt.Sprintf("--%s=contact@newvalidator.io", cli.FlagSecurityContact),
|
|
fmt.Sprintf("--%s='Hey, I am a new validator. Please delegate!'", cli.FlagDetails),
|
|
fmt.Sprintf("--%s=0.5", cli.FlagCommissionRate),
|
|
fmt.Sprintf("--%s=1.0", cli.FlagCommissionMaxRate),
|
|
fmt.Sprintf("--%s=0.1", cli.FlagCommissionMaxChangeRate),
|
|
fmt.Sprintf("--%s=1", cli.FlagMinSelfDelegation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, newAddr),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
true, 0, nil,
|
|
},
|
|
{
|
|
"invalid transaction (missing moniker)",
|
|
[]string{
|
|
fmt.Sprintf("--%s=%s", cli.FlagPubKey, consPubKeyBz),
|
|
fmt.Sprintf("--%s=%dstake", cli.FlagAmount, 100),
|
|
fmt.Sprintf("--%s=AFAF00C4", cli.FlagIdentity),
|
|
fmt.Sprintf("--%s=https://newvalidator.io", cli.FlagWebsite),
|
|
fmt.Sprintf("--%s=contact@newvalidator.io", cli.FlagSecurityContact),
|
|
fmt.Sprintf("--%s='Hey, I am a new validator. Please delegate!'", cli.FlagDetails),
|
|
fmt.Sprintf("--%s=0.5", cli.FlagCommissionRate),
|
|
fmt.Sprintf("--%s=1.0", cli.FlagCommissionMaxRate),
|
|
fmt.Sprintf("--%s=0.1", cli.FlagCommissionMaxChangeRate),
|
|
fmt.Sprintf("--%s=1", cli.FlagMinSelfDelegation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, newAddr),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
true, 0, nil,
|
|
},
|
|
{
|
|
"valid transaction",
|
|
[]string{
|
|
fmt.Sprintf("--%s=%s", cli.FlagPubKey, consPubKeyBz),
|
|
fmt.Sprintf("--%s=%dstake", cli.FlagAmount, 100),
|
|
fmt.Sprintf("--%s=NewValidator", cli.FlagMoniker),
|
|
fmt.Sprintf("--%s=AFAF00C4", cli.FlagIdentity),
|
|
fmt.Sprintf("--%s=https://newvalidator.io", cli.FlagWebsite),
|
|
fmt.Sprintf("--%s=contact@newvalidator.io", cli.FlagSecurityContact),
|
|
fmt.Sprintf("--%s='Hey, I am a new validator. Please delegate!'", cli.FlagDetails),
|
|
fmt.Sprintf("--%s=0.5", cli.FlagCommissionRate),
|
|
fmt.Sprintf("--%s=1.0", cli.FlagCommissionMaxRate),
|
|
fmt.Sprintf("--%s=0.1", cli.FlagCommissionMaxChangeRate),
|
|
fmt.Sprintf("--%s=1", cli.FlagMinSelfDelegation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, newAddr),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 0, &sdk.TxResponse{},
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.NewCreateValidatorCmd()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
if tc.expectErr {
|
|
require.Error(err)
|
|
} else {
|
|
require.NoError(err, "test: %s\noutput: %s", tc.name, out.String())
|
|
err = clientCtx.Codec.UnmarshalJSON(out.Bytes(), tc.respType)
|
|
require.NoError(err, out.String(), "test: %s, output\n:", tc.name, out.String())
|
|
|
|
txResp := tc.respType.(*sdk.TxResponse)
|
|
require.Equal(tc.expectedCode, txResp.Code,
|
|
"test: %s, output\n:", tc.name, out.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryValidator() {
|
|
val := s.network.Validators[0]
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expectErr bool
|
|
}{
|
|
{
|
|
"with invalid address ",
|
|
[]string{"somethinginvalidaddress", fmt.Sprintf("--%s=json", tmcli.OutputFlag)},
|
|
true,
|
|
},
|
|
{
|
|
"with valid and not existing address",
|
|
[]string{"cosmosvaloper15jkng8hytwt22lllv6mw4k89qkqehtahd84ptu", fmt.Sprintf("--%s=json", tmcli.OutputFlag)},
|
|
true,
|
|
},
|
|
{
|
|
"happy case",
|
|
[]string{val.ValAddress.String(), fmt.Sprintf("--%s=json", tmcli.OutputFlag)},
|
|
false,
|
|
},
|
|
}
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryValidator()
|
|
clientCtx := val.ClientCtx
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
if tc.expectErr {
|
|
s.Require().Error(err)
|
|
s.Require().NotEqual("internal", err.Error())
|
|
} else {
|
|
var result types.Validator
|
|
s.Require().NoError(clientCtx.Codec.UnmarshalJSON(out.Bytes(), &result))
|
|
s.Require().Equal(val.ValAddress.String(), result.OperatorAddress)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryValidators() {
|
|
val := s.network.Validators[0]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
minValidatorCount int
|
|
}{
|
|
{
|
|
"one validator case",
|
|
[]string{
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
fmt.Sprintf("--%s=1", flags.FlagLimit),
|
|
},
|
|
1,
|
|
},
|
|
{
|
|
"multi validator case",
|
|
[]string{fmt.Sprintf("--%s=json", tmcli.OutputFlag)},
|
|
len(s.network.Validators),
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryValidators()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
s.Require().NoError(err)
|
|
|
|
var result types.QueryValidatorsResponse
|
|
s.Require().NoError(clientCtx.Codec.UnmarshalJSON(out.Bytes(), &result))
|
|
s.Require().Equal(tc.minValidatorCount, len(result.Validators))
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryDelegation() {
|
|
val := s.network.Validators[0]
|
|
val2 := s.network.Validators[1]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expErr bool
|
|
respType proto.Message
|
|
expected proto.Message
|
|
}{
|
|
{
|
|
"with wrong delegator address",
|
|
[]string{
|
|
"wrongDelAddr",
|
|
val2.ValAddress.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true, nil, nil,
|
|
},
|
|
{
|
|
"with wrong validator address",
|
|
[]string{
|
|
val.Address.String(),
|
|
"wrongValAddr",
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true, nil, nil,
|
|
},
|
|
{
|
|
"with json output",
|
|
[]string{
|
|
val.Address.String(),
|
|
val2.ValAddress.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
false,
|
|
&types.DelegationResponse{},
|
|
&types.DelegationResponse{
|
|
Delegation: types.Delegation{
|
|
DelegatorAddress: val.Address.String(),
|
|
ValidatorAddress: val2.ValAddress.String(),
|
|
Shares: sdk.NewDec(10),
|
|
},
|
|
Balance: sdk.NewCoin(sdk.DefaultBondDenom, sdk.NewInt(10)),
|
|
},
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryDelegation()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
if tc.expErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
s.Require().NoError(err)
|
|
s.Require().NoError(clientCtx.Codec.UnmarshalJSON(out.Bytes(), tc.respType), out.String())
|
|
s.Require().Equal(tc.expected.String(), tc.respType.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryDelegations() {
|
|
val := s.network.Validators[0]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expErr bool
|
|
respType proto.Message
|
|
expected proto.Message
|
|
}{
|
|
{
|
|
"with no delegator address",
|
|
[]string{},
|
|
true, nil, nil,
|
|
},
|
|
{
|
|
"with wrong delegator address",
|
|
[]string{"wrongDelAddr"},
|
|
true, nil, nil,
|
|
},
|
|
{
|
|
"valid request (height specific)",
|
|
[]string{
|
|
val.Address.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
fmt.Sprintf("--%s=1", flags.FlagHeight),
|
|
},
|
|
false,
|
|
&types.QueryDelegatorDelegationsResponse{},
|
|
&types.QueryDelegatorDelegationsResponse{
|
|
DelegationResponses: types.DelegationResponses{
|
|
types.NewDelegationResp(val.Address, val.ValAddress, sdk.NewDecFromInt(cli.DefaultTokens), sdk.NewCoin(sdk.DefaultBondDenom, cli.DefaultTokens)),
|
|
},
|
|
Pagination: &query.PageResponse{},
|
|
},
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryDelegations()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
if tc.expErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
s.Require().NoError(err)
|
|
s.Require().NoError(clientCtx.Codec.UnmarshalJSON(out.Bytes(), tc.respType), out.String())
|
|
s.Require().Equal(tc.expected.String(), tc.respType.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryValidatorDelegations() {
|
|
val := s.network.Validators[0]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expErr bool
|
|
respType proto.Message
|
|
expected proto.Message
|
|
}{
|
|
{
|
|
"with no validator address",
|
|
[]string{},
|
|
true, nil, nil,
|
|
},
|
|
{
|
|
"wrong validator address",
|
|
[]string{"wrongValAddr"},
|
|
true, nil, nil,
|
|
},
|
|
{
|
|
"valid request(height specific)",
|
|
[]string{
|
|
val.Address.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
fmt.Sprintf("--%s=1", flags.FlagHeight),
|
|
},
|
|
false,
|
|
&types.QueryValidatorDelegationsResponse{},
|
|
&types.QueryValidatorDelegationsResponse{
|
|
DelegationResponses: types.DelegationResponses{
|
|
types.NewDelegationResp(val.Address, val.ValAddress, sdk.NewDecFromInt(cli.DefaultTokens), sdk.NewCoin(sdk.DefaultBondDenom, cli.DefaultTokens)),
|
|
},
|
|
Pagination: &query.PageResponse{},
|
|
},
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryDelegations()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
if tc.expErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
s.Require().NoError(err)
|
|
s.Require().NoError(clientCtx.Codec.UnmarshalJSON(out.Bytes(), tc.respType), out.String())
|
|
s.Require().Equal(tc.expected.String(), tc.respType.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryUnbondingDelegations() {
|
|
val := s.network.Validators[0]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expErr bool
|
|
}{
|
|
{
|
|
"wrong delegator address",
|
|
[]string{
|
|
"wrongDelAddr",
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true,
|
|
},
|
|
{
|
|
"valid request",
|
|
[]string{
|
|
val.Address.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
false,
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryUnbondingDelegations()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
|
|
if tc.expErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
var ubds types.QueryDelegatorUnbondingDelegationsResponse
|
|
err = val.ClientCtx.Codec.UnmarshalJSON(out.Bytes(), &ubds)
|
|
|
|
s.Require().NoError(err)
|
|
s.Require().Len(ubds.UnbondingResponses, 1)
|
|
s.Require().Equal(ubds.UnbondingResponses[0].DelegatorAddress, val.Address.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryUnbondingDelegation() {
|
|
val := s.network.Validators[0]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expErr bool
|
|
}{
|
|
{
|
|
"wrong delegator address",
|
|
[]string{
|
|
"wrongDelAddr",
|
|
val.ValAddress.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true,
|
|
},
|
|
{
|
|
"wrong validator address",
|
|
[]string{
|
|
val.Address.String(),
|
|
"wrongValAddr",
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true,
|
|
},
|
|
{
|
|
"valid request",
|
|
[]string{
|
|
val.Address.String(),
|
|
val.ValAddress.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
false,
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryUnbondingDelegation()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
|
|
if tc.expErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
var ubd types.UnbondingDelegation
|
|
|
|
err = val.ClientCtx.Codec.UnmarshalJSON(out.Bytes(), &ubd)
|
|
s.Require().NoError(err)
|
|
s.Require().Equal(ubd.DelegatorAddress, val.Address.String())
|
|
s.Require().Equal(ubd.ValidatorAddress, val.ValAddress.String())
|
|
s.Require().Len(ubd.Entries, 1)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryValidatorUnbondingDelegations() {
|
|
val := s.network.Validators[0]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expErr bool
|
|
}{
|
|
{
|
|
"wrong validator address",
|
|
[]string{
|
|
"wrongValAddr",
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true,
|
|
},
|
|
{
|
|
"valid request",
|
|
[]string{
|
|
val.ValAddress.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
false,
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryValidatorUnbondingDelegations()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
|
|
if tc.expErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
var ubds types.QueryValidatorUnbondingDelegationsResponse
|
|
err = val.ClientCtx.Codec.UnmarshalJSON(out.Bytes(), &ubds)
|
|
|
|
s.Require().NoError(err)
|
|
s.Require().Len(ubds.UnbondingResponses, 1)
|
|
s.Require().Equal(ubds.UnbondingResponses[0].DelegatorAddress, val.Address.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryRedelegations() {
|
|
val := s.network.Validators[0]
|
|
val2 := s.network.Validators[1]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expErr bool
|
|
}{
|
|
{
|
|
"wrong delegator address",
|
|
[]string{
|
|
"wrongdeladdr",
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true,
|
|
},
|
|
{
|
|
"valid request",
|
|
[]string{
|
|
val.Address.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
false,
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryRedelegations()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
|
|
if tc.expErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
var redelegations types.QueryRedelegationsResponse
|
|
err = val.ClientCtx.Codec.UnmarshalJSON(out.Bytes(), &redelegations)
|
|
|
|
s.Require().NoError(err)
|
|
|
|
s.Require().Len(redelegations.RedelegationResponses, 1)
|
|
s.Require().Equal(redelegations.RedelegationResponses[0].Redelegation.DelegatorAddress, val.Address.String())
|
|
s.Require().Equal(redelegations.RedelegationResponses[0].Redelegation.ValidatorSrcAddress, val.ValAddress.String())
|
|
s.Require().Equal(redelegations.RedelegationResponses[0].Redelegation.ValidatorDstAddress, val2.ValAddress.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryRedelegation() {
|
|
val := s.network.Validators[0]
|
|
val2 := s.network.Validators[1]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expErr bool
|
|
}{
|
|
{
|
|
"wrong delegator address",
|
|
[]string{
|
|
"wrongdeladdr",
|
|
val.ValAddress.String(),
|
|
val2.ValAddress.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true,
|
|
},
|
|
{
|
|
"wrong source validator address address",
|
|
[]string{
|
|
val.Address.String(),
|
|
"wrongSrcValAddress",
|
|
val2.ValAddress.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true,
|
|
},
|
|
{
|
|
"wrong destination validator address address",
|
|
[]string{
|
|
val.Address.String(),
|
|
val.ValAddress.String(),
|
|
"wrongDestValAddress",
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true,
|
|
},
|
|
{
|
|
"valid request",
|
|
[]string{
|
|
val.Address.String(),
|
|
val.ValAddress.String(),
|
|
val2.ValAddress.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
false,
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryRedelegation()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
|
|
if tc.expErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
var redelegations types.QueryRedelegationsResponse
|
|
|
|
err = val.ClientCtx.Codec.UnmarshalJSON(out.Bytes(), &redelegations)
|
|
s.Require().NoError(err)
|
|
|
|
s.Require().Len(redelegations.RedelegationResponses, 1)
|
|
s.Require().Equal(redelegations.RedelegationResponses[0].Redelegation.DelegatorAddress, val.Address.String())
|
|
s.Require().Equal(redelegations.RedelegationResponses[0].Redelegation.ValidatorSrcAddress, val.ValAddress.String())
|
|
s.Require().Equal(redelegations.RedelegationResponses[0].Redelegation.ValidatorDstAddress, val2.ValAddress.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryValidatorRedelegations() {
|
|
val := s.network.Validators[0]
|
|
val2 := s.network.Validators[1]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expErr bool
|
|
}{
|
|
{
|
|
"wrong validator address",
|
|
[]string{
|
|
"wrongValAddr",
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true,
|
|
},
|
|
{
|
|
"valid request",
|
|
[]string{
|
|
val.ValAddress.String(),
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
false,
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryValidatorRedelegations()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
|
|
if tc.expErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
var redelegations types.QueryRedelegationsResponse
|
|
err = val.ClientCtx.Codec.UnmarshalJSON(out.Bytes(), &redelegations)
|
|
|
|
s.Require().NoError(err)
|
|
|
|
s.Require().Len(redelegations.RedelegationResponses, 1)
|
|
s.Require().Equal(redelegations.RedelegationResponses[0].Redelegation.DelegatorAddress, val.Address.String())
|
|
s.Require().Equal(redelegations.RedelegationResponses[0].Redelegation.ValidatorSrcAddress, val.ValAddress.String())
|
|
s.Require().Equal(redelegations.RedelegationResponses[0].Redelegation.ValidatorDstAddress, val2.ValAddress.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryHistoricalInfo() {
|
|
val := s.network.Validators[0]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
error bool
|
|
}{
|
|
{
|
|
"wrong height",
|
|
[]string{
|
|
"-1",
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
true,
|
|
},
|
|
{
|
|
"valid request",
|
|
[]string{
|
|
"1",
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
},
|
|
false,
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryHistoricalInfo()
|
|
clientCtx := val.ClientCtx
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
|
|
if tc.error {
|
|
s.Require().Error(err)
|
|
} else {
|
|
var historicalInfo types.HistoricalInfo
|
|
|
|
err = val.ClientCtx.Codec.UnmarshalJSON(out.Bytes(), &historicalInfo)
|
|
s.Require().NoError(err)
|
|
s.Require().NotNil(historicalInfo)
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryParams() {
|
|
val := s.network.Validators[0]
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expectedOutput string
|
|
}{
|
|
{
|
|
"with text output",
|
|
[]string{fmt.Sprintf("--%s=text", tmcli.OutputFlag)},
|
|
`bond_denom: stake
|
|
historical_entries: 10000
|
|
max_entries: 7
|
|
max_validators: 100
|
|
unbonding_time: 1814400s`,
|
|
},
|
|
{
|
|
"with json output",
|
|
[]string{fmt.Sprintf("--%s=json", tmcli.OutputFlag)},
|
|
`{"unbonding_time":"1814400s","max_validators":100,"max_entries":7,"historical_entries":10000,"bond_denom":"stake"}`,
|
|
},
|
|
}
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryParams()
|
|
clientCtx := val.ClientCtx
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
s.Require().NoError(err)
|
|
s.Require().Equal(tc.expectedOutput, strings.TrimSpace(out.String()))
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestGetCmdQueryPool() {
|
|
val := s.network.Validators[0]
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expectedOutput string
|
|
}{
|
|
{
|
|
"with text",
|
|
[]string{
|
|
fmt.Sprintf("--%s=text", tmcli.OutputFlag),
|
|
fmt.Sprintf("--%s=1", flags.FlagHeight),
|
|
},
|
|
fmt.Sprintf(`bonded_tokens: "%s"
|
|
not_bonded_tokens: "0"`, cli.DefaultTokens.Mul(sdk.NewInt(2)).String()),
|
|
},
|
|
{
|
|
"with json",
|
|
[]string{
|
|
fmt.Sprintf("--%s=json", tmcli.OutputFlag),
|
|
fmt.Sprintf("--%s=1", flags.FlagHeight),
|
|
},
|
|
fmt.Sprintf(`{"not_bonded_tokens":"0","bonded_tokens":"%s"}`, cli.DefaultTokens.Mul(sdk.NewInt(2)).String()),
|
|
},
|
|
}
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.GetCmdQueryPool()
|
|
clientCtx := val.ClientCtx
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
s.Require().NoError(err)
|
|
s.Require().Equal(tc.expectedOutput, strings.TrimSpace(out.String()))
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestNewEditValidatorCmd() {
|
|
val := s.network.Validators[0]
|
|
|
|
details := "bio"
|
|
identity := "test identity"
|
|
securityContact := "test contact"
|
|
website := "https://test.com"
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expectErr bool
|
|
expectedCode uint32
|
|
respType proto.Message
|
|
}{
|
|
{
|
|
"with no edit flag (since all are optional)",
|
|
[]string{
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, "with wrong from address"),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
true, 0, nil,
|
|
},
|
|
{
|
|
"with no edit flag (since all are optional)",
|
|
[]string{
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 0, &sdk.TxResponse{},
|
|
},
|
|
{
|
|
"edit validator details",
|
|
[]string{
|
|
fmt.Sprintf("--details=%s", details),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 0, &sdk.TxResponse{},
|
|
},
|
|
{
|
|
"edit validator identity",
|
|
[]string{
|
|
fmt.Sprintf("--identity=%s", identity),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 0, &sdk.TxResponse{},
|
|
},
|
|
{
|
|
"edit validator security-contact",
|
|
[]string{
|
|
fmt.Sprintf("--security-contact=%s", securityContact),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 0, &sdk.TxResponse{},
|
|
},
|
|
{
|
|
"edit validator website",
|
|
[]string{
|
|
fmt.Sprintf("--website=%s", website),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 0, &sdk.TxResponse{},
|
|
},
|
|
{
|
|
"with all edit flags",
|
|
[]string{
|
|
fmt.Sprintf("--details=%s", details),
|
|
fmt.Sprintf("--identity=%s", identity),
|
|
fmt.Sprintf("--security-contact=%s", securityContact),
|
|
fmt.Sprintf("--website=%s", website),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 0, &sdk.TxResponse{},
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.NewEditValidatorCmd()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
if tc.expectErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
s.Require().NoError(err, out.String())
|
|
s.Require().NoError(clientCtx.Codec.UnmarshalJSON(out.Bytes(), tc.respType), out.String())
|
|
|
|
txResp := tc.respType.(*sdk.TxResponse)
|
|
s.Require().Equal(tc.expectedCode, txResp.Code, out.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestNewDelegateCmd() {
|
|
val := s.network.Validators[0]
|
|
|
|
info, _, err := val.ClientCtx.Keyring.NewMnemonic("NewAccount", keyring.English, sdk.FullFundraiserPath, keyring.DefaultBIP39Passphrase, hd.Secp256k1)
|
|
s.Require().NoError(err)
|
|
|
|
newAddr := sdk.AccAddress(info.GetPubKey().Address())
|
|
|
|
_, err = banktestutil.MsgSendExec(
|
|
val.ClientCtx,
|
|
val.Address,
|
|
newAddr,
|
|
sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(200))), fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
)
|
|
s.Require().NoError(err)
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expectErr bool
|
|
expectedCode uint32
|
|
respType proto.Message
|
|
}{
|
|
{
|
|
"without delegate amount",
|
|
[]string{
|
|
val.ValAddress.String(),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, newAddr.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
true, 0, nil,
|
|
},
|
|
{
|
|
"without validator address",
|
|
[]string{
|
|
sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(150)).String(),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, newAddr.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
true, 0, nil,
|
|
},
|
|
{
|
|
"valid transaction of delegate",
|
|
[]string{
|
|
val.ValAddress.String(),
|
|
sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(150)).String(),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, newAddr.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 0, &sdk.TxResponse{},
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.NewDelegateCmd()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
if tc.expectErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
s.Require().NoError(err, out.String())
|
|
s.Require().NoError(clientCtx.Codec.UnmarshalJSON(out.Bytes(), tc.respType), out.String())
|
|
|
|
txResp := tc.respType.(*sdk.TxResponse)
|
|
s.Require().Equal(tc.expectedCode, txResp.Code, out.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestNewRedelegateCmd() {
|
|
val := s.network.Validators[0]
|
|
val2 := s.network.Validators[1]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expectErr bool
|
|
expectedCode uint32
|
|
respType proto.Message
|
|
}{
|
|
{
|
|
"without amount",
|
|
[]string{
|
|
val.ValAddress.String(), // src-validator-addr
|
|
val2.ValAddress.String(), // dst-validator-addr
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
true, 0, nil,
|
|
},
|
|
{
|
|
"with wrong source validator address",
|
|
[]string{
|
|
`cosmosvaloper1gghjut3ccd8ay0zduzj64hwre2fxs9ldmqhffj`, // src-validator-addr
|
|
val2.ValAddress.String(), // dst-validator-addr
|
|
sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(150)).String(), // amount
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 3, &sdk.TxResponse{},
|
|
},
|
|
{
|
|
"with wrong destination validator address",
|
|
[]string{
|
|
val.ValAddress.String(), // dst-validator-addr
|
|
`cosmosvaloper1gghjut3ccd8ay0zduzj64hwre2fxs9ldmqhffj`, // src-validator-addr
|
|
sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(150)).String(), // amount
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 31, &sdk.TxResponse{},
|
|
},
|
|
{
|
|
"valid transaction of delegate",
|
|
[]string{
|
|
val.ValAddress.String(), // src-validator-addr
|
|
val2.ValAddress.String(), // dst-validator-addr
|
|
sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(150)).String(), // amount
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=%s", flags.FlagGas, "auto"),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 0, &sdk.TxResponse{},
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.NewRedelegateCmd()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
if tc.expectErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
s.Require().NoError(err, out.String())
|
|
s.Require().NoError(clientCtx.Codec.UnmarshalJSON(out.Bytes(), tc.respType), out.String())
|
|
|
|
txResp := tc.respType.(*sdk.TxResponse)
|
|
s.Require().Equal(tc.expectedCode, txResp.Code, out.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
func (s *IntegrationTestSuite) TestNewUnbondCmd() {
|
|
val := s.network.Validators[0]
|
|
|
|
testCases := []struct {
|
|
name string
|
|
args []string
|
|
expectErr bool
|
|
expectedCode uint32
|
|
respType proto.Message
|
|
}{
|
|
{
|
|
"Without unbond amount",
|
|
[]string{
|
|
val.ValAddress.String(),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
true, 0, nil,
|
|
},
|
|
{
|
|
"Without validator address",
|
|
[]string{
|
|
sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(150)).String(),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
true, 0, nil,
|
|
},
|
|
{
|
|
"valid transaction of unbond",
|
|
[]string{
|
|
val.ValAddress.String(),
|
|
sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(150)).String(),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, val.Address.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
},
|
|
false, 0, &sdk.TxResponse{},
|
|
},
|
|
}
|
|
|
|
for _, tc := range testCases {
|
|
tc := tc
|
|
|
|
s.Run(tc.name, func() {
|
|
cmd := cli.NewUnbondCmd()
|
|
clientCtx := val.ClientCtx
|
|
|
|
out, err := clitestutil.ExecTestCLICmd(clientCtx, cmd, tc.args)
|
|
if tc.expectErr {
|
|
s.Require().Error(err)
|
|
} else {
|
|
s.Require().NoError(err, out.String())
|
|
s.Require().NoError(clientCtx.Codec.UnmarshalJSON(out.Bytes(), tc.respType), out.String())
|
|
|
|
txResp := tc.respType.(*sdk.TxResponse)
|
|
s.Require().Equal(tc.expectedCode, txResp.Code, out.String())
|
|
}
|
|
})
|
|
}
|
|
}
|
|
|
|
// TestBlockResults tests that the validator updates correctly show when
|
|
// calling the /block_results RPC endpoint.
|
|
// ref: https://github.com/cosmos/cosmos-sdk/issues/7401.
|
|
func (s *IntegrationTestSuite) TestBlockResults() {
|
|
require := s.Require()
|
|
val := s.network.Validators[0]
|
|
|
|
// Create new account in the keyring.
|
|
info, _, err := val.ClientCtx.Keyring.NewMnemonic("NewDelegator", keyring.English, sdk.FullFundraiserPath, keyring.DefaultBIP39Passphrase, hd.Secp256k1)
|
|
require.NoError(err)
|
|
newAddr := sdk.AccAddress(info.GetPubKey().Address())
|
|
|
|
// Send some funds to the new account.
|
|
_, err = banktestutil.MsgSendExec(
|
|
val.ClientCtx,
|
|
val.Address,
|
|
newAddr,
|
|
sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(200))), fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
)
|
|
require.NoError(err)
|
|
|
|
// Use CLI to create a delegation from the new account to validator `val`.
|
|
delHeight, err := s.network.LatestHeight()
|
|
require.NoError(err)
|
|
cmd := cli.NewDelegateCmd()
|
|
_, err = clitestutil.ExecTestCLICmd(val.ClientCtx, cmd, []string{
|
|
val.ValAddress.String(),
|
|
sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(150)).String(),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFrom, newAddr.String()),
|
|
fmt.Sprintf("--%s=true", flags.FlagSkipConfirmation),
|
|
fmt.Sprintf("--%s=%s", flags.FlagBroadcastMode, flags.BroadcastBlock),
|
|
fmt.Sprintf("--%s=%s", flags.FlagFees, sdk.NewCoins(sdk.NewCoin(s.cfg.BondDenom, sdk.NewInt(10))).String()),
|
|
})
|
|
require.NoError(err)
|
|
|
|
// Create a HTTP rpc client.
|
|
rpcClient, err := http.New(val.RPCAddress, "/websocket")
|
|
require.NoError(err)
|
|
|
|
// Loop until we find a block result with the correct validator updates.
|
|
// By experience, it happens around 2 blocks after `delHeight`.
|
|
for {
|
|
latestHeight, err := s.network.LatestHeight()
|
|
require.NoError(err)
|
|
|
|
// Wait maximum 10 blocks, or else fail test.
|
|
if latestHeight > delHeight+10 {
|
|
s.Fail("timeout reached")
|
|
}
|
|
|
|
res, err := rpcClient.BlockResults(context.Background(), &latestHeight)
|
|
require.NoError(err)
|
|
|
|
if len(res.ValidatorUpdates) > 0 {
|
|
valUpdate := res.ValidatorUpdates[0]
|
|
require.Equal(
|
|
valUpdate.GetPubKey().Sum.(*crypto.PublicKey_Ed25519).Ed25519,
|
|
val.PubKey.Bytes(),
|
|
)
|
|
|
|
// We got our validator update, test passed.
|
|
break
|
|
}
|
|
|
|
s.network.WaitForNextBlock()
|
|
}
|
|
}
|