fix(shard): 🐛 Channel webhooks suddenly stopping working.

payphone/bot.py

@@ -194,7 +194,7 @@ class Payphone(commands.AutoShardedBot):
 
         return prefix
 
-    def clean_message(self, message: discord.Message, call) -> str:
+    def clean_message(self, message: discord.Message) -> str:
         """Cleans a message.
 
         Args:

payphone/cogs/calls/cog.py

@@ -247,7 +247,7 @@ class Calls(base.Cog):
                 ),
             )
 
-        message_content = self.bot.clean_message(message, call)
+        message_content = self.bot.clean_message(message)
 
         if message.stickers:
             if participant.user.flag & (
@@ -289,7 +289,7 @@ class Calls(base.Cog):
                         other_channel
                     ).fetch_message(original_message_id)
 
-                replied_message_content = self.bot.clean_message(replied_message, call)
+                replied_message_content = self.bot.clean_message(replied_message)
                 replied_participant = await call.get_participant(
                     replied_message.author.id
                 )
@@ -364,26 +364,33 @@ class Calls(base.Cog):
                 )
 
         async with aiohttp.ClientSession() as session:
-            webhook = discord.Webhook.from_url(
+            for _ in range(3):
-                await self.bot.call_handler.get_channel_webhook_url(other_channel),
+                try:
-                session=session,
+                    webhook = discord.Webhook.from_url(
-                bot_token=constants.TOKEN,
+                        await self.bot.call_handler.get_channel_webhook_url(other_channel),
-            )
+                        session=session,
+                        bot_token=constants.TOKEN,
+                    )
 
-            propagated_msg = await webhook.send(
+                    propagated_msg = await webhook.send(
-                content=message_content,
+                        content=message_content,
-                username=participant.display_name,
+                        username=participant.display_name,
-                avatar_url=participant.display_avatar_url,
+                        avatar_url=participant.display_avatar_url,
-                embeds=embeds,
+                        embeds=embeds,
-                wait=True,
+                        wait=True,
-            )
+                    )
 
-            await call.set_message(
+                    await call.set_message(
-                message.id,
+                        message.id,
-                message.channel.id,
+                        message.channel.id,
-                propagated_msg.id,
+                        propagated_msg.id,
-                message.author.id,
+                        message.author.id,
-            )
+                    )
+
+                    break
+
+                except discord.errors.DiscordException:
+                    await self.bot.call_handler.refresh_channel_webhook_url(other_channel)
 
     @commands.Cog.listener()
     async def on_raw_message_delete(

payphone/core/calls.py

@@ -563,6 +563,29 @@ class CallHandler:
         await self.bot.redis.hset("calls:channels:webhooks", channel_id, webhook.url)
 
         return webhook.url
+    
+    async def refresh_channel_webhook_url(self, channel_id: int) -> str:
+        """Refreshes a channel's webhook.
+
+        Args:
+            channel_id (int): The channel ID of the webhook to refresh.
+
+        Returns:
+            str: The new webhook's URL.
+        """
+
+        await self.bot.redis.hdel("calls:channels:webhooks", channel_id)
+
+        channel = await self.bot.get_or_fetch_channel(channel_id)
+
+        if channel is None:
+            return
+
+        for webhook in await channel.webhooks():
+            if webhook.name == "Payphone":
+                await webhook.delete()
+
+        return await self.get_channel_webhook_url(channel_id)
 
     async def get_message(self, message_id: int) -> Message | None:
         """Gets a message sent in a call.