more time for migrating

Author: ndyakov

maintnotifications/e2e/scenario_endpoint_types_test.go

@@ -232,7 +232,7 @@ func TestEndpointTypesPushNotifications(t *testing.T) {
 			// Wait for MIGRATING notification
 			match, found = logCollector.WaitForLogMatchFunc(func(s string) bool {
 				return strings.Contains(s, logs2.ProcessingNotificationMessage) && strings.Contains(s, "MIGRATING")
-			}, 30*time.Second)
+			}, 60*time.Second)
 			if !found {
 				ef("MIGRATING notification was not received for %s endpoint type", endpointTest.name)
 			}

maintnotifications/e2e/scenario_push_notifications_test.go

@@ -207,12 +207,12 @@ func TestPushNotifications(t *testing.T) {
 	go func() {
 		match, found = logCollector.WaitForLogMatchFunc(func(s string) bool {
 			return strings.Contains(s, logs2.ProcessingNotificationMessage) && strings.Contains(s, "MIGRATING")
-		}, 20*time.Second)
+		}, 60*time.Second)
 		commandsRunner.Stop()
 	}()
 	commandsRunner.FireCommandsUntilStop(ctx)
 	if !found {
-		ef("MIGRATING notification for migrate action was not received within 20 seconds")
+		ef("MIGRATING notification for migrate action was not received within 60 seconds")
 	}
 	migrateData := logs2.ExtractDataFromLogMessage(match)
 	seqIDToObserve = int64(migrateData["seqID"].(float64))

maintnotifications/e2e/scenario_timeout_configs_test.go

@@ -195,7 +195,7 @@ func TestTimeoutConfigurationsPushNotifications(t *testing.T) {
 			failoverResp, err := faultInjector.TriggerAction(ctx, ActionRequest{
 				Type: "failover",
 				Parameters: map[string]interface{}{
-					"bdb_id":        endpointConfig.BdbID,
+					"bdb_id": endpointConfig.BdbID,
 				},
 			})
 			if err != nil {
@@ -243,7 +243,7 @@ func TestTimeoutConfigurationsPushNotifications(t *testing.T) {
 			migrateResp, err := faultInjector.TriggerAction(ctx, ActionRequest{
 				Type: "migrate",
 				Parameters: map[string]interface{}{
-					"bdb_id":        endpointConfig.BdbID,
+					"bdb_id": endpointConfig.BdbID,
 				},
 			})
 			if err != nil {
@@ -253,7 +253,7 @@ func TestTimeoutConfigurationsPushNotifications(t *testing.T) {
 			// Wait for MIGRATING notification
 			match, found = logCollector.WaitForLogMatchFunc(func(s string) bool {
 				return strings.Contains(s, logs2.ProcessingNotificationMessage) && strings.Contains(s, "MIGRATING")
-			}, 30*time.Second)
+			}, 60*time.Second)
 			if !found {
 				ef("MIGRATING notification was not received for %s timeout config", timeoutTest.name)
 			}
@@ -274,7 +274,7 @@ func TestTimeoutConfigurationsPushNotifications(t *testing.T) {
 			bindResp, err := faultInjector.TriggerAction(ctx, ActionRequest{
 				Type: "bind",
 				Parameters: map[string]interface{}{
-					"bdb_id":        endpointConfig.BdbID,
+					"bdb_id": endpointConfig.BdbID,
 				},
 			})
 			if err != nil {

maintnotifications/e2e/scenario_tls_configs_test.go

@@ -192,50 +192,6 @@ func ТestTLSConfigurationsPushNotifications(t *testing.T) {
 				commandsRunner.FireCommandsUntilStop(ctx)
 			}()
 
-			// Test failover with this TLS configuration
-			p("Testing failover with %s TLS configuration...", tlsTest.name)
-			failoverResp, err := faultInjector.TriggerAction(ctx, ActionRequest{
-				Type: "failover",
-				Parameters: map[string]interface{}{
-					"bdb_id": endpointConfig.BdbID,
-				},
-			})
-			if err != nil {
-				ef("Failed to trigger failover action for %s: %v", tlsTest.name, err)
-			}
-
-			// Wait for FAILING_OVER notification
-			match, found := logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
-				return strings.Contains(s, logs2.ProcessingNotificationMessage) && notificationType(s, "FAILING_OVER")
-			}, 3*time.Minute)
-			if !found {
-				ef("FAILING_OVER notification was not received for %s TLS config", tlsTest.name)
-			}
-			failingOverData := logs2.ExtractDataFromLogMessage(match)
-			p("FAILING_OVER notification received for %s. %v", tlsTest.name, failingOverData)
-
-			// Wait for FAILED_OVER notification
-			seqIDToObserve := int64(failingOverData["seqID"].(float64))
-			connIDToObserve := uint64(failingOverData["connID"].(float64))
-			match, found = logCollector.MatchOrWaitForLogMatchFunc(func(s string) bool {
-				return notificationType(s, "FAILED_OVER") && connID(s, connIDToObserve) && seqID(s, seqIDToObserve+1)
-			}, 3*time.Minute)
-			if !found {
-				ef("FAILED_OVER notification was not received for %s TLS config", tlsTest.name)
-			}
-			failedOverData := logs2.ExtractDataFromLogMessage(match)
-			p("FAILED_OVER notification received for %s. %v", tlsTest.name, failedOverData)
-
-			// Wait for failover to complete
-			status, err := faultInjector.WaitForAction(ctx, failoverResp.ActionID,
-				WithMaxWaitTime(240*time.Second),
-				WithPollInterval(2*time.Second),
-			)
-			if err != nil {
-				ef("[FI] Failover action failed for %s: %v", tlsTest.name, err)
-			}
-			p("[FI] Failover action completed for %s: %s", tlsTest.name, status.Status)
-
 			// Test migration with this TLS configuration
 			p("Testing migration with %s TLS configuration...", tlsTest.name)
 			migrateResp, err := faultInjector.TriggerAction(ctx, ActionRequest{
@@ -251,7 +207,7 @@ func ТestTLSConfigurationsPushNotifications(t *testing.T) {
 			// Wait for MIGRATING notification
 			match, found = logCollector.WaitForLogMatchFunc(func(s string) bool {
 				return strings.Contains(s, logs2.ProcessingNotificationMessage) && strings.Contains(s, "MIGRATING")
-			}, 30*time.Second)
+			}, 60*time.Second)
 			if !found {
 				ef("MIGRATING notification was not received for %s TLS config", tlsTest.name)
 			}