Fix price lists tests and increase timeouts for e2e

Author: albertsola

mpt_api_client/http/async_client.py

@@ -27,7 +27,7 @@ def __init__(
         *,
         base_url: str | None = None,
         api_token: str | None = None,
-        timeout: float = 10.0,
+        timeout: float = 20.0,
         retries: int = 5,
     ):
         api_token = api_token or os.getenv("MPT_TOKEN")

mpt_api_client/http/client.py

@@ -40,7 +40,7 @@ def __init__(
         *,
         base_url: str | None = None,
         api_token: str | None = None,
-        timeout: float = 10.0,
+        timeout: float = 20.0,
         retries: int = 5,
     ):
         api_token = api_token or os.getenv("MPT_TOKEN")

tests/e2e/catalog/price_lists/conftest.py

@@ -26,5 +26,5 @@ def created_price_list(price_lists_service, price_list_data):
 
 
 @pytest.fixture
-def price_list_id(created_price_list):
-    return created_price_list.id
+def price_list_id(e2e_config):
+    return e2e_config["catalog.price_list.id"]

tests/e2e/catalog/price_lists/items/conftest.py

@@ -1,5 +1,7 @@
 import pytest
 
+from mpt_api_client import RQLQuery
+
 
 @pytest.fixture
 def price_list_items_service(mpt_ops, price_list_id):
@@ -21,6 +23,10 @@ def price_list_item_data(short_uuid):
 
 
 @pytest.fixture
-def price_list_item(price_list_items_service):
-    price_list_items = price_list_items_service.fetch_page(1)
-    return price_list_items[0]
+def price_list_item(price_list_items_service, item_id):
+    return next(price_list_items_service.filter(RQLQuery(item__id=item_id)).iterate())
+
+
+@pytest.fixture
+def price_list_item_id(price_list_item):
+    return price_list_item.id

tests/e2e/catalog/price_lists/items/test_async_price_list_items.py

@@ -8,22 +8,22 @@
 pytestmark = [pytest.mark.flaky]
 
 
-async def test_get_price_list_item(async_price_list_items_service, price_list_item):
-    result = await async_price_list_items_service.get(price_list_item.id)
+async def test_get_price_list_item(async_price_list_items_service, price_list_item_id):
+    result = await async_price_list_items_service.get(price_list_item_id)
 
-    assert result.id == price_list_item.id
+    assert result.id == price_list_item_id
 
 
-async def test_filter_price_list_items(async_price_list_items_service, price_list_item):
+async def test_filter_price_list_items(async_price_list_items_service, price_list_item_id):
     await assert_async_service_filter_with_iterate(
-        async_price_list_items_service, price_list_item.id, ["-notes"]
+        async_price_list_items_service, price_list_item_id, ["-notes"]
     )  # act
 
 
 async def test_update_price_list_item(
-    async_price_list_items_service, price_list_item, price_list_item_data
+    async_price_list_items_service, price_list_item_id, price_list_item_data
 ):
-    result = await async_price_list_items_service.update(price_list_item.id, price_list_item_data)
+    result = await async_price_list_items_service.update(price_list_item_id, price_list_item_data)
 
     assert result.reason_for_change == price_list_item_data["reasonForChange"]
 
@@ -35,8 +35,10 @@ async def test_get_price_list_item_not_found(async_price_list_items_service):
         await async_price_list_items_service.get(bogus_id)
 
 
-async def test_create_price_list_item_invalid_data(async_price_list_items_service, price_list_item):
-    invalid_data = {"unitPP": "0"}
+async def test_update_price_list_item_invalid_data(
+    async_price_list_items_service, price_list_item_id
+):
+    invalid_data = {"unitPP": "NaN"}
 
     with pytest.raises(MPTAPIError, match=r"400 Bad Request"):
-        await async_price_list_items_service.update(price_list_item.id, invalid_data)
+        await async_price_list_items_service.update(price_list_item_id, invalid_data)

tests/e2e/catalog/price_lists/items/test_sync_price_list_items.py

@@ -8,20 +8,20 @@
 pytestmark = [pytest.mark.flaky]
 
 
-def test_get_price_list_item(price_list_items_service, price_list_item):
-    result = price_list_items_service.get(price_list_item.id)
+def test_get_price_list_item(price_list_items_service, price_list_item_id):
+    result = price_list_items_service.get(price_list_item_id)
 
-    assert result.id == price_list_item.id
+    assert result.id == price_list_item_id
 
 
-def test_filter_price_list_items(price_list_items_service, price_list_item):
+def test_filter_price_list_items(price_list_items_service, price_list_item_id):
     assert_service_filter_with_iterate(
-        price_list_items_service, price_list_item.id, ["-notes"]
+        price_list_items_service, price_list_item_id, ["-notes"]
     )  # act
 
 
-def test_update_price_list_item(price_list_items_service, price_list_item, price_list_item_data):
-    result = price_list_items_service.update(price_list_item.id, price_list_item_data)
+def test_update_price_list_item(price_list_items_service, price_list_item_id, price_list_item_data):
+    result = price_list_items_service.update(price_list_item_id, price_list_item_data)
 
     assert result.reason_for_change == price_list_item_data["reasonForChange"]
 
@@ -33,8 +33,8 @@ def test_get_price_list_item_not_found(price_list_items_service):
         price_list_items_service.get(bogus_id)
 
 
-def test_create_price_list_item_invalid_data(price_list_items_service, price_list_item):
-    invalid_data = {"unitPP": "0"}
+def test_update_price_list_item_invalid_data(price_list_items_service, price_list_item_id):
+    invalid_data = {"unitPP": "NaN"}
 
     with pytest.raises(MPTAPIError, match=r"400 Bad Request"):
-        price_list_items_service.update(price_list_item.id, invalid_data)
+        price_list_items_service.update(price_list_item_id, invalid_data)

tests/e2e/catalog/price_lists/test_async_price_lists.py

@@ -29,28 +29,22 @@ def test_create_price_list(async_created_price_list, product_id):
     assert result.product.id == product_id
 
 
-async def test_get_price_list(async_price_lists_service, async_created_price_list):
-    result = await async_price_lists_service.get(async_created_price_list.id)
-
-    assert result.id == async_created_price_list.id
-
-
-async def test_get_price_list_by_id(async_price_lists_service, price_list_id):
+async def test_get_price_list(async_price_lists_service, price_list_id):
     result = await async_price_lists_service.get(price_list_id)
 
     assert result.id == price_list_id
 
 
-async def test_filter_price_lists(async_price_lists_service, async_created_price_list):
+async def test_filter_price_lists(async_price_lists_service, price_list_id):
     await assert_async_service_filter_with_iterate(
-        async_price_lists_service, async_created_price_list.id, ["-product"]
+        async_price_lists_service, price_list_id, ["-product"]
     )  # act
 
 
-async def test_update_price_list(async_price_lists_service, async_created_price_list, short_uuid):
+async def test_update_price_list(async_price_lists_service, price_list_id, short_uuid):
     await assert_async_update_resource(
         async_price_lists_service,
-        async_created_price_list.id,
+        price_list_id,
         "notes",
         f"Updated notes {short_uuid}",
     )  # act

tests/unit/http/test_async_client.py

@@ -32,7 +32,7 @@ def test_async_http_initialization(mocker):
             "User-Agent": "swo-marketplace-client/1.0",
             "Authorization": "Bearer test-token",
         },
-        timeout=10.0,
+        timeout=20.0,
         transport=mocker.ANY,
     )
 
@@ -51,7 +51,7 @@ def test_async_env_initialization(monkeypatch, mocker):
             "User-Agent": "swo-marketplace-client/1.0",
             "Authorization": f"Bearer {API_TOKEN}",
         },
-        timeout=10.0,
+        timeout=20.0,
         transport=mocker.ANY,
     )
 

tests/unit/http/test_client.py

@@ -22,7 +22,7 @@ def test_http_initialization(mocker):
             "User-Agent": "swo-marketplace-client/1.0",
             "Authorization": "Bearer test-token",
         },
-        timeout=10.0,
+        timeout=20.0,
         transport=mocker.ANY,
     )
 
@@ -41,7 +41,7 @@ def test_env_initialization(monkeypatch, mocker):
             "User-Agent": "swo-marketplace-client/1.0",
             "Authorization": f"Bearer {API_TOKEN}",
         },
-        timeout=10.0,
+        timeout=20.0,
         transport=mocker.ANY,
     )