fix: do not mutate functions URL

Author: o-santi

src/functions/pyproject.toml

@@ -15,6 +15,7 @@ requires-python = ">=3.9"
 dependencies = [
   "httpx[http2] >=0.26,<0.29",
   "strenum >=0.4.15",
+  "yarl>=1.20.1",
 ]
 
 

src/functions/src/supabase_functions/_async/functions_client.py

@@ -2,6 +2,7 @@
 from warnings import warn
 
 from httpx import AsyncClient, HTTPError, Response, QueryParams
+from yarl import URL
 
 from ..errors import FunctionsHttpError, FunctionsRelayError
 from ..utils import (
@@ -24,7 +25,7 @@ def __init__(
     ):
         if not is_http_url(url):
             raise ValueError("url must be a valid HTTP URL string")
-        self.url = url
+        self.url = URL(url)
         self.headers = {
             "User-Agent": f"supabase-py/functions-py v{__version__}",
             **headers,
@@ -51,37 +52,32 @@ def __init__(
 
         self.verify = bool(verify) if verify is not None else True
         self.timeout = int(abs(timeout)) if timeout is not None else 60
-
-        if http_client is not None:
-            http_client.base_url = self.url
-            http_client.headers.update({**self.headers})
-            self._client = http_client
-        else:
-            self._client = AsyncClient(
-                base_url=self.url,
-                headers=self.headers,
-                verify=self.verify,
-                timeout=self.timeout,
-                proxy=proxy,
-                follow_redirects=True,
-                http2=True,
-            )
+        self._client = http_client or AsyncClient(
+            verify=self.verify,
+            timeout=self.timeout,
+            proxy=proxy,
+            follow_redirects=True,
+            http2=True,
+        )
 
     async def _request(
         self,
         method: Literal["GET", "OPTIONS", "HEAD", "POST", "PUT", "PATCH", "DELETE"],
-        url: str,
+        path: list[str],
         headers: Optional[Dict[str, str]] = None,
         json: Optional[Dict[Any, Any]] = None,
         params: Optional[QueryParams] = None,
     ) -> Response:
+        url = self.url.joinpath(*path)
+        headers = headers or dict()
+        headers.update(self.headers)
         response = (
             await self._client.request(
-                method, url, data=json, headers=headers, params=params
+                method, str(url), data=json, headers=headers, params=params
             )
             if isinstance(json, str)
             else await self._client.request(
-                method, url, json=json, headers=headers, params=params
+                method, str(url), json=json, headers=headers, params=params
             )
         )
         try:
@@ -129,7 +125,6 @@ async def invoke(
         params = QueryParams()
         body = None
         response_type = "text/plain"
-        url = f"{self.url}/{function_name}"
 
         if invoke_options is not None:
             headers.update(invoke_options.get("headers", {}))
@@ -153,7 +148,7 @@ async def invoke(
                 headers["Content-Type"] = "application/json"
 
         response = await self._request(
-            "POST", url, headers=headers, json=body, params=params
+            "POST", [function_name], headers=headers, json=body, params=params
         )
         is_relay_error = response.headers.get("x-relay-header")
 

src/functions/src/supabase_functions/_sync/functions_client.py

@@ -2,6 +2,7 @@
 from warnings import warn
 
 from httpx import Client, HTTPError, Response, QueryParams
+from yarl import URL
 
 from ..errors import FunctionsHttpError, FunctionsRelayError
 from ..utils import (
@@ -24,7 +25,7 @@ def __init__(
     ):
         if not is_http_url(url):
             raise ValueError("url must be a valid HTTP URL string")
-        self.url = url
+        self.url = URL(url)
         self.headers = {
             "User-Agent": f"supabase-py/functions-py v{__version__}",
             **headers,
@@ -51,35 +52,32 @@ def __init__(
 
         self.verify = bool(verify) if verify is not None else True
         self.timeout = int(abs(timeout)) if timeout is not None else 60
-
-        if http_client is not None:
-            http_client.base_url = self.url
-            http_client.headers.update({**self.headers})
-            self._client = http_client
-        else:
-            self._client = Client(
-                base_url=self.url,
-                headers=self.headers,
-                verify=self.verify,
-                timeout=self.timeout,
-                proxy=proxy,
-                follow_redirects=True,
-                http2=True,
-            )
+        self._client = http_client or Client(
+            verify=self.verify,
+            timeout=self.timeout,
+            proxy=proxy,
+            follow_redirects=True,
+            http2=True,
+        )
 
     def _request(
         self,
         method: Literal["GET", "OPTIONS", "HEAD", "POST", "PUT", "PATCH", "DELETE"],
-        url: str,
+        path: list[str],
         headers: Optional[Dict[str, str]] = None,
         json: Optional[Dict[Any, Any]] = None,
         params: Optional[QueryParams] = None,
     ) -> Response:
+        url = self.url.joinpath(*path)
+        headers = headers or dict()
+        headers.update(self.headers)
         response = (
-            self._client.request(method, url, data=json, headers=headers, params=params)
+            self._client.request(
+                method, str(url), data=json, headers=headers, params=params
+            )
             if isinstance(json, str)
             else self._client.request(
-                method, url, json=json, headers=headers, params=params
+                method, str(url), json=json, headers=headers, params=params
             )
         )
         try:
@@ -127,7 +125,6 @@ def invoke(
         params = QueryParams()
         body = None
         response_type = "text/plain"
-        url = f"{self.url}/{function_name}"
 
         if invoke_options is not None:
             headers.update(invoke_options.get("headers", {}))
@@ -150,7 +147,9 @@ def invoke(
             elif isinstance(body, dict):
                 headers["Content-Type"] = "application/json"
 
-        response = self._request("POST", url, headers=headers, json=body, params=params)
+        response = self._request(
+            "POST", [function_name], headers=headers, json=body, params=params
+        )
         is_relay_error = response.headers.get("x-relay-header")
 
         if is_relay_error and is_relay_error == "true":

src/functions/tests/_async/test_function_client.py

@@ -31,7 +31,7 @@ async def test_init_with_valid_params(valid_url, default_headers):
     client = AsyncFunctionsClient(
         url=valid_url, headers=default_headers, timeout=10, verify=True
     )
-    assert client.url == valid_url
+    assert str(client.url) == valid_url
     assert "User-Agent" in client.headers
     assert client.headers["User-Agent"] == f"supabase-py/functions-py v{__version__}"
     assert client._client.timeout == Timeout(10)

src/functions/tests/_sync/test_function_client.py

@@ -31,7 +31,7 @@ def test_init_with_valid_params(valid_url, default_headers):
     client = SyncFunctionsClient(
         url=valid_url, headers=default_headers, timeout=10, verify=True
     )
-    assert client.url == valid_url
+    assert str(client.url) == valid_url
     assert "User-Agent" in client.headers
     assert client.headers["User-Agent"] == f"supabase-py/functions-py v{__version__}"
     assert client._client.timeout == Timeout(10)

src/functions/tests/test_client.py

@@ -22,7 +22,7 @@ def test_create_async_client(valid_url, valid_headers):
     )
 
     assert isinstance(client, AsyncFunctionsClient)
-    assert client.url == valid_url
+    assert str(client.url) == valid_url
     assert all(client.headers[key] == value for key, value in valid_headers.items())
 
 
@@ -33,7 +33,7 @@ def test_create_sync_client(valid_url, valid_headers):
     )
 
     assert isinstance(client, SyncFunctionsClient)
-    assert client.url == valid_url
+    assert str(client.url) == valid_url
     assert all(client.headers[key] == value for key, value in valid_headers.items())