Skip to content

Commit 729533a

Browse files
committed
fix(?) LC controller test
1 parent 194943e commit 729533a

File tree

1 file changed

+17
-15
lines changed

1 file changed

+17
-15
lines changed

internal/controller/linodecluster_controller_test.go

Lines changed: 17 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -118,6 +118,18 @@ var _ = Describe("cluster-lifecycle", Ordered, Label("cluster", "cluster-lifecyc
118118
ctlrSuite.Run(
119119
OneOf(
120120
Path(
121+
Path(
122+
Call("vpc doesn't exist", func(ctx context.Context, mck Mock) {
123+
}),
124+
OneOf(
125+
Path(Result("", func(ctx context.Context, mck Mock) {
126+
reconciler.Client = k8sClient
127+
_, err := reconciler.reconcile(ctx, cScope, mck.Logger())
128+
Expect(err).NotTo(HaveOccurred())
129+
Expect(linodeCluster.GetCondition(ConditionPreflightLinodeVPCReady).Status).To(Equal(metav1.ConditionFalse))
130+
})),
131+
),
132+
),
121133
Call("vpc present but not ready", func(ctx context.Context, mck Mock) {
122134
Expect(k8sClient.Create(ctx, &linodeVPC)).To(Succeed())
123135
linodeVPC.Status.Ready = false
@@ -139,6 +151,9 @@ var _ = Describe("cluster-lifecycle", Ordered, Label("cluster", "cluster-lifecyc
139151
Path(
140152
Call("firewall doesn't exist", func(ctx context.Context, mck Mock) {
141153
cScope.LinodeCluster.Spec.NodeBalancerFirewallRef = &corev1.ObjectReference{Name: "firewalltest"}
154+
Expect(k8sClient.Create(ctx, &linodeVPC)).To(Succeed())
155+
linodeVPC.Status.Ready = true
156+
Expect(k8sClient.Status().Update(ctx, &linodeVPC)).To(Succeed())
142157
}),
143158
Result("", func(ctx context.Context, mck Mock) {
144159
reconciler.Client = k8sClient
@@ -155,9 +170,8 @@ var _ = Describe("cluster-lifecycle", Ordered, Label("cluster", "cluster-lifecyc
155170
Path(
156171
Call("firewall present but not ready", func(ctx context.Context, mck Mock) {
157172
cScope.LinodeCluster.Spec.NodeBalancerFirewallRef = &corev1.ObjectReference{Name: "firewalltest"}
158-
Expect(k8sClient.Create(ctx, &linodeFirewall)).To(Succeed())
159173
linodeFirewall.Spec.FirewallID = nil
160-
k8sClient.Update(ctx, &linodeFirewall)
174+
Expect(k8sClient.Create(ctx, &linodeFirewall)).To(Succeed())
161175
}),
162176
Result("", func(ctx context.Context, mck Mock) {
163177
reconciler.Client = k8sClient
@@ -166,18 +180,6 @@ var _ = Describe("cluster-lifecycle", Ordered, Label("cluster", "cluster-lifecyc
166180
Expect(linodeCluster.GetCondition(ConditionPreflightLinodeNBFirewallReady).Status).To(Equal(metav1.ConditionFalse))
167181
}),
168182
),
169-
Path(
170-
Call("vpc doesn't exist", func(ctx context.Context, mck Mock) {
171-
}),
172-
OneOf(
173-
Path(Result("", func(ctx context.Context, mck Mock) {
174-
reconciler.Client = k8sClient
175-
_, err := reconciler.reconcile(ctx, cScope, mck.Logger())
176-
Expect(err).NotTo(HaveOccurred())
177-
Expect(linodeCluster.GetCondition(ConditionPreflightLinodeVPCReady).Status).To(Equal(metav1.ConditionFalse))
178-
})),
179-
),
180-
),
181183
Path(
182184
Call("cluster is not created because there was an error creating nb", func(ctx context.Context, mck Mock) {
183185
cScope.LinodeClient = mck.LinodeClient
@@ -188,7 +190,7 @@ var _ = Describe("cluster-lifecycle", Ordered, Label("cluster", "cluster-lifecyc
188190
// Create and mark firewall as ready if using firewall ref
189191
if cScope.LinodeCluster.Spec.NodeBalancerFirewallRef != nil {
190192
linodeFirewall.Spec.FirewallID = util.Pointer(123)
191-
k8sClient.Update(ctx, &linodeFirewall)
193+
Expect(k8sClient.Update(ctx, &linodeFirewall)).To(Succeed())
192194
}
193195

194196
// If using direct firewall ID

0 commit comments

Comments
 (0)