Adding more logging around sending messages

Author: blast-hardcheese

src/replit_river/common_session.py

@@ -127,13 +127,18 @@ async def buffered_message_sender(
     get_next_pending: Callable[[], TransportMessage | None],
     commit: Callable[[TransportMessage], None],
 ) -> None:
+    logger.debug("Entering buffered_message_sender")
     while True:
+        logger.debug("buffered_message_sender: LOOP")
         while msg := get_next_pending():
             ws = get_ws()
+            logger.debug("buffered_message_sender: Dequeued %r to send over %r", msg, ws)
             if not ws:
                 break
             try:
+                logger.debug("buffered_message_sender: Sending...")
                 await send_transport_message(msg, ws, websocket_closed_callback)
+                logger.debug("buffered_message_sender: committing!")
                 commit(msg)
             except WebsocketClosedException as e:
                 logger.debug(

src/replit_river/v2/client_transport.py

@@ -245,7 +245,6 @@ async def websocket_closed_callback() -> None:
 
         try:
             payload = handshake_request.model_dump()
-            logger.warning(f"PAYLOAD HERE: {repr(payload)}")
             await send_transport_message(
                 TransportMessage(
                     from_=self._transport_id,