Apply custom headers passed to client constructor (#268)

`Client.__init__` takes a `**kwargs` argument that gets passed to the
underlying httpx client constructor. However, the current implementation
doesn't honor any custom headers that are passed. This PR fixes that.

Signed-off-by: Mattt Zmuda <mattt@replicate.com>

Author: mattt

replicate/client.py

@@ -329,9 +329,8 @@ def _build_httpx_client(
     timeout: Optional[httpx.Timeout] = None,
     **kwargs,
 ) -> Union[httpx.Client, httpx.AsyncClient]:
-    headers = {
-        "User-Agent": f"replicate-python/{__version__}",
-    }
+    headers = kwargs.pop("headers", {})
+    headers["User-Agent"] = f"replicate-python/{__version__}"
 
     if (
         api_token := api_token or os.environ.get("REPLICATE_API_TOKEN")

tests/test_client.py

@@ -85,3 +85,27 @@ async def test_server_error_handling():
             client._request("GET", "/")
         assert "status: 500" in str(exc_info.value)
         assert "detail: Server error occurred" in str(exc_info.value)
+
+
+def test_custom_headers_are_applied():
+    import replicate
+    from replicate.exceptions import ReplicateError
+
+    custom_headers = {"Custom-Header": "CustomValue"}
+
+    def mock_send(request: httpx.Request, **kwargs) -> httpx.Response:
+        assert "Custom-Header" in request.headers
+        assert request.headers["Custom-Header"] == "CustomValue"
+
+        return httpx.Response(401, json={})
+
+    client = replicate.Client(
+        api_token="dummy_token",
+        headers=custom_headers,
+        transport=httpx.MockTransport(mock_send),
+    )
+
+    try:
+        client.accounts.current()
+    except ReplicateError:
+        pass