Merge pull request #315 from pehala/httpbin_object

Remove Httpbin templates

testsuite/openshift/__init__.py

@@ -1,5 +1,7 @@
 """OpenShift common objects"""
 import functools
+from dataclasses import dataclass, field
+from typing import Optional, Literal
 
 from openshift import APIObject, timeout
 
@@ -52,3 +54,28 @@ def _wrap(self, *args, **kwargs):
             func(self, *args, **kwargs)
 
     return _wrap
+
+
+@dataclass
+class MatchExpression:
+    """
+    Data class intended for defining K8 Label Selector expressions.
+    Used by selector.matchExpressions API key identity.
+    """
+
+    operator: Literal["In", "NotIn", "Exists", "DoesNotExist"]
+    values: list[str]
+    key: str = "group"
+
+
+@dataclass
+class Selector:
+    """Dataclass for specifying selectors based on either expression or labels"""
+
+    # pylint: disable=invalid-name
+    matchExpressions: Optional[list[MatchExpression]] = field(default=None, kw_only=True)
+    matchLabels: Optional[dict[str, str]] = field(default=None, kw_only=True)
+
+    def __post_init__(self):
+        if not (self.matchLabels is None) ^ (self.matchExpressions is None):
+            raise AttributeError("`matchLabels` xor `matchExpressions` argument must be used")

testsuite/openshift/api_key.py

@@ -2,9 +2,8 @@
 import base64
 from functools import cached_property
 
-from testsuite.policy.authorization import Selector
 from testsuite.openshift.client import OpenShiftClient
-from testsuite.openshift import OpenShiftObject, modify
+from testsuite.openshift import OpenShiftObject, modify, Selector
 
 
 class APIKey(OpenShiftObject):

testsuite/openshift/deployment.py

@@ -0,0 +1,50 @@
+"""Deployment related objects"""
+import openshift as oc
+
+from testsuite.openshift import OpenShiftObject, Selector
+from testsuite.utils import asdict
+
+
+class Deployment(OpenShiftObject):
+    """Kubernetes Deployment object"""
+
+    @classmethod
+    def create_instance(
+        cls, openshift, name, container_name, image, ports: dict[str, int], selector: Selector, labels: dict[str, str]
+    ):
+        """
+        Creates new instance of Deployment
+        Supports only single container Deployments everything else should be edited directly
+        """
+        model: dict = {
+            "kind": "Deployment",
+            "apiVersion": "apps/v1",
+            "metadata": {
+                "name": name,
+                "labels": labels,
+            },
+            "spec": {
+                "selector": asdict(selector),
+                "template": {
+                    "metadata": {"labels": {"deployment": name, **labels}},
+                    "spec": {
+                        "containers": [
+                            {
+                                "image": image,
+                                "name": container_name,
+                                "imagePullPolicy": "IfNotPresent",
+                                "ports": [{"name": name, "containerPort": port} for name, port in ports.items()],
+                            }
+                        ]
+                    },
+                },
+            },
+        }
+
+        return cls(model, context=openshift.context)
+
+    def wait_for_ready(self, timeout=90):
+        """Waits until Deployment is marked as ready"""
+        with oc.timeout(timeout):
+            success, _, _ = self.self_selector().until_all(success_func=lambda obj: "readyReplicas" in obj.model.status)
+            assert success, f"Deployment {self.name()} did not get ready in time"

testsuite/openshift/httpbin.py

@@ -1,14 +1,16 @@
-"""Module for Httpbin backend classes"""
+"""Httpbin related classes"""
 from functools import cached_property
-from importlib import resources
 
 from testsuite.lifecycle import LifecycleObject
 from testsuite.gateway import Referencable
+from testsuite.openshift import Selector
 from testsuite.openshift.client import OpenShiftClient
+from testsuite.openshift.deployment import Deployment
+from testsuite.openshift.service import Service, ServicePort
 
 
 class Httpbin(LifecycleObject, Referencable):
-    """Httpbin deployed in OpenShift through template"""
+    """Httpbin deployed in OpenShift"""
 
     def __init__(self, openshift: OpenShiftClient, name, label, replicas=1) -> None:
         super().__init__()
@@ -17,7 +19,8 @@ def __init__(self, openshift: OpenShiftClient, name, label, replicas=1) -> None:
         self.label = label
         self.replicas = replicas
 
-        self.httpbin_objects = None
+        self.deployment = None
+        self.service = None
 
     @property
     def reference(self):
@@ -29,27 +32,37 @@ def url(self):
         return f"{self.name}.{self.openshift.project}.svc.cluster.local"
 
     def commit(self):
-        self.httpbin_objects = self.openshift.new_app(
-            resources.files("testsuite.resources").joinpath("httpbin.yaml"),
-            {"NAME": self.name, "LABEL": self.label, "REPLICAS": self.replicas},
+        match_labels = {"app": self.label, "deployment": self.name}
+        self.deployment = Deployment.create_instance(
+            self.openshift,
+            self.name,
+            container_name="httpbin",
+            image="quay.io/jsmadis/httpbin:latest",
+            ports={"api": 8080},
+            selector=Selector(matchLabels=match_labels),
+            labels={"app": self.label},
         )
+        self.deployment.commit()
+        self.deployment.wait_for_ready()
 
-        with self.openshift.context:
-            assert self.openshift.is_ready(self.httpbin_objects.narrow("deployment")), "Httpbin wasn't ready in time"
+        self.service = Service.create_instance(
+            self.openshift,
+            self.name,
+            selector=match_labels,
+            ports=[ServicePort(name="http", port=8080, targetPort="api")],
+        )
+        self.service.commit()
 
     def delete(self):
         with self.openshift.context:
-            if self.httpbin_objects:
-                self.httpbin_objects.delete()
-        self.httpbin_objects = None
-
-    @cached_property
-    def service(self):
-        """Service associated with httpbin"""
-        with self.openshift.context:
-            return self.httpbin_objects.narrow("service").object()
+            if self.service:
+                self.service.delete()
+                self.service = None
+            if self.deployment:
+                self.deployment.delete()
+                self.deployment = None
 
     @cached_property
     def port(self):
         """Service port that httpbin listens on"""
-        return self.service.model.spec.ports[0].get("port")
+        return self.service.get_port("http").port

testsuite/openshift/service.py

@@ -0,0 +1,48 @@
+"""Service related objects"""
+from dataclasses import dataclass, asdict
+
+from testsuite.openshift import OpenShiftObject
+
+
+@dataclass
+class ServicePort:
+    """Kubernetes Service Port object"""
+
+    name: str
+    port: int
+    targetPort: int | str  # pylint: disable=invalid-name
+
+
+class Service(OpenShiftObject):
+    """Kubernetes Service object"""
+
+    @classmethod
+    def create_instance(
+        cls,
+        openshift,
+        name,
+        selector: dict[str, str],
+        ports: list[ServicePort],
+        labels: dict[str, str] = None,
+    ):
+        """Creates new Service"""
+        model: dict = {
+            "kind": "Service",
+            "apiVersion": "v1",
+            "metadata": {
+                "name": name,
+                "labels": labels,
+            },
+            "spec": {
+                "ports": [asdict(port) for port in ports],
+                "selector": selector,
+            },
+        }
+        return cls(model, context=openshift.context)
+
+    def get_port(self, name):
+        """Returns port definition for a port with said name"""
+        for port in self.model.spec.ports:
+            if port["name"] == name:
+                return port
+        raise KeyError(f"No port with name {name} exists")

testsuite/policy/authorization/__init__.py

@@ -1,33 +1,11 @@
 """Authorization related objects"""
 import abc
-from dataclasses import dataclass, field
+from dataclasses import dataclass
 from typing import Literal, Optional
 from testsuite.utils import asdict, JSONValues
 
 
 # pylint: disable=invalid-name
-@dataclass
-class MatchExpression:
-    """
-    Data class intended for defining K8 Label Selector expressions.
-    Used by selector.matchExpressions API key identity.
-    """
-
-    operator: Literal["In", "NotIn", "Exists", "DoesNotExist"]
-    values: list[str]
-    key: str = "group"
-
-
-@dataclass
-class Selector:
-    """Dataclass for specifying selectors based on either expression or labels"""
-
-    matchExpressions: Optional[list[MatchExpression]] = field(default=None, kw_only=True)
-    matchLabels: Optional[dict[str, str]] = field(default=None, kw_only=True)
-
-    def __post_init__(self):
-        if not (self.matchLabels is None) ^ (self.matchExpressions is None):
-            raise AttributeError("`matchLabels` xor `matchExpressions` argument must be used")
 
 
 @dataclass

testsuite/policy/authorization/sections.py

@@ -2,7 +2,6 @@
 from typing import Literal, Iterable, TYPE_CHECKING, Union
 
 from testsuite.policy.authorization import (
-    Selector,
     Credentials,
     Rule,
     Pattern,
@@ -15,7 +14,7 @@
     Cache,
 )
 from testsuite.utils import asdict
-from testsuite.openshift import modify
+from testsuite.openshift import modify, Selector
 
 if TYPE_CHECKING:
     from .auth_config import AuthConfig

testsuite/tests/kuadrant/authorino/identity/api_key/test_match_expression.py

@@ -5,7 +5,7 @@
 """
 import pytest
 
-from testsuite.policy.authorization import MatchExpression, Selector
+from testsuite.openshift import Selector, MatchExpression
 
 
 @pytest.fixture(scope="module")

testsuite/tests/kuadrant/authorino/identity/api_key/test_reconciliation.py

@@ -2,7 +2,7 @@
 import pytest
 
 from testsuite.httpx.auth import HeaderApiKeyAuth
-from testsuite.policy.authorization import Selector
+from testsuite.openshift import Selector
 
 
 @pytest.fixture(scope="function")

testsuite/tests/kuadrant/authorino/operator/tls/conftest.py

@@ -4,7 +4,7 @@
 import pytest
 
 from testsuite.certificates import Certificate, CertInfo
-from testsuite.policy.authorization import Selector
+from testsuite.openshift import Selector
 from testsuite.gateway import Exposer
 from testsuite.gateway.envoy.tls import TLSEnvoy
 from testsuite.gateway.gateway_api.hostname import OpenShiftExposer