client

type BucketInfo struct {
	Name         string
	CreationDate time.Time
}

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

type Config struct {
	// Region is the AWS region for the S3 service.
	Region string

	// Endpoint is an optional custom endpoint URL for S3-compatible services (SeaweedFS, LocalStack, etc.).
	Endpoint string

	// PresignEndpoint is an optional public-facing endpoint used only when
	// signing presigned URLs. When set, presigned URLs are signed against it so
	// they are reachable from outside the cluster, while data operations keep
	// using Endpoint (typically an internal/cluster address). Empty falls back
	// to Endpoint, preserving prior behavior.
	PresignEndpoint string

	// AccessKeyID is the AWS access key ID. If empty, the SDK credential chain is used.
	AccessKeyID string

	// SecretAccessKey is the AWS secret access key.
	SecretAccessKey string

	// SessionToken is an optional session token for temporary credentials.
	SessionToken string //#nosec G117 -- field name is an AWS credential, not a secret exposure

	// Profile is an optional AWS profile name to use from shared credentials/config.
	Profile string

	// UsePathStyle enables path-style addressing instead of virtual-hosted style.
	// Required for some S3-compatible services like SeaweedFS.
	UsePathStyle bool

	// Timeout is the timeout for S3 operations. For GetObject and
	// GetObjectRange it bounds the request up to the response headers, not the
	// body read that follows; ReadIdleTimeout governs that.
	Timeout time.Duration

	// ReadIdleTimeout bounds how long a GetObject or GetObjectRange body read
	// may go without receiving a byte. It is a stall detector, not a total:
	// a transfer that keeps making progress is never cut off, whatever the
	// object's size.
	ReadIdleTimeout time.Duration

	// Name is an optional identifier for this connection (used in multi-connection setups).
	Name string

	// DisableSSL disables SSL/TLS for the connection (useful for local development).
	DisableSSL bool
}

type CopyObjectInput struct {
	SourceBucket string
	SourceKey    string
	DestBucket   string
	DestKey      string
	Metadata     map[string]string
}

type CopyObjectOutput struct {
	ETag         string
	LastModified time.Time
	VersionID    string
}

type ListObjectsOutput struct {
	Objects           []ObjectInfo
	CommonPrefixes    []string
	IsTruncated       bool
	NextContinueToken string
	KeyCount          int32
}

type ObjectContent struct {
	Key         string
	Body        []byte
	ContentType string
	// Size is the whole object's length. From GetObjectRange it can exceed
	// len(Body).
	Size         int64
	LastModified time.Time
	ETag         string
	Metadata     map[string]string
}

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

type ObjectMetadata struct {
	Key           string
	Size          int64
	LastModified  time.Time
	ETag          string
	ContentType   string
	ContentLength int64
	Metadata      map[string]string
}

type ObjectUploader interface {
	UploadObject(
		ctx context.Context, input *transfermanager.UploadObjectInput, opts ...func(*transfermanager.Options),
	) (*transfermanager.UploadObjectOutput, error)
}

type PresignAPI interface {
	PresignGetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.PresignOptions)) (*v4.PresignedHTTPRequest, error)
	PresignPutObject(ctx context.Context, params *s3.PutObjectInput, optFns ...func(*s3.PresignOptions)) (*v4.PresignedHTTPRequest, error)
}

type PresignedURL struct {
	URL       string
	Method    string
	ExpiresAt time.Time
}

type PutObjectInput struct {
	Bucket      string
	Key         string
	Body        []byte
	ContentType string
	Metadata    map[string]string
}

type PutObjectOutput struct {
	ETag      string
	VersionID string
}

type PutObjectStreamInput struct {
	Bucket      string
	Key         string
	Body        io.Reader
	ContentType string
	Metadata    map[string]string

	// MaxBytes, when greater than zero, aborts the upload once more than
	// MaxBytes have been read from Body, returning an error that wraps
	// ErrStreamTooLarge. A value of zero means no limit is enforced here.
	MaxBytes int64
}

type S3API interface {
	ListBuckets(ctx context.Context, params *s3.ListBucketsInput, optFns ...func(*s3.Options)) (*s3.ListBucketsOutput, error)
	ListObjectsV2(ctx context.Context, params *s3.ListObjectsV2Input, optFns ...func(*s3.Options)) (*s3.ListObjectsV2Output, error)
	GetObject(ctx context.Context, params *s3.GetObjectInput, optFns ...func(*s3.Options)) (*s3.GetObjectOutput, error)
	HeadObject(ctx context.Context, params *s3.HeadObjectInput, optFns ...func(*s3.Options)) (*s3.HeadObjectOutput, error)
	PutObject(ctx context.Context, params *s3.PutObjectInput, optFns ...func(*s3.Options)) (*s3.PutObjectOutput, error)
	DeleteObject(ctx context.Context, params *s3.DeleteObjectInput, optFns ...func(*s3.Options)) (*s3.DeleteObjectOutput, error)
	CopyObject(ctx context.Context, params *s3.CopyObjectInput, optFns ...func(*s3.Options)) (*s3.CopyObjectOutput, error)
}