almet/umap
1
0
Fork 0
mirror of https://github.com/umap-project/umap.git synced 2025-04-28 19:42:36 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

wip(sync): remove a bit of server prints

Browse source
This commit is contained in:
Yohan Boniface 2025-01-20 19:17:34 +01:00
parent 82342ea00f
commit ef7c769abe
1 changed files with 2 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
umap/sync/app.py
View file

@ -33,22 +33,16 @@ async def sync(scope, receive, send, **kwargs):
peer._send = send peer._send = send
while True: while True:
event = await receive() event = await receive()
print("EVENT", event)
if event["type"] == "websocket.connect": if event["type"] == "websocket.connect":
try: try:
print("Let's accept")
await peer.connect() await peer.connect()
print("After connect")
await send({"type": "websocket.accept"}) await send({"type": "websocket.accept"})
print("After accept")
except ValueError: except ValueError:
await send({"type": "websocket.close"}) await send({"type": "websocket.close"})
if event["type"] == "websocket.disconnect": if event["type"] == "websocket.disconnect":
print("Closing", event)
await peer.disconnect() await peer.disconnect()
print("Closed")
break break
if event["type"] == "websocket.receive": if event["type"] == "websocket.receive":
@ -121,7 +115,7 @@ class Peer:
async def receive(self, text_data): async def receive(self, text_data):
if not self.is_authenticated: if not self.is_authenticated:
print("AUTHENTICATING", self.uuid) print("AUTHENTICATING", text_data)
message = JoinRequest.model_validate_json(text_data) message = JoinRequest.model_validate_json(text_data)
signed = TimestampSigner().unsign_object(message.token, max_age=30) signed = TimestampSigner().unsign_object(message.token, max_age=30)
user, room_id, permissions = signed.values() user, room_id, permissions = signed.values()
@ -155,7 +149,7 @@ class Peer:
await self.send_to(incoming.root.recipient, text_data) await self.send_to(incoming.root.recipient, text_data)
async def send(self, text): async def send(self, text):
print("SEND", text) print(" FORWARDING TO", self.peer_id, text)
await self._send({"type": "websocket.send", "text": text}) await self._send({"type": "websocket.send", "text": text})