testutil

Documentation

Overview

Package testutil provides mock implementations of various wasp components. They are used for unit-testing different parts.

Index

• func DummyOffledgerRequest(chainID *isc.ChainID) isc.OffLedgerRequest
• func NewTrustedNetworkManager() peering.TrustedNetworkManager
• func RunHeavy(t *testing.T)
• type ChainRecordRegistryProvider
  • func NewChainRecordRegistryProvider() *ChainRecordRegistryProvider
  • func (p *ChainRecordRegistryProvider) LoadChainRecord(chainID *isc.ChainID) (*registry.ChainRecord, error)
  • func (p *ChainRecordRegistryProvider) SaveChainRecord(chainRecord *registry.ChainRecord) error
• type DkgRegistryProvider
  • func NewDkgRegistryProvider(nodePrivKey *cryptolib.PrivateKey) *DkgRegistryProvider
  • func (p *DkgRegistryProvider) LoadDKShare(sharedAddress iotago.Address) (tcrypto.DKShare, error)
  • func (p *DkgRegistryProvider) SaveDKShare(dkShare tcrypto.DKShare) error
• type PeeringNetBehavior
  • func NewPeeringNetReliable(log *logger.Logger) PeeringNetBehavior
  • func NewPeeringNetUnreliable(deliverPct, repeatPct int, delayFrom, delayTill time.Duration, ...) PeeringNetBehavior
• type PeeringNetDynamic
  • func NewPeeringNetDynamic(log *logger.Logger) *PeeringNetDynamic
  • func (pndT *PeeringNetDynamic) AddLink(inCh, outCh chan *peeringMsg, dstPubKey *cryptolib.PublicKey)
  • func (pndT *PeeringNetDynamic) Close()
  • func (pndT *PeeringNetDynamic) RemoveHandler(id string) bool
  • func (pndT *PeeringNetDynamic) WithDelayingChannel(id *string, delayFrom, delayTill time.Duration) *PeeringNetDynamic
  • func (pndT *PeeringNetDynamic) WithLosingChannel(id *string, deliveryProbability int) *PeeringNetDynamic
  • func (pndT *PeeringNetDynamic) WithPeerDisconnected(id *string, peerPubKey *cryptolib.PublicKey) *PeeringNetDynamic
  • func (pndT *PeeringNetDynamic) WithRepeatingChannel(id *string, repeatProbability int) *PeeringNetDynamic
• type PeeringNetwork
  • func NewPeeringNetwork(netIDs []string, nodeIdentities []*cryptolib.KeyPair, bufSize int, ...) *PeeringNetwork
  • func (p *PeeringNetwork) Close() error
  • func (p *PeeringNetwork) NetworkProviders() []peering.NetworkProvider

Functions

func DummyOffledgerRequest

func DummyOffledgerRequest(chainID *isc.ChainID) isc.OffLedgerRequest

func NewTrustedNetworkManager

func NewTrustedNetworkManager() peering.TrustedNetworkManager

func RunHeavy

func RunHeavy(t *testing.T)

Types

type ChainRecordRegistryProvider

type ChainRecordRegistryProvider struct {
	DB map[isc.ChainID]*registry.ChainRecord
}

func NewChainRecordRegistryProvider

func NewChainRecordRegistryProvider() *ChainRecordRegistryProvider

func (*ChainRecordRegistryProvider) LoadChainRecord

func (p *ChainRecordRegistryProvider) LoadChainRecord(chainID *isc.ChainID) (*registry.ChainRecord, error)

func (*ChainRecordRegistryProvider) SaveChainRecord

func (p *ChainRecordRegistryProvider) SaveChainRecord(chainRecord *registry.ChainRecord) error

type DkgRegistryProvider

type DkgRegistryProvider struct {
	DB map[string][]byte
	// contains filtered or unexported fields
}

DkgRegistryProvider stands for a mock for dkg.DKShareRegistryProvider.

func NewDkgRegistryProvider

func NewDkgRegistryProvider(nodePrivKey *cryptolib.PrivateKey) *DkgRegistryProvider

NewDkgRegistryProvider creates new mocked DKG registry provider.

func (*DkgRegistryProvider) LoadDKShare

func (p *DkgRegistryProvider) LoadDKShare(sharedAddress iotago.Address) (tcrypto.DKShare, error)

LoadDKShare implements dkg.DKShareRegistryProvider.

func (*DkgRegistryProvider) SaveDKShare

func (p *DkgRegistryProvider) SaveDKShare(dkShare tcrypto.DKShare) error

SaveDKShare implements dkg.DKShareRegistryProvider.

type PeeringNetBehavior

type PeeringNetBehavior interface {
	AddLink(inCh, outCh chan *peeringMsg, dstPubKey *cryptolib.PublicKey)
	Close()
}

An interface for all the network behaviors.

func NewPeeringNetReliable

func NewPeeringNetReliable(log *logger.Logger) PeeringNetBehavior

NewPeeringNetReliable constructs the PeeringNetBehavior.

func NewPeeringNetUnreliable

func NewPeeringNetUnreliable(deliverPct, repeatPct int, delayFrom, delayTill time.Duration, log *logger.Logger) PeeringNetBehavior

NewPeeringNetReliable constructs the PeeringNetBehavior.

type PeeringNetDynamic

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

peeringNetDynamic provides a behavior of a network with dynamically changeable working conditions. It works as peeringNetReliable without any handlers set.

func NewPeeringNetDynamic

func NewPeeringNetDynamic(log *logger.Logger) *PeeringNetDynamic

NewPeeringNetDynamic constructs the PeeringNetBehavior.

func (*PeeringNetDynamic) AddLink

func (pndT *PeeringNetDynamic) AddLink(inCh, outCh chan *peeringMsg, dstPubKey *cryptolib.PublicKey)

AddLink implements PeeringNetBehavior.

func (*PeeringNetDynamic) Close

func (pndT *PeeringNetDynamic) Close()

Close implements PeeringNetBehavior.

func (*PeeringNetDynamic) RemoveHandler

func (pndT *PeeringNetDynamic) RemoveHandler(id string) bool

func (*PeeringNetDynamic) WithDelayingChannel

func (pndT *PeeringNetDynamic) WithDelayingChannel(id *string, delayFrom, delayTill time.Duration) *PeeringNetDynamic

func (*PeeringNetDynamic) WithLosingChannel

func (pndT *PeeringNetDynamic) WithLosingChannel(id *string, deliveryProbability int) *PeeringNetDynamic

func (*PeeringNetDynamic) WithPeerDisconnected

func (pndT *PeeringNetDynamic) WithPeerDisconnected(id *string, peerPubKey *cryptolib.PublicKey) *PeeringNetDynamic

func (*PeeringNetDynamic) WithRepeatingChannel

func (pndT *PeeringNetDynamic) WithRepeatingChannel(id *string, repeatProbability int) *PeeringNetDynamic

type PeeringNetwork

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

PeeringNetwork represents a global view of the mocked network.

func NewPeeringNetwork

func NewPeeringNetwork(
	netIDs []string,
	nodeIdentities []*cryptolib.KeyPair,
	bufSize int,
	behavior PeeringNetBehavior,
	log *logger.Logger,
) *PeeringNetwork

NewPeeringNetwork creates new test network, it can then be used to create network nodes.

func (*PeeringNetwork) Close

func (p *PeeringNetwork) Close() error

Close implements the io.Closer interface.

func (*PeeringNetwork) NetworkProviders

func (p *PeeringNetwork) NetworkProviders() []peering.NetworkProvider

NetworkProviders returns network providers for each of the nodes in the network.