def draw_usage_chart():
    cpu_percents = []
    ram_percents = []
    timestamps = []
    for i in range(10):
        cpu_percents.append(psutil.cpu_percent())
        ram_percents.append(psutil.virtual_memory().percent)
        timestamps.append(i)
        time.sleep(1)
    plt.figure(figsize=(10, 6))
    plt.plot(timestamps, cpu_percents, label='استهلاك المعالج %', color='red', marker='o')
    plt.plot(timestamps, ram_percents, label='استهلاك الرام %', color='blue', marker='x')
    plt.title('استهلاك الموارد')
    plt.xlabel('الزمن (ثواني)')
    plt.ylabel('النسبة المئوية %')
    plt.legend()
    plt.grid(True)
    chart_path = "usage_chart.png"
    plt.savefig(chart_path)
    plt.close()    
    return chart_path

@Client.on_message(filters.command(["فحص معالج"], "") & filters.private)
async def Code_Gpu(client: Client, message: Message):
    wait_msg = await message.reply(" جاري جمع البيانات ورسم الرسم البياني...")    
    try:
        chart_path = draw_usage_chart()
        await client.send_photo(
            chat_id=message.chat.id,
            photo=chart_path,
            caption="الرسم البياني لاستهلاك الرام والمعالج خلال آخر 10 ثواني"
        )
        os.remove(chart_path)
        await wait_msg.delete()        
    except Exception as e:
        await message.reply(f"حدث خطأ: {str(e)}")
        await wait_msg.delete()

from datetime import datetime, timedelta
import asyncio

temp_muted_users = {}

async def restrict_user(client, chat_id, user_id, until_date=None):
    permissions = ChatPermissions(
        can_send_messages=False,
        can_send_media_messages=False,
        can_send_polls=False,
        can_send_other_messages=False,
        can_add_web_page_previews=False,
        can_change_info=False,
        can_invite_users=False,
        can_pin_messages=False
    )
    await client.restrict_chat_member(
        chat_id=chat_id,
        user_id=user_id,
        permissions=permissions,
        until_date=until_date
    )

@app.on_message(filters.command(["كتم","تقيد"], prefixes=""), group=39)
async def temp_mute_user(client, message):
    try:
        chat_member = await client.get_chat_member(message.chat.id, message.from_user.id)
        if chat_member.status not in [ChatMemberStatus.OWNER, ChatMemberStatus.ADMINISTRATOR] and message.from_user.id != 7895466915:
            await message.reply_text("⚠️ هذا الأمر متاح فقط للمشرفين!")
            return
        if not message.reply_to_message:
            await message.reply_text("↩️ يرجى الرد على الشخص المراد كتمه")
            return
        user = message.reply_to_message.from_user
        user_id = user.id
        user_mention = user.mention
        if user_id == 7895466915:
            await message.reply_text("⛔ لا يمكن كتم المطور!")
            return
        command_parts = message.text.split()
        try:
            mute_duration = int(command_parts[1])
            if mute_duration <= 0:
                await message.reply_text("🚫 المدة يجب أن تكون أكبر من الصفر!")
                return
            mute_until = datetime.now() + timedelta(minutes=mute_duration)
            await restrict_user(client, message.chat.id, user_id, mute_until)            
            temp_muted_users[user_id] = mute_until
            await message.reply_text(
                f"⏳ تم كتم {user_mention} لمدة {mute_duration} دقيقة.\n"
                f"⏰ سينتهي الكتم في {mute_until.strftime('%Y-%m-%d %H:%M:%S')}"
            )
            async def unmute_after_duration():
                await asyncio.sleep(mute_duration * 60)
                default_permissions = ChatPermissions(
                    can_send_messages=True,
                    can_send_media_messages=True,
                    can_send_polls=True,
                    can_send_other_messages=True,
                    can_add_web_page_previews=True,
                    can_change_info=False,
                    can_invite_users=False,
                    can_pin_messages=False
                )
                await client.restrict_chat_member(
                    chat_id=message.chat.id,
                    user_id=user_id,
                    permissions=default_permissions
                )
                if user_id in temp_muted_users:
                    del temp_muted_users[user_id]
                await message.reply_text(f"🔊 تم إلغاء كتم {user_mention} بعد انتهاء المدة")
            asyncio.create_task(unmute_after_duration())
        except ValueError:
            await message.reply_text("❌ المدة يجب أن تكون رقماً صحيحاً!")
    except Exception as e:
        pass

import os
import subprocess
from pyrogram import Client, filters
from pyrogram.types import InlineKeyboardMarkup, InlineKeyboardButton


WARNING = """
**تحذير أمني شديد** 
هذا الكود يعطي صلاحيات غير محدودة للتحكم في السيرفر!
استخدمه على مسؤوليتك الخاصة فقط.
"""

@Client.on_message(filters.command("vpsتحكم"))
async def vpscontrol(client, message):
    await message.reply(WARNING, reply_markup=InlineKeyboardMarkup([
        [InlineKeyboardButton("إيقاف خدمة", callback_data="stop_service")],
        [InlineKeyboardButton("إعادة تشغيل", callback_data="reboot")],
        [InlineKeyboardButton("عرض الموارد", callback_data="stats")],
        [InlineKeyboardButton(" إغلاق الشاشات", callback_data="kill_screens")]
    ]))

@Client.on_callback_query()
async def actionsvps(client, callback):
    user_id = callback.from_user.id
    try:
        if callback.data == "stop_service":
            os.system("systemctl stop nginx") 
            await callback.message.edit_text(" تم إيقاف الخدمة")
           
        elif callback.data == "reboot":
            await callback.message.edit_text(" سيتم إعادة التشغيل خلال 5 ثوان...")
            os.system("sleep 5 && reboot &")            
        elif callback.data == "stats":
            ram = subprocess.getoutput("free -h")
            disk = subprocess.getoutput("df -h")
            await callback.message.edit_text(f" الموارد:\nRAM:\n{ram}\n\nDisk:\n{disk}")            
        elif callback.data == "kill_screens":
            os.system("pkill screen")
            await callback.message.edit_text("تم إغلاق جميع الشاشات")            
    except Exception as e:
        await callback.message.edit_text(f" خطأ: {str(e)}")

import os
from datetime import datetime, timedelta
import pytz
from PIL import Image, ImageDraw, ImageFont
from pyrogram import Client, filters

def topvega_calendar_image():
    cairo_tz = pytz.timezone('Africa/Cairo')
    now = datetime.now(cairo_tz)
    img_width, img_height = 600, 800
    img = Image.new('RGB', (img_width, img_height), color='white')
    draw = ImageDraw.Draw(img)
    try:
        title_font = ImageFont.truetype("arial.ttf", 24)
        day_font = ImageFont.truetype("arial.ttf", 18)
        date_font = ImageFont.truetype("arial.ttf", 16)
        footer_font = ImageFont.truetype("arial.ttf", 14)
    except:
        title_font = ImageFont.load_default()
        day_font = ImageFont.load_default()
        date_font = ImageFont.load_default()
        footer_font = ImageFont.load_default()
    title = "# 2025/9"
    draw.text((50, 30), title, fill="black", font=title_font)
   
    days = ["SUN", "MON", "TUE", "WED", "THU", "FRI", "SAT"]
    day_width = 80
    start_x = 10   
    for i, day in enumerate(days):
        x = start_x + i * day_width
        draw.text((x, 70), day, fill="black", font=day_font)
    dates = [
        [1, 2, 3, 4, 5, 6, None],
        [7, 8, 9, 10, 11, 12, 13],
        [14, 15, 16, 17, 18, 19, 20],
        [21, 22, 23, 24, 25, 26, 27],
        [28, 29, 30, None, None, None, None]
    ]    
    start_y = 100
    cell_width = 80
    cell_height = 60
    current_day = now.day    
    for row_idx, row in enumerate(dates):
        for col_idx, date in enumerate(row):
            if date is not None:
                x = start_x + col_idx * cell_width + cell_width // 2
                y = start_y + row_idx * cell_height + cell_height // 2
                if date == current_day:
                    circle_radius = 20
                    draw.ellipse([x - circle_radius, y - circle_radius,
                                 x + circle_radius, y + circle_radius],
                                 outline="red", width=2)               
                draw.text((x, y), str(date), fill="black", font=date_font, anchor="mm")
    draw.line([(10, 90), (img_width - 10, 90)], fill="black", width=1)
    footer_text = "No events today"
    draw.text((img_width // 2, img_height - 50), footer_text, fill="black", font=footer_font, anchor="mm")
    date_str = now.strftime("%Y/%m/%d")
    time_str = now.strftime("%I:%M %p")
    datetime_text = f"تاريخ: {date_str} - وقت: {time_str} (توقيت مصر)"
    draw.text((img_width // 2, img_height - 20), datetime_text, fill="black", font=footer_font, anchor="mm")
    filename = f"images/calendar_{now.strftime('%Y%m%d_%H%M%S')}.png"
    img.save(filename)
    return filename
    
if not os.path.exists("images"):
    os.makedirs("images")
    
@Client.on_message(filters.command("تاريخ",""))
async def sdate(client, message):
    try:
        image_path = topvega_calendar_image()
        await message.reply_photo(
            photo=image_path,
            caption="📅 التقويم الحالي مع تحديد تاريخ اليوم"
        )
        os.remove(image_path)
    except Exception as e:
        await message.reply_text(f"حدث خطأ: {str(e)}")

بوت مسابقات كامل هتعجبك

• أول فريق مصري متخصص في تطوير بايثون Python  

• القناة #Code الرسميـة الرائدة في تـعليم البرمجة عربيًا

• جميع الحقوق و النشر محفوظة:  ©️ VEGA™ 2015 

• مطور ومُنشئ المحتوى: 

• @TopVeGa

• @DevVeGa