drop websocket logging level (#26)

* drop websocket logging level

* docs

README.md

@@ -65,3 +65,29 @@ nox -s lint
 ```
 nox -s lint_check
 ```
+
+## Websocket Logging
+
+`WebsocketBackend` uses `structlog` for its logs. To view or suppress logs such as `Sending` and `Received` for all messages coming over the websocket, use this minimal structlog code.
+
+```
+import structlog
+import logging
+
+processors = [
+    structlog.stdlib.add_logger_name,
+    structlog.stdlib.add_log_level,
+    structlog.stdlib.ProcessorFormatter.wrap_for_formatter,
+]
+
+structlog.configure(
+    processors=processors, logger_factory=structlog.stdlib.LoggerFactory()
+)
+
+logging.basicConfig()
+# enable debug logs
+logging.getLogger("sending.backends.websocket").setLevel(logging.DEBUG)
+
+# suppress debug logs
+logging.getLogger("sending.backends.websocket").setLevel(logging.INFO)
+```

sending/backends/websocket.py

@@ -126,11 +126,11 @@ async def _publish(self, message: QueuedMessage):
                 # special logging here because this is a sign that you might be in
                 # a particularly bad position. Something called .send() before
                 # callback to .on_auth or similar 'set the authed_ws Future' triggered.
-                logger.info("Message queued, waiting for authed_ws to be set")
+                logger.debug("Message queued, waiting for authed_ws to be set")
             ws = await asyncio.wait_for(self.authed_ws, timeout=self.publish_timeout)
         else:
             ws = await asyncio.wait_for(self.unauth_ws, timeout=self.publish_timeout)
-        logger.info(f"Sending: {message.contents}")
+        logger.debug(f"Sending: {message.contents}")
         await ws.send(message.contents)
 
     async def _poll_loop(self):
@@ -154,7 +154,7 @@ async def _poll_loop(self):
                     fn = ensure_async(self.init_hook)
                     await fn(self)
                 async for message in websocket:
-                    logger.info(f"Received: {message}")
+                    logger.debug(f"Received: {message}")
                     self.schedule_for_delivery(topic="", contents=message)
             except websockets.ConnectionClosed:
                 # This will get raised if there's an error trying to connect,