Remove generated names from error messages to reduce reconciliation

Signed-off-by: killianmuldoon <[email protected]>

Author: killianmuldoon

internal/controllers/topology/cluster/reconcile_state.go

@@ -242,7 +242,7 @@ func (r *Reconciler) reconcileControlPlane(ctx context.Context, s *scope.Scope)
 
 		// Reconcile the current and desired state of the MachineHealthCheck.
 		if err := r.reconcileMachineHealthCheck(ctx, s.Current.ControlPlane.MachineHealthCheck, s.Desired.ControlPlane.MachineHealthCheck); err != nil {
-			return errors.Wrapf(err, "failed to update %s", tlog.KObj{Obj: s.Desired.ControlPlane.MachineHealthCheck})
+			return err
 		}
 	}
 	return nil
@@ -269,7 +269,7 @@ func (r *Reconciler) reconcileMachineHealthCheck(ctx context.Context, current, d
 
 		log.Infof("Creating %s", tlog.KObj{Obj: desired})
 		if err := r.Client.Create(ctx, desired); err != nil {
-			return errors.Wrapf(err, "failed to create %s", tlog.KObj{Obj: desired})
+			return createErrorWithoutObjectName(err, desired)
 		}
 		r.recorder.Eventf(desired, corev1.EventTypeNormal, createEventReason, "Created %q", tlog.KObj{Obj: desired})
 		return nil
@@ -403,21 +403,21 @@ func (r *Reconciler) createMachineDeployment(ctx context.Context, cluster *clust
 		cluster: cluster,
 		desired: md.InfrastructureMachineTemplate,
 	}); err != nil {
-		return errors.Wrapf(err, "failed to create %s", tlog.KObj{Obj: md.Object})
+		return errors.Wrapf(createErrorWithoutObjectName(err, md.InfrastructureMachineTemplate), "failed to create %s", md.Object.Kind)
 	}
 
 	bootstrapCtx, _ := log.WithObject(md.BootstrapTemplate).Into(ctx)
 	if err := r.reconcileReferencedTemplate(bootstrapCtx, reconcileReferencedTemplateInput{
 		cluster: cluster,
 		desired: md.BootstrapTemplate,
 	}); err != nil {
-		return errors.Wrapf(err, "failed to create %s", tlog.KObj{Obj: md.Object})
+		return errors.Wrapf(createErrorWithoutObjectName(err, md.BootstrapTemplate), "failed to create %s", md.Object.Kind)
 	}
 
 	log = log.WithObject(md.Object)
 	log.Infof(fmt.Sprintf("Creating %s", tlog.KObj{Obj: md.Object}))
 	if err := r.Client.Create(ctx, md.Object.DeepCopy()); err != nil {
-		return errors.Wrapf(err, "failed to create %s", tlog.KObj{Obj: md.Object})
+		return createErrorWithoutObjectName(err, md.Object)
 	}
 	r.recorder.Eventf(cluster, corev1.EventTypeNormal, createEventReason, "Created %q", tlog.KObj{Obj: md.Object})
 
@@ -429,7 +429,7 @@ func (r *Reconciler) createMachineDeployment(ctx context.Context, cluster *clust
 			*ownerReferenceTo(md.Object),
 		})
 		if err := r.reconcileMachineHealthCheck(ctx, nil, md.MachineHealthCheck); err != nil {
-			return errors.Wrapf(err, "failed to create %s", tlog.KObj{Obj: md.MachineHealthCheck})
+			return err
 		}
 	}
 	return nil
@@ -587,7 +587,7 @@ func (r *Reconciler) reconcileReferencedObject(ctx context.Context, in reconcile
 			return errors.Wrapf(err, "failed to create a copy of %s with the managed field annotation", tlog.KObj{Obj: in.desired})
 		}
 		if err := r.Client.Create(ctx, desiredWithManagedFieldAnnotation); err != nil {
-			return errors.Wrapf(err, "failed to create %s", tlog.KObj{Obj: desiredWithManagedFieldAnnotation})
+			return createErrorWithoutObjectName(err, desiredWithManagedFieldAnnotation)
 		}
 		r.recorder.Eventf(in.cluster, corev1.EventTypeNormal, createEventReason, "Created %q", tlog.KObj{Obj: in.desired})
 		return nil
@@ -664,7 +664,7 @@ func (r *Reconciler) reconcileReferencedTemplate(ctx context.Context, in reconci
 			return errors.Wrapf(err, "failed to create a copy of %s with the managed field annotation", tlog.KObj{Obj: in.desired})
 		}
 		if err := r.Client.Create(ctx, desiredWithManagedFieldAnnotation); err != nil {
-			return errors.Wrapf(err, "failed to create %s", tlog.KObj{Obj: desiredWithManagedFieldAnnotation})
+			return createErrorWithoutObjectName(err, desiredWithManagedFieldAnnotation)
 		}
 		r.recorder.Eventf(in.cluster, corev1.EventTypeNormal, createEventReason, "Created %q", tlog.KObj{Obj: in.desired})
 		return nil
@@ -716,7 +716,7 @@ func (r *Reconciler) reconcileReferencedTemplate(ctx context.Context, in reconci
 		return errors.Wrapf(err, "failed to create a copy of %s with the managed field annotation", tlog.KObj{Obj: in.desired})
 	}
 	if err := r.Client.Create(ctx, desiredWithManagedFieldAnnotation); err != nil {
-		return errors.Wrapf(err, "failed to create %s", tlog.KObj{Obj: desiredWithManagedFieldAnnotation})
+		return createErrorWithoutObjectName(err, desiredWithManagedFieldAnnotation)
 	}
 	r.recorder.Eventf(in.cluster, corev1.EventTypeNormal, createEventReason, "Created %q as a replacement for %q (template rotation)", tlog.KObj{Obj: in.desired}, in.ref.Name)
 
@@ -727,3 +727,24 @@ func (r *Reconciler) reconcileReferencedTemplate(ctx context.Context, in reconci
 
 	return nil
 }
+
+// CreateError removes details about the specific name of the object from the Error message. The full names include a hash
+// Cluster conditions.
+func createErrorWithoutObjectName(err error, obj client.Object) error {
+	out := ""
+	var statusError *apierrors.StatusError
+	if errors.As(err, &statusError) {
+		if statusError.Status().Details != nil {
+			for _, cause := range statusError.Status().Details.Causes {
+				out = fmt.Sprintf("%s %s: %s: %s", out, cause.Type, cause.Field, cause.Message)
+			}
+			out = fmt.Sprintf("%s.%s: %s.", statusError.Status().Details.Kind, statusError.Status().Details.Group, out)
+		}
+
+		// Replace the statusError message with the constructed message.
+		statusError.ErrStatus.Message = fmt.Sprintf("failed to create %s", out)
+		return statusError
+	}
+	// If this isn't a StatusError return a more generic error with the object details.
+	return errors.Wrapf(err, "failed to create %s", tlog.KObj{Obj: obj})
+}

internal/controllers/topology/cluster/reconcile_state_test.go

@@ -19,6 +19,7 @@ package cluster
 import (
 	"context"
 	"fmt"
+	"net/http"
 	"regexp"
 	"testing"
 	"time"
@@ -2081,3 +2082,51 @@ func TestReconciler_reconcileMachineHealthCheck(t *testing.T) {
 		})
 	}
 }
+
+func Test_createErrorWithoutObjectName(t *testing.T) {
+	originalError := &apierrors.StatusError{
+		ErrStatus: metav1.Status{
+			Status:  metav1.StatusFailure,
+			Code:    http.StatusUnprocessableEntity,
+			Reason:  metav1.StatusReasonInvalid,
+			Message: "DockerMachineTemplate.infrastructure.cluster.x-k8s.io \"docker-template-one\" is invalid: spec.template.spec.preLoadImages: Invalid value: \"array\": spec.template.spec.preLoadImages in body must be of type string: \"array\"",
+			Details: &metav1.StatusDetails{
+				Group: "infrastructure.cluster.x-k8s.io",
+				Kind:  "DockerMachineTemplate",
+				Name:  "docker-template-one",
+				Causes: []metav1.StatusCause{
+					{
+						Type:    "FieldValueInvalid",
+						Message: "Invalid value: \"array\": spec.template.spec.preLoadImages in body must be of type string: \"array\"",
+						Field:   "spec.template.spec.preLoadImages",
+					},
+				},
+			},
+		}}
+	wantError := &apierrors.StatusError{
+		ErrStatus: metav1.Status{
+			Status: metav1.StatusFailure,
+			Code:   http.StatusUnprocessableEntity,
+			Reason: metav1.StatusReasonInvalid,
+			// The only difference between the two objects should be in the Message section.
+			Message: "failed to create DockerMachineTemplate.infrastructure.cluster.x-k8s.io:  FieldValueInvalid: spec.template.spec.preLoadImages: Invalid value: \"array\": spec.template.spec.preLoadImages in body must be of type string: \"array\".",
+			Details: &metav1.StatusDetails{
+				Group: "infrastructure.cluster.x-k8s.io",
+				Kind:  "DockerMachineTemplate",
+				Name:  "docker-template-one",
+				Causes: []metav1.StatusCause{
+					{
+						Type:    "FieldValueInvalid",
+						Message: "Invalid value: \"array\": spec.template.spec.preLoadImages in body must be of type string: \"array\"",
+						Field:   "spec.template.spec.preLoadImages",
+					},
+				},
+			},
+		},
+	}
+	t.Run("Transform a create error correctly", func(t *testing.T) {
+		g := NewWithT(t)
+		err := createErrorWithoutObjectName(originalError, nil)
+		g.Expect(err).To(Equal(wantError), cmp.Diff(err, wantError))
+	})
+}