p2pmocks

type MessengerStub struct {
	ConnectedFullHistoryPeersOnTopicCalled func(topic string) []core.PeerID
	IDCalled                               func() core.PeerID
	CloseCalled                            func() error
	CreateTopicCalled                      func(name string, createChannelForTopic bool) error
	HasTopicCalled                         func(name string) bool
	HasTopicValidatorCalled                func(name string) bool
	BroadcastOnChannelCalled               func(channel string, topic string, buff []byte)
	BroadcastCalled                        func(topic string, buff []byte)
	RegisterMessageProcessorCalled         func(topic string, identifier string, handler p2p.MessageProcessor) error
	BootstrapCalled                        func() error
	PeerAddressesCalled                    func(pid core.PeerID) []string
	BroadcastOnChannelBlockingCalled       func(channel string, topic string, buff []byte) error
	IsConnectedToTheNetworkCalled          func() bool
	PeersCalled                            func() []core.PeerID
	AddressesCalled                        func() []string
	ConnectToPeerCalled                    func(address string) error
	IsConnectedCalled                      func(peerID core.PeerID) bool
	ConnectedPeersCalled                   func() []core.PeerID
	ConnectedAddressesCalled               func() []string
	ConnectedPeersOnTopicCalled            func(topic string) []core.PeerID
	UnregisterAllMessageProcessorsCalled   func() error
	UnregisterMessageProcessorCalled       func(topic string, identifier string) error
	SendToConnectedPeerCalled              func(topic string, buff []byte, peerID core.PeerID) error
	ThresholdMinConnectedPeersCalled       func() int
	SetThresholdMinConnectedPeersCalled    func(minConnectedPeers int) error
	SetPeerShardResolverCalled             func(peerShardResolver p2p.PeerShardResolver) error
	SetPeerDenialEvaluatorCalled           func(handler p2p.PeerDenialEvaluator) error
	GetConnectedPeersInfoCalled            func() *p2p.ConnectedPeersInfo
	UnjoinAllTopicsCalled                  func() error
	PortCalled                             func() int
	WaitForConnectionsCalled               func(maxWaitingTime time.Duration, minNumOfPeers uint32)
	SignCalled                             func(payload []byte) ([]byte, error)
	VerifyCalled                           func(payload []byte, pid core.PeerID, signature []byte) error
	AddPeerTopicNotifierCalled             func(notifier p2p.PeerTopicNotifier) error
	BroadcastUsingPrivateKeyCalled         func(topic string, buff []byte, pid core.PeerID, skBytes []byte)
	SignUsingPrivateKeyCalled              func(skBytes []byte, payload []byte) ([]byte, error)
}

type NetworkShardingCollectorStub struct {
	UpdatePeerIDPublicKeyPairCalled func(pid core.PeerID, pk []byte)
	UpdatePeerIDInfoCalled          func(pid core.PeerID, pk []byte, shardID uint32)
	PutPeerIdShardIdCalled          func(pid core.PeerID, shardId uint32)
	PutPeerIdSubTypeCalled          func(pid core.PeerID, peerSubType core.P2PPeerSubType)
	GetLastKnownPeerIDCalled        func(pk []byte) (core.PeerID, bool)
	GetPeerInfoCalled               func(pid core.PeerID) core.P2PPeerInfo
}

type PeersHolderStub struct {
	PutConnectionAddressCalled func(peerID core.PeerID, address string)
	PutShardIDCalled           func(peerID core.PeerID, shardID uint32)
	GetCalled                  func() map[uint32][]core.PeerID
	ContainsCalled             func(peerID core.PeerID) bool
	RemoveCalled               func(peerID core.PeerID)
	ClearCalled                func()
}

type PeersRatingHandlerStub struct {
	AddPeerCalled                  func(pid core.PeerID)
	IncreaseRatingCalled           func(pid core.PeerID)
	DecreaseRatingCalled           func(pid core.PeerID)
	GetTopRatedPeersFromListCalled func(peers []core.PeerID, numOfPeers int) []core.PeerID
}