Update README.md

README.md

@@ -18,7 +18,7 @@
   </a>
 </p>
 
-A production-grade, asynchronous HTTP client for Python engineered to tolerate downstream service outages, network instability, and latency spikes. It implements proven resilience patterns including **Circuit Breakers**, **Retry Policies**, **Fallback Mechanisms**, and a **Distributed Failure Store** to enable reliable service-to-service communication.
+Asynchronous HTTP client for Python engineered to tolerate downstream service outages, network instability, and latency spikes. It implements proven resilience patterns including **Circuit Breakers**, **Retry Policies**, **Fallback Mechanisms**, and a **Distributed Failure Store** to enable reliable service-to-service communication.
 
 Built on top of `httpx`, the library is designed for modern distributed systems where resilience is a first-class requirement.
 
@@ -131,7 +131,13 @@ async def main():
             },
         )
 
-        print(response)
+        # The request returns a raw httpx.Response object on success
+        if hasattr(response, "json"):
+            print("Status:", response.status_code)
+            print("Response Data:", response.json())
+        else:
+            # Fallback values returned as a dict
+            print("Fallback Response:", response)
 
 if __name__ == "__main__":
     asyncio.run(main())
@@ -311,4 +317,4 @@ Available examples:
 * Event-driven systems
 * Containerized applications
 * Kubernetes deployments
-* Any environment where downstream dependencies may become unavailable
+* Any environment where downstream dependencies may become unavailable

examples/fastapi_integration.py

@@ -45,4 +45,6 @@ async def create_charge(http: ResilientHttpClient = Depends(http_client)):
         },
     )
 
+    if hasattr(response, "json"):
+        return response.json()
     return response

examples/slack_example.py

@@ -39,7 +39,10 @@ async def main():
             },
         )
 
-        print(response)
+        if hasattr(response, "json"):
+            print(response.json())
+        else:
+            print(response)
 
 
 if __name__ == "__main__":

examples/stripe_example.py

@@ -37,7 +37,10 @@ async def main():
             },
         )
 
-        print(response)
+        if hasattr(response, "json"):
+            print(response.json())
+        else:
+            print(response)
 
 
 if __name__ == "__main__":

pyproject.toml

@@ -1,6 +1,6 @@
 [project]
 name = "ad-tech-inc-resilient-http"
-version = "0.1.1"
+version = "0.2.0"
 description = "A production-grade, asynchronous HTTP client for Python engineered to tolerate downstream service outages, network instability, and latency spikes."
 readme = "README.md"
 requires-python = ">=3.12"

src/resilient_http_client/client.py

@@ -1,11 +1,13 @@
 import logging
+import httpx
 from .http import HttpExecutor
 from .circuit_breaker import CircuitBreaker
 from .retry import RetryPolicy
 from .failure_store import FailureStore
 from .fallback import FallbackHandler
 from .config import ResilienceConfig
 
+
 logger = logging.getLogger(__name__)
 
 
@@ -40,7 +42,7 @@ async def __aexit__(self, exc_type, exc, tb):
     async def close(self):
         await self.http.close()
 
-    async def request(self, method: str, url: str, **kwargs):
+    async def request(self, method: str, url: str, **kwargs) -> httpx.Response:
         # 1. Check Circuit Breaker
         if not await self.circuit.allow_request():
             logger.warning(f"Request blocked by Circuit Breaker for {self.service}")
@@ -57,7 +59,7 @@ async def request(self, method: str, url: str, **kwargs):
 
                 if response.is_success:
                     await self.circuit.on_success()
-                    return response.data
+                    return response
 
                 # Non-success response (e.g., 5xx)
                 logger.error(f"Request failed with status {response.status_code}")

src/resilient_http_client/http.py

@@ -14,11 +14,11 @@ async def get_client(self) -> httpx.AsyncClient:
             self._client = httpx.AsyncClient(timeout=self.timeout)
         return self._client
 
-    async def send(self, method: str, url: str, **kwargs):
+    async def send(self, method: str, url: str, **kwargs) -> httpx.Response:
         client = await self.get_client()
         try:
             response = await client.request(method, url, **kwargs)
-            return HttpResponse(response)
+            return response
         except httpx.RequestError as exc:
             logger.error(f"An error occurred while requesting {exc.request.url!r}.")
             raise
@@ -27,22 +27,3 @@ async def close(self):
         if self._client and not self._client.is_closed:
             await self._client.aclose()
 
-
-class HttpResponse:
-    def __init__(self, response: httpx.Response):
-        self._response = response
-
-    @property
-    def is_success(self):
-        return 200 <= self._response.status_code < 300
-
-    @property
-    def status_code(self):
-        return self._response.status_code
-
-    @property
-    def data(self):
-        try:
-            return self._response.json()
-        except Exception:
-            return self._response.text

tests/test_flaky_resilience.py

@@ -38,7 +38,10 @@ class MockResponse:
     def __init__(self, is_success, status_code, data):
         self.is_success = is_success
         self.status_code = status_code
-        self.data = data
+        self._data = data
+
+    def json(self):
+        return self._data
 
 
 class FlakyHttpExecutor:
@@ -107,7 +110,7 @@ async def worker(worker_id: int):
     assert len(results) == 30
 
     # successes should exist
-    successes = [r for r in results if isinstance(r, dict) and r.get("ok") is True]
+    successes = [r for r in results if not isinstance(r, dict) and hasattr(r, "json") and r.json().get("ok") is True]
     assert len(successes) > 0
 
     # failures should exist due to upstream instability (returned as degraded responses)

tests/test_integration.py

@@ -47,7 +47,10 @@ class FakeResponse:
     def __init__(self, status_code=200):
         self.status_code = status_code
         self.is_success = 200 <= status_code < 300
-        self.data = {"ok": True} if self.is_success else {"error": "failed"}
+        self._data = {"ok": True} if self.is_success else {"error": "failed"}
+
+    def json(self):
+        return self._data
 
 
 @pytest.mark.asyncio
@@ -60,7 +63,7 @@ async def test_successful_request():
 
     result = await client.request("GET", "https://api.example.com")
 
-    assert result["ok"] is True
+    assert result.json()["ok"] is True
 
 
 @pytest.mark.asyncio