Added seeding and e2e tests for commerce subscriptions

Author: Robert Segal

e2e_config.test.json

@@ -33,5 +33,8 @@
   "commerce.product.item.id": "ITM-1767-7355-0001",
   "commerce.product.listing.id": "LST-5489-0806",
   "commerce.product.template.id": "TPL-1767-7355-0003",
+  "commerce.subscription.agreement.id": "AGR-2473-3299-1721",
+  "commerce.subscription.id": "SUB-3678-1831-2188",
+  "commerce.subscription.product.item.id": "ITM-1767-7355-0001",
   "notifications.message.id": "MSG-0000-6215-1019-0139"
 }

mpt_api_client/resources/commerce/subscriptions.py

@@ -7,10 +7,12 @@
     AsyncCreateMixin,
     AsyncDeleteMixin,
     AsyncGetMixin,
+    AsyncUpdateMixin,
     CollectionMixin,
     CreateMixin,
     DeleteMixin,
     GetMixin,
+    UpdateMixin,
 )
 from mpt_api_client.models import Model, ResourceData
 
@@ -29,6 +31,7 @@ class SubscriptionsServiceConfig:
 
 class SubscriptionsService(  # noqa: WPS215
     CreateMixin[Subscription],
+    UpdateMixin[Subscription],
     DeleteMixin,
     GetMixin[Subscription],
     CollectionMixin[Subscription],
@@ -49,7 +52,9 @@ def render(self, resource_id: str) -> str:
         response = self._resource_do_request(resource_id, "GET", "render")
         return response.text
 
-    def terminate(self, resource_id: str, resource_data: ResourceData) -> Subscription:
+    def terminate(
+        self, resource_id: str, resource_data: ResourceData | None = None
+    ) -> Subscription:
         """Terminate subscription.
 
         Args:
@@ -64,6 +69,7 @@ def terminate(self, resource_id: str, resource_data: ResourceData) -> Subscripti
 
 class AsyncSubscriptionsService(  # noqa: WPS215
     AsyncCreateMixin[Subscription],
+    AsyncUpdateMixin[Subscription],
     AsyncDeleteMixin,
     AsyncGetMixin[Subscription],
     AsyncCollectionMixin[Subscription],
@@ -84,7 +90,9 @@ async def render(self, resource_id: str) -> str:
         response = await self._resource_do_request(resource_id, "GET", "render")
         return response.text
 
-    async def terminate(self, resource_id: str, resource_data: ResourceData) -> Subscription:
+    async def terminate(
+        self, resource_id: str, resource_data: ResourceData | None = None
+    ) -> Subscription:
         """Terminate subscription.
 
         Args:

pyproject.toml

@@ -74,6 +74,9 @@ filterwarnings = [
     "ignore:pkg_resources is deprecated as an API:DeprecationWarning",
 ]
 rp_project = "mpt-api-python-client"
+markers = [
+  "flaky: mark test as flaky (may fail intermittently)",
+]
 
 [tool.coverage.run]
 branch = true
@@ -120,6 +123,7 @@ per-file-ignores = [
   "mpt_api_client/resources/catalog/*.py: WPS110 WPS214 WPS215 WPS235",
   "mpt_api_client/resources/catalog/mixins.py: WPS110 WPS202 WPS214 WPS215 WPS235",
   "mpt_api_client/resources/catalog/products.py: WPS204 WPS214 WPS215 WPS235",
+  "mpt_api_client/resources/commerce/*.py: WPS235 WPS215",
   "mpt_api_client/rql/query_builder.py: WPS110 WPS115 WPS210 WPS214",
   "tests/unit/http/test_async_service.py: WPS204 WPS202",
   "tests/unit/http/test_service.py: WPS204 WPS202",

tests/e2e/commerce/conftest.py

@@ -9,3 +9,13 @@ def agreement_id(e2e_config):
 @pytest.fixture
 def commerce_product_id(e2e_config):
     return e2e_config["commerce.product.id"]
+
+
+@pytest.fixture
+def subscription_item_id(e2e_config):
+    return e2e_config["commerce.subscription.product.item.id"]
+
+
+@pytest.fixture
+def subscription_agreement_id(e2e_config):
+    return e2e_config["commerce.subscription.agreement.id"]

tests/e2e/commerce/subscription/conftest.py

@@ -0,0 +1,41 @@
+import pytest
+from freezegun import freeze_time
+
+
+@pytest.fixture
+def subscription_id(e2e_config):
+    return e2e_config["commerce.subscription.id"]
+
+
+@pytest.fixture
+def invalid_subscription_id():
+    return "SUB-0000-0000-0000"
+
+
+@pytest.fixture
+def subscription_factory(subscription_agreement_id, subscription_item_id):
+    @freeze_time("2025-11-14T09:00:00.000Z")
+    def factory(
+        name: str = "E2E Created Subscription",
+        external_vendor_id: str = "ext-vendor-id",
+        quantity: int = 1,
+    ):
+        return {
+            "name": name,
+            "startDate": "2025-11-03T09:00:00.000Z",
+            "commitmentDate": "2026-11-02T09:00:00.000Z",
+            "autoRenew": True,
+            "agreement": {"id": subscription_agreement_id},
+            "externalIds": {"vendor": external_vendor_id},
+            "template": None,
+            "lines": [
+                {
+                    "item": {"id": subscription_item_id},
+                    "quantity": quantity,
+                    "price": {"unitPP": 10},
+                }
+            ],
+            "parameters": {"fulfillment": []},
+        }
+
+    return factory

tests/e2e/commerce/subscription/test_async_subscription.py

@@ -0,0 +1,82 @@
+import pytest
+
+from mpt_api_client.exceptions import MPTAPIError
+from mpt_api_client.rql.query_builder import RQLQuery
+
+pytestmark = [pytest.mark.flaky]
+
+
+@pytest.fixture
+async def created_subscription(async_mpt_vendor, subscription_factory):
+    subscription_data = subscription_factory()
+
+    subscription = await async_mpt_vendor.commerce.subscriptions.create(subscription_data)
+
+    yield subscription
+
+    try:
+        await async_mpt_vendor.commerce.subscriptions.terminate(subscription.id)
+    except MPTAPIError as error:
+        print(f"TEARDOWN - Unable to terminate subscription: {getattr(error, 'title', str(error))}")  # noqa: WPS421
+
+
+async def test_get_subscription_by_id(async_mpt_vendor, subscription_id):
+    result = await async_mpt_vendor.commerce.subscriptions.get(subscription_id)
+
+    assert result is not None
+
+
+async def test_list_subscriptions(async_mpt_vendor):
+    limit = 10
+
+    result = await async_mpt_vendor.commerce.subscriptions.fetch_page(limit=limit)
+
+    assert result is not None
+
+
+async def test_get_subscription_by_id_not_found(async_mpt_vendor, invalid_subscription_id):
+    with pytest.raises(MPTAPIError, match="404 Not Found"):
+        await async_mpt_vendor.commerce.subscriptions.get(invalid_subscription_id)
+
+
+async def test_filter_subscriptions(async_mpt_vendor, subscription_id):
+    select_fields = ["-externalIds"]
+    filtered_subscriptions = (
+        async_mpt_vendor.commerce.subscriptions.filter(RQLQuery(id=subscription_id))
+        .filter(RQLQuery(name="E2E Seeded Subscription"))
+        .select(*select_fields)
+    )
+
+    result = [subscription async for subscription in filtered_subscriptions.iterate()]
+
+    assert len(result) == 1
+
+
+def test_create_subscription(created_subscription):
+    result = created_subscription
+
+    assert result is not None
+
+
+async def test_update_subscription(async_mpt_vendor, created_subscription):
+    updated_subscription_data = {
+        "name": "E2E Updated Subscription",
+    }
+
+    result = await async_mpt_vendor.commerce.subscriptions.update(
+        created_subscription.id, updated_subscription_data
+    )
+
+    assert result is not None
+
+
+async def test_terminate_subscription(async_mpt_vendor, created_subscription):
+    result = await async_mpt_vendor.commerce.subscriptions.terminate(created_subscription.id)
+
+    assert result is not None
+
+
+async def test_render_subscription(async_mpt_vendor, created_subscription):
+    result = await async_mpt_vendor.commerce.subscriptions.render(created_subscription.id)
+
+    assert result is not None

tests/e2e/commerce/subscription/test_sync_subscription.py

@@ -0,0 +1,82 @@
+import pytest
+
+from mpt_api_client.exceptions import MPTAPIError
+from mpt_api_client.rql.query_builder import RQLQuery
+
+pytestmark = [pytest.mark.flaky]
+
+
+@pytest.fixture
+def created_subscription(mpt_vendor, subscription_factory):
+    subscription_data = subscription_factory()
+
+    subscription = mpt_vendor.commerce.subscriptions.create(subscription_data)
+
+    yield subscription
+
+    try:
+        mpt_vendor.commerce.subscriptions.terminate(subscription.id)
+    except MPTAPIError as error:
+        print(f"TEARDOWN - Unable to terminate subscription: {getattr(error, 'title', str(error))}")  # noqa: WPS421
+
+
+def test_get_subscription_by_id(mpt_vendor, subscription_id):
+    result = mpt_vendor.commerce.subscriptions.get(subscription_id)
+
+    assert result is not None
+
+
+def test_list_subscriptions(mpt_vendor):
+    limit = 10
+
+    result = mpt_vendor.commerce.subscriptions.fetch_page(limit=limit)
+
+    assert result is not None
+
+
+def test_get_subscription_by_id_not_found(mpt_vendor, invalid_subscription_id):
+    with pytest.raises(MPTAPIError, match="404 Not Found"):
+        mpt_vendor.commerce.subscriptions.get(invalid_subscription_id)
+
+
+def test_filter_subscriptions(mpt_vendor, subscription_id):
+    select_fields = ["-externalIds"]
+    filtered_subscriptions = (
+        mpt_vendor.commerce.subscriptions.filter(RQLQuery(id=subscription_id))
+        .filter(RQLQuery(name="E2E Seeded Subscription"))
+        .select(*select_fields)
+    )
+
+    result = list(filtered_subscriptions.iterate())
+
+    assert len(result) == 1
+
+
+def test_create_subscription(created_subscription):
+    result = created_subscription
+
+    assert result is not None
+
+
+def test_update_subscription(mpt_vendor, created_subscription):
+    updated_subscription_data = {
+        "name": "E2E Updated Subscription",
+    }
+
+    result = mpt_vendor.commerce.subscriptions.update(
+        created_subscription.id, updated_subscription_data
+    )
+
+    assert result is not None
+
+
+def test_terminate_subscription(mpt_vendor, created_subscription):
+    result = mpt_vendor.commerce.subscriptions.terminate(created_subscription.id)
+
+    assert result is not None
+
+
+def test_render_subscription(mpt_vendor, created_subscription):
+    result = mpt_vendor.commerce.subscriptions.render(created_subscription.id)
+
+    assert result is not None

tests/unit/resources/commerce/test_subscriptions.py

@@ -18,14 +18,14 @@ def async_subscriptions_service(async_http_client):
     return AsyncSubscriptionsService(http_client=async_http_client)
 
 
-@pytest.mark.parametrize("method", ["get", "create", "delete"])
+@pytest.mark.parametrize("method", ["get", "create", "update", "delete", "iterate"])
 def test_methods_present(subscriptions_service, method):
     result = hasattr(subscriptions_service, method)
 
     assert result is True
 
 
-@pytest.mark.parametrize("method", ["get", "create", "delete"])
+@pytest.mark.parametrize("method", ["get", "create", "update", "delete", "iterate"])
 def test_async_methods_present(async_subscriptions_service, method):
     result = hasattr(async_subscriptions_service, method)