Feat: 支持跨桶复制 && SSL 配置支持跳过 OSS 证书校验

Author: Jack

client.go

@@ -123,6 +123,9 @@ func newOSS(name string, cfg *BucketConfig, logger *elog.Component) (Client, err
 	if cfg.Debug {
 		opts = append(opts, oss.SetLogLevel(oss.Debug))
 	}
+	if !cfg.SSL {
+		opts = append(opts, oss.InsecureSkipVerify(true))
+	}
 	client, err := oss.New(cfg.Endpoint, cfg.AccessKeyID, cfg.AccessKeySecret, opts...)
 	if err != nil {
 		return nil, err

oss.go

@@ -30,6 +30,14 @@ func (ossClient *OSS) keyWithPrefix(key string) string {
 	return ossClient.cfg.Prefix + key
 }
 
+func extractBucketFromRawSrcKey(rawSrcKey string) (bucketName, key string, err error) {
+	parts := strings.SplitN(strings.TrimPrefix(rawSrcKey, "/"), "/", 2)
+	if len(parts) != 2 {
+		return "", "", fmt.Errorf("failed to parse rawSrcKey: %s", rawSrcKey)
+	}
+	return parts[0], parts[1], nil
+}
+
 func (ossClient *OSS) Copy(ctx context.Context, srcKey, dstKey string, options ...CopyOption) error {
 	cfg := DefaultCopyOptions()
 	for _, opt := range options {
@@ -65,10 +73,15 @@ func (ossClient *OSS) Copy(ctx context.Context, srcKey, dstKey string, options .
 	for k, v := range cfg.meta {
 		ossOptions = append(ossOptions, oss.Meta(k, v))
 	}
-	_, err = bucket.CopyObject(srcKeyWithBucket, dstKey, ossOptions...)
+	bucketName, keyName, err := extractBucketFromRawSrcKey(srcKeyWithBucket)
 	if err != nil {
 		return err
 	}
+	_, err = bucket.CopyObjectFrom(bucketName, keyName, dstKey, ossOptions...)
+	if err != nil {
+		return err
+	}
+
 	return nil
 }
 

oss_test.go

@@ -320,10 +320,24 @@ func TestOSS_Copy(t *testing.T) {
 	err = ossCmp.Del(ctx, guidCopyDst)
 	assert.NoError(t, err)
 
-	err = ossCmp.Copy(ctx, guidCopySrc, guidCopyDst, CopyWithRawSrcKey())
+	// 测试 rawSrcKey 模式 （跨 bucket 复制）
+	rawSrcKey := fmt.Sprintf("/%s/%s", os.Getenv("BUCKET"), guidCopySrc)
+	err = ossCmp.Copy(ctx, rawSrcKey, guidCopyDst, CopyWithRawSrcKey())
 	assert.NoError(t, err)
 
 	ok, err := ossCmp.Exists(ctx, guidCopyDst)
 	assert.NoError(t, err)
 	assert.Equal(t, true, ok)
+
+	// 测试同 bucket 模式
+	err = ossCmp.Del(ctx, guidCopyDst)
+	assert.NoError(t, err)
+
+	err = ossCmp.Copy(ctx, guidCopySrc, guidCopyDst)
+	assert.NoError(t, err)
+
+	ok, err = ossCmp.Exists(ctx, guidCopyDst)
+	assert.NoError(t, err)
+	assert.Equal(t, true, ok)
+
 }