Rename _HttpResponse to _AsyncResponse

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: Abel Milash

src/PowerPlatform/Dataverse/aio/core/_async_http.py

@@ -22,7 +22,7 @@
     from ...core._http_logger import _HttpLogger
 
 
-class _HttpResponse:
+class _AsyncResponse:
     """Materialized HTTP response returned by :class:`_AsyncHttpClient._request`.
 
     The body is fully buffered before this object is constructed, so all
@@ -88,14 +88,14 @@ def __init__(
         self._session = session
         self._logger = logger
 
-    async def _request(self, method: str, url: str, **kwargs: Any) -> _HttpResponse:
+    async def _request(self, method: str, url: str, **kwargs: Any) -> _AsyncResponse:
         """
         Execute an HTTP request asynchronously with automatic retry logic and timeout management.
 
         Applies default timeouts based on HTTP method (120s for POST/DELETE, 10s for others)
         and retries on network errors with exponential backoff.
 
-        The response body is fully buffered and returned as a :class:`_HttpResponse` whose
+        The response body is fully buffered and returned as a :class:`_AsyncResponse` whose
         accessors (``.text``, ``.json()``) are synchronous — no ``await`` required on the caller side.
 
         :param method: HTTP method (GET, POST, PUT, DELETE, etc.).
@@ -105,7 +105,7 @@ async def _request(self, method: str, url: str, **kwargs: Any) -> _HttpResponse:
         :param kwargs: Additional arguments passed to ``aiohttp.ClientSession.request()``,
             including headers, data, etc.
         :return: Materialized HTTP response with body fully buffered.
-        :rtype: :class:`_HttpResponse`
+        :rtype: :class:`_AsyncResponse`
         :raises aiohttp.ClientError: If all retry attempts fail.
         :raises RuntimeError: If no session has been set.
         """
@@ -144,7 +144,7 @@ async def _request(self, method: str, url: str, **kwargs: Any) -> _HttpResponse:
                 t0 = time.monotonic()
                 async with self._session.request(method, url, **kwargs) as resp:
                     body = await resp.read()
-                    materialized = _HttpResponse(resp.status, dict(resp.headers), body)
+                    materialized = _AsyncResponse(resp.status, dict(resp.headers), body)
                 elapsed_ms = (time.monotonic() - t0) * 1000
 
                 if self._logger is not None:

src/PowerPlatform/Dataverse/aio/data/_async_odata.py

@@ -16,7 +16,7 @@
 
 from urllib.parse import quote as _url_quote
 
-from ..core._async_http import _AsyncHttpClient, _HttpResponse
+from ..core._async_http import _AsyncHttpClient, _AsyncResponse
 from ._async_upload import _AsyncFileUploadMixin
 from ._async_relationships import _AsyncRelationshipOperationsMixin
 from ...core.errors import *
@@ -107,7 +107,7 @@ async def _headers(self) -> Dict[str, str]:
             "User-Agent": ua,
         }
 
-    async def _raw_request(self, method: str, url: str, **kwargs) -> _HttpResponse:
+    async def _raw_request(self, method: str, url: str, **kwargs) -> _AsyncResponse:
         return await self._http._request(method, url, **kwargs)
 
     async def _request(
@@ -117,7 +117,7 @@ async def _request(
         *,
         expected: tuple[int, ...] = _DEFAULT_EXPECTED_STATUSES,
         **kwargs,
-    ) -> _HttpResponse:
+    ) -> _AsyncResponse:
         # Acquire base headers once (async), then use a sync closure for _RequestContext.build.
         # _RequestContext.build is a sync classmethod defined in _ODataBase and shared by both
         # sync and async clients — keeping it sync avoids duplicating the header-injection logic.
@@ -201,7 +201,7 @@ async def _execute_raw(
         req: _RawRequest,
         *,
         expected: tuple[int, ...] = _DEFAULT_EXPECTED_STATUSES,
-    ) -> _HttpResponse:
+    ) -> _AsyncResponse:
         """Execute a ``_RawRequest`` and return the HTTP response.
 
         Encodes the pre-serialised body (if present) as UTF-8 and merges any
@@ -985,7 +985,7 @@ async def _wait_for_attribute_visibility(
             f"after {total_wait} seconds (exhausted all retries)."
         ) from last_error
 
-    async def _request_metadata_with_retry(self, method: str, url: str, **kwargs) -> _HttpResponse:
+    async def _request_metadata_with_retry(self, method: str, url: str, **kwargs) -> _AsyncResponse:
         """Fetch metadata with retries on transient errors."""
         max_attempts = 5
         backoff_seconds = 0.4

tests/unit/aio/core/test_async_http.py

@@ -6,7 +6,7 @@
 
 import aiohttp
 
-from PowerPlatform.Dataverse.aio.core._async_http import _AsyncHttpClient, _HttpResponse
+from PowerPlatform.Dataverse.aio.core._async_http import _AsyncHttpClient, _AsyncResponse
 
 
 def _make_resp(status: int = 200) -> MagicMock:
@@ -128,7 +128,7 @@ async def test_retries_on_client_error_and_succeeds(self):
             result = await client._request("get", "https://example.com/data")
 
         assert session.request.call_count == 2
-        assert isinstance(result, _HttpResponse)
+        assert isinstance(result, _AsyncResponse)
         assert result.status == 200
 
     async def test_raises_after_all_retries_exhausted(self):
@@ -178,7 +178,7 @@ async def test_retries_on_timeout_error(self):
             result = await client._request("get", "https://example.com/data")
 
         assert session.request.call_count == 2
-        assert isinstance(result, _HttpResponse)
+        assert isinstance(result, _AsyncResponse)
         assert result.status == 200
 
 

tests/unit/aio/data/test_async_batch_internal.py

@@ -8,7 +8,7 @@
 import pytest
 
 from PowerPlatform.Dataverse.aio.data._async_batch import _AsyncBatchClient
-from PowerPlatform.Dataverse.aio.core._async_http import _HttpResponse
+from PowerPlatform.Dataverse.aio.core._async_http import _AsyncResponse
 from PowerPlatform.Dataverse.core.errors import MetadataError, ValidationError
 from PowerPlatform.Dataverse.data._batch_base import (
     _RecordCreate,
@@ -628,37 +628,37 @@ async def test_not_found_raises(self):
 
 
 # ---------------------------------------------------------------------------
-# _HttpResponse
+# _AsyncResponse
 # ---------------------------------------------------------------------------
 
 
 class TestHttpResponse:
-    """Tests for _HttpResponse — the materialized response returned by _AsyncHttpClient."""
+    """Tests for _AsyncResponse — the materialized response returned by _AsyncHttpClient."""
 
     def test_json_parses_body(self):
         """json() parses the body bytes as JSON."""
-        r = _HttpResponse(200, {"Content-Type": "application/json"}, b'{"value": []}')
+        r = _AsyncResponse(200, {"Content-Type": "application/json"}, b'{"value": []}')
         assert r.json() == {"value": []}
 
     def test_json_empty_body_returns_empty_dict(self):
         """json() returns {} for an empty body."""
-        r = _HttpResponse(200, {}, b"")
+        r = _AsyncResponse(200, {}, b"")
         assert r.json() == {}
 
     def test_status_and_status_code_equal(self):
         """status and status_code are both set and equal."""
-        r = _HttpResponse(207, {}, b"")
+        r = _AsyncResponse(207, {}, b"")
         assert r.status == 207
         assert r.status_code == 207
 
     def test_text_decodes_body(self):
         """text property decodes body bytes as UTF-8."""
-        r = _HttpResponse(200, {}, b"body text")
+        r = _AsyncResponse(200, {}, b"body text")
         assert r.text == "body text"
 
     def test_text_empty_body(self):
         """text property returns empty string for empty body."""
-        r = _HttpResponse(200, {}, b"")
+        r = _AsyncResponse(200, {}, b"")
         assert r.text == ""
 
 

tests/unit/aio/data/test_async_odata_internal.py

@@ -28,7 +28,7 @@ def _make_client() -> _AsyncODataClient:
 
 
 def _resp(json_data=None, status=200, headers=None):
-    """Create a mock _HttpResponse-compatible response."""
+    """Create a mock _AsyncResponse-compatible response."""
     r = MagicMock()
     r.status = status
     r.headers = headers or {}

tests/unit/aio/data/test_async_relationships.py

@@ -31,7 +31,7 @@ def _make_client() -> _AsyncODataClient:
 
 
 def _resp(json_data=None, status=200, headers=None):
-    """Create a mock _HttpResponse-compatible response."""
+    """Create a mock _AsyncResponse-compatible response."""
     r = MagicMock()
     r.status = status
     r.headers = headers or {}