feat: add CopyObject (#22)

Author: cubatic45

cloud/object_storage/alicloud_object_storage.go

@@ -325,6 +325,20 @@ func (service *AliCloudObjectStorageService) DeleteObjects(ctx context.Context,
 	return err
 }
 
+func (service *AliCloudObjectStorageService) CopyObject(ctx context.Context, from, to string) error {
+	if from == "" || to == "" {
+		return ErrObjectKeyEmpty
+	}
+	bucket, err := service.client.Bucket(service.bucketName)
+	if err != nil {
+		return err
+	}
+	if _, err := bucket.CopyObject(from, to); err != nil {
+		return err
+	}
+	return nil
+}
+
 func (service *AliCloudObjectStorageService) GetSignedURL(key string, duration time.Duration) (string, error) {
 	if key == "" {
 		return "", ErrObjectKeyEmpty

cloud/object_storage/aws_object_storage.go

@@ -200,6 +200,18 @@ func (service *AWSObjectStorageService) DeleteObjects(ctx context.Context, keys
 	return err
 }
 
+func (service *AWSObjectStorageService) CopyObject(ctx context.Context, from, to string) error {
+	if from == "" || to == "" {
+		return ErrObjectKeyEmpty
+	}
+	_, err := service.client.CopyObjectWithContext(ctx, &s3.CopyObjectInput{
+		Bucket:     aws.String(service.bucketName),
+		CopySource: aws.String(from),
+		Key:        aws.String(to),
+	})
+	return err
+}
+
 func (service *AWSObjectStorageService) GetSignedURL(key string, duration time.Duration) (string, error) {
 	if key == "" {
 		return "", ErrObjectKeyEmpty

cloud/object_storage/object_storage.go

@@ -27,6 +27,7 @@ type ObjectStorageService interface {
 	PutObject(ctx context.Context, key string, input *PutObjectInput) error
 	DeleteObject(ctx context.Context, key string) error
 	DeleteObjects(ctx context.Context, keys ...string) error
+	CopyObject(ctx context.Context, from, to string) error
 	GetSignedURL(key string, duration time.Duration) (string, error)
 	// GetSignedURLForExistedKey generates signed url if key exists. If key does not exist, return error
 	GetSignedURLForExistedKey(ctx context.Context, key string, duration time.Duration) (string, error)
@@ -128,7 +129,6 @@ type PutHeaderOption struct {
 }
 
 func (o *PutHeaderOption) ToAliCloudOptions() []oss.Option {
-
 	options := make([]oss.Option, 0)
 	if o.ContentDisposition != nil {
 		options = append(options, oss.ContentDisposition(*o.ContentDisposition))
@@ -152,7 +152,6 @@ func (o *PutHeaderOption) ToAliCloudOptions() []oss.Option {
 }
 
 func (o *PutHeaderOption) ToTencentCloudOptions() *cos.PresignedURLOptions {
-
 	opt := &cos.PresignedURLOptions{
 		Query:  &url.Values{},
 		Header: &http.Header{},

cloud/object_storage/tencentcloud_object_storage.go

@@ -272,6 +272,14 @@ func (service *TencentCloudObjectStorageService) DeleteObjects(ctx context.Conte
 	return err
 }
 
+func (service *TencentCloudObjectStorageService) CopyObject(ctx context.Context, from, to string) error {
+	if from == "" || to == "" {
+		return ErrObjectKeyEmpty
+	}
+	_, _, err := service.client.Object.Copy(ctx, to, from, nil)
+	return err
+}
+
 func (service *TencentCloudObjectStorageService) GetSignedURL(key string, duration time.Duration) (string, error) {
 	if key == "" {
 		return "", ErrObjectKeyEmpty