Function SetupTestDatabaseAndFactory

maintnotifications/e2e/config_parser_test.go:1135–1251

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

(t *testing.T, ctx context.Context, databaseName string)

//	bdbID, factory, testMode, cleanup := SetupTestDatabaseAndFactory(t, ctx, "standalone")
//	defer cleanup()
func SetupTestDatabaseAndFactory(t *testing.T, ctx context.Context, databaseName string) (bdbID int, factory *ClientFactory, testMode *TestModeConfig, cleanup func()) {
	// Get environment config
	envConfig, err := GetEnvConfig()
	if err != nil {
		// No environment config - use Docker proxy setup
		t.Logf("No environment config found, using Docker proxy setup at 127.0.0.1:17000")

		// Determine cluster mode based on database name
		// "standalone" creates a non-cluster client for testing FAILING_OVER/FAILED_OVER notifications
		isClusterMode := databaseName != "standalone"

		// Create a simple Redis connection config for Docker proxy
		redisConfig := &RedisConnectionConfig{
			Host:          "127.0.0.1", // Use 127.0.0.1 to force IPv4
			Port:          17000,
			Username:      "",
			Password:      "",
			TLS:           false,
			BdbID:         0,
			IsClusterMode: isClusterMode,
		}

		factory = NewClientFactory(redisConfig)

		// Get proxy mock test mode config
		testMode = GetTestModeConfig()

		// No-op cleanup since we're not creating a database
		cleanup = func() {
			factory.DestroyAll()
		}

		return 0, factory, testMode, cleanup
	}

	// Get database config from environment
	databasesConfig, err := GetDatabaseConfigFromEnv(envConfig.RedisEndpointsConfigPath)
	if err != nil {
		t.Fatalf("Failed to get database config: %v", err)
	}

	// Get the specific database config
	var envDbConfig EnvDatabaseConfig
	var exists bool
	if databaseName == "" {
		// Get first database if no name provided
		for _, config := range databasesConfig {
			envDbConfig = config
			exists = true
			break
		}
	} else {
		envDbConfig, exists = databasesConfig[databaseName]
	}

	if !exists {
		t.Fatalf("Database %s not found in configuration", databaseName)
	}