We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 4373ac6 commit d510edeCopy full SHA for d510ede
app/app.py
@@ -376,9 +376,10 @@ async def on_message_for_websocket(
376
# as long as it uses the separator "|str()" and places properties at the end
377
# of the received string.
378
decoded_msg = f"{decoded_msg}|{message_context.offset}|{message_context.timestamp}|"
379
+ text = decoded_msg.encode("utf-8")
380
+ _LOGGER.info("Sending msg for %s (%s)...", es_id, text)
381
try:
- _LOGGER.debug("Sending msg for %s...", es_id)
- await websocket.send_text(str(decoded_msg.encode("utf-8")))
382
+ await websocket.send_text(text)
383
except WebSocketDisconnect:
384
_LOGGER.info("Got WebSocketDisconnect for %s (stopping)...", es_id)
385
shutdown = True
0 commit comments