Merge pull request #751 from Pycord-Development/features/voice-receive

Features/voice receive

Author: BobDotCom

.gitignore

@@ -10,6 +10,10 @@ docs/crowdin.py
 *.mp3
 *.m4a
 *.wav
+*.mp4
+*.ogg
+*.pcm
+*.png
 *.jpg
 *.flac
 *.mo
@@ -19,7 +23,11 @@ env/
 .DS_Store
 .python-version
 __pycache__
+.vs/*
+.vscode/*
+env/
 build/
-node_modules/*
 test.py
-*.png
+build/
+node_modules/*
+test.py

discord/__init__.py

@@ -13,14 +13,14 @@
 __author__ = 'Pycord Development'
 __license__ = 'MIT'
 __copyright__ = 'Copyright 2015-2021 Rapptz & Copyright 2021-present Pycord Development'
-__version__ = '2.0.0b'
+__version__ = '2.0.0b1'
 
 __path__ = __import__('pkgutil').extend_path(__path__, __name__)
 
 import logging
 from typing import NamedTuple, Literal
 
-from . import utils, opus, abc, ui
+from . import utils, opus, abc, ui, sinks
 from .activity import *
 from .appinfo import *
 from .asset import *

discord/errors.py

@@ -269,7 +269,6 @@ def __init__(self, shard_id: Optional[int]):
         )
         super().__init__(msg % shard_id)
 
-
 class InteractionResponded(ClientException):
     """Exception that's raised when sending another interaction response using
     :class:`InteractionResponse` when one has already been done before.

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):