mirror of
https://github.com/planetmint/planetmint-go.git
synced 2025-09-13 20:00:10 +00:00
1e1e19bb19
* Added more sync objects to avoid accidental data races * made lib.config.Config variables are private, so they cannot be tampered with (multithreading). Please introduce Get-methods to retrieve the varialbes outside of the package if you need it. This way, the race conditions and unexpected change of the global object state can be protected * added reverse takedown of the validators to avoid the following error [app] PoP broadcast tx failed: node0.info: key not found * moved util.TerminationWaitGroup.Wait() to the central network cleanup method * removed mappings for private variables Signed-off-by: Jürgen Eckel <juergen@riddleandcode.com>
126 lines
3.6 KiB
Go
126 lines
3.6 KiB
Go
package msgs
|
|
|
|
import (
|
|
sdk "github.com/cosmos/cosmos-sdk/types"
|
|
"github.com/planetmint/planetmint-go/lib"
|
|
e2etestutil "github.com/planetmint/planetmint-go/testutil/e2e"
|
|
"github.com/planetmint/planetmint-go/testutil/network"
|
|
"github.com/planetmint/planetmint-go/testutil/sample"
|
|
daotypes "github.com/planetmint/planetmint-go/x/dao/types"
|
|
machinetypes "github.com/planetmint/planetmint-go/x/machine/types"
|
|
"github.com/stretchr/testify/suite"
|
|
)
|
|
|
|
var msgs = []sdk.Msg{
|
|
&daotypes.MsgInitPop{},
|
|
&daotypes.MsgDistributionRequest{},
|
|
&daotypes.MsgDistributionResult{},
|
|
&daotypes.MsgReissueRDDLProposal{},
|
|
&daotypes.MsgReissueRDDLResult{},
|
|
&daotypes.MsgUpdateRedeemClaim{},
|
|
&machinetypes.MsgRegisterTrustAnchor{},
|
|
&machinetypes.MsgNotarizeLiquidAsset{},
|
|
}
|
|
|
|
type RestrictedMsgsE2ESuite struct {
|
|
suite.Suite
|
|
|
|
cfg network.Config
|
|
network *network.Network
|
|
}
|
|
|
|
func NewRestrictedMsgsE2ESuite(cfg network.Config) *RestrictedMsgsE2ESuite {
|
|
return &RestrictedMsgsE2ESuite{cfg: cfg}
|
|
}
|
|
|
|
func (s *RestrictedMsgsE2ESuite) SetupSuite() {
|
|
s.T().Log("setting up e2e dao restricted msg test suite")
|
|
|
|
s.network = network.Load(s.T(), s.cfg)
|
|
account, err := e2etestutil.CreateAccount(s.network, sample.Name, sample.Mnemonic)
|
|
s.Require().NoError(err)
|
|
err = e2etestutil.FundAccount(s.network, account, sample.FeeDenom)
|
|
s.Require().NoError(err)
|
|
}
|
|
|
|
func (s *RestrictedMsgsE2ESuite) TearDownSuite() {
|
|
s.T().Log("tearing down e2e dao restricted msg test suite")
|
|
}
|
|
|
|
func (s *RestrictedMsgsE2ESuite) TestRestrictedMsgsValidator() {
|
|
val := s.network.Validators[0]
|
|
|
|
msg := daotypes.NewMsgInitPop(val.Address.String(), val.Address.String(), val.Address.String(), val.Address.String(), 0)
|
|
out, err := lib.BroadcastTxWithFileLock(val.Address, msg)
|
|
s.Require().NoError(err)
|
|
|
|
txResponse, err := lib.GetTxResponseFromOut(out)
|
|
s.Require().NoError(err)
|
|
s.Require().Equal(int(0), int(txResponse.Code))
|
|
}
|
|
|
|
func (s *RestrictedMsgsE2ESuite) TestRestrictedMsgsNonValidator() {
|
|
val := s.network.Validators[0]
|
|
|
|
k, err := val.ClientCtx.Keyring.Key(sample.Name)
|
|
s.Require().NoError(err)
|
|
addr, _ := k.GetAddress()
|
|
|
|
for _, msg := range msgs {
|
|
msg = setCreator(msg, addr.String())
|
|
out, err := lib.BroadcastTxWithFileLock(addr, msg)
|
|
s.Require().NoError(err)
|
|
|
|
txResponse, err := lib.GetTxResponseFromOut(out)
|
|
s.Require().NoError(err)
|
|
s.Require().Equal(int(18), int(txResponse.Code))
|
|
s.Require().NoError(s.network.WaitForNextBlock())
|
|
}
|
|
}
|
|
|
|
func setCreator(msg sdk.Msg, creator string) sdk.Msg {
|
|
switch sdk.MsgTypeURL(msg) {
|
|
case "/planetmintgo.dao.MsgInitPop":
|
|
msg, ok := msg.(*daotypes.MsgInitPop)
|
|
if ok {
|
|
msg.Creator = creator
|
|
}
|
|
case "/planetmintgo.dao.MsgDistributionRequest":
|
|
msg, ok := msg.(*daotypes.MsgDistributionRequest)
|
|
if ok {
|
|
msg.Creator = creator
|
|
}
|
|
case "/planetmintgo.dao.MsgDistributionResult":
|
|
msg, ok := msg.(*daotypes.MsgDistributionResult)
|
|
if ok {
|
|
msg.Creator = creator
|
|
}
|
|
case "/planetmintgo.dao.MsgReissueRDDLProposal":
|
|
msg, ok := msg.(*daotypes.MsgReissueRDDLProposal)
|
|
if ok {
|
|
msg.Creator = creator
|
|
}
|
|
case "/planetmintgo.dao.MsgReissueRDDLResult":
|
|
msg, ok := msg.(*daotypes.MsgReissueRDDLResult)
|
|
if ok {
|
|
msg.Creator = creator
|
|
}
|
|
case "/planetmintgo.dao.MsgUpdateRedeemClaim":
|
|
msg, ok := msg.(*daotypes.MsgUpdateRedeemClaim)
|
|
if ok {
|
|
msg.Creator = creator
|
|
}
|
|
case "/planetmintgo.machine.MsgNotarizeLiquidAsset":
|
|
msg, ok := msg.(*machinetypes.MsgNotarizeLiquidAsset)
|
|
if ok {
|
|
msg.Creator = creator
|
|
}
|
|
case "/planetmintgo.machine.MsgRegisterTrustAnchor":
|
|
msg, ok := msg.(*machinetypes.MsgRegisterTrustAnchor)
|
|
if ok {
|
|
msg.Creator = creator
|
|
}
|
|
}
|
|
return msg
|
|
}
|