fix: use deterministic fake clock in TestShadowPubSub_DuplicateSecondaryBuffered

Copilot · bootjp · Copilot · commit 693b3075cb8b · 2026-03-20T08:16:07.000Z
Co-authored-by: bootjp &lt;1306365+bootjp@users.noreply.github.com&gt;
diff --git a/proxy/shadow_pubsub_test.go b/proxy/shadow_pubsub_test.go
@@ -168,7 +168,8 @@ func TestShadowPubSub_CompareLoopExitsOnChannelClose(t *testing.T) {
 }
 
 func TestShadowPubSub_DuplicateSecondaryBuffered(t *testing.T) {
-	sp := newTestShadowPubSub(10 * time.Millisecond)
+	clock := newTestClock()
+	sp := newTestShadowPubSubWithClock(1*time.Second, clock.Now)
 
 	// Two identical secondary messages arrive before any primary.
 	sp.matchSecondary(&redis.Message{Channel: "ch1", Payload: "dup"})

Original file line number	Diff line number	Diff line change
`@@ -168,7 +168,8 @@ func TestShadowPubSub_CompareLoopExitsOnChannelClose(t *testing.T) {`
`168`	`168`	`}`
`169`	`169`
`170`	`170`	`func TestShadowPubSub_DuplicateSecondaryBuffered(t *testing.T) {`
`171`		`- sp := newTestShadowPubSub(10 * time.Millisecond)`
	`171`	`+ clock := newTestClock()`
	`172`	`+ sp := newTestShadowPubSubWithClock(1*time.Second, clock.Now)`
`172`	`173`
`173`	`174`	`// Two identical secondary messages arrive before any primary.`
`174`	`175`	`sp.matchSecondary(&redis.Message{Channel: "ch1", Payload: "dup"})`