g* DddlmZmZmZmZddlmZmZdZGddZ y))AnyDictListOptional)RealtimeChannelOptionsSyncRealtimeChannelzkThis feature isn't available in the sync client. You can use the realtime feature in the async client only.ceZdZ ddedededeeeefdedede d dfd Z dd edee d e fd Z d ee fd Zde d dfdZddZdeed dfdZy)SyncRealtimeClientNurltokenauto_reconnectparams hb_interval max_retriesinitial_backoffreturncy)aY Initialize a RealtimeClient instance for WebSocket communication. :param url: WebSocket URL of the Realtime server. Starts with `ws://` or `wss://`. Also accepts default Supabase URL: `http://` or `https://`. :param token: Authentication token for the WebSocket connection. :param auto_reconnect: If True, automatically attempt to reconnect on disconnection. Defaults to False. :param params: Optional parameters for the connection. Defaults to an empty dictionary. :param hb_interval: Interval (in seconds) for sending heartbeat messages to keep the connection alive. Defaults to 30. :param max_retries: Maximum number of reconnection attempts. Defaults to 5. :param initial_backoff: Initial backoff time (in seconds) for reconnection attempts. Defaults to 1.0. N)selfr r rrrrrs J/var/www/openai/venv/lib/python3.12/site-packages/realtime/_sync/client.py__init__zSyncRealtimeClient.__init__ topicc tt)z :param topic: Initializes a channel and creates a two-way association with the socket :return: Channel NotImplementedErrorNOT_IMPLEMENTED_MESSAGE)rrrs rchannelzSyncRealtimeClient.channel s""9::rc ttNrrs r get_channelszSyncRealtimeClient.get_channels)s!"9::rr c tt)z Unsubscribes and removes a channel from the socket :param channel: Channel to remove :return: None r)rr s rremove_channelz!SyncRealtimeClient.remove_channel,s ""9::rc tt)z] Unsubscribes and removes all channels from the socket :return: None rr#s rremove_all_channelsz&SyncRealtimeClient.remove_all_channels4s ""9::rcy)a Set the authentication token for the connection and update all joined channels. This method updates the access token for the current connection and sends the new token to all joined channels. This is useful for refreshing authentication or changing users. Args: token (Optional[str]): The new authentication token. Can be None to remove authentication. Returns: None Nr)rr s rset_authzSyncRealtimeClient.set_auth;rr)TNg?r")rN)__name__ __module__ __qualname__strboolrrrintfloatrrr r rr$r&r(r*rrrr r s $+/!$     c3h(        0FJ;;"*+A"B; ;;d#67;;&9;d;;  hsm    rr N) typingrrrrr rr rr rrrr5s!,,@H? ? r