Traits: Only reconcile after onboarding and before decomissioning

As with 6bb6c6 for the aggregates:

Traits set by the operator may conflict with the testing,
and decomissioning may make the resource-provider disappear.
To avoid these controllers fighting, let's limit this controller
to the actual active lifetime of the hypervisor.

Unfortunately, that means we have to reconcile on every status update.

Author: fwiesel

internal/controller/traits_controller.go

@@ -30,7 +30,6 @@ import (
 	ctrl "sigs.k8s.io/controller-runtime"
 	k8sclient "sigs.k8s.io/controller-runtime/pkg/client"
 	logger "sigs.k8s.io/controller-runtime/pkg/log"
-	"sigs.k8s.io/controller-runtime/pkg/predicate"
 
 	"github.com/gophercloud/gophercloud/v2"
 	"github.com/gophercloud/gophercloud/v2/openstack/placement/v1/resourceproviders"
@@ -73,6 +72,11 @@ func (tc *TraitsController) Reconcile(ctx context.Context, req ctrl.Request) (ct
 		return ctrl.Result{RequeueAfter: 10 * time.Second}, nil
 	}
 
+	if !meta.IsStatusConditionFalse(hv.Status.Conditions, ConditionTypeOnboarding) ||
+		meta.IsStatusConditionTrue(hv.Status.Conditions, kvmv1.ConditionTypeTerminating) {
+		return ctrl.Result{}, nil
+	}
+
 	customTraitsApplied := slices.Collect(func(yield func(string) bool) {
 		for _, trait := range hv.Status.Traits {
 			if strings.HasPrefix(trait, customPrefix) && !yield(trait) {
@@ -178,6 +182,5 @@ func (tc *TraitsController) SetupWithManager(mgr ctrl.Manager) error {
 	return ctrl.NewControllerManagedBy(mgr).
 		Named(TraitsControllerName).
 		For(&kvmv1.Hypervisor{}).
-		WithEventFilter(predicate.GenerationChangedPredicate{}).
 		Complete(tc)
 }

internal/controller/traits_controller_test.go

@@ -63,6 +63,7 @@ var _ = Describe("TraitsController", func() {
 	BeforeEach(func(ctx context.Context) {
 		By("Setting up the OpenStack http mock server")
 		fakeServer = testhelper.SetupHTTP()
+		DeferCleanup(fakeServer.Teardown)
 
 		By("Creating the TraitsController")
 		tc = &TraitsController{
@@ -89,19 +90,21 @@ var _ = Describe("TraitsController", func() {
 			Status: v1.ConditionTrue,
 			Reason: "UnitTest",
 		})
+		meta.SetStatusCondition(&hypervisor.Status.Conditions, v1.Condition{
+			Type:   ConditionTypeOnboarding,
+			Status: v1.ConditionFalse,
+			Reason: "UnitTest",
+		})
 		hypervisor.Status.Traits = []string{"CUSTOM_FOO", "HW_CPU_X86_VMX"}
 		hypervisor.Status.HypervisorID = "1234"
 		Expect(k8sClient.Status().Update(ctx, hypervisor)).To(Succeed())
-	})
-
-	AfterEach(func() {
-		By("Deleting the Hypervisor resource")
-		hypervisor := &kvmv1.Hypervisor{}
-		Expect(tc.Client.Get(ctx, types.NamespacedName{Name: "hv-test", Namespace: "default"}, hypervisor)).To(Succeed())
-		Expect(tc.Client.Delete(ctx, hypervisor)).To(Succeed())
 
-		By("Tearing down the OpenStack http mock server")
-		fakeServer.Teardown()
+		DeferCleanup(func(ctx context.Context) {
+			By("Deleting the Hypervisor resource")
+			hypervisor := &kvmv1.Hypervisor{}
+			Expect(tc.Client.Get(ctx, types.NamespacedName{Name: "hv-test", Namespace: "default"}, hypervisor)).To(Succeed())
+			Expect(tc.Client.Delete(ctx, hypervisor)).To(Succeed())
+		})
 	})
 
 	// Tests