nolan/PyWebSockets
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Configured to add network delay and check message IDs

Browse Source
This commit is contained in:
nolan 2025-09-30 19:30:27 -04:00
parent d9d3e46d44
commit a3042432f2
2 changed files with 8 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
client.py
View File

@ -35,7 +35,12 @@ class TestClient:
async def receive(self) -> None: async def receive(self) -> None:
while (self.connected): while (self.connected):
response: str = await self.connection.recv() response: str = await self.connection.recv()
data: dict = json.loads(response)
print(f"Received: {response}") print(f"Received: {response}")
print(f"CURRENT MESSAGE ID: {self.msgId} - RECEIVED MESSAGE ID: {data["ID"]}")
if (data["ID"] != self.msgId - 1):
print("MESSAGE DISCARDED\n")
else:
print("MESSAGE UP TO DATE. ACCEPTED\n")
if __name__ == "__main__": if __name__ == "__main__":
client = TestClient() client = TestClient()

3
server.py
View File

@ -1,5 +1,5 @@
from websockets import * from websockets import *
import asyncio, json, signal, sys import asyncio, json, signal, sys, time, random
class WebSocketServer: class WebSocketServer:
server: Server = None server: Server = None
@ -22,6 +22,7 @@ class WebSocketServer:
raw: str = await connection.recv() raw: str = await connection.recv()
message = json.loads(raw) message = json.loads(raw)
print(f"Received: {message["message"]} width id {message["ID"]}") print(f"Received: {message["message"]} width id {message["ID"]}")
time.sleep(random.randrange(1, 10) / 10)
response = {"ID": message["ID"], "message": f"received: {message["message"]}"} response = {"ID": message["ID"], "message": f"received: {message["message"]}"}
await connection.send(json.dumps(response)) await connection.send(json.dumps(response))
print("Server replied") print("Server replied")