blob

type AfterCopyObjectHook func(req *CopyObjectParams, resp *CopyObjectResponse)

type AfterDeleteObjectHook func(req string, resp bool)

type AfterPutObjectHook func(req *PutObjectParams, resp *PutObjectResponse)

type BlobChangeCallback func(key string, eventType BlobEventType)

type BlobEventType uint8

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

type BlobInfo struct {
	Key          string `json:"key" db:"key"`
	ETag         string `json:"etag" db:"etag"`
	Size         int64  `json:"size" db:"size"`
	LastModified string `json:"lastModified" db:"last_modified"`
}

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

type CompleteMultipartUploadParams struct {
	Key      string           `json:"key"`
	UploadID string           `json:"uploadId"`
	Parts    []*CompletedPart `json:"parts"`
}

type CompletedPart struct {
	PartNumber int    `json:"partNumber"`
	ETag       string `json:"etag"`
}

type CopyObjectParams struct {
	SourceKey      string
	DestinationKey string
}

type CopyObjectResponse struct {
	ETag         string
	LastModified time.Time
}

type GetObjectResponse struct {
	Body         io.ReadCloser
	ETag         string
	Size         int64
	LastModified time.Time
}

type IBlobBackend interface {
	// GetObject retrieves an object from storage by its key
	GetObject(ctx context.Context, key string) (*GetObjectResponse, error)

	// GetObjectPresigned generates a presigned URL for downloading an object
	GetObjectPresigned(ctx context.Context, key string) (string, error)

	// PutObject uploads a single object to storage
	PutObject(ctx context.Context, params *PutObjectParams) (*PutObjectResponse, error)

	// PutObjectPresigned generates a presigned URL for uploading an object
	PutObjectPresigned(ctx context.Context, key string) (string, error)

	// PutObjectMultipart initiates a multipart upload and returns upload URLs
	PutObjectMultipart(ctx context.Context, params *PutObjectMultipartParams) (*PutObjectMultipartResponse, error)

	// CompleteMultipartUpload finalizes a multipart upload
	CompleteMultipartUpload(ctx context.Context, params *CompleteMultipartUploadParams) (*PutObjectResponse, error)

	// CopyObject copies an object from one location to another
	CopyObject(ctx context.Context, params *CopyObjectParams) (*CopyObjectResponse, error)

	// DeleteObject removes an object from storage, returns true if successful
	DeleteObject(ctx context.Context, key string) (bool, error)

	// ListObjects returns a list of all objects in storage
	ListObjects(ctx context.Context) ([]*BlobInfo, error)

	// Delegate returns the underlying backend implementation
	Delegate() any
	// contains filtered or unexported methods
}

type IBlobIndex interface {
	// Get retrieves a blob by its key, returning the blob info and whether it exists
	Get(key string) (*BlobInfo, bool)

	// Set stores a blob in the index, creating or updating the entry
	Set(blob *BlobInfo) error

	// SetMany stores multiple blobs in the index in a single operation
	SetMany(blobs []*BlobInfo) error

	// Remove deletes a blob from the index by its key
	Remove(key string) error

	// List returns all blobs in the index as a slice
	List() ([]*BlobInfo, error)

	// Iter returns an iterator for traversing all blobs in the index
	Iter() iter.Seq[*BlobInfo]

	// Count returns the total number of blobs in the index
	Count() int

	// FilterByKeyGlob filters blobs by key using glob pattern matching
	FilterByKeyGlob(pattern string) ([]*BlobInfo, error)

	// FilterByPrefix filters blobs by key prefix
	FilterByPrefix(prefix string) ([]*BlobInfo, error)

	// FilterBySuffix filters blobs by key suffix
	FilterBySuffix(suffix string) ([]*BlobInfo, error)

	// FilterByTime filters blobs based on a time range filter
	FilterByTime(filter TimeFilter) ([]*BlobInfo, error)

	// FilterAfterTime filters blobs modified after the specified time
	FilterAfterTime(after time.Time) ([]*BlobInfo, error)

	// FilterBeforeTime filters blobs modified before the specified time
	FilterBeforeTime(before time.Time) ([]*BlobInfo, error)
}

type PutObjectMultipartParams struct {
	Key   string `json:"key" binding:"required"`
	Parts uint16 `json:"parts" binding:"required"`
}

type PutObjectMultipartResponse struct {
	Key      string   `json:"key"`
	UploadID string   `json:"uploadId"`
	URLs     []string `json:"urls"`
}

type PutObjectParams struct {
	Key  string
	ETag string
	Size int64
	Body io.Reader
}

type PutObjectPresignedResponse struct {
	Name          string   `json:"name" binding:"required"`
	UploadID      string   `json:"uploadId"`
	PresignedURLs []string `json:"presignedUrls"`
}

type PutObjectResponse struct {
	Key          string
	Version      string
	ETag         string
	Size         int64
	LastModified time.Time
}

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

type S3Config struct {
	BucketName    string `mapstructure:"bucket_name"`
	Region        string `mapstructure:"region"`
	AccessKey     string `mapstructure:"access_key"`
	SecretKey     string `mapstructure:"secret_key"`
	Endpoint      string `mapstructure:"endpoint"`
	UseAccelerate bool   `mapstructure:"use_accelerate"`
}

type Service interface {
	// Backend returns the underlying blob storage backend
	Backend() IBlobBackend

	// Index returns the blob index for metadata management
	Index() IBlobIndex

	// OnBlobChange registers a callback for blob change events
	OnBlobChange(callback BlobChangeCallback)
}

type TimeFilter struct {
	Before *time.Time
	After  *time.Time
}