From 2ae2e8450cad47031067f3baae3b09ff521c5c87 Mon Sep 17 00:00:00 2001 From: retoor Date: Fri, 31 Jan 2025 13:42:12 +0100 Subject: [PATCH] Unbuffered. --- src/snek/view/rpc.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/src/snek/view/rpc.py b/src/snek/view/rpc.py index be1a743..eefc4f9 100644 --- a/src/snek/view/rpc.py +++ b/src/snek/view/rpc.py @@ -141,10 +141,10 @@ class RPCView(BaseView): ws = web.WebSocketResponse() await ws.prepare(self.request) - #if self.request.session.get("logged_in") is True: - #await self.services.socket.add(ws) - #async for subscription in self.services.channel_member.find(user_uid=self.request.session.get("uid"),deleted_at=None,is_banned=False): - #await self.services.socket.subscribe(ws,subscription["channel_uid"]) + if self.request.session.get("logged_in") is True: + await self.services.socket.add(ws) + async for subscription in self.services.channel_member.find(user_uid=self.request.session.get("uid"),deleted_at=None,is_banned=False): + await self.services.socket.subscribe(ws,subscription["channel_uid"]) #print("Subscribed for: ", subscription["label"],flush=True) rpc = RPCView.RPCApi(self,ws) async for msg in ws: