vm, controller: Create IPAMClaim for primary

Signed-off-by: Enrique Llorente <[email protected]>

pkg/vminetworkscontroller/vmi_controller.go

@@ -25,6 +25,8 @@ import (
 	virtv1 "kubevirt.io/api/core/v1"
 
 	"github.com/kubevirt/ipam-extensions/pkg/config"
+	"github.com/kubevirt/ipam-extensions/pkg/ipamclaim"
+	"github.com/kubevirt/ipam-extensions/pkg/udn"
 )
 
 const kubevirtVMFinalizer = "kubevirt.io/persistent-ipam"
@@ -82,13 +84,46 @@ func (r *VirtualMachineInstanceReconciler) Reconcile(
 		)
 	}
 
+	primaryNetworkNAD, err := udn.FindPrimaryNetwork(ctx, r.Client, vmi.Namespace)
+	if err != nil {
+		return controllerruntime.Result{}, err
+	}
+
+	if primaryNetworkNAD != nil {
+		primaryNetworkConfig, err := config.NewConfig(primaryNetworkNAD.Spec.Config)
+		if err != nil {
+			r.Log.Error(err, "failed extracting the relevant NAD configuration",
+				"NAD name", client.ObjectKeyFromObject(primaryNetworkNAD))
+			return controllerruntime.Result{}, fmt.Errorf("failed to extract the relevant NAD information: %w", err)
+		}
+
+		if primaryNetworkConfig.AllowPersistentIPs {
+			claimKey := ipamclaim.GenerateName(vmi.Name, primaryNetworkConfig.Name)
+			ipamClaim := &ipamclaimsapi.IPAMClaim{
+				ObjectMeta: controllerruntime.ObjectMeta{
+					Name:            claimKey,
+					Namespace:       vmi.Namespace,
+					OwnerReferences: []metav1.OwnerReference{ownerInfo},
+					Finalizers:      []string{kubevirtVMFinalizer},
+					Labels:          ownedByVMLabel(vmi.Name),
+				},
+				Spec: ipamclaimsapi.IPAMClaimSpec{
+					Network: primaryNetworkNAD.Name,
+				},
+			}
+			if err := r.CreateIPAMClaim(ctx, ipamClaim, &ownerInfo); err != nil {
+				return controllerruntime.Result{}, err
+			}
+		}
+	}
+
 	vmiNetworks, err := r.vmiNetworksClaimingIPAM(ctx, vmi)
 	if err != nil {
 		return controllerruntime.Result{}, err
 	}
 
 	for logicalNetworkName, netConfigName := range vmiNetworks {
-		claimKey := fmt.Sprintf("%s.%s", vmi.Name, logicalNetworkName)
+		claimKey := ipamclaim.GenerateName(vmi.Name, logicalNetworkName)
 		ipamClaim := &ipamclaimsapi.IPAMClaim{
 			ObjectMeta: controllerruntime.ObjectMeta{
 				Name:            claimKey,
@@ -201,7 +236,8 @@ func (r *VirtualMachineInstanceReconciler) Cleanup(vmiKey apitypes.NamespacedNam
 	return nil
 }
 
-func (r *VirtualMachineReconciler) CreateIPAMClaim(ctx context.Context, ipamClaim *ipamclaimsapi.IPAMClaim, ownerInfo *metav1.OwnerReference) error {
+func (r *VirtualMachineInstanceReconciler) CreateIPAMClaim(ctx context.Context,
+	ipamClaim *ipamclaimsapi.IPAMClaim, ownerInfo *metav1.OwnerReference) error {
 	if err := r.Client.Create(ctx, ipamClaim, &client.CreateOptions{}); err != nil {
 		if apierrors.IsAlreadyExists(err) {
 			claimKey := apitypes.NamespacedName{