Function TestMultiCollectionDCP

rest/api_collections_test.go:247–277

(t *testing.T)

}

func TestMultiCollectionDCP(t *testing.T) {
	base.TestRequiresCollections(t)
	base.SkipImportTestsIfNotEnabled(t)

	const numCollections = 2

	rt := NewRestTesterMultipleCollections(t, &RestTesterConfig{
		DatabaseConfig: &DatabaseConfig{DbConfig: DbConfig{AutoImport: true}},
	}, numCollections)
	defer rt.Close()

	colls := rt.GetDbCollections()
	require.Len(t, colls, numCollections)

	for _, c := range colls {
		_, err := c.GetCollectionDatastore().Add(t.Name(), 0, map[string]any{"test": true})
		require.NoError(t, err)
	}

	// ensure the docs are picked up by the import DCP feed and actually gets imported
	err := rt.WaitForCondition(func() bool {
		return rt.GetDatabase().DbStats.SharedBucketImport().ImportCount.Value() == numCollections
	})
	require.NoError(t, err)

	rt.WaitForPendingChanges()

	for _, ks := range rt.GetKeyspaces() {
		rt.WaitForChanges(1, fmt.Sprintf("/%s/_changes", ks), "", true)
	}
}

func TestMultiCollectionChannelAccess(t *testing.T) {
	base.TestRequiresCollections(t)