test(core): drain capture commands before the layer change

commit: 0b0d373afa0cf6761cc377b14c27e7eee53317ab
author: brice · 2d ago · 2026-10-21 07:42 UTC
parent: 0e8d58d
signature: GPG VerifiedCD88F9E564E0102646FB6077A1A07C7C7C3E349D · arch-gpg Verified for the committer email
checks: 1/1

1 file · +12 -6

M internal/core/capture_test.go +12 -6


@@ -68,6 +68,16 @@ func (r *captureRig) layer(id ports.WindowID, layer ports.Layer, keyboard uint32
68	68		return ports.LayerSurface{ID: id, Layer: layer, Anchor: ports.AnchorTop \| ports.AnchorLeft, Width: 10, Height: 10, Output: "OUT-1", Keyboard: keyboard}
69	69		}
70	70
	71	+	// drainCommands drops the commands already queued. Call it only once the
	72	+	// core is quiet (after receiving a scene, which is published after its
	73	+	// commands) and before sending the event under test: draining after the
	74	+	// send races with the core emitting the commands the test waits for.
	75	+	func (r *captureRig) drainCommands() {
	76	+	for len(r.commands) > 0 {
	77	+	<-r.commands
	78	+	}
	79	+	}
	80	+
71	81		// excludedScene waits for a scene whose exclusion list has n entries.
72	82		func (r captureRig) excludedScene(t testing.T, n int) ports.Scene {
73	83		t.Helper()

@@ -372,10 +382,8 @@ func TestCaptureExclusionKeyboardClamp(t *testing.T) {
372	382		r.client <- ports.CaptureExclusionBegin{Session: 1}
373	383		r.client <- ports.CaptureExclusionLayer{Session: 1, Layer: 10, Attached: true}
374	384		r.excludedScene(t, 1)
	385	+	r.drainCommands()
375	386		r.client <- ports.LayerChanged{Layers: []ports.LayerSurface{r.layer(10, ports.LayerOverlay, 1), r.layer(11, ports.LayerOverlay, 1)}}
376		-	for len(r.commands) > 0 {
377		-	<-r.commands
378		-	}
379	387		scene(t, r.scenes)
380	388		for {
381	389		if f, ok := receive(t, r.commands).(ports.FocusWindow); ok {

@@ -396,9 +404,7 @@ func TestCaptureExclusionKeyboardNone(t *testing.T) {
396	404		r.client <- ports.CaptureExclusionBegin{Session: 1}
397	405		r.client <- ports.CaptureExclusionLayer{Session: 1, Layer: 10, Attached: true}
398	406		r.excludedScene(t, 1)
399		-	for len(r.commands) > 0 {
400		-	<-r.commands
401		-	}
	407	+	r.drainCommands()
402	408		r.client <- ports.WindowMapped{ID: 1}
403	409		scene(t, r.scenes)
404	410		for len(r.commands) > 0 {

 	return ports.LayerSurface{ID: id, Layer: layer, Anchor: ports.AnchorTop | ports.AnchorLeft, Width: 10, Height: 10, Output: "OUT-1", Keyboard: keyboard}
 }
+// drainCommands drops the commands already queued. Call it only once the
+// core is quiet (after receiving a scene, which is published after its
+// commands) and before sending the event under test: draining after the
+// send races with the core emitting the commands the test waits for.
+func (r *captureRig) drainCommands() {
+	for len(r.commands) > 0 {
+		<-r.commands
+	}
+}
 // excludedScene waits for a scene whose exclusion list has n entries.
 func (r *captureRig) excludedScene(t *testing.T, n int) ports.Scene {
 	t.Helper()
 	r.client <- ports.CaptureExclusionBegin{Session: 1}
 	r.client <- ports.CaptureExclusionLayer{Session: 1, Layer: 10, Attached: true}
 	r.excludedScene(t, 1)
+	r.drainCommands()
 	r.client <- ports.LayerChanged{Layers: []ports.LayerSurface{r.layer(10, ports.LayerOverlay, 1), r.layer(11, ports.LayerOverlay, 1)}}
-	for len(r.commands) > 0 {
-		<-r.commands
-	}
 	scene(t, r.scenes)
 	for {
 		if f, ok := receive(t, r.commands).(ports.FocusWindow); ok {
 	r.client <- ports.CaptureExclusionBegin{Session: 1}
 	r.client <- ports.CaptureExclusionLayer{Session: 1, Layer: 10, Attached: true}
 	r.excludedScene(t, 1)
-	for len(r.commands) > 0 {
+	r.drainCommands()
-		<-r.commands
-	}
 	r.client <- ports.WindowMapped{ID: 1}
 	scene(t, r.scenes)
 	for len(r.commands) > 0 {