fix: default mutable arguments (#216)

* fix: mutable arguments

* remove unused import

* fix accessing get on NoneType

realtime/_async/channel.py

@@ -42,7 +42,7 @@ def __init__(
         self,
         socket: AsyncRealtimeClient,
         topic: str,
-        params: RealtimeChannelOptions = {"config": {}},
+        params: Optional[RealtimeChannelOptions] = None,
     ) -> None:
         """
         Initialize the Channel object.
@@ -52,20 +52,20 @@ def __init__(
         :param params: Optional parameters for connection.
         """
         self.socket = socket
-        self.params = params
+        self.params = params or RealtimeChannelOptions(
+            config={
+                "broadcast": {"ack": False, "self": False},
+                "presence": {"key": ""},
+                "private": False,
+            }
+        )
         self.topic = topic
         self._joined_once = False
         self.bindings: Dict[str, List[Binding]] = {}
         self.presence = AsyncRealtimePresence(self)
         self.state = ChannelStates.CLOSED
         self._push_buffer: List[AsyncPush] = []
         self.timeout = self.socket.timeout
-        self.params["config"] = {
-            "broadcast": {"ack": False, "self": False},
-            "presence": {"key": ""},
-            "private": False,
-            **params.get("config", {}),
-        }
 
         self.join_push = AsyncPush(self, ChannelEvents.join, self.params)
         self.rejoin_timer = AsyncTimer(
@@ -306,7 +306,7 @@ async def join(self) -> AsyncRealtimeChannel:
 
     # Event handling methods
     def _on(
-        self, type: str, callback: Callback, filter: Dict[str, Any] = {}
+        self, type: str, callback: Callback, filter: Optional[Dict[str, Any]] = None
     ) -> AsyncRealtimeChannel:
         """
         Set up a listener for a specific event.
@@ -318,7 +318,7 @@ def _on(
         """
 
         type_lowercase = type.lower()
-        binding = Binding(type=type_lowercase, filter=filter, callback=callback)
+        binding = Binding(type=type_lowercase, filter=filter or {}, callback=callback)
         self.bindings.setdefault(type_lowercase, []).append(binding)
 
         return self

realtime/_async/client.py

@@ -42,8 +42,8 @@ def __init__(
         self,
         url: str,
         token: str,
-        auto_reconnect: bool = False,
-        params: Dict[str, Any] = {},
+        auto_reconnect: bool = True,
+        params: Optional[Dict[str, Any]] = None,
         hb_interval: int = 30,
         max_retries: int = 5,
         initial_backoff: float = 1.0,
@@ -63,7 +63,7 @@ def __init__(
         self.url = f"{re.sub(r'https://', 'wss://', re.sub(r'http://', 'ws://', url, flags=re.IGNORECASE), flags=re.IGNORECASE)}/websocket?apikey={token}"
         self.http_endpoint = http_endpoint_url(url)
         self.is_connected = False
-        self.params = params
+        self.params = params or {}
         self.apikey = token
         self.access_token = token
         self.send_buffer: List[Callable] = []
@@ -221,7 +221,7 @@ async def _heartbeat(self) -> None:
 
     @ensure_connection
     def channel(
-        self, topic: str, params: RealtimeChannelOptions = {}
+        self, topic: str, params: Optional[RealtimeChannelOptions] = None
     ) -> AsyncRealtimeChannel:
         """
         :param topic: Initializes a channel and creates a two-way association with the socket

realtime/_async/push.py

@@ -15,12 +15,12 @@ def __init__(
         self,
         channel: "AsyncRealtimeChannel",
         event: str,
-        payload: Dict[str, Any] = {},
+        payload: Optional[Dict[str, Any]] = None,
         timeout: int = DEFAULT_TIMEOUT,
     ):
         self.channel = channel
         self.event = event
-        self.payload = payload
+        self.payload = payload or {}
         self.timeout = timeout
         self.rec_hooks: List[_Hook] = []
         self.ref: Optional[str] = None

realtime/_sync/channel.py

@@ -1,6 +1,6 @@
 from __future__ import annotations
 
-from typing import TYPE_CHECKING
+from typing import TYPE_CHECKING, Optional
 
 from realtime.types import RealtimeChannelOptions
 
@@ -19,7 +19,7 @@ def __init__(
         self,
         socket: SyncRealtimeClient,
         topic: str,
-        params: RealtimeChannelOptions = {"config": {}},
+        params: Optional[RealtimeChannelOptions] = None,
     ) -> None:
         """
         Initialize the Channel object.

realtime/_sync/client.py

@@ -10,8 +10,8 @@ def __init__(
         self,
         url: str,
         token: str,
-        auto_reconnect: bool = False,
-        params: Dict[str, Any] = {},
+        auto_reconnect: bool = True,
+        params: Optional[Dict[str, Any]] = None,
         hb_interval: int = 30,
         max_retries: int = 5,
         initial_backoff: float = 1.0,
@@ -30,7 +30,7 @@ def __init__(
         """
 
     def channel(
-        self, topic: str, params: RealtimeChannelOptions = {}
+        self, topic: str, params: Optional[RealtimeChannelOptions] = None
     ) -> SyncRealtimeChannel:
         """
         :param topic: Initializes a channel and creates a two-way association with the socket