Function TestChangesFeedCVWithOldRevOnlyData

rest/changes_test.go:628–675

(t *testing.T)

}

func TestChangesFeedCVWithOldRevOnlyData(t *testing.T) {
	rt := NewRestTester(t, nil)
	defer rt.Close()

	seq, err := db.AllocateTestSequence(rt.GetDatabase())
	require.NoError(t, err)
	oldDoc := "oldDoc"
	oldDocBody := `{"body_field":"1234"}`
	oldDocSyncData := []byte(fmt.Sprintf(`{"sequence":%d,"rev":{"rev": "1-abc"},"history":{"revs":["1-abc"],"parents":[-1],"channels":[null]},"value_crc32c":"%s"}`, seq, base.Crc32cHashString([]byte(oldDocBody))))
	_, err = rt.GetSingleDataStore().WriteWithXattrs(t.Context(), oldDoc, 0, 0, []byte(oldDocBody), map[string][]byte{base.SyncXattrName: oldDocSyncData}, nil, nil)
	require.NoError(t, err)

	newDoc := "newDoc"
	newDocBody := `{"foo":"bar"}`
	rt.PutDoc(newDoc, newDocBody)

	rt.WaitForPendingChanges()

	resp := rt.SendAdminRequest(http.MethodGet, "/{{.keyspace}}/_changes?version_type=cv&include_docs=true", "")
	RequireStatus(t, resp, http.StatusOK)
	var changesResults ChangesResults
	require.NoError(t, base.JSONUnmarshal(resp.Body.Bytes(), &changesResults))
	require.Len(t, changesResults.Results, 2)
	for i, changeEntry := range changesResults.Results {
		for _, change := range changeEntry.Changes {
			require.Len(t, change, 1) // ensure only one version type is present
			// and that it was the expected one (and we have a value)
			var expectedType db.ChangesVersionType
			if i == 0 {
				// first doc was written with a RevID and no CV available
				expectedType = db.ChangesVersionTypeRevTreeID
			} else {
				expectedType = db.ChangesVersionTypeCV
			}
			versionValue, ok := change[expectedType]
			require.Truef(t, ok, "Expected version type %s, got %v", expectedType, change)
			require.NotEmpty(t, versionValue)
		}
		var expectedBody string
		switch changeEntry.ID {
		case oldDoc:
			expectedBody = oldDocBody
		case newDoc:
			expectedBody = newDocBody
		}
		require.Contains(t, string(changeEntry.Doc), expectedBody[1:len(expectedBody)-1]) // strip {}s from doc body - 1.x API stamps additional properties so accommodate
	}
}