tests

Documentation

Index

• Variables
• func GenerateKeyAndAddr(t *testing.T) (*ecdsa.PrivateKey, types.Address)
• func GenerateTestBridgeAssociatedAddress(t *testing.T, signerCount int) (owner types.Address, signers []types.Address)
• func GenerateTestMultiAddr(t *testing.T) multiaddr.Multiaddr
• func GetFreePort() (port int, err error)
• func RetryUntilTimeout(ctx context.Context, f func() (interface{}, bool)) (interface{}, error)
• func WaitForNonce(ctx context.Context, ethClient *jsonrpc.Eth, addr web3.Address, ...) (interface{}, error)
• func WaitForReceipt(ctx context.Context, client *jsonrpc.Eth, hash web3.Hash) (*web3.Receipt, error)
• func WaitUntilTxPoolEmpty(ctx context.Context, client txpoolOp.TxnPoolOperatorClient) (*txpoolOp.TxnPoolStatusResp, error)

Variables

var (
	ErrTimeout = errors.New("timeout")
)

Functions

func GenerateKeyAndAddr

func GenerateKeyAndAddr(t *testing.T) (*ecdsa.PrivateKey, types.Address)

func GenerateTestBridgeAssociatedAddress

func GenerateTestBridgeAssociatedAddress(t *testing.T, signerCount int) (owner types.Address, signers []types.Address)

func GenerateTestMultiAddr

func GenerateTestMultiAddr(t *testing.T) multiaddr.Multiaddr

func GetFreePort

func GetFreePort() (port int, err error)

GetFreePort asks the kernel for a free open port that is ready to use

func RetryUntilTimeout

func RetryUntilTimeout(ctx context.Context, f func() (interface{}, bool)) (interface{}, error)

func WaitForNonce

func WaitForNonce(
	ctx context.Context,
	ethClient *jsonrpc.Eth,
	addr web3.Address,
	expectedNonce uint64,
) (
	interface{},
	error,
)

func WaitForReceipt

func WaitForReceipt(ctx context.Context, client *jsonrpc.Eth, hash web3.Hash) (*web3.Receipt, error)

WaitForReceipt waits transaction receipt

func WaitUntilTxPoolEmpty

func WaitUntilTxPoolEmpty(
	ctx context.Context,
	client txpoolOp.TxnPoolOperatorClient,
) (
	*txpoolOp.TxnPoolStatusResp,
	error,
)

WaitUntilTxPoolEmpty waits until node has 0 transactions in txpool, otherwise returns timeout