chore: stabilize TestContainerLogWithErrClosed and re-enable it for rootful CI

Author: malikov73

logconsumer_test.go

@@ -219,9 +219,47 @@ func Test_MultipleLogConsumers(t *testing.T) {
 	require.Equal(t, expected, second.Msgs())
 }
 
+// waitLogsQuiet waits until the consumer has received no new log messages for
+// quiet, returning the count observed. It fails the test if the stream is
+// still producing new messages after timeout.
+func waitLogsQuiet(t *testing.T, c *TestLogConsumer, quiet, timeout time.Duration) int {
+	t.Helper()
+
+	count := len(c.Msgs())
+	lastChange := time.Now()
+	deadline := time.Now().Add(timeout)
+	for time.Now().Before(deadline) {
+		if n := len(c.Msgs()); n != count {
+			count = n
+			lastChange = time.Now()
+		} else if time.Since(lastChange) >= quiet {
+			return count
+		}
+		time.Sleep(50 * time.Millisecond)
+	}
+	t.Fatalf("log stream still producing new messages after %v", timeout)
+	return 0
+}
+
+// requireNewMsgs waits until at least want new log messages (beyond existing)
+// have been consumed, lets the stream settle so unexpected extra lines still
+// surface, and then asserts the exact count. It returns the new total count.
+func requireNewMsgs(t *testing.T, c *TestLogConsumer, existing, want int, hint string) int {
+	t.Helper()
+
+	require.Eventuallyf(t, func() bool {
+		return len(c.Msgs())-existing >= want
+	}, time.Minute, 50*time.Millisecond, "%s: expected %d new log message(s)", hint, want)
+
+	count := waitLogsQuiet(t, c, time.Second, 10*time.Second)
+	msgs := c.Msgs()
+	require.Equalf(t, want, count-existing, "%s: expected exactly %d new log message(s), instead has:\n%v", hint, want, msgs[existing:])
+	return count
+}
+
 func TestContainerLogWithErrClosed(t *testing.T) {
-	if os.Getenv("GITHUB_RUN_ID") != "" {
-		t.Skip("Skipping as flaky on GitHub Actions, Please see https://github.com/testcontainers/testcontainers-go/issues/1924")
+	if os.Getenv("XDG_RUNTIME_DIR") != "" {
+		t.Skip("Docker-in-Docker does not work with rootless Docker")
 	}
 
 	t.Cleanup(func() {
@@ -304,9 +342,9 @@ func TestContainerLogWithErrClosed(t *testing.T) {
 	port, err := nginx.MappedPort(ctx, "80/tcp")
 	require.NoError(t, err)
 
-	// Gather the initial container logs
-	time.Sleep(time.Second * 1)
-	existingLogs := len(consumer.Msgs())
+	// Wait for the initial nginx startup logs to drain so the baseline count
+	// is stable before asserting on new messages.
+	existingLogs := waitLogsQuiet(t, &consumer, time.Second, 30*time.Second)
 
 	hitNginx := func() {
 		i, _, err := dind.Exec(ctx, []string{"wget", "--spider", net.JoinHostPort("localhost", port.Port())})
@@ -315,10 +353,7 @@ func TestContainerLogWithErrClosed(t *testing.T) {
 	}
 
 	hitNginx()
-	time.Sleep(time.Second * 1)
-	msgs := consumer.Msgs()
-	require.Equalf(t, 1, len(msgs)-existingLogs, "logConsumer should have 1 new log message, instead has: %v", msgs[existingLogs:])
-	existingLogs = len(consumer.Msgs())
+	existingLogs = requireNewMsgs(t, &consumer, existingLogs, 1, "logConsumer should have 1 new log message")
 
 	iptableArgs := []string{
 		"INPUT", "-p", "tcp", "--dport", "2375",
@@ -331,16 +366,14 @@ func TestContainerLogWithErrClosed(t *testing.T) {
 	i, _, err = dind.Exec(ctx, append([]string{"iptables", "-D"}, iptableArgs...))
 	require.NoErrorf(t, err, "Failed to re-open connection to dind daemon: i(%d), err %v", i, err)
 	require.Zerof(t, i, "Failed to re-open connection to dind daemon: i(%d), err %v", i, err)
+	// Deliberate fixed wait (not an assertion race): give the log producer
+	// time to observe the TCP reset and restart its log stream.
 	time.Sleep(time.Second * 3)
 
 	hitNginx()
 	hitNginx()
-	time.Sleep(time.Second * 1)
-	msgs = consumer.Msgs()
-	require.Equalf(t, 2, len(msgs)-existingLogs,
-		"LogConsumer should have 2 new log messages after detecting closed connection and"+
-			" re-requesting logs. Instead has:\n%s", msgs[existingLogs:],
-	)
+	requireNewMsgs(t, &consumer, existingLogs, 2,
+		"LogConsumer should have 2 new log messages after detecting closed connection and re-requesting logs")
 }
 
 func TestContainerLogsShouldBeWithoutStreamHeader(t *testing.T) {