add complex node test

Author: ndyakov

docker-compose.yml

@@ -46,35 +46,33 @@ services:
     environment:
       - TARGET_HOST=redis
       - TARGET_PORT=6379
-      - LISTEN_PORT=7000,7001,7002  # Multiple proxy nodes for cluster simulation
+      - LISTEN_PORT=17000,17001,17002,17003  # 4 proxy nodes: initially show 3, swap in 4th during SMIGRATED
       - LISTEN_HOST=0.0.0.0
       - API_PORT=3000
       - DEFAULT_INTERCEPTORS=cluster,hitless
     ports:
-      - "7000:7000"  # Proxy node 1 (host:container)
-      - "7001:7001"  # Proxy node 2 (host:container)
-      - "7002:7002"  # Proxy node 3 (host:container)
-      - "8100:3000"  # HTTP API port (host:container)
+      - "17000:17000"  # Proxy node 1 (host:container)
+      - "17001:17001"  # Proxy node 2 (host:container)
+      - "17002:17002"  # Proxy node 3 (host:container)
+      - "17003:17003"  # Proxy node 4 (host:container) - hidden initially, swapped in during SMIGRATED
+      - "18100:3000"  # HTTP API port (host:container)
     depends_on:
       - redis
     profiles:
       - e2e
       - all
 
   proxy-fault-injector:
-    image: golang:1.23-alpine
+    build:
+      context: .
+      dockerfile: maintnotifications/e2e/cmd/proxy-fi-server/Dockerfile
     container_name: proxy-fault-injector
-    working_dir: /app
-    environment:
-      - CGO_ENABLED=0
-    command: >
-      sh -c "go run ./maintnotifications/e2e/cmd/proxy-fi-server/main.go --listen 0.0.0.0:5000 --proxy-api-url http://cae-resp-proxy:3000"
     ports:
-      - "5000:5000"  # Fault injector API port
+      - "15000:5000"  # Fault injector API port (host:container)
     depends_on:
       - cae-resp-proxy
-    volumes:
-      - ".:/app"
+    environment:
+      - PROXY_API_URL=http://cae-resp-proxy:3000
     profiles:
       - e2e
       - all

maintnotifications/e2e/cmd/proxy-fi-server/Dockerfile

@@ -39,5 +39,5 @@ EXPOSE 5000
 
 # Run the server
 ENTRYPOINT ["/app/proxy-fi-server"]
-CMD ["--listen", "0.0.0.0:5000", "--proxy-api-port", "3000"]
+CMD ["--listen", "0.0.0.0:5000", "--proxy-api-url", "http://cae-resp-proxy:3000"]
 

maintnotifications/e2e/cmd/proxy-fi-server/main.go

@@ -12,7 +12,7 @@ import (
 
 func main() {
 	listenAddr := flag.String("listen", "0.0.0.0:5000", "Address to listen on for fault injector API")
-	proxyAPIURL := flag.String("proxy-api-url", "http://localhost:8100", "URL of the cae-resp-proxy API")
+	proxyAPIURL := flag.String("proxy-api-url", "http://localhost:18100", "URL of the cae-resp-proxy API (updated to avoid macOS Control Center conflict)")
 	flag.Parse()
 
 	fmt.Printf("Starting Proxy Fault Injector Server...\n")

maintnotifications/e2e/config_autostart_logic_test.go

@@ -153,7 +153,7 @@ func TestFaultInjectorClientCreation(t *testing.T) {
 		name string
 		url  string
 	}{
-		{"localhost", "http://localhost:5000"},
+		{"localhost", "http://localhost:15000"}, // Updated to avoid macOS Control Center conflict
 		{"with port", "http://test:9999"},
 		{"with trailing slash", "http://test:9999/"},
 	}

maintnotifications/e2e/config_parser_test.go

@@ -561,7 +561,7 @@ func CreateTestFaultInjector() (*FaultInjectorClient, error) {
 //
 // Decision logic based on environment:
 // 1. If REDIS_ENDPOINTS_CONFIG_PATH is set -> use real fault injector from FAULT_INJECTION_API_URL
-// 2. If REDIS_ENDPOINTS_CONFIG_PATH is NOT set -> use Docker fault injector at http://localhost:5000
+// 2. If REDIS_ENDPOINTS_CONFIG_PATH is NOT set -> use Docker fault injector at http://localhost:15000
 //
 // Both the Docker proxy and fault injector should already be running (started via Docker Compose)
 // This function does NOT start any services - it only connects to existing ones
@@ -578,9 +578,9 @@ func CreateTestFaultInjectorWithCleanup() (*FaultInjectorClient, func(), error)
 	// If environment config fails, use Docker fault injector
 	// Note: GetEnvConfig() only fails if REDIS_ENDPOINTS_CONFIG_PATH is not set
 	if err != nil {
-		// Use Docker fault injector at http://localhost:5000
+		// Use Docker fault injector at http://localhost:15000 (updated to avoid macOS Control Center conflict)
 		// The fault injector should already be running via docker-compose
-		faultInjectorURL := "http://localhost:5000"
+		faultInjectorURL := "http://localhost:15000"
 
 		// Check if fault injector is accessible
 		client := &http.Client{Timeout: 2 * time.Second}
@@ -1012,7 +1012,7 @@ func SetupTestDatabaseWithConfig(t *testing.T, ctx context.Context, dbConfig Dat
 // SetupTestDatabaseAndFactory creates a database from environment config and returns both bdbID, factory, test mode config, and cleanup function
 // This is the recommended way to setup tests as it ensures the client factory connects to the newly created database
 //
-// If REDIS_ENDPOINTS_CONFIG_PATH is not set, it will use the Docker proxy setup (localhost:7000) instead of creating a new database.
+// If REDIS_ENDPOINTS_CONFIG_PATH is not set, it will use the Docker proxy setup (127.0.0.1:17000) instead of creating a new database.
 // This allows tests to work with either the real fault injector OR the Docker proxy setup.
 //
 // Usage:
@@ -1024,12 +1024,12 @@ func SetupTestDatabaseAndFactory(t *testing.T, ctx context.Context, databaseName
 	envConfig, err := GetEnvConfig()
 	if err != nil {
 		// No environment config - use Docker proxy setup
-		t.Logf("No environment config found, using Docker proxy setup at localhost:7000")
+		t.Logf("No environment config found, using Docker proxy setup at 127.0.0.1:17000")
 
 		// Create a simple Redis connection config for Docker proxy
 		redisConfig := &RedisConnectionConfig{
-			Host:     "localhost",
-			Port:     7000,
+			Host:     "127.0.0.1", // Use 127.0.0.1 to force IPv4
+			Port:     17000,
 			Username: "",
 			Password: "",
 			TLS:      false,
@@ -1126,7 +1126,7 @@ func SetupTestDatabaseAndFactory(t *testing.T, ctx context.Context, databaseName
 
 // SetupTestDatabaseAndFactoryWithConfig creates a database with custom config and returns both bdbID, factory, test mode config, and cleanup function
 //
-// If REDIS_ENDPOINTS_CONFIG_PATH is not set, it will use the Docker proxy setup (localhost:7000) instead of creating a new database.
+// If REDIS_ENDPOINTS_CONFIG_PATH is not set, it will use the Docker proxy setup (127.0.0.1:17000) instead of creating a new database.
 // This allows tests to work with either the real fault injector OR the Docker proxy setup.
 //
 // Usage:
@@ -1138,12 +1138,12 @@ func SetupTestDatabaseAndFactoryWithConfig(t *testing.T, ctx context.Context, da
 	envConfig, err := GetEnvConfig()
 	if err != nil {
 		// No environment config - use Docker proxy setup
-		t.Logf("No environment config found, using Docker proxy setup at localhost:7000")
+		t.Logf("No environment config found, using Docker proxy setup at 127.0.0.1:17000")
 
 		// Create a simple Redis connection config for Docker proxy
 		redisConfig := &RedisConnectionConfig{
-			Host:     "localhost",
-			Port:     7000,
+			Host:     "127.0.0.1", // Use 127.0.0.1 to force IPv4
+			Port:     17000,
 			Username: "",
 			Password: "",
 			TLS:      false,