test: improve test reliability for Redis and cache operations

- Add waiting for both log message and listening port to improve Redis container startup reliability
- Force use of IPv4 loopback address to prevent IPv6 connection issues in tests
- Insert short delays after cache invalidation steps to ensure propagation during tests

Signed-off-by: Bo-Yi Wu <appleboy.tw@gmail.com>

Author: appleboy

pkg/store/redis_test.go

@@ -20,7 +20,10 @@ func setupRedisContainer(ctx context.Context) (string, error) {
 	req := testcontainers.ContainerRequest{
 		Image:        "redis:7-alpine",
 		ExposedPorts: []string{"6379/tcp"},
-		WaitingFor:   wait.ForLog("Ready to accept connections").WithStartupTimeout(30 * time.Second),
+		WaitingFor: wait.ForAll(
+			wait.ForLog("Ready to accept connections").WithStartupTimeout(30 * time.Second),
+			wait.ForListeningPort("6379/tcp").WithStartupTimeout(30 * time.Second),
+		),
 	}
 
 	container, err := testcontainers.GenericContainer(ctx, testcontainers.GenericContainerRequest{
@@ -45,6 +48,11 @@ func setupRedisContainer(ctx context.Context) (string, error) {
 		return "", fmt.Errorf("failed to get container port: %w", err)
 	}
 
+	// Force IPv4 127.0.0.1 instead of localhost to avoid IPv6 issues
+	if host == "localhost" {
+		host = "127.0.0.1"
+	}
+
 	return fmt.Sprintf("%s:%s", host, port.Port()), nil
 }
 
@@ -659,6 +667,9 @@ func TestRedisStore_ClientLifecycle(t *testing.T) {
 		t.Fatalf("UpdateClient() failed: %v", err)
 	}
 
+	// Small delay to allow cache invalidation to propagate
+	time.Sleep(100 * time.Millisecond)
+
 	// Verify update
 	updated, err := store.GetClient(ctx, client.ID)
 	if err != nil {
@@ -673,6 +684,9 @@ func TestRedisStore_ClientLifecycle(t *testing.T) {
 		t.Fatalf("DeleteClient() failed: %v", err)
 	}
 
+	// Small delay to allow cache invalidation to propagate
+	time.Sleep(100 * time.Millisecond)
+
 	// Verify deletion
 	_, err = store.GetClient(ctx, client.ID)
 	if err != ErrClientNotFound {
@@ -720,6 +734,9 @@ func TestRedisStore_AuthorizationCodeLifecycle(t *testing.T) {
 		t.Fatalf("DeleteAuthorizationCode() failed: %v", err)
 	}
 
+	// Small delay to allow cache invalidation to propagate
+	time.Sleep(100 * time.Millisecond)
+
 	// Verify deletion
 	_, err = store.GetAuthorizationCode(ctx, code.ClientID)
 	if err != ErrCodeNotFound {