in controllers/keycloakrealmrole/keycloakrealmrole_controller.go [87:139]
func (r *ReconcileKeycloakRealmRole) Reconcile(ctx context.Context, request reconcile.Request) (result reconcile.Result, resultErr error) {
log := ctrl.LoggerFrom(ctx)
log.Info("Reconciling KeycloakRealmRole")
var instance keycloakApi.KeycloakRealmRole
if err := r.client.Get(ctx, request.NamespacedName, &instance); err != nil {
if k8sErrors.IsNotFound(err) {
return
}
resultErr = errors.Wrap(err, "unable to get keycloak realm role from k8s")
return
}
if updated, err := r.applyDefaults(ctx, &instance); err != nil {
resultErr = fmt.Errorf("unable to apply default values: %w", err)
return
} else if updated {
return
}
defer func() {
if err := r.client.Status().Update(ctx, &instance); err != nil {
resultErr = err
}
}()
roleID, err := r.tryReconcile(ctx, &instance)
if err != nil {
if errors.Is(err, helper.ErrKeycloakIsNotAvailable) {
return ctrl.Result{
RequeueAfter: helper.RequeueOnKeycloakNotAvailablePeriod,
}, nil
}
instance.Status.Value = err.Error()
result.RequeueAfter = r.helper.SetFailureCount(&instance)
log.Error(err, "an error has occurred while handling keycloak realm role", "name",
request.Name)
return
}
helper.SetSuccessStatus(&instance)
instance.Status.ID = roleID
result.RequeueAfter = r.successReconcileTimeout
log.Info("Reconciling done")
return
}