discovery

type DiscoveryChallenger interface {
	Challenge(pubKey ic.PubKey, level int, streamF challenge.StreamFunc) (bool, error)
}

type DiscoveryHandler func(warpnet.WarpAddrInfo)

type DiscoveryInfoStorer interface {
	NodeInfo() warpnet.NodeInfo
	Peerstore() warpnet.WarpPeerstore
	SimpleConnect(warpnet.WarpAddrInfo) error
	GenericStream(nodeId string, path stream.WarpRoute, data any) ([]byte, error)
	SetNodePriority(pid warpnet.WarpPeerID, r warpnet.WarpReachability)
	SetMaxNodePriority(pid warpnet.WarpPeerID)
	SetMinNodePriority(pid warpnet.WarpPeerID)
}

type MetricsOnlineDiscoverer interface {
	PushStatusOnline(nodeId string)
	PushStatusOffline(nodeId string)
}

type NodeStorer interface {
	BlocklistRemove(peerId string) error
	IsBlocklisted(peerId string) bool
	BlocklistExponential(peerId string) error
	BlocklistTerm(peerId string) (*database.BlocklistTerm, error)
}

type UserStorer interface {
	Create(user domain.User) (domain.User, error)
	Update(userId string, newUser domain.User) (domain.User, error)
	GetByNodeID(nodeID string) (user domain.User, err error)
}