Update main.py

main.py

@@ -6,7 +6,6 @@ import asyncio
 
 # ==========================================
 # 🪄 THE HUGGING FACE TRICK
-# Hugging Face requires a web server on port 7860 to keep the Space "Green" and Running.
 # ==========================================
 class DummyHandler(BaseHTTPRequestHandler):
     def do_GET(self):
@@ -21,12 +20,13 @@ def keep_alive():
 threading.Thread(target=keep_alive, daemon=True).start()
 
 # ==========================================
-# 🤖 BOT LIBRARIES
+# 🤖 BOT LIBRARIES (STABLE)
 # ==========================================
 from pyrogram import Client, filters
 from pyrogram.types import InlineKeyboardMarkup, InlineKeyboardButton, CallbackQuery
 from pytgcalls import PyTgCalls
-from pytgcalls.types import MediaStream, AudioQuality, VideoQuality
+from pytgcalls.types.input_stream import AudioPiped, AudioVideoPiped
+from pytgcalls.types.input_stream.quality import HighQualityAudio, HighQualityVideo
 import yt_dlp
 import requests
 import sqlite3
@@ -70,7 +70,11 @@ async def play_audio(client, message):
     status = await message.reply_text("🔍 Connecting to Voice Chat...")
     try:
         url, title = await asyncio.to_thread(get_stream_url, query, False)
-        await call_py.play(message.chat.id, MediaStream(url, audio_parameters=AudioQuality.HIGH))
+        # Stable v2.1.0 Join Command
+        await call_py.join_group_call(
+            message.chat.id,
+            AudioPiped(url, HighQualityAudio())
+        )
         await status.edit_text(f"🎵 **Playing Live in VC:** {title}")
     except Exception as e:
         await status.edit_text(f"🩸 **VC Error:** {str(e)}")
@@ -82,7 +86,11 @@ async def play_video(client, message):
     status = await message.reply_text("🔍 Connecting to Video Chat...")
     try:
         url, title = await asyncio.to_thread(get_stream_url, query, True)
-        await call_py.play(message.chat.id, MediaStream(url, audio_parameters=AudioQuality.HIGH, video_parameters=VideoQuality.HD_720p))
+        # Stable v2.1.0 Video Command
+        await call_py.join_group_call(
+            message.chat.id,
+            AudioVideoPiped(url, HighQualityAudio(), HighQualityVideo())
+        )
         await status.edit_text(f"🎬 **Streaming Video Live in VC:** {title}")
     except Exception as e:
         await status.edit_text(f"🩸 **VC Error:** {str(e)}")
@@ -90,7 +98,7 @@ async def play_video(client, message):
 @app.on_message(filters.command("stop") & filters.group)
 async def stop_stream(client, message):
     try:
-        await call_py.leave_call(message.chat.id)
+        await call_py.leave_group_call(message.chat.id)
         await message.reply_text("🛑 Left the Voice Chat.")
     except:
         await message.reply_text("I am not in a Voice Chat right now.")