Function TestBulkGetWithCV

rest/doc_api_test.go:230–318

(t *testing.T)

}

func TestBulkGetWithCV(t *testing.T) {
	rt := NewRestTesterPersistentConfig(t)
	defer rt.Close()

	doc1ID := "doc1"
	doc1Version := rt.PutDoc(doc1ID, `{"foo": "bar"}`)
	doc1Version = rt.UpdateDoc(doc1ID, doc1Version, `{"foo": "bar", "updates": 1}`)
	doc1Version = rt.UpdateDoc(doc1ID, doc1Version, `{"foo": "bar", "updated": 2}`)
	doc1Version = rt.UpdateDoc(doc1ID, doc1Version, `{"foo": "bar", "updated": 3}`)
	doc1RevTreeGen, _ := db.ParseRevID(base.TestCtx(t), doc1Version.RevTreeID)
	doc1Raw := rt.GetRawDoc(doc1ID)
	// build newest to oldest list of revtree digests (required for validating _revisions response)
	var doc1HistoryDigests = make([]string, 0, doc1RevTreeGen)
	for _, v := range slices.Backward(slices.Sorted(maps.Keys(doc1Raw.Xattrs.Sync.History))) {
		_, digest := db.ParseRevID(base.TestCtx(t), v)
		doc1HistoryDigests = append(doc1HistoryDigests, digest)
	}

	doc2ID := "doc2"
	doc2Version := rt.PutDoc(doc2ID, `{"foo": "baz"}`)
	doc2RevTreeGen, doc2RevTreeDigest := db.ParseRevID(base.TestCtx(t), doc2Version.RevTreeID)

	testCases := []struct {
		name     string
		url      string
		showRevs bool
		input    string
		output   []string
	}{
		{
			name:  "get multipart",
			url:   "/{{.keyspace}}/_bulk_get",
			input: fmt.Sprintf(`{"docs":[{"id":"%s"},{"id":"%s"}]}`, doc1ID, doc2ID),
			output: []string{
				fmt.Sprintf(`{"_id":"%s","_rev":"%s","_cv":"%s","foo":"bar","updated":3}`, doc1ID, doc1Version.RevTreeID, doc1Version.CV.String()),
				fmt.Sprintf(`{"_id":"%s","_rev":"%s","_cv":"%s","foo":"baz"}`, doc2ID, doc2Version.RevTreeID, doc2Version.CV.String()),
			},
		},
		{
			name:  "get by rev",
			url:   "/{{.keyspace}}/_bulk_get",
			input: fmt.Sprintf(`{"docs":[{"id":"%s","rev":"%s"},{"id":"%s","rev":"%s"}]}`, doc1ID, doc1Version.RevTreeID, doc2ID, doc2Version.RevTreeID),
			output: []string{
				fmt.Sprintf(`{"_id":"%s","_rev":"%s","_cv":"%s","foo":"bar","updated":3}`, doc1ID, doc1Version.RevTreeID, doc1Version.CV.String()),
				fmt.Sprintf(`{"_id":"%s","_rev":"%s","_cv":"%s","foo":"baz"}`, doc2ID, doc2Version.RevTreeID, doc2Version.CV.String()),
			},
		},
		{
			name:  "get by cv",
			url:   "/{{.keyspace}}/_bulk_get",
			input: fmt.Sprintf(`{"docs":[{"id":"%s","rev":"%s"},{"id":"%s","rev":"%s"}]}`, doc1ID, doc1Version.CV.String(), doc2ID, doc2Version.CV.String()),
			output: []string{
				fmt.Sprintf(`{"_id":"%s","_rev":"%s","_cv":"%s","foo":"bar","updated":3}`, doc1ID, doc1Version.RevTreeID, doc1Version.CV.String()),
				fmt.Sprintf(`{"_id":"%s","_rev":"%s","_cv":"%s","foo":"baz"}`, doc2ID, doc2Version.RevTreeID, doc2Version.CV.String()),
			},
		},
		{
			name:     "get by cv show_revs",