p2p

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

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

type DebugService interface {
	Service
	SetWelcomeMessage(val string) error
	GetWelcomeMessage() string
}

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

type Disconnecter interface {
	Disconnect(overlay swarm.Address) error
	// Blocklist will disconnect a peer and put it on a blocklist (blocking in & out connections) for provided duration
	// duration 0 is treated as an infinite duration
	Blocklist(overlay swarm.Address, duration time.Duration) error
}

type Halter interface {
	// Halt new incoming connections while shutting down
	Halt()
}

type HandlerFunc func(context.Context, Peer, Stream) error

type HandlerMiddleware func(HandlerFunc) HandlerFunc

type Headers map[string][]byte

type HeadlerFunc func(Headers, swarm.Address) Headers

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

type Notifier interface {
	Connected(context.Context, Peer, bool) error
	Disconnected(Peer)
	Announce(context.Context, swarm.Address, bool) error
}

type Peer struct {
	Address         swarm.Address
	FullNode        bool
	EthereumAddress []byte
}

type PickyNotifier interface {
	Pick(Peer) bool
	Notifier
}

type ProtocolSpec struct {
	Name          string
	Version       string
	StreamSpecs   []StreamSpec
	ConnectIn     func(context.Context, Peer) error
	ConnectOut    func(context.Context, Peer) error
	DisconnectIn  func(Peer) error
	DisconnectOut func(Peer) error
}

type Service interface {
	AddProtocol(ProtocolSpec) error
	// Connect to a peer but do not notify topology about the established connection.
	Connect(ctx context.Context, addr ma.Multiaddr) (address *bzz.Address, err error)
	Disconnecter
	Peers() []Peer
	BlocklistedPeers() ([]Peer, error)
	Addresses() ([]ma.Multiaddr, error)
	SetPickyNotifier(PickyNotifier)
	Halter
}

type Stream interface {
	io.ReadWriter
	io.Closer
	ResponseHeaders() Headers
	Headers() Headers
	FullClose() error
	Reset() error
}

type StreamSpec struct {
	Name    string
	Handler HandlerFunc
	Headler HeadlerFunc
}

type Streamer interface {
	NewStream(ctx context.Context, address swarm.Address, h Headers, protocol, version, stream string) (Stream, error)
}

type StreamerDisconnecter interface {
	Streamer
	Disconnecter
}