fix: add single instance of client instantiation

Author: silentworks

supafunc/_async/functions_client.py

@@ -13,25 +13,25 @@ def __init__(self, url: str, headers: Dict):
             "User-Agent": f"supabase-py/functions-py v{__version__}",
             **headers,
         }
+        self._client = AsyncClient(base_url=self.url, headers=self.headers)
 
     async def _request(
         self,
         method: Literal["GET", "OPTIONS", "HEAD", "POST", "PUT", "PATCH", "DELETE"],
         url: str,
         headers: Union[Dict[str, str], None] = None,
-        json: Optional[dict[Any, Any]] = None,
+        json: Optional[Dict[Any, Any]] = None,
     ) -> Response:
-        async with AsyncClient(base_url=self.url, headers=self.headers) as client:
-            response = await client.request(method, url, json=json, headers=headers)
-            try:
-                response.raise_for_status()
-            except HTTPError as exc:
-                raise FunctionsHttpError(
-                    response.json().get("error")
-                    or f"An error occurred while requesting your edge function at {exc.request.url!r}."
-                ) from exc
-
-            return response
+        response = await self._client.request(method, url, json=json, headers=headers)
+        try:
+            response.raise_for_status()
+        except HTTPError as exc:
+            raise FunctionsHttpError(
+                response.json().get("error")
+                or f"An error occurred while requesting your edge function at {exc.request.url!r}."
+            ) from exc
+
+        return response
 
     def set_auth(self, token: str) -> None:
         """Updates the authorization header

supafunc/_sync/functions_client.py

@@ -13,25 +13,25 @@ def __init__(self, url: str, headers: Dict):
             "User-Agent": f"supabase-py/functions-py v{__version__}",
             **headers,
         }
+        self._client = SyncClient(base_url=self.url, headers=self.headers)
 
     def _request(
         self,
         method: Literal["GET", "OPTIONS", "HEAD", "POST", "PUT", "PATCH", "DELETE"],
         url: str,
         headers: Union[Dict[str, str], None] = None,
-        json: Optional[dict[Any, Any]] = None,
+        json: Optional[Dict[Any, Any]] = None,
     ) -> Response:
-        with SyncClient(base_url=self.url, headers=self.headers) as client:
-            response = client.request(method, url, json=json, headers=headers)
-            try:
-                response.raise_for_status()
-            except HTTPError as exc:
-                raise FunctionsHttpError(
-                    response.json().get("error")
-                    or f"An error occurred while requesting your edge function at {exc.request.url!r}."
-                )
-
-            return response
+        response = self._client.request(method, url, json=json, headers=headers)
+        try:
+            response.raise_for_status()
+        except HTTPError as exc:
+            raise FunctionsHttpError(
+                response.json().get("error")
+                or f"An error occurred while requesting your edge function at {exc.request.url!r}."
+            ) from exc
+
+        return response
 
     def set_auth(self, token: str) -> None:
         """Updates the authorization header
@@ -44,7 +44,9 @@ def set_auth(self, token: str) -> None:
 
         self.headers["Authorization"] = f"Bearer {token}"
 
-    def invoke(self, function_name: str, invoke_options: Optional[Dict] = None) -> Dict:
+    def invoke(
+        self, function_name: str, invoke_options: Optional[Dict] = None
+    ) -> Dict:
         """Invokes a function
 
         Parameters