| | import asyncio |
| | import os |
| |
|
| | from pyrogram import filters |
| | from pyrogram.errors import FloodWait |
| | from pyrogram.types import CallbackQuery, InputMediaPhoto, Message |
| |
|
| | import config |
| | from Devine import app |
| | from Devine.misc import db |
| | from Devine.utils import AnonyBin, get_channeplayCB, seconds_to_min |
| | from Devine.utils.database import get_cmode, is_active_chat, is_music_playing |
| | from Devine.utils.decorators.language import language, languageCB |
| | from Devine.utils.inline import queue_back_markup, queue_markup |
| | from config import BANNED_USERS |
| |
|
| | basic = {} |
| |
|
| |
|
| | def get_image(videoid): |
| | if os.path.isfile(f"cache/{videoid}.png"): |
| | return f"cache/{videoid}.png" |
| | else: |
| | return config.YOUTUBE_IMG_URL |
| |
|
| |
|
| | def get_duration(playing): |
| | file_path = playing[0]["file"] |
| | if "index_" in file_path or "live_" in file_path: |
| | return "Unknown" |
| | duration_seconds = int(playing[0]["seconds"]) |
| | if duration_seconds == 0: |
| | return "Unknown" |
| | else: |
| | return "Inline" |
| |
|
| |
|
| | @app.on_message( |
| | filters.command(["queue", "cqueue", "player", "cplayer", "playing", "cplaying"]) |
| | & filters.group |
| | & ~BANNED_USERS |
| | ) |
| | @language |
| | async def get_queue(client, message: Message, _): |
| | if message.command[0][0] == "c": |
| | chat_id = await get_cmode(message.chat.id) |
| | if chat_id is None: |
| | return await message.reply_text(_["setting_7"]) |
| | try: |
| | await app.get_chat(chat_id) |
| | except: |
| | return await message.reply_text(_["cplay_4"]) |
| | cplay = True |
| | else: |
| | chat_id = message.chat.id |
| | cplay = False |
| | if not await is_active_chat(chat_id): |
| | return await message.reply_text(_["general_5"]) |
| | got = db.get(chat_id) |
| | if not got: |
| | return await message.reply_text(_["queue_2"]) |
| | file = got[0]["file"] |
| | videoid = got[0]["vidid"] |
| | user = got[0]["by"] |
| | title = (got[0]["title"]).title() |
| | typo = (got[0]["streamtype"]).title() |
| | DUR = get_duration(got) |
| | if "live_" in file: |
| | IMAGE = get_image(videoid) |
| | elif "vid_" in file: |
| | IMAGE = get_image(videoid) |
| | elif "index_" in file: |
| | IMAGE = config.STREAM_IMG_URL |
| | else: |
| | if videoid == "telegram": |
| | IMAGE = ( |
| | config.TELEGRAM_AUDIO_URL |
| | if typo == "Audio" |
| | else config.TELEGRAM_VIDEO_URL |
| | ) |
| | elif videoid == "soundcloud": |
| | IMAGE = config.SOUNCLOUD_IMG_URL |
| | else: |
| | IMAGE = get_image(videoid) |
| | send = _["queue_6"] if DUR == "Unknown" else _["queue_7"] |
| | cap = _["queue_8"].format(app.mention, title, typo, user, send) |
| | upl = ( |
| | queue_markup(_, DUR, "c" if cplay else "g", videoid) |
| | if DUR == "Unknown" |
| | else queue_markup( |
| | _, |
| | DUR, |
| | "c" if cplay else "g", |
| | videoid, |
| | seconds_to_min(got[0]["played"]), |
| | got[0]["dur"], |
| | ) |
| | ) |
| | basic[videoid] = True |
| | mystic = await message.reply_photo(IMAGE, caption=cap, reply_markup=upl) |
| | if DUR != "Unknown": |
| | try: |
| | while db[chat_id][0]["vidid"] == videoid: |
| | await asyncio.sleep(5) |
| | if await is_active_chat(chat_id): |
| | if basic[videoid]: |
| | if await is_music_playing(chat_id): |
| | try: |
| | buttons = queue_markup( |
| | _, |
| | DUR, |
| | "c" if cplay else "g", |
| | videoid, |
| | seconds_to_min(db[chat_id][0]["played"]), |
| | db[chat_id][0]["dur"], |
| | ) |
| | await mystic.edit_reply_markup(reply_markup=buttons) |
| | except FloodWait: |
| | pass |
| | else: |
| | pass |
| | else: |
| | break |
| | else: |
| | break |
| | except: |
| | return |
| |
|
| |
|
| | @app.on_callback_query(filters.regex("GetTimer") & ~BANNED_USERS) |
| | async def quite_timer(client, CallbackQuery: CallbackQuery): |
| | try: |
| | await CallbackQuery.answer() |
| | except: |
| | pass |
| |
|
| |
|
| | @app.on_callback_query(filters.regex("GetQueued") & ~BANNED_USERS) |
| | @languageCB |
| | async def queued_tracks(client, CallbackQuery: CallbackQuery, _): |
| | callback_data = CallbackQuery.data.strip() |
| | callback_request = callback_data.split(None, 1)[1] |
| | what, videoid = callback_request.split("|") |
| | try: |
| | chat_id, channel = await get_channeplayCB(_, what, CallbackQuery) |
| | except: |
| | return |
| | if not await is_active_chat(chat_id): |
| | return await CallbackQuery.answer(_["general_5"], show_alert=True) |
| | got = db.get(chat_id) |
| | if not got: |
| | return await CallbackQuery.answer(_["queue_2"], show_alert=True) |
| | if len(got) == 1: |
| | return await CallbackQuery.answer(_["queue_5"], show_alert=True) |
| | await CallbackQuery.answer() |
| | basic[videoid] = False |
| | buttons = queue_back_markup(_, what) |
| | med = InputMediaPhoto( |
| | media="https://telegra.ph//file/6f7d35131f69951c74ee5.jpg", |
| | caption=_["queue_1"], |
| | ) |
| | await CallbackQuery.edit_message_media(media=med) |
| | j = 0 |
| | msg = "" |
| | for x in got: |
| | j += 1 |
| | if j == 1: |
| | msg += f'Streaming :\n\n✨ Title : {x["title"]}\nDuration : {x["dur"]}\nBy : {x["by"]}\n\n' |
| | elif j == 2: |
| | msg += f'Queued :\n\n✨ Title : {x["title"]}\nDuration : {x["dur"]}\nBy : {x["by"]}\n\n' |
| | else: |
| | msg += f'✨ Title : {x["title"]}\nDuration : {x["dur"]}\nBy : {x["by"]}\n\n' |
| | if "Queued" in msg: |
| | if len(msg) < 700: |
| | await asyncio.sleep(1) |
| | return await CallbackQuery.edit_message_text(msg, reply_markup=buttons) |
| | if "✨" in msg: |
| | msg = msg.replace("✨", "") |
| | link = await AnonyBin(msg) |
| | med = InputMediaPhoto(media=link, caption=_["queue_3"].format(link)) |
| | await CallbackQuery.edit_message_media(media=med, reply_markup=buttons) |
| | else: |
| | await asyncio.sleep(1) |
| | return await CallbackQuery.edit_message_text(msg, reply_markup=buttons) |
| |
|
| |
|
| | @app.on_callback_query(filters.regex("queue_back_timer") & ~BANNED_USERS) |
| | @languageCB |
| | async def queue_back(client, CallbackQuery: CallbackQuery, _): |
| | callback_data = CallbackQuery.data.strip() |
| | cplay = callback_data.split(None, 1)[1] |
| | try: |
| | chat_id, channel = await get_channeplayCB(_, cplay, CallbackQuery) |
| | except: |
| | return |
| | if not await is_active_chat(chat_id): |
| | return await CallbackQuery.answer(_["general_5"], show_alert=True) |
| | got = db.get(chat_id) |
| | if not got: |
| | return await CallbackQuery.answer(_["queue_2"], show_alert=True) |
| | await CallbackQuery.answer(_["set_cb_5"], show_alert=True) |
| | file = got[0]["file"] |
| | videoid = got[0]["vidid"] |
| | user = got[0]["by"] |
| | title = (got[0]["title"]).title() |
| | typo = (got[0]["streamtype"]).title() |
| | DUR = get_duration(got) |
| | if "live_" in file: |
| | IMAGE = get_image(videoid) |
| | elif "vid_" in file: |
| | IMAGE = get_image(videoid) |
| | elif "index_" in file: |
| | IMAGE = config.STREAM_IMG_URL |
| | else: |
| | if videoid == "telegram": |
| | IMAGE = ( |
| | config.TELEGRAM_AUDIO_URL |
| | if typo == "Audio" |
| | else config.TELEGRAM_VIDEO_URL |
| | ) |
| | elif videoid == "soundcloud": |
| | IMAGE = config.SOUNCLOUD_IMG_URL |
| | else: |
| | IMAGE = get_image(videoid) |
| | send = _["queue_6"] if DUR == "Unknown" else _["queue_7"] |
| | cap = _["queue_8"].format(app.mention, title, typo, user, send) |
| | upl = ( |
| | queue_markup(_, DUR, cplay, videoid) |
| | if DUR == "Unknown" |
| | else queue_markup( |
| | _, |
| | DUR, |
| | cplay, |
| | videoid, |
| | seconds_to_min(got[0]["played"]), |
| | got[0]["dur"], |
| | ) |
| | ) |
| | basic[videoid] = True |
| |
|
| | med = InputMediaPhoto(media=IMAGE, caption=cap) |
| | mystic = await CallbackQuery.edit_message_media(media=med, reply_markup=upl) |
| | if DUR != "Unknown": |
| | try: |
| | while db[chat_id][0]["vidid"] == videoid: |
| | await asyncio.sleep(5) |
| | if await is_active_chat(chat_id): |
| | if basic[videoid]: |
| | if await is_music_playing(chat_id): |
| | try: |
| | buttons = queue_markup( |
| | _, |
| | DUR, |
| | cplay, |
| | videoid, |
| | seconds_to_min(db[chat_id][0]["played"]), |
| | db[chat_id][0]["dur"], |
| | ) |
| | await mystic.edit_reply_markup(reply_markup=buttons) |
| | except FloodWait: |
| | pass |
| | else: |
| | pass |
| | else: |
| | break |
| | else: |
| | break |
| | except: |
| | return |
| |
|
