Function TestCVPopulationOnDocIDChanges

rest/changes_test.go:426–453

(t *testing.T)

}

func TestCVPopulationOnDocIDChanges(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(base.TestCtx(t)))

	changes := rt.WaitForChanges(1, fmt.Sprintf(`/{{.keyspace}}/_changes?version_type=cv&filter=_doc_ids&doc_ids=%s`, DocID), "", 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)
}

// TestChangesVersionType tests the /_changes REST endpoint with different version_type parameters for each possible underlying feed type and HTTP method.
func TestChangesVersionType(t *testing.T) {