Function TestChannelCacheRemove

db/channel_cache_single_test.go:455–501

(t *testing.T)

}

func TestChannelCacheRemove(t *testing.T) {

	base.SetUpTestLogging(t, base.LevelInfo, base.KeyCache)

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

	stats, err := base.NewSyncGatewayStats()
	require.NoError(t, err)

	dbstats, err := stats.NewDBStats("", false, false, false, nil, nil)
	require.NoError(t, err)

	collection := GetSingleDatabaseCollection(t, db.DatabaseContext)
	collectionID := collection.GetCollectionID()

	cache := newSingleChannelCache(collection, channels.NewID("Test1", collectionID), 0, dbstats.Cache())

	// Add some entries to cache
	cache.addToCache(ctx, testLogEntry(1, "doc1", "1-a"), false)
	cache.addToCache(ctx, testLogEntry(2, "doc3", "3-a"), false)
	cache.addToCache(ctx, testLogEntry(3, "doc5", "5-a"), false)

	entries, err := cache.GetChanges(ctx, getChangesOptionsWithZeroSeq(t))
	require.Len(t, entries, 3)
	assert.True(t, verifyChannelSequences(entries, []uint64{1, 2, 3}))
	assert.True(t, verifyChannelDocIDs(entries, []string{"doc1", "doc3", "doc5"}))
	assert.True(t, err == nil)

	// Now remove doc1
	cache.Remove(ctx, collectionID, []string{"doc1"}, time.Now())
	entries, err = cache.GetChanges(ctx, getChangesOptionsWithZeroSeq(t))
	require.Len(t, entries, 2)
	assert.True(t, verifyChannelSequences(entries, []uint64{2, 3}))
	assert.True(t, verifyChannelDocIDs(entries, []string{"doc3", "doc5"}))
	assert.True(t, err == nil)

	// Try to remove doc5 with a startTime before it was added to ensure it's not removed
	// This will print a debug level log:
	// [DBG] Cache+: Skipping removal of doc "doc5" from cache "Test1" - received after purge
	cache.Remove(ctx, collectionID, []string{"doc5"}, time.Now().Add(-time.Second*5))
	entries, err = cache.GetChanges(ctx, getChangesOptionsWithZeroSeq(t))
	require.Len(t, entries, 2)
	assert.True(t, verifyChannelSequences(entries, []uint64{2, 3}))
	assert.True(t, verifyChannelDocIDs(entries, []string{"doc3", "doc5"}))
	assert.True(t, err == nil)
}

func TestChannelCacheStats(t *testing.T) {