feat(storage): support to set ACL_PUBLIC_READ ENV

Author: sy-records

storage-aliyunoss/aliyunoss.go

@@ -25,6 +25,7 @@ import (
 	"encoding/hex"
 	"encoding/json"
 	"fmt"
+	"os"
 	"path/filepath"
 	"strings"
 	"time"
@@ -40,6 +41,11 @@ import (
 //go:embed  info.yaml
 var Info embed.FS
 
+var (
+	// aclPublicRead is the environment variable for some special platforms such as digital ocean
+	aclPublicRead = os.Getenv("ACL_PUBLIC_READ")
+)
+
 type Storage struct {
 	Config *StorageConfig
 }
@@ -121,7 +127,11 @@ func (s *Storage) UploadFile(ctx *plugin.GinContext, condition plugin.UploadFile
 		ObjectKey: objectKey,
 		Reader:    open,
 	}
-	respBody, err := bucket.DoPutObject(request, nil)
+	var options []oss.Option
+	if len(aclPublicRead) > 0 {
+		options = append(options, oss.ObjectACL(oss.ACLPublicRead))
+	}
+	respBody, err := bucket.DoPutObject(request, options)
 	if err != nil {
 		resp.OriginalError = fmt.Errorf("upload file failed: %v", err)
 		resp.DisplayErrorMsg = plugin.MakeTranslator(i18n.ErrUploadFileFailed)

storage-aliyunoss/info.yaml

@@ -17,6 +17,6 @@
 
 slug_name: aliyunoss_storage
 type: storage
-version: 1.2.12
+version: 1.2.13
 author: answerdev
 link: https://github.com/apache/answer-plugins/tree/main/storage-aliyunoss

storage-tencentyuncos/info.yaml

@@ -17,6 +17,6 @@
 
 slug_name: tencentyuncos_storage
 type: storage
-version: 1.0.3
+version: 1.0.4
 author: Luffy
 link: https://github.com/apache/answer-plugins/tree/main/storage-tencentyuncos

storage-tencentyuncos/tencentyuncos.go

@@ -27,6 +27,7 @@ import (
 	"fmt"
 	"net/http"
 	"net/url"
+	"os"
 	"path/filepath"
 	"strings"
 	"time"
@@ -42,6 +43,11 @@ import (
 //go:embed  info.yaml
 var Info embed.FS
 
+var (
+	// aclPublicRead is the environment variable for some special platforms such as digital ocean
+	aclPublicRead = os.Getenv("ACL_PUBLIC_READ")
+)
+
 type Storage struct {
 	Config *StorageConfig
 }
@@ -122,7 +128,15 @@ func (s *Storage) UploadFile(ctx *plugin.GinContext, condition plugin.UploadFile
 	defer openFile.Close()
 
 	objectKey := s.createObjectKey(file.Filename, condition.Source)
-	_, err = client.Object.Put(ctx, objectKey, openFile, nil)
+	var options *cos.ObjectPutOptions
+	if len(aclPublicRead) > 0 {
+		options = &cos.ObjectPutOptions{
+			ACLHeaderOptions: &cos.ACLHeaderOptions{
+				XCosACL: "public-read",
+			},
+		}
+	}
+	_, err = client.Object.Put(ctx, objectKey, openFile, options)
 	if err != nil {
 		resp.OriginalError = fmt.Errorf("upload file failed: %v", err)
 		resp.DisplayErrorMsg = plugin.MakeTranslator(i18n.ErrUploadFileFailed)