Function TestBucket

pkg/fetch/bucket_test.go:27–57

(t *testing.T)

)

func TestBucket(t *testing.T) {
	a := assertions.New(t)
	ctx := test.Context()

	conf := config.BlobConfig{Provider: "local"}
	conf.Local.Directory = t.TempDir()

	filename := "file"
	content := []byte("Hello world")

	bucket, err := conf.Bucket(ctx, "bucket", test.HTTPClientProvider)
	a.So(err, should.BeNil)

	err = bucket.WriteAll(ctx, filename, content, nil)
	a.So(err, should.BeNil)

	fetcher := FromBucket(ctx, bucket, "")

	// Reading working file
	{
		fileContent, err := fetcher.File(filename)
		a.So(err, should.BeNil)
		a.So(string(fileContent), should.Equal, string(content))
	}

	// Reading non-working file
	{
		_, err = fetcher.File("non-existing file")
		a.So(err, should.NotBeNil)
	}
}