Function TestRevCacheOnDemandImportNoCache

db/revision_cache_test.go:2229–2256

(t *testing.T)

}

func TestRevCacheOnDemandImportNoCache(t *testing.T) {
	base.SkipImportTestsIfNotEnabled(t)

	db, ctx := setupTestDB(t)
	defer db.Close(ctx)
	collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)

	docID := "doc1"
	revID1, _, err := collection.Put(ctx, docID, Body{"foo": "bar"})
	require.NoError(t, err)

	_, exists := collection.revisionCache.Peek(ctx, docID, revID1)
	require.True(t, exists)

	require.NoError(t, collection.dataStore.Set(docID, 0, nil, []byte(`{"foo": "baz"}`)))

	doc, err := collection.GetDocument(ctx, docID, DocUnmarshalSync)
	require.NoError(t, err)
	require.Equal(t, Body{"foo": "baz"}, doc.Body(ctx))

	// rev1 still exists in cache but not on server
	_, exists = collection.revisionCache.Peek(ctx, docID, revID1)
	require.True(t, exists)

	// rev2 is not in cache but is on server
	_, exists = collection.revisionCache.Peek(ctx, docID, doc.GetRevTreeID())
	require.False(t, exists)
}

func TestFetchBackupWithDeletedFlag(t *testing.T) {
	db, ctx := SetupTestDBWithOptions(t, DatabaseContextOptions{