From e00e0928bbc7696ae0a3dd640be039a65bf1f2c6 Mon Sep 17 00:00:00 2001 From: Andreas Wrede Date: Sat, 19 Jun 2021 21:38:56 -0400 Subject: [PATCH] report ws clients --- hbd | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/hbd b/hbd index 6bc1962..3c5baf9 100755 --- a/hbd +++ b/hbd @@ -846,9 +846,12 @@ ws_connections = {} async def ws_serve(websocket, path): ws_connections[websocket] = path + remote_address = websocket.remote_address + if verbose: print(f"DBG ws_serve: {remote_address}") while True: try: name = await websocket.recv() + if verbose: print(f"DBG ws_serve: receive {name}") except ( websockets.exceptions.ConnectionClosedOK, websockets.exceptions.ConnectionClosedError) as e: @@ -862,6 +865,7 @@ async def ws_serve(websocket, path): jmsg = json.dumps({'type': 'message', 'data': m }) await websocket.send(jmsg) + if verbose: print(f"DBG ws_serve: close {remote_address}") try: del ws_connections[websocket] except Exception as e: @@ -1126,7 +1130,7 @@ ssl_context.load_cert_chain(wss_pem, keyfile=wss_key) wss_start_server = websockets.serve(ws_serve, hbd_host, WSSPORT, ssl=ssl_context) loop.run_until_complete(wss_start_server) -ws_start_server = websockets.serve(ws_serve, hbd_host, WSPORT) +ws_start_server = websockets.serve(ws_serve, hbd_host, WSPORT, loop = loop) loop.run_until_complete(ws_start_server)