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

chore: use logging.debug instead of print for sync debugging (#2481)
Some checks are pending
Test & Docs / tests (postgresql, 3.10) (push) Waiting to run
Details
Test & Docs / tests (postgresql, 3.12) (push) Waiting to run
Details
Test & Docs / lint (push) Waiting to run
Details
Test & Docs / docs (push) Waiting to run
Details

Browse source
This commit is contained in:
Yohan Boniface 2025-02-05 19:59:59 +01:00 committed by GitHub
commit fe011d89e2
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 8 additions and 8 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
umap/sync/app.py
View file

@ -93,7 +93,7 @@ class Peer:
try:
message = await pubsub.get_message(ignore_subscribe_messages=True)
except Exception as err:
print(err)
logging.debug(err)
break
if message is not None:
await self.send(message["data"].decode())
@ -123,18 +123,18 @@ class Peer:
await self.broadcast(message.model_dump_json())
async def broadcast(self, message):
print("BROADCASTING", message)
logging.debug("BROADCASTING", message)
# Send to all channels (including sender!)
await self.client.publish(self.room_key, message)
async def send_to(self, peer_id, message):
print("SEND TO", peer_id, message)
logging.debug("SEND TO", peer_id, message)
# Send to one given channel
await self.client.publish(f"user:{self.map_id}:{peer_id}", message)
async def receive(self, text_data):
if not self.is_authenticated:
print("AUTHENTICATING", text_data)
logging.debug("AUTHENTICATING", text_data)
message = JoinRequest.model_validate_json(text_data)
signed = TimestampSigner().unsign_object(message.token, max_age=30)
user, map_id, permissions = signed.values()
@ -143,7 +143,7 @@ class Peer:
return await self.disconnect()
self.peer_id = message.peer
self.username = message.username
print("AUTHENTICATED", self.peer_id)
logging.debug("AUTHENTICATED", self.peer_id)
await self.store_username()
await self.listen()
response = JoinResponse(peer=self.peer_id, peers=await self.get_peers())
@ -170,12 +170,12 @@ class Peer:
await self.send_to(incoming.root.recipient, text_data)
async def send(self, text):
print(" FORWARDING TO", self.peer_id, text)
logging.debug(" FORWARDING TO", self.peer_id, text)
try:
await self._send({"type": "websocket.send", "text": text})
except Exception as err:
print("Error sending message:", text)
print(err)
logging.debug("Error sending message:", text)
logging.debug(err)
urlpatterns = [path("ws/sync/<str:map_id>", name="ws_sync", view=sync)]