testing

Documentation

Index

• Constants
• Variables
• type OperatorMock
  • func NewOperatorMock(relayEndpoint string, res *swconfig.MergedResources, startIndex int) (*OperatorMock, error)
  • func (m *OperatorMock) SetStartIndex(startIndex int)
  • func (m *OperatorMock) SetTotal(total int)
  • func (m *OperatorMock) SubmitValidatorsRequest() (*relay.ValidatorsResponse, error)
• type StakeWiseNode
  • func (n *StakeWiseNode) Close() error
  • func (n *StakeWiseNode) CreateSubNode(hdNode *hdtesting.HyperdriveNode, address string, port uint16) (*StakeWiseNode, error)
  • func (n *StakeWiseNode) GetApiClient() *swclient.ApiClient
  • func (n *StakeWiseNode) GetHyperdriveNode() *hdtesting.HyperdriveNode
  • func (n *StakeWiseNode) GetRelayServer() *relay.RelayServer
  • func (n *StakeWiseNode) GetServerManager() *swserver.ServerManager
  • func (n *StakeWiseNode) GetServiceProvider() swcommon.IStakeWiseServiceProvider
• type StakeWiseTestManager
  • func NewStakeWiseTestManager() (*StakeWiseTestManager, error)
  • func (m *StakeWiseTestManager) CloseModule() error
  • func (m *StakeWiseTestManager) DependsOnStakeWiseBaseline() error
  • func (m *StakeWiseTestManager) GetModuleName() string
  • func (m *StakeWiseTestManager) GetNode() *StakeWiseNode
  • func (m *StakeWiseTestManager) GetOperatorMock() *OperatorMock
  • func (m *StakeWiseTestManager) RevertModuleToSnapshot(moduleState any) error
  • func (m *StakeWiseTestManager) TakeModuleSnapshot() (any, error)

Constants

const (
	DefaultTotal int = 100
	BatchSize    int = 10
)

const (
	// Address of a mock StakeWise vault for testing
	StakeWiseVaultString string = "0x57ace215eeeeeeeeeeeeeeeeeeeeeeeeeeeeeeee"
)

Variables

var (
	// Code 503 - returned when the server is busy loading private keys or doing lookback scans
	ErrorUnavailable error = fmt.Errorf("server is currently unavailable to handle the request")

	// Code 429 - returned when there's an active request being processed already, since only one can run at a time
	ErrorTooManyRequests error = fmt.Errorf("too many requests, please try again later")
)

Types

type OperatorMock

type OperatorMock struct {
	// contains filtered or unexported fields
}

Mocks the StakeWise operator for stimulating the relay

func NewOperatorMock

func NewOperatorMock(relayEndpoint string, res *swconfig.MergedResources, startIndex int) (*OperatorMock, error)

Creates a new operator mock

func (*OperatorMock) SetStartIndex

func (m *OperatorMock) SetStartIndex(startIndex int)

Set the start index provided in requests

func (*OperatorMock) SetTotal

func (m *OperatorMock) SetTotal(total int)

Set the total number of validators in requests

func (*OperatorMock) SubmitValidatorsRequest

func (m *OperatorMock) SubmitValidatorsRequest() (*relay.ValidatorsResponse, error)

Simulate the relay request to create validators and return the response

type StakeWiseNode

type StakeWiseNode struct {
	// contains filtered or unexported fields
}

A complete StakeWise node instance

func (*StakeWiseNode) Close

func (n *StakeWiseNode) Close() error

Closes the StakeWise node. The caller is responsible for stopping the Hyperdrive daemon owning this module.

func (*StakeWiseNode) CreateSubNode

func (n *StakeWiseNode) CreateSubNode(hdNode *hdtesting.HyperdriveNode, address string, port uint16) (*StakeWiseNode, error)

Create a new StakeWise node based on this one's configuration, but with a custom folder, address, and port.

func (*StakeWiseNode) GetApiClient

func (n *StakeWiseNode) GetApiClient() *swclient.ApiClient

Get the HTTP API client for interacting with the node's daemon server

func (*StakeWiseNode) GetHyperdriveNode

func (n *StakeWiseNode) GetHyperdriveNode() *hdtesting.HyperdriveNode

Get the Hyperdrive node for this StakeWise module

func (*StakeWiseNode) GetRelayServer

func (n *StakeWiseNode) GetRelayServer() *relay.RelayServer

Get the HTTP Relay server for the node's daemon

func (*StakeWiseNode) GetServerManager

func (n *StakeWiseNode) GetServerManager() *swserver.ServerManager

Get the HTTP API server for the node's daemon

func (*StakeWiseNode) GetServiceProvider

func (n *StakeWiseNode) GetServiceProvider() swcommon.IStakeWiseServiceProvider

Get the daemon's service provider

type StakeWiseTestManager

type StakeWiseTestManager struct {
	*hdtesting.HyperdriveTestManager
	// contains filtered or unexported fields
}

StakeWiseTestManager for managing testing resources and services

func NewStakeWiseTestManager

func NewStakeWiseTestManager() (*StakeWiseTestManager, error)

Creates a new TestManager instance

func (*StakeWiseTestManager) CloseModule

func (m *StakeWiseTestManager) CloseModule() error

Closes the test manager, shutting down the nodeset mock server and all other resources

func (*StakeWiseTestManager) DependsOnStakeWiseBaseline

func (m *StakeWiseTestManager) DependsOnStakeWiseBaseline() error

Reverts the service states to the baseline snapshot

func (*StakeWiseTestManager) GetModuleName

func (m *StakeWiseTestManager) GetModuleName() string

func (*StakeWiseTestManager) GetNode

func (m *StakeWiseTestManager) GetNode() *StakeWiseNode

Get the node handle

func (*StakeWiseTestManager) GetOperatorMock

func (m *StakeWiseTestManager) GetOperatorMock() *OperatorMock

Get the operator mock handle

func (*StakeWiseTestManager) RevertModuleToSnapshot

func (m *StakeWiseTestManager) RevertModuleToSnapshot(moduleState any) error

func (*StakeWiseTestManager) TakeModuleSnapshot

func (m *StakeWiseTestManager) TakeModuleSnapshot() (any, error)

Takes a snapshot of the service states