Voice Receiving

.gitignore

@@ -10,6 +10,7 @@ docs/crowdin.py
 *.mp3
 *.m4a
 *.wav
+*.pcm
 *.png
 *.jpg
 *.flac
@@ -18,6 +19,8 @@ docs/crowdin.py
 .DS_Store
 .python-version
 __pycache__
-.vs/slnx.sqlite
+.vs/*
+.vscode/*
 env/
 build/
+test.py

discord/__init__.py

@@ -57,6 +57,7 @@
 from .sticker import *
 from .stage_instance import *
 from .interactions import *
+from .sink import *
 from .components import *
 from .threads import *
 from .bot import *

discord/errors.py

@@ -59,7 +59,8 @@
     'ExtensionNotLoaded',
     'NoEntryPointError',
     'ExtensionFailed',
-    'ExtensionNotFound'
+    'ExtensionNotFound',
+    'RecordingException',
 )
 
 
@@ -269,6 +270,19 @@ def __init__(self, shard_id: Optional[int]):
         )
         super().__init__(msg % shard_id)
 
+class RecordingException(ClientException):
+    """Exception that's thrown when there is an error while trying to record
+    audio from a voice channel.
+
+    .. versionadded:: 2.0
+    """
+    pass
+
+class SinkException(ClientException):
+    """Raised when a Sink error occurs.
+
+    .. versionadded:: 2.0
+    """
 
 class InteractionResponded(ClientException):
     """Exception that's raised when sending another interaction response using

discord/gateway.py

@@ -728,6 +728,7 @@ def __init__(self, socket, loop, *, hook=None):
         self._keep_alive = None
         self._close_code = None
         self.secret_key = None
+        self.ssrc_map = {}
         if hook:
             self._hook = hook
 
@@ -839,6 +840,15 @@ async def received_message(self, msg):
             self._keep_alive = VoiceKeepAliveHandler(ws=self, interval=min(interval, 5.0))
             self._keep_alive.start()
 
+        elif op == self.SPEAKING:
+            ssrc = data['ssrc']
+            user = int(data['user_id'])
+            speaking = data['speaking']
+            if ssrc in self.ssrc_map:
+                self.ssrc_map[ssrc]['speaking'] = speaking
+            else:
+                self.ssrc_map.update({ssrc: {'user_id': user, 'speaking': speaking}})
+
         await self._hook(self, msg)
 
     async def initial_connection(self, data):