andreas/heartbeat
Public Access
1
0
Fork 1
Code Issues Pull Requests Actions Packages Projects Releases 44 Wiki Activity

report ws clients

Browse Source
This commit is contained in:
Andreas Wrede
2021-06-19 21:38:56 -04:00
parent 3e771d7aba
commit e00e0928bb
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
hbd
+5 -1
View File
@@ -846,9 +846,12 @@ ws_connections = {}
async def ws_serve(websocket, path): async def ws_serve(websocket, path):
ws_connections[websocket] = path ws_connections[websocket] = path
remote_address = websocket.remote_address
if verbose: print(f"DBG ws_serve: {remote_address}")
while True: while True:
try: try:
name = await websocket.recv() name = await websocket.recv()
if verbose: print(f"DBG ws_serve: receive {name}")
except ( except (
websockets.exceptions.ConnectionClosedOK, websockets.exceptions.ConnectionClosedOK,
websockets.exceptions.ConnectionClosedError) as e: websockets.exceptions.ConnectionClosedError) as e:
@@ -862,6 +865,7 @@ async def ws_serve(websocket, path):
jmsg = json.dumps({'type': 'message', 'data': m }) jmsg = json.dumps({'type': 'message', 'data': m })
await websocket.send(jmsg) await websocket.send(jmsg)
if verbose: print(f"DBG ws_serve: close {remote_address}")
try: try:
del ws_connections[websocket] del ws_connections[websocket]
except Exception as e: 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) wss_start_server = websockets.serve(ws_serve, hbd_host, WSSPORT, ssl=ssl_context)
loop.run_until_complete(wss_start_server) 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) loop.run_until_complete(ws_start_server)