(client, message)
| 79 | |
| 80 | @Client.on_message(filters.private & filters.reply) |
| 81 | async def refunc(client, message): |
| 82 | reply_message = message.reply_to_message |
| 83 | if (reply_message.reply_markup) and isinstance(reply_message.reply_markup, ForceReply): |
| 84 | new_name = message.text |
| 85 | await message.delete() |
| 86 | msg = await client.get_messages(message.chat.id, reply_message.id) |
| 87 | file = msg.reply_to_message |
| 88 | media = getattr(file, file.media.value) |
| 89 | if not "." in new_name: |
| 90 | if "." in media.file_name: |
| 91 | extn = media.file_name.rsplit('.', 1)[-1] |
| 92 | else: |
| 93 | extn = "mkv" |
| 94 | new_name = new_name + "." + extn |
| 95 | await reply_message.delete() |
| 96 | button = [[InlineKeyboardButton("📁 Dᴏᴄᴜᴍᴇɴᴛ",callback_data = "upload#document")]] |
| 97 | if file.media in [MessageMediaType.VIDEO, MessageMediaType.DOCUMENT]: |
| 98 | button.append([InlineKeyboardButton("🎥 Vɪᴅᴇᴏ", callback_data = "upload#video")]) |
| 99 | elif file.media == MessageMediaType.AUDIO: |
| 100 | button.append([InlineKeyboardButton("🎵 Aᴜᴅɪᴏ", callback_data = "upload#audio")]) |
| 101 | await message.reply( |
| 102 | text=f"**Sᴇʟᴇᴄᴛ Tʜᴇ Oᴜᴛᴩᴜᴛ Fɪʟᴇ Tyᴩᴇ**\n**• Fɪʟᴇ Nᴀᴍᴇ :-**`{new_name}`", |
| 103 | reply_to_message_id=file.id, |
| 104 | reply_markup=InlineKeyboardMarkup(button) |
| 105 | ) |
| 106 | |
| 107 | async def upload_files(bot, sender_id, upload_type, file_path, ph_path, caption, duration, rkn_processing): |
| 108 | """ |
nothing calls this directly
no outgoing calls
no test coverage detected