feat(dedibox): add waiter support dedibox

internal/namespaces/dedibox/v1/custom.go

@@ -9,6 +9,8 @@ import (
 func GetCommands() *core.Commands {
 	cmds := GetGeneratedCommands()
 
+	cmds.MustFind("dedibox", "server", "create").Override(serviceCreateBuilder)
+
 	for _, commandPath := range [][]string{
 		{"dedibox", "server", "list"},
 		{"dedibox", "service", "list"},

internal/namespaces/dedibox/v1/custom_server.go

@@ -0,0 +1 @@
+package dedibox

internal/namespaces/dedibox/v1/custom_service.go

@@ -0,0 +1,50 @@
+package dedibox
+
+import (
+	"context"
+	"errors"
+	"fmt"
+	"github.com/scaleway/scaleway-cli/v2/internal/core"
+	"github.com/scaleway/scaleway-sdk-go/api/dedibox/v1"
+	"github.com/scaleway/scaleway-sdk-go/scw"
+	"net/http"
+	"time"
+)
+
+const (
+	serviceActionTimeout = time.Minute * 60
+)
+
+const (
+	serviceActionCreate = iota
+	serviceActionDelete
+)
+
+func serviceCreateBuilder(c *core.Command) *core.Command {
+	c.WaitFunc = waitForServiceFunc(serviceActionCreate)
+	return c
+}
+
+func waitForServiceFunc(action int) core.WaitFunc {
+	return func(ctx context.Context, argsI, respI interface{}) (interface{}, error) {
+		service, err := dedibox.NewAPI(core.ExtractClient(ctx)).WaitForService(&dedibox.WaitForServiceRequest{
+			ServiceID:     respI.(*dedibox.Service).ID,
+			Zone:          argsI.(*dedibox.CreateServerRequest).Zone,
+			Timeout:       scw.TimeDurationPtr(serviceActionTimeout),
+			RetryInterval: core.DefaultRetryInterval,
+		})
+		switch action {
+		case serviceActionCreate:
+			return service, err
+		case serviceActionDelete:
+			if err != nil {
+				notFoundError := &scw.ResourceNotFoundError{}
+				responseError := &scw.ResponseError{}
+				if errors.As(err, &responseError) && responseError.StatusCode == http.StatusNotFound || errors.As(err, &notFoundError) {
+					return fmt.Sprintf("Server %s successfully deleted.", respI.(*dedibox.Service).ID), nil
+				}
+			}
+		}
+		return nil, err
+	}
+}