Chore: error while run command against wrong cluser

pkg/cmd/accept/exec.go

@@ -7,20 +7,19 @@ import (
 	"strings"
 	"time"
 
+	"github.com/spf13/cobra"
+	certificatesv1 "k8s.io/api/certificates/v1"
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/types"
+	utilerrors "k8s.io/apimachinery/pkg/util/errors"
 	"k8s.io/apimachinery/pkg/util/sets"
 	"k8s.io/apimachinery/pkg/util/wait"
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/klog/v2"
-	"open-cluster-management.io/clusteradm/pkg/helpers"
-
-	"github.com/spf13/cobra"
-	certificatesv1 "k8s.io/api/certificates/v1"
-	utilerrors "k8s.io/apimachinery/pkg/util/errors"
 	clusterclientset "open-cluster-management.io/api/client/cluster/clientset/versioned"
+	"open-cluster-management.io/clusteradm/pkg/helpers"
 )
 
 const (
@@ -52,6 +51,11 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) Validate() error {
+	err := o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	return nil
 }
 

pkg/cmd/addon/disable/exec.go

@@ -5,10 +5,9 @@ import (
 	"context"
 	"fmt"
 
-	"k8s.io/apimachinery/pkg/api/errors"
-
 	"github.com/spf13/cobra"
 	apiextensionsclient "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
+	"k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/util/sets"
 	"k8s.io/client-go/dynamic"
@@ -26,6 +25,11 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) Validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(o.Names) == 0 {
 		return fmt.Errorf("names is missing")
 	}
@@ -37,6 +41,7 @@ func (o *Options) Validate() (err error) {
 	if o.Allclusters && len(o.Clusters) != 0 {
 		return fmt.Errorf("flag --all-clusters and --clusters can not be set together")
 	}
+
 	return nil
 }
 

pkg/cmd/addon/enable/exec.go

@@ -7,14 +7,13 @@ import (
 	"strings"
 
 	"github.com/spf13/cobra"
-	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-	"k8s.io/klog/v2"
-
 	"github.com/stolostron/applier/pkg/apply"
 	apiextensionsclient "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
+	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 	"k8s.io/apimachinery/pkg/util/sets"
 	"k8s.io/client-go/dynamic"
 	"k8s.io/client-go/kubernetes"
+	"k8s.io/klog/v2"
 	clusterclientset "open-cluster-management.io/api/client/cluster/clientset/versioned"
 	"open-cluster-management.io/clusteradm/pkg/cmd/addon/enable/scenario"
 	"open-cluster-management.io/clusteradm/pkg/helpers"
@@ -52,7 +51,12 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 	return nil
 }
 
-func (o *Options) Validate() error {
+func (o *Options) Validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(o.Names) == 0 {
 		return fmt.Errorf("names is missing")
 	}

pkg/cmd/clean/exec.go

@@ -8,11 +8,7 @@ import (
 	"log"
 	"time"
 
-	clustermanagerclient "open-cluster-management.io/api/client/operator/clientset/versioned"
-	"open-cluster-management.io/clusteradm/pkg/helpers"
-
 	"github.com/spf13/cobra"
-
 	apiextensionsclient "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
 	"k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -21,6 +17,8 @@ import (
 	"k8s.io/client-go/kubernetes"
 	"k8s.io/client-go/util/retry"
 	"k8s.io/klog/v2"
+	clustermanagerclient "open-cluster-management.io/api/client/operator/clientset/versioned"
+	"open-cluster-management.io/clusteradm/pkg/helpers"
 )
 
 func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {

pkg/cmd/clusterset/bind/exec.go

@@ -27,9 +27,15 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) Validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(o.Namespace) == 0 {
 		return fmt.Errorf("namespace name must be specified in --namespace")
 	}
+
 	return nil
 }
 

pkg/cmd/clusterset/set/exec.go

@@ -25,9 +25,15 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) Validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(o.Clusters) == 0 {
 		return fmt.Errorf("cluster name must be specified in --clusters")
 	}
+
 	return nil
 }
 

pkg/cmd/clusterset/unbind/exec.go

@@ -26,9 +26,15 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) Validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(o.Namespace) == 0 {
 		return fmt.Errorf("namespace name must be specified in --namespace")
 	}
+
 	return nil
 }
 

pkg/cmd/create/clusterset/exec.go

@@ -12,19 +12,24 @@ import (
 )
 
 func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
-
 	o.Clustersets = args
 
 	return nil
 }
 
 func (o *Options) Validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(o.Clustersets) == 0 {
 		return fmt.Errorf("the name of the clusterset must be specified")
 	}
 	if len(o.Clustersets) > 1 {
 		return fmt.Errorf("only one clusterset can be created")
 	}
+
 	return nil
 }
 

pkg/cmd/create/sampleapp/exec.go

@@ -45,6 +45,10 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) Validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
 
 	return nil
 }

pkg/cmd/create/work/exec.go

@@ -34,6 +34,11 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(o.Cluster) == 0 && len(o.Placement) == 0 {
 		return fmt.Errorf("--clusters or --placement must be specified")
 	}
@@ -46,6 +51,7 @@ func (o *Options) validate() (err error) {
 	if len(*o.FileNameFlags.Filenames) == 0 {
 		return fmt.Errorf("manifest files must be specified")
 	}
+
 	return nil
 }
 

pkg/cmd/delete/clusterset/exec.go

@@ -21,12 +21,18 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(o.Clustersets) == 0 {
 		return fmt.Errorf("the name of the clusterset must be specified")
 	}
 	if len(o.Clustersets) > 1 {
 		return fmt.Errorf("only one clusterset can be deleted")
 	}
+
 	return nil
 }
 

pkg/cmd/delete/token/exec.go

@@ -5,16 +5,13 @@ import (
 	"context"
 	"fmt"
 
+	"github.com/spf13/cobra"
+	apiextensionsclient "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
 	"k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
-
+	"k8s.io/client-go/kubernetes"
 	"open-cluster-management.io/clusteradm/pkg/config"
 	"open-cluster-management.io/clusteradm/pkg/helpers"
-
-	"github.com/spf13/cobra"
-
-	apiextensionsclient "k8s.io/apiextensions-apiserver/pkg/client/clientset/clientset"
-	"k8s.io/client-go/kubernetes"
 )
 
 func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {

pkg/cmd/delete/work/exec.go

@@ -6,14 +6,12 @@ import (
 	"fmt"
 	"time"
 
-	"k8s.io/apimachinery/pkg/watch"
-
+	"github.com/spf13/cobra"
 	"k8s.io/apimachinery/pkg/api/errors"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
+	"k8s.io/apimachinery/pkg/watch"
 	workclientset "open-cluster-management.io/api/client/work/clientset/versioned"
 	"open-cluster-management.io/clusteradm/pkg/helpers"
-
-	"github.com/spf13/cobra"
 )
 
 func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
@@ -30,7 +28,12 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 	return nil
 }
 
-func (o *Options) validate() error {
+func (o *Options) validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(o.Cluster) == 0 {
 		return fmt.Errorf("the name of the cluster must be specified")
 	}

pkg/cmd/get/addon/exec.go

@@ -28,6 +28,11 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) validate() (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	return nil
 }
 

pkg/cmd/get/cluster/exec.go

@@ -21,6 +21,11 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) validate(args []string) (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(args) != 0 {
 		return fmt.Errorf("there should be no argument")
 	}

pkg/cmd/get/clusterset/exec.go

@@ -32,6 +32,11 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) validate(args []string) (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(args) != 0 {
 		return fmt.Errorf("there should be no argument")
 	}

pkg/cmd/get/hubinfo/exec.go

@@ -39,10 +39,16 @@ func (o *Options) complete(cmd *cobra.Command, args []string) error {
 	return nil
 }
 
-func (o *Options) validate(args []string) error {
+func (o *Options) validate(args []string) (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(args) != 0 {
 		return fmt.Errorf("there should be no argument")
 	}
+
 	return nil
 }
 

pkg/cmd/get/klusterletinfo/exec.go

@@ -39,10 +39,16 @@ func (o *Options) complete(cmd *cobra.Command, args []string) error {
 	return nil
 }
 
-func (o *Options) validate(args []string) error {
+func (o *Options) validate(args []string) (err error) {
+	err = o.ClusteradmFlags.ValidateManagedCluster()
+	if err != nil {
+		return err
+	}
+
 	if len(args) != 0 {
 		return fmt.Errorf("there should be no argument")
 	}
+
 	return nil
 }
 

pkg/cmd/get/placement/exec.go

@@ -25,6 +25,11 @@ func (o *Options) complete(cmd *cobra.Command, args []string) (err error) {
 }
 
 func (o *Options) validate(args []string) (err error) {
+	err = o.ClusteradmFlags.ValidateHub()
+	if err != nil {
+		return err
+	}
+
 	if len(args) > 1 {
 		return fmt.Errorf("the number of placement name should be 0 or 1")
 	}