APEX/BrowserUse_and_ComputerUse_skills
5
0
Fork 0
Code Issues 6 Pull requests 1 Projects 1 Releases Packages Wiki Activity Actions

fix(voice): add UDP keepalive to prevent Discord dropping voice after silence

Browse source 
Discord drops the UDP voice route after ~60s of silence - no packets
arrive even when users start speaking again. Send an Opus silence
frame every 15s to keep the UDP session alive.
This commit is contained in:
0xbyt4 2026-03-15 00:49:38 +03:00 • committed by teknium1
parent f1b4d0b280
commit 0cc784068d
1 changed files with 18 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

18
gateway/platforms/discord.py
View file

@ -1002,14 +1002,32 @@ class DiscordAdapter(BasePlatformAdapter):
# Voice listening (Phase 2) # Voice listening (Phase 2)
# ------------------------------------------------------------------ # ------------------------------------------------------------------
# UDP keepalive interval in seconds — prevents Discord from dropping
# the UDP route after ~60s of silence.
_KEEPALIVE_INTERVAL = 15
async def _voice_listen_loop(self, guild_id: int): async def _voice_listen_loop(self, guild_id: int):
"""Periodically check for completed utterances and process them.""" """Periodically check for completed utterances and process them."""
receiver = self._voice_receivers.get(guild_id) receiver = self._voice_receivers.get(guild_id)
if not receiver: if not receiver:
return return
last_keepalive = time.monotonic()
try: try:
while receiver._running: while receiver._running:
await asyncio.sleep(0.2) await asyncio.sleep(0.2)
# Send periodic UDP keepalive to prevent Discord from
# dropping the UDP session after ~60s of silence.
now = time.monotonic()
if now - last_keepalive >= self._KEEPALIVE_INTERVAL:
last_keepalive = now
try:
vc = self._voice_clients.get(guild_id)
if vc and vc.is_connected():
vc._connection.send_packet(b'\xf8\xff\xfe')
except Exception:
pass
completed = receiver.check_silence() completed = receiver.check_silence()
for user_id, pcm_data in completed: for user_id, pcm_data in completed:
if not self._is_allowed_user(str(user_id)): if not self._is_allowed_user(str(user_id)):