From f3d12a257e7a43e3292654d7f67f05d823f16283 Mon Sep 17 00:00:00 2001 From: retoor Date: Mon, 27 Jan 2025 03:48:53 +0100 Subject: [PATCH] Update. --- src/snek/service/socket.py | 2 ++ src/snek/system/cache.py | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) diff --git a/src/snek/service/socket.py b/src/snek/service/socket.py index 55909ce..b7f172a 100644 --- a/src/snek/service/socket.py +++ b/src/snek/service/socket.py @@ -27,6 +27,8 @@ class SocketService(BaseService): await ws.send_json(message) except Exception as ex: print(ex) + print("Deleting socket.") + self.subscriptions[channel_uid].remove(ws) continue count += 1 return count diff --git a/src/snek/system/cache.py b/src/snek/system/cache.py index 86f5557..39e6fc3 100644 --- a/src/snek/system/cache.py +++ b/src/snek/system/cache.py @@ -61,7 +61,7 @@ class Cache: if is_new: self.version += 1 - print("New version:", self.version, flush=True) + print("Cache store! New version:", self.version, flush=True) async def delete(self, args): if args in self.cache: