Test Core CopyObjectPart implementation for unencrypted to unencrypted copy
()
| 10940 | |
| 10941 | // Test Core CopyObjectPart implementation for unencrypted to unencrypted copy |
| 10942 | func testUnencryptedToUnencryptedCopyPart() { |
| 10943 | // initialize logging params |
| 10944 | startTime := time.Now() |
| 10945 | testName := getFuncName() |
| 10946 | function := "CopyObjectPart(destination, source)" |
| 10947 | args := map[string]interface{}{} |
| 10948 | |
| 10949 | client, err := NewClient(ClientConfig{}) |
| 10950 | if err != nil { |
| 10951 | logError(testName, function, args, startTime, "", "MinIO v4 client object creation failed", err) |
| 10952 | return |
| 10953 | } |
| 10954 | |
| 10955 | // Instantiate new core client object. |
| 10956 | c := minio.Core{Client: client} |
| 10957 | |
| 10958 | // Generate a new random bucket name. |
| 10959 | bucketName := randString(60, rand.NewSource(time.Now().UnixNano()), "minio-go-test") |
| 10960 | |
| 10961 | // Make a new bucket. |
| 10962 | err = c.MakeBucket(context.Background(), bucketName, minio.MakeBucketOptions{Region: "us-east-1"}) |
| 10963 | if err != nil { |
| 10964 | logError(testName, function, args, startTime, "", "MakeBucket failed", err) |
| 10965 | return |
| 10966 | } |
| 10967 | defer cleanupBucket(bucketName, client) |
| 10968 | // Make a buffer with 5MB of data |
| 10969 | buf := bytes.Repeat([]byte("abcde"), 1024*1024) |
| 10970 | |
| 10971 | // Save the data |
| 10972 | objectName := randString(60, rand.NewSource(time.Now().UnixNano()), "") |
| 10973 | putmetadata := map[string]string{ |
| 10974 | "Content-Type": "binary/octet-stream", |
| 10975 | } |
| 10976 | opts := minio.PutObjectOptions{ |
| 10977 | UserMetadata: putmetadata, |
| 10978 | } |
| 10979 | uploadInfo, err := c.PutObject(context.Background(), bucketName, objectName, bytes.NewReader(buf), int64(len(buf)), "", "", opts) |
| 10980 | if err != nil { |
| 10981 | logError(testName, function, args, startTime, "", "PutObject call failed", err) |
| 10982 | return |
| 10983 | } |
| 10984 | st, err := c.StatObject(context.Background(), bucketName, objectName, minio.StatObjectOptions{}) |
| 10985 | if err != nil { |
| 10986 | logError(testName, function, args, startTime, "", "StatObject call failed", err) |
| 10987 | return |
| 10988 | } |
| 10989 | |
| 10990 | if st.Size != int64(len(buf)) { |
| 10991 | logError(testName, function, args, startTime, "", fmt.Sprintf("Error: number of bytes does not match, want %v, got %v\n", len(buf), st.Size), err) |
| 10992 | return |
| 10993 | } |
| 10994 | |
| 10995 | destBucketName := bucketName |
| 10996 | destObjectName := objectName + "-dest" |
| 10997 | |
| 10998 | uploadID, err := c.NewMultipartUpload(context.Background(), destBucketName, destObjectName, minio.PutObjectOptions{}) |
| 10999 | if err != nil { |
no test coverage detected