Function TestItemResidentInCacheBackupRevLoaded

db/revision_cache_test.go:2788–2872

(t *testing.T)

}

func TestItemResidentInCacheBackupRevLoaded(t *testing.T) {
	testCases := []struct {
		name     string
		useRevID bool
	}{
		{"FetchByRevID", true},
		{"FetchByCV", false},
	}
	for _, tc := range testCases {
		t.Run(tc.name, func(t *testing.T) {
			db, ctx := SetupTestDBWithOptions(t, DatabaseContextOptions{
				OldRevExpirySeconds: base.DefaultOldRevExpirySeconds,
				RevisionCacheOptions: &RevisionCacheOptions{
					ShardCount:   1,  // turn off sharding for simplicity
					MaxItemCount: 10, // turn off size based eviction
					MaxBytes:     0,  // turn off memory limit
				},
				DeltaSyncOptions: DeltaSyncOptions{
					Enabled:          true,
					RevMaxAgeSeconds: DefaultDeltaSyncRevMaxAge,
				},
			})
			defer db.Close(ctx)
			collection, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)

			docID := SafeDocumentName(t, t.Name())
			var firstRevisionID, firstCV string
			_, doc1, err := collection.Put(ctx, docID, Body{"foo": "bar"})
			require.NoError(t, err)

			firstRevisionID = doc1.GetRevTreeID()
			firstCV = doc1.HLV.GetCurrentVersionString()

			// make revision 2
			_, doc1, err = collection.Put(ctx, docID, Body{BodyRev: firstRevisionID, "foo": "baz"})
			require.NoError(t, err)

			// flush cache, this can be removed pending CBG-4542
			db.FlushRevisionCacheForTest()
			// grab current version of the doc
			if tc.useRevID {
				_, err = collection.getRev(ctx, docID, doc1.GetRevTreeID(), 0, nil)
			} else {
				_, err = collection.getRev(ctx, docID, doc1.HLV.GetCurrentVersionString(), 0, nil)
			}
			require.NoError(t, err)

			// now fetch for backup rev, should load rev and only populate CV map and not revID map when fetching
			// by CV and vice versa for fetch by revID
			if tc.useRevID {
				_, err = collection.getRev(ctx, docID, firstRevisionID, 0, nil)
				require.NoError(t, err)
				assert.Equal(t, int64(2), db.DbStats.Cache().RevisionCacheNumItems.Value())
			} else {
				_, err = collection.getRev(ctx, docID, firstCV, 0, nil)
				require.Error(t, err)
				require.ErrorContains(t, err, "missing")
				assert.Equal(t, int64(1), db.DbStats.Cache().RevisionCacheNumItems.Value())