use get_response_json in get_category_products

Adds the body guard this site lacked; a non-dict body now logs and
returns before the fan-out instead of raising on searchTotalCount.

samsung_shop/samsung_shop_monitor.py

@@ -4,7 +4,7 @@ from urllib.parse import urlencode
 
 from aioweb_tls import TLSSession
 from monitor_utils.config import DevelopmentMode
-from monitor_utils.constants import CYCLE_DELAY, EXPECTED_TASK_ERRORS
+from monitor_utils.constants import CYCLE_DELAY
 from monitor_utils.database import add_products_to_database
 from monitor_utils.models import AvailabilityInfo, PricingInfo, Product, ProductMetadata
 from monitor_utils.runner import (
@@ -14,7 +14,7 @@ from monitor_utils.runner import (
     run_bounded_cycle,
     setup_monitor_logging,
 )
-from monitor_utils.sessions import send_request
+from monitor_utils.sessions import get_response_json, send_request
 from motor.motor_asyncio import AsyncIOMotorCollection
 
 setup_monitor_logging(monitor="samsung_shop")
@@ -53,7 +53,6 @@ async def get_category_products(
     offset=0,
 ):
     LOGGER.debug("getting products", extra={"category": category_id, "offset": offset})
-    try:
     response = await send_request(
         session,
         url="https://sribsrch.ecom.samsung.com/estoresearch-api/v1/scom/us/pf_search",
@@ -73,14 +72,13 @@ async def get_category_products(
         ),
         headers={"content-type": "application/x-www-form-urlencoded"},
     )
-    except EXPECTED_TASK_ERRORS:
-        LOGGER.warning(
-            "failed to get products",
-            extra={"category": category_id, "offset": offset},
-        )
-        raise
 
-    data = response.json()
+    data = get_response_json(
+        response, logger=LOGGER, category=category_id, offset=offset
+    )
+    if data is None:
+        return
+
     if offset != 0:
         await process_page(data, category_id, offset, collection)
         return
@@ -114,14 +112,13 @@ async def process_page(
 ):
     """Extract and persist one page of category search results."""
 
-    try:
     products = extract_products(response)
     if products:
         await add_products_to_database(
             products,
             collection,
             category_identifier=category_id,
-                monitor_name="samsung_shop",
+            monitor="samsung_shop",
         )
         LOGGER.info(
             "added products",
@@ -136,12 +133,6 @@ async def process_page(
             "no products found",
             extra={"category": category_id, "offset": offset},
         )
-    except EXPECTED_TASK_ERRORS:
-        LOGGER.warning(
-            "failed to build products",
-            extra={"category": category_id, "offset": offset},
-        )
-        raise
 
 
 def extract_products(response: dict) -> list[Product]: