#605 ebay store categories

Author: BranDavidSebastian

OneSila/OneSila/settings/base.py

@@ -429,6 +429,10 @@
     "https://api.ebay.com/oauth/api_scope/sell.stores.readonly",
     "https://api.ebay.com/oauth/scope/sell.edelivery",
     "https://api.ebay.com/oauth/api_scope/commerce.vero",
+    "https://api.ebay.com/oauth/api_scope/sell.inventory.mapping",
+    "https://api.ebay.com/oauth/api_scope/commerce.message",
+    "https://api.ebay.com/oauth/api_scope/commerce.feedback",
+    "https://api.ebay.com/oauth/api_scope/commerce.shipping",
 ]
 
 

OneSila/media/migrations/0007_auto_20250930_0953.py

@@ -28,8 +28,6 @@ def populate_image_titles(apps, schema_editor):
             media.title = title
             media.save(update_fields=['title'])
             updated_count += 1
-    
-    print(f"Updated {updated_count} image media objects with titles")
 
 
 def reverse_populate_image_titles(apps, schema_editor):
@@ -42,9 +40,6 @@ def reverse_populate_image_titles(apps, schema_editor):
 
     # Clear titles for all IMAGE type media
     Media.objects.filter(type=Media.IMAGE).update(title=None)
-    
-    print("Cleared titles for all IMAGE type media objects")
-
 
 
 class Migration(migrations.Migration):

OneSila/sales_channels/integrations/ebay/factories/imports/products_imports.py

@@ -39,7 +39,7 @@
     EbayMediaThroughProduct,
     EbayPrice,
     EbayProductContent,
-    EbayEanCode, EbayProductProperty, EbayProductCategory,
+    EbayEanCode, EbayProductProperty, EbayProductCategory, EbayStoreCategory, EbayProductStoreCategory,
 )
 from sales_channels.models import SalesChannelIntegrationPricelist, SalesChannelViewAssign
 from sales_prices.models import SalesPrice
@@ -1416,6 +1416,10 @@ def _extract_listing_details(*, payload: Mapping[str, Any] | None) -> tuple[str
             view=resolved_view,
             offer_payloads=offer_payloads,
         )
+        self._sync_product_store_categories(
+            product=local_product,
+            offer_payloads=offer_payloads,
+        )
 
     def _ensure_product_offer(
         self,
@@ -1551,6 +1555,145 @@ def _sync_product_category(
                 exc=exc,
             )
 
+    def _extract_offer_store_category_names(
+        self,
+        *offer_payloads: Mapping[str, Any] | None,
+    ) -> list[str] | None:
+        """Return normalized store category paths when explicitly declared by the offer payload."""
+
+        for payload in offer_payloads:
+            if not isinstance(payload, Mapping):
+                continue
+
+            for key in ("store_category_names", "storeCategoryNames"):
+                if key not in payload:
+                    continue
+
+                raw_values = payload.get(key)
+                if isinstance(raw_values, str):
+                    source_values = [raw_values]
+                elif isinstance(raw_values, list):
+                    source_values = raw_values
+                else:
+                    return []
+
+                normalized_values: list[str] = []
+                for raw_value in source_values:
+                    if raw_value is None:
+                        continue
+                    normalized = str(raw_value).strip()
+                    if normalized:
+                        normalized_values.append(normalized)
+
+                return normalized_values
+
+        return None
+
+    def _resolve_store_category_leaf_by_full_path(
+        self,
+        *,
+        full_path: str,
+    ) -> EbayStoreCategory | None:
+        """Resolve a store-category full path and return the leaf category when it exists."""
+
+        segments = [segment.strip() for segment in str(full_path).split("/") if segment and segment.strip()]
+        if not segments:
+            return None
+
+        parent_id: int | None = None
+        current: EbayStoreCategory | None = None
+        last_index = len(segments) - 1
+
+        for index, segment in enumerate(segments):
+            queryset = EbayStoreCategory.objects.filter(
+                sales_channel=self.sales_channel,
+                parent_id=parent_id,
+                name__iexact=segment,
+            )
+
+            # The requested path must end on a leaf category.
+            if index == last_index:
+                queryset = queryset.filter(is_leaf=True)
+
+            current = queryset.order_by("id").first()
+            if current is None:
+                return None
+
+            parent_id = current.id
+
+        return current
+
+    def _sync_product_store_categories(
+        self,
+        *,
+        product: Any | None,
+        offer_payloads: tuple[Mapping[str, Any] | None, ...],
+    ) -> None:
+        """Create/update product store-category mapping from offer storeCategoryNames."""
+
+        if product is None:
+            return
+
+        store_category_names = self._extract_offer_store_category_names(*offer_payloads)
+        if store_category_names is None:
+            return
+
+        resolved_categories: list[EbayStoreCategory] = []
+        seen_ids: set[int] = set()
+        for full_path in store_category_names:
+            category = self._resolve_store_category_leaf_by_full_path(full_path=full_path)
+            if category is None or category.id in seen_ids:
+                continue
+            resolved_categories.append(category)
+            seen_ids.add(category.id)
+            if len(resolved_categories) >= 2:
+                break
+
+        if not resolved_categories:
+            return
+
+        primary_category = resolved_categories[0]
+        secondary_category = resolved_categories[1] if len(resolved_categories) > 1 else None
+        mapping = (
+            EbayProductStoreCategory.objects.filter(
+                product=product,
+                sales_channel=self.sales_channel,
+            )
+            .order_by("id")
+            .first()
+        )
+
+        try:
+            if mapping is None:
+                mapping = EbayProductStoreCategory.objects.create(
+                    multi_tenant_company=self.multi_tenant_company,
+                    product=product,
+                    sales_channel=self.sales_channel,
+                    primary_store_category=primary_category,
+                    secondary_store_category=secondary_category,
+                )
+            else:
+                update_fields: list[str] = []
+                if mapping.primary_store_category_id != primary_category.id:
+                    mapping.primary_store_category = primary_category
+                    update_fields.append("primary_store_category")
+                desired_secondary_id = secondary_category.id if secondary_category else None
+                if mapping.secondary_store_category_id != desired_secondary_id:
+                    mapping.secondary_store_category = secondary_category
+                    update_fields.append("secondary_store_category")
+                if mapping.sales_channel_id != self.sales_channel.id:
+                    mapping.sales_channel = self.sales_channel
+                    update_fields.append("sales_channel")
+                if update_fields:
+                    mapping.save(update_fields=update_fields)
+        except ValidationError:
+            return
+
+        EbayProductStoreCategory.objects.filter(
+            product=product,
+            sales_channel=self.sales_channel,
+        ).exclude(id=mapping.id).delete()
+
     def update_remote_product(
         self,
         import_instance: Any,

OneSila/sales_channels/integrations/ebay/factories/mixins.py

@@ -44,6 +44,7 @@ def get_api(self) -> API:
             "refresh_token": self.sales_channel.refresh_token,
             "refresh_token_expiry": self.sales_channel.refresh_token_expiration.strftime("%Y-%m-%dT%H:%M:%S.%f")[:-3] + "Z",
             "email_or_username": "OneSila",
+            "scopes": settings.EBAY_APPLICATION_SCOPES,
             "password": "???"  # For some reason username and password are validating even if we provide the
             # refresh_token and we can add anything here
         }
@@ -126,6 +127,12 @@ def _get_account_api_base_url(self) -> str:
 
         return "https://api.ebay.com/sell/account/v1"
 
+    def _get_stores_api_base_url(self) -> str:
+        if self.sales_channel.environment == EbaySalesChannel.SANDBOX:
+            return "https://api.sandbox.ebay.com/sell/stores/v1"
+
+        return "https://api.ebay.com/sell/stores/v1"
+
     def _get_account_headers(self) -> dict[str, str]:
         api = getattr(self, "api", None)
         if api is None:
@@ -150,6 +157,23 @@ def _request_account_policy(self, endpoint: str, view_remote_id: str) -> dict:
         except ValueError:
             return {}
 
+    def _request_store(self, *, endpoint: str) -> dict:
+        """Call Store API with user token via requests, bypassing broken wrapper auth mode."""
+        url = f"{self._get_stores_api_base_url()}/{endpoint}"
+        headers = self._get_account_headers()
+        response = requests.get(url, headers=headers)
+        response.raise_for_status()
+        try:
+            return response.json()
+        except ValueError:
+            return {}
+
+    def get_store(self) -> dict:
+        return self._request_store(endpoint="store")
+
+    def get_store_categories(self) -> dict:
+        return self._request_store(endpoint="store/categories")
+
     def get_fulfillment_policies(self) -> dict:
         return self._request_account_policy("fulfillment_policy", self.view.remote_id)
 

OneSila/sales_channels/integrations/ebay/factories/products/mixins.py

@@ -29,7 +29,7 @@
     render_sales_channel_content_template,
 )
 
-from sales_channels.integrations.ebay.models import EbayCategory, EbayProductCategory
+from sales_channels.integrations.ebay.models import EbayCategory, EbayProductCategory, EbayProductStoreCategory
 from sales_channels.integrations.ebay.models.products import (
     EbayMediaThroughProduct,
     EbayProductOffer,
@@ -1851,6 +1851,33 @@ def _build_offer_metadata(self) -> Dict[str, Any]:
 
         return metadata
 
+    def _get_store_category_names(self, *, product) -> List[str]:
+        row = (
+            EbayProductStoreCategory.objects.filter(
+                product=product,
+                sales_channel=self.sales_channel,
+            )
+            .select_related("primary_store_category", "secondary_store_category")
+            .order_by("-id")
+            .first()
+        )
+
+        if row is None:
+            return []
+
+        names: List[str] = []
+        if row.primary_store_category:
+            primary_path = row.primary_store_category.full_path
+            if primary_path and primary_path not in names:
+                names.append(primary_path)
+
+        if row.secondary_store_category:
+            secondary_path = row.secondary_store_category.full_path
+            if secondary_path and secondary_path not in names:
+                names.append(secondary_path)
+
+        return names[:2]
+
     def _apply_offer_section(self, *, payload: Dict[str, Any], key: str, value: Any) -> None:
         if isinstance(value, Mapping):
             if value:
@@ -1882,6 +1909,11 @@ def build_offer_payload(self) -> Dict[str, Any]:
                 key="secondaryCategoryId",
                 value=secondary_category_id,
             )
+        self._apply_offer_section(
+            payload=payload,
+            key="storeCategoryNames",
+            value=self._get_store_category_names(product=product) or None,
+        )
         self._apply_offer_section(
             payload=payload,
             key="listingPolicies",

OneSila/sales_channels/integrations/ebay/factories/sales_channels/__init__.py

@@ -3,6 +3,7 @@
 from .languages import EbayRemoteLanguagePullFactory
 from .views import EbaySalesChannelViewPullFactory
 from .categories import EbayCategorySuggestionFactory
+from .store_categories import EbayStoreCategoryPullFactory
 from .full_schema import EbayProductTypeRuleFactory
 from .product_type_mapping import EbayProductTypeRemoteMappingFactory
 
@@ -14,5 +15,6 @@
     'EbaySalesChannelViewPullFactory',
     'EbayProductTypeRuleFactory',
     'EbayCategorySuggestionFactory',
+    'EbayStoreCategoryPullFactory',
     'EbayProductTypeRemoteMappingFactory',
 ]