Test Core CopyObjectPart implementation for unencrypted to SSE-S3 encrypted copy
()
| 11584 | |
| 11585 | // Test Core CopyObjectPart implementation for unencrypted to SSE-S3 encrypted copy |
| 11586 | func testSSES3EncryptedToSSES3CopyObjectPart() { |
| 11587 | // initialize logging params |
| 11588 | startTime := time.Now() |
| 11589 | testName := getFuncName() |
| 11590 | function := "CopyObjectPart(destination, source)" |
| 11591 | args := map[string]interface{}{} |
| 11592 | |
| 11593 | client, err := NewClient(ClientConfig{}) |
| 11594 | if err != nil { |
| 11595 | logError(testName, function, args, startTime, "", "MinIO v4 client object creation failed", err) |
| 11596 | return |
| 11597 | } |
| 11598 | |
| 11599 | // Instantiate new core client object. |
| 11600 | c := minio.Core{Client: client} |
| 11601 | |
| 11602 | // Generate a new random bucket name. |
| 11603 | bucketName := randString(60, rand.NewSource(time.Now().UnixNano()), "minio-go-test") |
| 11604 | |
| 11605 | // Make a new bucket. |
| 11606 | err = c.MakeBucket(context.Background(), bucketName, minio.MakeBucketOptions{Region: "us-east-1"}) |
| 11607 | if err != nil { |
| 11608 | logError(testName, function, args, startTime, "", "MakeBucket failed", err) |
| 11609 | return |
| 11610 | } |
| 11611 | defer cleanupBucket(bucketName, client) |
| 11612 | // Make a buffer with 5MB of data |
| 11613 | buf := bytes.Repeat([]byte("abcde"), 1024*1024) |
| 11614 | |
| 11615 | // Save the data |
| 11616 | objectName := randString(60, rand.NewSource(time.Now().UnixNano()), "") |
| 11617 | srcEncryption := encrypt.NewSSE() |
| 11618 | opts := minio.PutObjectOptions{ |
| 11619 | UserMetadata: map[string]string{ |
| 11620 | "Content-Type": "binary/octet-stream", |
| 11621 | }, |
| 11622 | ServerSideEncryption: srcEncryption, |
| 11623 | } |
| 11624 | |
| 11625 | uploadInfo, err := c.PutObject(context.Background(), bucketName, objectName, bytes.NewReader(buf), int64(len(buf)), "", "", opts) |
| 11626 | if err != nil { |
| 11627 | logError(testName, function, args, startTime, "", "PutObject call failed", err) |
| 11628 | return |
| 11629 | } |
| 11630 | st, err := c.StatObject(context.Background(), bucketName, objectName, minio.StatObjectOptions{ServerSideEncryption: srcEncryption}) |
| 11631 | if err != nil { |
| 11632 | logError(testName, function, args, startTime, "", "StatObject call failed", err) |
| 11633 | return |
| 11634 | } |
| 11635 | if st.Size != int64(len(buf)) { |
| 11636 | logError(testName, function, args, startTime, "", fmt.Sprintf("Error: number of bytes does not match, want %v, got %v\n", len(buf), st.Size), err) |
| 11637 | return |
| 11638 | } |
| 11639 | |
| 11640 | destBucketName := bucketName |
| 11641 | destObjectName := objectName + "-dest" |
| 11642 | dstencryption := encrypt.NewSSE() |
| 11643 |
no test coverage detected