Function TestAddPendingLogs

db/change_cache_test.go:2928–3106

TestAddPendingLogs: - Test age-based eviction of sequences and ranges from pending logs. - Adds to pending logs directly via heap.Push with backdated TimeReceived, triggers eviction with call to _addPendingLogs - tests duplicate handling when popping pending entries - reproduces CBG-4215

(t *testing.T)

//   - tests duplicate handling when popping pending entries
//   - reproduces CBG-4215
func TestAddPendingLogs(t *testing.T) {
	base.SetUpTestLogging(t, base.LevelDebug, base.KeyCache, base.KeyChanges)

	ctx := base.TestCtx(t)
	bucket := base.GetTestBucket(t)
	dbContext, err := NewDatabaseContext(ctx, "db", bucket, false, DatabaseContextOptions{
		Scopes: GetScopesOptions(t, bucket, 1),
	})
	require.NoError(t, err)
	defer dbContext.Close(ctx)

	ctx = dbContext.AddDatabaseLogContext(ctx)
	err = dbContext.StartOnlineProcesses(ctx)
	require.NoError(t, err)

	testCases := []struct {
		incoming             []sequenceRange // test simulates adding these to pending in the order found in the slice
		channelName          string          // non-range values (endSeq=0) will be assigned to this channel for verification of proper caching
		expectedCached       []uint64        // expected cached sequences
		expectedSkipped      []sequenceRange // expected skipped sequence ranges
		expectedNextSequence uint64          // expected cache.nextSequence
	}{
		{
			// single range
			incoming:             []sequenceRange{{2, 4}},
			expectedNextSequence: 5,
			expectedSkipped:      []sequenceRange{{1, 1}},
		},
		{
			// multiple non-overlapping ranges arriving out of sequence order
			incoming:             []sequenceRange{{2, 4}, {9, 10}, {6, 8}, {14, 20}, {11, 13}, {5, 5}},
			expectedNextSequence: 21,
			expectedSkipped:      []sequenceRange{{1, 1}},
		},
		{
			// non overlapping ranges, arrive in sequence order
			incoming:             []sequenceRange{{2, 4}, {5, 8}},
			expectedNextSequence: 9,
			expectedSkipped:      []sequenceRange{{1, 1}},
		},
		{
			// non overlapping ranges, arrive out of sequence order
			incoming:             []sequenceRange{{5, 8}, {2, 4}},
			expectedNextSequence: 9,
			expectedSkipped:      []sequenceRange{{1, 1}},
		},
		{
			// range overlaps single, range arrives first
			incoming:             []sequenceRange{{2, 4}, {3, 0}},
			channelName:          "A",
			expectedNextSequence: 4,
			expectedCached:       []uint64{3},
			expectedSkipped:      []sequenceRange{{1, 1}},
		},
		{
			// single arrives then range overlaps single both sides
			incoming:             []sequenceRange{{3, 3}, {2, 4}},
			expectedNextSequence: 4,