Merge branch 'master' of github.com:judge0/judge0-py into setup-logging

Author: fkdosilovic

docs/source/conf.py

@@ -97,7 +97,7 @@
     "special-members": False,
     "inherited-members": False,
 }
-autodoc_mock_imports = ["requests", "pydantic"]
+autodoc_mock_imports = ["httpx", "pydantic"]
 
 napoleon_google_docstring = False
 

docs/source/in_depth/client_resolution.rst

@@ -24,7 +24,7 @@ If a custom client is not configured, the SDK will try to find API keys for one
 
 * **Judge0 Cloud**:
     * ``JUDGE0_CLOUD_CE_AUTH_HEADERS`` for ``Judge0CloudCE``
-    * ``JUDGE0_CLOUD_EXTRA_CE_AUTH_HEADERS` for ``Judge0CloudExtraCE``
+    * ``JUDGE0_CLOUD_EXTRA_CE_AUTH_HEADERS`` for ``Judge0CloudExtraCE``
 
 * **RapidAPI**:
     *   ``JUDGE0_RAPID_API_KEY`` for both ``RapidJudge0CE`` and ``RapidJudge0ExtraCE``

pyproject.toml

@@ -24,7 +24,7 @@ classifiers = [
     "Topic :: Software Development :: Libraries :: Python Modules",
     "Typing :: Typed",
 ]
-dependencies = ["requests>=2.28.0,<3.0.0", "pydantic>=2.0.0,<3.0.0"]
+dependencies = ["httpx>=0.28.1,<1.0.0", "pydantic>=2.0.0,<3.0.0"]
 
 [build-system]
 requires = ["setuptools>=70.0"]

src/judge0/clients.py

@@ -1,6 +1,6 @@
 from typing import ClassVar, Optional, Union
 
-import requests
+import httpx
 
 from .base_types import Config, Iterable, Language, LanguageAlias
 from .data import LANGUAGE_TO_LANGUAGE_ID
@@ -40,7 +40,7 @@ def __init__(
         self.endpoint = endpoint
         self.auth_headers = auth_headers
         self.retry_strategy = retry_strategy
-        self.session = requests.Session()
+        self.client = httpx.Client()
 
         try:
             self.languages = self.get_languages()
@@ -53,7 +53,7 @@ def __init__(
             ) from e
 
     def __del__(self):
-        self.session.close()
+        self.client.close()
 
     @handle_too_many_requests_error_for_preview_client
     def get_about(self) -> dict:
@@ -64,7 +64,7 @@ def get_about(self) -> dict:
         dict
             General information about judge0.
         """
-        response = self.session.get(
+        response = self.client.get(
             f"{self.endpoint}/about",
             headers=self.auth_headers,
         )
@@ -80,7 +80,7 @@ def get_config_info(self) -> Config:
         Config
             Client's configuration.
         """
-        response = self.session.get(
+        response = self.client.get(
             f"{self.endpoint}/config_info",
             headers=self.auth_headers,
         )
@@ -102,7 +102,7 @@ def get_language(self, language_id: int) -> Language:
             Language corresponding to the passed id.
         """
         request_url = f"{self.endpoint}/languages/{language_id}"
-        response = self.session.get(request_url, headers=self.auth_headers)
+        response = self.client.get(request_url, headers=self.auth_headers)
         response.raise_for_status()
         return Language(**response.json())
 
@@ -116,7 +116,7 @@ def get_languages(self) -> list[Language]:
             A list of supported languages.
         """
         request_url = f"{self.endpoint}/languages"
-        response = self.session.get(request_url, headers=self.auth_headers)
+        response = self.client.get(request_url, headers=self.auth_headers)
         response.raise_for_status()
         return [Language(**lang_dict) for lang_dict in response.json()]
 
@@ -129,7 +129,7 @@ def get_statuses(self) -> list[dict]:
         list of dict
             A list of possible submission statues.
         """
-        response = self.session.get(
+        response = self.client.get(
             f"{self.endpoint}/statuses",
             headers=self.auth_headers,
         )
@@ -208,7 +208,7 @@ def create_submission(self, submission: Submission) -> Submission:
 
         body = submission.as_body(self)
 
-        response = self.session.post(
+        response = self.client.post(
             f"{self.endpoint}/submissions",
             json=body,
             params=params,
@@ -254,7 +254,7 @@ def get_submission(
         else:
             params["fields"] = "*"
 
-        response = self.session.get(
+        response = self.client.get(
             f"{self.endpoint}/submissions/{submission.token}",
             params=params,
             headers=self.auth_headers,
@@ -291,7 +291,7 @@ def create_submissions(self, submissions: Submissions) -> Submissions:
 
         submissions_body = [submission.as_body(self) for submission in submissions]
 
-        response = self.session.post(
+        response = self.client.post(
             f"{self.endpoint}/submissions/batch",
             headers=self.auth_headers,
             params={"base64_encoded": "true"},
@@ -342,7 +342,7 @@ def get_submissions(
         tokens = ",".join([submission.token for submission in submissions])
         params["tokens"] = tokens
 
-        response = self.session.get(
+        response = self.client.get(
             f"{self.endpoint}/submissions/batch",
             params=params,
             headers=self.auth_headers,

src/judge0/utils.py

@@ -3,15 +3,14 @@
 from functools import wraps
 from http import HTTPStatus
 
-from requests import HTTPError
+from httpx import HTTPError, HTTPStatusError
 
 from .errors import PreviewClientLimitError
 
 
 def is_http_too_many_requests_error(exception: Exception) -> bool:
     return (
-        isinstance(exception, HTTPError)
-        and exception.response is not None
+        isinstance(exception, HTTPStatusError)
         and exception.response.status_code == HTTPStatus.TOO_MANY_REQUESTS
     )