Devine/plugins/Dev/upload.py

import requests
from pyrogram import Client, filters
from Devine import app as Devine
import time
import asyncio
from config import OWNER_ID

CLOUDINARY_UPLOAD_URL = "https://api.cloudinary.com/v1_1/your_cloud_name/upload"
CLOUD_NAME = "Untitled"  
API_KEY = "769593722143466"
API_SECRET = "DztGFORQqYfBoxCdawh0g5jBRCg"
MAX_FILE_SIZE_MB = 32  
USER_UPLOAD_LIMIT = {}

async def send_temp_message(message, text):
    reply = await message.reply(text)
    
    for i in range(3):
        await asyncio.sleep(0.3)  
        updated_text = text + '.' * (i + 1)  
        await reply.edit(updated_text)  
        
    return reply  

async def upload_file(client, message, file_path):
    waiting_message = await send_temp_message(message, "ᴡᴀɪᴛ")
    
    start_time = time.time()

    with open(file_path, 'rb') as file:
        files = {
            "file": file,
            "api_key": API_KEY,
            "timestamp": int(time.time()),
            "signature": API_SECRET  
        }
        response = requests.post(CLOUDINARY_UPLOAD_URL, data=files)

    upload_time = round(time.time() - start_time, 2)

    if response.status_code == 200:
        response_data = response.json()
        file_url = response_data["secure_url"]  

        await waiting_message.edit(f"<b>ᴜᴘʟᴏᴀᴅᴇᴅ ᴛᴏ <a href='{file_url}' target='_blank'>Cloudinary</a> ɪɴ {upload_time} sᴇᴄᴏɴᴅs.</b>\n\n"
                                   f"<b>ᴄᴏᴘʏ ʟɪɴᴋ : <code>{file_url}</code></b> ")
    else:
        await waiting_message.edit("<b>ғᴀɪʟᴇᴅ ᴛᴏ ᴜᴘʟᴏᴀᴅ ᴛʜᴇ ғɪʟᴇ.</b>")

async def handle_upload(client, message, target_message):
    user_id = message.from_user.id
    current_time = time.time()
    last_upload_time = USER_UPLOAD_LIMIT.get(user_id, 0)

    if current_time - last_upload_time < 10:
        await message.reply("<b>ʏᴏᴜ ᴀʀᴇ ʙᴇɪɴɢ ʀᴀᴛᴇ-ʟɪᴍɪᴛᴇᴅ. ᴛʀʏ ᴀɢᴀɪɴ ᴀғᴛᴇʀ 10 sᴇᴄᴏɴᴅs.</b>")
        return

    USER_UPLOAD_LIMIT[user_id] = current_time

    file_size = (target_message.photo or target_message.video).file_size / (1024 * 1024)  
    if file_size > MAX_FILE_SIZE_MB:
        await message.reply("<b>ғɪʟᴇ sɪᴢᴇ ᴇxᴄᴇᴇᴅs 32 ᴍʙ ʟɪᴍɪᴛ.</b>")
    else:
        file_path = await target_message.download()
        await upload_file(client, message, file_path)

@Devine.on_message(filters.command("xtgm"))
async def upload_command(client, message):
    if message.from_user.is_bot:
        return  

    target_message = message.reply_to_message if message.reply_to_message else message
    media = target_message.photo or target_message.video

    if media:
        await handle_upload(client, message, target_message)
    else:
        await message.reply("<b>sᴇɴᴅ ᴏʀ ʀᴇᴘʟʏ ᴛᴏ ᴀ ᴘʜᴏᴛᴏ ᴏʀ ᴠɪᴅᴇᴏ ғᴏʀ ᴜᴘʟᴏᴀᴅ.</b>")