feat(k8s): add wait and status color to k8s node

Signed-off-by: Patrik Cyvoct <[email protected]>

Author: Sh4d1

internal/namespaces/k8s/v1beta4/custom.go

@@ -16,8 +16,9 @@ func GetCommands() *core.Commands {
 	cmds := GetGeneratedCommands()
 
 	human.RegisterMarshalerFunc(k8s.ClusterStatus(0), human.BindAttributesMarshalFunc(clusterStatusAttributes))
+	human.RegisterMarshalerFunc(k8s.NodeStatus(0), human.BindAttributesMarshalFunc(nodeStatusAttributes))
 
-	cmds.MustFind("k8s", "cluster", "list-available-versions").Override(clusterAvailableVersionsListBuilder)
+	cmds.MustFind("k8s", "node", "reboot").Override(nodeRebootBuilder)
 
 	return cmds
 }

internal/namespaces/k8s/v1beta4/custom_node.go

@@ -0,0 +1,58 @@
+package k8s
+
+import (
+	"context"
+	"fmt"
+	"time"
+
+	"github.com/fatih/color"
+	"github.com/scaleway/scaleway-cli/internal/core"
+	"github.com/scaleway/scaleway-cli/internal/human"
+	k8s "github.com/scaleway/scaleway-sdk-go/api/k8s/v1beta4"
+	"github.com/scaleway/scaleway-sdk-go/scw"
+)
+
+const (
+	nodeActionTimeout = 10 * time.Minute
+)
+
+//
+// Marshalers
+//
+
+// nodeStatusMarshalerFunc marshals a k8s.ClusterStatus.
+var (
+	nodeStatusAttributes = human.Attributes{
+		k8s.NodeStatusCreating:      color.FgBlue,
+		k8s.NodeStatusRebooting:     color.FgBlue,
+		k8s.NodeStatusReady:         color.FgGreen,
+		k8s.NodeStatusNotready:      color.FgYellow,
+		k8s.NodeStatusCreationError: color.FgRed,
+		k8s.NodeStatusLocked:        color.FgRed,
+		k8s.NodeStatusWarning:       color.FgHiYellow,
+	}
+)
+
+const (
+	nodeActionReboot = iota
+)
+
+func nodeRebootBuilder(c *core.Command) *core.Command {
+	c.WaitFunc = waitForNodeFunc(nodeActionReboot)
+	return c
+}
+
+func waitForNodeFunc(action int) core.WaitFunc {
+	return func(ctx context.Context, _, respI interface{}) (interface{}, error) {
+		_, err := k8s.NewAPI(core.ExtractClient(ctx)).WaitForNode(&k8s.WaitForNodeRequest{
+			Region:  respI.(*k8s.Node).Region,
+			NodeID:  respI.(*k8s.Node).ID,
+			Timeout: scw.DurationPtr(nodeActionReboot),
+		})
+		switch action {
+		case nodeActionReboot:
+			return fmt.Sprintf("Node %s successfully rebooted.", respI.(*k8s.Node).ID), nil
+		}
+		return nil, err
+	}
+}