Update.
This commit is contained in:
parent
b961954aa1
commit
b9b31a494a
@ -529,8 +529,8 @@ class RPCView(BaseView):
|
|||||||
try:
|
try:
|
||||||
await self.ws.send_str(json.dumps(obj, default=str))
|
await self.ws.send_str(json.dumps(obj, default=str))
|
||||||
except Exception as ex:
|
except Exception as ex:
|
||||||
|
print("THIS IS THE DeAL>",str(ex), flush=True)
|
||||||
await self.services.socket.delete(self.ws)
|
await self.services.socket.delete(self.ws)
|
||||||
await self.ws.close()
|
|
||||||
|
|
||||||
async def get_online_users(self, channel_uid):
|
async def get_online_users(self, channel_uid):
|
||||||
self._require_login()
|
self._require_login()
|
||||||
@ -638,7 +638,7 @@ class RPCView(BaseView):
|
|||||||
try:
|
try:
|
||||||
await rpc(msg.json())
|
await rpc(msg.json())
|
||||||
except Exception as ex:
|
except Exception as ex:
|
||||||
print("Deleting socket", ex, flush=True)
|
print("XXXXXXXXXX Deleting socket", ex, flush=True)
|
||||||
logger.exception(ex)
|
logger.exception(ex)
|
||||||
await self.services.socket.delete(ws)
|
await self.services.socket.delete(ws)
|
||||||
break
|
break
|
||||||
|
Loading…
Reference in New Issue
Block a user