s3

type AbortCall struct {
	Bucket   string
	Key      string
	UploadID string
}

type CompleteCall struct {
	Bucket   string
	Key      string
	UploadID string
	Parts    int
}

type CreateMultipartCall struct {
	Bucket string
	Key    string
}

type GetObjectCall struct {
	Bucket string
	Key    string
}

type HeadObjectCall struct {
	Bucket string
	Key    string
}

type MockS3Client struct {
	// TestServerURL is the base URL for generating fake presigned URLs.
	// Requests to these URLs should be handled by a test server (httptest.Server).
	TestServerURL string

	// UploadID is returned by CreateMultipartUpload.
	// If empty, a UUID is generated.
	UploadID string

	// Objects stores in-memory blobs for PutObject/HeadObject/DeleteObject/CopyObject/ListObjectsV2.
	Objects map[string][]byte

	CreateMultipartCalls []CreateMultipartCall
	CompleteCalls        []CompleteCall
	AbortCalls           []AbortCall
	UploadPartCalls      []UploadPartCall
	GetObjectCalls       []GetObjectCall
	HeadObjectCalls      []HeadObjectCall
	PutObjectCalls       []PutObjectCall

	// Error injection for testing error handling
	CreateMultipartError error
	CompleteError        error
	AbortError           error
	HeadObjectError      error
	CopyObjectError      error
	// contains filtered or unexported fields
}

type PutObjectCall struct {
	Bucket string
	Key    string
}

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

type S3Client interface {
	// Multipart upload operations
	CreateMultipartUpload(ctx context.Context, input *awss3.CreateMultipartUploadInput, opts ...func(*awss3.Options)) (*awss3.CreateMultipartUploadOutput, error)
	CompleteMultipartUpload(ctx context.Context, input *awss3.CompleteMultipartUploadInput, opts ...func(*awss3.Options)) (*awss3.CompleteMultipartUploadOutput, error)
	AbortMultipartUpload(ctx context.Context, input *awss3.AbortMultipartUploadInput, opts ...func(*awss3.Options)) (*awss3.AbortMultipartUploadOutput, error)

	// Direct object operations
	GetObject(ctx context.Context, input *awss3.GetObjectInput, opts ...func(*awss3.Options)) (*awss3.GetObjectOutput, error)
	HeadObject(ctx context.Context, input *awss3.HeadObjectInput, opts ...func(*awss3.Options)) (*awss3.HeadObjectOutput, error)
	PutObject(ctx context.Context, input *awss3.PutObjectInput, opts ...func(*awss3.Options)) (*awss3.PutObjectOutput, error)
	CopyObject(ctx context.Context, input *awss3.CopyObjectInput, opts ...func(*awss3.Options)) (*awss3.CopyObjectOutput, error)
	DeleteObject(ctx context.Context, input *awss3.DeleteObjectInput, opts ...func(*awss3.Options)) (*awss3.DeleteObjectOutput, error)
	ListObjectsV2(ctx context.Context, input *awss3.ListObjectsV2Input, opts ...func(*awss3.Options)) (*awss3.ListObjectsV2Output, error)

	// Presigned URL operations - return URL string directly
	PresignGetObject(ctx context.Context, input *awss3.GetObjectInput, expires time.Duration) (string, error)
	PresignHeadObject(ctx context.Context, input *awss3.HeadObjectInput, expires time.Duration) (string, error)
	PresignPutObject(ctx context.Context, input *awss3.PutObjectInput, expires time.Duration) (string, error)
	PresignUploadPart(ctx context.Context, input *awss3.UploadPartInput, expires time.Duration) (string, error)
}

type S3Service struct {
	Client     S3Client // S3 client for presigned URLs (interface for testability)
	Bucket     string   // S3 bucket name
	PathPrefix string   // S3 path prefix (if any)
}

type UploadPartCall struct {
	Bucket     string
	Key        string
	UploadID   string
	PartNumber int32
}