connections

type ConnHandler ¶

type ConnHandler interface {
	Handle(logger *zap.Logger) *libp2pnetwork.NotifyBundle
}

ConnHandler handles new connections (inbound / outbound) using libp2pnetwork.NotifyBundle

func NewConnHandler(
	ctx context.Context,
	handshaker Handshaker,
	subnetsProvider SubnetsProvider,
	subnetsIndex peers.SubnetsIndex,
	connIdx peers.ConnectionIndex,
	peerInfos peers.PeerInfoIndex,
	mr Metrics,
) ConnHandler

type HandshakeFilter ¶

type HandshakeFilter func(senderID peer.ID, sni records.AnyNodeInfo) error

HandshakeFilter can be used to filter nodes once we handshaked with them

func NetworkIDFilter(networkID string) HandshakeFilter

func RegisteredOperatorsFilter(nodeStorage storage.Storage, keysConfigWhitelist []string) HandshakeFilter

func SenderRecipientIPsCheckFilter(me peer.ID) HandshakeFilter

func SignatureCheckFilter() HandshakeFilter

type Handshaker ¶

type Handshaker interface {
	Handshake(logger *zap.Logger, conn libp2pnetwork.Conn) error
	Handler(logger *zap.Logger) libp2pnetwork.StreamHandler
}

Handshaker is the interface for handshaking with peers. it uses node info protocol to exchange information with other nodes and decide whether we want to connect.

NOTE: due to compatibility with v0, we accept nodes with user agent as a fallback when the new protocol is not supported.

func NewHandshaker(ctx context.Context, cfg *HandshakerCfg, filters func() []HandshakeFilter) Handshaker

type HandshakerCfg ¶

type HandshakerCfg struct {
	Network         libp2pnetwork.Network
	Streams         streams.StreamController
	NodeInfos       peers.NodeInfoIndex
	PeerInfos       peers.PeerInfoIndex
	ConnIdx         peers.ConnectionIndex
	SubnetsIdx      peers.SubnetsIndex
	IDService       identify.IDService
	OperatorSigner  keys.OperatorSigner
	SubnetsProvider SubnetsProvider
	Permissioned    func() bool
}

HandshakerCfg is the configuration for creating an handshaker instance

type Metrics ¶ added in v1.2.2

type Metrics interface {
	PeerDisconnected(peer.ID)
}

type SubnetsProvider ¶

type SubnetsProvider func() records.Subnets

SubnetsProvider returns the subnets of or node