Function TestCVPopulationOnChangesViaAPI

rest/changes_test.go:397–424

(t *testing.T)

}

func TestCVPopulationOnChangesViaAPI(t *testing.T) {
	rtConfig := RestTesterConfig{
		SyncFn: `function(doc) {channel(doc.channels)}`,
	}
	rt := NewRestTester(t, &rtConfig)
	defer rt.Close()
	collection, ctx := rt.GetSingleTestDatabaseCollection()
	bucketUUID := rt.GetDatabase().EncodedSourceID
	const DocID = "doc1"

	// activate channel cache
	_ = rt.WaitForChanges(0, "/{{.keyspace}}/_changes", "", true)

	resp := rt.SendAdminRequest(http.MethodPut, "/{{.keyspace}}/"+DocID, `{"channels": ["ABC"]}`)
	RequireStatus(t, resp, http.StatusCreated)

	require.NoError(t, collection.WaitForPendingChanges(t.Context()))

	changes := rt.WaitForChanges(1, "/{{.keyspace}}/_changes?version_type=cv", "", true)

	fetchedDoc, _, err := collection.GetDocWithXattrs(ctx, DocID, db.DocUnmarshalCAS)
	require.NoError(t, err)

	entryCV := db.GetChangeEntryCV(t, &changes.Results[0])
	assert.Equal(t, "doc1", changes.Results[0].ID)
	assert.Equal(t, bucketUUID, entryCV.SourceID)
	assert.Equal(t, fetchedDoc.Cas, entryCV.Value)
}

func TestCVPopulationOnDocIDChanges(t *testing.T) {
	rtConfig := RestTesterConfig{