Unbuffered.

Browse Source
This commit is contained in:
retoor 2025-01-31 12:38:21 +01:00
parent 312b9eeeca
commit c6f4393166
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
src/snek/view/rpc.py
View File

@ -122,7 +122,7 @@ class RPCView(BaseView):
try: try:
result = await method(*args) result = await method(*args)
except Exception as ex: 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()) #dict(error=ex=str(ex),traceback=traceback.format_exc())
await self.ws.send_json({"callId":call_id,"success":True,"data":result}) await self.ws.send_json({"callId":call_id,"success":True,"data":result})
except Exception as ex: except Exception as ex:
@ -137,10 +137,10 @@ class RPCView(BaseView):
ws = web.WebSocketResponse() ws = web.WebSocketResponse()
await ws.prepare(self.request) await ws.prepare(self.request)
if self.request.session.get("logged_in") is True: #if self.request.session.get("logged_in") is True:
await self.services.socket.add(ws) #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): #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"]) #await self.services.socket.subscribe(ws,subscription["channel_uid"])
print("Subscribed for: ", subscription["label"],flush=True) print("Subscribed for: ", subscription["label"],flush=True)
rpc = RPCView.RPCApi(self,ws) rpc = RPCView.RPCApi(self,ws)
async for msg in ws: async for msg in ws: