Function TestPrependChanges

db/channel_cache_single_test.go:246–453

(t *testing.T)

}

func TestPrependChanges(t *testing.T) {

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

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

	// 1. Test prepend to empty cache
	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)

	cache := newSingleChannelCache(collection, channels.NewID("PrependEmptyCache", collection.GetCollectionID()), 0, dbstats.Cache())
	assert.NotNil(t, cache)

	changesToPrepend := LogEntries{
		testLogEntry(10, "doc3", "2-a"),
		testLogEntry(12, "doc2", "2-a"),
		testLogEntry(14, "doc1", "2-a"),
	}

	numPrepended := cache.prependChanges(ctx, changesToPrepend, 5, 14)
	assert.Equal(t, 3, numPrepended)

	// Validate cache
	validFrom, cachedChanges := cache.GetCachedChanges(getChangesOptionsWithCtxOnly(t))
	assert.Equal(t, uint64(5), validFrom)
	require.Len(t, cachedChanges, 3)

	// 2. Test prepend to populated cache, with overlap and duplicates
	stats, err = base.NewSyncGatewayStats()
	require.NoError(t, err)
	dbstats, err = stats.NewDBStats("", false, false, false, nil, nil)
	require.NoError(t, err)
	cache = newSingleChannelCache(collection, channels.NewID("PrependPopulatedCache", collection.GetCollectionID()), 0, dbstats.Cache())
	cache.validFrom = 13
	cache.addToCache(ctx, testLogEntry(14, "doc1", "2-a"), false)
	cache.addToCache(ctx, testLogEntry(20, "doc2", "3-a"), false)

	// Prepend
	changesToPrepend = LogEntries{
		testLogEntry(10, "doc3", "2-a"),
		testLogEntry(11, "doc5", "2-a"),
		testLogEntry(12, "doc2", "2-a"),
		testLogEntry(14, "doc1", "2-a"),
	}

	numPrepended = cache.prependChanges(ctx, changesToPrepend, 5, 14)
	assert.Equal(t, 2, numPrepended)

	// Validate cache
	validFrom, cachedChanges = cache.GetCachedChanges(getChangesOptionsWithCtxOnly(t))
	assert.Equal(t, uint64(5), validFrom)
	require.Len(t, cachedChanges, 4)