Signed-off-by: Frank Villaro-Dixon <frank@villaro-dixon.eu>
This commit is contained in:
parent
73556d37ec
commit
fcb8af9af1
1 changed files with 3 additions and 4 deletions
7
pod.py
7
pod.py
|
@ -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():
|
||||||
|
|
Loading…
Reference in a new issue