Skip to content

Commit e80352b

Browse files
committed
chore(test): improve knative kamelet binding test
1 parent cd14935 commit e80352b

File tree

2 files changed

+11
-18
lines changed

2 files changed

+11
-18
lines changed

e2e/global/knative/kamelet_test.go

Lines changed: 4 additions & 18 deletions
Original file line numberDiff line numberDiff line change
@@ -42,6 +42,7 @@ func TestKameletChange(t *testing.T) {
4242
WithNewTestNamespace(t, func(ns string) {
4343
operatorID := "camel-k-kamelet-change"
4444
timerSource := "my-timer-source"
45+
4546
Expect(KamelInstallWithID(operatorID, ns).Execute()).To(Succeed())
4647
Expect(CreateTimerKamelet(ns, timerSource)()).To(Succeed())
4748
Expect(CreateKnativeChannel(ns, "messages")()).To(Succeed())
@@ -66,44 +67,29 @@ func TestKameletChange(t *testing.T) {
6667
"trait.camel.apache.org/health.readiness-initial-delay": "10",
6768
}
6869

70+
// Create the KameletBinding
6971
Expect(BindKameletTo(ns, timerBinding, annotations, from, to, map[string]string{"message": "message is Hello"}, map[string]string{})()).To(Succeed())
7072

71-
Eventually(KameletBindingConditionStatus(ns, timerBinding, v1alpha1.KameletBindingConditionReady), TestTimeoutShort).Should(Equal(corev1.ConditionFalse))
72-
Eventually(KameletBindingCondition(ns, timerBinding, v1alpha1.KameletBindingConditionReady), TestTimeoutMedium).Should(And(
73-
WithTransform(KameletBindingConditionReason, Equal(v1.IntegrationConditionDeploymentProgressingReason)),
74-
WithTransform(KameletBindingConditionMessage, Or(
75-
Equal("0/1 updated replicas"),
76-
Equal("0/1 ready replicas"),
77-
))))
78-
7973
Eventually(IntegrationPodPhase(ns, timerBinding), TestTimeoutLong).Should(Equal(corev1.PodRunning))
8074
Eventually(IntegrationConditionStatus(ns, "timer-binding", v1.IntegrationConditionReady), TestTimeoutShort).Should(Equal(corev1.ConditionTrue))
8175
Eventually(IntegrationLogs(ns, "display"), TestTimeoutShort).Should(ContainSubstring("message is Hello"))
8276

83-
Eventually(KameletBindingConditionStatus(ns, timerBinding, v1alpha1.KameletBindingConditionReady), TestTimeoutShort).Should(Equal(corev1.ConditionTrue))
8477
Eventually(KameletBindingCondition(ns, timerBinding, v1alpha1.KameletBindingConditionReady), TestTimeoutMedium).Should(And(
78+
WithTransform(KameletBindingConditionStatusExtract, Equal(corev1.ConditionTrue)),
8579
WithTransform(KameletBindingConditionReason, Equal(v1.IntegrationConditionDeploymentReadyReason)),
8680
WithTransform(KameletBindingConditionMessage, Equal(fmt.Sprintf("1/1 ready replicas"))),
8781
))
8882

8983
// Update the KameletBinding
9084
Expect(BindKameletTo(ns, "timer-binding", annotations, from, to, map[string]string{"message": "message is Hi"}, map[string]string{})()).To(Succeed())
9185

92-
Eventually(KameletBindingConditionStatus(ns, timerBinding, v1alpha1.KameletBindingConditionReady), TestTimeoutShort).Should(Equal(corev1.ConditionFalse))
93-
Eventually(KameletBindingCondition(ns, timerBinding, v1alpha1.KameletBindingConditionReady), TestTimeoutMedium).Should(And(
94-
WithTransform(KameletBindingConditionReason, Equal(v1.IntegrationConditionDeploymentProgressingReason)),
95-
WithTransform(KameletBindingConditionMessage, Or(
96-
Equal("0/1 updated replicas"),
97-
Equal("0/1 ready replicas"),
98-
))))
99-
10086
Eventually(IntegrationPodPhase(ns, "timer-binding"), TestTimeoutLong).Should(Equal(corev1.PodRunning))
10187
Eventually(IntegrationConditionStatus(ns, "timer-binding", v1.IntegrationConditionReady), TestTimeoutShort).Should(Equal(corev1.ConditionTrue))
10288
Eventually(IntegrationLogs(ns, "display"), TestTimeoutShort).Should(ContainSubstring("message is Hi"))
10389

104-
Eventually(KameletBindingConditionStatus(ns, timerBinding, v1alpha1.KameletBindingConditionReady), TestTimeoutShort).Should(Equal(corev1.ConditionTrue))
10590
Eventually(KameletBindingCondition(ns, timerBinding, v1alpha1.KameletBindingConditionReady), TestTimeoutMedium).
10691
Should(And(
92+
WithTransform(KameletBindingConditionStatusExtract, Equal(corev1.ConditionTrue)),
10793
WithTransform(KameletBindingConditionReason, Equal(v1.IntegrationConditionDeploymentReadyReason)),
10894
WithTransform(KameletBindingConditionMessage, Equal("1/1 ready replicas")),
10995
))

e2e/support/test_support.go

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1089,6 +1089,13 @@ func KameletBindingCondition(ns string, name string, conditionType v1alpha1.Kame
10891089
}
10901090
}
10911091

1092+
func KameletBindingConditionStatusExtract(c *v1alpha1.KameletBindingCondition) corev1.ConditionStatus {
1093+
if c == nil {
1094+
return ""
1095+
}
1096+
return c.Status
1097+
}
1098+
10921099
func KameletBindingConditionReason(c *v1alpha1.KameletBindingCondition) string {
10931100
if c == nil {
10941101
return ""

0 commit comments

Comments
 (0)