christofsteel/syng
christofsteel/syng
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity Actions

Handle disconnect more gracefully

Browse source
This commit is contained in:
Christoph Stahl 2025-02-17 18:33:48 +01:00
parent a761126eb5
commit b3faae7b10
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
syng/client.py
View file

@ -33,7 +33,7 @@ from uuid import UUID
from qrcode.main import QRCode from qrcode.main import QRCode
import socketio import socketio
from socketio.exceptions import ConnectionError from socketio.exceptions import ConnectionError, BadNamespaceError
import engineio import engineio
from yaml import load, Loader from yaml import load, Loader
@ -375,7 +375,10 @@ class Client:
self.skipped.remove(entry.uuid) self.skipped.remove(entry.uuid)
await self.sio.emit("get-first") await self.sio.emit("get-first")
else: else:
try:
await self.sio.emit("pop-then-get-next") await self.sio.emit("pop-then-get-next")
except BadNamespaceError:
pass
async def handle_search(self, data: dict[str, Any]) -> None: async def handle_search(self, data: dict[str, Any]) -> None:
""" """
@ -520,6 +523,9 @@ class Client:
self.player.mpv.terminate() self.player.mpv.terminate()
def quit_callback(self) -> None: def quit_callback(self) -> None:
if self.is_quitting:
return
self.is_quitting = True
if self.loop is not None: if self.loop is not None:
asyncio.run_coroutine_threadsafe(self.sio.disconnect(), self.loop) asyncio.run_coroutine_threadsafe(self.sio.disconnect(), self.loop)