Cloudpods/backend/vendor/github.com/ks3sdklib/aws-sdk-go/service/s3/util.go

package s3

import (
	"crypto/md5"
	"encoding/base64"
	"io"
	"net/url"
	"os"
)

// GetBase64MD5Str 计算Base64格式字符串的MD5值
func GetBase64MD5Str(str string) string {
	// 创建一个MD5哈希对象
	hash := md5.New()

	// 将字符串转换为字节数组并计算MD5哈希值
	hash.Write([]byte(str))
	md5Hash := hash.Sum(nil)

	// 将MD5哈希值转换为Base64格式
	base64Str := base64.StdEncoding.EncodeToString(md5Hash)

	return base64Str
}

// GetBase64Str 计算Base64格式字符串
func GetBase64Str(str string) string {
	return base64.StdEncoding.EncodeToString([]byte(str))
}

// GetBase64FileMD5Str 计算Base64格式文件的MD5值
func GetBase64FileMD5Str(filePath string) (string, error) {
	file, err := os.Open(filePath)
	if err != nil {
		return "", err
	}
	defer file.Close()

	hash := md5.New()
	if _, err := io.Copy(hash, file); err != nil {
		return "", err
	}

	md5Hash := hash.Sum(nil)

	// 将MD5哈希值转换为Base64格式
	base64Str := base64.StdEncoding.EncodeToString(md5Hash)

	return base64Str, err
}

// BuildCopySource 构建拷贝源
func BuildCopySource(bucket *string, key *string) string {
	if bucket == nil || key == nil {
		return ""
	}
	return "/" + *bucket + "/" + url.QueryEscape(*key)
}

// GetCannedACL 获取访问控制权限
func GetCannedACL(Grants []*Grant) string {
	allUsersPermissions := map[string]*string{}
	for _, value := range Grants {
		if value.Grantee.URI != nil && *value.Grantee.URI == AllUsersUri {
			allUsersPermissions[*value.Permission] = value.Permission
		}
	}
	_, read := allUsersPermissions["READ"]
	_, write := allUsersPermissions["WRITE"]
	if read && write {
		return ACLPublicReadWrite
	} else if read {
		return ACLPublicRead
	} else {
		return ACLPrivate
	}
}

// FileExists returns whether the given file exists or not
func FileExists(filename string) bool {
	info, err := os.Stat(filename)
	if os.IsNotExist(err) {
		return false
	}
	return !info.IsDir()
}

// DirExists returns whether the given directory exists or not
func DirExists(dir string) bool {
	info, err := os.Stat(dir)
	if os.IsNotExist(err) {
		return false
	}
	return info.IsDir()
}

// Min returns the smaller of two integers
func Min(a, b int64) int64 {
	if a < b {
		return a
	}
	return b
}

// IsV4Signature checks if the signer is V4 or V4_UNSIGNED_PAYLOAD_SIGNER
func IsV4Signature(signer string) bool {
	return signer == "V4" || signer == "V4_UNSIGNED_PAYLOAD_SIGNER"
}