Mukan Erkin Törük
88dd97a9f8
Some checks failed
CodeQL / Analyze (push) Waiting to run
golangci-lint / lint (push) Waiting to run
Tests / Code Coverage / build (amd64) (push) Waiting to run
Tests / Code Coverage / build (arm64) (push) Waiting to run
Tests / Code Coverage / unit-tests (map[additional-args:-tags="test_e2e" name:e2e path:./e2e]) (push) Waiting to run
Tests / Code Coverage / unit-tests (map[name:08-wasm path:./modules/light-clients/08-wasm]) (push) Waiting to run
Tests / Code Coverage / unit-tests (map[name:ibc-go path:.]) (push) Waiting to run
Docker Build & Push Simapp (main) / docker-build (push) Has been cancelled
96 lines
3.4 KiB
Go
96 lines
3.4 KiB
Go
package ibctesting
|
|
|
|
import (
|
|
"errors"
|
|
"fmt"
|
|
"math/rand"
|
|
"strings"
|
|
"testing"
|
|
|
|
"github.com/stretchr/testify/require"
|
|
|
|
"git.cw.tr/mukan-network/mukan-sdk/codec"
|
|
sdk "git.cw.tr/mukan-network/mukan-sdk/types"
|
|
govtypesv1 "git.cw.tr/mukan-network/mukan-sdk/x/gov/types/v1"
|
|
|
|
abci "git.cw.tr/mukan-network/mukan-consensus/abci/types"
|
|
cmttypes "git.cw.tr/mukan-network/mukan-consensus/types"
|
|
)
|
|
|
|
// ApplyValSetChanges takes in cmttypes.ValidatorSet and []abci.ValidatorUpdate and will return a new cmttypes.ValidatorSet which has the
|
|
// provided validator updates applied to the provided validator set.
|
|
func ApplyValSetChanges(tb testing.TB, valSet *cmttypes.ValidatorSet, valUpdates []abci.ValidatorUpdate) *cmttypes.ValidatorSet {
|
|
tb.Helper()
|
|
updates, err := cmttypes.PB2TM.ValidatorUpdates(valUpdates)
|
|
require.NoError(tb, err)
|
|
|
|
// must copy since validator set will mutate with UpdateWithChangeSet
|
|
newVals := valSet.Copy()
|
|
err = newVals.UpdateWithChangeSet(updates)
|
|
require.NoError(tb, err)
|
|
|
|
return newVals
|
|
}
|
|
|
|
// VoteAndCheckProposalStatus votes on a gov proposal, checks if the proposal has passed, and returns an error if it has not with the failure reason.
|
|
func VoteAndCheckProposalStatus(endpoint *Endpoint, proposalID uint64) error {
|
|
// vote on proposal
|
|
ctx := endpoint.Chain.GetContext()
|
|
require.NoError(endpoint.Chain.TB, endpoint.Chain.GetSimApp().GovKeeper.AddVote(ctx, proposalID, endpoint.Chain.SenderAccount.GetAddress(), govtypesv1.NewNonSplitVoteOption(govtypesv1.OptionYes), ""))
|
|
|
|
// fast forward the chain context to end the voting period
|
|
params, err := endpoint.Chain.GetSimApp().GovKeeper.Params.Get(ctx)
|
|
require.NoError(endpoint.Chain.TB, err)
|
|
|
|
endpoint.Chain.Coordinator.IncrementTimeBy(*params.VotingPeriod + *params.MaxDepositPeriod)
|
|
endpoint.Chain.NextBlock()
|
|
|
|
// check if proposal passed or failed on msg execution
|
|
// we need to grab the context again since the previous context is no longer valid as the chain header time has been incremented
|
|
p, err := endpoint.Chain.GetSimApp().GovKeeper.Proposals.Get(endpoint.Chain.GetContext(), proposalID)
|
|
require.NoError(endpoint.Chain.TB, err)
|
|
if p.Status != govtypesv1.StatusPassed {
|
|
return fmt.Errorf("proposal failed: %s", p.FailedReason)
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// GenerateString generates a random string of the given length in bytes
|
|
func GenerateString(length uint) string {
|
|
bytes := make([]byte, length)
|
|
for i := range bytes {
|
|
bytes[i] = charset[rand.Intn(len(charset))]
|
|
}
|
|
return string(bytes)
|
|
}
|
|
|
|
// UnmarshalMsgResponses parse out msg responses from a transaction result
|
|
func UnmarshalMsgResponses(cdc codec.Codec, data []byte, msgs ...codec.ProtoMarshaler) error {
|
|
var txMsgData sdk.TxMsgData
|
|
if err := cdc.Unmarshal(data, &txMsgData); err != nil {
|
|
return err
|
|
}
|
|
|
|
if len(msgs) != len(txMsgData.MsgResponses) {
|
|
return fmt.Errorf("expected %d message responses but got %d", len(msgs), len(txMsgData.MsgResponses))
|
|
}
|
|
|
|
for i, msg := range msgs {
|
|
if err := cdc.Unmarshal(txMsgData.MsgResponses[i].Value, msg); err != nil {
|
|
return err
|
|
}
|
|
}
|
|
|
|
return nil
|
|
}
|
|
|
|
// RequireErrorIsOrContains verifies that the passed error is either a target error or contains its error message.
|
|
func RequireErrorIsOrContains(t *testing.T, err, targetError error, msgAndArgs ...any) {
|
|
t.Helper()
|
|
require.Error(t, err)
|
|
require.True(
|
|
t,
|
|
errors.Is(err, targetError) ||
|
|
strings.Contains(err.Error(), targetError.Error()),
|
|
msgAndArgs...)
|
|
}
|