pubsub

type PubsubClientNodeStreamer interface {
	ClientStream(nodeId string, path string, data any) (_ []byte, err error)
	IsRunning() bool
}

type PubsubFollowingStorer interface {
	GetFollowees(userId string, limit *uint64, cursor *string) ([]domain.Following, string, error)
}

type PubsubModeratorConnector interface {
	Node() warpnet.P2PNode
	GenericStream(nodeId string, path stream.WarpRoute, data any) (_ []byte, err error)
}

type PubsubServerNodeConnector interface {
	Node() warpnet.P2PNode
	NodeInfo() warpnet.NodeInfo
}