Skip to content

Commit c484da9

Browse files
committed
fix tests broken by CAPI upgrade
1 parent 39a7852 commit c484da9

File tree

3 files changed

+33
-3
lines changed

3 files changed

+33
-3
lines changed

internal/controller/linodecluster_controller_test.go

Lines changed: 21 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -63,6 +63,9 @@ var _ = Describe("cluster-lifecycle", Ordered, Label("cluster", "cluster-lifecyc
6363
linodeCluster := infrav1alpha2.LinodeCluster{
6464
ObjectMeta: metadata,
6565
Spec: infrav1alpha2.LinodeClusterSpec{
66+
ControlPlaneEndpoint: clusterv1.APIEndpoint{
67+
Port: int32(controlPlaneEndpointPort),
68+
},
6669
Region: "us-ord",
6770
VPCRef: &corev1.ObjectReference{Name: "vpctest", Namespace: defaultNamespace},
6871
},
@@ -371,6 +374,10 @@ var _ = Describe("cluster-lifecycle-dns", Ordered, Label("cluster", "cluster-lif
371374
ObjectMeta: metadata,
372375
Spec: infrav1alpha2.LinodeClusterSpec{
373376
Region: "us-ord",
377+
ControlPlaneEndpoint: clusterv1.APIEndpoint{
378+
Host: controlPlaneEndpointHost,
379+
Port: int32(controlPlaneEndpointPort),
380+
},
374381
Network: infrav1alpha2.NetworkSpec{
375382
LoadBalancerType: "dns",
376383
DNSRootDomain: "lkedevs.net",
@@ -621,11 +628,21 @@ var _ = Describe("dns-override-endpoint", Ordered, Label("cluster", "dns-overrid
621628
}
622629
cluster := clusterv1.Cluster{
623630
ObjectMeta: metadata,
631+
Spec: clusterv1.ClusterSpec{
632+
ControlPlaneEndpoint: clusterv1.APIEndpoint{
633+
Host: controlPlaneEndpointHost,
634+
Port: int32(controlPlaneEndpointPort),
635+
},
636+
},
624637
}
625638
linodeCluster := infrav1alpha2.LinodeCluster{
626639
ObjectMeta: metadata,
627640
Spec: infrav1alpha2.LinodeClusterSpec{
628641
Region: "us-ord",
642+
ControlPlaneEndpoint: clusterv1.APIEndpoint{
643+
Host: controlPlaneEndpointHost,
644+
Port: int32(controlPlaneEndpointPort),
645+
},
629646
Network: infrav1alpha2.NetworkSpec{
630647
ApiserverLoadBalancerPort: controlPlaneEndpointPort,
631648
LoadBalancerType: "dns",
@@ -744,7 +761,10 @@ var _ = Describe("cluster-with-direct-vpcid", Ordered, Label("cluster", "direct-
744761
ObjectMeta: metadata,
745762
Spec: infrav1alpha2.LinodeClusterSpec{
746763
Region: "us-ord",
747-
VPCID: ptr.To(12345),
764+
ControlPlaneEndpoint: clusterv1.APIEndpoint{
765+
Port: 6443,
766+
},
767+
VPCID: ptr.To(12345),
748768
},
749769
}
750770

internal/controller/linodemachine_controller_test.go

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -72,6 +72,9 @@ var _ = Describe("create", Label("machine", "create"), func() {
7272
Namespace: defaultNamespace,
7373
},
7474
Spec: infrav1alpha2.LinodeClusterSpec{
75+
ControlPlaneEndpoint: clusterv1.APIEndpoint{
76+
Port: 6443,
77+
},
7578
Network: infrav1alpha2.NetworkSpec{
7679
NodeBalancerID: ptr.To(1),
7780
ApiserverNodeBalancerConfigID: ptr.To(2),
@@ -1319,6 +1322,9 @@ var _ = Describe("machine-lifecycle", Ordered, Label("machine", "machine-lifecyc
13191322
Labels: make(map[string]string),
13201323
},
13211324
Spec: infrav1alpha2.LinodeClusterSpec{
1325+
ControlPlaneEndpoint: clusterv1.APIEndpoint{
1326+
Port: 6443,
1327+
},
13221328
Network: infrav1alpha2.NetworkSpec{
13231329
NodeBalancerID: ptr.To(1),
13241330
ApiserverNodeBalancerConfigID: ptr.To(2),
@@ -1640,6 +1646,9 @@ var _ = Describe("machine-update", Ordered, Label("machine", "machine-update"),
16401646
Labels: make(map[string]string),
16411647
},
16421648
Spec: infrav1alpha2.LinodeClusterSpec{
1649+
ControlPlaneEndpoint: clusterv1.APIEndpoint{
1650+
Port: 6443,
1651+
},
16431652
Network: infrav1alpha2.NetworkSpec{
16441653
NodeBalancerID: ptr.To(1),
16451654
ApiserverNodeBalancerConfigID: ptr.To(2),

util/helpers.go

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -105,14 +105,15 @@ func IsLinodePrivateIP(ipAddress string) bool {
105105
func SetOwnerReferenceToLinodeCluster(ctx context.Context, k8sclient client.Client, cluster *clusterv1.Cluster, obj client.Object, scheme *runtime.Scheme) error {
106106
logger := log.Log.WithName("SetOwnerReferenceToLinodeCluster")
107107

108-
if cluster == nil {
108+
if cluster == nil || cluster.Spec.InfrastructureRef.Name == "" {
109109
logger.Info("the Cluster is nil, cannot fetch LinodeCluster")
110110
return nil
111111
}
112112

113113
var linodeCluster infrav1alpha2.LinodeCluster
114114
key := types.NamespacedName{
115-
Name: cluster.Spec.InfrastructureRef.Name,
115+
Name: cluster.Spec.InfrastructureRef.Name,
116+
Namespace: cluster.Namespace,
116117
}
117118
if err := k8sclient.Get(ctx, key, &linodeCluster); err != nil {
118119
if client.IgnoreNotFound(err) != nil {

0 commit comments

Comments
 (0)