feat(tests): add sync and async E2E tests for notification categories

Author: jentyk

tests/e2e/notifications/__init__.py

@@ -0,0 +1,15 @@
+import pytest
+
+
+@pytest.fixture
+def category_data(short_uuid):
+    return {
+        "name": f"e2e-category-{short_uuid}",
+        "description": "E2E test category - please delete",
+        "externalId": f"e2e-cat-{short_uuid}",
+    }
+
+
+@pytest.fixture
+def invalid_category_id():
+    return "NCT-000-000-000"

tests/e2e/notifications/categories/__init__.py

@@ -0,0 +1,107 @@
+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 async_created_category(async_mpt_ops, category_data):
+    service = async_mpt_ops.notifications.categories
+    category = await service.create(category_data)
+    yield category
+    try:
+        await service.delete(category.id)
+    except MPTAPIError as error:
+        print(f"TEARDOWN - Unable to delete category {category.id}: {error.title}")  # noqa: WPS421
+
+
+async def test_create_category(async_created_category, category_data):
+    assert async_created_category.name == category_data["name"]
+    assert async_created_category.description == category_data["description"]
+
+
+async def test_get_category(async_mpt_vendor, async_created_category):
+    service = async_mpt_vendor.notifications.categories
+
+    result = await service.get(async_created_category.id)
+
+    assert result.id == async_created_category.id
+    assert result.name == async_created_category.name
+
+
+async def test_update_category(async_mpt_ops, async_created_category):
+    service = async_mpt_ops.notifications.categories
+    update_data = {
+        "name": "e2e-async-updated-category",
+        "description": "Async updated description",
+    }
+
+    result = await service.update(async_created_category.id, update_data)
+
+    assert result.name == "e2e-async-updated-category"
+    assert result.description == "Async updated description"
+
+
+async def test_list_categories(async_mpt_vendor, async_created_category):
+    service = async_mpt_vendor.notifications.categories
+
+    result = [category async for category in service.iterate()]
+
+    assert any(category.id == async_created_category.id for category in result)
+
+
+async def test_filter_categories(async_mpt_vendor, async_created_category):
+    service = async_mpt_vendor.notifications.categories
+
+    result = [
+        category
+        async for category in service.filter(RQLQuery(id=async_created_category.id)).iterate()
+    ]
+
+    assert len(result) == 1
+    assert result[0].id == async_created_category.id
+
+
+async def test_publish_category(async_mpt_ops, async_created_category):
+    service = async_mpt_ops.notifications.categories
+
+    unpublish_note_data = {"note": "Unpublishing category for async testing"}
+    await service.unpublish(async_created_category.id, unpublish_note_data)
+
+    note_data = {"note": "Publishing category for async testing"}
+    result = await service.publish(async_created_category.id, note_data)
+
+    assert result.id == async_created_category.id
+
+
+async def test_unpublish_category(async_mpt_ops, async_created_category):
+    service = async_mpt_ops.notifications.categories
+
+    unpublish_note_data = {"note": "Unpublishing category for async testing"}
+    result = await service.unpublish(async_created_category.id, unpublish_note_data)
+
+    assert result.id == async_created_category.id
+
+
+async def test_category_not_found(async_mpt_vendor):
+    service = async_mpt_vendor.notifications.categories
+
+    with pytest.raises(MPTAPIError):
+        await service.get("NCT-000-000-000")
+
+
+async def test_delete_category(async_mpt_ops, async_created_category):
+    service = async_mpt_ops.notifications.categories
+
+    await service.delete(async_created_category.id)
+
+    await service.get(async_created_category.id)
+
+
+async def test_delete_category_not_found(async_mpt_ops, invalid_category_id):
+    service = async_mpt_ops.notifications.categories
+
+    with pytest.raises(MPTAPIError):
+        await service.delete(invalid_category_id)

tests/e2e/notifications/categories/conftest.py

@@ -0,0 +1,104 @@
+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_category(mpt_ops, category_data):
+    service = mpt_ops.notifications.categories
+    category = service.create(category_data)
+    yield category
+    try:
+        service.delete(category.id)
+    except MPTAPIError as error:
+        print(f"TEARDOWN - Unable to delete category {category.id}: {error.title}")  # noqa: WPS421
+
+
+def test_create_category(created_category, category_data):
+    assert created_category.name == category_data["name"]
+    assert created_category.description == category_data["description"]
+
+
+def test_get_category(mpt_client, created_category):
+    service = mpt_client.notifications.categories
+
+    result = service.get(created_category.id)
+
+    assert result.id == created_category.id
+    assert result.name == created_category.name
+
+
+def test_update_category(mpt_ops, created_category):
+    service = mpt_ops.notifications.categories
+    update_data = {
+        "name": "e2e-updated-category",
+        "description": "Updated description",
+    }
+
+    result = service.update(created_category.id, update_data)
+
+    assert result.name == "e2e-updated-category"
+    assert result.description == "Updated description"
+
+
+def test_list_categories(mpt_client, created_category):
+    service = mpt_client.notifications.categories
+
+    result = list(service.iterate())
+
+    assert any(category.id == created_category.id for category in result)
+
+
+def test_filter_categories(mpt_client, created_category):
+    service = mpt_client.notifications.categories
+
+    result = list(service.filter(RQLQuery(id=created_category.id)).iterate())
+
+    assert len(result) == 1
+    assert result[0].id == created_category.id
+
+
+def test_publish_category(mpt_ops, created_category):
+    service = mpt_ops.notifications.categories
+
+    unpublish_note_data = {"note": "Unpublishing category for testing"}
+    service.unpublish(created_category.id, unpublish_note_data)
+
+    note_data = {"note": "Publishing category for testing"}
+    result = service.publish(created_category.id, note_data)
+
+    assert result.id == created_category.id
+
+
+def test_unpublish_category(mpt_ops, created_category):
+    service = mpt_ops.notifications.categories
+
+    unpublish_note_data = {"note": "Unpublishing category for testing"}
+    result = service.unpublish(created_category.id, unpublish_note_data)
+
+    assert result.id == created_category.id
+
+
+def test_category_not_found(mpt_client, invalid_category_id):
+    service = mpt_client.notifications.categories
+
+    with pytest.raises(MPTAPIError):
+        service.get(invalid_category_id)
+
+
+def test_delete_category(mpt_ops, created_category):
+    service = mpt_ops.notifications.categories
+
+    service.delete(created_category.id)
+
+    service.get(created_category.id)
+
+
+def test_delete_category_not_found(mpt_ops, invalid_category_id):
+    service = mpt_ops.notifications.categories
+
+    with pytest.raises(MPTAPIError):
+        service.delete(invalid_category_id)