node

type BuilderNode struct {
	Node
	SearcherNode
	// contains filtered or unexported fields
}

type ConnectionGater interface {
	// GetPeerType get peer type builder or searcher
	GetPeerType(p peer.ID) (peerType commons.PeerType)
	//  DeletePeer delete registered peer
	DeletePeer(p peer.ID)
	// InterceptPeerDial intercepts peer dialing
	InterceptPeerDial(p peer.ID) (allow bool)
	// InterceptAddrDial intercepts address dialing
	InterceptAddrDial(peer.ID, multiaddr.Multiaddr) (allow bool)
	// InterceptAccept intercepts connection acceptance
	InterceptAccept(network.ConnMultiaddrs) (allow bool)
	// InterceptSecured intercepts secured connection
	InterceptSecured(network.Direction, peer.ID, network.ConnMultiaddrs) (allow bool)
	// InterceptUpgraded intercepts upgraded connection
	InterceptUpgraded(network.Conn) (allow bool, reason control.DisconnectReason)
}

type IBuilderNode interface {
	// INode extends the IBuilderNode interface and adds methods specific to node functionality.
	INode

	// ISearcherNode extends the IBuilderNode interface and adds methods specific to searchers functionality.
	ISearcherNode

	// GetBuilderPeersOnTopic returns the list of connected builder peers on the topic.
	GetBuilderPeersOnTopic() peer.IDSlice

	// GetSearcherPeersOnTopic returns the list of connected searcher peers on the topic.
	GetSearcherPeersOnTopic() peer.IDSlice

	// GetApprovedBuilderPeers returns the list of approved builder peers on the psio.
	GetApprovedBuilderPeers() []peer.ID

	// GetApprovedBuilderPeers returns the list of approved searcher peers on the psio.
	GetApprovedSearcherPeers() []peer.ID

	// Publish publishes a message over the topic.
	PublishB(message.OutboundMessage) error

	// Stream stream a message over the proto to specific peer.
	StreamB(peer.ID, message.OutboundMessage) error

	// Gossip gossip a message over the gossip proto to specific peers.
	GossipB(message.OutboundMessage) error

	// SignatureReader returns a channel for reading signatures from the node.
	SignatureReader() <-chan messages.PeerMsg

	// BlockKeyReader returns a channel for reading block keys from the node.
	BlockKeyReader() <-chan messages.PeerMsg

	// BundleReader returns a channel for reading bundels from the node.
	BundleReader() <-chan messages.PeerMsg

	// PreconfReader returns a channel for reading pre-confirmation bids from the node.
	PreconfReader() <-chan messages.PeerMsg

	// SignatureSend sends signature over the node.
	SignatureSend(peer.ID, []byte) error

	// BlockKeySend sends block key over the node.
	BlockKeySend(peer.ID, []byte) error

	// BundleSend sends bundles over the node.
	BundleSend(commons.Broadcast, []byte) error

	// PreconfSend sends a pre-confirmation bid over the node.
	PreconfSend(commons.Broadcast, []byte) error
}

type INode interface {
	// GetPeerID returns the peer id of the node.
	GetPeerID() peer.ID

	//GetAddrs() returns the peer addrs of the node.
	GetAddrs() []multiaddr.Multiaddr

	// GetToken returns the token of the node.
	GetToken() []byte

	// GetEthAddress returns the eth address of the node.
	GetEthAddress() common.Address

	// GetStake returns the stake amount of the node.
	GetStake() *big.Int

	// GetPeers returns the list of connected peers.
	GetPeers() peer.IDSlice

	// Close closes the node with the given reason and code.
	Close(string, int)

	// Ready returns a channel that signals when the node is ready.
	Ready() <-chan struct{}
}

type ISearcherNode interface {
	// INode extends the ISearcherNode interface and adds methods specific to node functionality.
	INode

	// GetBuilderPeersOnTopic returns the list of connected builder peers on the topic.
	GetBuilderPeersOnTopic() peer.IDSlice

	// GetApprovedBuilderPeers returns the list of approved builder peers on the psio.
	GetApprovedBuilderPeers() []peer.ID

	// Publish publishes a message over the topic.
	PublishS(message.OutboundMessage) error

	// Stream stream a message over the proto to specific peer.
	StreamS(peer.ID, message.OutboundMessage) error

	// Gossip gossip a message over the gossip proto to specific peers.
	GossipS(message.OutboundMessage) error

	// read the bids from searchers on the builders
	// BidReader returns a channel for reading bids from the node. NOTE: currently in the testing phase
	BidReader() <-chan messages.PeerMsg

	// read the commitments from builders on the searchers
	// CommitmentReader returns a channel for reading commitments from the node. NOTE: currently in the testing phase
	CommitmentReader() <-chan messages.PeerMsg

	// send from searchers to builders | recommended broadcast type: Publish
	// BidSend sends bid over the node.	NOTE: currently in the testing phase
	BidSend(commons.Broadcast, []byte) error

	// send from builders to searchers | recommended broadcast type: Gossip
	// CommitmentSend sends commitments over the node.	NOTE: currently in the testing phase
	CommitmentSend(commons.Broadcast, []byte) error
}

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

type SearcherNode struct {
	Node
	// contains filtered or unexported fields
}