Function TestFetchCurrentRevAfterFetchBackupRevByCV

db/database_test.go:1068–1111

(t *testing.T)

}

func TestFetchCurrentRevAfterFetchBackupRevByCV(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyAll)
	db, ctx := SetupTestDBWithOptions(t, DatabaseContextOptions{
		// enable delta sync other wise CV keyed backup revs won't be stored
		DeltaSyncOptions: DeltaSyncOptions{
			Enabled:          true,
			RevMaxAgeSeconds: DefaultDeltaSyncRevMaxAge,
		},
	})
	defer db.Close(ctx)

	collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)

	// Create the first revision of doc1.
	rev1Body := Body{
		"k1": "v1",
	}
	rev1ID, doc, err := collection.Put(ctx, "doc1", rev1Body)
	require.NoError(t, err, "Error creating doc")

	// create the second revision of doc1.
	rev2Body := Body{
		"k1":    "v2",
		BodyRev: rev1ID,
	}
	rev2ID, doc2, err := collection.Put(ctx, "doc1", rev2Body)
	require.NoError(t, err, "Error creating doc")

	// Flush the revision cache, this can be removed pending CBG-4542
	db.FlushRevisionCacheForTest()

	// fetch backup rev by cv and ensure we have no revID populated (no way to get revID from backup rev in CV)
	docRev, err := collection.revisionCache.GetWithCV(ctx, "doc1", doc.HLV.ExtractCurrentVersionFromHLV(), false, true)
	require.NoError(t, err, "Error fetching backup revision CV")
	assert.Equal(t, "", docRev.RevID)
	assert.Equal(t, `{"k1":"v1"}`, string(docRev.BodyBytes))

	// fetch current revision and ensure we actually get rev2
	docRev, err = collection.GetRev(ctx, "doc1", "", true, nil)
	require.NoError(t, err, "error fetching current revision")
	assert.Equal(t, rev2ID, docRev.RevID)
	assert.Equal(t, `{"k1":"v2"}`, string(docRev.BodyBytes))
	assert.Equal(t, doc2.HLV.GetCurrentVersionString(), docRev.CV.String())
}

func TestFetchCurrentRevAfterFetchBackupRevByRevID(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyAll)