test(maas): add subscription enforcement tests for TinyLlama

tests/model_serving/model_server/maas_billing/maas_subscription/conftest.py

@@ -186,19 +186,19 @@ def maas_subscription_tinyllama_free(
         name="tinyllama-free-subscription",
         namespace=applications_namespace,
         owner={
-            "kind": "Group",
-            "name": maas_free_group,
+            "groups": [{"name": maas_free_group}],
         },
         model_refs=[
             {
                 "name": maas_model_tinyllama_free.name,
-                "tokensPerMinute": 100,
+                "tokenRateLimits": [{"limit": 100, "window": "1m"}],
             }
         ],
         priority=0,
         teardown=True,
         wait_for_resource=True,
     ) as maas_subscription_free:
+        maas_subscription_free.wait_for_condition(condition="Ready", status="True", timeout=300)
         yield maas_subscription_free
 
 
@@ -215,19 +215,19 @@ def maas_subscription_tinyllama_premium(
         name="tinyllama-premium-subscription",
         namespace=applications_namespace,
         owner={
-            "kind": "Group",
-            "name": maas_premium_group,
+            "groups": [{"name": maas_premium_group}],
         },
         model_refs=[
             {
                 "name": maas_model_tinyllama_premium.name,
-                "tokensPerMinute": 1000,
+                "tokenRateLimits": [{"limit": 1000, "window": "1m"}],
             }
         ],
         priority=0,
         teardown=True,
         wait_for_resource=True,
     ) as maas_subscription_premium:
+        maas_subscription_premium.wait_for_condition(condition="Ready", status="True", timeout=300)
         yield maas_subscription_premium
 
 

tests/model_serving/model_server/maas_billing/maas_subscription/test_maas_sub_enforcement.py

@@ -0,0 +1,94 @@
+from __future__ import annotations
+
+import pytest
+import requests
+from simple_logger.logger import get_logger
+
+from tests.model_serving.model_server.maas_billing.maas_subscription.utils import chat_payload_for_url
+from tests.model_serving.model_server.maas_billing.utils import build_maas_headers
+
+LOGGER = get_logger(name=__name__)
+
+MAAS_SUBSCRIPTION_HEADER = "x-maas-subscription"
+INVALID_SUBSCRIPTION = "does-not-exist"
+
+
+@pytest.mark.usefixtures(
+    "maas_unprivileged_model_namespace",
+    "maas_controller_enabled_latest",
+    "maas_gateway_api",
+    "maas_api_gateway_reachable",
+    "maas_inference_service_tinyllama_premium",
+    "maas_model_tinyllama_premium",
+    "maas_auth_policy_tinyllama_premium",
+    "maas_subscription_tinyllama_premium",
+)
+class TestSubscriptionEnforcementTinyLlama:
+    """Tests that MaaSSubscription correctly enforces subscription selection & limits."""
+
+    @pytest.mark.sanity
+    @pytest.mark.parametrize("ocp_token_for_actor", [{"type": "premium"}], indirect=True)
+    def test_subscribed_user_gets_200(
+        self,
+        request_session_http: requests.Session,
+        model_url_tinyllama_premium: str,
+        ocp_token_for_actor: str,
+    ) -> None:
+        resp = request_session_http.post(
+            url=model_url_tinyllama_premium,
+            headers=build_maas_headers(token=ocp_token_for_actor),
+            json=chat_payload_for_url(model_url=model_url_tinyllama_premium),
+            timeout=60,
+        )
+        LOGGER.info(f"test_subscribed_user_gets_200 -> {resp.status_code}")
+        assert resp.status_code == 200, f"Expected 200, got {resp.status_code}: {resp.text[:200]}"
+
+    @pytest.mark.sanity
+    @pytest.mark.parametrize("ocp_token_for_actor", [{"type": "premium"}], indirect=True)
+    def test_explicit_subscription_header_works(
+        self,
+        request_session_http: requests.Session,
+        model_url_tinyllama_premium: str,
+        ocp_token_for_actor: str,
+        maas_subscription_tinyllama_premium,
+    ) -> None:
+        """
+        - Send valid x-maas-subscription
+        - Expect 200
+        """
+        headers = build_maas_headers(token=ocp_token_for_actor)
+        headers[MAAS_SUBSCRIPTION_HEADER] = maas_subscription_tinyllama_premium.name
+
+        resp = request_session_http.post(
+            url=model_url_tinyllama_premium,
+            headers=headers,
+            json=chat_payload_for_url(model_url=model_url_tinyllama_premium),
+            timeout=60,
+        )
+        LOGGER.info(f"test_explicit_subscription_header_works -> {resp.status_code}")
+
+        assert resp.status_code == 200, f"Expected 200, got {resp.status_code}: {resp.text[:200]}"
+
+    @pytest.mark.sanity
+    @pytest.mark.parametrize("ocp_token_for_actor", [{"type": "premium"}], indirect=True)
+    def test_invalid_subscription_header_gets_429(
+        self,
+        request_session_http: requests.Session,
+        model_url_tinyllama_premium: str,
+        ocp_token_for_actor: str,
+    ) -> None:
+        """
+        - Send invalid x-maas-subscription
+        - Expect 429 or 403
+        """
+        headers = build_maas_headers(token=ocp_token_for_actor)
+        headers[MAAS_SUBSCRIPTION_HEADER] = INVALID_SUBSCRIPTION
+
+        resp = request_session_http.post(
+            url=model_url_tinyllama_premium,
+            headers=headers,
+            json=chat_payload_for_url(model_url=model_url_tinyllama_premium),
+            timeout=60,
+        )
+
+        assert resp.status_code in (429, 403), f"Expected 429 or 403, got {resp.status_code}: {resp.text[:200]}"