Compare commits

...

2 commits

Author SHA1 Message Date
Frank Villaro-Dixon fcb8af9af1 remove useless logs
All checks were successful
ci / docker (push) Successful in 1m17s
Signed-off-by: Frank Villaro-Dixon <frank@villaro-dixon.eu>
2024-09-02 17:17:01 +02:00
Frank Villaro-Dixon 73556d37ec fix cleanup
Signed-off-by: Frank Villaro-Dixon <frank@villaro-dixon.eu>
2024-09-02 17:16:33 +02:00
2 changed files with 4 additions and 5 deletions

7
pod.py
View file

@ -16,7 +16,7 @@ async def handle_socket_read(socketid, tcpreader, ws):
print(f"New socket: {socketid}. Waiting on recv") print(f"New socket: {socketid}. Waiting on recv")
while True: while True:
data = await tcpreader.read(2024) data = await tcpreader.read(2024)
print(f"TCP@{socketid} Received {len(data)} bytes") #print(f"TCP@{socketid} Received {len(data)} bytes")
if data == b'': if data == b'':
print(f"TCP@{socketid} Connection closed") print(f"TCP@{socketid} Connection closed")
c = conn.WSMsg(socketid, conn.MsgType.DISCONNECT) c = conn.WSMsg(socketid, conn.MsgType.DISCONNECT)
@ -24,7 +24,7 @@ async def handle_socket_read(socketid, tcpreader, ws):
break break
c = conn.WSMsg(socketid, conn.MsgType.DATA, data) c = conn.WSMsg(socketid, conn.MsgType.DATA, data)
print(f'TCP>WS: {c}') #print(f'TCP>WS: {c}')
await ws.send(c.to_bytes()) await ws.send(c.to_bytes())
except Exception as e: except Exception as e:
@ -62,9 +62,8 @@ async def handle_ws_incoming(cfg, ws, sockets):
elif c.msg == conn.MsgType.DATA: elif c.msg == conn.MsgType.DATA:
tcpreader, tcpwriter = sockets[socketid] tcpreader, tcpwriter = sockets[socketid]
print(f'WS>TCP: {c}') #print(f'WS>TCP: {c}')
tcpwriter.write(c.payload) tcpwriter.write(c.payload)
print('written')
def get_config(): def get_config():

View file

@ -29,7 +29,7 @@ async def handler(websocket):
print(f"Connection closed: {e}") print(f"Connection closed: {e}")
finally: finally:
# Unregister the client # Unregister the client
connected_clients.remove(websocket) connected_clients.get(websocket.request.path, set()).remove(websocket)
async def main(): async def main():
# Start the WebSocket server # Start the WebSocket server