oss

type AWSConfig struct {
	Region          string `yaml:"region" env:"OSS_AWS_REGION" required:"true"`
	AccessKeyID     string `yaml:"access_key_id" env:"OSS_AWS_ACCESS_KEY_ID" required:"true"`
	SecretAccessKey string `yaml:"secret_access_key" env:"OSS_AWS_SECRET_ACCESS_KEY" required:"true"`
	BucketName      string `yaml:"bucket_name" env:"OSS_AWS_BUCKET_NAME" required:"true"`
	Endpoint        string `yaml:"endpoint,omitempty" env:"OSS_AWS_ENDPOINT"` // 可选，用于兼容 S3 的服务
	UseSSL          bool   `yaml:"use_ssl" env:"OSS_AWS_USE_SSL" default:"true"`
}

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

type AliyunConfig struct {
	Endpoint        string `yaml:"endpoint" env:"OSS_ALIYUN_ENDPOINT" required:"true"`
	AccessKeyID     string `yaml:"access_key_id" env:"OSS_ALIYUN_ACCESS_KEY_ID" required:"true"`
	SecretAccessKey string `yaml:"secret_access_key" env:"OSS_ALIYUN_SECRET_ACCESS_KEY" required:"true"`
	BucketName      string `yaml:"bucket_name" env:"OSS_ALIYUN_BUCKET_NAME" required:"true"`
	UseSSL          bool   `yaml:"use_ssl" env:"OSS_ALIYUN_USE_SSL" default:"true"`
}

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

type Config struct {
	// Enabled 是否启用 OSS（必填）
	Enabled bool `yaml:"enabled" env:"OSS_ENABLED" required:"true"`
	// Default 默认使用的厂商名称
	Default string `yaml:"default" env:"OSS_DEFAULT"`
	// Stores 各厂商配置映射
	Stores map[string]StoreConfig `yaml:"stores" json:"stores"`
}

type IObjectStore interface {
	// PutObject 上传对象
	PutObject(ctx context.Context, bucket, key string, data io.Reader, opts ...PutOption) error
	// GetObject 下载对象
	GetObject(ctx context.Context, bucket, key string) (io.ReadCloser, error)
	// DeleteObject 删除对象
	DeleteObject(ctx context.Context, bucket, key string) error
	// ListObjects 列出对象
	ListObjects(ctx context.Context, bucket, prefix string, opts ...ListOption) ([]ObjectInfo, error)
	// PresignedGetObject 生成预签名下载 URL
	PresignedGetObject(ctx context.Context, bucket, key string, expiry time.Duration) (string, error)
	// PresignedPutObject 生成预签名上传 URL
	// contentType 用于指定上传时的 Content-Type，如果为空则不在签名中包含 Content-Type
	PresignedPutObject(ctx context.Context, bucket, key string, expiry time.Duration, contentType string) (string, error)
	// BucketExists 检查存储桶是否存在
	BucketExists(ctx context.Context, bucket string) (bool, error)
	// StatObject 获取对象信息
	StatObject(ctx context.Context, bucket, key string) (*ObjectInfo, error)
	// Close 关闭连接
	Close() error
}

type LifecycleManager interface {
	// SetLifecycle 设置生命周期规则
	SetLifecycle(ctx context.Context, bucket string, rules []LifecycleRule) error
}

type LifecycleRule struct {
	ID     string
	Status string
	Prefix string
	Expiry int // 过期天数
}

type ListOption struct {
	MaxKeys int
	Marker  string
}

type MinIOConfig struct {
	Endpoint        string `yaml:"endpoint" env:"OSS_MINIO_ENDPOINT" required:"true"`
	AccessKeyID     string `yaml:"access_key_id" env:"OSS_MINIO_ACCESS_KEY_ID" required:"true"`
	SecretAccessKey string `yaml:"secret_access_key" env:"OSS_MINIO_SECRET_ACCESS_KEY" required:"true"`
	BucketName      string `yaml:"bucket_name" env:"OSS_MINIO_BUCKET_NAME" required:"true"`
	UseSSL          bool   `yaml:"use_ssl" env:"OSS_MINIO_USE_SSL" default:"false"`
	Region          string `yaml:"region,omitempty" env:"OSS_MINIO_REGION"` // 可选，默认 us-east-1
}

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

type MultipartUploader interface {
	// CreateMultipartUpload 创建分块上传
	CreateMultipartUpload(ctx context.Context, bucket, key string) (string, error)
	// UploadPart 上传分块
	UploadPart(ctx context.Context, bucket, key, uploadId string, partNumber int, data io.Reader) (PartInfo, error)
	// CompleteMultipartUpload 完成分块上传
	CompleteMultipartUpload(ctx context.Context, bucket, key, uploadId string, parts []PartInfo) error
}

type ObjectInfo struct {
	Key          string
	Size         int64
	LastModified time.Time
	ContentType  string
	ETag         string
}

type Options struct {
	// Enabled 是否启用 OSS
	Enabled bool
	// Default 默认使用的厂商名称
	Default string
	// Stores 各厂商配置映射
	Stores map[string]StoreOptions
}

type PartInfo struct {
	PartNumber int
	ETag       string
}

type Provider string

type PutOption struct {
	ContentType   string
	ContentLength int64
	Metadata      map[string]string
}

type StoreConfig struct {
	// Enabled 是否启用此存储（必填）
	Enabled bool `yaml:"enabled" env:"OSS_STORE_ENABLED" required:"true"`
	// Type 厂商类型：aliyun, aws, tencent, minio
	Type string `yaml:"type" env:"OSS_STORE_TYPE" required:"true"`
	// Aliyun 阿里云 OSS 配置
	Aliyun *AliyunConfig `yaml:"aliyun,omitempty" json:"aliyun,omitempty"`
	// AWS AWS S3 配置
	AWS *AWSConfig `yaml:"aws,omitempty" json:"aws,omitempty"`
	// Tencent 腾讯云 COS 配置
	Tencent *TencentConfig `yaml:"tencent,omitempty" json:"tencent,omitempty"`
	// MinIO MinIO 配置
	MinIO *MinIOConfig `yaml:"minio,omitempty" json:"minio,omitempty"`
	// EnableTrace 是否启用追踪
	EnableTrace bool `yaml:"enable_trace" env:"OSS_ENABLE_TRACE" default:"true"`
}

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

type StoreOptions struct {
	// Enabled 是否启用此存储
	Enabled bool
	// Type 厂商类型
	Type Provider
	// Aliyun 阿里云 OSS 配置
	Aliyun *AliyunConfig
	// AWS AWS S3 配置
	AWS *AWSConfig
	// Tencent 腾讯云 COS 配置
	Tencent *TencentConfig
	// MinIO MinIO 配置
	MinIO *MinIOConfig
	// EnableTrace 是否启用追踪
	EnableTrace bool
}

type TencentConfig struct {
	Region     string `yaml:"region" env:"OSS_TENCENT_REGION" required:"true"`
	SecretID   string `yaml:"secret_id" env:"OSS_TENCENT_SECRET_ID" required:"true"`
	SecretKey  string `yaml:"secret_key" env:"OSS_TENCENT_SECRET_KEY" required:"true"`
	BucketName string `yaml:"bucket_name" env:"OSS_TENCENT_BUCKET_NAME" required:"true"`
	UseSSL     bool   `yaml:"use_ssl" env:"OSS_TENCENT_USE_SSL" default:"true"`
}

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