Admin: Implement sh, eval, and /usage commands with system monitoring

plugins/eval.py

@@ -0,0 +1,89 @@
+import os
+import sys
+import traceback
+import io
+import asyncio
+from pyrogram import Client, filters
+from config import ADMIN
+
+@Client.on_message(filters.user(ADMIN) & filters.command("sh"))
+async def shell_runner(client, message):
+    if len(message.command) < 2:
+        return await message.reply_text("<b>Usage:</b> <code>/sh [command]</code>")
+    
+    code = message.text.split(None, 1)[1]
+    msg = await message.reply_text("<code>Executing...</code>")
+    
+    process = await asyncio.create_subprocess_shell(
+        code,
+        stdout=asyncio.subprocess.PIPE,
+        stderr=asyncio.subprocess.PIPE
+    )
+    stdout, stderr = await process.communicate()
+    
+    result = str(stdout.decode().strip()) + str(stderr.decode().strip())
+    
+    if len(result) > 4096:
+        with io.BytesIO(str.encode(result)) as out_file:
+            out_file.name = "shell.txt"
+            await message.reply_document(document=out_file, caption=f"<code>{code}</code>")
+            await msg.delete()
+    else:
+        await msg.edit(f"<b>Command:</b>\n<code>{code}</code>\n\n<b>Result:</b>\n<code>{result}</code>")
+
+@Client.on_message(filters.user(ADMIN) & filters.command("eval"))
+async def eval_runner(client, message):
+    if len(message.command) < 2:
+        return await message.reply_text("<b>Usage:</b> <code>/eval [code]</code>")
+        
+    status_message = await message.reply_text("<code>Processing...</code>")
+    cmd = message.text.split(None, 1)[1]
+
+    old_stderr = sys.stderr
+    old_stdout = sys.stdout
+    redirected_output = io.StringIO()
+    redirected_error = io.StringIO()
+    sys.stdout = redirected_output
+    sys.stderr = redirected_error
+    stdout, stderr, exc = None, None, None
+
+    try:
+        await aexec(cmd, client, message)
+    except Exception:
+        exc = traceback.format_exc()
+
+    stdout = redirected_output.getvalue()
+    stderr = redirected_error.getvalue()
+    sys.stdout = old_stdout
+    sys.stderr = old_stderr
+
+    evaluation = ""
+    if exc:
+        evaluation = exc
+    elif stderr:
+        evaluation = stderr
+    elif stdout:
+        evaluation = stdout
+    else:
+        evaluation = "Success"
+
+    final_output = f"<b>EVAL</b>: <code>{cmd}</code>\n\n<b>OUTPUT</b>:\n<code>{evaluation}</code>"
+
+    if len(final_output) > 4096:
+        with io.BytesIO(str.encode(evaluation)) as out_file:
+            out_file.name = "eval.txt"
+            await message.reply_document(
+                document=out_file,
+                caption=f"<code>{cmd}</code>",
+                quote=True
+            )
+            await status_message.delete()
+    else:
+        await status_message.edit(final_output)
+
+async def aexec(code, client, message):
+    exec(
+        f"async def __aexec(client, message): "
+        + "".join(f"\n {l}" for l in code.split("\n"))
+    )
+    return await locals()["__aexec"](client, message)

plugins/usage.py

@@ -0,0 +1,36 @@
+import shutil
+import psutil
+from pyrogram import Client, filters
+from config import ADMIN
+from helper.progress import humanbytes
+
+@Client.on_message(filters.user(ADMIN) & filters.command("usage"))
+async def usage_stats(client, message):
+    msg = await message.reply_text("<code>Fetching System Stats...</code>")
+    
+    # CPU Usage
+    cpu_usage = psutil.cpu_percent(interval=0.5)
+    
+    # RAM Usage
+    ram = psutil.virtual_memory()
+    ram_total = humanbytes(ram.total)
+    ram_used = humanbytes(ram.used)
+    ram_usage = ram.percent
+    
+    # Disk Usage
+    disk = shutil.disk_usage("/")
+    disk_total = humanbytes(disk.total)
+    disk_used = humanbytes(disk.used)
+    disk_free = humanbytes(disk.free)
+    disk_usage = (disk.used / disk.total) * 100
+    
+    stats = f"""<b><emoji id=5875184591395885737>📊</emoji> System Usage Stats</b>
+    
+<b><emoji id=5456140674028019486>🖥️</emoji> CPU Usage:</b> <code>{cpu_usage}%</code>
+<b><emoji id=5985386442824619877>📟</emoji> RAM Usage:</b> <code>{ram_used}</code> / <code>{ram_total}</code> (<code>{ram_usage}%</code>)
+<b><emoji id=5433653135799228968>📁</emoji> Disk Usage:</b> <code>{disk_used}</code> / <code>{disk_total}</code> (<code>{disk_usage:.1f}%</code>)
+<b><emoji id=5787432469598835099>💿</emoji> Disk Free:</b> <code>{disk_free}</code>
+
+<b><emoji id=5316994101688677895>⚡️</emoji> Status:</b> <code>Stable</code>"""
+
+    await msg.edit(stats)

requirements.txt

@@ -9,4 +9,5 @@ dnspython==2.8.0
 Flask==3.1.3
 gunicorn==25.1.0
 aiohttp==3.13.3
+psutil==7.0.0