upload

type ListConfig = store.PaginationConfig

type ListOption func(cfg *ListConfig)

type ListShardsConfig = store.PaginationConfig

type ListShardsOption func(cfg *ListShardsConfig)

type Store interface {
	Exists(ctx context.Context, space did.DID, root cid.Cid) (bool, error)
	// May return [ErrUploadNotFound] if the upload does not exist.
	Get(ctx context.Context, space did.DID, root cid.Cid) (UploadRecord, error)
	Inspect(ctx context.Context, root cid.Cid) (UploadInspectRecord, error)
	List(ctx context.Context, space did.DID, options ...ListOption) (store.Page[UploadRecord], error)
	// Lists the shards of an upload.
	ListShards(ctx context.Context, space did.DID, root cid.Cid, options ...ListShardsOption) (store.Page[cid.Cid], error)
	// Removes an item from the table but fails if the item does not exist.
	Remove(ctx context.Context, space did.DID, root cid.Cid) error
	// Inserts an item in the table if it does not already exist or updates an
	// existing item if it does exist.
	Upsert(ctx context.Context, space did.DID, root cid.Cid, shards []cid.Cid, cause cid.Cid) error
}

type UploadInspectRecord struct {
	Spaces []did.DID
}

type UploadRecord struct {
	Space      did.DID
	Root       cid.Cid
	Cause      cid.Cid
	InsertedAt time.Time
	UpdatedAt  time.Time
}