feat: Proxy support (#950)

Co-authored-by: Andrew Smith <[email protected]>

Author: juancarlospaco

poetry.lock

@@ -19,7 +19,7 @@ python = "^3.9"
 postgrest = "^0.17.0"
 realtime = "^2.0.0"
 gotrue = "^2.7.0"
-httpx = ">=0.24,<0.28"
+httpx = ">=0.26,<0.28"
 storage3 = "^0.8.0"
 supafunc = "^0.6.0"
 typing-extensions = "^4.12.2"

pyproject.toml

@@ -24,6 +24,7 @@ def __init__(
         http_client: Optional[AsyncClient] = None,
         flow_type: AuthFlowType = "implicit",
         verify: bool = True,
+        proxy: Optional[str] = None,
     ):
         """Instantiate SupabaseAuthClient instance."""
         if headers is None:
@@ -40,4 +41,5 @@ def __init__(
             http_client=http_client,
             flow_type=flow_type,
             verify=verify,
+            proxy=proxy,
         )

supabase/_async/auth_client.py

@@ -231,14 +231,18 @@ def _init_storage_client(
         headers: Dict[str, str],
         storage_client_timeout: int = DEFAULT_STORAGE_CLIENT_TIMEOUT,
         verify: bool = True,
+        proxy: Optional[str] = None,
     ) -> AsyncStorageClient:
-        return AsyncStorageClient(storage_url, headers, storage_client_timeout, verify)
+        return AsyncStorageClient(
+            storage_url, headers, storage_client_timeout, verify, proxy
+        )
 
     @staticmethod
     def _init_supabase_auth_client(
         auth_url: str,
         client_options: ClientOptions,
         verify: bool = True,
+        proxy: Optional[str] = None,
     ) -> AsyncSupabaseAuthClient:
         """Creates a wrapped instance of the GoTrue Client."""
         return AsyncSupabaseAuthClient(
@@ -249,6 +253,7 @@ def _init_supabase_auth_client(
             headers=client_options.headers,
             flow_type=client_options.flow_type,
             verify=verify,
+            proxy=proxy,
         )
 
     @staticmethod
@@ -258,6 +263,7 @@ def _init_postgrest_client(
         schema: str,
         timeout: Union[int, float, Timeout] = DEFAULT_POSTGREST_CLIENT_TIMEOUT,
         verify: bool = True,
+        proxy: Optional[str] = None,
     ) -> AsyncPostgrestClient:
         """Private helper for creating an instance of the Postgrest client."""
         return AsyncPostgrestClient(
@@ -266,6 +272,7 @@ def _init_postgrest_client(
             schema=schema,
             timeout=timeout,
             verify=verify,
+            proxy=proxy,
         )
 
     def _create_auth_header(self, token: str):

supabase/_async/client.py

@@ -24,6 +24,7 @@ def __init__(
         http_client: Optional[SyncClient] = None,
         flow_type: AuthFlowType = "implicit",
         verify: bool = True,
+        proxy: Optional[str] = None,
     ):
         """Instantiate SupabaseAuthClient instance."""
         if headers is None:
@@ -40,4 +41,5 @@ def __init__(
             http_client=http_client,
             flow_type=flow_type,
             verify=verify,
+            proxy=proxy,
         )

supabase/_sync/auth_client.py

@@ -230,14 +230,18 @@ def _init_storage_client(
         headers: Dict[str, str],
         storage_client_timeout: int = DEFAULT_STORAGE_CLIENT_TIMEOUT,
         verify: bool = True,
+        proxy: Optional[str] = None,
     ) -> SyncStorageClient:
-        return SyncStorageClient(storage_url, headers, storage_client_timeout, verify)
+        return SyncStorageClient(
+            storage_url, headers, storage_client_timeout, verify, proxy
+        )
 
     @staticmethod
     def _init_supabase_auth_client(
         auth_url: str,
         client_options: ClientOptions,
         verify: bool = True,
+        proxy: Optional[str] = None,
     ) -> SyncSupabaseAuthClient:
         """Creates a wrapped instance of the GoTrue Client."""
         return SyncSupabaseAuthClient(
@@ -248,6 +252,7 @@ def _init_supabase_auth_client(
             headers=client_options.headers,
             flow_type=client_options.flow_type,
             verify=verify,
+            proxy=proxy,
         )
 
     @staticmethod
@@ -257,6 +262,7 @@ def _init_postgrest_client(
         schema: str,
         timeout: Union[int, float, Timeout] = DEFAULT_POSTGREST_CLIENT_TIMEOUT,
         verify: bool = True,
+        proxy: Optional[str] = None,
     ) -> SyncPostgrestClient:
         """Private helper for creating an instance of the Postgrest client."""
         return SyncPostgrestClient(
@@ -265,6 +271,7 @@ def _init_postgrest_client(
             schema=schema,
             timeout=timeout,
             verify=verify,
+            proxy=proxy,
         )
 
     def _create_auth_header(self, token: str):