| import asyncio |
| import os |
|
|
| from pyrogram import filters |
| from pyrogram.errors import FloodWait |
| from pyrogram.types import CallbackQuery, InputMediaPhoto, Message |
|
|
| import config |
| from SONALI import app |
| from SONALI.misc import db |
| from SONALI.utils import RAUSHANBin, get_channeplayCB, seconds_to_min |
| from SONALI.utils.database import get_cmode, is_active_chat, is_music_playing |
| from SONALI.utils.decorators.language import language, languageCB |
| from SONALI.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'sᴛʀᴇᴀᴍɪɴɢ :\n\n✨ ᴛɪᴛʟᴇ : {x["title"]}\nᴅᴜʀᴀᴛɪᴏɴ : {x["dur"]}\nʙʏ : {x["by"]}\n\n' |
| elif j == 2: |
| msg += f'ϙᴜᴇᴜᴇᴅ :\n\n✨ ᴛɪᴛʟᴇ : {x["title"]}\nᴅᴜʀᴀᴛɪᴏɴ : {x["dur"]}\nʙʏ : {x["by"]}\n\n' |
| else: |
| msg += f'✨ ᴛɪᴛʟᴇ : {x["title"]}\nᴅᴜʀᴀᴛɪᴏɴ : {x["dur"]}\nʙʏ : {x["by"]}\n\n' |
| if "ϙᴜᴇᴜᴇᴅ" 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 RAUSHANBin(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 |
|
|
