MPT-14767 E2E seeding proof of concept

- Added seeding proof of concept
- Fix create product request

Run: docker compose run --rm bash python seed/main.py

Author: albertsola

mpt_api_client/http/async_service.py

@@ -31,19 +31,20 @@ async def _resource_do_request(  # noqa: WPS211
     ) -> Response:
         """Perform an action on a specific resource using.
 
-        Request with action: `HTTP_METHOD /endpoint/{resource_id}/{action}`.
-        Request without action: `HTTP_METHOD /endpoint/{resource_id}`.
+        :Loading parameter group
+                Request with action: `HTTP_METHOD /endpoint/{resource_id}/{action}`.
+                Request without action: `HTTP_METHOD /endpoint/{resource_id}`.
 
         Args:
-            resource_id: The resource ID to operate on.
-            method: The HTTP method to use.
-            action: The action name to use.
-            json: The updated resource data.
-            query_params: Additional query parameters.
-            headers: Additional headers.
+                    resource_id: The resource ID to operate on.
+                    method: The HTTP method to use.
+                    action: The action name to use.
+                    json: The updated resource data.
+                    query_params: Additional query parameters.
+                    headers: Additional headers.
 
         Raises:
-            HTTPError: If the action fails.
+                    HTTPError: If the action fails.
         """
         resource_url = urljoin(f"{self.path}/", resource_id)
         url = urljoin(f"{resource_url}/", action) if action else resource_url

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,

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]

mpt_api_client/models/model.py

@@ -52,6 +52,11 @@ def from_response(cls, response: Response) -> Self:
         meta = Meta.from_response(response)
         return cls.new(response_data, meta)
 
+    @property
+    def id(self) -> str:
+        """Returns the resource ID."""
+        return str(self._resource_data.get("id", ""))  # type: ignore[no-untyped-call]
+
     def to_dict(self) -> dict[str, Any]:
         """Returns the resource as a dictionary."""
         return self._resource_data.to_dict()

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,
+    ) -> Product:
+        """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,
+    ) -> Product:
+        """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(

pyproject.toml

@@ -26,6 +26,7 @@ dependencies = [
 
 [dependency-groups]
 dev = [
+    "dependency-injector>=4.48.2",
     "freezegun==1.5.*",
     "ipdb==0.13.*",
     "ipython==9.*",

seed/__init__.py

@@ -0,0 +1,39 @@
+import asyncio
+import logging
+from typing import Any
+
+from seed.catalog.item import seed_items
+from seed.catalog.item_group import seed_item_group
+from seed.catalog.product import seed_product
+from seed.catalog.product_parameters import seed_parameters
+from seed.catalog.product_parameters_group import seed_parameter_group
+
+logger = logging.getLogger(__name__)
+
+
+async def seed_catalog_stage1() -> None:
+    """Seed parallel tasks for item groups and parameter groups."""
+    tasks: list[asyncio.Task[Any]] = [
+        asyncio.create_task(seed_item_group()),
+        asyncio.create_task(seed_parameter_group()),
+    ]
+    await asyncio.gather(*tasks)
+
+
+async def seed_catalog_stage2() -> None:
+    """Seed final tasks for items and parameters."""
+    tasks: list[asyncio.Task[Any]] = [
+        asyncio.create_task(seed_items()),
+        asyncio.create_task(seed_parameters()),
+    ]
+    await asyncio.gather(*tasks)
+
+
+async def seed_catalog() -> None:
+    """Seed catalog data including products, item groups, and parameters."""
+    logger.debug("Seeding catalog ...")
+    await seed_product()
+    await seed_catalog_stage1()
+    await seed_catalog_stage2()
+
+    logger.debug("Seeded catalog completed.")