Update seeding for Catalog

Author: albertsola

pyproject.toml

@@ -121,6 +121,7 @@ per-file-ignores = [
   "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/rql/query_builder.py: WPS110 WPS115 WPS210 WPS214",
+  "seed/catalog/product.py: WPS202 WPS217 WPS201 WPS213",
   "tests/unit/http/test_async_service.py: WPS204 WPS202",
   "tests/unit/http/test_service.py: WPS204 WPS202",
   "tests/unit/http/test_mixins.py: WPS204 WPS202 WPS210",
@@ -131,6 +132,7 @@ per-file-ignores = [
   "tests/e2e/accounts/*.py: WPS430 WPS202",
   "tests/e2e/catalog/*.py: WPS202 WPS421",
   "tests/e2e/catalog/items/*.py: WPS110 WPS202",
+  "tests/seed/catalog/test_product.py: WPS202 WPS219",
   "tests/*: WPS432 WPS202",
   "seed/accounts/*.py: WPS453",
 ]

seed/accounts/buyer.py

@@ -11,7 +11,7 @@
 
 logger = logging.getLogger(__name__)
 
-icon = pathlib.Path("seed/data/logo.png").resolve()
+icon = pathlib.Path(__file__).parent.parent / "data/logo.png"
 
 
 @inject

seed/catalog/authorization.py

@@ -0,0 +1,35 @@
+import uuid
+
+from mpt_api_client import AsyncMPTClient
+from mpt_api_client.resources.catalog.authorizations import Authorization
+from seed.context import Context
+from seed.defaults import DEFAULT_CONTEXT, DEFAULT_MPT_OPERATIONS
+from seed.helper import init_resource, require_context_id
+
+
+async def seed_authorization(context: Context = DEFAULT_CONTEXT) -> None:
+    """Seed authorization."""
+    await init_resource("catalog.authorization.id", create_authorization, context)
+
+
+async def create_authorization(
+    operations: AsyncMPTClient = DEFAULT_MPT_OPERATIONS, context: Context = DEFAULT_CONTEXT
+) -> Authorization:
+    """Creates an authorization."""
+    product_id = require_context_id(context, "catalog.product.id", "Create authorization")
+    seller_id = require_context_id(context, "accounts.seller.id", "Create authorization")
+    account_id = require_context_id(context, "accounts.account.id", "Create authorization")
+    short_uuid = uuid.uuid4().hex[:8]
+
+    authorization_data = {
+        "externalIds": {"operations": f"e2e-seeded-{short_uuid}"},
+        "product": {"id": product_id},
+        "owner": {"id": seller_id},
+        "journal": {"firstInvoiceDate": "2025-12-01", "frequency": "1m"},
+        "eligibility": {"client": True, "partner": True},
+        "currency": "USD",
+        "notes": "E2E Seeded",
+        "name": "E2E Seeded",
+        "vendor": {"id": account_id},
+    }
+    return await operations.catalog.authorizations.create(authorization_data)

seed/catalog/catalog.py

@@ -1,39 +1,19 @@
-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.authorization import seed_authorization
+from seed.catalog.listing import seed_listing
+from seed.catalog.price_list import seed_price_list
 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_groups_and_group_params() -> 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_items_and_params() -> 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_groups_and_group_params()
-    await seed_items_and_params()
+    await seed_authorization()
+    await seed_price_list()
+    await seed_listing()
 
     logger.debug("Seeded catalog completed.")

seed/catalog/listing.py

@@ -0,0 +1,42 @@
+from mpt_api_client import AsyncMPTClient
+from mpt_api_client.resources.catalog.listings import Listing
+from seed.context import Context
+from seed.defaults import DEFAULT_CONTEXT, DEFAULT_MPT_OPERATIONS
+from seed.helper import init_resource, require_context_id
+
+
+async def seed_listing(context: Context = DEFAULT_CONTEXT) -> None:
+    """Seed listing."""
+    await init_resource("catalog.listing.id", create_listing, context)
+
+
+async def create_listing(  # noqa: WPS210
+    operations: AsyncMPTClient = DEFAULT_MPT_OPERATIONS, context: Context = DEFAULT_CONTEXT
+) -> Listing:
+    """Creates a listing."""
+    product_id = require_context_id(context, "catalog.product.id", "Create listing")
+    seller_id = require_context_id(context, "accounts.seller.id", "Create authorization")
+    authorization_id = require_context_id(context, "accounts.authorization.id", "Create listing")
+    account_id = require_context_id(context, "accounts.account.id", "Create listing")
+    price_list_id = require_context_id(context, "accounts.price_list.id", "Create listing")
+
+    listing_data = {
+        "name": "e2e - please delete",
+        "authorization": {
+            "id": authorization_id,
+        },
+        "product": {
+            "id": product_id,
+        },
+        "vendor": {
+            "id": account_id,
+        },
+        "seller": {
+            "id": seller_id,
+        },
+        "priceList": {"id": price_list_id},
+        "primary": False,
+        "notes": "",
+        "eligibility": {"client": True, "partner": False},
+    }
+    return await operations.catalog.listings.create(listing_data)

seed/catalog/price_list.py

@@ -0,0 +1,26 @@
+from mpt_api_client import AsyncMPTClient
+from mpt_api_client.resources.catalog.price_lists import PriceList
+from seed.context import Context
+from seed.defaults import DEFAULT_CONTEXT, DEFAULT_MPT_OPERATIONS
+from seed.helper import init_resource, require_context_id
+
+
+async def seed_price_list(context: Context = DEFAULT_CONTEXT) -> None:
+    """Seed price list."""
+    await init_resource("catalog.price_list.id", create_price_list, context)
+
+
+async def create_price_list(
+    operations: AsyncMPTClient = DEFAULT_MPT_OPERATIONS, context: Context = DEFAULT_CONTEXT
+) -> PriceList:
+    """Creates a price list."""
+    product_id = require_context_id(context, "catalog.product.id", "Create authorization")
+
+    price_list_data = {
+        "notes": "E2E Seeded",
+        "defaultMarkup": "20.0",
+        "product": {"id": product_id},
+        "currency": "USD",
+        "default": False,
+    }
+    return await operations.catalog.price_lists.create(price_list_data)