Function TestObjectLinks

jetstream/test/object_test.go:731–857

(t *testing.T)

}

func TestObjectLinks(t *testing.T) {
	s := RunBasicJetStreamServer()
	defer shutdownJSServerAndRemoveStorage(t, s)

	nc, js := jsClient(t, s)
	defer nc.Close()
	ctx := context.Background()

	root, err := js.CreateObjectStore(ctx, jetstream.ObjectStoreConfig{Bucket: "ROOT"})
	expectOk(t, err)

	_, err = root.PutString(ctx, "A", "AAA")
	expectOk(t, err)
	_, err = root.PutString(ctx, "B", "BBB")
	expectOk(t, err)

	infoA, err := root.GetInfo(ctx, "A")
	expectOk(t, err)

	// Link to individual object.
	infoLA, err := root.AddLink(ctx, "LA", infoA)
	expectOk(t, err)
	expectLinkIsCorrect(t, infoA, infoLA)

	// link to a link
	_, err = root.AddLink(ctx, "LALA", infoLA)
	expectErr(t, err, jetstream.ErrNoLinkToLink)

	dir, err := js.CreateObjectStore(ctx, jetstream.ObjectStoreConfig{Bucket: "DIR"})
	expectOk(t, err)

	_, err = dir.PutString(ctx, "DIR/A", "DIR-AAA")
	expectOk(t, err)
	_, err = dir.PutString(ctx, "DIR/B", "DIR-BBB")
	expectOk(t, err)

	infoB, err := dir.GetInfo(ctx, "DIR/B")
	expectOk(t, err)

	infoLB, err := root.AddLink(ctx, "DBL", infoB)
	expectOk(t, err)
	expectLinkIsCorrect(t, infoB, infoLB)

	// Now add whole other store as a link, like a directory.
	infoBucketLink, err := root.AddBucketLink(ctx, "dir", dir)
	expectOk(t, err)

	_, err = root.Get(ctx, infoBucketLink.Name)
	expectErr(t, err, jetstream.ErrCantGetBucket)

	expectLinkPartsAreCorrect(t, infoBucketLink, "DIR", "")

	// Try to get a linked object, same bucket
	getLA, err := root.GetString(ctx, "LA")
	expectOk(t, err)

	if getLA != "AAA" {
		t.Fatalf("Expected %q but got %q", "AAA", getLA)