send SPEAKING to all users in vc

yepcord · May 10, 2024 · 4d2439f · 4d2439f
1 parent a35297f
commit 4d2439f
Show file tree

Hide file tree

Showing 3 changed files with 18 additions and 2 deletions.
diff --git a/poetry.lock b/poetry.lock
diff --git a/pyproject.toml b/pyproject.toml
@@ -68,6 +68,7 @@ yc-protobuf3-to-dict = "^0.3.0"
 s3lite = "^0.1.4"
 fast-depends = ">=2.4.2"
 faststream = {extras = ["kafka", "nats", "rabbit", "redis"], version = "^0.5.4"}
+semanticsdp = "^0.1.0b9"
 
 [tool.poetry.group.dev.dependencies]
 pytest = "^8.2.0"

diff --git a/yepcord/voice_gateway/gateway.py b/yepcord/voice_gateway/gateway.py
@@ -136,7 +136,11 @@ async def handle_SELECT_PROTOCOL(self, data: dict):
     async def handle_SPEAKING(self, data: dict):
         if self.ssrc != data["ssrc"] or data["ssrc"] < 1:
             return await self.ws.close(4014)
-        await self.esend(SpeakingEvent(self.ssrc, self.user_id, data["speaking"]))
+
+        for client in self._gw.channels[self.channel_id].values():
+            if client is self:
+                continue
+            await client.esend(SpeakingEvent(self.ssrc, self.user_id, data["speaking"]))
 
     @require_auth
     async def handle_VIDEO(self, data: dict):