From b4ab5798f3d14020ff47a8716c5d4ab36f36e9d3 Mon Sep 17 00:00:00 2001
From: benbierens <thatbenbierens@gmail.com>
Date: Sun, 19 Mar 2023 08:22:38 +0100
Subject: [PATCH] checking service status before proceeding

---
 TestCore/DistTest.cs | 11 +++++++++++
 TestCore/Timing.cs   |  5 +++++
 2 files changed, 16 insertions(+)

diff --git a/TestCore/DistTest.cs b/TestCore/DistTest.cs
index 3a970fd..9201a50 100644
--- a/TestCore/DistTest.cs
+++ b/TestCore/DistTest.cs
@@ -106,6 +106,11 @@ namespace CodexDistTests.TestCore
             activeService = client.CreateNamespacedService(serviceSpec, k8sNamespace);
 
             // todo: wait until online!
+            while (activeDeployment.Status.AvailableReplicas == null || activeDeployment.Status.AvailableReplicas != 1)
+            {
+                Timing.WaitForServiceDelay();
+                activeDeployment = client.ReadNamespacedDeployment(activeDeployment.Name(), k8sNamespace);
+            }
         }
 
         public CodexNode GetCodexNode()
@@ -123,6 +128,12 @@ namespace CodexDistTests.TestCore
             client.DeleteNamespace(activeNamespace.Name());
 
             // todo: wait until terminated!
+            var pods = client.ListNamespacedPod(k8sNamespace);
+            while (pods.Items.Any())
+            {
+                Timing.WaitForServiceDelay();
+                pods = client.ListNamespacedPod(k8sNamespace);
+            }
         }
     }
 }
diff --git a/TestCore/Timing.cs b/TestCore/Timing.cs
index cca6dd5..89896f6 100644
--- a/TestCore/Timing.cs
+++ b/TestCore/Timing.cs
@@ -11,5 +11,10 @@
         {
             Utils.Sleep(TimeSpan.FromSeconds(3));
         }
+
+        public static void WaitForServiceDelay()
+        {
+            Utils.Sleep(TimeSpan.FromSeconds(1));
+        }
     }
 }