Skip to content

Commit

Permalink
.
Browse files Browse the repository at this point in the history
  • Loading branch information
kerenlahav committed Dec 8, 2024
1 parent 0bb2585 commit ee6c04f
Showing 1 changed file with 7 additions and 10 deletions.
17 changes: 7 additions & 10 deletions controllers/serviceinstance_controller.go
Original file line number Diff line number Diff line change
Expand Up @@ -83,6 +83,9 @@ func (r *ServiceInstanceReconciler) Reconcile(ctx context.Context, req ctrl.Requ
}
serviceInstance = serviceInstance.DeepCopy()

if utils.IsMarkedForDeletion(serviceInstance.ObjectMeta) {
return r.deleteInstance(ctx, serviceInstance)
}
if len(serviceInstance.GetConditions()) == 0 {
err := utils.InitConditions(ctx, r.Client, serviceInstance)
if err != nil {
Expand All @@ -102,10 +105,6 @@ func (r *ServiceInstanceReconciler) Reconcile(ctx context.Context, req ctrl.Requ
return ctrl.Result{}, nil
}

if utils.IsMarkedForDeletion(serviceInstance.ObjectMeta) {
return r.deleteInstance(ctx, serviceInstance)
}

if len(serviceInstance.Status.OperationURL) > 0 {
// ongoing operation - poll status from SM
return r.poll(ctx, serviceInstance)
Expand Down Expand Up @@ -264,6 +263,7 @@ func (r *ServiceInstanceReconciler) updateInstance(ctx context.Context, smClient
func (r *ServiceInstanceReconciler) deleteInstance(ctx context.Context, serviceInstance *v1.ServiceInstance) (ctrl.Result, error) {
log := utils.GetLogger(ctx)

log.Info("deleting instance")
if controllerutil.ContainsFinalizer(serviceInstance, common.FinalizerName) {
smClient, err := r.GetSMClient(ctx, serviceInstance)
if err != nil {
Expand Down Expand Up @@ -625,10 +625,7 @@ func (r *ServiceInstanceReconciler) buildSMRequestParameters(ctx context.Context

func isFinalState(ctx context.Context, serviceInstance *v1.ServiceInstance) bool {
log := utils.GetLogger(ctx)
if utils.IsMarkedForDeletion(serviceInstance.ObjectMeta) {
log.Info("instance is not in final state, it is marked for deletion")
return false
}

if len(serviceInstance.Status.OperationURL) > 0 {
log.Info(fmt.Sprintf("instance is not in final state, async operation is in progress (%s)", serviceInstance.Status.OperationURL))
return false
Expand All @@ -652,7 +649,7 @@ func isFinalState(ctx context.Context, serviceInstance *v1.ServiceInstance) bool
}
return false
}
if serviceInstance.Spec.SubscribeToSecretChanges != nil && *serviceInstance.Spec.SubscribeToSecretChanges && serviceInstance.Status.ForceReconcile {
if serviceInstance.Status.ForceReconcile {
log.Info("instance is not in final state, SubscribeToSecretChanges is true")
return false
}
Expand All @@ -670,7 +667,7 @@ func updateRequired(serviceInstance *v1.ServiceInstance) bool {
if cond != nil && cond.Reason == common.UpdateInProgress { //in case of transient error occurred
return true
}
if serviceInstance.Spec.SubscribeToSecretChanges != nil && *serviceInstance.Spec.SubscribeToSecretChanges && serviceInstance.Status.ForceReconcile {
if serviceInstance.Status.ForceReconcile {
return true
}

Expand Down

0 comments on commit ee6c04f

Please sign in to comment.