diff --git a/supabase/_async/client.py b/supabase/_async/client.py index c7e45781..062155de 100644 --- a/supabase/_async/client.py +++ b/supabase/_async/client.py @@ -10,7 +10,6 @@ AsyncRPCFilterRequestBuilder, ) from postgrest.constants import DEFAULT_POSTGREST_CLIENT_TIMEOUT -from realtime.connection import Socket from storage3 import AsyncStorageClient from storage3.constants import DEFAULT_TIMEOUT as DEFAULT_STORAGE_CLIENT_TIMEOUT from supafunc import AsyncFunctionsClient @@ -81,7 +80,12 @@ def __init__( auth_url=self.auth_url, client_options=options, ) - self.realtime = self._init_realtime_client(self.realtime_url, self.supabase_key) + # TODO: Bring up to parity with JS client. + # self.realtime: SupabaseRealtimeClient = self._init_realtime_client( + # realtime_url=self.realtime_url, + # supabase_key=self.supabase_key, + # ) + self.realtime = None self._postgrest = None self._storage = None self._functions = None @@ -269,11 +273,6 @@ def _init_postgrest_client( verify=verify, ) - @staticmethod - def _init_realtime_client(realtime_url: str, supabase_key: str) -> Socket: - """Private helper for creating an instance of the Socket client.""" - return Socket(realtime_url, supabase_key) - def _create_auth_header(self, token: str): return f"Bearer {token}" diff --git a/supabase/_sync/client.py b/supabase/_sync/client.py index 1e58def2..527b030c 100644 --- a/supabase/_sync/client.py +++ b/supabase/_sync/client.py @@ -10,7 +10,6 @@ SyncRPCFilterRequestBuilder, ) from postgrest.constants import DEFAULT_POSTGREST_CLIENT_TIMEOUT -from realtime.connection import Socket from storage3 import SyncStorageClient from storage3.constants import DEFAULT_TIMEOUT as DEFAULT_STORAGE_CLIENT_TIMEOUT from supafunc import SyncFunctionsClient @@ -81,7 +80,12 @@ def __init__( auth_url=self.auth_url, client_options=options, ) - self.realtime = self._init_realtime_client(self.realtime_url, self.supabase_key) + # TODO: Bring up to parity with JS client. + # self.realtime: SupabaseRealtimeClient = self._init_realtime_client( + # realtime_url=self.realtime_url, + # supabase_key=self.supabase_key, + # ) + self.realtime = None self._postgrest = None self._storage = None self._functions = None @@ -269,11 +273,6 @@ def _init_postgrest_client( verify=verify, ) - @staticmethod - def _init_realtime_client(realtime_url: str, supabase_key: str) -> Socket: - """Private helper for creating an instance of the Socket client.""" - return Socket(realtime_url, supabase_key) - def _create_auth_header(self, token: str): return f"Bearer {token}"