1.3.0

Automatically generated by python-semantic-release

Author: semantic-release

pyproject.toml

@@ -4,7 +4,7 @@ build-backend = "hatchling.build"
 
 [project]
 name = "lingodotdev"
-version = "1.2.0"
+version = "1.3.0"
 description = "Lingo.dev Python SDK"
 readme = "README.md"
 requires-python = ">=3.8"

src/lingodotdev/__init__.py

@@ -5,7 +5,7 @@
 plain text, objects, chat sequences, and HTML documents.
 """
 
-__version__ = "1.2.0"
+__version__ = "1.3.0"
 
 from .engine import LingoDotDevEngine
 

src/lingodotdev/engine.py

@@ -5,6 +5,7 @@
 # mypy: disable-error-code=unreachable
 
 import asyncio
+import json
 from typing import Any, Callable, Dict, List, Optional
 from urllib.parse import urljoin
 
@@ -80,6 +81,36 @@ async def close(self):
         if self._client and not self._client.is_closed:
             await self._client.aclose()
 
+    @staticmethod
+    def _truncate_response(text: str, max_length: int = 200) -> str:
+        """Truncate response text for error messages"""
+        if len(text) > max_length:
+            return text[:max_length] + "..."
+        return text
+
+    @staticmethod
+    def _safe_parse_json(response: httpx.Response) -> Dict[str, Any]:
+        """
+        Safely parse JSON response, handling HTML error pages gracefully.
+
+        Args:
+            response: The httpx response object
+
+        Returns:
+            Parsed JSON as a dictionary
+
+        Raises:
+            RuntimeError: If the response cannot be parsed as JSON
+        """
+        try:
+            return response.json()
+        except json.JSONDecodeError:
+            preview = LingoDotDevEngine._truncate_response(response.text)
+            raise RuntimeError(
+                f"Failed to parse API response as JSON (status {response.status_code}). "
+                f"This may indicate a gateway or proxy error. Response: {preview}"
+            )
+
     async def _localize_raw(
         self,
         payload: Dict[str, Any],
@@ -184,19 +215,31 @@ async def _localize_chunk(
             response = await self._client.post(url, json=request_data)
 
             if not response.is_success:
+                response_preview = self._truncate_response(response.text)
                 if 500 <= response.status_code < 600:
+                    error_details = ""
+                    try:
+                        error_json = response.json()
+                        if isinstance(error_json, dict) and "error" in error_json:
+                            error_details = f" {error_json['error']}"
+                    except Exception:
+                        pass
+
                     raise RuntimeError(
-                        f"Server error ({response.status_code}): {response.reason_phrase}. "
-                        f"{response.text}. This may be due to temporary service issues."
+                        f"Server error ({response.status_code}): {response.reason_phrase}.{error_details} "
+                        "This may be due to temporary service issues."
                     )
                 elif response.status_code == 400:
                     raise ValueError(
-                        f"Invalid request ({response.status_code}): {response.reason_phrase}"
+                        f"Invalid request ({response.status_code}): {response.reason_phrase}. "
+                        f"Response: {response_preview}"
                     )
                 else:
-                    raise RuntimeError(response.text)
+                    raise RuntimeError(
+                        f"Request failed ({response.status_code}): {response_preview}"
+                    )
 
-            json_response = response.json()
+            json_response = self._safe_parse_json(response)
 
             # Handle streaming errors
             if not json_response.get("data") and json_response.get("error"):
@@ -426,16 +469,26 @@ async def recognize_locale(self, text: str) -> str:
             response = await self._client.post(url, json={"text": text})
 
             if not response.is_success:
+                response_preview = self._truncate_response(response.text)
                 if 500 <= response.status_code < 600:
+                    error_details = ""
+                    try:
+                        error_json = response.json()
+                        if isinstance(error_json, dict) and "error" in error_json:
+                            error_details = f" {error_json['error']}"
+                    except Exception:
+                        pass
+
                     raise RuntimeError(
-                        f"Server error ({response.status_code}): {response.reason_phrase}. "
+                        f"Server error ({response.status_code}): {response.reason_phrase}.{error_details} "
                         "This may be due to temporary service issues."
                     )
                 raise RuntimeError(
-                    f"Error recognizing locale: {response.reason_phrase}"
+                    f"Error recognizing locale ({response.status_code}): {response.reason_phrase}. "
+                    f"Response: {response_preview}"
                 )
 
-            json_response = response.json()
+            json_response = self._safe_parse_json(response)
             return json_response.get("locale") or ""
 
         except httpx.RequestError as e:
@@ -456,13 +509,21 @@ async def whoami(self) -> Optional[Dict[str, str]]:
             response = await self._client.post(url)
 
             if response.is_success:
-                payload = response.json()
+                payload = self._safe_parse_json(response)
                 if payload.get("email"):
                     return {"email": payload["email"], "id": payload["id"]}
 
             if 500 <= response.status_code < 600:
+                error_details = ""
+                try:
+                    error_json = response.json()
+                    if isinstance(error_json, dict) and "error" in error_json:
+                        error_details = f" {error_json['error']}"
+                except Exception:
+                    pass
+
                 raise RuntimeError(
-                    f"Server error ({response.status_code}): {response.reason_phrase}. "
+                    f"Server error ({response.status_code}): {response.reason_phrase}.{error_details} "
                     "This may be due to temporary service issues."
                 )
 

tests/test_502_handling.py

@@ -0,0 +1,63 @@
+import pytest
+import json
+from unittest.mock import Mock, patch
+from lingodotdev import LingoDotDevEngine
+
+
+@pytest.mark.asyncio
+async def test_502_html_handling():
+    """Test that 502 errors with HTML bodies are sanitized"""
+    config = {"api_key": "test_key", "api_url": "https://api.test.com"}
+
+    html_body = "<html><body>" + ("<h1>502 Bad Gateway</h1>" * 50) + "</body></html>"
+    assert len(html_body) > 200  # Ensure it triggers truncation
+
+    with patch("lingodotdev.engine.httpx.AsyncClient.post") as mock_post:
+        mock_response = Mock()
+        mock_response.is_success = False
+        mock_response.status_code = 502
+        mock_response.reason_phrase = "Bad Gateway"
+        mock_response.text = html_body
+        mock_response.json.side_effect = ValueError(
+            "Not JSON"
+        )  # simulating non-JSON response
+        mock_post.return_value = mock_response
+
+        async with LingoDotDevEngine(config) as engine:
+            with pytest.raises(RuntimeError) as exc_info:
+                await engine.localize_text("hello", {"target_locale": "es"})
+
+        error_msg = str(exc_info.value)
+
+        # Assertions
+        assert "Server error (502): Bad Gateway." in error_msg
+        assert "This may be due to temporary service issues." in error_msg
+        assert "Response:" not in error_msg
+        assert "<html>" not in error_msg
+        assert "<body>" not in error_msg
+
+
+@pytest.mark.asyncio
+async def test_500_json_handling():
+    """Test that 500 errors with JSON bodies are preserved"""
+    config = {"api_key": "test_key", "api_url": "https://api.test.com"}
+    error_json = {"error": "Specific internal error message"}
+
+    with patch("lingodotdev.engine.httpx.AsyncClient.post") as mock_post:
+        mock_response = Mock()
+        mock_response.is_success = False
+        mock_response.status_code = 500
+        mock_response.reason_phrase = "Internal Server Error"
+        mock_response.text = json.dumps(error_json)  # Needed for response_preview
+        mock_response.json.return_value = error_json
+        mock_post.return_value = mock_response
+
+        async with LingoDotDevEngine(config) as engine:
+            with pytest.raises(RuntimeError) as exc_info:
+                await engine.localize_text("hello", {"target_locale": "es"})
+
+        error_msg = str(exc_info.value)
+
+        # Assertions
+        assert "Server error (500): Internal Server Error." in error_msg
+        assert "Specific internal error message" in error_msg