fixed bdbid parsing

Author: htemelski-oss

maintnotifications/e2e/config_parser_test.go

@@ -30,7 +30,7 @@ type DatabaseEndpoint struct {
 
 // DatabaseConfig represents the configuration for a single database
 type DatabaseConfig struct {
-	BdbID                int                `json:"bdb_id,omitempty"`
+	BdbID                interface{}        `json:"bdb_id,omitempty"`
 	Username             string             `json:"username,omitempty"`
 	Password             string             `json:"password,omitempty"`
 	TLS                  bool               `json:"tls"`
@@ -157,13 +157,23 @@ func GetDatabaseConfig(databasesConfig DatabasesConfig, databaseName string) (*R
 		return nil, fmt.Errorf("no endpoints found in database configuration")
 	}
 
+	var bdbId int
+	switch (dbConfig.BdbID).(type) {
+	case int:
+		bdbId = dbConfig.BdbID.(int)
+	case float64:
+		bdbId = int(dbConfig.BdbID.(float64))
+	case string:
+		bdbId, _ = strconv.Atoi(dbConfig.BdbID.(string))
+	}
+
 	return &RedisConnectionConfig{
 		Host:                 host,
 		Port:                 port,
 		Username:             dbConfig.Username,
 		Password:             dbConfig.Password,
 		TLS:                  dbConfig.TLS,
-		BdbID:                dbConfig.BdbID,
+		BdbID:                bdbId,
 		CertificatesLocation: dbConfig.CertificatesLocation,
 		Endpoints:            dbConfig.Endpoints,
 	}, nil

maintnotifications/e2e/scenario_endpoint_types_test.go

@@ -61,7 +61,7 @@ func TestEndpointTypesPushNotifications(t *testing.T) {
 	}()
 
 	// Create client factory from configuration
-	factory, err := CreateTestClientFactory("m-standalone")
+	factory, err := CreateTestClientFactory("m-standard")
 	if err != nil {
 		t.Skipf("Enterprise cluster not available, skipping endpoint types test: %v", err)
 	}

maintnotifications/e2e/scenario_push_notifications_test.go

@@ -59,7 +59,7 @@ func TestPushNotifications(t *testing.T) {
 	}()
 
 	// Create client factory from configuration
-	factory, err := CreateTestClientFactory("m-standalone")
+	factory, err := CreateTestClientFactory("m-standard")
 	if err != nil {
 		t.Skipf("Enterprise cluster not available, skipping push notification tests: %v", err)
 	}

maintnotifications/e2e/scenario_stress_test.go

@@ -49,7 +49,7 @@ func TestStressPushNotifications(t *testing.T) {
 	}()
 
 	// Create client factory from configuration
-	factory, err := CreateTestClientFactory("m-standalone")
+	factory, err := CreateTestClientFactory("m-standard")
 	if err != nil {
 		t.Skipf("Enterprise cluster not available, skipping stress test: %v", err)
 	}

maintnotifications/e2e/scenario_timeout_configs_test.go

@@ -77,7 +77,7 @@ func TestTimeoutConfigurationsPushNotifications(t *testing.T) {
 	}()
 
 	// Create client factory from configuration
-	factory, err := CreateTestClientFactory("m-standalone")
+	factory, err := CreateTestClientFactory("m-standard")
 	if err != nil {
 		t.Skipf("Enterprise cluster not available, skipping timeout configs test: %v", err)
 	}

maintnotifications/e2e/scenario_tls_configs_test.go

@@ -74,7 +74,7 @@ func TestTLSConfigurationsPushNotifications(t *testing.T) {
 	}()
 
 	// Create client factory from configuration
-	factory, err := CreateTestClientFactory("m-standalone")
+	factory, err := CreateTestClientFactory("m-standard")
 	if err != nil {
 		t.Skipf("Enterprise cluster not available, skipping TLS configs test: %v", err)
 	}