test: become bob; become minikube

Author: mplsgrant

test/namespace_admin_test.py

@@ -8,6 +8,7 @@
 from test_base import TestBase
 
 from warnet.k8s import get_kubeconfig_value
+from warnet.process import run_command
 
 
 class NamespaceAdminTest(TestBase):
@@ -26,10 +27,17 @@ def run_test(self):
             self.setup_namespaces()
             self.setup_service_accounts()
             self.deploy_network_in_team_namespaces()
-            self.authenticate_bob()
+            self.authenticate_and_become_bob()
+            self.become_minikube_once_again()
         finally:
             self.cleanup()
 
+    def become_minikube_once_again(self):
+        minikube = "minikube"
+        cmd = f"kubectl config use-context {minikube}"
+        self.log.info(run_command(cmd))
+        self.wait_for_predicate(self.this_is_the_current_context(minikube))
+
     def this_is_the_current_context(self, context: str) -> Callable[[], bool]:
         cmd = "kubectl config current-context"
         current_context = run_command(cmd).strip()
@@ -80,10 +88,11 @@ def deploy_network_in_team_namespaces(self):
             self.log.info(f"Deploying network into: {namespace}")
             self.log.info(self.warnet(f"deploy networks/{network_name}/ --namespace {namespace}"))
         self.wait_for_all_tanks_status()
+        self.log.info("Waiting for all edges")
         self.wait_for_all_edges()
 
-    def authenticate_bob(self):
-        self.log.info("Authenticating bob...")
+    def authenticate_and_become_bob(self):
+        self.log.info("Authenticating and becoming bob...")
         assert get_kubeconfig_value("{.current-context}") == "minikube"
         self.log.info(self.warnet("auth kubeconfigs/bob-wargames-red-team-kubeconfig"))
         assert get_kubeconfig_value("{.current-context}") == "bob-wargames-red-team"