Delete router/network/subnet

Author: hidekazuna

controllers/openstackcluster_controller.go

@@ -150,7 +150,24 @@ func (r *OpenStackClusterReconciler) reconcileDelete(ctx context.Context, log lo
 		}
 	}
 
-	// TODO(sbueringer) Delete network/subnet/router/... if created by CAPO
+	if openStackCluster.Status.Network.Router != nil {
+		log.Info("Deleting router", "name", openStackCluster.Status.Network.Router.Name)
+		err := networkingService.DeleteRouter(openStackCluster.Status.Network)
+		if err != nil {
+			return ctrl.Result{}, errors.Errorf("failed to delete router: %v", err)
+		}
+		log.Info("OpenStack router deleted successfully")
+	}
+
+	if openStackCluster.Status.Network != nil {
+		log.Info("Deleting network", "name", openStackCluster.Status.Network.Name)
+		err := networkingService.DeleteNetwork(openStackCluster.Status.Network)
+		if err != nil {
+			return ctrl.Result{}, errors.Errorf("failed to delete network: %v", err)
+		}
+		log.Info("OpenStack network deleted successfully")
+	}
+	log.Info("OpenStack cluster deleted successfully")
 
 	// Cluster is deleted so remove the finalizer.
 	controllerutil.RemoveFinalizer(openStackCluster, infrav1.ClusterFinalizer)
@@ -297,6 +314,7 @@ func (r *OpenStackClusterReconciler) reconcileNormal(ctx context.Context, log lo
 	}
 
 	openStackCluster.Status.Ready = true
+	log.Info("Reconciled Cluster create successfully")
 	return ctrl.Result{}, nil
 }
 

pkg/cloud/services/networking/network.go

@@ -91,6 +91,19 @@ func (s *Service) ReconcileNetwork(clusterName string, openStackCluster *infrav1
 	return nil
 }
 
+func (s *Service) DeleteNetwork(network *infrav1.Network) error {
+	exists, err := s.existsNetwork(network.ID)
+	if err != nil {
+		return err
+	}
+	if exists {
+		err = networks.Delete(s.client, network.ID).ExtractErr()
+	} else {
+		s.logger.Info("No network", "network", network.ID)
+	}
+	return err
+}
+
 func (s *Service) ReconcileSubnet(clusterName string, openStackCluster *infrav1.OpenStackCluster) error {
 
 	if openStackCluster.Status.Network == nil || openStackCluster.Status.Network.ID == "" {
@@ -188,3 +201,21 @@ func (s *Service) getNetworkByName(networkName string) (networks.Network, error)
 	}
 	return networks.Network{}, errors.New("too many resources")
 }
+
+func (s *Service) existsNetwork(networkID string) (bool, error) {
+	opts := networks.ListOpts{
+		ID: networkID,
+	}
+	allPages, err := networks.List(s.client, opts).AllPages()
+	if err != nil {
+		return false, err
+	}
+	allNetworks, err := networks.ExtractNetworks(allPages)
+	if err != nil {
+		return false, err
+	}
+	if len(allNetworks) == 0 {
+		return false, nil
+	}
+	return true, nil
+}

pkg/cloud/services/networking/router.go

@@ -165,6 +165,30 @@ INTERFACE_LOOP:
 	return nil
 }
 
+func (s *Service) DeleteRouter(network *infrav1.Network) error {
+	exists, err := s.existsRouter(network.Router.ID)
+	if err != nil {
+		return err
+	}
+	if exists {
+		if network.Subnet == nil || network.Subnet.ID == "" {
+			s.logger.V(4).Info("No need to remove router interface since no subnet exists.")
+		} else {
+			_, err := routers.RemoveInterface(s.client, network.Router.ID, routers.RemoveInterfaceOpts{
+				SubnetID: network.Subnet.ID,
+			}).Extract()
+			if err != nil {
+				return fmt.Errorf("unable to remove router interface: %v", err)
+			}
+			s.logger.V(4).Info("Removed RouterInterface of Router", "id", network.Router.ID)
+		}
+		err = routers.Delete(s.client, network.Router.ID).ExtractErr()
+	} else {
+		s.logger.Info("No router", "router", network.Router.ID)
+	}
+	return err
+}
+
 func (s *Service) getRouterInterfaces(routerID string) ([]ports.Port, error) {
 	allPages, err := ports.List(s.client, ports.ListOpts{
 		DeviceID: routerID,
@@ -247,3 +271,21 @@ func GetSubnetsByFilter(networkClient *gophercloud.ServiceClient, opts subnets.L
 	}
 	return snets, nil
 }
+
+func (s *Service) existsRouter(routerID string) (bool, error) {
+	opts := routers.ListOpts{
+		ID: routerID,
+	}
+	allPages, err := routers.List(s.client, opts).AllPages()
+	if err != nil {
+		return false, err
+	}
+	allRouters, err := routers.ExtractRouters(allPages)
+	if err != nil {
+		return false, err
+	}
+	if len(allRouters) == 0 {
+		return false, nil
+	}
+	return true, nil
+}