bucket_test.go

func (s *BucketSuite) TestObject() {
	key := "test-object"
	ct := "application/json"
	cl := int64(len(s.testdata))

	content, err := ioutils.NewFileReadSeeker(bytes.NewReader(s.testdata))
	if !s.NoError(err) {
		return
	}
	defer content.Close()

	// 1. Put new object
	{
		_, err := s.bucket.PutObject(
			key,
			content,
			option.ContentType(ct),
			option.ContentLength(cl),
			option.ACLPrivate(),
		)

		if !s.NoError(err) {
			return
		}
	}

	// 2. Get the object and assert its metadata and content
	{
		object, err := s.bucket.GetObject(key)
		if !s.NoError(err) {
			return
		}

		body, err := ioutil.ReadAll(object.Body)
		if !s.NoError(err) {
			return
		}
		defer object.Body.Close()

		s.Equal(ct, *object.ContentType)
		s.Equal(cl, *object.ContentLength)
		s.Equal(s.testdata, body)
	}

	// 3. The object must exist
	{
		exists, err := s.bucket.ExistsObject(key)
		s.NoError(err)
		s.True(exists)
	}

	// 4. Delete the object
	{
		_, err := s.bucket.DeleteObject(key)
		if !s.NoError(err) {
			return
		}
	}

	// 5. Head the object
	{
		_, err := s.bucket.HeadObject(key)
		s.Error(err)
	}

	// 6. The object must not exist
	{
		exists, err := s.bucket.ExistsObject(key)
		s.NoError(err)
		s.False(exists)
	}
}