add async handling

Author: rubenhoenle

internal/cmd/ske/cluster/hibernate/hibernate.go

@@ -13,7 +13,9 @@ import (
 	"github.com/stackitcloud/stackit-cli/internal/pkg/print"
 	"github.com/stackitcloud/stackit-cli/internal/pkg/projectname"
 	"github.com/stackitcloud/stackit-cli/internal/pkg/services/ske/client"
+	"github.com/stackitcloud/stackit-cli/internal/pkg/spinner"
 	"github.com/stackitcloud/stackit-sdk-go/services/ske"
+	"github.com/stackitcloud/stackit-sdk-go/services/ske/wait"
 )
 
 const (
@@ -69,7 +71,22 @@ func NewCmd(params *params.CmdParams) *cobra.Command {
 				return fmt.Errorf("hibernate SKE cluster: %w", err)
 			}
 
-			params.Printer.Info("Hibernate got triggered for %q\n", model.ClusterName)
+			// Wait for async operation, if async mode not enabled
+			if !model.Async {
+				s := spinner.New(params.Printer)
+				s.Start("Hibernating cluster")
+				_, err = wait.TriggerClusterHibernationWaitHandler(ctx, apiClient, model.ProjectId, model.Region, model.ClusterName).WaitWithContext(ctx)
+				if err != nil {
+					return fmt.Errorf("wait for SKE cluster hibernation: %w", err)
+				}
+				s.Stop()
+			}
+
+			operationState := "Hibernated"
+			if model.Async {
+				operationState = "Triggered hibernation of"
+			}
+			params.Printer.Outputf("%s cluster %q\n", operationState, model.ClusterName)
 			return nil
 		},
 	}

internal/cmd/ske/cluster/maintenance/maintenance.go

@@ -13,7 +13,9 @@ import (
 	"github.com/stackitcloud/stackit-cli/internal/pkg/print"
 	"github.com/stackitcloud/stackit-cli/internal/pkg/projectname"
 	"github.com/stackitcloud/stackit-cli/internal/pkg/services/ske/client"
+	"github.com/stackitcloud/stackit-cli/internal/pkg/spinner"
 	"github.com/stackitcloud/stackit-sdk-go/services/ske"
+	"github.com/stackitcloud/stackit-sdk-go/services/ske/wait"
 )
 
 const (
@@ -69,7 +71,22 @@ func NewCmd(params *params.CmdParams) *cobra.Command {
 				return fmt.Errorf("trigger maintenance SKE cluster: %w", err)
 			}
 
-			params.Printer.Info("Maintenance got triggered for %q\n", model.ClusterName)
+			// Wait for async operation, if async mode not enabled
+			if !model.Async {
+				s := spinner.New(params.Printer)
+				s.Start("Performing cluster maintenance")
+				_, err = wait.TriggerClusterMaintenanceWaitHandler(ctx, apiClient, model.ProjectId, model.Region, model.ClusterName).WaitWithContext(ctx)
+				if err != nil {
+					return fmt.Errorf("wait for SKE cluster maintenance to complete: %w", err)
+				}
+				s.Stop()
+			}
+
+			operationState := "Performed maintenance for"
+			if model.Async {
+				operationState = "Triggered maintenance for"
+			}
+			params.Printer.Outputf("%s cluster %q\n", operationState, model.ClusterName)
 			return nil
 		},
 	}

internal/cmd/ske/cluster/reconcile/reconcile.go

@@ -12,7 +12,9 @@ import (
 	"github.com/stackitcloud/stackit-cli/internal/pkg/globalflags"
 	"github.com/stackitcloud/stackit-cli/internal/pkg/print"
 	"github.com/stackitcloud/stackit-cli/internal/pkg/services/ske/client"
+	"github.com/stackitcloud/stackit-cli/internal/pkg/spinner"
 	"github.com/stackitcloud/stackit-sdk-go/services/ske"
+	"github.com/stackitcloud/stackit-sdk-go/services/ske/wait"
 )
 
 const (
@@ -55,7 +57,22 @@ func NewCmd(params *params.CmdParams) *cobra.Command {
 				return fmt.Errorf("reconcile SKE cluster: %w", err)
 			}
 
-			params.Printer.Info("Reconcile got triggered for %q\n", model.ClusterName)
+			// Wait for async operation, if async mode not enabled
+			if !model.Async {
+				s := spinner.New(params.Printer)
+				s.Start("Performing cluster reconciliation")
+				_, err = wait.TriggerClusterReconciliationWaitHandler(ctx, apiClient, model.ProjectId, model.Region, model.ClusterName).WaitWithContext(ctx)
+				if err != nil {
+					return fmt.Errorf("wait for SKE cluster reconciliation: %w", err)
+				}
+				s.Stop()
+			}
+
+			operationState := "Performed reconciliation for"
+			if model.Async {
+				operationState = "Triggered reconcile for"
+			}
+			params.Printer.Outputf("%s cluster %q\n", operationState, model.ClusterName)
 			return nil
 		},
 	}

internal/cmd/ske/cluster/wakeup/wakeup.go

@@ -12,7 +12,9 @@ import (
 	"github.com/stackitcloud/stackit-cli/internal/pkg/globalflags"
 	"github.com/stackitcloud/stackit-cli/internal/pkg/print"
 	"github.com/stackitcloud/stackit-cli/internal/pkg/services/ske/client"
+	"github.com/stackitcloud/stackit-cli/internal/pkg/spinner"
 	"github.com/stackitcloud/stackit-sdk-go/services/ske"
+	"github.com/stackitcloud/stackit-sdk-go/services/ske/wait"
 )
 
 const (
@@ -55,7 +57,22 @@ func NewCmd(params *params.CmdParams) *cobra.Command {
 				return fmt.Errorf("wakeup SKE cluster: %w", err)
 			}
 
-			params.Printer.Info("Wakeup got triggered for %q\n", model.ClusterName)
+			// Wait for async operation, if async mode not enabled
+			if !model.Async {
+				s := spinner.New(params.Printer)
+				s.Start("Performing cluster wakeup")
+				_, err = wait.TriggerClusterWakeupWaitHandler(ctx, apiClient, model.ProjectId, model.Region, model.ClusterName).WaitWithContext(ctx)
+				if err != nil {
+					return fmt.Errorf("wait for SKE cluster wakeup: %w", err)
+				}
+				s.Stop()
+			}
+
+			operationState := "Performed wakeup of"
+			if model.Async {
+				operationState = "Triggered wakeup of"
+			}
+			params.Printer.Outputf("%s cluster %q\n", operationState, model.ClusterName)
 			return nil
 		},
 	}