feat: Implement barebones Forum channel support.

interactions/api/http/channel.py

@@ -307,3 +307,72 @@ async def delete_stage_instance(self, channel_id: int, reason: Optional[str] = N
         return await self._req.request(
             Route("DELETE", f"/stage-instances/{channel_id}"), reason=reason
         )
+
+    async def create_tag(
+        self,
+        channel_id: int,
+        name: str,
+        emoji_id: Optional[int] = None,
+        emoji_name: Optional[str] = None,
+    ) -> dict:
+        """
+        Create a new tag.
+
+        .. note::
+            Can either have an emoji_id or an emoji_name, but not both.
+            emoji_id is meant for custom emojis, emoji_name is meant for unicode emojis.
+
+        :param channel_id: Channel ID snowflake.
+        :param name: The name of the tag
+        :param emoji_id: The ID of the emoji to use for the tag
+        :param emoji_name: The name of the emoji to use for the tag
+        """
+
+        _dct = {"name": name}
+        if emoji_id:
+            _dct["emoji_id"] = emoji_id
+        if emoji_name:
+            _dct["emoji_name"] = emoji_name
+
+        return await self._req.request(Route("POST", f"/channels/{channel_id}/tags"), json=_dct)
+
+    async def edit_tag(
+        self,
+        channel_id: int,
+        tag_id: int,
+        name: str,
+        emoji_id: Optional[int] = None,
+        emoji_name: Optional[str] = None,
+    ) -> dict:
+        """
+        Update a tag.
+
+        .. note::
+            Can either have an emoji_id or an emoji_name, but not both.
+            emoji_id is meant for custom emojis, emoji_name is meant for unicode emojis.
+
+        :param channel_id: Channel ID snowflake.
+        :param tag_id: The ID of the tag to update.
+        :param name: The new name of the tag
+        :param emoji_id: The ID of the emoji to use for the tag
+        :param emoji_name: The name of the emoji to use for the tag
+        """
+
+        _dct = {"name": name}
+        if emoji_id:
+            _dct["emoji_id"] = emoji_id
+        if emoji_name:
+            _dct["emoji_name"] = emoji_name
+
+        return await self._req.request(
+            Route("PUT", f"/channels/{channel_id}/tags/{tag_id}"), json=_dct
+        )
+
+    async def delete_tag(self, channel_id: int, tag_id: int) -> dict:
+        """
+        Delete a forum tag.
+
+        :param channel_id: Channel ID snowflake.
+        :param tag_id: The ID of the tag to delete
+        """
+        return await self._req.request(Route("DELETE", f"/channels/{channel_id}/tags/{tag_id}"))

interactions/api/http/thread.py

@@ -1,7 +1,11 @@
 from typing import Dict, List, Optional
 
+from aiohttp import MultipartWriter
+
 from ...api.cache import Cache
+from ..models.attrs_utils import MISSING
 from ..models.channel import Channel
+from ..models.misc import File
 from .request import _Request
 from .route import Route
 
@@ -189,3 +193,62 @@ async def create_thread(
             self.cache[Channel].add(Channel(**request))
 
         return request
+
+    async def create_thread_in_forum(
+        self,
+        channel_id: int,
+        name: str,
+        auto_archive_duration: int,
+        message_payload: dict,
+        applied_tags: List[str] = None,
+        files: Optional[List[File]] = MISSING,
+        rate_limit_per_user: Optional[int] = None,
+        reason: Optional[str] = None,
+    ) -> dict:
+        """
+        From a given Forum channel, create a Thread with a message to start with.
+
+        :param channel_id: The ID of the channel to create this thread in
+        :param name: The name of the thread
+        :param auto_archive_duration: duration in minutes to automatically archive the thread after recent activity,
+            can be set to: 60, 1440, 4320, 10080
+        :param message_payload: The payload/dictionary contents of the first message in the forum thread.
+        :param applied_tags: List of tags that can be applied to the forum, if any.
+        :param files: An optional list of files to send attached to the message.
+        :param rate_limit_per_user: Seconds a user has to wait before sending another message (0 to 21600), if given.
+        :param reason: An optional reason for the audit log
+        :return: Returns a Thread in a Forum object with a starting Message.
+        """
+        query = {"use_nested_fields": 1}
+
+        payload = {"name": name, "auto_archive_duration": auto_archive_duration}
+        if rate_limit_per_user:
+            payload["rate_limit_per_user"] = rate_limit_per_user
+        if applied_tags:
+            payload["applied_tags"] = applied_tags
+
+        data = None
+        if files is not MISSING and len(files) > 0:
+
+            data = MultipartWriter("form-data")
+            part = data.append_json(payload)
+            part.set_content_disposition("form-data", name="payload_json")
+            payload = None
+
+            for id, file in enumerate(files):
+                part = data.append(
+                    file._fp,
+                )
+                part.set_content_disposition(
+                    "form-data", name=f"files[{str(id)}]", filename=file._filename
+                )
+        else:
+            payload.update(message_payload)
+
+        return await self._req.request(
+            Route("POST", f"/channels/{channel_id}/threads"),
+            json=payload,
+            data=data,
+            params=query,
+            reason=reason,
+        )

interactions/api/models/channel.py

@@ -53,6 +53,7 @@ class ChannelType(IntEnum):
     PUBLIC_THREAD = 11
     PRIVATE_THREAD = 12
     GUILD_STAGE_VOICE = 13
+    GUILD_DIRECTORY = 14
     GUILD_FORUM = 15
 
 
@@ -95,6 +96,22 @@ class ThreadMember(ClientSerializerMixin):
     :ivar bool muted: Whether the member is muted or not.
     """
 
+    # __slots__ = (
+    #     "_json",
+    #     "id",
+    #     "user_id",
+    #     "join_timestamp",
+    #     "flags",
+    #     # TODO: Document below attributes.
+    #     "muted",  # ??
+    #     "user",
+    #     "team_id",
+    #     "membership_state",
+    #     "permissions",
+    #     "member",
+    #     "presence",
+    # )
+
     id: Optional[Snowflake] = field(converter=Snowflake, default=None, repr=False)
     user_id: Optional[Snowflake] = field(converter=Snowflake, default=None)
     join_timestamp: datetime = field(converter=datetime.fromisoformat, repr=False)
@@ -104,6 +121,12 @@ class ThreadMember(ClientSerializerMixin):
         default=None, repr=False
     )  # todo explore this, it isn't in the ddev docs
 
+    # Take these conversions with a grain of salt.
+
+    # Commented out for circular import reasons, but schema says they do work.
+    # self.member = Member(**self._json.get("member")) if self._json.get("member") else None
+    # self.presence = Presence(**self._json.get("presence")) if self._json.get("presence") else None
+
 
 class AsyncHistoryIterator(DiscordPaginationIterator):
     """
@@ -319,6 +342,15 @@ class Channel(ClientSerializerMixin, IDMixin):
     :ivar Optional[int] total_message_sent?: Number of messages ever sent in a thread.
     """
 
+    # __slots__ = (
+    #     # TODO: Document banner when Discord officially documents them.
+    #     "banner",
+    #     "guild_hashes",
+    #     "flags",
+    #     "template",
+    #     "available_tags",
+    # )
+
     __slots__ = (
         # TODO: Document banner when Discord officially documents them.
         "banner",
@@ -1505,10 +1537,60 @@ async def get_permissions_for(self, member: "Member") -> Permissions:
 @define()
 class Thread(Channel):
     """An object representing a thread.
-
     .. note::
         This is a derivation of the base Channel, since a
         thread can be its own event.
+        Also note that forums are also dispatched as Thread
+        objects.
+    """
+
+    # __slots__ = (
+    #     "_json",
+    #     "id",
+    #     "type",
+    #     "guild_id",
+    #     "position",
+    #     "permission_overwrites",
+    #     "name",
+    #     "topic",
+    #     "nsfw",
+    #     "last_message_id",
+    #     "bitrate",
+    #     "user_limit",
+    #     "rate_limit_per_user",
+    #     "recipients",
+    #     "icon",
+    #     "owner_id",
+    #     "application_id",
+    #     "parent_id",
+    #     "last_pin_timestamp",
+    #     "rtc_region",
+    #     "video_quality_mode",
+    #     "message_count",
+    #     "member_count",
+    #     "thread_metadata",
+    #     "member",
+    #     "default_auto_archive_duration",
+    #     "permissions",
+    #     "_client",
+    #     # TODO: Document these when Discord officially documents them.
+    #     "banner",
+    #     "guild_hashes",
+    #     "flags",  # This seems to be forum unique.
+    #     "newly_created",
+    #     "template",
+    #     "available_tags",
+    # )
+
+    ...
+
+
+@define()
+class Forum(Thread):
+    """An object representing a Forum.
+    .. note::
+        While this isn't directly dispatched for GW based events,
+        this object exists moreso for future helper methods.
     """
 
     ...

interactions/api/models/gw.py

@@ -517,6 +517,10 @@ class MessageReactionRemove(MessageReaction):
     # todo see if the missing member attribute affects anything
 
 
+# TODO: (temp) Add Thread object for a THREAD_UPDATE event.
+# More prevalent on forums for some odd reason.
+
+
 @define()
 class ThreadList(DictSerializerMixin):
     """