91 lines
2.4 KiB
Go
91 lines
2.4 KiB
Go
package devtests
|
|
|
|
import (
|
|
"context"
|
|
"fmt"
|
|
"math/big"
|
|
"testing"
|
|
"time"
|
|
|
|
"github.com/stretchr/testify/suite"
|
|
|
|
"github.com/ethereum/go-ethereum/accounts/abi/bind"
|
|
"github.com/ethereum/go-ethereum/common"
|
|
"github.com/ethereum/go-ethereum/common/hexutil"
|
|
gethtypes "github.com/ethereum/go-ethereum/core/types"
|
|
|
|
"github.com/status-im/status-go/eth-node/types"
|
|
"github.com/status-im/status-go/services/wallet"
|
|
"github.com/status-im/status-go/t/utils"
|
|
)
|
|
|
|
func TestTransfersSuite(t *testing.T) {
|
|
suite.Run(t, new(TransfersSuite))
|
|
}
|
|
|
|
type TransfersSuite struct {
|
|
DevNodeSuite
|
|
}
|
|
|
|
func (s *TransfersSuite) getAllTranfers() (rst []wallet.TransferView, err error) {
|
|
return rst, s.Local.Call(&rst, "wallet_getTransfersByAddress", s.DevAccountAddress, (*hexutil.Big)(big.NewInt(1000)), (*hexutil.Big)(big.NewInt(40)))
|
|
}
|
|
|
|
func (s *TransfersSuite) sendTx(nonce uint64, to types.Address) {
|
|
tx := gethtypes.NewTransaction(nonce, common.Address(to), big.NewInt(1e18), 1e6, big.NewInt(10), nil)
|
|
// TODO move signer to DevNodeSuite
|
|
tx, err := gethtypes.SignTx(tx, gethtypes.NewEIP155Signer(big.NewInt(1337)), s.DevAccount)
|
|
s.Require().NoError(err)
|
|
s.Require().NoError(s.Eth.SendTransaction(context.Background(), tx))
|
|
timeout, cancel := context.WithTimeout(context.Background(), 5*time.Second)
|
|
_, err = bind.WaitMined(timeout, s.Eth, tx)
|
|
cancel()
|
|
s.Require().NoError(err)
|
|
}
|
|
|
|
func (s *TransfersSuite) TestNewTransfers() {
|
|
s.sendTx(0, s.DevAccountAddress)
|
|
s.Require().NoError(utils.Eventually(func() error {
|
|
all, err := s.getAllTranfers()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if len(all) != 1 {
|
|
return fmt.Errorf("waiting for one transfer")
|
|
}
|
|
return nil
|
|
}, 20*time.Second, 1*time.Second))
|
|
|
|
go func() {
|
|
for i := 1; i < 10; i++ {
|
|
s.sendTx(uint64(i), s.DevAccountAddress)
|
|
}
|
|
}()
|
|
s.Require().NoError(utils.Eventually(func() error {
|
|
all, err := s.getAllTranfers()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if len(all) != 10 {
|
|
return fmt.Errorf("waiting for 10 transfers")
|
|
}
|
|
return nil
|
|
}, 30*time.Second, 1*time.Second))
|
|
}
|
|
|
|
func (s *TransfersSuite) TestHistoricalTransfers() {
|
|
for i := 0; i < 30; i++ {
|
|
s.sendTx(uint64(i), s.DevAccountAddress)
|
|
}
|
|
s.Require().NoError(utils.Eventually(func() error {
|
|
all, err := s.getAllTranfers()
|
|
if err != nil {
|
|
return err
|
|
}
|
|
if len(all) < 30 {
|
|
return fmt.Errorf("waiting for atleast 30 transfers, got %d", len(all))
|
|
}
|
|
return nil
|
|
}, 30*time.Second, 1*time.Second))
|
|
}
|