testutils

Documentation

Index

• Variables
• func Head(val interface{}) *evmtypes.Head
• func NewAddress() common.Address
• func NewAddressPtr() *common.Address
• func NewEthClientMock(t *testing.T) *evmclmocks.Client
• func NewEthClientMockWithDefaultChain(t *testing.T) *evmclmocks.Client
• func NewHash() common.Hash
• func NewLegacyTransaction(nonce uint64, to common.Address, value *big.Int, gasLimit uint32, ...) *types.Transaction
• func NewRandomEVMChainID() *big.Int
• func NewTestChainScopedConfig(t testing.TB, overrideFn func(c *toml.EVMConfig)) config.ChainScopedConfig
• func NewWSServer(t *testing.T, chainID *big.Int, callback JSONRPCHandler) (ts *testWSServer)
• func WSServerURL(t *testing.T, s *httptest.Server) *url.URL
• type Awaiter
  • func NewAwaiter() Awaiter
  • func (a Awaiter) AssertHappened(t *testing.T, expected bool)
  • func (a Awaiter) AwaitOrFail(t testing.TB, durationParams ...time.Duration)
  • func (a Awaiter) ItHappened()
• type JSONRPCHandler
• type JSONRPCResponse
• type MockEth
  • func (m *MockEth) NewSub(t *testing.T) ethereum.Subscription
  • func (m *MockEth) SubsErr(err error)
  • func (m *MockEth) SubscribeCallCount() int32
  • func (m *MockEth) UnsubscribeCallCount() int32
• type RawSub
  • func NewRawSub[T any](ch chan<- T, err <-chan error) RawSub[T]
  • func (r *RawSub[T]) CloseCh()
  • func (r *RawSub[T]) TrySend(t T)

Variables

var FixtureChainID = big.NewInt(0)

FixtureChainID matches the chain always added by fixtures.sql It is set to 0 since no real chain ever has this ID and allows a virtual "test" chain ID to be used without clashes

var SimulatedChainID = big.NewInt(1337)

SimulatedChainID is the chain ID for the go-ethereum simulated backend

Functions

func Head

func Head(val interface{}) *evmtypes.Head

Head given the value convert it into an Head

func NewAddress

func NewAddress() common.Address

NewAddress return a random new address

func NewAddressPtr

func NewAddressPtr() *common.Address

func NewEthClientMock

func NewEthClientMock(t *testing.T) *evmclmocks.Client

func NewEthClientMockWithDefaultChain

func NewEthClientMockWithDefaultChain(t *testing.T) *evmclmocks.Client

func NewHash

func NewHash() common.Hash

NewHash return random Keccak256

func NewLegacyTransaction

func NewLegacyTransaction(nonce uint64, to common.Address, value *big.Int, gasLimit uint32, gasPrice *big.Int, data []byte) *types.Transaction

func NewRandomEVMChainID

func NewRandomEVMChainID() *big.Int

NewRandomEVMChainID returns a suitable random chain ID that will not conflict with fixtures

func NewTestChainScopedConfig

func NewTestChainScopedConfig(t testing.TB, overrideFn func(c *toml.EVMConfig)) config.ChainScopedConfig

func NewWSServer

func NewWSServer(t *testing.T, chainID *big.Int, callback JSONRPCHandler) (ts *testWSServer)

NewWSServer starts a websocket server which invokes callback for each message received. If chainID is set, then eth_chainId calls will be automatically handled.

func WSServerURL

func WSServerURL(t *testing.T, s *httptest.Server) *url.URL

WSServerURL returns a ws:// url for the server

Types

type Awaiter

type Awaiter chan struct{}

func NewAwaiter

func NewAwaiter() Awaiter

func (Awaiter) AssertHappened

func (a Awaiter) AssertHappened(t *testing.T, expected bool)

func (Awaiter) AwaitOrFail

func (a Awaiter) AwaitOrFail(t testing.TB, durationParams ...time.Duration)

func (Awaiter) ItHappened

func (a Awaiter) ItHappened()

type JSONRPCHandler

type JSONRPCHandler func(reqMethod string, reqParams gjson.Result) JSONRPCResponse

JSONRPCHandler is called with the method and request param(s). respResult will be sent immediately. notifyResult is optional, and sent after a short delay.

type JSONRPCResponse

type JSONRPCResponse struct {
	Result, Notify string // raw JSON (i.e. quoted strings etc.)

	Error struct {
		Code    int
		Message string
	}
}

type MockEth

type MockEth struct {
	EthClient       *evmclmocks.Client
	CheckFilterLogs func(int64, int64)
	// contains filtered or unexported fields
}

func (*MockEth) NewSub

func (m *MockEth) NewSub(t *testing.T) ethereum.Subscription

func (*MockEth) SubsErr

func (m *MockEth) SubsErr(err error)

func (*MockEth) SubscribeCallCount

func (m *MockEth) SubscribeCallCount() int32

func (*MockEth) UnsubscribeCallCount

func (m *MockEth) UnsubscribeCallCount() int32

type RawSub

type RawSub[T any] struct {
	// contains filtered or unexported fields
}

func NewRawSub

func NewRawSub[T any](ch chan<- T, err <-chan error) RawSub[T]

func (*RawSub[T]) CloseCh

func (r *RawSub[T]) CloseCh()

func (*RawSub[T]) TrySend

func (r *RawSub[T]) TrySend(t T)