func()

in pkg/datasource/k8s/controllers/systemrules_controller.go [48:103]

• 51 lines of code
• 8 McCabe index (conditional complexity)

func (r *SystemRulesReconciler) Reconcile(req ctrl.Request) (ctrl.Result, error) {
	ctx := context.Background()
	log := r.Logger.WithValues("expectedNamespace", r.Namespace, "expectedCrName", r.ExpectedCrName, "req", req.String())

	if req.Namespace != r.Namespace {
		log.V(int(logging.DebugLevel)).Info("ignore unmatched namespace")
		return ctrl.Result{
			Requeue:      false,
			RequeueAfter: 0,
		}, nil
	}

	if req.Name != r.ExpectedCrName {
		return ctrl.Result{
			Requeue:      false,
			RequeueAfter: 0,
		}, nil
	}

	systemRulesCR := &datasourcev1.SystemRules{}
	if err := r.Get(ctx, req.NamespacedName, systemRulesCR); err != nil {
		k8sApiErr, ok := err.(*k8sApiError.StatusError)
		if !ok {
			log.Error(err, "Fail to get datasourcev1.SystemRules.")
			return ctrl.Result{
				Requeue:      false,
				RequeueAfter: 0,
			}, nil
		}
		if k8sApiErr.Status().Code != http.StatusNotFound {
			log.Error(err, "Fail to get datasourcev1.SystemRules.")
			return ctrl.Result{
				Requeue:      false,
				RequeueAfter: 0,
			}, nil
		}
		log.Info("datasourcev1.SystemRules had been deleted.")
		systemRulesCR = nil
	}

	var systemRules []*system.Rule
	if systemRulesCR == nil {
		log.Info("Receive datasourcev1.SystemRules", "rules:", systemRulesCR.Spec.Rules)
		systemRules = r.assembleSystemRules(systemRulesCR)
	}

	_, err := system.LoadRules(systemRules)
	if err != nil {
		log.Error(err, "Fail to Load system.Rules")
		return ctrl.Result{
			Requeue:      false,
			RequeueAfter: 0,
		}, err
	}
	return ctrl.Result{}, nil
}