feat: deletes the machine pool created during oc registration (#1844)

pkg/cmd/kafka/openshift-cluster/deregister/deregister.go

@@ -24,6 +24,7 @@ type options struct {
 	clusterManagementApiUrl string
 	accessToken             string
 	selectedCluster         *clustersmgmtv1.Cluster
+	machinePoolId           string
 
 	f *factory.Factory
 }
@@ -34,6 +35,7 @@ const (
 	strimziAddonId      = "managed-kafka"
 	fleetshardAddonIdQE = "kas-fleetshard-operator-qe"
 	strimziAddonIdQE    = "managed-kafka-qe"
+	machinePoolTaintKey = "bf2.org/kafkaInstanceProfileType"
 )
 
 func NewDeRegisterClusterCommand(f *factory.Factory) *cobra.Command {
@@ -113,6 +115,18 @@ func runDeRegisterClusterCmd(opts *options) error {
 		return err
 	}
 
+	// Get the kafka machine pool id
+	opts.machinePoolId, err = ocmUtils.GetMachinePoolIdByTaintKey(opts.f, opts.clusterManagementApiUrl, opts.accessToken, opts.selectedCluster.ID(), machinePoolTaintKey)
+	if err != nil {
+		return err
+	}
+
+	// remove the kafka machine pool from the cluster
+	err = ocmUtils.DeleteMachinePool(opts.f, opts.clusterManagementApiUrl, opts.accessToken, opts.selectedCluster.ID(), opts.machinePoolId)
+	if err != nil {
+		return err
+	}
+
 	return nil
 }
 

pkg/shared/connection/api/clustermgmt/ocm_utils.go

@@ -131,6 +131,40 @@ func CreateMachinePool(f *factory.Factory, clustermgmturl string, accessToken st
 	return response.Body(), nil
 }
 
+func GetMachinePoolIdByTaintKey(f *factory.Factory, clustermgmturl string, accessToken string, clusterId string, machinePoolTaintKey string) (string, error) {
+	client, closeConnection, err := clustermgmtConnection(f, accessToken, clustermgmturl)
+	if err != nil {
+		return "", err
+	}
+	defer closeConnection()
+	response, err := client.Clusters().Cluster(clusterId).MachinePools().List().Send()
+	if err != nil {
+		return "", err
+	}
+	machinePools := response.Items()
+	for _, machinePool := range machinePools.Slice() {
+		for _, taint := range machinePool.Taints() {
+			if taint.Key() == machinePoolTaintKey {
+				return machinePool.ID(), nil
+			}
+		}
+	}
+	return "", nil
+}
+
+func DeleteMachinePool(f *factory.Factory, clustermgmturl string, accessToken string, clusterId string, machinePoolId string) error {
+	client, closeConnection, err := clustermgmtConnection(f, accessToken, clustermgmturl)
+	if err != nil {
+		return err
+	}
+	defer closeConnection()
+	_, err = client.Clusters().Cluster(clusterId).MachinePools().MachinePool(machinePoolId).Delete().Send()
+	if err != nil {
+		return err
+	}
+	return nil
+}
+
 func GetMachinePoolNodeCount(machinePool *v1.MachinePool) int {
 	var nodeCount int
 	replicas, ok := machinePool.GetReplicas()