DRIFT FREE SOURCE CODE

import asyncio
import psutil
from telegram import Update
from telegram.ext import Application, CommandHandler, ContextTypes

# Escape MarkdownV2 special characters
def escape_md(text):
    reserved = r'_*[]()~`>#+-=|{}.!'
    return ''.join(f'\\{c}' if c in reserved else c for c in str(text))

async def status(update: Update, context: ContextTypes.DEFAULT_TYPE):
    user = update.effective_user
    chat_id = update.effective_chat.id

    # Helper to build the status text (exactly your original template)
    def build_text():
        disk = psutil.disk_usage('/')
        used = disk.used / (1024**3)
        total = disk.total / (1024**3)
        cpu = psutil.cpu_percent(interval=0.5)
        cores = psutil.cpu_count(logical=True)

        return (
            f"🖥️ Nᴏɴ-Rᴏᴏᴛ VPS Sᴇʀᴠᴇʀ\n\n"
            f"📛 Nᴀᴍᴇ - `{escape_md(user.full_name)}`\n"
            f"👤 Uꜱᴇʀɴᴀᴍᴇ - `{escape_md(user.username or 'N/A')}`\n"
            f"🆔 Uꜱᴇʀ Iᴅ - `{user.id}`\n\n"
            f"🌐 Sᴇʀᴠᴇʀ - `Nᴏɴ-Rᴏᴏᴛ VPS`\n"
            f"💾 Sᴛᴏʀᴀɢᴇ - `{used:.1f} / {total:.0f} Gɪʙ`\n"
            f"⚙️ CPU - `{cpu:.0f}% / {cores} Cᴏʀᴇ`\n"
            f"🔄 Rᴇᴘʟɪᴛ Bᴀᴄᴋᴜᴘ - `Aᴠᴀɪʟᴀʙʟᴇ`"
        )

    # Send the first message (no "fetching" text)
    first_msg = await update.message.reply_text(
        build_text(),
        parse_mode='MarkdownV2'
    )
    msg_id = first_msg.message_id

    # Update the same message 10 times (every 5 seconds)
    for _ in range(10):
        await asyncio.sleep(5)                      # wait 5 seconds
        new_text = build_text()                     # fresh data
        await context.bot.edit_message_text(
            chat_id=chat_id,
            message_id=msg_id,
            text=new_text,
            parse_mode='MarkdownV2'
        )

    # No final note – the last updated message stays as is.

def main():
    app = Application.builder().token("YOUR_BOT_TOKEN").build()
    app.add_handler(CommandHandler("status", status))
    print("Bot is running. Try /status")
    app.run_polling()

if __name__ == "__main__":
    main()

GUYSS ABBI THORE DIN KE LIYE DOSTO KE SATH BAHAR GHUM RAHA HU TO TO BAHUT SARE USERS KO REPLY NHI MIL PAYEGA AUR ESS CODE ME KOI PROBLEM HO TO ME AAKE THEEK KAR DUNGA AUR ABHI TIME NHI HAI ESKE VAJAH SE AUR ACHHA NHI KAR PAYA TIME MILEGA TO KAR DUNGA

# Final summary (Bold + Green + Magenta values) print(f"\n{Colors.BOLD}{Colors.OKGREEN}[✅] Finished! Total successful reports: {Colors.HEADER}{success_count} / {count}{Colors.BOLD}{Colors.OKGREEN}{Colors.ENDC}") await client.disconnect() if name == "main": asyncio.run(main())

#!/usr/bin/env python3 import asyncio import random from telethon import TelegramClient from telethon.tl.functions.account import ReportPeerRequest # <-- Correct one for reporting a user from telethon.tl.types import InputReportReasonSpam from telethon.errors import FloodWaitError, RPCError # ========== ANSI COLOR CODES ========== class Colors: HEADER = '\033[95m' # Magenta (Values) OKBLUE = '\033[94m' # Blue (Info) OKCYAN = '\033[96m' # Cyan (Processing) OKGREEN = '\033[92m' # Green (Success) WARNING = '\033[93m' # Yellow (Wait/Warning) FAIL = '\033[91m' # Red (Error) BOLD = '\033[1m' # Bold (Finish) ENDC = '\033[0m' # Reset # ---------- CONFIG ---------- API_ID = int(input(f"{Colors.OKBLUE}Enter your API ID: {Colors.ENDC}")) API_HASH = input(f"{Colors.OKBLUE}Enter your API hash: {Colors.ENDC}") SESSION_FILE = "report_session" async def send_report_with_retry(client, entity, max_retries=5): """Send one report with retries on temporary failures.""" attempt = 0 while attempt < max_retries: try: # This reports the entire user/chat directly (works without message IDs) await client(ReportPeerRequest( peer=entity, reason=InputReportReasonSpam(), message="Spamming repeatedly." )) return True except FloodWaitError as e: wait = e.seconds print(f"{Colors.WARNING}[⏳] Flood wait for {wait}s, retrying same report...{Colors.ENDC}") await asyncio.sleep(wait) attempt += 1 except RPCError as e: print(f"{Colors.WARNING}[⚠️] RPC error: {e}. Retrying in 5s...{Colors.ENDC}") await asyncio.sleep(5) attempt += 1 except Exception as e: print(f"{Colors.FAIL}[✗] Unexpected error: {e}. Retrying in 10s...{Colors.ENDC}") await asyncio.sleep(10) attempt += 1 print(f"{Colors.FAIL}[✗] Failed after {max_retries} attempts for this report.{Colors.ENDC}") return False async def main(): client = TelegramClient(SESSION_FILE, API_ID, API_HASH) await client.start() print(f"\n{Colors.OKGREEN}[✓] Login successful.{Colors.ENDC}\n") # 1️⃣ Ask for report count first try: count_input = input(f"{Colors.OKBLUE}How many reports to send? (e.g., 1000): {Colors.ENDC}") count = int(count_input) except ValueError: count = 1000 print(f"{Colors.WARNING}[!] Invalid input, using default {count}{Colors.ENDC}") # 2️⃣ Then ask for username username = input(f"{Colors.OKBLUE}Enter username to report (without @): {Colors.ENDC}").strip() if not username: print(f"{Colors.FAIL}[✗] No username provided. Exiting.{Colors.ENDC}") return try: entity = await client.get_entity(f"@{username}") print(f"{Colors.HEADER}[✓] Target user found: @{username}{Colors.ENDC}") except Exception as e: print(f"{Colors.FAIL}[✗] User not found: {e}{Colors.ENDC}") return # 3️⃣ Processing message (Cyan + Magenta values) print(f"\n{Colors.OKCYAN}[⏳] Processing… Starting {Colors.HEADER}{count}{Colors.OKCYAN} reports on {Colors.HEADER}@{username}{Colors.OKCYAN}...{Colors.ENDC}") success_count = 0 for i in range(1, count + 1): print(f"{Colors.OKBLUE}[→] Sending report #{i}...{Colors.ENDC}") ok = await send_report_with_retry(client, entity, max_retries=5) if ok: success_count += 1 if success_count % 10 == 0: print(f"{Colors.OKGREEN}[✓] {Colors.HEADER}{success_count}{Colors.OKGREEN} reports sent successfully so far...{Colors.ENDC}") else: print(f"{Colors.FAIL}[✗] Report #{i} failed permanently. Skipping...{Colors.ENDC}") # Random gap between reports to avoid detection await asyncio.sleep(random.uniform(2, 4))