From c6f43931664c01c597c642e35c64ec49f3008101 Mon Sep 17 00:00:00 2001 From: retoor Date: Fri, 31 Jan 2025 12:38:21 +0100 Subject: [PATCH] Unbuffered. --- src/snek/view/rpc.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/snek/view/rpc.py b/src/snek/view/rpc.py index 431bf72..cd12786 100644 --- a/src/snek/view/rpc.py +++ b/src/snek/view/rpc.py @@ -122,7 +122,7 @@ class RPCView(BaseView): try: result = await method(*args) except Exception as ex: - result = dict({"callId":call_id,"success": False, "data":{"exception":str(ex),"traceback":traceback.format_exc()}}) + result = dict({"exception":str(ex),"traceback":traceback.format_exc()}) #dict(error=ex=str(ex),traceback=traceback.format_exc()) await self.ws.send_json({"callId":call_id,"success":True,"data":result}) except Exception as ex: @@ -137,10 +137,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: