s3

type Bucket struct {
	*Client
	// contains filtered or unexported fields
}

type BucketInfo struct {
	Name         string
	CreationDate time.Time
}

type BucketInterface interface {
	// Object operations
	PutObject(ctx context.Context, bucket, key string, reader io.Reader, size int64, opts ...ObjectOptions) error
	GetObject(ctx context.Context, bucket, key string) (io.ReadCloser, error)
	DeleteObject(ctx context.Context, bucket, key string) error
	ListObjects(ctx context.Context, bucket string, opts ...ListOptions) ([]ObjectInfo, error)
	ObjectExists(ctx context.Context, bucket, key string) (bool, error)
	HeadObject(ctx context.Context, bucket, key string) (*ObjectInfo, error)

	// Advanced operations
	PutObjectStream(ctx context.Context, bucket, key string, reader io.Reader, opts ...ObjectOptions) error
	GetObjectStream(ctx context.Context, bucket, key string, writer io.Writer) error
	CopyObject(ctx context.Context, srcBucket, srcKey, dstBucket, dstKey string, opts ...ObjectOptions) error

	// Advanced download operations
	GetObjectRange(ctx context.Context, bucket, key string, start, end int64) (io.ReadCloser, error)
	GetObjectStreamRange(ctx context.Context, bucket, key string, writer io.Writer, start, end int64) error
	GetObjectAdvanced(ctx context.Context, bucket, key string, writer io.Writer, opts DownloadOptions) error

	// Multipart upload operations
	PutObjectMultipart(ctx context.Context, bucket, key string, reader io.Reader, size int64, opts ...ObjectOptions) error
	PutObjectAdvanced(ctx context.Context, bucket, key string, reader io.Reader, size int64, opts UploadOptions) error

	// Pre-signed URLs
	PresignGetObject(ctx context.Context, bucket, key string, expiry time.Duration) (string, error)
	PresignPutObject(ctx context.Context, bucket, key string, expiry time.Duration, opts ...ObjectOptions) (string, error)
}

type BucketOptions struct {
	Region string
	ACL    string
}

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

type ClientInterface interface {
	// Connection management
	Connect(ctx context.Context) error
	MinioClient() *minio.Client
	Close() error
	IsConnected() bool

	// Bucket operations
	CreateBucket(ctx context.Context, bucket string, opts ...BucketOptions) error
	DeleteBucket(ctx context.Context, bucket string) error
	ListBuckets(ctx context.Context) ([]BucketInfo, error)
	BucketExists(ctx context.Context, bucket string) (bool, error)
}

type Config struct {
	// Connection settings
	Endpoint    string `json:"endpoint"`    // Custom endpoint for S3-compatible services
	Region      string `json:"region"`      // AWS region
	AccessKeyID string `json:"accessKeyId"` // AWS access key ID

	// Secret access key using secure credential handling
	secure.DefaultCredentialConfig

	// Optional bucket default
	DefaultBucket string `json:"defaultBucket"`

	// Behavior settings
	ForcePathStyle bool `json:"forcePathStyle"` // Force path-style addressing (for MinIO, etc.)
	UseAccelerate  bool `json:"useAccelerate"`  // Use S3 transfer acceleration
	UseSSL         bool `json:"useSSL"`         // Use SSL/TLS (default: true)

	// Timeout settings
	TimeoutSeconds       int `json:"timeoutSeconds"`       // Request timeout in seconds
	UploadTimeoutSeconds int `json:"uploadTimeoutSeconds"` // Upload timeout in seconds (for large files)

	// Multipart upload settings
	MultipartThreshold int64 `json:"multipartThreshold"` // Threshold for multipart uploads in bytes
	PartSize           int64 `json:"partSize"`           // Size of each part in multipart uploads
	MaxUploadParts     int   `json:"maxUploadParts"`     // Maximum number of parts in multipart upload
	Concurrency        int   `json:"concurrency"`        // Number of concurrent uploads

	// TLS configuration
	tls.ClientConfig

	// connection polling
	MaxIdleConns        int           `json:"maxIdleConns"`        // Total idle connections
	MaxIdleConnsPerHost int           `json:"maxIdleConnsPerHost"` // Per-host idle connections
	MaxConnsPerHost     int           `json:"maxConnsPerHost"`     // Max connections per host
	IdleConnTimeout     time.Duration `json:"idleConnTimeout"`

	// Retry settings
	MaxRetries int    `json:"maxRetries"` // Maximum number of retries
	RetryMode  string `json:"retryMode"`  // Retry mode: "standard" or "adaptive"
}

type DownloadOptions struct {
	// Range specification
	StartByte *int64
	EndByte   *int64

	// Concurrency control
	Concurrency int

	// Part size for multipart downloads
	PartSize int64
}

type ListOptions struct {
	Prefix     string
	Delimiter  string
	MaxKeys    int32
	StartAfter string
}

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

type ObjectOptions struct {
	ContentType        string
	CacheControl       string
	ContentDisposition string
	ContentEncoding    string
	ContentLanguage    string
	Metadata           map[string]string
	Tags               map[string]string
	StorageClass       string
	// Server-Side Encryption options
	ServerSideEncryption    string            // AES256, aws:kms, aws:kms:dsse
	SSEKMSKeyId             string            // KMS key ID for SSE-KMS
	SSEKMSEncryptionContext map[string]string // KMS encryption context
	SSECustomerAlgorithm    string            // Customer-provided encryption algorithm (AES256)
	SSECustomerKey          string            // Customer-provided encryption key (base64)
	SSECustomerKeyMD5       string            // MD5 digest of customer key
	BucketKeyEnabled        *bool             // Enable S3 Bucket Key for cost optimization
}

type UploadOptions struct {
	ObjectOptions
	// Additional upload-specific options
	LeavePartsOnError bool // Leave successfully uploaded parts on error for manual recovery
	MaxUploadParts    int  // Override the default maximum number of parts
	Concurrency       int  // Override the default concurrency level
}