object_test.go

package bfs_test

import (
	"context"
	"io"

	"github.com/bsm/bfs"
	. "github.com/bsm/ginkgo/v2"
	. "github.com/bsm/gomega"
)

var _ = Describe("Object", func() {
	var subject *bfs.Object
	var ctx = context.Background()

	BeforeEach(func() {
		var err error
		subject, err = bfs.NewObject(ctx, "mem:///path/to/file.txt")
		Expect(err).NotTo(HaveOccurred())
	})

	It("should have a name", func() {
		Expect(subject.Name()).To(Equal("path/to/file.txt"))
	})

	It("should head/read/write", func() {
		_, err := subject.Head(ctx)
		Expect(err).To(Equal(bfs.ErrNotFound))

		_, err = subject.Open(ctx)
		Expect(err).To(Equal(bfs.ErrNotFound))

		w, err := subject.Create(ctx, nil)
		Expect(err).ToNot(HaveOccurred())
		defer w.Discard()

		Expect(w.Write([]byte("TESTDATA"))).To(Equal(8))
		Expect(w.Commit()).To(Succeed())

		i, err := subject.Head(ctx)
		Expect(err).ToNot(HaveOccurred())
		Expect(i.Size).To(Equal(int64(8)))
		Expect(i.Name).To(Equal("path/to/file.txt"))

		r, err := subject.Open(ctx)
		Expect(err).ToNot(HaveOccurred())
		Expect(io.ReadAll(r)).To(Equal([]byte("TESTDATA")))
		Expect(r.Close()).To(Succeed())

		Expect(subject.Remove(ctx)).To(Succeed())
		_, err = subject.Head(ctx)
		Expect(err).To(Equal(bfs.ErrNotFound))
	})
})