lib

type AdvancedQueryMessage struct {
	Filter QueryFilter
}

type BlockData struct {
	Leaf   merkle_dag.DagLeaf
	Branch merkle_dag.ClassicTreeBranch
}

type ClaimOwnershipMessage struct {
	Root      string
	PublicKey string
	Signature string
}

type Connector interface {
	Connect(ctx context.Context) error
	Disconnect() error
	OpenStream(ctx context.Context, protocolID string) (Stream, error)
}

type DagData struct {
	PublicKey secp256k1.PublicKey
	Signature schnorr.Signature
	Dag       merkle_dag.Dag
}

type DownloadFilter struct {
	LeafRanges     *LeafLabelRange
	LeafHashes     []string
	IncludeContent bool
}

type DownloadMessage struct {
	Root      string
	PublicKey string
	Signature string
	Filter    *DownloadFilter
}

type DownloadProgress struct {
	ConnectionID   string
	LeafsRetreived int
	Error          error
}

type ErrorMessage struct {
	Message string
}

type LeafLabelRange struct {
	From int
	To   int
}

type MessageEnvelope struct {
	Type    string      `cbor:"type"`
	Payload interface{} `cbor:"payload"`
}

type QueryFilter struct {
	Names   []string
	PubKeys []string
	Tags    map[string]string
}

type QueryMessage struct {
	QueryFilter map[string]string
}

type QueryResponse struct {
	Hashes []string
}

type ResponseMessage struct {
	Ok      bool
	Message string
}

type Stream interface {
	Read(p []byte) (int, error)
	Write(p []byte) (int, error)
	Close() error
	Context() context.Context
}

type TagFilter struct {
	Tags    map[string]string
	OrderBy string
}

type UploadMessage struct {
	Root          string
	Packet        merkle_dag.SerializableBatchedTransmissionPacket
	PublicKey     string
	Signature     string
	IsFinalPacket bool // Indicates this is the last packet in the transmission
}

type UploadProgress struct {
	ConnectionID string
	LeafsSent    int
	TotalLeafs   int
	Error        error
}