logan/node-26
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

updates

Browse Source
This commit is contained in:
Logan
2026-04-12 03:34:11 -04:00
parent 3cf5bc0d05
commit 4e41df9f95
2 changed files with 32 additions and 8 deletions
Download Patch File Download Diff File Expand all files Collapse all files
drb-edge-node/app/internal/discord_radio.py
+11 -2
View File
@@ -115,8 +115,17 @@ class RadioBot:
def _on_stream_end(self, error):
if error:
logger.error(f"Stream ended: {error}")
if self._loop and self._voice_client and self._voice_client.is_connected() and not self._voice_client.is_playing():
logger.error(f"Stream ended with error: {error}")
if not (self._loop and self._voice_client and self._voice_client.is_connected() and not self._voice_client.is_playing()):
return
if error:
# Back off before retrying — prevents tight loop when PulseAudio is unavailable
async def _delayed_restart():
await asyncio.sleep(5)
if self._voice_client and self._voice_client.is_connected() and not self._voice_client.is_playing():
self._play_stream()
self._loop.call_soon_threadsafe(lambda: asyncio.ensure_future(_delayed_restart()))
else:
self._loop.call_soon_threadsafe(self._play_stream)
def _stop_stream(self):