bcnet

type AskHandler interface {
	HandleAsk(ctx context.Context, res []byte, req p2p.Message[PeerID]) int
}

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

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

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

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

type BlobReq struct {
	Add    []cadata.ID  `json:"add,omitempty"`
	Delete []cadata.ID  `json:"delete,omitempty"`
	Exists []cadata.ID  `json:"exists,omitempty"`
	List   *ListBlobReq `json:"list,omitempty"`
}

type BlobRes struct {
	Error *WireError `json:"error,omitempty"`

	Add    []bool       `json:"add,omitempty"`
	Delete []bool       `json:"delete,omitempty"`
	Exists []bool       `json:"exists,omitempty"`
	List   *ListBlobRes `json:"list,omitempty"`
}

type ListBlobReq struct {
	First cadata.ID `json:"first"`
	Limit int       `json:"limit"`
}

type ListBlobRes struct {
	IDs []cadata.ID `json:"ids"`
}

type NodeInfo struct {
	TotalCount int64 `json:"quota_count"`
	FreeCount  int64 `json:"free_count"`
}

type Params struct {
	Swarm       p2p.SecureAskSwarm[PeerID, inet256.PublicKey]
	OpenStore   func(PeerID) cadata.Store
	TreeService TreeService
	Logger      *logrus.Logger
}

type PeerID = inet256.ID

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

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

type TreeID int64

type TreeInfo struct {
	ID TreeID `json:"id"`

	Root     tries.Root `json:"root"`
	MaxCount int64      `json:"max_count"`

	Status TreeStatus `json:"status"`
	Reason string     `json:"message"`
}

type TreePostReq struct {
	Root     tries.Root `json:"root"`
	MaxCount int64      `json:"max_nodes"`
}

type TreeReq struct {
	Post        *TreePostReq `json:"post,omitempty"`
	Drop        *TreeID      `json:"delete,omitempty"`
	List        *struct{}    `json:"list,omitempty"`
	GetNodeInfo *struct{}    `json:"get_node_info,omitempty"`
}

type TreeResp struct {
	Error *WireError `json:"error,omitempty"`

	Post     *TreeInfo  `json:"post,omitempty"`
	Drop     *bool      `json:"drop,omitempty"`
	List     []TreeInfo `json:"list,omitempty"`
	NodeInfo *NodeInfo  `json:"node_info,omitempty"`
}

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

type TreeService interface {
	Post(context.Context, PeerID, tries.Root, int64) (*TreeInfo, error)
	Drop(context.Context, PeerID, TreeID) (bool, error)
	List(context.Context, PeerID) ([]TreeInfo, error)
	GetNodeInfo(context.Context, PeerID) (*NodeInfo, error)
}

type TreeStatus string

type WireError struct {
	Code    codes.Code `json:"code"`
	Message string     `json:"msg"`
}