Add support to send voice messages

discord/abc.py

@@ -55,7 +55,7 @@
 from .permissions import PermissionOverwrite, Permissions
 from .role import Role
 from .invite import Invite
-from .file import File
+from .file import File, VoiceMessageFile
 from .http import handle_message_parameters
 from .voice_client import VoiceClient, VoiceProtocol
 from .sticker import GuildSticker, StickerItem
@@ -74,7 +74,7 @@
 T = TypeVar('T', bound=VoiceProtocol)
 
 if TYPE_CHECKING:
     from typing_extensions import Self
 
     from .client import Client
     from .user import ClientUser
@@ -1915,6 +1915,31 @@
                 # There's no data left after this
                 break
 
+    async def send_voice_message(self, file: VoiceMessageFile):
+        """|coro|
+
+        Sends a voice message to the destination.
+
+        Parameters
+        -----------
+        file: :class:`~discord.VoiceMessageFile`
+            The voice message file to send.
+
+        Raises
+        -------
+        ~discord.HTTPException
+            Sending the voice message failed.
+        ~discord.Forbidden
+            You do not have the proper permissions to send the voice message.
+
+        Returns
+        --------
+        :class:`~discord.Message`
+            The message that was sent.
+        """
+        channel = await self._get_channel()
+        data = await self._state.http.send_voice_message(channel.id, file)
+        return self._state.create_message(channel=channel, data=data)
 
 class Connectable(Protocol):
     """An ABC that details the common operations on a channel that can

discord/file.py

@@ -27,12 +27,14 @@
 
 import os
 import io
+import base64
 
 from .utils import MISSING
 
 # fmt: off
 __all__ = (
     'File',
+    'VoiceMessageFile',
 )
 # fmt: on
 
@@ -157,3 +159,41 @@ def to_dict(self, index: int) -> Dict[str, Any]:
             payload['description'] = self.description
 
         return payload
+
+
+class VoiceMessageFile(File):
+    """A file object used for sending voice messages.
+
+    This is a subclass of :class:`File` that is specifically used for sending voice messages.
+
+    .. versionadded:: 2.6
+    """
+
+    def __init__(
+        self,
+        fp: Union[str, bytes, os.PathLike[Any], io.BufferedIOBase],
+        duration: float = 5.0,
+        waveform: Optional[str] = None,
+    ):
+        super().__init__(fp, filename="voice-message.ogg", spoiler=False)
+        self.duration = duration
+        self._waveform = waveform
+        self.uploaded_filename = None
+
+    def to_dict(self, index: int) -> Dict[str, Any]:
+        payload = super().to_dict(index)
+        payload['duration_secs'] = self.duration
+        payload['waveform'] = self.waveform
+        if self.uploaded_filename is not None:
+            payload['uploaded_filename'] = self.uploaded_filename
+        return payload
+
+    @property
+    def waveform(self) -> str:
+        """:class:`bytes`: The waveform data for the voice message."""
+        if self._waveform is None:
+            return base64.b64encode(os.urandom(256)).decode('utf-8')
+        return self._waveform
+
+    def size(self):
+        return 47194 # Placeholder, figure out how to get size

discord/http.py

@@ -53,7 +53,7 @@
 
 from .errors import HTTPException, RateLimited, Forbidden, NotFound, LoginFailure, DiscordServerError, GatewayNotFound
 from .gateway import DiscordClientWebSocketResponse
-from .file import File
+from .file import File, VoiceMessageFile
 from .mentions import AllowedMentions
 from . import __version__, utils
 from .utils import MISSING
@@ -243,7 +243,10 @@
         file_index = 0
         attachments_payload = []
         for attachment in attachments:
-            if isinstance(attachment, File):
+            if isinstance(attachment, VoiceMessageFile):
+                attachments_payload.append(attachment.to_dict(file_index))
+                file_index += 1
+            elif isinstance(attachment, File):
                 attachments_payload.append(attachment.to_dict(file_index))
                 file_index += 1
             else:
@@ -269,6 +272,9 @@
     multipart = []
     if files:
         multipart.append({'name': 'payload_json', 'value': utils._to_json(payload)})
+        print(";;;;")
+        print(utils._to_json(payload))
+        print(";;;;")
         payload = None
         for index, file in enumerate(files):
             multipart.append(
@@ -617,7 +623,9 @@
                 headers['X-Audit-Log-Reason'] = _uriquote(reason, safe='/ ')
 
         kwargs['headers'] = headers
-
+        print("=-=-=-=-=-=-=-=-=-=-=-=")
+        print(headers)
+        print("=-=-=-=-=-=-=-=-=-=-=-=")
         # Proxy support
         if self.proxy is not None:
             kwargs['proxy'] = self.proxy
@@ -868,6 +876,10 @@
         *,
         params: MultipartParameters,
     ) -> Response[message.Message]:
+        print(":::::")
+        print(params.payload)
+        print(params.multipart)
+        print(":::::")
         r = Route('POST', '/channels/{channel_id}/messages', channel_id=channel_id)
         if params.files:
             return self.request(r, files=params.files, form=params.multipart)
@@ -1058,6 +1070,63 @@
     def pins_from(self, channel_id: Snowflake) -> Response[List[message.Message]]:
         return self.request(Route('GET', '/channels/{channel_id}/pins', channel_id=channel_id))
 
+    async def send_voice_message(self, channel_id: Snowflake, VoiceMessage: VoiceMessageFile):
+        """|coro|
+
+        Sends a voice message to the specified channel.
+
+        Parameters
+        -----------
+        channel_id: :class:`~discord.abc.Snowflake`
+            The ID of the channel to send the voice message to.
+        VoiceMessage: :class:`~discord.VoiceMessageFile`
+            The voice message file to send. This should be an instance of :class:`~discord.VoiceMessageFile`.
+        """
+        from .message import MessageFlags
+        uploadRoute = Route('POST', '/channels/{channel_id}/attachments', channel_id=channel_id)
+        payload = {
+            "files": [{
+                "filename": "voice-message.ogg",
+                "file_size": VoiceMessage.size(),
+                "id": 0,
+            }]
+        }
+        response = await self.request(uploadRoute, json=payload)
+
+        upload_data = response['attachments'][0]
+        upload_url = upload_data["upload_url"]
+        uploaded_filename = upload_data["upload_filename"]
+
+        import requests
+
+        t = requests.put(upload_url, headers={"Content-Type": "audio/ogg"}, data=VoiceMessage.fp)
+        print(f"Status code: {t.status_code}")
+
+        # x = await self.__session.request("PUT", upload_url, headers={"Content-Type": "audio/ogg"}, data=VoiceMessage.fp)
+        # print("*********")
+        # print(upload_url)
+        # print(x.read())
+        # print("*********")
+
+        VoiceMessage.uploaded_filename = uploaded_filename
+
+        r = Route('POST', '/channels/{channel_id}/messages', channel_id=channel_id)
+
+        message_payload = {
+            "flags": 8192,  # IS_VOICE_MESSAGE
+            "attachments": [VoiceMessage.to_dict(0)],
+        }
+
+        headers = {"Authorization": f"Bot {self.token}",
+                   "Content-Type": "application/json"}
+
+        res = requests.post("" + r.url, headers=headers, json=message_payload)
+        return res.json()
+
+        # params = handle_message_parameters(file=VoiceMessage, flags=MessageFlags(voice=True))
+        # return await self.request(r, files=params.files, form=params.multipart)
+
+
     # Member management
 
     def kick(self, user_id: Snowflake, guild_id: Snowflake, reason: Optional[str] = None) -> Response[None]: