Function TestCollectionsChangeConfigScope

rest/api_collections_test.go:604–673

(t *testing.T)

}

func TestCollectionsChangeConfigScope(t *testing.T) {
	if base.UnitTestUrlIsWalrus() {
		t.Skip("can not create new buckets and scopes in walrus")
	}

	base.TestRequiresCollections(t)

	ctx := base.TestCtx(t)
	tb := base.GetTestBucket(t)
	defer tb.Close(ctx)

	scopesAndCollections := map[string][]string{
		"fooScope": {
			"bar",
		},
		"quxScope": {
			"quux",
		},
	}
	err := base.CreateBucketScopesAndCollections(ctx, tb.BucketSpec, scopesAndCollections)
	require.NoError(t, err)
	defer func() {
		collection, err := base.AsCollection(tb.DefaultDataStore())
		require.NoError(t, err)
		cm := collection.Collection.Bucket().Collections()
		for scope := range scopesAndCollections {
			assert.NoError(t, cm.DropScope(scope, nil))
		}

	}()

	rt := NewRestTester(t, &RestTesterConfig{
		PersistentConfig: true,
		CustomTestBucket: tb.NoCloseClone(),
	})
	defer rt.Close()

	// Create a DB configured with one scope
	res := rt.SendAdminRequest(http.MethodPut, "/db/", string(base.MustJSONMarshal(t, map[string]any{
		"bucket":                      tb.GetName(),
		"num_index_replicas":          0,
		"enable_shared_bucket_access": base.TestUseXattrs(),
		"use_views":                   base.TestsDisableGSI(),
		"scopes": ScopesConfig{
			"fooScope": {
				Collections: CollectionsConfig{
					"bar": {},
				},
			},
		},
	})))
	RequireStatus(t, res, http.StatusCreated)

	// Try updating its scopes
	res = rt.SendAdminRequest(http.MethodPut, "/db/_config", string(base.MustJSONMarshal(t, map[string]any{
		"bucket":                      tb.GetName(),
		"num_index_replicas":          0,
		"enable_shared_bucket_access": base.TestUseXattrs(),