Merge: pull request #1381 from interactions-py/unstable

5.3.0

Author: LordOfPolls

.github/workflows/pytest-push.yml

@@ -42,7 +42,7 @@ jobs:
           BOT_TOKEN: ${{ secrets.BOT_TOKEN }}
           RUN_TESTBOT: ${{ matrix.RUN_TESTBOT }}
         run: |
-          pytest
+          pytest --cov=./ --cov-report xml:coverage.xml
           coverage xml -i
       - name: Upload Coverage
         run: |

interactions/api/events/base.py

@@ -27,6 +27,11 @@ class BaseEvent:
     bot: "Client" = attrs.field(repr=False, kw_only=True, default=MISSING)
     """The client instance that dispatched this event."""
 
+    @property
+    def client(self) -> "Client":
+        """The client instance that dispatched this event."""
+        return self.bot
+
     @property
     def resolved_name(self) -> str:
         """The name of the event, defaults to the class name if not overridden."""

interactions/api/events/processors/reaction_events.py

@@ -2,6 +2,7 @@
 
 import interactions.api.events as events
 from interactions.models import PartialEmoji, Reaction
+
 from ._template import EventMixinTemplate, Processor
 
 if TYPE_CHECKING:
@@ -14,6 +15,8 @@ class ReactionEvents(EventMixinTemplate):
     async def _handle_message_reaction_change(self, event: "RawGatewayEvent", add: bool) -> None:
         if member := event.data.get("member"):
             author = self.cache.place_member_data(event.data.get("guild_id"), member)
+        elif guild_id := event.data.get("guild_id"):
+            author = await self.cache.fetch_member(guild_id, event.data.get("user_id"))
         else:
             author = await self.cache.fetch_user(event.data.get("user_id"))
 

interactions/client/client.py

@@ -571,11 +571,17 @@ async def _async_wrap(_coro: Listener, _event: BaseEvent, *_args, **_kwargs) ->
                 ):
                     await self.wait_until_ready()
 
-                if len(_event.__attrs_attrs__) == 2 and coro.event != "event":
-                    # override_name & bot & logging
-                    await _coro()
-                else:
+                # don't pass event object if listener doesn't expect it
+                if _coro.pass_event_object:
                     await _coro(_event, *_args, **_kwargs)
+                else:
+                    if not _coro.warned_no_event_arg and len(_event.__attrs_attrs__) > 2 and _coro.event != "event":
+                        self.logger.warning(
+                            f"{_coro} is listening to {_coro.event} event which contains event data. "
+                            f"Add an event argument to this listener to receive the event data object."
+                        )
+                        _coro.warned_no_event_arg = True
+                    await _coro()
             except asyncio.CancelledError:
                 pass
             except Exception as e:
@@ -1202,6 +1208,8 @@ def add_listener(self, listener: Listener) -> None:
             self.logger.debug(f"Listener {listener} has already been hooked, not re-hooking it again")
             return
 
+        listener.lazy_parse_params()
+
         if listener.event not in self.listeners:
             self.listeners[listener.event] = []
         self.listeners[listener.event].append(listener)

interactions/ext/prefixed_commands/manager.py

@@ -239,7 +239,7 @@ async def _register_command(self, event: CallbackAdded) -> None:
     @listen("extension_unload")
     async def _handle_ext_unload(self, event: ExtensionUnload) -> None:
         """Unregisters all prefixed commands in an extension as it is being unloaded."""
-        for name in self._ext_command_list[event.extension.extension_name]:
+        for name in self._ext_command_list[event.extension.extension_name].copy():
             self.remove_command(name)
 
     @listen("raw_message_create", is_default_listener=True)

interactions/models/discord/auto_mod.py

@@ -121,7 +121,6 @@ class HarmfulLinkFilter(BaseTrigger):
         repr=True,
         metadata=docs("The type of trigger"),
     )
-    ...
 
 
 @attrs.define(eq=False, order=False, hash=False, kw_only=True)
@@ -151,12 +150,24 @@ class MentionSpamTrigger(BaseTrigger):
     )
 
 
+@attrs.define(eq=False, order=False, hash=False, kw_only=True)
+class MemberProfileTrigger(BaseTrigger):
+    regex_patterns: list[str] = attrs.field(
+        factory=list, repr=True, metadata=docs("The regex patterns to check against")
+    )
+    keyword_filter: str | list[str] = attrs.field(
+        factory=list, repr=True, metadata=docs("The keywords to check against")
+    )
+    allow_list: list["Snowflake_Type"] = attrs.field(
+        factory=list, repr=True, metadata=docs("The roles exempt from this rule")
+    )
+
+
 @attrs.define(eq=False, order=False, hash=False, kw_only=True)
 class BlockMessage(BaseAction):
     """blocks the content of a message according to the rule"""
 
     type: AutoModAction = attrs.field(repr=False, default=AutoModAction.BLOCK_MESSAGE, converter=AutoModAction)
-    ...
 
 
 @attrs.define(eq=False, order=False, hash=False, kw_only=True)
@@ -175,6 +186,13 @@ class TimeoutUser(BaseAction):
     type: AutoModAction = attrs.field(repr=False, default=AutoModAction.TIMEOUT_USER, converter=AutoModAction)
 
 
+@attrs.define(eq=False, order=False, hash=False, kw_only=False)
+class BlockMemberInteraction(BaseAction):
+    """Block a member from using text, voice, or other interactions"""
+
+    # this action has no metadata
+
+
 @attrs.define(eq=False, order=False, hash=False, kw_only=True)
 class AutoModRule(DiscordObject):
     """A representation of an auto mod rule"""
@@ -345,11 +363,13 @@ def member(self) -> "Optional[Member]":
     AutoModAction.BLOCK_MESSAGE: BlockMessage,
     AutoModAction.ALERT_MESSAGE: AlertMessage,
     AutoModAction.TIMEOUT_USER: TimeoutUser,
+    AutoModAction.BLOCK_MEMBER_INTERACTION: BlockMemberInteraction,
 }
 
 TRIGGER_MAPPING = {
     AutoModTriggerType.KEYWORD: KeywordTrigger,
     AutoModTriggerType.HARMFUL_LINK: HarmfulLinkFilter,
     AutoModTriggerType.KEYWORD_PRESET: KeywordPresetTrigger,
     AutoModTriggerType.MENTION_SPAM: MentionSpamTrigger,
+    AutoModTriggerType.MEMBER_PROFILE: MemberProfileTrigger,
 }

interactions/models/discord/channel.py

@@ -1901,6 +1901,11 @@ def permission_overwrites(self) -> List["PermissionOverwrite"]:
         """The permission overwrites for this channel."""
         return []
 
+    @property
+    def clyde_created(self) -> bool:
+        """Whether this thread was created by Clyde."""
+        return ChannelFlags.CLYDE_THREAD in self.flags
+
     def permissions_for(self, instance: Snowflake_Type) -> Permissions:
         """
         Calculates permissions for an instance

interactions/models/discord/enums.py

@@ -457,6 +457,8 @@ class MessageFlags(DiscordIntFlag):  # type: ignore
     """This message contains a abusive website link, pops up a warning when clicked"""
     SILENT = 1 << 12
     """This message should not trigger push or desktop notifications"""
+    VOICE_MESSAGE = 1 << 13
+    """This message is a voice message"""
 
     # Special members
     NONE = 0
@@ -551,6 +553,16 @@ class Permissions(DiscordIntFlag):  # type: ignore
     """Allows for using Activities (applications with the `EMBEDDED` flag) in a voice channel"""
     MODERATE_MEMBERS = 1 << 40
     """Allows for timing out users to prevent them from sending or reacting to messages in chat and threads, and from speaking in voice and stage channels"""
+    VIEW_CREATOR_MONETIZATION_ANALYTICS = 1 << 41
+    """Allows for viewing guild monetization insights"""
+    USE_SOUNDBOARD = 1 << 42
+    """Allows for using the soundboard in a voice channel"""
+    CREATE_GUILD_EXPRESSIONS = 1 << 43
+    """Allows for creating emojis, stickers, and soundboard sounds"""
+    USE_EXTERNAL_SOUNDS = 1 << 45
+    """Allows the usage of custom sounds from other servers"""
+    SEND_VOICE_MESSAGES = 1 << 46
+    """Allows for sending audio messages"""
 
     # Shortcuts/grouping/aliases
     REQUIRES_MFA = (
@@ -780,6 +792,8 @@ class SystemChannelFlags(DiscordIntFlag):
 class ChannelFlags(DiscordIntFlag):
     PINNED = 1 << 1
     """ Thread is pinned to the top of its parent forum channel """
+    CLYDE_THREAD = 1 << 8
+    """This thread was created by Clyde"""
 
     # Special members
     NONE = 0
@@ -964,6 +978,7 @@ class AuditLogEventType(CursedIntEnum):
     ONBOARDING_UPDATE = 167
     GUILD_HOME_FEATURE_ITEM = 171
     GUILD_HOME_FEATURE_ITEM_UPDATE = 172
+    BLOCKED_PHISHING_LINK = 180
     SERVER_GUIDE_CREATE = 190
     SERVER_GUIDE_UPDATE = 191
 
@@ -974,16 +989,19 @@ class AutoModTriggerType(CursedIntEnum):
     SPAM = 3
     KEYWORD_PRESET = 4
     MENTION_SPAM = 5
+    MEMBER_PROFILE = 6
 
 
 class AutoModAction(CursedIntEnum):
     BLOCK_MESSAGE = 1
     ALERT_MESSAGE = 2
     TIMEOUT_USER = 3
+    BLOCK_MEMBER_INTERACTION = 4
 
 
 class AutoModEvent(CursedIntEnum):
     MESSAGE_SEND = 1
+    MEMBER_UPDATE = 2
 
 
 class AutoModLanuguageType(Enum):

interactions/models/discord/guild.py

@@ -439,6 +439,21 @@ def voice_states(self) -> List["models.VoiceState"]:
         # noinspection PyProtectedMember
         return [v_state for v_state in self._client.cache.voice_state_cache.values() if v_state._guild_id == self.id]
 
+    @property
+    def mention_onboarding_customize(self) -> str:
+        """Return a mention string for the customise section of Onboarding"""
+        return "<id:customize>"
+
+    @property
+    def mention_onboarding_browse(self) -> str:
+        """Return a mention string for the browse section of Onboarding"""
+        return "<id:browse>"
+
+    @property
+    def mention_onboarding_guide(self) -> str:
+        """Return a mention string for the guide section of Onboarding"""
+        return "<id:guide>"
+
     async def fetch_member(self, member_id: Snowflake_Type, *, force: bool = False) -> Optional["models.Member"]:
         """
         Return the Member with the given discord ID, fetching from the API if necessary.

interactions/models/discord/message.py

@@ -1,4 +1,5 @@
 import asyncio
+import base64
 import re
 from dataclasses import dataclass
 from typing import (
@@ -89,12 +90,22 @@ class Attachment(DiscordObject):
     """width of file (if image)"""
     ephemeral: bool = attrs.field(repr=False, default=False)
     """whether this attachment is ephemeral"""
+    duration_secs: Optional[int] = attrs.field(repr=False, default=None)
+    """the duration of the audio file (currently for voice messages)"""
+    waveform: bytearray = attrs.field(repr=False, default=None)
+    """base64 encoded bytearray representing a sampled waveform (currently for voice messages)"""
 
     @property
     def resolution(self) -> tuple[Optional[int], Optional[int]]:
         """Returns the image resolution of the attachment file"""
         return self.height, self.width
 
+    @classmethod
+    def _process_dict(cls, data: Dict[str, Any], _) -> Dict[str, Any]:
+        if waveform := data.pop("waveform", None):
+            data["waveform"] = bytearray(base64.b64decode(waveform))
+        return data
+
 
 @attrs.define(eq=False, order=False, hash=False, kw_only=True)
 class ChannelMention(DiscordObject):
@@ -369,6 +380,13 @@ def thread(self) -> "models.TYPE_THREAD_CHANNEL":
         """The thread that was started from this message, if any"""
         return self._client.cache.get_channel(self.id)
 
+    @property
+    def editable(self) -> bool:
+        """Whether this message can be edited by the current user"""
+        if self.author.id == self._client.user.id:
+            return MessageFlags.VOICE_MESSAGE not in self.flags
+        return False
+
     async def fetch_referenced_message(self, *, force: bool = False) -> Optional["Message"]:
         """
         Fetch the message this message is referencing, if any.