Remove shouldFilter

Author: prestonvasquez

internal/integration/unified/client_entity.go

@@ -84,24 +84,6 @@ func (es *eventSequencer) recordPooledEvent() {
 	es.mu.Unlock()
 }
 
-// shouldFilter returns true if the event at the given index should be filtered.
-func (es *eventSequencer) shouldFilter(eventType monitoringEventType, index int) bool {
-	cutoff := es.cutoff.Load()
-	if cutoff == 0 {
-		return false
-	}
-
-	es.mu.RLock()
-	defer es.mu.RUnlock()
-
-	seqs, ok := es.seqByEventType[eventType]
-	if !ok || index < 0 || index >= len(seqs) {
-		return false
-	}
-
-	return seqs[index] <= cutoff
-}
-
 // clientEntity is a wrapper for a mongo.Client object that also holds additional information required during test
 // execution.
 type clientEntity struct {

internal/integration/unified/client_entity_test.go

@@ -7,7 +7,6 @@
 package unified
 
 import (
-	"sync/atomic"
 	"testing"
 
 	"go.mongodb.org/mongo-driver/v2/event"
@@ -170,65 +169,3 @@ func Test_eventSequencer_setCutoff(t *testing.T) {
 	assert.Equal(t, int64(3), client.eventSequencer.counter.Load(), "counter should be 3")
 	assert.Equal(t, int64(2), client.eventSequencer.cutoff.Load(), "cutoff should still be 2")
 }
-
-func Test_eventSequencer_shouldFilter(t *testing.T) {
-	es := &eventSequencer{
-		seqByEventType: map[monitoringEventType][]int64{
-			serverDescriptionChangedEvent: {1, 2, 3, 4, 5},
-		},
-	}
-	es.counter = atomic.Int64{}
-	es.counter.Store(5)
-
-	tests := []struct {
-		name      string
-		cutoff    int64
-		eventType monitoringEventType
-		index     int
-		expected  bool
-	}{
-		{
-			name:      "no cutoff",
-			cutoff:    0,
-			eventType: serverDescriptionChangedEvent,
-			index:     0,
-			expected:  false,
-		},
-		{
-			name:      "before cutoff",
-			cutoff:    3,
-			eventType: serverDescriptionChangedEvent,
-			index:     0,
-			expected:  true, // seq=1 <= 3
-		},
-		{
-			name:      "at cutoff",
-			cutoff:    3,
-			eventType: serverDescriptionChangedEvent,
-			index:     2,
-			expected:  true, // seq=3 <= 3
-		},
-		{
-			name:      "after cutoff",
-			cutoff:    3,
-			eventType: serverDescriptionChangedEvent,
-			index:     3,
-			expected:  false, // seq=4 > 3
-		},
-		{
-			name:      "last event",
-			cutoff:    3,
-			eventType: serverDescriptionChangedEvent,
-			index:     4,
-			expected:  false, // seq=5 > 3
-		},
-	}
-
-	for _, tt := range tests {
-		t.Run(tt.name, func(t *testing.T) {
-			es.cutoff.Store(tt.cutoff)
-			result := es.shouldFilter(tt.eventType, tt.index)
-			assert.Equal(t, tt.expected, result, "shouldFilter result mismatch")
-		})
-	}
-}