Function Test200MultipartUploadWithSpaces

200OKwithError_test.go:32–87

(t *testing.T)

)

func Test200MultipartUploadWithSpaces(t *testing.T) {
	ts := httptest.NewServer(http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
		w.Write([]byte(`<?xml version="1.0" encoding="UTF-8"?>`))
		w.(http.Flusher).Flush()
		for i := 0; i < 10; i++ {
			time.Sleep(time.Second)
			w.Write([]byte(" "))
			w.(http.Flusher).Flush()
		}

		w.Write([]byte(`<CompleteMultipartUploadResult xmlns="http://s3.amazonaws.com/doc/2006-03-01/"><Location>http://random/bucket/object</Location><Bucket>bucket</Bucket><Key>object</Key><ETag>&#34;2b3ffa539769372e2df9553358fe26b2-2&#34;</ETag></CompleteMultipartUploadResult>`))
	}))

	srv, err := url.Parse(ts.URL)
	if err != nil {
		t.Fatal(err)
	}

	// Instantiate new minio client object.
	core, err := NewCore(
		srv.Host,
		&Options{
			Creds:  credentials.NewStaticV4("foo", "foo12345", ""),
			Secure: srv.Scheme == "https",
		})
	if err != nil {
		t.Fatal("Error:", err)
	}

	parts := []CompletePart{
		{PartNumber: 1, ETag: "b386a859d8a22ff986c0b1252be34658"},
		{PartNumber: 2, ETag: "78c577a580bbbba92845789cda1fa932"},
	}

	foundUploadInfo, err := core.CompleteMultipartUpload(context.Background(),
		"bucket",
		"object",
		"jY1M2U5NWMtZGY2OC00ZjYyLTljZGYtYmZlOWEzODM3MDMwLjlmZWY5OGNlLWQ1Y2EtNDgwMC04N2Y4LWZkNTNkMDM4ZDdiMXgxNzQ4NjA0NzI0NzE4NjU3MTY3",
		parts,
		PutObjectOptions{},
	)
	if err != nil {
		t.Fatal("Error:", err)
	}

	expectedUploadInfo := UploadInfo{
		Bucket:   "bucket",
		Key:      "object",
		ETag:     "2b3ffa539769372e2df9553358fe26b2-2",
		Location: "http://random/bucket/object",
	}

	if foundUploadInfo != expectedUploadInfo {
		t.Fatalf("Unexpected upload info, expected: `%v`, found: `%v`", expectedUploadInfo, foundUploadInfo)
	}
}

func Test200MultipartUploadWithError(t *testing.T) {