chore: cluster delete support force (#582)

Co-authored-by: yipeng1030 <yipeng1030@users.noreply.github.com>
(cherry picked from commit a472c89)

Author: yipeng1030

docs/user_docs/cli/kbcli_cluster_delete.md

@@ -13,8 +13,12 @@ kbcli cluster delete NAME [flags]
 ```
   # delete a cluster named mycluster
   kbcli cluster delete mycluster
+  
   # delete a cluster by label selector
   kbcli cluster delete --selector clusterdefinition.kubeblocks.io/name=apecloud-mysql
+  
+  # delete a cluster named mycluster forcedly
+  kbcli cluster delete mycluster --force
 ```
 
 ### Options

pkg/cmd/cluster/delete.go

@@ -29,9 +29,12 @@ import (
 	cmdutil "k8s.io/kubectl/pkg/cmd/util"
 	"k8s.io/kubectl/pkg/util/templates"
 
+	appsv1 "github.com/apecloud/kubeblocks/apis/apps/v1"
 	appsv1alpha1 "github.com/apecloud/kubeblocks/apis/apps/v1alpha1"
+	"github.com/apecloud/kubeblocks/pkg/constant"
 
 	"github.com/apecloud/kbcli/pkg/action"
+	"github.com/apecloud/kbcli/pkg/printer"
 	"github.com/apecloud/kbcli/pkg/types"
 	"github.com/apecloud/kbcli/pkg/util"
 )
@@ -40,8 +43,12 @@ var (
 	deleteExample = templates.Examples(`
 		# delete a cluster named mycluster
 		kbcli cluster delete mycluster
+
 		# delete a cluster by label selector
 		kbcli cluster delete --selector clusterdefinition.kubeblocks.io/name=apecloud-mysql
+
+		# delete a cluster named mycluster forcedly
+		kbcli cluster delete mycluster --force
 `)
 )
 
@@ -80,9 +87,25 @@ func clusterPreDeleteHook(o *action.DeleteOptions, object runtime.Object) error
 	if err != nil {
 		return err
 	}
-	if cluster.Spec.TerminationPolicy == appsv1alpha1.DoNotTerminate {
+	if cluster.Spec.TerminationPolicy == appsv1.DoNotTerminate {
 		return fmt.Errorf("cluster %s is protected by termination policy %s, skip deleting", cluster.Name, appsv1alpha1.DoNotTerminate)
 	}
+
+	if o.Force {
+		fmt.Fprintf(o.Out, printer.BoldRed("WARNING: Using --force may lead to potential data loss or residual dirty data if the cluster depends on other clusters.\n"))
+		components := util.GetComponentsOrShards(cluster)
+		for _, componentName := range components {
+			dynamicClient, err := o.Factory.DynamicClient()
+			if err != nil {
+				return err
+			}
+			err = util.AddAnnotationToComponentOrShard(dynamicClient, constant.GenerateClusterComponentName(cluster.Name, componentName), cluster.Namespace, constant.SkipPreTerminateAnnotationKey, "true")
+			if err != nil {
+				return fmt.Errorf("failed to add annotation to component %s: %v", componentName, err)
+			}
+		}
+	}
+
 	return nil
 }
 
@@ -96,12 +119,12 @@ func clusterPostDeleteHook(o *action.DeleteOptions, object runtime.Object) error
 	return nil
 }
 
-func getClusterFromObject(object runtime.Object) (*appsv1alpha1.Cluster, error) {
-	if object.GetObjectKind().GroupVersionKind().Kind != appsv1alpha1.ClusterKind {
+func getClusterFromObject(object runtime.Object) (*appsv1.Cluster, error) {
+	if object.GetObjectKind().GroupVersionKind().Kind != appsv1.ClusterKind {
 		return nil, fmt.Errorf("object %s is not of kind %s", object.GetObjectKind().GroupVersionKind().Kind, appsv1alpha1.ClusterKind)
 	}
 	u := object.(*unstructured.Unstructured)
-	cluster := &appsv1alpha1.Cluster{}
+	cluster := &appsv1.Cluster{}
 	if err := runtime.DefaultUnstructuredConverter.FromUnstructured(u.Object, cluster); err != nil {
 		return nil, err
 	}

pkg/util/util.go

@@ -1287,3 +1287,38 @@ func SetHelmOwner(dynamicClient dynamic.Interface, gvr schema.GroupVersionResour
 	}
 	return nil
 }
+
+// AddAnnotationToComponentOrShard adds a specific annotation to a component.
+func AddAnnotationToComponentOrShard(dynamicClient dynamic.Interface, componentName, namespace, annotationKey, annotationValue string) error {
+	gvr := types.ComponentGVR()
+	resourceClient := dynamicClient.Resource(gvr).Namespace(namespace)
+	componentObj, err := resourceClient.Get(context.Background(), componentName, metav1.GetOptions{})
+	if err != nil {
+		return fmt.Errorf("failed to get component %s: %v", componentName, err)
+	}
+
+	annotations := componentObj.GetAnnotations()
+	if annotations == nil {
+		annotations = make(map[string]string)
+	}
+	annotations[annotationKey] = annotationValue
+	componentObj.SetAnnotations(annotations)
+
+	_, err = resourceClient.Update(context.Background(), componentObj, metav1.UpdateOptions{})
+	if err != nil {
+		return fmt.Errorf("failed to update component %s with annotation %s: %v", componentName, annotationKey, err)
+	}
+
+	return nil
+}
+
+func GetComponentsOrShards(cluster *kbappsv1.Cluster) []string {
+	var components []string
+	for _, component := range cluster.Spec.ComponentSpecs {
+		components = append(components, component.Name)
+	}
+	for _, sharding := range cluster.Spec.Shardings {
+		components = append(components, sharding.Name)
+	}
+	return components
+}