Upload 10 files

Zaid/plugins/__init__.py

@@ -0,0 +1 @@
+

Zaid/plugins/activevoice.py

@@ -0,0 +1,32 @@
+import os
+
+from telethon import Button, events
+from Zaid import Zaid
+from Zaid.helpers.queues import get_active_chats
+
+
+@Zaid.on(events.NewMessage(pattern="^/activevoice"))
+async def activevc(message):
+    mystic = await message.reply(
+        "Getting active voice chats.. Please hold"
+    )
+    served_chats = await get_active_chats()
+    text = ""
+    j = 0
+    for x in served_chats:
+        try:
+            title = (await message.client.get_entity(x)).title
+        except Exception:
+            title = "Private Group"
+        if (await message.client.get_entity(x)).username:
+            user = (await message.client.get_entity(x)).username
+            text += f"{j + 1}.  [{title}](https://t.me/{user})[`{x}`]\n"
+        else:
+            text += f"{j + 1}. {title} [`{x}`]\n"
+        j += 1
+    if not text:
+        await mystic.edit("No Active Voice Chats")
+    else:
+        await mystic.edit(
+            f"**Active Voice Chats:-**\n\n{text}"
+        )

Zaid/plugins/admins.py

@@ -0,0 +1,37 @@
+from telethon import events, Button
+from Zaid import Zaid
+from Zaid.status import *
+from Config import Config
+from telethon.tl.functions.channels import EditAdminRequest
+from telethon.tl.types import ChatAdminRights
+from telethon.tl.functions.users import GetFullUserRequest
+from telethon.tl.functions.messages import ExportChatInviteRequest
+
+@Zaid.on(events.callbackquery.CallbackQuery(data="admin"))
+async def _(event):
+
+    await event.edit(ADMIN_TEXT, buttons=[[Button.inline("« Bᴀᴄᴋ", data="help")]])
+
+@Zaid.on(events.callbackquery.CallbackQuery(data="play"))
+async def _(event):
+
+    await event.edit(PLAY_TEXT, buttons=[[Button.inline("« Bᴀᴄᴋ", data="help")]])
+
+
+ADMIN_TEXT = """
+**✘ A module from which admins of the chat can use!**
+
+‣ `?end` - To End music streaming.
+‣ `?skip` - To Skip Tracks Going on.
+‣ `?pause` - To Pause streaming.
+‣ `?resume` - to Resume Streaming.
+‣ `?leavevc` - force The Userbot to leave Vc Chat (Sometimes Joined).
+‣ `?playlist` - to check playlists.
+"""
+
+PLAY_TEXT = """
+**✘ A module from which users of the chat can use!**
+
+‣ `?play` - To Play Audio from Else Reply to audio file.
+‣ `?vplay` - To Stream Videos (HEROKU_MODE > Doesn't support).
+"""

Zaid/plugins/autoleave.py

@@ -0,0 +1,35 @@
+import asyncio
+from Zaid import call_py, client
+from Config import Config
+from telethon.tl.functions.channels import LeaveChannelRequest
+
+AUTO_LEAVE_TIME = Config.AUTO_LEAVE_TIME
+AUTO_LEAVE = Config.AUTO_LEAVE
+
+async def leave_from_inactive_call():
+  if AUTO_LEAVE == True:
+   while not await asyncio.sleep(AUTO_LEAVE_TIME):
+    all_chat_id = []
+    async for chat in client.iter_dialogs():
+        chat_id = chat.id
+        if chat_id != -1001578320240:
+          if chat.is_group:
+            for call in call_py.calls:
+                call_chat_id = int(getattr(call, "chat_id"))
+                if call_chat_id in all_chat_id:
+                    pass
+                else:
+                    all_chat_id.append(call_chat_id)
+                call_status = getattr(call, "status")
+                try:
+                    if call_chat_id == chat_id and call_status == "not_playing":
+                        await client(LeaveChannelRequest(chat_id))
+                    elif chat_id not in all_chat_id:
+                        await client(LeaveChannelRequest(chat_id))
+                except Exception:
+                    pass
+            if chat_id not in all_chat_id:
+                try:
+                    await client(LeaveChannelRequest(chat_id))
+                except Exception:
+                    pass

Zaid/plugins/help.py

@@ -0,0 +1,34 @@
+from telethon import events, Button
+from Zaid import Zaid, BOT_USERNAME
+from Config import Config
+
+
+btn =[
+    [Button.inline("ᴀᴅᴍɪɴ", data="admin"), Button.inline("ᴘʟᴀʏ", data="play")],
+    [Button.inline("ʜᴏᴍᴇ", data="start")]]
+
+HELP_TEXT = "ᴄʜᴏᴏsᴇ ᴛʜᴇ ᴄᴀᴛᴇɢᴏʀʏ ғᴏʀ ᴡʜɪᴄʜ ʏᴏᴜ ᴡᴀɴɴᴀ ɢᴇᴛ ʜᴇʟᴩ\n\nᴀʟʟ ᴄᴏᴍᴍᴀɴᴅs ᴄᴀɴ ʙᴇ ᴜsᴇᴅ ᴡɪᴛʜ : `/`"
+
+
+@Zaid.on(events.NewMessage(pattern="[!?/]help"))
+async def help(event):
+    if Config.MANAGEMENT_MODE == "ENABLE":
+        return
+    if event.is_group:
+       await event.reply("Contact me in PM to get available help menu!", buttons=[
+       [Button.url("Help And Commands!", "t.me/{}?start=help".format(BOT_USERNAME))]])
+       return
+
+    await event.reply(HELP_TEXT, buttons=btn)
+
+@Zaid.on(events.NewMessage(pattern="^/start help"))
+async def _(event):
+    if Config.MANAGEMENT_MODE == "ENABLE":
+        return
+    await event.reply(HELP_TEXT, buttons=btn)
+
+@Zaid.on(events.callbackquery.CallbackQuery(data="help"))
+async def _(event):
+    if Config.MANAGEMENT_MODE == "ENABLE":
+        return
+    await event.edit(HELP_TEXT, buttons=btn)

Zaid/plugins/ping.py

@@ -0,0 +1,40 @@
+import os
+import sys
+import asyncio
+from time import time
+from datetime import datetime
+
+
+from telethon import Button, events
+
+from Zaid import *
+
+START_TIME = datetime.utcnow()
+TIME_DURATION_UNITS = (
+    ('Week', 60 * 60 * 24 * 7),
+    ('Day', 60 * 60 * 24),
+    ('Hour', 60 * 60),
+    ('Min', 60),
+    ('Sec', 1)
+)
+async def _human_time_duration(seconds):
+    if seconds == 0:
+        return 'inf'
+    parts = []
+    for unit, div in TIME_DURATION_UNITS:
+        amount, seconds = divmod(int(seconds), div)
+        if amount > 0:
+            parts.append('{} {}{}'
+                         .format(amount, unit, "" if amount == 1 else "s"))
+    return ', '.join(parts)
+
+
+@Zaid.on(events.NewMessage(pattern="^/ping"))
+async def _(event):
+   start = time()
+   current_time = datetime.utcnow()
+   delta_ping = time() - start
+   uptime_sec = (current_time - START_TIME).total_seconds()
+   uptime = await _human_time_duration(int(uptime_sec))
+   UMM = [[Button.url("⚜ Cԋαɳɳҽʅ ⚜", "https://t.me/TheUpdatesChannel")]]
+   await event.reply(f"╰☞ 𝗣𝗢𝗡𝗚™╮\n☞ {delta_ping * 1000:.3f}\n☞ {uptime}", buttons=UMM)

Zaid/plugins/play.py

@@ -0,0 +1,549 @@
+from pytgcalls import StreamType
+from pytgcalls.types import Update
+from pytgcalls.types.input_stream import AudioPiped, AudioVideoPiped
+from pytgcalls.types.input_stream.quality import (
+    HighQualityAudio,
+    HighQualityVideo,
+    LowQualityVideo,
+    MediumQualityVideo,
+)
+from telethon.tl.functions.channels import LeaveChannelRequest
+from telethon.tl.functions.messages import ImportChatInviteRequest
+from telethon.tl.functions.messages import ImportChatInviteRequest
+from pytgcalls.exceptions import (
+    NoActiveGroupCall,
+    NotInGroupCallError
+)
+from Zaid.status import *
+from telethon.tl.functions.users import GetFullUserRequest
+from telethon.tl.functions.messages import ExportChatInviteRequest
+import telethon.utils
+from telethon.tl import functions
+from telethon.tl import types
+from telethon.utils import get_display_name
+from telethon.tl.functions.users import GetFullUserRequest
+from youtubesearchpython import VideosSearch
+
+ 
+fotoplay = "https://telegra.ph/file/b6402152be44d90836339.jpg"
+ngantri = "https://telegra.ph/file/b6402152be44d90836339.jpg"
+from Zaid import call_py, Zaid, client as Client
+owner = "1669178360"
+from Zaid.helpers.yt_dlp import bash
+from Zaid.helpers.chattitle import CHAT_TITLE
+from Zaid.helpers.queues import (
+    QUEUE,
+    add_to_queue,
+    clear_queue,
+    get_queue,
+    pop_an_item,
+    active,
+)
+from telethon import Button, events
+from Config import Config
+
+from Zaid.helpers.thumbnail import gen_thumb
+from Zaid.helpers.joiner import AssistantAdd
+
+def vcmention(user):
+    full_name = get_display_name(user)
+    if not isinstance(user, types.User):
+        return full_name
+    return f"[{full_name}](tg://user?id={user.id})"
+
+
+def ytsearch(query: str):
+    try:
+        search = VideosSearch(query, limit=1).result()
+        data = search["result"][0]
+        songname = data["title"]
+        url = data["link"]
+        duration = data["duration"]
+        thumbnail = f"https://i.ytimg.com/vi/{data['id']}/hqdefault.jpg"
+        videoid = data["id"]
+        return [songname, url, duration, thumbnail, videoid]
+    except Exception as e:
+        print(e)
+        return 0
+
+
+async def ytdl(format: str, link: str):
+    stdout, stderr = await bash(f'yt-dlp -g -f "{format}" {link}')
+    if stdout:
+        return 1, stdout.split("\n")[0]
+    return 0, stderr
+
+
+async def skip_item(chat_id: int, x: int):
+    if chat_id not in QUEUE:
+        return 0
+    chat_queue = get_queue(chat_id)
+    try:
+        songname = chat_queue[x][0]
+        chat_queue.pop(x)
+        return songname
+    except Exception as e:
+        print(e)
+        return 0
+
+
+async def skip_current_song(chat_id: int):
+    if chat_id not in QUEUE:
+        return 0
+    chat_queue = get_queue(chat_id)
+    if len(chat_queue) == 1:
+        await call_py.leave_group_call(chat_id)
+        clear_queue(chat_id)
+        active.remove(chat_id)
+        return 1
+    songname = chat_queue[1][0]
+    url = chat_queue[1][1]
+    link = chat_queue[1][2]
+    type = chat_queue[1][3]
+    RESOLUSI = chat_queue[1][4]
+    if type == "Audio":
+        await call_py.change_stream(
+            chat_id,
+            AudioPiped(
+                url,
+            ),
+        )
+    elif type == "Video":
+        if RESOLUSI == 720:
+            hm = HighQualityVideo()
+        elif RESOLUSI == 480:
+            hm = MediumQualityVideo()
+        elif RESOLUSI == 360:
+            hm = LowQualityVideo()
+        await call_py.change_stream(
+            chat_id, AudioVideoPiped(url, HighQualityAudio(), hm)
+        )
+    pop_an_item(chat_id)
+    return [songname, link, type]
+
+
+@Zaid.on(events.callbackquery.CallbackQuery(data="cls"))
+async def _(event):
+
+     await event.delete()
+
+btnn =[[Button.inline("✯ cʟᴏꜱᴇ ✯", data="cls")]]
+
+
+#play
+@Zaid.on(events.NewMessage(pattern="^[?!/]play"))
+@AssistantAdd
+async def play(event):
+    title = ' '.join(event.text[5:])
+    replied = await event.get_reply_message()
+    sender = await event.get_sender()
+    chat = await event.get_chat()
+    chat_id = event.chat_id
+    from_user = vcmention(event.sender) 
+    public = event.chat_id
+    if (
+        replied
+        and not replied.audio
+        and not replied.voice
+        and not title
+        or not replied
+        and not title
+    ):
+        return await event.client.send_file(chat_id, Config.CMD_IMG, caption="**Give Me Your Query Which You want to Play**\n\n **Example**: `/play Nira Ishq Bass boosted`", buttons=btnn)
+    elif replied and not replied.audio and not replied.voice or not replied:
+        botman = await event.reply("🔎")
+        query = event.text.split(maxsplit=1)[1]
+        search = ytsearch(query)
+        if search == 0:
+            await botman.edit(
+                "**Can't Find Song** Try searching with More Specific Title"
+            )     
+        else:
+            songname = search[0]
+            title = search[0]
+            url = search[1]
+            duration = search[2]
+            thumbnail = search[3]
+            videoid = search[4]
+            userid = sender.id
+            titlegc = chat.title
+            ctitle = await CHAT_TITLE(titlegc)
+            thumb = await gen_thumb(videoid)
+            format = "best[height<=?720][width<=?1280]"
+            hm, ytlink = await ytdl(format, url)
+            if hm == 0:
+                await botman.edit(f"`{ytlink}`")
+            elif chat_id in QUEUE:
+                pos = add_to_queue(chat_id, songname, ytlink, url, "Audio", 0)
+                caption = f"✨ **ᴀᴅᴅᴇᴅ ᴛᴏ ǫᴜᴇᴜᴇ ᴀᴛ** {pos}\n\n❄ **ᴛɪᴛʟᴇ :** [{songname}]({url})\n⏱ **ᴅᴜʀᴀᴛɪᴏɴ :** {duration} ᴍɪɴᴜᴛᴇs\n🥀 **ʀᴇǫᴜᴇsᴛᴇᴅ ʙʏ :** {from_user}"
+                await botman.delete()
+                await event.client.send_file(chat_id, thumb, caption=caption, buttons=btnn)
+            else:
+                try:
+                    await call_py.join_group_call(
+                        chat_id,
+                        AudioPiped(
+                            ytlink,
+                        ),
+                        stream_type=StreamType().pulse_stream,
+                    )
+                    add_to_queue(chat_id, songname, ytlink, url, "Audio", 0)
+                    caption = f"➻ **sᴛᴀʀᴛᴇᴅ sᴛʀᴇᴀᴍɪɴɢ**\n\n🌸 **ᴛɪᴛʟᴇ :** [{songname}]({url})\n⏱ **ᴅᴜʀᴀᴛɪᴏɴ :** {duration} ᴍɪɴᴜᴛᴇs\n🥀 **ʀᴇǫᴜᴇsᴛᴇᴅ ʙʏ :** {from_user}"
+                    await botman.delete()
+                    await event.client.send_file(chat_id, thumb, caption=caption, buttons=btnn)
+                except Exception as ep:
+                    clear_queue(chat_id)
+                    await botman.edit(f"`{ep}`")
+
+    else:
+        botman = await event.reply("➕ Downloading File...")
+        dl = await replied.download_media()
+        link = f"https://t.me/c/{chat.id}/{event.reply_to_msg_id}"
+        if replied.audio:
+            songname = "Telegram Music Player"
+        elif replied.voice:
+            songname = "Voice Note"
+        if chat_id in QUEUE:
+            pos = add_to_queue(chat_id, songname, dl, link, "Audio", 0)
+            caption = f"✨ **ᴀᴅᴅᴇᴅ ᴛᴏ ǫᴜᴇᴜᴇ ᴀᴛ** {pos}\n\n❄ **ᴛɪᴛʟᴇ :** [{songname}]({url})\n🥀 **ʀᴇǫᴜᴇsᴛᴇᴅ ʙʏ :** {from_user}"
+            await event.client.send_file(chat_id, ngantri, caption=caption, buttons=btnn)
+            await botman.delete()
+        else:
+            try:
+                await call_py.join_group_call(
+                    chat_id,
+                    AudioPiped(
+                        dl,
+                    ),
+                    stream_type=StreamType().pulse_stream,
+                )
+                add_to_queue(chat_id, songname, dl, link, "Audio", 0)
+                caption = f"➻ **sᴛᴀʀᴛᴇᴅ sᴛʀᴇᴀᴍɪɴɢ**\n\n🌸 **ᴛɪᴛʟᴇ :** [{songname}]({link})\n🥀 **ʀᴇǫᴜᴇsᴛᴇᴅ ʙʏ :** {from_user}"
+                await event.client.send_file(chat_id, fotoplay, caption=caption, buttons=btnn)
+                await botman.delete()
+            except Exception as ep:
+                clear_queue(chat_id)
+                await botman.edit(f"`{ep}`")
+
+
+
+
+
+#end
+
+@Zaid.on(events.NewMessage(pattern="^[/?!]end"))
+@is_admin
+async def vc_end(event, perm):
+    chat_id = event.chat_id
+    from_user = vcmention(event.sender)
+    try:
+        await call_py.leave_group_call(chat_id)
+    except Exception:
+        pass
+    if chat_id in QUEUE:
+        clear_queue(chat_id)
+        await event.reply(f"**Streaming Ended**")
+    else:
+        await event.reply("**Ntg is playing ~**")
+
+
+@Zaid.on(events.NewMessage(pattern="^[?!/]vplay"))
+@AssistantAdd
+async def vplay(event):
+    if Config.HEROKU_MODE == "ENABLE":
+        await event.reply("__Currently Heroku Mode is ENABLED so You Can't Stream Video because Video Streaming Cause of Banning Your Heroku Account__.")
+        return
+    title = ' '.join(event.text[6:])
+    replied = await event.get_reply_message()
+    sender = await event.get_sender()
+    userid = sender.id
+    chat = await event.get_chat()
+    titlegc = chat.title
+    chat_id = event.chat_id
+    public = event.chat_id
+    from_user = vcmention(event.sender)
+    if (
+        replied
+        and not replied.video
+        and not replied.document
+        and not title
+        or not replied
+        and not title
+    ):
+        return await event.client.send_file(chat_id, Config.CMD_IMG, caption="**Give Me Your Query Which You want to Stream**\n\n **Example**: `/vplay Nira Ishq Bass boosted`", buttons=btnn)
+    if replied and not replied.video and not replied.document:
+        xnxx = await event.reply("**🔄 Processing Query... Please Wait!**")
+        query = event.text.split(maxsplit=1)[1]
+        search = ytsearch(query)
+        RESOLUSI = 720
+        hmmm = HighQualityVideo()
+        if search == 0:
+            await xnxx.edit(
+                "**Give Me Valid Inputs**"
+            )
+        else:
+            query = event.text.split(maxsplit=1)[1]
+            search = ytsearch(query)
+            songname = search[0]
+            title = search[0]
+            url = search[1]
+            duration = search[2]
+            thumbnail = search[3]
+            videoid = search[4]
+            ctitle = await CHAT_TITLE(titlegc)
+            thumb = await gen_thumb(videoid)
+            format = "best[height<=?720][width<=?1280]"
+            hm, ytlink = await ytdl(format, url)
+            if hm == 0:
+                await xnxx.edit(f"`{ytlink}`")
+            elif chat_id in QUEUE:
+                pos = add_to_queue(
+                    chat_id, songname, ytlink, url, "Video", RESOLUSI)
+                caption = f"**✨ ᴀᴅᴅᴇᴅ ᴛᴏ ǫᴜᴇᴜᴇ ᴀᴛ** {pos}\n\n❄ **ᴛɪᴛʟᴇ :** [{songname}]({url})\n⏱ **ᴅᴜʀᴀᴛɪᴏɴ :** {duration} ᴍɪɴᴜᴛᴇs\n🥀 **ʀᴇǫᴜᴇsᴛᴇᴅ ʙʏ :** {from_user}"
+                await xnxx.delete()
+                await event.client.send_file(chat_id, thumb, caption=caption, buttons=btnn)
+            else:
+                try:
+                    await call_py.join_group_call(
+                        chat_id,
+                        AudioVideoPiped(ytlink, HighQualityAudio(), hmmm),
+                        stream_type=StreamType().pulse_stream,
+                    )
+                    add_to_queue(
+                        chat_id,
+                        songname,
+                        ytlink,
+                        url,
+                        "Video",
+                        RESOLUSI)
+                    await xnxx.delete()
+                    await event.client.send_file(event.chat_id,
+                        f"➻ **sᴛᴀʀᴛᴇᴅ sᴛʀᴇᴀᴍɪɴɢ**\n\n🌸 **ᴛɪᴛʟᴇ :** [{songname}]({url})\n⏱ **ᴅᴜʀᴀᴛɪᴏɴ :** {duration} ᴍɪɴᴜᴛᴇs\n🥀 **ʀᴇǫᴜᴇsᴛᴇᴅ ʙʏ :** {from_user}, buttons=btnn",
+                        link_preview=False,
+                    )
+                except Exception as ep:
+                    clear_queue(chat_id)
+                    await xnxx.edit(f"`{ep}`")
+
+    elif replied:
+        xnxx = await event.reply("➕ **Downloading Replied File**")
+        dl = await replied.download_media()
+        link = f"https://t.me/c/{chat.id}/{event.reply_to_msg_id}"
+        if len(event.text.split()) < 2:
+            RESOLUSI = 720
+        else:
+            pq = event.text.split(maxsplit=1)[1]
+            RESOLUSI = int(pq)
+        if replied.video or replied.document:
+            songname = "Telegram Video Player"
+        if chat_id in QUEUE:
+            pos = add_to_queue(chat_id, songname, dl, link, "Video", RESOLUSI)
+            caption = f"**✨ ᴀᴅᴅᴇᴅ ᴛᴏ ǫᴜᴇᴜᴇ ᴀᴛ** {pos}\n\n❄ **ᴛɪᴛʟᴇ :** [{songname}]({url})\n🥀 **ʀᴇǫᴜᴇsᴛᴇᴅ ʙʏ :** {from_user}"
+            await event.client.send_file(chat_id, ngantri, caption=caption, buttons=btnn)
+            await xnxx.delete()
+        else:
+            if RESOLUSI == 360:
+                hmmm = LowQualityVideo()
+            elif RESOLUSI == 480:
+                hmmm = MediumQualityVideo()
+            elif RESOLUSI == 720:
+                hmmm = HighQualityVideo()
+            try:
+                await call_py.join_group_call(
+                    chat_id,
+                    AudioVideoPiped(dl, HighQualityAudio(), hmmm),
+                    stream_type=StreamType().pulse_stream,
+                )
+                add_to_queue(chat_id, songname, dl, link, "Video", RESOLUSI)
+                caption = f"➻ **sᴛᴀʀᴛᴇᴅ sᴛʀᴇᴀᴍɪɴɢ**\n\n✨ **ᴛɪᴛʟᴇ :** [{songname}]({link})\n🥀 **ʀᴇǫᴜᴇsᴛᴇᴅ ʙʏ :** {from_user}"
+                await xnxx.delete()
+                await event.client.send_file(chat_id, fotoplay, caption=caption, buttons=btnn)
+            except Exception as ep:
+                clear_queue(chat_id)
+                await xnxx.edit(f"`{ep}`")
+    else:
+        xnxx = await event.reply("**🔄 Processing Query... Please Wait!**")
+        query = event.text.split(maxsplit=1)[1]
+        search = ytsearch(query)
+        RESOLUSI = 720
+        hmmm = HighQualityVideo()
+        if search == 0:
+            await xnxx.edit("**Unable To featch your Query**")
+        else:
+            songname = search[0]
+            title = search[0]
+            url = search[1]
+            duration = search[2]
+            thumbnail = search[3]
+            videoid = search[4]
+            ctitle = await CHAT_TITLE(titlegc)
+            thumb = await gen_thumb(videoid)
+            format = "best[height<=?720][width<=?1280]"
+            hm, ytlink = await ytdl(format, url)
+            if hm == 0:
+                await xnxx.edit(f"`{ytlink}`")
+            elif chat_id in QUEUE:
+                pos = add_to_queue(
+                    chat_id, songname, ytlink, url, "Video", RESOLUSI)
+                caption = f"**✨ ᴀᴅᴅᴇᴅ ᴛᴏ ǫᴜᴇᴜᴇ ᴀᴛ** {pos}\n\n❄ **ᴛɪᴛʟᴇ :** [{songname}]({url})\n⏱ **ᴅᴜʀᴀᴛɪᴏɴ :** {duration} ᴍɪɴᴜᴛᴇs\n🥀 **ʀᴇǫᴜᴇsᴛᴇᴅ ʙʏ :** {from_user}"
+                await xnxx.delete()
+                await event.client.send_file(chat_id, thumb, caption=caption, buttons=btnn)
+            else:
+                try:
+                    await call_py.join_group_call(
+                        chat_id,
+                        AudioVideoPiped(ytlink, HighQualityAudio(), hmmm),
+                        stream_type=StreamType().pulse_stream,
+                    )
+                    add_to_queue(
+                        chat_id,
+                        songname,
+                        ytlink,
+                        url,
+                        "Video",
+                        RESOLUSI)
+                    caption = f"➻ **sᴛᴀʀᴛᴇᴅ sᴛʀᴇᴀᴍɪɴɢ**\n\n✨ **ᴛɪᴛʟᴇ :** [{songname}]({url})\n⏱ **ᴅᴜʀᴀᴛɪᴏɴ :** {duration} ᴍɪɴᴜᴛᴇs\n🥀 **ʀᴇǫᴜᴇsᴛᴇᴅ ʙʏ :** {from_user}"
+                    await xnxx.delete()
+                    await event.client.send_file(chat_id, thumb, caption=caption, buttons=btnn)
+                except Exception as ep:
+                    clear_queue(chat_id)
+                    await xnxx.edit(f"`{ep}`")
+
+
+
+
+#playlist
+@Zaid.on(events.NewMessage(pattern="^[?!/]playlist"))
+@is_admin
+async def vc_playlist(event, perm):
+    chat_id = event.chat_id
+    if chat_id in QUEUE:
+        chat_queue = get_queue(chat_id)
+        if len(chat_queue) == 1:
+            await event.reply(
+                f"**�PlAYLIST:**\n• [{chat_queue[0][0]}]({chat_queue[0][2]}) | `{chat_queue[0][3]}`",
+                link_preview=False,
+            )
+        else:
+            PLAYLIST = f"**🎧 PLAYLIST:**\n**• [{chat_queue[0][0]}]({chat_queue[0][2]})** | `{chat_queue[0][3]}` \n\n**• Upcoming Streaming:**"
+            l = len(chat_queue)
+            for x in range(1, l):
+                hmm = chat_queue[x][0]
+                hmmm = chat_queue[x][2]
+                hmmmm = chat_queue[x][3]
+                PLAYLIST = PLAYLIST + "\n" + \
+                    f"**#{x}** - [{hmm}]({hmmm}) | `{hmmmm}`"
+            await event.reply(PLAYLIST, link_preview=False)
+    else:
+        await event.reply("**Ntg is Streaming**")
+
+
+
+
+
+
+#leavevc
+@Zaid.on(events.NewMessage(pattern="^[?!/]leavevc"))
+@is_admin
+async def leavevc(event, perm):
+    xnxx = await event.reply("Processing")
+    chat_id = event.chat_id
+    from_user = vcmention(event.sender)
+    if from_user:
+        try:
+            await call_py.leave_group_call(chat_id)
+        except (NotInGroupCallError, NoActiveGroupCall):
+            pass
+        await xnxx.edit("**Left the voice chat** `{}`".format(str(event.chat_id)))
+    else:
+        await xnxx.edit(f"**Sorry {owner} not on Voice Chat**")
+
+
+
+@Zaid.on(events.NewMessage(pattern="^[?!/]skip"))
+@is_admin
+async def vc_skip(event, perm):
+    chat_id = event.chat_id
+    if len(event.text.split()) < 2:
+        op = await skip_current_song(chat_id)
+        if op == 0:
+            await event.reply("**Nothing Is Streaming**")
+        elif op == 1:
+            await event.reply("empty queue, leaving voice chat")
+        else:
+            await event.reply(
+                f"**⏭ Skipped**\n**🎧 Now Playing** - [{op[0]}]({op[1]})",
+                link_preview=False,
+            )
+    else:
+        skip = event.text.split(maxsplit=1)[1]
+        DELQUE = "**Removing Following Songs From Queue:**"
+        if chat_id in QUEUE:
+            items = [int(x) for x in skip.split(" ") if x.isdigit()]
+            items.sort(reverse=True)
+            for x in items:
+                if x != 0:
+                    hm = await skip_item(chat_id, x)
+                    if hm != 0:
+                        DELQUE = DELQUE + "\n" + f"**#{x}** - {hm}"
+            await event.reply(DELQUE)
+
+
+@Zaid.on(events.NewMessage(pattern="^[?!/]pause"))
+@is_admin
+async def vc_pause(event, perm):
+    chat_id = event.chat_id
+    if chat_id in QUEUE:
+        try:
+            await call_py.pause_stream(chat_id)
+            await event.reply("**Streaming Paused**")
+        except Exception as e:
+            await event.reply(f"**ERROR:** `{e}`")
+    else:
+        await event.reply("**Nothing Is Playing**")
+
+
+
+@Zaid.on(events.NewMessage(pattern="^[?!/]resume"))
+@is_admin
+async def vc_resume(event, perm):
+    chat_id = event.chat_id
+    if chat_id in QUEUE:
+        try:
+            await call_py.resume_stream(chat_id)
+            await event.reply("**Streaming Started Back 🔙**")
+        except Exception as e:
+            await event.reply(f"**ERROR:** `{e}`")
+    else:
+        await event.reply("**Nothing Is Streaming**")
+
+
+@call_py.on_stream_end()
+async def stream_end_handler(_, u: Update):
+    chat_id = u.chat_id
+    print(chat_id)
+    await skip_current_song(chat_id)
+
+
+@call_py.on_closed_voice_chat()
+async def closedvc(_, chat_id: int):
+    if chat_id in QUEUE:
+        clear_queue(chat_id)
+    if chat_id in active:
+        active.remove(chat_id)
+
+
+@call_py.on_left()
+async def leftvc(_, chat_id: int):
+    if chat_id in QUEUE:
+        clear_queue(chat_id)
+    if chat_id in active:
+        active.remove(chat_id)
+
+
+@call_py.on_kicked()
+async def kickedvc(_, chat_id: int):
+    if chat_id in QUEUE:
+        clear_queue(chat_id)
+    if chat_id in active:
+        active.remove(chat_id)

Zaid/plugins/speedtest.py

@@ -0,0 +1,40 @@
+from telethon import Button, events
+
+from Zaid import *
+
+import asyncio
+import speedtest
+
+# Commands
+
+def testspeed(m):
+    try:
+        test = speedtest.Speedtest()
+        test.get_best_server()
+        test.download()
+        test.upload()
+        test.results.share()
+        result = test.results.dict()
+    except Exception as e:
+        return
+    return result
+
+@Zaid.on(events.NewMessage(pattern="^/speedtest"))
+async def speedtest_function(message):
+    m = await message.reply("Running Speed test")
+    loop = asyncio.get_event_loop()
+    result = await loop.run_in_executor(None, testspeed, m)
+    output = f"""**Speedtest Results**
+    
+**Client:**
+**__ISP:__** {result['client']['isp']}
+**__Country:__** {result['client']['country']}
+  
+**Server:**
+**__Name:__** {result['server']['name']}
+**__Country:__** {result['server']['country']}, {result['server']['cc']}
+**__Sponsor:__** {result['server']['sponsor']}
+**__Latency:__** {result['server']['latency']}  
+**__Ping:__** {result['ping']}"""
+    await Zaid.send_file(message.chat.id, result["share"], caption=output)
+    await m.delete()

Zaid/plugins/start.py

@@ -0,0 +1,41 @@
+from Zaid import Zaid, BOT_USERNAME
+from Config import Config
+from telethon import events, Button
+
+PM_START_TEXT = """
+ʜᴇʏᴀ! {}
+
+• ɪ'ᴍ ᴀ ꜱɪᴍᴘʟᴇ ᴛᴇʟᴇɢʀᴀᴍ ᴍᴜꜱɪᴄ ʙᴏᴛ.
+• ɪ ᴄᴀɴ ᴘʟᴀʏ ꜱᴏɴɢꜱ ɪɴ ʏᴏᴜʀ ᴠᴏɪᴄᴇ.
+• ᴛʜɪꜱ ʙᴏᴛ ʙᴀꜱᴇᴅ ᴏɴ ᴛᴇʟᴇᴛʜᴏɴ. ꜱᴏ ɪᴛ'ꜱ ᴘʀᴏᴠɪᴅᴇ ᴍᴏʀᴇ ꜱᴛᴀʙɪʟɪᴛʏ ꜰʀᴏᴍ ᴏᴛʜᴇʀ ʙᴏᴛꜱ!
+• ɪ ᴄᴀɴ ᴅᴏ ᴏᴛʜᴇʀ ᴛʜɪɴɢꜱ ʟɪᴋᴇ ᴘɪɴꜱ ᴇᴛᴄꜱ.
+
+➻ **ᴄʟɪᴄᴋ ᴏɴ ʜᴇʟᴘ ʙᴜᴛᴛᴏɴ ꜰᴏʀ ᴍᴏʀᴇ ɪɴꜰᴏʀᴍᴀᴛɪᴏɴ**.
+"""
+
+@Zaid.on(events.NewMessage(pattern="^[?!/]start$"))
+async def start(event):
+    if Config.MANAGEMENT_MODE == "ENABLE":
+        return
+    if event.is_private:
+       await event.client.send_file(event.chat_id,
+             Config.START_IMG,
+             caption=PM_START_TEXT.format(event.sender.first_name), 
+             buttons=[
+        [Button.url("✨ ᴀᴅᴅ ᴍᴇ", f"https://t.me/{BOT_USERNAME}?startgroup=true"), Button.inline("🥀 ʜᴇʟᴘ", data="help")]])
+       return
+
+    if event.is_group:
+       await event.reply("**ʜᴇʏ! ɪ'ᴍ ꜱᴛɪʟʟ ᴀʟɪᴠᴇ ✅**")
+       return
+
+
+
+@Zaid.on(events.callbackquery.CallbackQuery(data="start"))
+async def _(event):
+    if Config.MANAGEMENT_MODE == "ENABLE":
+        return
+    if event.is_private:
+       await event.edit(PM_START_TEXT.format(event.sender.first_name), buttons=[
+        [Button.url("✨ ᴀᴅᴅ ᴍᴇ", f"https://t.me/{BOT_USERNAME}?startgroup=true"), Button.inline("🥀 ʜᴇʟᴘ", data="help")]])
+       return

Zaid/plugins/userbotjoin.py

@@ -0,0 +1,60 @@
+
+import os
+import sys
+import random
+from datetime import datetime
+from os import execl
+from telethon import TelegramClient, events
+from telethon.sessions import StringSession
+from telethon.tl.functions.account import UpdateProfileRequest
+import asyncio
+import telethon.utils
+from telethon.tl import functions
+from telethon.tl.functions.channels import LeaveChannelRequest
+from telethon.tl.functions.messages import ImportChatInviteRequest
+from Zaid import *
+from Zaid.status import *
+
+
+
+@Zaid.on(events.NewMessage(pattern="^[!?/]join ?(.*)"))
+@Zaid.on(events.NewMessage(pattern="^[!?/]userbotjoin ?(.*)"))
+@is_admin
+async def _(e, perm):
+    chat_id = e.chat_id
+    usage = "𝗠𝗼𝗱𝘂𝗹𝗲 𝗡𝗮𝗺𝗲 = 𝗝𝗼𝗶𝗻\n\nCommand:\n\n/join <Group Link/Username> if your Group is private then use !pjoin <Chat link>"
+    if e.is_group:
+        umm = ("".join(e.text.split(maxsplit=1)[1:])).split(" ", 1)
+        if len(e.text) > 6:
+            bc = umm[0]
+            text = "Joining..."
+            event = await e.reply(text, parse_mode=None, link_preview=None )
+            try:
+                await client(functions.channels.JoinChannelRequest(channel=bc))
+                await event.edit("Succesfully Joined if not joined Use !pjoin and your group link")
+            except Exception as e:
+                await event.edit(str(e))   
+        else:
+            await e.reply(usage, parse_mode=None, link_preview=None )
+
+
+@Zaid.on(events.NewMessage(pattern="^[!?/]pjoin ?(.*)"))
+@is_admin        
+async def _(e, perm):
+    chat_id = e.chat_id
+    usage = "𝗠𝗼𝗱𝘂𝗹𝗲 𝗡𝗮𝗺𝗲 = 𝗣𝗿𝗶𝘃𝗮𝘁𝗲 𝗝𝗼𝗶𝗻\n\nCommand:\n\n!pjoin <Private Channel or Group's access hash>\n\nExample :\nLink = https://t.me/joinchat/Ihsvig1907226#\n\n!pjoin Ihsvig1907226"
+    if e.is_group:
+        umm = ("".join(e.text.split(maxsplit=1)[1:])).split(" ", 1)
+        if len(e.text) > 7:
+            invitelink = umm[0]
+            text = "Joining...."
+            event = await e.reply(text, parse_mode=None, link_preview=None )
+            try:
+                await client(ImportChatInviteRequest(invitelink))
+                await event.edit("Succesfully Joined")
+            except Exception as e:
+                await event.edit(str(e))   
+        else:
+            await e.reply(usage, parse_mode=None, link_preview=None )
+            
+