add put object with tagging (#17)

Author: cubatic45

cloud/examples/object_storage/object_storage.go

@@ -44,7 +44,7 @@ func object_storage_examples(bucketName string, option cloud.Option) {
 	}
 
 	files := map[string]*object_storage.PutObjectInput{
-		"abc/a.txt":  {Body: []byte("abc"), ContentType: "application/json"},
+		"abc/a.txt":  {Body: []byte("abc"), ContentType: "application/json", Tagging: "Key1=Value1&Key2=Value2"},
 		"abc/ab.txt": {Body: []byte("abcdefg"), ContentType: "text/html"},
 		"bc/b.txt":   {Body: []byte("xyz")},
 	}

cloud/object_storage/alicloud_object_storage.go

@@ -5,12 +5,13 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"io"
+	"time"
+
 	"github.com/alibabacloud-go/tea/tea"
 	"github.com/aliyun/aliyun-oss-go-sdk/oss"
 	"github.com/byte-power/gorich/cloud"
 	"github.com/byte-power/gorich/utils"
-	"io"
-	"time"
 )
 
 var ossClientMap = make(map[string]*oss.Client)
@@ -264,7 +265,14 @@ func (service *AliCloudObjectStorageService) PutObject(ctx context.Context, key
 	if err != nil {
 		return err
 	}
-	return bucket.PutObject(key, bytes.NewReader(input.Body), oss.ContentType(input.ContentType))
+	var opts []oss.Option
+	if input.ContentType != "" {
+		opts = append(opts, oss.ContentType(input.ContentType))
+	}
+	if input.Tagging != "" {
+		opts = append(opts, oss.SetHeader(oss.HTTPHeaderOssTagging, input.Tagging))
+	}
+	return bucket.PutObject(key, bytes.NewReader(input.Body), opts...)
 }
 
 func (service *AliCloudObjectStorageService) DeleteObject(ctx context.Context, key string) error {

cloud/object_storage/aws_object_storage.go

@@ -4,7 +4,7 @@ import (
 	"bytes"
 	"context"
 	"errors"
-	"io/ioutil"
+	"io"
 	"time"
 
 	"github.com/aws/aws-sdk-go/aws"
@@ -110,7 +110,7 @@ func (service *AWSObjectStorageService) GetObject(ctx context.Context, key strin
 		}
 		return Object{}, err
 	}
-	bs, err := ioutil.ReadAll(resp.Body)
+	bs, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return Object{}, err
 	}
@@ -139,6 +139,9 @@ func (service *AWSObjectStorageService) PutObject(ctx context.Context, key strin
 		Key:    &key,
 		Body:   bytes.NewReader(input.Body),
 	}
+	if input.Tagging != "" {
+		opts.Tagging = aws.String(input.Tagging)
+	}
 	if input.ContentType != "" {
 		opts.ContentType = &input.ContentType
 	}

cloud/object_storage/object_storage.go

@@ -22,13 +22,14 @@ type ObjectStorageService interface {
 	DeleteObject(ctx context.Context, key string) error
 	DeleteObjects(ctx context.Context, keys ...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 generates signed url if key exists. If key does not exist, return error
 	GetSignedURLForExistedKey(ctx context.Context, key string, duration time.Duration) (string, error)
 }
 
 type PutObjectInput struct {
 	Body        []byte
 	ContentType string
+	Tagging     string
 }
 
 type Object struct {

cloud/object_storage/tencentcloud_object_storage.go

@@ -5,7 +5,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
-	"io/ioutil"
+	"io"
 	"net/http"
 	"net/url"
 	"time"
@@ -55,7 +55,8 @@ func GetTencentCloudObjectService(bucketName string, option cloud.Option) (Objec
 		Transport: &cos.AuthorizationTransport{
 			SecretID:  option.GetSecretID(),
 			SecretKey: option.GetSecretKey(),
-		}})
+		},
+	})
 	return &TencentCloudObjectStorageService{client: client}, nil
 }
 
@@ -136,7 +137,7 @@ func (service *TencentCloudObjectStorageService) GetObject(ctx context.Context,
 		}
 		return Object{}, err
 	}
-	bs, err := ioutil.ReadAll(resp.Body)
+	bs, err := io.ReadAll(resp.Body)
 	if err != nil {
 		return Object{}, err
 	}
@@ -198,13 +199,12 @@ func (service *TencentCloudObjectStorageService) PutObject(ctx context.Context,
 	if input == nil {
 		return errors.New("parameter input is nil")
 	}
-	var opts *cos.ObjectPutOptions
+	opts := &cos.ObjectPutOptions{ObjectPutHeaderOptions: &cos.ObjectPutHeaderOptions{}}
 	if input.ContentType != "" {
-		opts = &cos.ObjectPutOptions{
-			ObjectPutHeaderOptions: &cos.ObjectPutHeaderOptions{
-				ContentType: input.ContentType,
-			},
-		}
+		opts.ContentType = input.ContentType
+	}
+	if input.Tagging != "" {
+		opts.XOptionHeader = &http.Header{"x-cos-tagging": []string{input.Tagging}}
 	}
 	_, err := service.client.Object.Put(ctx, key, bytes.NewReader(input.Body), opts)
 	return err