@@ -19,6 +19,7 @@ import (
19
19
clientgoscheme "k8s.io/client-go/kubernetes/scheme"
20
20
clusterv1 "sigs.k8s.io/cluster-api/api/v1beta1"
21
21
runtimehooksv1 "sigs.k8s.io/cluster-api/exp/runtime/hooks/api/v1alpha1"
22
+ "sigs.k8s.io/cluster-api/util"
22
23
ctrlclient "sigs.k8s.io/controller-runtime/pkg/client"
23
24
24
25
"github.com/nutanix-cloud-native/cluster-api-runtime-extensions-nutanix/api/v1alpha1"
@@ -462,6 +463,17 @@ var _ = Describe("Generate Image registry patches", func() {
462
463
client , err := helpers .TestEnv .GetK8sClientWithScheme (clientScheme )
463
464
gomega .Expect (err ).To (gomega .BeNil ())
464
465
466
+ // get the Cluster to use for the owner reference assertion
467
+ clusterKey := ctrlclient.ObjectKey {
468
+ Namespace : request .Namespace ,
469
+ Name : request .ClusterName ,
470
+ }
471
+ cluster := & clusterv1.Cluster {}
472
+ gomega .Expect (client .Get (
473
+ context .Background (),
474
+ clusterKey ,
475
+ cluster ,
476
+ )).To (gomega .BeNil ())
465
477
for _ , name := range []string {validSecretName , credentialSecretName (request .ClusterName )} {
466
478
key := ctrlclient.ObjectKey {
467
479
Namespace : request .Namespace ,
@@ -473,7 +485,16 @@ var _ = Describe("Generate Image registry patches", func() {
473
485
key ,
474
486
secret ,
475
487
)).To (gomega .BeNil ())
488
+
489
+ // assert the owner reference with the Cluster was added to the Secret
476
490
gomega .Expect (secret .OwnerReferences ).ToNot (gomega .BeEmpty ())
491
+ ownerRef := metav1.OwnerReference {
492
+ APIVersion : clusterv1 .GroupVersion .String (),
493
+ Kind : cluster .Kind ,
494
+ UID : cluster .UID ,
495
+ Name : cluster .Name ,
496
+ }
497
+ util .HasOwnerRef (secret .OwnerReferences , ownerRef )
477
498
}
478
499
}
479
500
})
0 commit comments