From a049ab2e99ae266ca47d20cdc6df8a892dd224b5 Mon Sep 17 00:00:00 2001
From: Luke <conway220@gmail.com>
Date: Fri, 7 Jun 2024 13:42:15 -0400
Subject: [PATCH] feat: add warning in web requests if it fails to decode

---
 roborock/web_api.py | 32 ++++++++++++++++++++++++--------
 1 file changed, 24 insertions(+), 8 deletions(-)

diff --git a/roborock/web_api.py b/roborock/web_api.py
index 33450dd..44646f6 100644
--- a/roborock/web_api.py
+++ b/roborock/web_api.py
@@ -3,11 +3,13 @@
 import base64
 import hashlib
 import hmac
+import logging
 import math
 import secrets
 import time
 
 import aiohttp
+from aiohttp import ContentTypeError
 
 from roborock.containers import HomeData, HomeDataRoom, ProductResponse, RRiot, UserData
 from roborock.exceptions import (
@@ -23,6 +25,8 @@
     RoborockUrlException,
 )
 
+_LOGGER = logging.getLogger(__name__)
+
 
 class RoborockApiClient:
     def __init__(self, username: str, base_url=None) -> None:
@@ -294,11 +298,23 @@ async def request(self, method: str, url: str, params=None, data=None, headers=N
         _url = "/".join(s.strip("/") for s in [self.base_url, url])
         _headers = {**self.base_headers, **(headers or {})}
         async with aiohttp.ClientSession() as session:
-            async with session.request(
-                method,
-                _url,
-                params=params,
-                data=data,
-                headers=_headers,
-            ) as resp:
-                return await resp.json()
+            try:
+                async with session.request(
+                    method,
+                    _url,
+                    params=params,
+                    data=data,
+                    headers=_headers,
+                ) as resp:
+                    return await resp.json()
+            except ContentTypeError as err:
+                """If we get an error, lets log everything for debugging."""
+                try:
+                    resp_json = await resp.json(content_type=None)
+                    _LOGGER.info("Resp: %s", resp_json)
+                except ContentTypeError as err_2:
+                    _LOGGER.info(err_2)
+                resp_raw = await resp.read()
+                _LOGGER.info("Resp raw: %s", resp_raw)
+                # Still raise the err so that it's clear it failed.
+                raise err