Added voice chat

.gitignore

@@ -1,3 +1,4 @@
+*.raw
 images/
 # Byte-compiled / optimized / DLL files
 __pycache__/

requirements.txt

@@ -1,3 +1,4 @@
+pytgcalls
 requests
 python-arq
 TgCrypto

wbb/__init__.py

@@ -5,6 +5,7 @@ from config import (
     PHONE_NUMBER
 )
 from pyrogram import Client
+from pytgcalls import GroupCall
 from motor.motor_asyncio import AsyncIOMotorClient as MongoClient
 from Python_ARQ import ARQ
 import time
@@ -46,6 +47,8 @@ bot_start_time = time.time()
 mongo_client = MongoClient(MONGO_DB_URI)
 db = mongo_client.wbb
 
+
+# Userbot client
 print("\nStarting Helper Userbot")
 app2 = Client(
     "userbot",
@@ -54,6 +57,8 @@ app2 = Client(
     api_hash=API_HASH
 )
 
+
+# Mainbot client
 print("\nStarting Main Bot\n")
 app = Client(
     "wbb",
@@ -62,4 +67,13 @@ app = Client(
     api_hash=API_HASH
 )
 
+# Pytgcalls client
+vc = GroupCall(
+        app2,
+        input_filename="input.raw",
+        play_on_repeat=False,
+        enable_logs_to_console=False
+        )
+
+# ARQ client
 arq = ARQ(ARQ_API)

wbb/modules/voice_chat.py

@@ -1 +1,51 @@
+from pyrogram import filters
+from wbb import vc, arq, app
+from wbb.utils.errors import capture_err
+from wbb.utils.botinfo import USERBOT_ID
+import ffmpeg
+import aiohttp
+import aiofiles
 
+__MODULE__ = "Voice Chat"
+__HELP__ = """/joinvc - To Join A Voice Chat
+/music [SONG_NAME] - To Play Music In VC"""
+
+
+@app.on_message(filters.command("joinvc") & filters.user(USERBOT_ID))
+@capture_err
+async def joinvc(_, message):
+    if vc.is_connected:
+        await message.reply_text("__**Bot Is Already In Voice Chat.**__")
+        return
+    await vc.start(message.chat.id)
+    await message.reply_text("__**Joined The Voice Chat.**__")
+
+
+@app.on_message(filters.command("music") & filters.user(USERBOT_ID))
+@capture_err
+async def play_music(_, message):
+    if len(message.command) < 2:
+        await message.reply_text("**Usage:**\n/music [SONG_NAME]")
+        return
+    m = await message.reply_text("__**Searching**__")
+    query = message.text.split(None, 1)[1]
+    song = (await arq.saavn(query))[0]
+    await m.edit("__**Downloading**__")
+    await download_and_transcode_song(song.media_url)
+    await m.edit(f"__**Playing {song.song}\n**__")
+
+
+async def download_and_transcode_song(url):
+    async with aiohttp.ClientSession() as session:
+        async with session.get(url) as resp:
+            if resp.status == 200:
+                f = await aiofiles.open('song.mp3', mode='wb')
+                await f.write(await resp.read())
+                await f.close()
+    transcode("song.mp3")
+
+
+def transcode(filename):
+    ffmpeg.input(filename).output("input.raw", format='s16le',
+                                  acodec='pcm_s16le', ac=2, ar='48k').overwrite_output().run()
+    os.remove(filename)