zv/tempvoice
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(tempvoice): enhance temporary channel deletion with retry mechanism

Browse Source
This commit is contained in:
zv
2026-04-29 20:09:15 +02:00
parent 58544309ba
commit 888aea3550
1 changed files with 37 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

59
tempvoice.py
View File

@@ -524,7 +524,12 @@ class TempVoice(commands.Cog):
await self._send_creation_message(member, new_channel) await self._send_creation_message(member, new_channel)
async def _delete_temp_channel_if_empty(self, channel: discord.abc.GuildChannel) -> None: async def _delete_temp_channel_if_empty(
self,
channel: discord.abc.GuildChannel,
retries: int = 1,
retry_delay: float = 0.75,
) -> None:
if not isinstance(channel, discord.VoiceChannel): if not isinstance(channel, discord.VoiceChannel):
return return
@@ -532,27 +537,37 @@ class TempVoice(commands.Cog):
if owner_id is None: if owner_id is None:
return return
if channel.members: for attempt in range(retries + 1):
return refreshed_channel = channel.guild.get_channel(channel.id)
if not isinstance(refreshed_channel, discord.VoiceChannel):
await self._remove_channel_mappings_bulk(channel.guild, {channel.id})
return
try: if refreshed_channel.members:
await channel.delete(reason="TempVoice: deleting empty temporary channel") if attempt < retries:
except discord.NotFound: await asyncio.sleep(retry_delay)
await self._remove_channel_mappings_bulk(channel.guild, {channel.id}) continue
except discord.Forbidden: return
log.warning(
"Missing permissions to delete temporary channel %s (%s).", try:
channel, await refreshed_channel.delete(reason="TempVoice: deleting empty temporary channel")
channel.id, except discord.NotFound:
) await self._remove_channel_mappings_bulk(channel.guild, {refreshed_channel.id})
except discord.HTTPException: except discord.Forbidden:
log.exception( log.warning(
"HTTP error while deleting temporary channel %s (%s).", "Missing permissions to delete temporary channel %s (%s).",
channel, refreshed_channel,
channel.id, refreshed_channel.id,
) )
else: except discord.HTTPException:
await self._remove_channel_mappings_bulk(channel.guild, {channel.id}) log.exception(
"HTTP error while deleting temporary channel %s (%s).",
refreshed_channel,
refreshed_channel.id,
)
else:
await self._remove_channel_mappings_bulk(channel.guild, {refreshed_channel.id})
return
async def _setlimit_impl(self, ctx: commands.Context, limit: int) -> None: async def _setlimit_impl(self, ctx: commands.Context, limit: int) -> None:
await self._set_locale_context(ctx.guild) await self._set_locale_context(ctx.guild)
@@ -641,7 +656,7 @@ class TempVoice(commands.Cog):
await self._handle_join_to_create(member, target_category_id) await self._handle_join_to_create(member, target_category_id)
if before.channel is not None: if before.channel is not None:
await self._delete_temp_channel_if_empty(before.channel) await self._delete_temp_channel_if_empty(before.channel, retries=2, retry_delay=0.75)
except Exception: except Exception:
log.exception( log.exception(
"Unexpected exception in on_voice_state_update for member %s (%s).", "Unexpected exception in on_voice_state_update for member %s (%s).",