MPT-14767 E2E seeding proof of concept

albertsola · albertsola · commit 7adea355810c · 2025-10-28T11:08:57.000Z
- Added seeding proof of concept
- Fix create product request
diff --git a/mpt_api_client/http/client.py b/mpt_api_client/http/client.py
@@ -49,7 +49,6 @@ def __init__(
         base_headers = {
             "User-Agent": "swo-marketplace-client/1.0",
             "Authorization": f"Bearer {api_token}",
-            "content-type": "application/json",
         }
         self.httpx_client = Client(
             base_url=base_url,
diff --git a/mpt_api_client/http/mixins.py b/mpt_api_client/http/mixins.py
@@ -86,7 +86,6 @@ def create(
                 _json_to_file_payload(resource_data),
                 "application/json",
             )
-
         response = self.http_client.request("post", self.path, files=files)  # type: ignore[attr-defined]
 
         return self._model_class.from_response(response)  # type: ignore[attr-defined, no-any-return]
diff --git a/mpt_api_client/resources/catalog/products.py b/mpt_api_client/resources/catalog/products.py
@@ -1,10 +1,13 @@
+import json
+
 from mpt_api_client.http import AsyncService, Service
 from mpt_api_client.http.mixins import (
     AsyncCollectionMixin,
-    AsyncManagedResourceMixin,
+    AsyncModifiableResourceMixin,
     CollectionMixin,
-    ManagedResourceMixin,
+    ModifiableResourceMixin,
 )
+from mpt_api_client.http.types import FileTypes
 from mpt_api_client.models import Model, ResourceData
 from mpt_api_client.resources.catalog.mixins import (
     AsyncPublishableMixin,
@@ -54,13 +57,38 @@ class ProductsServiceConfig:
 
 class ProductsService(
     PublishableMixin[Product],
-    ManagedResourceMixin[Product],
+    ModifiableResourceMixin[Product],
     CollectionMixin[Product],
     Service[Product],
     ProductsServiceConfig,
 ):
     """Products service."""
 
+    def create(
+        self,
+        resource_data: ResourceData,
+        icon: FileTypes,
+    ) -> Model:
+        """Create product with icon.
+
+        Args:
+            resource_data: Product data.
+            icon: Icon image in jpg, png, GIF, etc.
+
+        Returns:
+            Created resource.
+        """
+        files: dict[str, FileTypes] = {}
+        files["product"] = (
+            None,
+            json.dumps(resource_data),
+            "application/json",
+        )
+        files["icon"] = icon
+        response = self.http_client.request("post", self.path, files=files)
+
+        return self._model_class.from_response(response)
+
     def item_groups(self, product_id: str) -> ItemGroupsService:
         """Return item_groups service."""
         return ItemGroupsService(
@@ -108,13 +136,37 @@ def update_settings(self, product_id: str, settings: ResourceData) -> Product:
 
 class AsyncProductsService(
     AsyncPublishableMixin[Product],
-    AsyncManagedResourceMixin[Product],
+    AsyncModifiableResourceMixin[Product],
     AsyncCollectionMixin[Product],
     AsyncService[Product],
     ProductsServiceConfig,
 ):
     """Products service."""
 
+    async def create(
+        self,
+        resource_data: ResourceData,
+        icon: FileTypes,
+    ) -> Model:
+        """Create product with icon.
+
+        Args:
+            resource_data: Product data.
+            icon: Icon image in jpg, png, GIF, etc.
+
+        Returns:
+            Created resource.
+        """
+        files: dict[str, FileTypes] = {}
+        files["product"] = (
+            None,
+            json.dumps(resource_data),
+            "application/json",
+        )
+        files["icon"] = icon
+        response = await self.http_client.request("post", self.path, files=files)
+        return self._model_class.from_response(response)
+
     def item_groups(self, product_id: str) -> AsyncItemGroupsService:
         """Return item_groups service."""
         return AsyncItemGroupsService(
diff --git a/setup.cfg b/setup.cfg
@@ -48,7 +48,7 @@ per-file-ignores =
   tests/unit/resources/accounts/test_users.py: WPS204 WPS202 WPS210
   tests/unit/test_mpt_client.py: WPS235
 
-  tests/unit/*:
+  tests/*:
     # Allow magic strings.
     WPS432
     # Found too many modules members.
diff --git a/tests/seed/__init__.py b/tests/seed/__init__.py
diff --git a/tests/seed/catalog/FIL-9920-4780-9379.png b/tests/seed/catalog/FIL-9920-4780-9379.png
diff --git a/tests/seed/catalog/__init__.py b/tests/seed/catalog/__init__.py
diff --git a/tests/seed/catalog/test_product.py b/tests/seed/catalog/test_product.py
@@ -0,0 +1,52 @@
+import datetime as dt
+import json
+import pathlib
+import uuid
+
+import httpx
+import pytest
+
+
+@pytest.fixture
+def icon_path():
+    return pathlib.Path(__file__).parent / "FIL-9920-4780-9379.png"
+
+
+@pytest.fixture
+def product_id(mpt_vendor, mpt_operations, icon_path):
+    product_data = {
+        "name": "Microsoft 365 online services for commercial",
+        "shortDescription": "Microsoft 365 and Office 365 [...]",
+        "longDescription": "Microsoft 365 and Office 365 [...long]",
+        "website": "https://www.microsoft.com",
+    }
+
+    with pathlib.Path.open(icon_path, "rb") as icon_file:
+        new_product = mpt_vendor.catalog.products.create(
+            product_data,
+            icon=icon_file,
+        )
+    assert new_product.meta.response.status_code == httpx.Response.raise_for_status()
+
+    return new_product.id
+
+
+@pytest.fixture
+def product_data(product_id):
+    return {
+        "product_id": product_id,
+    }
+
+
+@pytest.fixture
+def product_json_path():
+    date = dt.datetime.now(tz=dt.UTC).strftime("%Y-%m-%d")
+    test_run_id = str(uuid.uuid4())[:8]
+    return pathlib.Path(__file__).parent / f"../../../test-data-{date}-{test_run_id}.json"
+
+
+def test_save(product_json_path, product_data, logger):
+    catalog_data_json = json.dumps(product_data, indent=2)
+    pathlib.Path(product_json_path).write_text(catalog_data_json, encoding="utf-8")
+    logger.info("Saved commerce data to `%s`", product_json_path)
+    logger.debug(catalog_data_json)
diff --git a/tests/seed/conftest.py b/tests/seed/conftest.py
@@ -0,0 +1,30 @@
+import os
+
+import pytest
+
+from mpt_api_client import MPTClient
+
+
+@pytest.fixture
+def operations_token():
+    return os.getenv("MPT_API_TOKEN_OPERATIONS")
+
+
+@pytest.fixture
+def base_url():
+    return os.getenv("MPT_API_BASE_URL")
+
+
+@pytest.fixture
+def vendor_token():
+    return os.getenv("MPT_API_TOKEN_VENDOR")
+
+
+@pytest.fixture
+def mpt_vendor(vendor_token, base_url):
+    return MPTClient.from_config(api_token=vendor_token, base_url=base_url)
+
+
+@pytest.fixture
+def mpt_operations(operations_token, base_url):
+    return MPTClient.from_config(api_token=operations_token, base_url=base_url)
diff --git a/tests/unit/http/test_client.py b/tests/unit/http/test_client.py
@@ -19,7 +19,6 @@ def test_http_initialization(mocker):
         headers={
             "User-Agent": "swo-marketplace-client/1.0",
             "Authorization": "Bearer test-token",
-            "content-type": "application/json",
         },
         timeout=5.0,
         transport=mocker.ANY,
@@ -38,7 +37,6 @@ def test_env_initialization(monkeypatch, mocker):
         headers={
             "User-Agent": "swo-marketplace-client/1.0",
             "Authorization": f"Bearer {API_TOKEN}",
-            "content-type": "application/json",
         },
         timeout=5.0,
         transport=mocker.ANY,
diff --git a/tests/unit/http/test_mixins.py b/tests/unit/http/test_mixins.py
@@ -154,6 +154,7 @@ async def test_async_file_create_with_data(async_media_service):
         b"Content-Type: image/jpeg\r\n\r\n"
         b"Image content\r\n" in request.content
     )
+    assert "multipart/form-data" in request.headers["Content-Type"]
     assert new_media.to_dict() == media_data
 
 
@@ -261,6 +262,7 @@ def test_sync_file_create_with_data(media_service):
         b"Content-Type: image/jpeg\r\n\r\n"
         b"Image content\r\n" in request.content
     )
+    assert "multipart/form-data" in request.headers["Content-Type"]
     assert new_media.to_dict() == media_data
 
 
diff --git a/tests/unit/resources/catalog/test_products.py b/tests/unit/resources/catalog/test_products.py
@@ -135,3 +135,47 @@ async def test_async_update_settings(async_products_service):
     assert request.method == "PUT"
     assert request.url.path == f"/public/v1/catalog/products/{product_id}/settings"
     assert product.to_dict() == expected_response
+
+
+def test_product_create(products_service, tmp_path):
+    """Test creating a product (sync)."""
+    product_data = {"name": "New Product", "category": "Books"}
+    expected_response = {"id": "PRD-123", "name": "New Product", "category": "Books"}
+
+    # Create a temporary icon file
+    icon_path = tmp_path / "icon.png"
+    icon_path.write_bytes(b"fake image data")
+    with icon_path.open("rb") as icon_file, respx.mock:
+        mock_route = respx.post("https://api.example.com/public/v1/catalog/products").mock(
+            return_value=httpx.Response(httpx.codes.CREATED, json=expected_response)
+        )
+
+        product = products_service.create(product_data, icon=icon_file)
+
+    assert mock_route.call_count == 1
+    request = mock_route.calls[0].request
+    assert request.method == "POST"
+    assert request.url.path == "/public/v1/catalog/products"
+    assert product.to_dict() == expected_response
+
+
+async def test_async_product_create(async_products_service, tmp_path):
+    """Test creating a product (async)."""
+    product_data = {"name": "Async Product", "category": "Music"}
+    expected_response = {"id": "PRD-456", "name": "Async Product", "category": "Music"}
+
+    # Create a temporary icon file
+    icon_path = tmp_path / "icon.png"
+    icon_path.write_bytes(b"fake image data")
+    with icon_path.open("rb") as icon_file, respx.mock:
+        mock_route = respx.post("https://api.example.com/public/v1/catalog/products").mock(
+            return_value=httpx.Response(httpx.codes.CREATED, json=expected_response)
+        )
+
+        product = await async_products_service.create(product_data, icon=icon_file)
+
+    assert mock_route.call_count == 1
+    request = mock_route.calls[0].request
+    assert request.method == "POST"
+    assert request.url.path == "/public/v1/catalog/products"
+    assert product.to_dict() == expected_response

Original file line number	Diff line number	Diff line change
`@@ -49,7 +49,6 @@ def __init__(`
`49`	`49`	`base_headers = {`
`50`	`50`	`"User-Agent": "swo-marketplace-client/1.0",`
`51`	`51`	`"Authorization": f"Bearer {api_token}",`
`52`		`- "content-type": "application/json",`
`53`	`52`	`}`
`54`	`53`	`self.httpx_client = Client(`
`55`	`54`	`base_url=base_url,`
Original file line number	Diff line number	Diff line change
`@@ -86,7 +86,6 @@ def create(`
`86`	`86`	`_json_to_file_payload(resource_data),`
`87`	`87`	`"application/json",`
`88`	`88`	`)`
`89`		`-`
`90`	`89`	`response = self.http_client.request("post", self.path, files=files) # type: ignore[attr-defined]`
`91`	`90`
`92`	`91`	`return self._model_class.from_response(response) # type: ignore[attr-defined, no-any-return]`