54: Added integration tests

tests/conftest.py

@@ -235,6 +235,7 @@ def k8s_server(
         {
             "server.enabled": True,
             "server.wg.publicHost": "wormhole-server-server.server.svc.cluster.local",
+            "server.service.type": "ClusterIP",
             "docker.image": wormhole_image.split(":")[0],
             "docker.version": wormhole_image.split(":")[1],
             "docker.wgImage": wireguard_image.split(":")[0],

tests/fixtures.py

@@ -46,7 +46,7 @@ def start(self):
             "--metrics",
             "--metrics-port",
             str(self.metrics_port),
-            "listen",
+            "server",
             "--name",
             uuid.uuid4().hex,
             "--directory-state-manager-path",
@@ -164,7 +164,7 @@ def start(self):
             "--metrics",
             "--metrics-port",
             str(self.metrics_port),
-            "join",
+            "client",
             "--name",
             uuid.uuid4().hex,
             "--nginx-confd-path",

tests/test_kubernetes.py

@@ -201,4 +201,44 @@ def _ensure_that_proxied_service_is_deleted():
     if 'client-custom' in [
         svc['metadata']['name'] for svc in kubectl.json(["-n", "server", "get", "svc"])["items"]
     ]:
-        pytest.skip("The orphaned service should be removed, but it's not critical, so skipping for now")
+        pytest.skip(
+            "The orphaned service should be removed, but it's not critical, so skipping for now"
+        )
+
+
+def test_connection_via_the_tunnel(
+    kubectl,
+    k8s_server,
+    k8s_client,
+    mock_server,
+):
+
+    annotator = Annotator(mock_server, kubectl)
+    amount_of_services_before_annotation = len(
+        kubectl.json(["-n", "server", "get", "svc"])["items"]
+    )
+    annotator.do("wormhole.glothriel.github.com/exposed", "yes")
+
+    @retry(tries=60, delay=1)
+    def _ensure_that_proxied_service_is_created():
+        assert (
+            len(kubectl.json(["-n", "server", "get", "svc"])["items"])
+            == amount_of_services_before_annotation + 1
+        )
+    _ensure_that_proxied_service_is_created()
+
+    @retry(tries=60, delay=1)
+    def _ensure_that_proxied_service_is_reachable():
+        kubectl.run(
+            [
+                '-n',
+                'nginx',
+                'exec',
+                'deployment/nginx',
+                '--',
+                'curl',
+                'server-nginx-nginx.client.svc.cluster.local'
+            ]
+        )
+
+    _ensure_that_proxied_service_is_reachable()