Merge pull request #1068 from airweave-ai/feat/add_hubspot_logging

feat(hubspot): add comprehensive logging on http errors

Author: felixschmetz

backend/airweave/platform/sources/hubspot.py

@@ -81,6 +81,29 @@ async def _get_with_auth(self, client: httpx.AsyncClient, url: str) -> Dict:
             headers = {"Authorization": f"Bearer {access_token}"}
             response = await client.get(url, headers=headers)
 
+        # Log detailed error information for 4xx/5xx responses before raising
+        if not response.is_success:
+            try:
+                error_body = response.json()
+                correlation_id = error_body.get("correlationId", "N/A")
+                error_message = error_body.get("message", "No message provided")
+                error_category = error_body.get("category", "Unknown")
+                self.logger.error(
+                    f"❌ HubSpot API error at {url} - "
+                    f"Status: {response.status_code}, "
+                    f"Message: {error_message}, "
+                    f"Category: {error_category}, "
+                    f"CorrelationId: {correlation_id}, "
+                    f"Full response: {error_body}"
+                )
+            except Exception:
+                # If we can't parse JSON, log the raw response
+                self.logger.error(
+                    f"❌ HubSpot API error at {url} - "
+                    f"Status: {response.status_code}, "
+                    f"Response: {response.text}"
+                )
+
         response.raise_for_status()
         return response.json()
 
@@ -124,6 +147,31 @@ async def _post_with_auth(
             }
             response = await client.post(url, headers=headers, json=json_data)
 
+        # Log detailed error information for 4xx/5xx responses before raising
+        if not response.is_success:
+            try:
+                error_body = response.json()
+                correlation_id = error_body.get("correlationId", "N/A")
+                error_message = error_body.get("message", "No message provided")
+                error_category = error_body.get("category", "Unknown")
+                self.logger.error(
+                    f"❌ HubSpot API error at {url} - "
+                    f"Status: {response.status_code}, "
+                    f"Message: {error_message}, "
+                    f"Category: {error_category}, "
+                    f"CorrelationId: {correlation_id}, "
+                    f"Request body: {json_data}, "
+                    f"Full response: {error_body}"
+                )
+            except Exception:
+                # If we can't parse JSON, log the raw response
+                self.logger.error(
+                    f"❌ HubSpot API error at {url} - "
+                    f"Status: {response.status_code}, "
+                    f"Request body: {json_data}, "
+                    f"Response: {response.text}"
+                )
+
         response.raise_for_status()
         return response.json()