fix(vmip): fix double create VirtualMachineIPLease

Signed-off-by: Dmitry Lopatin <dmitry.lopatin@flant.com>

Author: LopatinDmitr

images/virtualization-artifact/pkg/controller/vmip/internal/iplease_handler.go

@@ -20,6 +20,7 @@ import (
 	"context"
 	"errors"
 	"fmt"
+	"time"
 
 	corev1 "k8s.io/api/core/v1"
 	metav1 "k8s.io/apimachinery/pkg/apis/meta/v1"
@@ -183,7 +184,7 @@ func (h IPLeaseHandler) createNewLease(ctx context.Context, state state.VMIPStat
 
 	h.recorder.Event(vmip, corev1.EventTypeNormal, virtv2.ReasonBound, "VirtualMachineIPAddress is bound to a new VirtualMachineIPAddressLease.")
 
-	return reconcile.Result{}, nil
+	return reconcile.Result{RequeueAfter: 2 * time.Second}, nil
 }
 
 func (h IPLeaseHandler) Name() string {

images/virtualization-artifact/pkg/controller/vmiplease/vmiplease_reconciler.go

@@ -109,10 +109,6 @@ func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reco
 		return h.Handle(ctx, s)
 	})
 	rec.SetResourceUpdater(func(ctx context.Context) error {
-		if s.ShouldDeletion() {
-			return r.client.Delete(ctx, lease.Changed())
-		}
-
 		if !reflect.DeepEqual(lease.Current().Spec, lease.Changed().Spec) {
 			leaseStatus := lease.Changed().Status.DeepCopy()
 			err = r.client.Update(ctx, lease.Changed())
@@ -122,7 +118,16 @@ func (r *Reconciler) Reconcile(ctx context.Context, req reconcile.Request) (reco
 			lease.Changed().Status = *leaseStatus
 		}
 
-		return lease.Update(ctx)
+		err = lease.Update(ctx)
+		if err != nil {
+			return err
+		}
+
+		if s.ShouldDeletion() {
+			return r.client.Delete(ctx, lease.Changed())
+		}
+
+		return nil
 	})
 
 	return rec.Reconcile(ctx)