blossom

type BlobIndex interface {
	Keep(ctx context.Context, blob blossom.BlobDescriptor, pubkey nostr.PubKey) error
	List(ctx context.Context, pubkey nostr.PubKey) iter.Seq[blossom.BlobDescriptor]
	Get(ctx context.Context, sha256 string) (*blossom.BlobDescriptor, error)
	Delete(ctx context.Context, sha256 string, pubkey nostr.PubKey) error
}

type BlossomServer struct {
	ServiceURL string
	Store      BlobIndex

	StoreBlob     func(ctx context.Context, sha256 string, ext string, body []byte) error
	LoadBlob      func(ctx context.Context, sha256 string, ext string) (io.ReadSeeker, *url.URL, error)
	DeleteBlob    func(ctx context.Context, sha256 string, ext string) error
	ReceiveReport func(ctx context.Context, reportEvt nostr.Event) error

	RejectUpload func(ctx context.Context, auth *nostr.Event, size int, ext string) (bool, string, int)
	RejectGet    func(ctx context.Context, auth *nostr.Event, sha256 string, ext string) (bool, string, int)
	RejectList   func(ctx context.Context, auth *nostr.Event, pubkey nostr.PubKey) (bool, string, int)
	RejectDelete func(ctx context.Context, auth *nostr.Event, sha256 string, ext string) (bool, string, int)
}

type EventStoreBlobIndexWrapper struct {
	eventstore.Store

	ServiceURL string
}

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