libp2p

type BootstrapNode interface {
	process.Interface
	log.Logger
	Libp2pHost() p2phost.Host
	Libp2pPeerID() string
	DHT() *dht.IpfsDHT
	Peers() []peer.AddrInfo
	Peerstore() corepeerstore.Peerstore
}

type DHT interface {
	Provide(context.Context, cid.Cid, bool) error
	FindProvidersAsync(ctx context.Context, key cid.Cid, count int) <-chan peer.AddrInfo
}

type DHTClient interface {
	process.Interface
	AnnounceStateURIs(ctx context.Context, stateURIs types.Set[string])
	AnnounceBlobs(ctx context.Context, blobIDs types.Set[blob.ID])
	ProvidersOfStateURI(ctx context.Context, stateURI string) (<-chan prototree.TreePeerConn, error)
	ProvidersOfBlob(ctx context.Context, blobID blob.ID) (<-chan protoblob.BlobPeerConn, error)
}

type Msg struct {
	Type    msgType     `json:"type"`
	Payload interface{} `json:"payload"`
}

type PeerManager interface {
	process.Interface
	NewPeerConn(ctx context.Context, dialAddr string) (swarm.PeerConn, error)
	OnPeerFound(via string, pinfo peer.AddrInfo)
	OnConnectedToPeer(network network.Network, conn network.Conn)
	MakeConnectedPeerConn(stream network.Stream) *peerConn
	MakeDisconnectedPeerConn(pinfo peer.AddrInfo) (*peerConn, error)
	EnsureConnectedToAllPeers()
}

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

type Store interface {
	StaticRelays() PeerSet
	AddStaticRelay(relayAddr string) error
	RemoveStaticRelay(relayAddr string) error

	DebugPrint()
}

type Transport interface {
	process.Interface
	swarm.Transport
	protoauth.AuthTransport
	protoblob.BlobTransport
	protohush.HushTransport
	prototree.TreeTransport
	Libp2pPeerID() string
	ListenAddrs() []string
	Peers() []peer.AddrInfo
	AddStaticRelay(relayAddr string) error
	RemoveStaticRelay(relayAddr string) error
	StaticRelays() PeerSet
}