Function TestChannelCacheSize

db/change_cache_test.go:1159–1197

Test size config

(t *testing.T)

// Test size config
func TestChannelCacheSize(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyCache)

	options := DefaultCacheOptions()
	options.ChannelCacheOptions.ChannelCacheMinLength = 600
	options.ChannelCacheOptions.ChannelCacheMaxLength = 600

	log.Printf("Options in test:%+v", options)
	db, ctx := setupTestDBWithCacheOptions(t, options)
	defer db.Close(ctx)

	// Create a user with access to channel ABC
	authenticator := db.Authenticator(ctx)
	user, err := authenticator.NewUser("naomi", "letmein", channels.BaseSetOf(t, "ABC"))
	require.NoError(t, err)
	require.NoError(t, authenticator.Save(user))

	collection := GetSingleDatabaseCollection(t, db.DatabaseContext)
	// Write 750 docs to channel ABC
	for i := 1; i <= 750; i++ {
		WriteDirect(t, collection, []string{"ABC"}, uint64(i))
	}

	// Validate that retrieval returns expected sequences
	require.NoError(t, db.changeCache.waitForSequence(ctx, 750, base.DefaultWaitForSequence))
	collectionWithUser, ctx := GetSingleDatabaseCollectionWithUser(ctx, t, db)
	collectionWithUser.user, err = authenticator.GetUser("naomi")
	require.NoError(t, err)
	changes := getChanges(t, collectionWithUser, base.SetOf("ABC"), getChangesOptionsWithZeroSeq(t))
	assert.Len(t, changes, 750)

	// Validate that cache stores the expected number of values
	collectionID := collection.GetCollectionID()

	abcCache, err := db.changeCache.getChannelCache().getSingleChannelCache(ctx, channels.NewID("ABC", collectionID))
	require.NoError(t, err)

	assert.Len(t, abcCache.(*singleChannelCacheImpl).logs, 600)
}

func shortWaitCache() CacheOptions {