Add tests for database and distributed architecture

Signed-off-by: Dmitry Tantsur <[email protected]>

Author: dtantsur

test/suite_test.go

@@ -83,7 +83,7 @@ var _ = BeforeSuite(func() {
 
 })
 
-func WaitForIronic(name types.NamespacedName) *metal3api.Ironic {
+func WaitForIronic(name types.NamespacedName, distributed bool) *metal3api.Ironic {
 	GinkgoHelper()
 
 	ironic := &metal3api.Ironic{}
@@ -98,8 +98,19 @@ func WaitForIronic(name types.NamespacedName) *metal3api.Ironic {
 		if cond != nil && cond.Status == metav1.ConditionTrue {
 			return true
 		}
-
 		GinkgoWriter.Printf("Current status of Ironic: %+v\n", ironic)
+
+		serviceName := fmt.Sprintf("%s-service", name.Name)
+		if distributed {
+			deploy, err := clientset.AppsV1().DaemonSets(name.Namespace).Get(ctx, serviceName, metav1.GetOptions{})
+			Expect(err).NotTo(HaveOccurred())
+			GinkgoWriter.Printf("... status of DaemonSet: %+v\n", deploy)
+		} else {
+			deploy, err := clientset.AppsV1().Deployments(name.Namespace).Get(ctx, serviceName, metav1.GetOptions{})
+			Expect(err).NotTo(HaveOccurred())
+			GinkgoWriter.Printf("... status of Deployment: %+v\n", deploy)
+		}
+
 		return false
 	}).WithTimeout(15 * time.Minute).WithPolling(10 * time.Second).Should(BeTrue())
 
@@ -180,7 +191,45 @@ var _ = Describe("Ironic object tests", func() {
 			DeleteAndWait(ironic)
 		})
 
-		ironic = WaitForIronic(name)
+		ironic = WaitForIronic(name, false)
+		VerifyIronic(ironic)
+	})
+
+	It("creates distributed Ironic", func() {
+		name := types.NamespacedName{
+			Name:      "test-ironic",
+			Namespace: namespace,
+		}
+
+		ironicDb := &metal3api.IronicDatabase{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      fmt.Sprintf("%s-db", name.Name),
+				Namespace: name.Namespace,
+			},
+		}
+
+		err := k8sClient.Create(ctx, ironicDb)
+		Expect(err).NotTo(HaveOccurred())
+
+		ironic := &metal3api.Ironic{
+			ObjectMeta: metav1.ObjectMeta{
+				Name:      name.Name,
+				Namespace: name.Namespace,
+			},
+			Spec: metal3api.IronicSpec{
+				DatabaseRef: corev1.LocalObjectReference{
+					Name: ironicDb.Name,
+				},
+				Distributed: true,
+			},
+		}
+		err = k8sClient.Create(ctx, ironic)
+		Expect(err).NotTo(HaveOccurred())
+		DeferCleanup(func() {
+			DeleteAndWait(ironic)
+		})
+
+		ironic = WaitForIronic(name, true)
 		VerifyIronic(ironic)
 	})
 })