owlnet

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

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

type BlobPullReq struct {
	Store Handle    `json:"store"`
	ID    cadata.ID `json:"id"`
}

type BlobPullServer struct {
	Open func(peerID PeerID, volID uint32, sid uint8) cadata.Getter
	// contains filtered or unexported fields
}

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

type DAGInfo struct {
	Scheme string       `json:"scheme"`
	Epochs []owldag.Ref `json:"epochs"`
	Handle Handle       `json:"handle"`
	Stores []Handle     `json:"stores"`
}

type DAGReq struct {
	GetHeads  *GetHeadsReq  `json:"get_heads,omitempty"`
	PushHeads *PushHeadsReq `json:"push_heads,omitempty"`
	GetList   *GetListReq   `json:"list,omitempty"`
}

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

	GetHeads  []owldag.Head `json:"get_heads,omitempty"`
	PushHeads *struct{}     `json:"push_heads,omitempty"`
	GetList   []DAGInfo     `json:"get_list,omitempty"`
}

type DAGServer struct {
	OnPushHeads func(from PeerID, volID int, srcDAG Handle, heads []owldag.Head) error
	OnGetHeads  func(from PeerID, volID int) ([]owldag.Head, error)
	OnList      func(from PeerID, schemeIs string, mustContain []owldag.Ref) ([]LocalDAGInfo, error)
	// contains filtered or unexported fields
}

type GetHeadsReq struct {
	DAG Handle `json:"dag"`
}

type GetListReq struct {
	// Scheme, if set, restricts the results returned to those which match the scheme
	Scheme string `json:"scheme"`
	// Contains when len(_) > 0 restricts the results to those which contain all the Refs.
	Contains []owldag.Ref `json:"contains"`
}

type Handle [32]byte

type LocalDAGInfo struct {
	ID     int
	Scheme string
	Epochs []owldag.Ref
}

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

type PeerID = owldag.PeerID

type PushHeadsReq struct {
	SrcDAG Handle        `json:"src_dag"`
	DstDAG Handle        `json:"dst_dag"`
	Heads  []owldag.Head `json:"heads"`
	Blobs  []byte        `json:"blobs"`
}

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

type Swarm = p2p.SecureAskSwarm[PeerID, inet256.PublicKey]

type WireError struct {
	Code codes.Code
	Msg  string
}