chore(realtime): move most 'info' level logs into 'debug' (#1358)

Author: o-santi

src/realtime/src/realtime/_async/channel.py

@@ -232,7 +232,7 @@ def on_join_push_ok(payload: ReplyPostgresChanges):
                             if i < len(server_postgres_changes)
                             else None
                         )
-                        logger.info(f"{server_binding}, {postgres_callback}")
+                        logger.debug(f"{server_binding}, {postgres_callback}")
 
                         if (
                             server_binding
@@ -505,7 +505,7 @@ def _broadcast_endpoint_url(self):
     async def _rejoin(self) -> None:
         if self.is_leaving:
             return
-        logger.info(f"Rejoining channel after reconnection: {self.topic}")
+        logger.debug(f"Rejoining channel after reconnection: {self.topic}")
         self.state = ChannelStates.JOINING
         await self.join_push.resend()
 
@@ -516,7 +516,7 @@ async def send_presence(self, event: str, data: Any) -> None:
         await self.push(ChannelEvents.presence, {"event": event, "payload": data})
 
     def _handle_message(self, message: ServerMessage):
-        logger.info(f"{self.topic} : {message!r}")
+        logger.debug(f"{self.topic} : {message!r}")
         if isinstance(message, SystemMessage):
             if isinstance(message.payload, SuccessSystemPayload):
                 for callback in self.system_callbacks:

src/realtime/src/realtime/_async/client.py

@@ -99,14 +99,14 @@ async def _listen(self) -> None:
 
         try:
             async for msg in self._ws_connection:
-                logger.info(f"receive: {msg!r}")
+                logger.debug(f"receive: {msg!r}")
 
                 try:
                     message = ServerMessageAdapter.validate_json(msg)
                 except ValidationError as e:
                     logger.error(f"Unrecognized message format {msg!r}\n{e}")
                     continue
-                logger.info(f"parsed message as {message!r}")
+                logger.debug(f"parsed message as {message!r}")
                 if channel := self.channels.get(message.topic):
                     channel._handle_message(message)
         except websockets.exceptions.ConnectionClosedError as e:
@@ -148,19 +148,19 @@ async def connect(self) -> None:
         """
 
         if self.is_connected:
-            logger.info("WebSocket connection already established")
+            logger.debug("WebSocket connection already established")
             return
 
         retries = 0
         backoff = self.initial_backoff
 
-        logger.info(f"Attempting to connect to WebSocket at {self.url}")
+        logger.debug(f"Attempting to connect to WebSocket at {self.url}")
 
         while retries < self.max_retries:
             try:
                 ws = await connect(self.url)
                 self._ws_connection = ws
-                logger.info("WebSocket connection established successfully")
+                logger.debug("WebSocket connection established successfully")
                 return await self._on_connect()
             except Exception as e:
                 retries += 1
@@ -173,7 +173,7 @@ async def connect(self) -> None:
                     raise
                 else:
                     wait_time = backoff * (2 ** (retries - 1))
-                    logger.info(
+                    logger.debug(
                         f"Retry {retries}/{self.max_retries}: Next attempt in {wait_time:.2f}s (backoff={backoff}s)"
                     )
                     await asyncio.sleep(wait_time)
@@ -208,7 +208,7 @@ async def _on_connect_error(
         )
 
         if self.auto_reconnect:
-            logger.info("Initiating auto-reconnect sequence...")
+            logger.debug("Initiating auto-reconnect sequence...")
             await self._reconnect()
         else:
             logger.error("Auto-reconnect disabled, terminating connection")
@@ -353,7 +353,7 @@ async def send(self, message: Union[Message, Dict[str, Any]]) -> None:
             )
             msg = Message(**message)
         message_str = msg.model_dump_json()
-        logger.info(f"send: {message_str}")
+        logger.debug(f"send: {message_str}")
 
         async def send_message():
             if not self._ws_connection: