danvics/ytptube
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions 1

Fix sio disconnect event

Browse source
This commit is contained in:
arabcoders 2025-06-19 23:07:29 +03:00
parent 47484c2d35
commit c4b8bf51d5
2 changed files with 6 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
app/library/HttpSocket.py
View file

@ -117,7 +117,9 @@ class HttpSocket:
@staticmethod
def _injector(func, event: str):
async def wrapper(sid, data, **kwargs):
async def wrapper(sid, data=None, **kwargs):
if not data:
data = {}
return await Services.get_instance().handle_async(func, sid=sid, data=data, event=event, **kwargs)
return wrapper

5
app/routes/socket/connection.py
View file

@ -34,11 +34,12 @@ async def connect(config: Config, queue: DownloadQueue, notify: EventBus, sid: s
@route(RouteType.SOCKET, "disconnect", "socket_disconnect")
async def disconnect(sid: str, data: str = None):
async def disconnect(sio: socketio.AsyncServer, sid: str, data: str = None):
"""
Handle client disconnection.
Args:
sio (socketio.AsyncServer): The Socket.IO server instance.
sid (str): The session ID of the client.
data (str): The reason for disconnection.
@ -47,7 +48,7 @@ async def disconnect(sid: str, data: str = None):
for event in _Data.subscribers:
if sid in _Data.subscribers[event]:
await unsubscribe(sid=sid, data=event)
await unsubscribe(sio=sio, sid=sid, data=event)
@route(RouteType.SOCKET, "subscribe", "socket_subscribe")