radio95/RadioPlayer
0
1
Fork 0
mirror of https://github.com/radio95-rnt/RadioPlayer.git synced 2026-07-29 23:39:15 +02:00
Code Issues Activity

ah fuck

Browse Source
This commit is contained in:
kuba
2026-04-11 14:15:24 +02:00
parent db446ef972
commit 34ffb41ba2
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
modules/web.py
+5 -1
View File
@@ -67,7 +67,11 @@ async def ws_handler(websocket: ServerConnection, shared_data: dict, imc_q: mult
await websocket.send(json.dumps({"data": result, "event": "toplay"})) # Yes, this is not an accident await websocket.send(json.dumps({"data": result, "event": "toplay"})) # Yes, this is not an accident
await websocket.loop.run_in_executor(None, ws_q.put, {"data": result, "event": "toplay"}) await websocket.loop.run_in_executor(None, ws_q.put, {"data": result, "event": "toplay"})
elif action == "skip_next": elif action == "skip_next":
result = await get_imc("activemod", {"action": "skip_next", "set": msg.get("set",True)}) result = await get_imc("activemod", msg)
if result is None: await websocket.send(json.dumps({"error": "timeout", "code": 504}))
else: await websocket.send(json.dumps({"data": result, "event": "skip_next"}))
elif action == "skipc":
result = await get_imc("activemod", msg)
if result is None: await websocket.send(json.dumps({"error": "timeout", "code": 504})) if result is None: await websocket.send(json.dumps({"error": "timeout", "code": 504}))
else: await websocket.send(json.dumps({"data": result, "event": "skip_next"})) else: await websocket.send(json.dumps({"data": result, "event": "skip_next"}))
elif action == "jingle": elif action == "jingle":