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

More logging

Browse source
This commit is contained in:
Christoph Stahl 2025-06-16 23:11:44 +02:00
parent 8cc6674723
commit ef4424ab51
2 changed files with 19 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
syng/client.py
View file

@ -346,8 +346,14 @@ class Client:
if entry.ident in source.downloaded_files: if entry.ident in source.downloaded_files:
continue continue
logger.info("Buffering: %s (%d s)", entry.title, entry.duration) logger.info("Buffering: %s (%d s)", entry.title, entry.duration)
started = datetime.datetime.now()
try: try:
await self.sources[entry.source].buffer(entry, pos) await self.sources[entry.source].buffer(entry, pos)
logger.info(
"Buffered %s in %d seconds",
entry.title,
(datetime.datetime.now() - started).seconds,
)
except ValueError as e: except ValueError as e:
logger.error("Error buffering: %s", e) logger.error("Error buffering: %s", e)
await self.sio.emit("skip", {"uuid": entry.uuid}) await self.sio.emit("skip", {"uuid": entry.uuid})
@ -450,6 +456,14 @@ class Client:
f"Playing: {entry.artist} - {entry.title} [{entry.album}] " f"Playing: {entry.artist} - {entry.title} [{entry.album}] "
f"({entry.source}) for {entry.performer}" f"({entry.source}) for {entry.performer}"
) )
logger.info(
"Playing: %s - %s [%s] (%s) for %s",
entry.artist,
entry.title,
entry.album,
entry.source,
entry.performer,
)
if entry.uuid not in self.skipped: if entry.uuid not in self.skipped:
try: try:
if self.state.config["preview_duration"] > 0: if self.state.config["preview_duration"] > 0:
@ -486,6 +500,7 @@ class Client:
:type data: dict[str, Any] :type data: dict[str, Any]
:rtype: None :rtype: None
""" """
logger.debug("Handling search: %s (%s)", data["query"], data["search_id"])
query = data["query"] query = data["query"]
sid = data["sid"] sid = data["sid"]
search_id = data["search_id"] search_id = data["search_id"]
@ -498,6 +513,7 @@ class Client:
for source_result in results_list for source_result in results_list
for search_result in source_result for search_result in source_result
] ]
logger.debug("Search results: %d results", len(results))
await self.sio.emit( await self.sio.emit(
"search-results", {"results": results, "sid": sid, "search_id": search_id} "search-results", {"results": results, "sid": sid, "search_id": search_id}

5
syng/server.py
View file

@ -642,6 +642,7 @@ class Server:
) )
return None return None
logger.debug(f"Appending {entry} to queue in room {state.sid}")
entry.uid = data["uid"] if "uid" in data else None entry.uid = data["uid"] if "uid" in data else None
await self.append_to_queue(state, entry, sid) await self.append_to_queue(state, entry, sid)
@ -1351,7 +1352,7 @@ class Server:
if room in self.clients: if room in self.clients:
old_state: State = self.clients[room] old_state: State = self.clients[room]
if data["config"]["secret"] == old_state.client.config["secret"]: if data["config"]["secret"] == old_state.client.config["secret"]:
logger.info("Got new client connection for %s", room) logger.info("Got new playback client connection for %s", room)
old_state.sid = sid old_state.sid = sid
old_state.client = Client( old_state.client = Client(
sources=old_state.client.sources, sources=old_state.client.sources,
@ -1364,7 +1365,7 @@ class Server:
logger.warning("Got wrong secret for %s", room) logger.warning("Got wrong secret for %s", room)
raise ConnectionRefusedError(f"Wrong secret for room {room}.") raise ConnectionRefusedError(f"Wrong secret for room {room}.")
else: else:
logger.info("Registerd new client %s", room) logger.info("Registerd new playback client %s", room)
initial_entries = [Entry(**entry) for entry in data["queue"]] initial_entries = [Entry(**entry) for entry in data["queue"]]
initial_waiting_room = [Entry(**entry) for entry in data["waiting_room"]] initial_waiting_room = [Entry(**entry) for entry in data["waiting_room"]]
initial_recent = [Entry(**entry) for entry in data["recent"]] initial_recent = [Entry(**entry) for entry in data["recent"]]