import asyncio import io import re import json import html import os import httpx import random import string import time import struct import hmac import hashlib import base64 from datetime import datetime, timedelta from telegram import ( Update, ReplyKeyboardMarkup, KeyboardButton, InlineKeyboardButton, InlineKeyboardMarkup, ) from telegram.ext import ApplicationBuilder, CommandHandler, MessageHandler, ContextTypes, filters, CallbackQueryHandler # ==================== LOCAL CONFIGURATION ==================== # This is the complete single-file bot. Replace the two placeholders below. # Never share this file after putting real credentials in it. CONFIG_BOT_TOKEN = "8960718300:AAEPuPMHAXXyzTHDDvjXX_T0kjjLFezu4Ek" CONFIG_VOLTX_API_KEY = os.getenv("VOLTX_API_KEY", "").strip() CONFIG_VOLTX_BASE_URL = "https://api.2oo9.cloud/MXS47FLFX0U/tnevs/@public/api" CONFIG_ADMIN_ID = 8346777366 CONFIG_OTP_GROUP_ID = -1003941189680 # Premium copy button (PTB 21+) try: from telegram import CopyTextButton HAS_COPY_BTN = True except ImportError: HAS_COPY_BTN = False # ==================== CONFIG SECTION ==================== # Credentials are configured above in this same file. # Environment variables override these values when provided. BOT_TOKEN = os.getenv("BOT_TOKEN", "").strip() or CONFIG_BOT_TOKEN.strip() USER_DATA_FILE = "users.json" PAID_SMS_FILE = "paid_sms.json" STATS_FILE = "user_stats.json" REFERRAL_DATA_FILE = "referral_data.json" BANNED_USERS_FILE = "banned_users.json" WITHDRAW_DATA_FILE = "withdraw_requests.json" ACTIVITY_LOGS_FILE = "activity_logs.json" DATA_RANGE_FILE = "datarange.json" SETTINGS_FILE = "settings.json" BOT_USERNAME = None # set at runtime via post_init # ==================== ADMIN CONFIGURATION ==================== # Set the primary admin ID only here. # Additional admins can still be added from the Bot Settings menu. ADMIN_ID = int(os.getenv("ADMIN_ID", str(CONFIG_ADMIN_ID or "8346777366"))) ADMINS = [ADMIN_ID] OTP_GROUP_ID = int(os.getenv("OTP_GROUP_ID", str(CONFIG_OTP_GROUP_ID or "-1003941189680"))) # ==================== PREMIUM EMOJI MAPPING ==================== EMOJI_ID_MAP = { "telegram": "5271801931814165886", "instagram": "5269682734820777950", "facebook": "5269427536453984598", "tiktok": "5271527792641595125", "x": "5269500885905468781", "whatsapp": "5271536803482981220", "up": "5244837092042750681", "down": "5246762912428603768", "add": "5397916757333654639", "setting": "5341715473882955310", "1st": "5440539497383087970", "2st": "5447203607294265305", "3rd": "5453902265922376865", "free": "5406756500108501710", "msg": "5253742260054409879", "link": "5271604874419647061", "status": "5231200819986047254", "home": "5416041192905265756", "gift_box": "5970074171449808121", "delete": "5422557736330106570", "number_change": "5267295703666824255", "refer_btn": "5420396762189831222", "get_number_btn": "5375338737028841420", "cross": "5420130255174145507", "stop": "5956074558044770726", "ban": "5420323339723881652", "loading": "5386367538735104399", "profile": "5352861489541714456", "done": "6298670698948724690", "otp_success": "5190781475468915802", "nagad": "5352985330628730418", "bkash": "5348469219761626211", "rocket": "5346042941196507141", "binance": "5348212415077064131", "live": "5355102594886833928", "developer": "5267294466716244344", "channel": "6215074610845585917", "copy": "5429483843541284898", "admin": "5350396951407895212", "waiting": "6217721388736712699", "back": "5267490665117275176", "leader_board": "5280769763398671636", "money": "6233367447789899509", "discord": "5807892405306791778", "custom_range": "5231012545799666522", "paypal": "5107533253946901363", "imo": "5337155807752524558", "hi": "5353027129250453493", "off": "5352974971167611327", "diamond": "5251562950698759162", "broadcast": "5251671501702196837", "key": "5296369303661067030", "bot_logo": "4943094697238201446", "tk": "5201873447554145566", "roket": "5188481279963715781", "all_done": "5859265295113261399", "yes": "5875017993909440887", "no": "5875005555684152921", "fire_love": "5864093929275658617", } FALLBACK_EMOJI_MAP = { "telegram": "\u2708\ufe0f", "instagram": "\U0001f4f7", "facebook": "\U0001f535", "tiktok": "\U0001f3b5", "x": "\u274c", "whatsapp": "\U0001f4ac", "up": "\U0001f4c8", "down": "\U0001f4c9", "add": "\u2795", "setting": "\u2699\ufe0f", "1st": "\U0001f947", "2st": "\U0001f948", "3rd": "\U0001f949", "free": "\U0001f193", "msg": "\U0001f4ac", "link": "\U0001f517", "status": "\U0001f4ca", "home": "\U0001f3e0", "gift_box": "\U0001f381", "delete": "\U0001f5d1\ufe0f", "number_change": "\U0001f504", "get_number_btn": "\U0001f4de", "cross": "\u274c", "stop": "\U0001f6d1", "ban": "\U0001f6ab", "loading": "\u23f3", "profile": "\U0001f464", "done": "\u2705", "otp_success": "\u2b50", "nagad": "\U0001f7e0", "bkash": "\U0001f496", "rocket": "\U0001f680", "binance": "\U0001f7e1", "live": "\U0001f7e2", "developer": "\U0001f468\u200d\U0001f4bb", "channel": "\U0001f4e2", "copy": "\U0001f4cb", "admin": "\U0001f451", "waiting": "\u23f3", "back": "\U0001f519", "leader_board": "\U0001f3c6", "custom_range": "\U0001f3af", "refer_btn": "\U0001f517", "paypal": "\U0001f4b3", "imo": "\U0001f4ac", "hi": "\U0001f44b", "off": "\U0001f6d1", "diamond": "\U0001f48e", "broadcast": "\U0001f4e2", "key": "\U0001f511", "tk": "\u09f3", "roket": "\U0001f680", "all_done": "\u2705", "yes": "\u2714\ufe0f", "no": "\u274c", "fire_love": "\u2764\ufe0f", } PREMIUM_FLAGS = { "\U0001f1fa\U0001f1f8": "5913463998522592692", "\U0001f1fa\U0001f1e6": "5911406692007941050", "\U0001f1f5\U0001f1f1": "5913550391789752571", "\U0001f1f0\U0001f1ff": "5913724621433082323", "\U0001f1e6\U0001f1ff": "5911197578640233518", "\U0001f1ea\U0001f1fa": "5911106310585193018", "\U0001f1e6\U0001f1f2": "5913272455866093666", "\U0001f1f7\U0001f1fa": "5913274246867456342", "\U0001f1fa\U0001f1ff": "5911051846104912282", "\U0001f1e9\U0001f1ea": "5911096835887337583", "\U0001f1ef\U0001f1f5": "5913293711659241040", "\U0001f1f9\U0001f1f7": "5910995113881901195", "\U0001f1e7\U0001f1fe": "5911011185649521599", "\U0001f1ec\U0001f1e7": "5913443365499703513", "\U0001f1ee\U0001f1f3": "5913754823643107921", "\U0001f1e7\U0001f1f7": "5911148568768418614", "\U0001f1fe\U0001f1ea": "5913346492512341993", "\U0001f1fb\U0001f1f3": "5913428887164949581", "\U0001f1e6\U0001f1ea": "5913726554168365343", "\U0001f1fa\U0001f1ec": "5913488939397681980", "\U0001f1f9\U0001f1f2": "5913315521503170180", "\U0001f1f9\U0001f1f3": "5911332947419468671", "\U0001f1f9\U0001f1ed": "5913617968805187987", "\U0001f1f9\U0001f1ff": "5911418949844603556", "\U0001f1f8\U0001f1ea": "5911156510162949403", "\U0001f1f8\U0001f1e9": "5911387497799094470", "\U0001f1ea\U0001f1f8": "5911193287967904547", "\U0001f1f1\U0001f1f0": "5911293163137406640", "\U0001f1ff\U0001f1e6": "5911203119148044594", "\U0001f1f8\U0001f1ec": "5911531460808051849", "\U0001f1f7\U0001f1f8": "5913592598433369871", "\U0001f1f8\U0001f1f3": "5910995302860461643", "\U0001f1f6\U0001f1e6": "5911260864983339619", "\U0001f1f5\U0001f1f9": "5911023653939581472", "\U0001f1f5\U0001f1ed": "5911268638874145162", "\U0001f1f5\U0001f1ea": "5911207993935925780", "\U0001f1f5\U0001f1f0": "5913705895375672082", "\U0001f1f4\U0001f1f2": "5913570801474343473", "\U0001f1f3\U0001f1f4": "5913617397574537046", "\U0001f1f3\U0001f1ec": "5911143844304393105", "\U0001f1f3\U0001f1ff": "5913640044937089340", "\U0001f1f3\U0001f1f1": "5913367645226275100", "\U0001f1f3\U0001f1f5": "5913496520014958723", "\U0001f1f2\U0001f1e6": "5911482111633658301", "\U0001f1f2\U0001f1f3": "5911041383564580038", "\U0001f1f2\U0001f1e9": "5913456847402045950", "\U0001f1f2\U0001f1fd": "5913687302462246518", "\U0001f1f2\U0001f1fe": "5913654360063087453", "\U0001f1f0\U0001f1ea": "5911154710571651231", "\U0001f1f1\U0001f1f9": "5911172315642597775", "\U0001f1f1\U0001f1fb": "5913738489882480243", "\U0001f1f1\U0001f1e7": "5911504273664905447", "\U0001f1ee\U0001f1e9": "5913479361620611038", "\U0001f1ee\U0001f1f7": "5911308891307643032", "\U0001f1ee\U0001f1f6": "5911382442622587735", "\U0001f1ee\U0001f1f1": "5911471936856134692", "\U0001f1ee\U0001f1f9": "5913688444923547525", "\U0001f1ed\U0001f1fa": "5913767635530551104", "\U0001f1ec\U0001f1f7": "5911210399117611448", "\U0001f1ec\U0001f1ed": "5913391155877252952", "\U0001f1ec\U0001f1ea": "5913434771270144023", "\U0001f1eb\U0001f1f7": "5913605586414473124", "\U0001f1eb\U0001f1ee": "5911041344909873378", "\U0001f1ea\U0001f1f9": "5911078333168227043", "\U0001f1ea\U0001f1ec": "5913694831539916769", "\U0001f1e9\U0001f1f0": "5911206009661034712", "\U0001f1e8\U0001f1fe": "5911023550860366409", "\U0001f1ed\U0001f1f7": "5913692684056269311", "\U0001f1e8\U0001f1f3": "5913779335021466780", "\U0001f1e7\U0001f1e9": "5911365056594973179", "\U0001f1e7\U0001f1ea": "5913529642802745141", "\U0001f1e6\U0001f1fa": "5913632326880858455", "\U0001f1e6\U0001f1f9": "5911338831524664592", "\U0001f1e6\U0001f1f7": "5913573356979884082", "\U0001f1f0\U0001f1f7": "5913371673905598425", "\U0001f1f8\U0001f1e6": "4985897134424328239", "\U0001f1e8\U0001f1f4": "5913773060074246009", "\U0001f1e8\U0001f1f1": "5911470957603592832", "\U0001f1ff\U0001f1f2": "5913564754160389778", } def get_tg_emoji(key, default_char=""): emoji_id = EMOJI_ID_MAP.get(key) fallback = default_char or FALLBACK_EMOJI_MAP.get(key, "\u2b50") if emoji_id: return f'{fallback}' return fallback def get_country_tg_flag(flag_emoji): emoji_id = PREMIUM_FLAGS.get(flag_emoji) if emoji_id: return f'{flag_emoji}' return f'{flag_emoji}' # ==================== SYSTEM DYNAMIC SETTINGS ==================== _settings_cache = None def load_settings(): global _settings_cache if _settings_cache is not None: return _settings_cache default = { "active_panel": "voltx", "voltx_api_key": os.getenv("VOLTX_API_KEY", "").strip() or CONFIG_VOLTX_API_KEY.strip(), "voltx_base_url": os.getenv("VOLTX_BASE_URL", CONFIG_VOLTX_BASE_URL), "panel_url": f"https://t.me/volt_x_lite_otp", "allowed_services": ["Instagram","Facebook","WhatsApp","TikTok","Telegram","Discord","PayPal","Imo"], "otp_group_url": "https://t.me/+31eV11IT7WQzMjI9", "channel_url": "https://t.me/MinoXofficial0", "support_username": "@support", "maintenance_mode": False, "cooldown_time": 1.0, "min_withdraw": 50.0, "otp_bonus": 0.20, "referral_bonus": 0.0, "admins": [ADMIN_ID], "owners": [ADMIN_ID], "otp_group_chat_id": None, "force_join_channel": None, "manual_services": [], } if not os.path.exists(SETTINGS_FILE): with open(SETTINGS_FILE, "w") as f: json.dump(default, f, indent=4) _settings_cache = default return default try: with open(SETTINGS_FILE, "r") as f: data = json.load(f) updated = False for k, v in default.items(): if k not in data: data[k] = v; updated = True if updated: with open(SETTINGS_FILE, "w") as f: json.dump(data, f, indent=4) _settings_cache = data return data except Exception: _settings_cache = default return default def save_settings(settings): global _settings_cache _settings_cache = settings with open(SETTINGS_FILE, "w") as f: json.dump(settings, f, indent=4) def clean_base_url(url): return str(url).strip().rstrip('/') def get_api_credentials(): settings = load_settings() env_api_key = os.getenv("VOLTX_API_KEY", "").strip() or CONFIG_VOLTX_API_KEY.strip() configured_api_key = str(settings.get("voltx_api_key", "")).strip() if not configured_api_key: configured_api_key = str(settings.get("zenex_api_key", "")).strip() configured_base = settings.get("voltx_base_url") or settings.get("zenex_base_url") or CONFIG_VOLTX_BASE_URL return (env_api_key or configured_api_key, clean_base_url(configured_base)) def get_api_urls(base_url): base = str(base_url).strip().rstrip('/') return { "getnum": f"{base}/getnum", "liveaccess": f"{base}/liveaccess", "otp": f"{base}/success-otp", } def get_api_headers(api_key): return {"mauthapi": api_key, "Accept": "application/json", "Content-Type": "application/json"} def api_json_ok(payload): if not isinstance(payload, dict): return False meta = payload.get("meta") try: return isinstance(meta, dict) and int(meta.get("code", 0) or 0) == 200 except (TypeError, ValueError): return False # ==================== WELCOME MESSAGE CONFIGURATION ==================== WELCOME_MESSAGE = """✨ 𝗪𝗘𝗟𝗖𝗢𝗠𝗘 𝗧𝗢 TEST BOT🚀 ✨ ━━━━━━━━━━━━━━━━━━━━━━ 🚀 Enjoy Premium Quality Service 🚀""" # ==================== OTP RATE CONFIGURATION ==================== OTP_RATE = 0.20 # ==================== REFERRAL / WITHDRAW CONFIGURATION ==================== REFERRAL_PRICE = 0 MIN_WITHDRAW = 50 MAX_WITHDRAW = 10000 # ==================== SUPPORT & DEVELOPER LINKS ==================== SUPPORT_LINK = "https://t.me/DEM_Support_Chat" # আপনার সাপোর্ট লিংক দিন DEVELOPER_LINK = "https://t.me/Davil_Raju" # আপনার ডেভেলপার লিংক দিন request_queue = asyncio.Queue() MAX_WORKERS = max(1, int(os.getenv("MAX_WORKERS", "20"))) client_async = httpx.AsyncClient( http2=True, timeout=httpx.Timeout(8.0, connect=2.0, read=5.0), limits=httpx.Limits(max_connections=100, max_keepalive_connections=20), trust_env=False, ) active_numbers = {} last_range = {} CHECK_INTERVAL = 1.5 number_assignment_lock = asyncio.Lock() # ==================== VOLTX RANGES CACHE ==================== _ranges_cache = {"data": None, "updated_at": 0.0, "fetching": False} def get_app_emoji_id(app_name): n = app_name.lower() # Ordered: longer/more-specific names first to avoid partial-match errors SERVICE_EMOJI_MAP = [ ("whatsapp business", "5336814486701514414"), ("whatsapp", "5334759662677957452"), ("telegram", "5337010556253543833"), ("facebook", "5334807341109908955"), ("instagram", "5334868205091459431"), ("amazon prime", "6111801057061374810"), ("amazon", "4995019580536524226"), ("imo", "5337155807752524558"), ("apple", "5334637951894722661"), ("google", "5335010201005231986"), ("microsoft", "5334880948259427772"), ("teams", "5334590977837403844"), ("tiktok", "5339213256001102461"), ("bkash", "5348469219761626211"), ("bybit", "5348372939479751825"), ("binance", "5348212415077064131"), ("melbet", "5337102391244263212"), ("snapchat", "5359441366554255082"), ("uber", "5298715455316303708"), ("paypal", "5776103539872896061"), ("discord", "5116246243646898866"), ("viber", "5463060437572528782"), ("linkedin", "6224222994265279792"), ("line", "5399818044866327279"), ("wechat", "5782757599560602950"), ("twitter", "5215726959056662534"), ("reddit", "4992421103847604984"), ("pinterest", "5346103513120258857"), ("twitch", "5233333563306301418"), ("zoom", "5881799193219043268"), ("signal", "5293998404404272267"), ("slack", "4994972469040251302"), ("skype", "4992613535562334989"), ("netflix", "6255738712664050133"), ("spotify", "5411392711146095115"), ("hoichoi", "6104822598493801746"), ("daraz", "5336879280578138635"), ("foodpanda", "5336879280578138635"), ("pathao", "5336879280578138635"), ("aliexpress", "5336879280578138635"), ("shopee", "5336879280578138635"), ("payoneer", "5336879280578138635"), ("wise", "5336879280578138635"), ("chatgpt", "5296516998996445955"), ("notion", "5336879280578138635"), ("github", "5417836094098007862"), ("canva", "5111661409008092227"), ("figma", "5336879280578138635"), ("upwork", "5336879280578138635"), ("fiverr", "5336879280578138635"), ("yahoo", "5336879280578138635"), ("dropbox", "5336879280578138635"), ("coursera", "5336879280578138635"), ("duolingo", "5336879280578138635"), ("rocket", "5346042941196507141"), ] for k, v in SERVICE_EMOJI_MAP: if k in n: return v return "5861680977994060034" def get_platform_icon(platform_name): return f'📞' def get_clean_app_name(raw): n = raw.lower().strip() for k, v in [("facebook","Facebook"),("instagram","Instagram"),("whatsapp","WhatsApp"), ("tiktok","TikTok"),("paypal","PayPal"),("telegram","Telegram"), ("discord","Discord"),("imo","Imo")]: if k in n: return v return raw.strip().capitalize() def make_bold_text(text): out = [] for ch in str(text): o = ord(ch) if 65 <= o <= 90: out.append(chr(o - 65 + 0x1D5D4)) elif 97 <= o <= 122: out.append(chr(o - 97 + 0x1D5EE)) elif 48 <= o <= 57: out.append(chr(o - 48 + 0x1D7EC)) else: out.append(ch) return "".join(out) async def fetch_top55_ranges_by_app(): settings = load_settings() api_key, base_url = get_api_credentials() if not api_key: return None, "VoltxSMS API key is not configured." allowed = {s.lower() for s in settings.get("allowed_services", ["Instagram","Facebook","WhatsApp","TikTok","Telegram","Discord","PayPal","Imo"])} urls = get_api_urls(base_url) headers = get_api_headers(api_key) for attempt in range(2): try: r = await client_async.get(urls["liveaccess"], headers=headers, timeout=httpx.Timeout(5.0, connect=1.5, read=4.0)) if not 200 <= r.status_code < 300: if attempt == 0: await asyncio.sleep(0.2); continue return None, f"VoltxSMS HTTP {r.status_code}." payload = r.json() if not api_json_ok(payload): meta = payload.get("meta", {}) if isinstance(payload, dict) else {} return None, str(payload.get("message") or meta.get("status") or "VoltxSMS API error.") data = payload.get("data") or {} services = data.get("services") if isinstance(data, dict) else None if not isinstance(services, list): return {}, None top = {} for obj in services: if not isinstance(obj, dict): continue service = obj.get("sid") or obj.get("service") or obj.get("app") or "Unknown" clean = get_clean_app_name(str(service)) if clean.lower() not in allowed and clean != "Unknown": continue ranges = obj.get("ranges") or [] if not isinstance(ranges, list): continue top.setdefault(clean, {"icon": get_platform_icon(clean), "ranges": []}) for rng in ranges: rng = str(rng).strip().upper() if rng and re.search(r"\d", rng) and rng not in top[clean]["ranges"]: top[clean]["ranges"].append(rng) top = {k:v for k,v in top.items() if v["ranges"]} return dict(sorted(top.items(), key=lambda x: len(x[1]["ranges"]), reverse=True)), None except (httpx.TimeoutException, httpx.NetworkError, ValueError, TypeError) as exc: if attempt == 0: await asyncio.sleep(0.2) else: return None, f"VoltxSMS request failed: {exc}" except Exception as exc: return None, f"VoltxSMS error: {exc}" return None, "VoltxSMS server unreachable." def extract_active_ranges(payload): """Read active ranges from all supported API response shapes.""" if isinstance(payload, list): return payload if not isinstance(payload, dict): return None for key in ( "active_ranges", "activeRanges", "available_ranges", "availableRanges", "ranges", "range_list", ): value = payload.get(key) if isinstance(value, list): return value # Newer responses may wrap the same object in data/result/response. for key in ("data", "result", "response", "payload"): value = payload.get(key) if isinstance(value, (dict, list)): nested = extract_active_ranges(value) if nested is not None: return nested # A few versions return {"WhatsApp": ["880XXX", ...]}. grouped = [] for service, values in payload.items(): if not isinstance(values, list): continue for value in values: if isinstance(value, dict): item = dict(value) item.setdefault("service", service) else: item = {"service": service, "range": value} grouped.append(item) return grouped if grouped else None def build_app_buttons_from_cache(top): btns, row, ci = [], [], 0 clrs = ["primary"] for app_name in top: row.append(InlineKeyboardButton(make_bold_text(app_name), callback_data=f"sel_app_{app_name}", api_kwargs={"icon_custom_emoji_id": get_app_emoji_id(app_name), "style": clrs[ci % len(clrs)]})) ci += 1 if len(row) == 2: btns.append(row); row = [] if row: btns.append(row) return btns async def _bg_refresh_ranges(): global _ranges_cache while True: try: if not _ranges_cache["fetching"]: _ranges_cache["fetching"] = True try: data, _ = await fetch_top55_ranges_by_app() if data: _ranges_cache["data"] = data _ranges_cache["updated_at"] = time.monotonic() except Exception: pass finally: _ranges_cache["fetching"] = False except Exception: pass await asyncio.sleep(200) # ==================== CHECK IF USER IS ADMIN ==================== def is_admin(user_id): try: user_id = int(user_id) except (TypeError, ValueError): return False return user_id in get_admin_ids() def get_admin_ids(): """Return valid admin IDs, even if settings.json stored them as strings.""" candidates = [ADMIN_ID, CONFIG_ADMIN_ID] try: configured = load_settings().get("admins", []) if isinstance(configured, list): candidates.extend(configured) except Exception as exc: print(f"Support admin settings could not be loaded: {exc}") admin_ids = [] for candidate in candidates: try: admin_id = int(candidate) except (TypeError, ValueError): continue if admin_id > 0 and admin_id not in admin_ids: admin_ids.append(admin_id) return admin_ids def get_min_withdraw(): """Read the current minimum withdrawal from persisted bot settings.""" try: return max(0.0, float(load_settings().get("min_withdraw", MIN_WITHDRAW))) except (TypeError, ValueError): return float(MIN_WITHDRAW) # ==================== WITHDRAW DATA FUNCTIONS ==================== def load_withdraw_requests(): if not os.path.exists(WITHDRAW_DATA_FILE): with open(WITHDRAW_DATA_FILE, "w") as f: json.dump({}, f) return {} try: with open(WITHDRAW_DATA_FILE, "r") as f: return json.load(f) except: return {} def save_withdraw_requests(data): with open(WITHDRAW_DATA_FILE, "w") as f: json.dump(data, f, indent=4) def generate_payment_id(): return ''.join(random.choices(string.ascii_lowercase + string.digits, k=20)) # ==================== BANNED USERS FUNCTIONS ==================== def load_banned_users(): if not os.path.exists(BANNED_USERS_FILE): with open(BANNED_USERS_FILE, "w") as f: json.dump([], f) return [] try: with open(BANNED_USERS_FILE, "r") as f: return json.load(f) except: return [] def save_banned_users(banned_list): with open(BANNED_USERS_FILE, "w") as f: json.dump(banned_list, f, indent=4) def is_user_banned(uid): banned_list = load_banned_users() return str(uid) in banned_list def ban_user(uid): banned_list = load_banned_users() uid_str = str(uid) if uid_str not in banned_list: banned_list.append(uid_str) save_banned_users(banned_list) return True return False def unban_user(uid): banned_list = load_banned_users() uid_str = str(uid) if uid_str in banned_list: banned_list.remove(uid_str) save_banned_users(banned_list) return True return False # ==================== REFERRAL DATA FUNCTIONS ==================== def load_referral_data(): if not os.path.exists(REFERRAL_DATA_FILE): with open(REFERRAL_DATA_FILE, "w") as f: json.dump({}, f) return {} try: with open(REFERRAL_DATA_FILE, "r") as f: return json.load(f) except: return {} def save_referral_data(data): with open(REFERRAL_DATA_FILE, "w") as f: json.dump(data, f, indent=4) def update_referral_count(uid, count): referral_data = load_referral_data() uid_str = str(uid) if uid_str not in referral_data: referral_data[uid_str] = {"referral_count": 0} referral_data[uid_str]["referral_count"] = count save_referral_data(referral_data) def get_referral_count(uid): referral_data = load_referral_data() uid_str = str(uid) return referral_data.get(uid_str, {}).get("referral_count", 0) # ==================== DATA RANGE FILE ==================== def load_range_db(): if not os.path.exists(DATA_RANGE_FILE): return {} try: with open(DATA_RANGE_FILE, "r") as f: return json.load(f) except: return {} def save_range_db(data): with open(DATA_RANGE_FILE, "w") as f: json.dump(data, f, indent=4) def save_number_range_info(uid, number, range_text): db = load_range_db() flag, name = get_country_info(number) db[normalize_number(number)] = { "user_id": str(uid), "number": f"+{normalize_number(number)}", "range": range_text, "country": f"{flag} {name}" } save_range_db(db) # ==================== COUNTRY MAPPING SECTION ==================== def get_country_info(number): number = str(number).strip() country_map = { "2376": ("🇨🇲", "Cameroon"), "2250": ("🇨🇮", "Ivory Coast"), "2613": ("🇲🇬", "Madagascar"), "4077": ("🇷🇴", "Romania"), "237": ("🇨🇲", "Cameroon"), "225": ("🇨🇮", "Ivory Coast"), "261": ("🇲🇬", "Madagascar"), "20": ("🇪🇬", "Egypt"), "27": ("🇿🇦", "South Africa"), "234": ("🇳🇬", "Nigeria"), "254": ("🇰🇪", "Kenya"), "233": ("🇬🇭", "Ghana"), "212": ("🇲🇦", "Morocco"), "213": ("🇩🇿", "Algeria"), "216": ("🇹🇳", "Tunisia"), "218": ("🇱🇾", "Libya"), "249": ("🇸🇩", "Sudan"), "251": ("🇪🇹", "Ethiopia"), "252": ("🇸🇴", "Somalia"), "253": ("🇩🇯", "Djibouti"), "255": ("🇹🇿", "Tanzania"), "256": ("🇺🇬", "Uganda"), "257": ("🇧🇮", "Burundi"), "258": ("🇲🇿", "Mozambique"), "260": ("🇿🇲", "Zambia"), "263": ("🇿🇼", "Zimbabwe"), "264": ("🇳🇦", "Namibia"), "265": ("🇲🇼", "Malawi"), "266": ("🇱🇸", "Lesotho"), "267": ("🇧🇼", "Botswana"), "268": ("🇸🇿", "Swaziland"), "269": ("🇰🇲", "Comoros"), "220": ("🇬🇲", "Gambia"), "221": ("🇸🇳", "Senegal"), "222": ("🇲🇷", "Mauritania"), "223": ("🇲🇱", "Mali"), "224": ("🇬🇳", "Guinea"), "226": ("🇧🇫", "Burkina Faso"), "227": ("🇳🇪", "Niger"), "228": ("🇹🇬", "Togo"), "229": ("🇧🇯", "Benin"), "230": ("🇲🇺", "Mauritius"), "231": ("🇱🇷", "Liberia"), "232": ("🇸🇱", "Sierra Leone"), "235": ("🇹🇩", "Chad"), "236": ("🇨🇫", "Central African Republic"), "238": ("🇨🇻", "Cape Verde"), "239": ("🇸🇹", "Sao Tome and Principe"), "240": ("🇬🇶", "Equatorial Guinea"), "241": ("🇬🇦", "Gabon"), "242": ("🇨🇬", "Congo"), "243": ("🇨🇩", "DR Congo"), "244": ("🇦🇴", "Angola"), "245": ("🇬🇼", "Guinea-Bissau"), "247": ("🇸🇭", "Saint Helena"), "248": ("🇸🇨", "Seychelles"), "250": ("🇷🇼", "Rwanda"), "290": ("🇸🇭", "Saint Helena"), "291": ("🇪🇷", "Eritrea"), "40": ("🇷🇴", "Romania"), "44": ("🇬🇧", "United Kingdom"), "33": ("🇫🇷", "France"), "49": ("🇩🇪", "Germany"), "39": ("🇮🇹", "Italy"), "34": ("🇪🇸", "Spain"), "31": ("🇳🇱", "Netherlands"), "32": ("🇧🇪", "Belgium"), "41": ("🇨🇭", "Switzerland"), "43": ("🇦🇹", "Austria"), "46": ("🇸🇪", "Sweden"), "47": ("🇳🇴", "Norway"), "45": ("🇩🇰", "Denmark"), "358": ("🇫🇮", "Finland"), "351": ("🇵🇹", "Portugal"), "353": ("🇮🇪", "Ireland"), "36": ("🇭🇺", "Hungary"), "48": ("🇵🇱", "Poland"), "380": ("🇺🇦", "Ukraine"), "370": ("🇱🇹", "Lithuania"), "371": ("🇱🇻", "Latvia"), "372": ("🇪🇪", "Estonia"), "373": ("🇲🇩", "Moldova"), "374": ("🇦🇲", "Armenia"), "375": ("🇧🇾", "Belarus"), "376": ("🇦🇩", "Andorra"), "377": ("🇲🇨", "Monaco"), "381": ("🇷🇸", "Serbia"), "382": ("🇲🇪", "Montenegro"), "385": ("🇭🇷", "Croatia"), "386": ("🇸🇮", "Slovenia"), "387": ("🇧🇦", "Bosnia and Herzegovina"), "389": ("🇲🇰", "North Macedonia"), "350": ("🇬🇮", "Gibraltar"), "352": ("🇱🇺", "Luxembourg"), "354": ("🇮🇸", "Iceland"), "355": ("🇦🇱", "Albania"), "356": ("🇲🇹", "Malta"), "357": ("🇨🇾", "Cyprus"), "359": ("🇧🇬", "Bulgaria"), "421": ("🇸🇰", "Slovakia"), "420": ("🇨🇿", "Czech Republic"), "298": ("🇫🇴", "Faroe Islands"), "299": ("🇬🇱", "Greenland"), "1": ("🇺🇸", "United States"), "7": ("🇷🇺", "Russia"), "91": ("🇮🇳", "India"), "92": ("🇵🇰", "Pakistan"), "880": ("🇧🇩", "Bangladesh"), "86": ("🇨🇳", "China"), "81": ("🇯🇵", "Japan"), "82": ("🇰🇷", "South Korea"), "84": ("🇻🇳", "Vietnam"), "66": ("🇹🇭", "Thailand"), "62": ("🇮🇩", "Indonesia"), "60": ("🇲🇾", "Malaysia"), "65": ("🇸🇬", "Singapore"), "63": ("🇵🇭", "Philippines"), "95": ("🇲🇲", "Myanmar"), "94": ("🇱🇰", "Sri Lanka"), "977": ("🇳🇵", "Nepal"), "93": ("🇦🇫", "Afghanistan"), "98": ("🇮🇷", "Iran"), "90": ("🇹🇷", "Turkey"), "964": ("🇮🇶", "Iraq"), "963": ("🇸🇾", "Syria"), "961": ("🇱🇧", "Lebanon"), "962": ("🇯🇴", "Jordan"), "965": ("🇰🇼", "Kuwait"), "966": ("🇸🇦", "Saudi Arabia"), "967": ("🇾🇲", "Yemen"), "968": ("🇴🇲", "Oman"), "971": ("🇦🇪", "United Arab Emirates"), "972": ("🇮🇱", "Israel"), "973": ("🇧🇭", "Bahrain"), "974": ("🇶🇦", "Qatar"), "994": ("🇦🇿", "Azerbaijan"), "995": ("🇬🇪", "Georgia"), "996": ("🇰🇬", "Kyrgyzstan"), "992": ("🇹🇯", "Tajikistan"), "993": ("🇹🇲", "Turkmenistan"), "998": ("🇺🇿", "Uzbekistan"), "855": ("🇰🇭", "Cambodia"), "856": ("🇱🇦", "Laos"), "976": ("🇲🇳", "Mongolia"), "850": ("🇰🇵", "North Korea"), "55": ("🇧🇷", "Brazil"), "52": ("🇲🇽", "Mexico"), "54": ("🇦🇷", "Argentina"), "57": ("🇨🇴", "Colombia"), "51": ("🇵🇪", "Peru"), "58": ("🇻🇪", "Venezuela"), "56": ("🇨🇱", "Chile"), "593": ("🇪🇨", "Ecuador"), "591": ("🇧🇴", "Bolivia"), "595": ("🇵🇾", "Paraguay"), "598": ("🇺🇾", "Uruguay"), "502": ("🇬🇹", "Guatemala"), "503": ("🇸🇻", "El Salvador"), "504": ("🇭🇳", "Honduras"), "506": ("🇨🇷", "Costa Rica"), "507": ("🇵🇦", "Panama"), "509": ("🇭🇹", "Haiti"), "501": ("🇧🇿", "Belize"), "61": ("🇦🇺", "Australia"), "64": ("🇳🇿", "New Zealand"), "675": ("🇵🇬", "Papua New Guinea"), "679": ("🇫🇯", "Fiji"), "1246": ("🇧🇧", "Barbados"), "1876": ("🇯🇲", "Jamaica"), "53": ("🇨🇺", "Cuba"), "592": ("🇬🇾", "Guyana"), } clean_num = str(number).replace('+', '').replace(' ', '').replace('-', '').strip() sorted_prefixes = sorted(country_map.keys(), key=len, reverse=True) for prefix in sorted_prefixes: if clean_num.startswith(prefix): return country_map[prefix] return ("🌍", "Unknown") # ==================== SERVICE DETECTION SECTION ==================== def detect_service(full_sms): if not full_sms: return "SMS SERVICE" sms_lower = full_sms.lower() service_keywords = { "facebook": "FACEBOOK", "fb": "FACEBOOK", "instagram": "INSTAGRAM", "insta": "INSTAGRAM", "tiktok": "TIKTOK", "twitter": "TWITTER", "x.com": "TWITTER", "snapchat": "SNAPCHAT", "snap": "SNAPCHAT", "whatsapp": "WHATSAPP", "telegram": "TELEGRAM", "discord": "DISCORD", "messenger": "MESSENGER", "linkedin": "LINKEDIN", "google": "GOOGLE", "gmail": "GOOGLE", "amazon": "AMAZON", "microsoft": "MICROSOFT", "outlook": "MICROSOFT", "yahoo": "YAHOO", "paypal": "PAYPAL", "binance": "BINANCE", "coinbase": "COINBASE", "spotify": "SPOTIFY", "netflix": "NETFLIX", "uber": "UBER", "apple": "APPLE", "icloud": "APPLE", "bkash": "BKASH", "nagad": "NAGAD", "stripe": "STRIPE", "line": "LINE", "wechat": "WECHAT", "viber": "VIBER", "signal": "SIGNAL", "pubg": "PUBG", "free fire": "FREE FIRE", } for keyword, service_name in sorted(service_keywords.items(), key=lambda x: len(x[0]), reverse=True): if keyword in sms_lower: return service_name return "SMS SERVICE" # ==================== KEYBOARDS SECTION ==================== # Main user menu keyboard from telegram import KeyboardButton, ReplyKeyboardMarkup def make_reply_btn(text, emoji_id=None, style=None): api_kwargs = {} if emoji_id: api_kwargs['icon_custom_emoji_id'] = str(emoji_id) if style: api_kwargs['style'] = style return KeyboardButton( text=text, api_kwargs=api_kwargs if api_kwargs else None ) def main_keyboard(user_id): keyboard = [ [ make_reply_btn("GET NUMBER", emoji_id="5228843986747147814", style="primary"), make_reply_btn("GET 2FA", emoji_id="5296369303661067030", style="primary") ], [ make_reply_btn("PROFILE", emoji_id="5422444280473998663", style="primary"), make_reply_btn("LEADERBOARD", emoji_id="5228875876879318811", style="primary") ], [ make_reply_btn("SUPPORT", emoji_id="5267294466716244344", style="primary") ], ] if is_admin(user_id): keyboard.append([ make_reply_btn("ADMIN PANEL", emoji_id="5350396951407895212", style="primary") ]) return ReplyKeyboardMarkup(keyboard, resize_keyboard=True) def account_keyboard(): """Keyboard for account-related actions grouped under one main-menu button.""" keyboard = [ [ make_reply_btn("BALANCE", emoji_id="6233367447789899509", style="primary"), make_reply_btn("REFER AND EARN", emoji_id="5420396762189831222", style="primary") ], [ make_reply_btn("VIEW PROFILE", emoji_id="5422444280473998663", style="primary") ,make_reply_btn("BACK TO MAIN", emoji_id="5267490665117275176", style="primary") ], ] return ReplyKeyboardMarkup(keyboard, resize_keyboard=True) def cancel_keyboard(): keyboard = [[make_reply_btn("CANCEL", emoji_id="5420130255174145507", style="primary")]] return ReplyKeyboardMarkup(keyboard, resize_keyboard=True) def admin_main_keyboard(): keyboard = [ [make_reply_btn("USER MANAGEMENT", emoji_id="5193063022226086560", style="primary"), make_reply_btn("SYSTEM CONFIGURATION", emoji_id="5341715473882955310", style="primary")], [make_reply_btn("BOT SETTINGS", emoji_id="5282843764451195532", style="primary"), make_reply_btn("SERVICE MANAGEMENT", emoji_id="5375338737028841420", style="primary")], [make_reply_btn("WITHDRAWAL MANAGEMENT", emoji_id="6233367447789899509", style="primary"), make_reply_btn("SUPPORT CHAT", emoji_id="5267294466716244344", style="primary")], [make_reply_btn("⏳ PENDING WITHDRAWALS", emoji_id="6217721388736712699", style="primary")], [make_reply_btn("BACK TO MAIN", emoji_id="5267490665117275176", style="primary")] ] return ReplyKeyboardMarkup(keyboard, resize_keyboard=True) def user_management_keyboard(): keyboard = [ [make_reply_btn("SEND MESSAGE TO ALL USERS", emoji_id="5251671733630431622", style="primary"), make_reply_btn("ALL USER ID", emoji_id="5352861489541714456", style="primary")], [make_reply_btn("BAN USER LIST", emoji_id="5420323339723881652", style="primary"), make_reply_btn("ALL USER BALANCE", emoji_id="6233367447789899509", style="primary")], [make_reply_btn("BACK TO ADMIN", emoji_id="5267490665117275176", style="primary")] ] return ReplyKeyboardMarkup(keyboard, resize_keyboard=True) def system_config_keyboard(): keyboard = [ [make_reply_btn("TODAY ALL STATUS", emoji_id="5231200819986047254", style="primary"), make_reply_btn("USER STATUS CHECK", emoji_id="5352861489541714456", style="primary")], [make_reply_btn("BAN USER", emoji_id="5420323339723881652", style="primary"), make_reply_btn("UNBAN USER", emoji_id="5875017993909440887", style="primary")], [make_reply_btn("BAN USER LIST", emoji_id="5956074558044770726", style="primary"), make_reply_btn("REMOVE BALANCE", emoji_id="5244837092042750681", style="primary")], [make_reply_btn("ADD BALANCE", emoji_id="5397916757333654639", style="primary"), make_reply_btn("BACK TO ADMIN", emoji_id="5267490665117275176", style="primary")] ] return ReplyKeyboardMarkup(keyboard, resize_keyboard=True) def bot_settings_keyboard(): keyboard = [ [make_reply_btn("ADD ADMIN", emoji_id="5397916757333654639", style="primary"), make_reply_btn("REMOVE ADMIN", emoji_id="5244837092042750681", style="primary")], [make_reply_btn("SET OTP GROUP LINK", emoji_id="5253742260054409879", style="primary"), make_reply_btn("SET FORCE CHANNEL", emoji_id="5282843764451195532", style="primary")], [make_reply_btn("SET OTP CHAT ID", emoji_id="5231200819986047254", style="primary"), make_reply_btn("VOLTX CONFIG", emoji_id="5350396951407895212", style="primary")], [make_reply_btn("BACK TO ADMIN", emoji_id="5267490665117275176", style="primary")] ] return ReplyKeyboardMarkup(keyboard, resize_keyboard=True) def voltx_config_keyboard(): keyboard = [ [make_reply_btn("SET API KEY", emoji_id="5397916757333654639", style="primary"), make_reply_btn("SET BASE URL", emoji_id="5253742260054409879", style="primary")], [make_reply_btn("SET ALLOWED SERVICES", emoji_id="5341715473882955310", style="primary"), make_reply_btn("VIEW VOLTX CONFIG", emoji_id="5231200819986047254", style="primary")], [make_reply_btn("BACK TO BOT SETTINGS", emoji_id="5267490665117275176", style="primary")] ] return ReplyKeyboardMarkup(keyboard, resize_keyboard=True) def service_management_keyboard(): keyboard = [ [make_reply_btn("ADD SERVICE", emoji_id="5397916757333654639", style="primary"), make_reply_btn("REMOVE SERVICE", emoji_id="5244837092042750681", style="primary")], [make_reply_btn("LIST SERVICES", emoji_id="5352861489541714456", style="primary"), make_reply_btn("BACK TO ADMIN", emoji_id="5267490665117275176", style="primary")] ] return ReplyKeyboardMarkup(keyboard, resize_keyboard=True) def withdrawal_management_keyboard(): keyboard = [ [ make_reply_btn("PENDING WITHDRAWALS", emoji_id="6217721388736712699", style="primary"), make_reply_btn("SET MINIMUM WITHDRAW", emoji_id="5397916757333654639", style="primary"), ], [ make_reply_btn("BACK TO ADMIN", emoji_id="5267490665117275176", style="primary"), ], ] return ReplyKeyboardMarkup(keyboard, resize_keyboard=True) def withdraw_method_keyboard(): keyboard = ReplyKeyboardMarkup([ [make_reply_btn("BKASH", emoji_id="5348469219761626211", style="primary"), make_reply_btn("NAGAD", emoji_id="5352985330628730418", style="primary")], [make_reply_btn("ROCKET", emoji_id="5346042941196507141", style="primary"), make_reply_btn("BINANCE",emoji_id="5348212415077064131", style="primary")], [make_reply_btn("CANCEL", emoji_id="5420130255174145507", style="primary")] ], resize_keyboard=True) return keyboard # ==================== HELPER FUNCTIONS SECTION ==================== def format_balance(balance): return f"{balance:.2f}" def extract_otp(text): if not text or text == "No Content": return "N/A" spaced_otp = re.search(r'\b(\d{3}\s\d{3})\b', text) if spaced_otp: return spaced_otp.group(1).replace(" ", "") match = re.search(r'\b(\d{4,8})\b', text) return match.group(1) if match else "N/A" def normalize_number(num): return re.sub(r'\D', '', str(num)) def mask_number(num): if len(num) > 6: return f"{num[:4]}****{num[-6:]}" return num def get_date_reset_time(): now = datetime.now() today_midnight = datetime(now.year, now.month, now.day, 0, 0, 0) return today_midnight def is_valid_bangladesh_number(number): number = re.sub(r'\D', '', str(number)) return len(number) == 11 and number.startswith('01') def is_range_request(param): return 'X' in param.upper() def is_referral_request(param): return param.isdigit() # ==================== DATABASE FUNCTIONS SECTION ==================== def load_data(filename=USER_DATA_FILE): if not os.path.exists(filename): with open(filename, "w") as f: json.dump({}, f) return {} try: with open(filename, "r") as f: return json.load(f) except: return {} def save_data(data, filename=USER_DATA_FILE): with open(filename, "w") as f: json.dump(data, f, indent=4) def get_user(uid): uid = str(uid) data = load_data() if uid not in data: data[uid] = {"user_id": uid, "balance": 0.0, "total_numbers": 0, "referral_count": 0} save_data(data) return data[uid] async def update_db_balance(uid, amount): uid = str(uid) data = load_data() if uid in data: data[uid]["balance"] = round(data[uid].get("balance", 0.0) + amount, 2) save_data(data) return data[uid]["balance"] return 0.0 def get_all_users(): data = load_data(USER_DATA_FILE) return list(data.keys()) if data else [] def user_exists(uid): data = load_data(USER_DATA_FILE) return str(uid) in data # ==================== STATS FUNCTIONS SECTION ==================== def load_stats(): if not os.path.exists(STATS_FILE): with open(STATS_FILE, "w") as f: json.dump({}, f) return {} try: with open(STATS_FILE, "r") as f: return json.load(f) except: return {} def save_stats(stats): with open(STATS_FILE, "w") as f: json.dump(stats, f, indent=4) def add_number_taken(uid, count=1): uid = str(uid) stats = load_stats() if uid not in stats: stats[uid] = {"numbers_taken": [], "otps_received": []} now = datetime.now().isoformat() for _ in range(count): stats[uid]["numbers_taken"].append(now) log_global_activity(uid, "NUMBER_TAKEN", {"count": count}) save_stats(stats) def add_otp_received(uid): uid = str(uid) stats = load_stats() if uid not in stats: stats[uid] = {"numbers_taken": [], "otps_received": []} stats[uid]["otps_received"].append(datetime.now().isoformat()) save_stats(stats) def get_user_stats(uid): uid = str(uid) stats = load_stats() user_stats = stats.get(uid, {"numbers_taken": [], "otps_received": []}) now = datetime.now() today_midnight = get_date_reset_time() last_24h = now - timedelta(hours=24) last_7d = now - timedelta(days=7) numbers_taken = user_stats.get("numbers_taken", []) otps_received = user_stats.get("otps_received", []) today_numbers = sum(1 for t in numbers_taken if datetime.fromisoformat(t) >= today_midnight) today_otps = sum(1 for t in otps_received if datetime.fromisoformat(t) >= today_midnight) last24h_numbers = sum(1 for t in numbers_taken if datetime.fromisoformat(t) > last_24h) last24h_otps = sum(1 for t in otps_received if datetime.fromisoformat(t) > last_24h) last7d_numbers = sum(1 for t in numbers_taken if datetime.fromisoformat(t) > last_7d) last7d_otps = sum(1 for t in otps_received if datetime.fromisoformat(t) > last_7d) total_numbers = len(numbers_taken) total_otps = len(otps_received) return { "total_numbers": total_numbers, "total_otps": total_otps, "today_numbers": today_numbers, "today_otps": today_otps, "last24h_numbers": last24h_numbers, "last24h_otps": last24h_otps, "last7d_numbers": last7d_numbers, "last7d_otps": last7d_otps } def log_global_activity(uid, action, details): if not os.path.exists(ACTIVITY_LOGS_FILE): with open(ACTIVITY_LOGS_FILE, "w") as f: json.dump([], f) try: with open(ACTIVITY_LOGS_FILE, "r") as f: logs = json.load(f) except: logs = [] now = datetime.now() logs.append({ "uid": str(uid), "action": action, "details": details, "timestamp": now.isoformat(), "date": now.strftime("%d/%m/%Y"), "time": now.strftime("%H:%M:%S") }) with open(ACTIVITY_LOGS_FILE, "w") as f: json.dump(logs, f, indent=4) def get_global_system_stats(): stats = load_stats() now = datetime.now() today_midnight = datetime(now.year, now.month, now.day) last_7d = now - timedelta(days=7) total_n = total_o = today_n = today_o = seven_n = seven_o = 0 for uid in stats: u = stats[uid] n_list = u.get("numbers_taken", []) o_list = u.get("otps_received", []) total_n += len(n_list) total_o += len(o_list) for t in n_list: dt = datetime.fromisoformat(t) if dt >= today_midnight: today_n += 1 if dt >= last_7d: seven_n += 1 for t in o_list: dt = datetime.fromisoformat(t) if dt >= today_midnight: today_o += 1 if dt >= last_7d: seven_o += 1 return today_n, today_o, seven_n, seven_o, total_n, total_o # ==================== LEADERBOARD SECTION ==================== async def leaderboard_command(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id if is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return stats_data = load_stats() today_midnight = get_date_reset_time() user_data_all = load_data(USER_DATA_FILE) user_today_counts = [] for uid_str, user_stats in stats_data.items(): otps_received = user_stats.get("otps_received", []) today_count = 0 for ts in otps_received: try: dt = datetime.fromisoformat(ts) if dt >= today_midnight: today_count += 1 except: continue if today_count > 0: name = user_data_all.get(uid_str, {}).get("full_name") if not name: name = user_data_all.get(uid_str, {}).get("username") if not name: name = f"User {uid_str}" user_today_counts.append((uid_str, today_count, html.escape(name))) user_today_counts.sort(key=lambda x: x[1], reverse=True) top10 = user_today_counts[:10] if not top10: msg = ( "🏆 TOP 10 OTP LEADERBOARD 🏆\n" "━━━━━━━━━━━━━━━━━━━━\n\n" "❌ আজ পর্যন্ত কেউ OTP পায়নি।\n" ) else: msg = ( "🏆 TOP 10 OTP RECEIVERS (TODAY) 🏆\n" "━━━━━━━━━━━━━━━━━━━━\n\n" ) for idx, (uid_str, count, name) in enumerate(top10, 1): if idx == 1: medal = "🥇" elif idx == 2: medal = "🥈" elif idx == 3: medal = "🥉" else: medal = f"{idx}️⃣" msg += f"{medal} {name}\n 🔑 {count} OTPs\n\n" msg += ( "━━━━━━━━━━━━━━━━━━━━\n" "📊 প্রতিদিন রাত ১২টায় রিসেট হয়" ) await update.message.reply_text(msg, parse_mode="HTML", reply_markup=main_keyboard(uid)) # ==================== 2FA CODE GENERATOR SECTION ==================== def generate_2fa_code(secret_key): try: clean_secret = secret_key.replace(" ", "").upper().strip() key = base64.b32decode(clean_secret, casefold=True) t = int(time.time()) // 30 msg_bytes = struct.pack(">Q", t) h = hmac.new(key, msg_bytes, hashlib.sha1).digest() o = h[-1] & 0xf code = (struct.unpack(">I", h[o:o+4])[0] & 0x7fffffff) % 1_000_000 return f"{code:06d}", clean_secret except: return None, None async def get_2fa_code(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id if is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return context.user_data["mode"] = "get_2fa" await update.message.reply_text( "⚡ GET 2FA CODE ⚡\n\n" "
🔑 ENTER YOUR 2FA SECRET KEY:
", parse_mode="HTML" ) async def process_2fa_key(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id secret_key = update.message.text.strip() context.user_data["mode"] = None otp_code, clean_key = generate_2fa_code(secret_key) if otp_code is None: await update.message.reply_text( "❌ INVALID 2FA SECRET KEY\n\n⚠️ Please send a valid base32 key.", parse_mode="HTML", reply_markup=main_keyboard(uid) ) return now = datetime.now() final_msg = ( "✅ 2FA CODE GENERATED!\n\n" f"
🔑 KEY: {clean_key}
\n" f"
🔢 CODE: {otp_code}
\n" f"
⏳ EXPIRES IN: 30 SECONDS
\n" f"📅 {now.strftime('%d %B, %Y')} | {now.strftime('%I:%M %p')}" ) await update.message.reply_text(final_msg, parse_mode="HTML") def build_manual_service_buttons(): """Build inline buttons for manually added services.""" s = load_settings() manual = s.get("manual_services", []) btns = [] clrs = ["primary"] for i, svc in enumerate(manual): btns.append(InlineKeyboardButton( make_bold_text(svc['name']), callback_data=f"manual_svc_{i}", api_kwargs={"icon_custom_emoji_id": get_app_emoji_id(svc['name']), "style": clrs[i % len(clrs)]} )) rows = [btns[j:j+2] for j in range(0, len(btns), 2)] return rows async def show_app_selection(update, context): uid = update.effective_user.id if is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return context.user_data.pop("top_ranges_by_app", None) # Build combined keyboard: Zenex apps + manual services async def _build_full_keyboard(top): voltx_rows = build_app_buttons_from_cache(top) manual_rows = build_manual_service_buttons() all_rows = voltx_rows + manual_rows if not all_rows: all_rows = [] all_rows.append([InlineKeyboardButton("⚙️ CUSTOM RANGE", callback_data="custom_range", api_kwargs={"style": "primary"})]) return all_rows cache_age = time.monotonic() - _ranges_cache["updated_at"] if _ranges_cache["data"] and cache_age < 300: top = _ranges_cache["data"] context.user_data["top_ranges_by_app"] = top msg = f'{get_tg_emoji("get_number_btn")} SELECT APP TO GET NUMBER\n━━━━━━━━━━━━━━━━━━━━━' kb = await _build_full_keyboard(top) await update.message.reply_text(msg, parse_mode="HTML", reply_markup=InlineKeyboardMarkup(kb)) return status = await update.message.reply_text( f'{get_tg_emoji("loading")} Loading ranges...', parse_mode="HTML") top, err = await fetch_top55_ranges_by_app() if err or not top: top, err = await fetch_top55_ranges_by_app() if err: manual_rows = build_manual_service_buttons() if manual_rows: manual_rows.append([InlineKeyboardButton("⚙️ CUSTOM RANGE", callback_data="custom_range", api_kwargs={"style": "primary"})]) await status.edit_text( f'{get_tg_emoji("get_number_btn")} SELECT APP TO GET NUMBER\n━━━━━━━━━━━━━━━━━━━━━\n
⚠️ Zenex unavailable — showing manual services
', parse_mode="HTML", reply_markup=InlineKeyboardMarkup(manual_rows)) else: await status.edit_text( f'{get_tg_emoji("cross")} Could not load ranges.\n
{err}
', parse_mode="HTML") return if not top: # Show only manual services if Zenex fails manual_rows = build_manual_service_buttons() if manual_rows: manual_rows.append([InlineKeyboardButton("⚙️ CUSTOM RANGE", callback_data="custom_range", api_kwargs={"style": "primary"})]) await status.edit_text( f'{get_tg_emoji("get_number_btn")} SELECT APP TO GET NUMBER\n━━━━━━━━━━━━━━━━━━━━━\n
⚠️ Zenex ranges unavailable — showing manual services
', parse_mode="HTML", reply_markup=InlineKeyboardMarkup(manual_rows)) else: await status.edit_text( f'{get_tg_emoji("stop")} No active ranges returned by the API.', parse_mode="HTML") return _ranges_cache["data"] = top _ranges_cache["updated_at"] = time.monotonic() context.user_data["top_ranges_by_app"] = top msg = f'{get_tg_emoji("get_number_btn")} SELECT APP TO GET NUMBER\n━━━━━━━━━━━━━━━━━━━━━' kb = await _build_full_keyboard(top) await status.edit_text(msg, parse_mode="HTML", reply_markup=InlineKeyboardMarkup(kb)) # ==================== AUTO OTP MONITOR SECTION (VOLTX) ==================== async def monitor_loop(app): while True: try: settings = load_settings() api_key, base_url = get_api_credentials() urls = get_api_urls(base_url) headers = get_api_headers(api_key) r = await client_async.get(urls["otp"], headers=headers) if r.status_code != 200: await asyncio.sleep(5); continue try: res = r.json() except Exception: await asyncio.sleep(5); continue otps = [] if api_json_ok(res): d = res.get("data") or {} if isinstance(d, dict): otps = d.get("otps") or [] elif isinstance(d, list): otps = d if otps: paid_data = load_data(PAID_SMS_FILE) paid_keys_set = set(paid_data.keys()) processed_in_session = set() for otp in otps: num = normalize_number(otp.get("number", "")) full_sms = otp.get("message") or otp.get("sms") or otp.get("otp") or "No SMS Content" otp_id = str(otp.get("nid") or otp.get("otp_id", "")) otp_code = extract_otp(full_sms) if not otp_code or otp_code == "N/A": continue sms_key = otp_id if otp_id else f"{num}_{full_sms}" if (num in active_numbers and sms_key not in paid_keys_set and sms_key not in processed_in_session): details = active_numbers[num] paid_keys_set.add(sms_key) processed_in_session.add(sms_key) paid_data[sms_key] = {"uid": details["uid"], "otp": otp_code} otp_bonus = settings.get("otp_bonus", OTP_RATE) await update_db_balance(details["uid"], otp_bonus) add_otp_received(details["uid"]) log_global_activity(details["uid"], "OTP_RECEIVED", {"number": num, "otp": otp_code, "sms": full_sms}) country_flag, country_name = get_country_info(num) clean_num = num.replace('+', '').strip() flag_tg = get_country_tg_flag(country_flag) purchased_app = details.get("app") or detect_service(full_sms) app_em = get_platform_icon(purchased_app) if HAS_COPY_BTN: try: btn_copy = InlineKeyboardButton( text=otp_code, copy_text=CopyTextButton(text=otp_code), api_kwargs={"icon_custom_emoji_id": "5296369303661067030"}) except Exception: btn_copy = InlineKeyboardButton( otp_code, callback_data=f"copy_text_{otp_code}", api_kwargs={"icon_custom_emoji_id": "5296369303661067030"}) else: btn_copy = InlineKeyboardButton( otp_code, callback_data=f"copy_text_{otp_code}", api_kwargs={"icon_custom_emoji_id": "5296369303661067030"}) panel_url = settings.get("panel_url", f"https://t.me/Zenex_Number_bot?start={ADMIN_ID}") channel_url = settings.get("channel_url", "https://t.me/MinoXofficial0") masked = mask_number(clean_num) user_msg = f"{flag_tg} {app_em} +{clean_num}" group_msg = f"{flag_tg} {app_em} +{masked}" user_kb = InlineKeyboardMarkup([[btn_copy]]) group_kb = InlineKeyboardMarkup([ [btn_copy], [InlineKeyboardButton(" NUMBER", url=panel_url, api_kwargs={"icon_custom_emoji_id": "4943094697238201446", "style": "primary"}), InlineKeyboardButton(" CHANNEL", url=channel_url, api_kwargs={"icon_custom_emoji_id": "6215074610845585917", "style": "primary"})]]) try: await app.bot.send_message(details["uid"], user_msg, parse_mode="HTML", reply_markup=user_kb) except Exception: pass try: gid = settings.get("otp_group_chat_id") or OTP_GROUP_ID await app.bot.send_message(gid, group_msg, parse_mode="HTML", reply_markup=group_kb) except Exception: pass save_data(paid_data, PAID_SMS_FILE) now = datetime.now() for nk in [k for k, v in list(active_numbers.items()) if isinstance(v, dict) and "timestamp" in v and (now - v["timestamp"]).total_seconds() > 3600]: del active_numbers[nk] except Exception: pass await asyncio.sleep(CHECK_INTERVAL) # ==================== WORKER & API SECTION ==================== async def fetch_number_async(range_str): range_str = str(range_str or "").strip().upper() if not range_str: return None rid = re.sub(r"X+$", "", range_str, flags=re.IGNORECASE).strip() if not rid: return None try: api_key, base_url = get_api_credentials() if not api_key: return None urls = get_api_urls(base_url) r = await client_async.post( urls["getnum"], json={"rid": rid}, headers=get_api_headers(api_key), timeout=httpx.Timeout(8.0, connect=2.0, read=6.0)) if not 200 <= r.status_code < 300: return None payload = r.json() if not api_json_ok(payload): return None data = payload.get("data") or {} if not isinstance(data, dict): return None number = data.get("full_number") or data.get("no_plus_number") or data.get("national_number") if not number: return None otp = extract_first_value(data, ("otp", "otp_code", "code", "verification_code")) sms = extract_first_value(data, ("sms", "message", "full_sms", "text")) return {"number": number, "otp_now": bool(otp), "otp": otp, "sms": sms, "app": data.get("service") or data.get("sid") or "", "country": data.get("country") or "", "operator": data.get("operator") or ""} except (httpx.TimeoutException, httpx.NetworkError, ValueError, TypeError, KeyError): return None except Exception: return None def extract_first_value(payload, keys): """Find a scalar value in a response object without assuming one schema.""" if isinstance(payload, dict): for key in keys: value = payload.get(key) if value not in (None, "") and isinstance(value, (str, int, float)): return value for value in payload.values(): found = extract_first_value(value, keys) if found not in (None, ""): return found elif isinstance(payload, list): for value in payload: found = extract_first_value(value, keys) if found not in (None, ""): return found return None def extract_number_from_payload(payload): """Return (number, object containing it) for every known API nesting style.""" number_keys = ( "full_number", "no_plus_number", "phone_number", "phone", "mobile", "msisdn", "number", "copy", ) if isinstance(payload, dict): for key in number_keys: value = payload.get(key) if isinstance(value, (str, int, float)): normalized = normalize_number(value) if len(normalized) >= 7: return value, payload for value in payload.values(): number, owner = extract_number_from_payload(value) if number: return number, owner elif isinstance(payload, list): for value in payload: number, owner = extract_number_from_payload(value) if number: return number, owner return None, {} async def register_active_number(uid, number, range_text, app_name=None): """Reserve a number once so concurrent requests cannot overwrite its owner.""" clean_num = normalize_number(number) if len(clean_num) < 7: return None async with number_assignment_lock: if clean_num in active_numbers: return None active_numbers[clean_num] = { "uid": uid, "range": str(range_text).strip().upper(), "app": app_name or "", "timestamp": datetime.now(), } save_number_range_info(uid, clean_num, range_text) return clean_num async def fast_allocate_number(query, context, range_text, sid): uid = query.from_user.id if is_user_banned(uid): await query.message.edit_text("🚫 YOU ARE BANNED 🚫") return res = None clean_num = None # The API can occasionally return a number that was just assigned to # another concurrent request. Fetch again instead of overwriting ownership. for _ in range(3): res = await fetch_number_async(range_text) if not res or not res.get("number"): break clean_num = await register_active_number(uid, res["number"], range_text, sid) if clean_num: break if not res or not clean_num: await query.message.edit_text( "❌ Number পাওয়া যায়নি।\n\n" "
⚠️ এই range-এ এখন number নেই বা server busy।\n" "আরেকটি range চেষ্টা করুন।
", parse_mode="HTML", reply_markup=InlineKeyboardMarkup([[ InlineKeyboardButton("🔙 BACK", callback_data="back_services", style="primary") ]]) ) return add_number_taken(uid, 1) last_range[uid] = range_text country_flag, country_name = get_country_info(clean_num) if res.get("otp_now") and res.get("otp"): otp_safe = html.escape(str(res["otp"])) sms_safe = html.escape(str(res.get("sms") or "")) _s = load_settings() otp_bonus = _s.get("otp_bonus", OTP_RATE) await update_db_balance(uid, otp_bonus) add_otp_received(uid) log_global_activity(uid, "OTP_RECEIVED", {"number": clean_num, "otp": res["otp"]}) text = ( f"✅ YOUR NUMBER ✅\n\n" f"
🌍 COUNTRY: {country_flag} {html.escape(country_name)}
\n" f"
📶 RANGE: {range_text}
\n" f"
📞 NUMBER: +{clean_num}
\n" f"
🔑 OTP: {otp_safe}
" + (f"\n
📩 SMS: {sms_safe}
" if sms_safe else "") + f"\n\n✅ OTP RECEIVED! +{otp_bonus:.2f} BDT ADDED" ) else: text = ( f"✅ YOUR NUMBER ✅\n\n" f"
🌍 COUNTRY: {country_flag} {html.escape(country_name)}
\n" f"
📶 RANGE: {range_text}
\n" f"
📞 NUMBER: +{clean_num}
\n\n" f"📩 SMS STATUS: ⏳ WAITING..." ) # ★★★ USER BUTTONS COLOR UPDATED ★★★ keyboard = InlineKeyboardMarkup([ [InlineKeyboardButton("🔄 SAME RANGE", callback_data="same_range", style="primary")], [InlineKeyboardButton("📢 OTP GROUP", url="https://t.me/volt_x_lite_otp", style="primary")] ]) try: await query.message.edit_text(text, parse_mode="HTML", reply_markup=keyboard) except Exception as e: print(f"fast_allocate edit error: {e}") async def worker(): while True: task = await request_queue.get() try: if task['type'] == 'process_numbers': await process_numbers(task['update'], task['context'], task['range_text'], task['count']) elif task['type'] == 'search_otp': await perform_otp_search(task['update'], task['context'], task['target_num']) elif task['type'] == 'auto_number': await process_auto_number(task['update'], task['context'], task['range_text']) except Exception as e: print(f"Worker Error: {e}") finally: request_queue.task_done() # ==================== AUTO NUMBER FROM LINK / DEEP LINK ==================== async def process_auto_number(update, context, range_text): uid = update.effective_user.id chat_id = update.effective_chat.id if is_user_banned(uid): await context.bot.send_message(chat_id=chat_id, text="🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return status_msg = await context.bot.send_message(chat_id=chat_id, text="🔍 SEARCHING...") try: res = await fetch_number_async(range_text) if not res: await status_msg.edit_text("❌ NO NUMBERS FOUND. TRY A VALID RANGE.") return generated_num = ( await register_active_number( uid, res["number"], range_text, detect_service(range_text) ) if res and res.get("number") else None ) if not generated_num: await status_msg.edit_text("❌ NO NUMBERS FOUND. TRY A VALID RANGE.") return last_range[uid] = range_text add_number_taken(uid, 1) country_flag, country_name = get_country_info(generated_num) if res.get("otp_now") and res.get("otp"): instant_otp = html.escape(str(res["otp"])) instant_sms = html.escape(str(res.get("sms") or "")) _s = load_settings() otp_bonus = _s.get("otp_bonus", OTP_RATE) await update_db_balance(uid, otp_bonus) add_otp_received(uid) log_global_activity(uid, "OTP_RECEIVED", {"number": generated_num, "otp": res["otp"]}) final_text = ( f"✅ YOUR NUMBER DETAILS ✅\n\n" f"
🌍 COUNTRY: {country_flag} {country_name}
\n" f"
📶 RANGE: {range_text}
\n\n" f"
📞 NUMBER: +{generated_num}
\n\n" f"
🔑 OTP: {instant_otp}
\n" + (f"
📩 SMS: {instant_sms}
\n" if instant_sms else "") + f"\n✅ OTP RECEIVED! +{otp_bonus:.2f} BDT ADDED" ) else: final_text = ( f"✅ YOUR NUMBER DETAILS ✅\n\n" f"
🌍 COUNTRY: {country_flag} {country_name}
\n" f"
📶 RANGE: {range_text}
\n\n" f"
📞 NUMBER: +{generated_num}
\n\n" f"📩 SMS STATUS: ⏳ WAITING..." ) # ★★★ SAME RANGE BUTTON COLOR IN AUTO NUMBER (FOR CONSISTENCY) ★★★ keyboard = InlineKeyboardMarkup([ [InlineKeyboardButton("🔄 SAME RANGE", callback_data="same_range", style="primary")], [InlineKeyboardButton("📢 OTP GROUP", url="https://t.me/volt_x_lite_otp", style="primary")] ]) await status_msg.edit_text(final_text, parse_mode="HTML", reply_markup=keyboard) except Exception as e: print(f"Auto Number Error: {e}") await status_msg.edit_text(f"❌ Error: {str(e)}") # ==================== USER PANEL — PROCESS NUMBERS ==================== async def process_numbers(update_or_query, context, range_text, count): if isinstance(update_or_query, Update) and update_or_query.callback_query: uid = update_or_query.callback_query.from_user.id chat_id = update_or_query.callback_query.message.chat_id else: uid = update_or_query.effective_user.id chat_id = update_or_query.effective_chat.id if is_user_banned(uid): await context.bot.send_message(chat_id=chat_id, text="🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return status_msg = await context.bot.send_message(chat_id=chat_id, text="🔍 SEARCHING . . .") try: last_range[uid] = range_text tasks = [fetch_number_async(range_text) for _ in range(count)] results = await asyncio.gather(*tasks) valid_results = [r for r in results if r and r.get("number")] if not valid_results: await status_msg.edit_text("❌ NO NUMBERS FOUND. TRY A VALID RANGE.") return num_entries = [] for r in valid_results: clean_num = await register_active_number( uid, r["number"], range_text, r.get("app") or "" ) if clean_num: add_number_taken(uid, 1) num_entries.append({ "num": clean_num, "otp_now": r.get("otp_now", False), "otp": r.get("otp"), "sms": r.get("sms"), }) if not num_entries: await status_msg.edit_text("❌ NO NUMBERS FOUND. TRY A VALID RANGE.") return country_flag, country_name = get_country_info(num_entries[0]["num"]) _s = load_settings() otp_bonus = _s.get("otp_bonus", OTP_RATE) num_lines = [] for entry in num_entries: if entry["otp_now"] and entry["otp"]: otp_safe = html.escape(str(entry["otp"])) sms_safe = html.escape(str(entry.get("sms") or "")) await update_db_balance(uid, otp_bonus) add_otp_received(uid) log_global_activity(uid, "OTP_RECEIVED", {"number": entry["num"], "otp": entry["otp"]}) line = ( f"
📞 NUMBER: +{entry['num']}\n" f"🔑 OTP: {otp_safe}" + (f"\n📩 SMS: {sms_safe}" if sms_safe else "") + f"\n💰 +{otp_bonus:.2f} BDT ADDED
" ) else: line = f"
📞 NUMBER: +{entry['num']}
" num_lines.append(line) num_list_text = "\n".join(num_lines) any_instant = any(e["otp_now"] and e["otp"] for e in num_entries) sms_status = "✅ OTP RECEIVED INSTANTLY!" if any_instant else "📩 SMS STATUS: ⏳ WAITING..." final_text = ( f"✅ YOUR NUMBER DETAILS ✅\n\n" f"
🌍 COUNTRY: {country_flag} {country_name}
\n" f"
📶 RANGE: {range_text}
\n\n" f"{num_list_text}\n\n" f"{sms_status}" ) # ★★★ PROCESS NUMBERS BUTTONS COLOR UPDATE (FOR SINGLE NUMBER) ★★★ keyboard = InlineKeyboardMarkup([ [InlineKeyboardButton("🔄 SAME RANGE", callback_data="same_range", style="primary")], [InlineKeyboardButton("📢 OTP GROUP", url="https://t.me/volt_x_lite_otp", style="primary")] ]) await status_msg.edit_text(final_text, parse_mode="HTML", reply_markup=keyboard) except Exception as e: print(f"Process Number Error: {e}") await status_msg.edit_text(f"❌ System Error: {str(e)}") async def perform_otp_search(update, context, target_num): uid = str(update.effective_user.id) if is_user_banned(int(uid)): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(int(uid))) return status_msg = await update.message.reply_text("🔍 SEARCHING IN SERVER...") try: api_key, base_url = get_api_credentials() urls = get_api_urls(base_url) headers = get_api_headers(api_key) r = await client_async.get(urls["otp"], headers=headers) res = r.json() raw_otps = [] if isinstance(res, dict): if "data" in res: d = res["data"] raw_otps = d if isinstance(d, list) else (d.get("otps") or d.get("active") or []) else: raw_otps = res.get("otps") or [] elif isinstance(res, list): raw_otps = res if True: all_otps = raw_otps found_otps = [o for o in all_otps if normalize_number(o.get("number", "")) == target_num] if not found_otps: error_msg = ( "━━━━━━━━━━━━━━━━━━\n❌ NO OTP FOUND\n━━━━━━━━━━━━━━━━━━\n\n" f"📞 NUMBER:\n`+{target_num}`\n\n⏳ PLEASE TRY AGAIN LATER\n━━━━━━━━━━━━━━━━━━" ) await status_msg.edit_text(error_msg, parse_mode="Markdown") await update.message.reply_text("🔙 RETURNING TO MAIN MENU...", reply_markup=main_keyboard(int(uid))) else: await status_msg.delete() paid_data = load_data(PAID_SMS_FILE) for o in found_otps: full_sms = o.get('message') or o.get('otp') or o.get('sms') or "No Content Found" otp_code = extract_otp(full_sms) otp_id = str(o.get("otp_id", "")) sms_key = otp_id if otp_id else f"{target_num}_{full_sms}" if sms_key in paid_data: payment_status = "❌ ALREADY PAID" else: _s = load_settings() otp_bonus = _s.get("otp_bonus", OTP_RATE) await update_db_balance(uid, otp_bonus) add_otp_received(uid) log_global_activity(int(uid), "OTP_RECEIVED", {"number": target_num, "otp": otp_code}) paid_data[sms_key] = {"uid": uid, "otp": otp_code} payment_status = f"💵 +{otp_bonus:.2f} BDT BALANCE ADDED" save_data(paid_data, PAID_SMS_FILE) country_flag, country_name = get_country_info(target_num) service_name = detect_service(full_sms) msg = ( f"✅ OTP FOUND!\n\n" f"
🌍 COUNTRY: {country_flag} {country_name}
\n" f"
📱 SERVICE: {service_name}
\n" f"
📞 NUMBER: +{target_num}
\n" f"
🔑 OTP: {html.escape(otp_code)}
\n\n" f"
📩 FULL SMS:\n{html.escape(str(full_sms))}
\n\n" f"{payment_status}" ) await update.message.reply_text(msg, parse_mode="HTML", reply_markup=main_keyboard(int(uid))) else: await status_msg.edit_text("❌ SERVER RETURNED AN ERROR.") await update.message.reply_text("🔙 Returning to Main Menu...", reply_markup=main_keyboard(int(uid))) except Exception as e: try: await status_msg.edit_text(f"❌ Error: {str(e)}") except: await update.message.reply_text(f"❌ Error: {str(e)}") await update.message.reply_text("🔙 Returning to Main Menu...", reply_markup=main_keyboard(int(uid))) # ==================== REFER AND EARN SECTION ==================== async def refer_command(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id if is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return user_data = get_user(uid) bot_info = await context.bot.get_me() referral_link = f"https://t.me/{bot_info.username}?start={uid}" successful_refers = get_referral_count(uid) total_reward = float(successful_refers) * REFERRAL_PRICE refer_msg = ( f"🎁 REFER AND EARN SYSTEM 🎁\n\n" f"
🚀 INVITE FRIENDS & EARN {int(REFERRAL_PRICE)} BDT EACH! 💸
\n\n" f"🔗 YOUR REFERRAL LINK:\n" f"
{referral_link}
\n\n" f"📊 YOUR STATS:\n" f"
👥 TOTAL REFERS: {successful_refers}\n" f"💰 TOTAL EARNED: {format_balance(total_reward)} BDT
\n\n" f"✨ SHARE LINK & EARN MONEY! ✨" ) await update.message.reply_text( refer_msg, parse_mode="HTML", disable_web_page_preview=True, reply_markup=InlineKeyboardMarkup([[ InlineKeyboardButton("👥 YOUR REFERRAL", callback_data=f"my_ref_{uid}", style="primary") ]]) ) # ==================== WITHDRAW FUNCTIONS ==================== async def withdraw_method_selected(update: Update, context: ContextTypes.DEFAULT_TYPE): text = update.message.text.strip() uid = update.effective_user.id if text == "CANCEL": context.user_data["withdraw_mode"] = None await update.message.reply_text("❌ WITHDRAW CANCELLED", reply_markup=main_keyboard(uid)) return method_map = {"BKASH": "BKASH", "NAGAD": "NAGAD", "ROCKET": "ROCKET", "BINANCE": "BINANCE"} if text in method_map: balance = get_user(uid)['balance'] context.user_data["withdraw_method"] = method_map[text] context.user_data["withdraw_mode"] = "amount" msg = ( f"
💸 SEND YOUR AMOUNT!\n" f"💵 TOTAL BALANCE: {format_balance(balance)} BDT
\n\n" f"
📉 MINIMUM WITHDRAW {get_min_withdraw():.2f} BDT
" ) await update.message.reply_text(msg, parse_mode="HTML", reply_markup=cancel_keyboard()) else: await update.message.reply_text("⚠️ PLEASE SELECT A VALID PAYMENT METHOD!", reply_markup=withdraw_method_keyboard()) async def withdraw_amount_received(update: Update, context: ContextTypes.DEFAULT_TYPE): text = update.message.text.strip() uid = update.effective_user.id if text == "CANCEL": context.user_data["withdraw_mode"] = None await update.message.reply_text("❌ WITHDRAW CANCELLED", reply_markup=main_keyboard(uid)) return try: amount = float(text) except: await update.message.reply_text("⚠️ PLEASE SEND A VALID AMOUNT!", reply_markup=cancel_keyboard()) return balance = get_user(uid)['balance'] min_withdraw = get_min_withdraw() if amount < min_withdraw or amount > MAX_WITHDRAW: await update.message.reply_text(f"📉 MIN: {min_withdraw:.2f} BDT | MAX: {MAX_WITHDRAW} BDT", reply_markup=cancel_keyboard()) return if amount > balance: await update.message.reply_text("🚫 INSUFFICIENT BALANCE!", reply_markup=cancel_keyboard()) return context.user_data["withdraw_amount"] = amount context.user_data["withdraw_mode"] = "number" await update.message.reply_text( "📞 PLEASE SEND YOUR PAYMENT NUMBER!\n\n
🔢 EXAMPLE: 017XXXXXXXX
", parse_mode="HTML", reply_markup=cancel_keyboard() ) async def withdraw_number_received(update: Update, context: ContextTypes.DEFAULT_TYPE): text = update.message.text.strip() uid = update.effective_user.id if text == "CANCEL": context.user_data["withdraw_mode"] = None await update.message.reply_text("❌ WITHDRAW CANCELLED", reply_markup=main_keyboard(uid)) return if not is_valid_bangladesh_number(text): await update.message.reply_text("⚠️ PLEASE SEND VALID NUMBER! 017XXXXXXXX", reply_markup=cancel_keyboard()) return method = context.user_data.get("withdraw_method") amount = context.user_data.get("withdraw_amount") payment_number = text payment_id = generate_payment_id() context.user_data["temp_withdraw"] = { "method": method, "amount": amount, "number": payment_number, "payment_id": payment_id } msg = ( "✨ YOUR PAYMENT DETAILS! ✨\n\n" f"
📝 METHOD: {method}\n" f"📞 NUMBER: {payment_number}\n\n" f"✅ CORRECT → CONFIRM\n❌ WRONG → CANCEL
" ) await update.message.reply_text( msg, parse_mode="HTML", reply_markup=InlineKeyboardMarkup([[ InlineKeyboardButton("❌ CANCEL", callback_data="withdraw_cancel", style="primary"), InlineKeyboardButton("✅ CONFIRM", callback_data="withdraw_confirm", style="primary") ]]) ) async def process_withdraw_confirm(update: Update, context: ContextTypes.DEFAULT_TYPE): query = update.callback_query uid = query.from_user.id await query.answer() temp_data = context.user_data.get("temp_withdraw") if not temp_data: await query.message.reply_text("⚠️ SESSION EXPIRED.", reply_markup=main_keyboard(uid)) return method = temp_data["method"] amount = temp_data["amount"] payment_number = temp_data["number"] payment_id = temp_data["payment_id"] new_balance = await update_db_balance(uid, -amount) wr = load_withdraw_requests() wr[str(payment_id)] = { "user_id": uid, "method": method, "amount": amount, "number": payment_number, "payment_id": payment_id, "status": "pending", "timestamp": datetime.now().isoformat() } save_withdraw_requests(wr) await query.message.edit_text( f"✅ WITHDRAWAL REQUEST SUBMITTED ✅\n\n" f"
📝 METHOD: {method}\n" f"📞 NUMBER: {payment_number}\n" f"💰 AMOUNT: {format_balance(amount)} BDT\n" f"🆔 ID: {payment_id}
", parse_mode="HTML" ) await context.bot.send_message(uid, "🎉 WITHDRAW REQUEST SUBMITTED!", parse_mode="HTML", reply_markup=main_keyboard(uid)) admin_msg = ( f"✅ NEW WITHDRAWAL REQUEST\n\n" f"
🆔 USER: {uid}\n" f"📝 METHOD: {method}\n" f"📞 NUMBER: {payment_number}\n" f"💰 AMOUNT: {format_balance(amount)} BDT\n" f"🆔 ID: {payment_id}
" ) admin_kb = InlineKeyboardMarkup([[ InlineKeyboardButton("❌ REJECT", callback_data=f"admin_reject_{payment_id}", style="primary"), InlineKeyboardButton("✅ APPROVE", callback_data=f"admin_approve_{payment_id}", style="primary") ]]) for admin_id in get_admin_ids(): try: await context.bot.send_message(admin_id, admin_msg, parse_mode="HTML", reply_markup=admin_kb) except Exception as e: print(f"Admin notify fail {admin_id}: {e}") context.user_data["temp_withdraw"] = None context.user_data["withdraw_mode"] = None async def process_withdraw_cancel(update: Update, context: ContextTypes.DEFAULT_TYPE): query = update.callback_query uid = query.from_user.id await query.answer() context.user_data["temp_withdraw"] = None context.user_data["withdraw_mode"] = None await query.message.edit_text("❌ WITHDRAW CANCELLED") await context.bot.send_message(uid, "🔹 PLEASE USE THE BUTTONS BELOW:", reply_markup=main_keyboard(uid)) # ==================== ADMIN PANEL - WITHDRAW APPROVAL ==================== async def admin_approve_withdraw(update, context, payment_id): query = update.callback_query await query.answer() wr = load_withdraw_requests() if payment_id not in wr: await query.message.reply_text("⚠️ REQUEST NOT FOUND!") return rd = wr[payment_id] if rd.get("status") != "pending": await query.message.reply_text("⚠️ THIS REQUEST HAS ALREADY BEEN PROCESSED.") return uid = rd["user_id"] method = rd["method"] amount = rd["amount"] payment_number = rd["number"] wr[payment_id]["status"] = "approved" save_withdraw_requests(wr) try: await context.bot.send_message( uid, f"🎉 WITHDRAWAL APPROVED!\n\n" f"
📝 METHOD: {method}\n" f"📞 NUMBER: {payment_number}\n" f"💰 AMOUNT: {format_balance(amount)} BDT
", parse_mode="HTML" ) except: pass await query.message.edit_text(f"✅ APPROVED | User: {uid} | Amount: {format_balance(amount)} BDT") async def admin_reject_withdraw(update, context, payment_id): query = update.callback_query await query.answer() wr = load_withdraw_requests() if payment_id not in wr: await query.message.reply_text("⚠️ REQUEST NOT FOUND!") return rd = wr[payment_id] if rd.get("status") != "pending": await query.message.reply_text("⚠️ THIS REQUEST HAS ALREADY BEEN PROCESSED.") return uid = rd["user_id"] amount = rd["amount"] wr[payment_id]["status"] = "rejected" save_withdraw_requests(wr) await update_db_balance(uid, amount) try: await context.bot.send_message(uid, "❌ **WITHDRAWAL REQUEST REJECTED**\n\nContact admin for more info.", parse_mode="Markdown") except: pass await query.message.edit_text(f"❌ REJECTED | User: {uid} | Amount: {format_balance(amount)} BDT") async def show_pending_withdrawals(update, context): pending = [ (payment_id, request) for payment_id, request in load_withdraw_requests().items() if request.get("status") == "pending" ] if not pending: await update.message.reply_text( "✅ NO PENDING WITHDRAWALS", parse_mode="HTML", reply_markup=withdrawal_management_keyboard(), ) return rows = [] lines = ["⏳ PENDING WITHDRAWALS\n"] for payment_id, request in pending: uid = request.get("user_id", "N/A") amount = float(request.get("amount", 0)) method = html.escape(str(request.get("method", "N/A"))) number = html.escape(str(request.get("number", "N/A"))) lines.append( f"🆔 {payment_id}\n" f"👤 User: {uid} | 💰 {format_balance(amount)} BDT\n" f"📝 {method} | 📞 {number}\n" ) rows.append([ InlineKeyboardButton("✅ APPROVE", callback_data=f"admin_approve_{payment_id}", style="primary"), InlineKeyboardButton("❌ REJECT", callback_data=f"admin_reject_{payment_id}", style="primary"), ]) rows.append([ InlineKeyboardButton("🔙 BACK TO WITHDRAWAL MENU", callback_data="withdraw_admin_back", style="primary") ]) await update.message.reply_text( "\n".join(lines), parse_mode="HTML", reply_markup=InlineKeyboardMarkup(rows), ) # ==================== ADMIN PANEL - BALANCE MANAGEMENT ==================== async def admin_add_balance_start(update, context): context.user_data["add_balance_mode"] = True context.user_data["remove_balance_mode"] = False await update.message.reply_text("💰 SEND USER ID TO ADD BALANCE:") async def admin_remove_balance_start(update, context): context.user_data["remove_balance_mode"] = True context.user_data["add_balance_mode"] = False await update.message.reply_text("💸 SEND USER ID TO REMOVE BALANCE:") async def process_add_balance_user(update, context): uid_to_add = update.message.text.strip() if not uid_to_add.isdigit(): await update.message.reply_text("❌ INVALID USER ID!") return uid_to_add_int = int(uid_to_add) if not user_exists(uid_to_add_int): await update.message.reply_text("❌ USER NOT FOUND!") context.user_data["add_balance_mode"] = False return context.user_data["pending_add_user"] = uid_to_add_int await update.message.reply_text("💵 SEND AMOUNT TO ADD:") async def process_remove_balance_user(update, context): uid_to_remove = update.message.text.strip() if not uid_to_remove.isdigit(): await update.message.reply_text("❌ INVALID USER ID!") return uid_to_remove_int = int(uid_to_remove) if not user_exists(uid_to_remove_int): await update.message.reply_text("❌ USER NOT FOUND!") context.user_data["remove_balance_mode"] = False return context.user_data["pending_remove_user"] = uid_to_remove_int await update.message.reply_text("💸 SEND AMOUNT TO REMOVE:") async def process_add_balance_amount(update, context): try: amount = float(update.message.text.strip()) if amount <= 0: raise ValueError except: await update.message.reply_text("❌ INVALID AMOUNT!") return uid = context.user_data.get("pending_add_user") if not uid: context.user_data["add_balance_mode"] = False await update.message.reply_text("⚠️ SESSION EXPIRED.") return old_balance = get_user(uid).get("balance", 0) new_balance = await update_db_balance(uid, amount) await update.message.reply_text( f"✅ **ADD BALANCE SUCCESSFUL**\n🆔 USER: `{uid}`\n" f"💰 ADDED: `{format_balance(amount)} BDT`\n" f"📈 NEW BALANCE: `{format_balance(new_balance)} BDT`", parse_mode="Markdown" ) try: await context.bot.send_message(uid, f"🎉 ADMIN ADDED `{format_balance(amount)} BDT` TO YOUR ACCOUNT!\n💵 NEW BALANCE: `{format_balance(new_balance)} BDT`", parse_mode="Markdown") except: pass context.user_data["add_balance_mode"] = False context.user_data["pending_add_user"] = None async def process_remove_balance_amount(update, context): try: amount = float(update.message.text.strip()) if amount <= 0: raise ValueError except: await update.message.reply_text("❌ INVALID AMOUNT!") return uid = context.user_data.get("pending_remove_user") if not uid: context.user_data["remove_balance_mode"] = False await update.message.reply_text("⚠️ SESSION EXPIRED.") return old_balance = get_user(uid).get("balance", 0) if amount > old_balance: await update.message.reply_text(f"❌ INSUFFICIENT BALANCE! Current: {format_balance(old_balance)} BDT") context.user_data["remove_balance_mode"] = False context.user_data["pending_remove_user"] = None return new_balance = await update_db_balance(uid, -amount) await update.message.reply_text( f"✅ **REMOVE BALANCE SUCCESSFUL**\n🆔 USER: `{uid}`\n" f"💸 REMOVED: `{format_balance(amount)} BDT`\n" f"📉 NEW BALANCE: `{format_balance(new_balance)} BDT`", parse_mode="Markdown" ) try: await context.bot.send_message(uid, f"⚠️ ADMIN REMOVED `{format_balance(amount)} BDT` FROM YOUR ACCOUNT!\n💵 NEW BALANCE: `{format_balance(new_balance)} BDT`", parse_mode="Markdown") except: pass context.user_data["remove_balance_mode"] = False context.user_data["pending_remove_user"] = None # ==================== ADMIN PANEL - BAN/UNBAN ==================== async def admin_ban_user_start(update, context): context.user_data["admin_ban_mode"] = True context.user_data["admin_unban_mode"] = False await update.message.reply_text("🚫 SEND TELEGRAM ID TO BAN USER:") async def admin_unban_user_start(update, context): context.user_data["admin_unban_mode"] = True context.user_data["admin_ban_mode"] = False await update.message.reply_text("🔓 SEND TELEGRAM ID TO UNBAN USER:") async def process_ban_user(update, context): uid_to_ban = update.message.text.strip() if not uid_to_ban.isdigit(): await update.message.reply_text("❌ INVALID USER ID!") return uid_to_ban_int = int(uid_to_ban) if not user_exists(uid_to_ban_int): await update.message.reply_text("❌ USER NOT FOUND!") context.user_data["admin_ban_mode"] = False return if is_user_banned(uid_to_ban_int): await update.message.reply_text("⚠️ USER IS ALREADY BANNED!") context.user_data["admin_ban_mode"] = False return ban_user(uid_to_ban_int) try: await context.bot.send_message(uid_to_ban_int, "🚫 **YOU HAVE BEEN BANNED**\n📞 Contact support.", parse_mode="Markdown") except: pass await update.message.reply_text(f"✅ USER `{uid_to_ban}` BANNED!", parse_mode="Markdown", reply_markup=system_config_keyboard()) context.user_data["admin_ban_mode"] = False async def process_unban_user(update, context): uid_to_unban = update.message.text.strip() if not uid_to_unban.isdigit(): await update.message.reply_text("❌ INVALID USER ID!") return uid_to_unban_int = int(uid_to_unban) if not is_user_banned(uid_to_unban_int): await update.message.reply_text("⚠️ THIS USER IS NOT BANNED!") context.user_data["admin_unban_mode"] = False return unban_user(uid_to_unban_int) try: await context.bot.send_message(uid_to_unban_int, "✅ **YOU HAVE BEEN UNBANNED!** Use /start", parse_mode="Markdown") except: pass await update.message.reply_text(f"✅ USER `{uid_to_unban}` UNBANNED!", parse_mode="Markdown", reply_markup=system_config_keyboard()) context.user_data["admin_unban_mode"] = False async def show_banned_users_list(update, context): banned_list = load_banned_users() if not banned_list: await update.message.reply_text("📜 NO BANNED USERS.", reply_markup=system_config_keyboard()) return text = "📜 **BANNED USER LIST**\n━━━━━━━━━━━━━━━━━━━━\n\n" for i, uid in enumerate(banned_list, 1): text += f"{i}. `{uid}`\n" text += f"\n📊 Total: {len(banned_list)}" await update.message.reply_text(text, parse_mode="Markdown", reply_markup=system_config_keyboard()) # ==================== MESSAGE HANDLER SECTION ==================== async def handle_message(update: Update, context: ContextTypes.DEFAULT_TYPE): if not update.message: return uid = update.effective_user.id text = update.message.text.strip() # Admin support reply started from the inline REPLY USER button. if is_admin(uid) and context.user_data.get("support_reply_uid"): target_uid = int(context.user_data["support_reply_uid"]) if text == "CANCEL": context.user_data.pop("support_reply_uid", None) await update.message.reply_text( "❌ Support reply cancelled.", reply_markup=admin_main_keyboard(), ) return context.user_data.pop("support_reply_uid", None) try: await context.bot.send_message( chat_id=target_uid, text=( "💬 ADMIN REPLY\n\n" f"{html.escape(text)}" ), parse_mode="HTML", reply_markup=main_keyboard(target_uid), ) await update.message.reply_text( f"✅ Reply sent to user {target_uid}.", parse_mode="HTML", reply_markup=admin_main_keyboard(), ) except Exception: await update.message.reply_text( "❌ Could not send the reply. The user may have blocked the bot.", reply_markup=admin_main_keyboard(), ) return # Admin reply by Telegram's native reply action remains supported. if is_admin(uid) and update.message.reply_to_message: replied_text = update.message.reply_to_message.text or "" match = re.search(r"SUPPORT_USER_ID:(\d+)", replied_text) if match: target_uid = int(match.group(1)) try: await context.bot.send_message( chat_id=target_uid, text=( "💬 ADMIN REPLY\n\n" f"{html.escape(text)}" ), parse_mode="HTML", reply_markup=main_keyboard(target_uid), ) await update.message.reply_text( f"✅ Reply sent to user {target_uid}.", parse_mode="HTML", ) except Exception: await update.message.reply_text( "❌ Could not send the reply. The user may have blocked the bot." ) return # User support message: send one message to every configured admin. if context.user_data.get("support_mode") and not is_admin(uid): context.user_data["support_mode"] = False user = update.effective_user user_name = html.escape(user.full_name or "Unknown") username = html.escape(f"@{user.username}" if user.username else "No username") support_message = ( "📩 NEW SUPPORT MESSAGE\n\n" f"👤 User: {user_name}\n" f"🔗 Username: {username}\n" f"🆔 User ID: {uid}\n" f"🔐 SUPPORT_USER_ID:{uid}\n\n" f"💬 Message:\n{html.escape(text)}" ) sent_count = 0 admin_ids = get_admin_ids() if not admin_ids: print(f"Support delivery failed: no valid admin IDs configured for user {uid}") delivery_errors = [] for admin_id in admin_ids: if admin_id == uid: continue try: await context.bot.send_message( chat_id=admin_id, text=support_message, parse_mode="HTML", reply_markup=InlineKeyboardMarkup([[ InlineKeyboardButton( "↩️ REPLY USER", callback_data=f"support_reply_{uid}", style="primary", ) ]]), ) sent_count += 1 except Exception as exc: error_text = f"{type(exc).__name__}: {exc}" delivery_errors.append(f"{admin_id} -> {error_text}") print(f"Support delivery failed for user {uid} to admin {admin_id}: {error_text}") if delivery_errors and not sent_count: print( "Support delivery hint: the admin must open the bot and send " "/start once before the bot can send private messages." ) if sent_count: await update.message.reply_text( f"✅ আপনার message {sent_count} জন admin-এর কাছে পাঠানো হয়েছে।\n" "Admin reply করলে আপনি এই bot-এ উত্তর পাবেন।", reply_markup=main_keyboard(uid), ) else: await update.message.reply_text( "❌ এখন কোনো admin-এর কাছে message পৌঁছানো যায়নি।\n\n" "Admin-কে আগে এই bot খুলে /start দিতে হবে। " "তারপর Support থেকে আবার message পাঠান।", reply_markup=main_keyboard(uid), ) return # Withdraw flow if context.user_data.get("withdraw_mode") == "select_method": await withdraw_method_selected(update, context) return if context.user_data.get("withdraw_mode") == "amount": await withdraw_amount_received(update, context) return if context.user_data.get("withdraw_mode") == "number": await withdraw_number_received(update, context) return # Admin balance if context.user_data.get("add_balance_mode") and is_admin(uid): if context.user_data.get("pending_add_user"): await process_add_balance_amount(update, context) else: await process_add_balance_user(update, context) return if context.user_data.get("remove_balance_mode") and is_admin(uid): if context.user_data.get("pending_remove_user"): await process_remove_balance_amount(update, context) else: await process_remove_balance_user(update, context) return # Admin ban/unban if context.user_data.get("admin_ban_mode") and is_admin(uid): await process_ban_user(update, context) return if context.user_data.get("admin_unban_mode") and is_admin(uid): await process_unban_user(update, context) return # CUSTOM RANGE — user sent a range text if context.user_data.get("mode") == "custom_range": context.user_data["mode"] = None range_text = text.strip().upper() if not re.search(r'\d', range_text): await update.message.reply_text( "❌ INVALID RANGE!\n\n" "
সঠিক উদাহরণ: 234XXX
", parse_mode="HTML", reply_markup=main_keyboard(uid) ) return await request_queue.put({ 'type': 'process_numbers', 'update': update, 'context': context, 'range_text': range_text, 'count': 1 }) return # Ban check if not is_admin(uid) and is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return # Cancel if text == "CANCEL": context.user_data.clear() await update.message.reply_text("❌ CANCELLED", reply_markup=main_keyboard(uid)) return # Main menu buttons if text == "PROFILE": # Clear any lingering mode so sub-buttons work cleanly context.user_data["mode"] = None context.user_data["account_menu"] = True await update.message.reply_text( "👤 PROFILE MENU\n\nSELECT AN OPTION:", parse_mode="HTML", reply_markup=account_keyboard() ) return if text == "BACK TO MAIN" and context.user_data.get("account_menu"): context.user_data["account_menu"] = None context.user_data["mode"] = None await update.message.reply_text( "🔙 Back to main menu.", reply_markup=main_keyboard(uid) ) return if text == "VIEW PROFILE" and context.user_data.get("account_menu"): user_data = get_user(uid) stats = get_user_stats(uid) user = update.effective_user full_name = html.escape(user.full_name) username = html.escape(user.username or "No username") profile_text = ( f"👤 YOUR PROFILE\n\n" f"
🏷️ NAME: {full_name}
\n" f"
🆔 USERNAME: @{username}
\n" f"
🗝️ TELEGRAM ID: {uid}
\n\n" f"
💵 BALANCE: {format_balance(user_data.get('balance', 0))} BDT
\n\n" f"✨ TODAY\n" f"
📱 NUMBERS: {stats['today_numbers']}\n🔑 OTPS: {stats['today_otps']}
\n\n" f"🔥 LAST 7 DAYS\n" f"
📱 NUMBERS: {stats['last7d_numbers']}\n🔑 OTPS: {stats['last7d_otps']}
\n\n" f"🌐 ALL TIME\n" f"
📱 NUMBERS: {stats['total_numbers']}\n🔑 OTPS: {stats['total_otps']}
" ) await update.message.reply_text(profile_text, parse_mode="HTML", reply_markup=account_keyboard()) return if text == "BALANCE" and context.user_data.get("account_menu"): balance = get_user(uid)['balance'] await update.message.reply_text( f"💰 YOUR CURRENT BALANCE\n\n" f"
💵 TOTAL: {format_balance(balance)} BDT
", parse_mode="HTML", reply_markup=InlineKeyboardMarkup([[ InlineKeyboardButton("💸 WITHDRAW", callback_data="withdraw_start", style="primary") ]]) ) return if text == "REFER AND EARN" and context.user_data.get("account_menu"): await refer_command(update, context) return # SEARCH OTP if text == "SEARCH OTP": context.user_data["mode"] = "search_otp" await update.message.reply_text("🔍 **ENTER THE NUMBER TO SEARCH OTP:**", parse_mode="Markdown") return if context.user_data.get("mode") == "search_otp": context.user_data["mode"] = None await request_queue.put({'type': 'search_otp', 'update': update, 'context': context, 'target_num': normalize_number(text)}) return # GET 2FA if text == "GET 2FA": await get_2fa_code(update, context) return # GET NUMBER if text == "GET NUMBER": await show_app_selection(update, context) return if context.user_data.get("mode") == "get_2fa": await process_2fa_key(update, context) return # LEADERBOARD if text == "LEADERBOARD": await leaderboard_command(update, context) return # SUPPORT BUTTON HANDLER if text == "SUPPORT": if is_admin(uid): await update.message.reply_text( "💬 SUPPORT CHAT\n\n" "User-এর message-এর উপর সরাসরি Reply করলে উত্তরটি সেই user-এর কাছে যাবে।", parse_mode="HTML", reply_markup=main_keyboard(uid), ) return context.user_data["support_mode"] = True await update.message.reply_text( "💬 SUPPORT CHAT\n\n" "আপনার সমস্যা বা message লিখে পাঠান। " "আমি সেটি admin-এর কাছে পাঠিয়ে দেব।", parse_mode="HTML", reply_markup=cancel_keyboard(), ) return # Admin panel if text == "ADMIN PANEL" and is_admin(uid): context.user_data["admin_mode"] = "main" await update.message.reply_text( "⌬━━━━━━━━━━━━━━━━━━━━⌬\n WELCOME ADMIN PANEL\n⌬━━━━━━━━━━━━━━━━━━━━⌬", reply_markup=admin_main_keyboard() ) return if text == "BACK TO MAIN" and context.user_data.get("admin_mode"): context.user_data["admin_mode"] = None await update.message.reply_text("🔙 Back to main menu.", reply_markup=main_keyboard(uid)) return if text == "BACK TO ADMIN": context.user_data["user_management_mode"] = None context.user_data["system_config_mode"] = None context.user_data["bot_settings_mode"] = None context.user_data["voltx_config_mode"] = None context.user_data["service_mgmt_mode"] = None context.user_data["withdrawal_admin_mode"] = None context.user_data["admin_mode"] = "main" await update.message.reply_text("🔙 Back to admin panel.", reply_markup=admin_main_keyboard()) return if text == "SUPPORT CHAT" and context.user_data.get("admin_mode") == "main" and is_admin(uid): await update.message.reply_text( "💬 SUPPORT CHAT\n\n" "User-এর message-এর উপর সরাসরি Reply করুন। " "আপনার reply automatically সেই user-এর কাছে চলে যাবে।", parse_mode="HTML", reply_markup=admin_main_keyboard(), ) return if text == "WITHDRAWAL MANAGEMENT" and context.user_data.get("admin_mode") == "main" and is_admin(uid): context.user_data["withdrawal_admin_mode"] = "main" await update.message.reply_text( "💸 WITHDRAWAL MANAGEMENT\n\n" f"📉 Current minimum: {get_min_withdraw():.2f} BDT", parse_mode="HTML", reply_markup=withdrawal_management_keyboard(), ) return # Direct PENDING WITHDRAWALS from admin_main_keyboard (no sub-mode required) if text == "⏳ PENDING WITHDRAWALS" and is_admin(uid): await show_pending_withdrawals(update, context) return if text == "PENDING WITHDRAWALS" and context.user_data.get("withdrawal_admin_mode") == "main" and is_admin(uid): await show_pending_withdrawals(update, context) return if text == "SET MINIMUM WITHDRAW" and context.user_data.get("withdrawal_admin_mode") == "main" and is_admin(uid): context.user_data["withdrawal_admin_mode"] = "set_minimum" await update.message.reply_text( f"📉 SET MINIMUM WITHDRAW\n\n" f"Current amount: {get_min_withdraw():.2f} BDT\n\n" "নতুন minimum amount BDT-তে লিখে পাঠান:", parse_mode="HTML", reply_markup=cancel_keyboard(), ) return if context.user_data.get("withdrawal_admin_mode") == "set_minimum" and is_admin(uid): try: new_minimum = float(text) except ValueError: await update.message.reply_text( "❌ সঠিক amount দিন, যেমন: 50 বা 100", reply_markup=cancel_keyboard(), ) return if new_minimum <= 0 or new_minimum > MAX_WITHDRAW: await update.message.reply_text( f"❌ Amount 0-এর বেশি এবং {MAX_WITHDRAW} BDT-এর মধ্যে হতে হবে।", reply_markup=cancel_keyboard(), ) return settings = load_settings() settings["min_withdraw"] = new_minimum save_settings(settings) context.user_data["withdrawal_admin_mode"] = "main" await update.message.reply_text( f"✅ MINIMUM WITHDRAW UPDATED\n" f"New minimum: {new_minimum:.2f} BDT", parse_mode="HTML", reply_markup=withdrawal_management_keyboard(), ) return if text == "USER MANAGEMENT" and context.user_data.get("admin_mode") == "main" and is_admin(uid): context.user_data["user_management_mode"] = "main" await update.message.reply_text("👥 User Management:", reply_markup=user_management_keyboard()) return if text == "SYSTEM CONFIGURATION" and context.user_data.get("admin_mode") == "main" and is_admin(uid): context.user_data["system_config_mode"] = "main" await update.message.reply_text("⚙️ System Configuration:", reply_markup=system_config_keyboard()) return if text == "TODAY ALL STATUS" and context.user_data.get("system_config_mode") == "main" and is_admin(uid): t_n, t_o, s_n, s_o, tot_n, tot_o = get_global_system_stats() msg = ( f"📊 SYSTEM STATUS\n━━━━━━━━━━━━━━━━━━━━━━\n\n" f"✨ TODAY\n📱 NUMBERS: {t_n}\n🔑 OTPS: {t_o}\n\n" f"🔥 LAST 7 DAYS\n📱 NUMBERS: {s_n}\n🔑 OTPS: {s_o}\n\n" f"🌐 ALL TIME\n📱 NUMBERS: {tot_n}\n🔑 OTPS: {tot_o}" ) await update.message.reply_text(msg, parse_mode="HTML") return if text == "USER STATUS CHECK" and is_admin(uid): context.user_data["mode"] = "input_user_id" await update.message.reply_text("🔍 ENTER TELEGRAM ID:", reply_markup=cancel_keyboard()) return if context.user_data.get("mode") == "input_user_id" and is_admin(uid): target_uid = text.strip() if not target_uid.isdigit(): await update.message.reply_text("❌ INVALID ID!") return context.user_data["mode"] = None stats = get_user_stats(target_uid) msg = ( f"👤 USER STATUS — {target_uid}\n━━━━━━━━━━━━━━━━━━━━━━\n\n" f"✨ TODAY: 📱 {stats['today_numbers']} | 🔑 {stats['today_otps']}\n" f"🔥 7 DAYS: 📱 {stats['last7d_numbers']} | 🔑 {stats['last7d_otps']}\n" f"🌐 ALL TIME: 📱 {stats['total_numbers']} | 🔑 {stats['total_otps']}" ) await update.message.reply_text( msg, parse_mode="HTML", reply_markup=InlineKeyboardMarkup([[ InlineKeyboardButton("📂 CHECK ALL DATA", callback_data=f"full_logs_{target_uid}", style="primary") ]]) ) return if text == "ALL USER ID" and context.user_data.get("user_management_mode") == "main" and is_admin(uid): users = get_all_users() if users: content = "\n".join(f"{i}. {u}" for i, u in enumerate(users, 1)) f = io.BytesIO(content.encode()); f.name = f"ALL_USERS_{len(users)}.txt" await update.message.reply_document(document=f, caption=f"👥 Total Users: {len(users)}", reply_markup=user_management_keyboard()) else: await update.message.reply_text("No users found.", reply_markup=user_management_keyboard()) return if text == "ALL USER BALANCE" and context.user_data.get("user_management_mode") == "main" and is_admin(uid): user_db = load_data(USER_DATA_FILE) if user_db: total_bal = sum(v.get("balance", 0) for v in user_db.values()) lines = [f"{i}. {uid_}: {v.get('balance', 0):.2f} BDT" for i, (uid_, v) in enumerate(user_db.items(), 1)] content = f"💰 TOTAL BALANCE: {total_bal:.2f} BDT\n\n" + "\n".join(lines) f = io.BytesIO(content.encode()); f.name = f"BALANCES_{total_bal:.0f}.txt" await update.message.reply_document(document=f, caption=f"💵 Total Balance: {total_bal:.2f} BDT", reply_markup=user_management_keyboard()) else: await update.message.reply_text("No data.", reply_markup=user_management_keyboard()) return if text == "BAN USER LIST" and is_admin(uid): await show_banned_users_list(update, context) return if text == "BAN USER" and context.user_data.get("system_config_mode") == "main" and is_admin(uid): await admin_ban_user_start(update, context) return if text == "UNBAN USER" and context.user_data.get("system_config_mode") == "main" and is_admin(uid): await admin_unban_user_start(update, context) return if text == "ADD BALANCE" and context.user_data.get("system_config_mode") == "main" and is_admin(uid): await admin_add_balance_start(update, context) return if text == "REMOVE BALANCE" and context.user_data.get("system_config_mode") == "main" and is_admin(uid): await admin_remove_balance_start(update, context) return # ==================== FIXED BROADCAST (TEXT, PHOTO, VIDEO, FILE, ETC.) ==================== if text == "SEND MESSAGE TO ALL USERS" and is_admin(uid): context.user_data["broadcast_mode"] = True await update.message.reply_text( "📢 ADMIN BROADCAST SYSTEM (PRO)\n\n" "💬 আপনি এখন যা পাঠাবেন (Text, Photo, Video, Document, Voice, Audio, Animation, Sticker) – সকল ইউজারের কাছে প্রফেশনাল হেডারসহ চলে যাবে।\n\n" "✨ রেঞ্জ (যেমন: 237XXX) থাকলে তা অটোমেটিক ক্লিক-টু-কপি হয়ে যাবে।", parse_mode="HTML", reply_markup=cancel_keyboard() ) return if context.user_data.get("broadcast_mode") and is_admin(uid): context.user_data["broadcast_mode"] = False user_db = load_data(USER_DATA_FILE) all_uids = list(user_db.keys()) if not all_uids: await update.message.reply_text("❌ পাঠানোর জন্য কোনো ইউজার পাওয়া যায়নি!") return success_ids, fail_ids = [], [] status_msg = await update.message.reply_text(f"🚀 ব্রডকাস্ট শুরু হয়েছে...\n🎯 টার্গেট: {len(all_uids)} জন ইউজার।", parse_mode="HTML") def format_broadcast_caption(caption_text): if not caption_text: return "
📢 ADMIN NOTICE :
" formatted = re.sub(r'(\d{3,}[xX]{3,})', r'\1', str(caption_text)) return f"
📢 ADMIN NOTICE :
\n\n{formatted}" for user_id_str in all_uids: try: target_id = int(user_id_str) # টেক্সট মেসেজ if update.message.text: await context.bot.send_message( chat_id=target_id, text=format_broadcast_caption(update.message.text), parse_mode="HTML" ) # ফটো elif update.message.photo: caption = format_broadcast_caption(update.message.caption) if update.message.caption else None await context.bot.send_photo( chat_id=target_id, photo=update.message.photo[-1].file_id, caption=caption, parse_mode="HTML" if caption else None ) # ভিডিও elif update.message.video: caption = format_broadcast_caption(update.message.caption) if update.message.caption else None await context.bot.send_video( chat_id=target_id, video=update.message.video.file_id, caption=caption, parse_mode="HTML" if caption else None ) # ডকুমেন্ট (যেকোনো ফাইল) elif update.message.document: caption = format_broadcast_caption(update.message.caption) if update.message.caption else None await context.bot.send_document( chat_id=target_id, document=update.message.document.file_id, caption=caption, parse_mode="HTML" if caption else None ) # অডিও elif update.message.audio: caption = format_broadcast_caption(update.message.caption) if update.message.caption else None await context.bot.send_audio( chat_id=target_id, audio=update.message.audio.file_id, caption=caption, parse_mode="HTML" if caption else None ) # ভয়েস elif update.message.voice: caption = format_broadcast_caption(update.message.caption) if update.message.caption else None await context.bot.send_voice( chat_id=target_id, voice=update.message.voice.file_id, caption=caption, parse_mode="HTML" if caption else None ) # অ্যানিমেশন (GIF) elif update.message.animation: caption = format_broadcast_caption(update.message.caption) if update.message.caption else None await context.bot.send_animation( chat_id=target_id, animation=update.message.animation.file_id, caption=caption, parse_mode="HTML" if caption else None ) # স্টিকার elif update.message.sticker: await context.bot.send_sticker( chat_id=target_id, sticker=update.message.sticker.file_id ) # অন্য সব কিছু (ফরোয়ার্ড/কপি) else: try: await context.bot.copy_message( chat_id=target_id, from_chat_id=update.message.chat_id, message_id=update.message.message_id ) except: await context.bot.send_message( chat_id=target_id, text="📢 ADMIN NOTICE :\n\nআপনার জন্য একটি নতুন বার্তা আছে, কিন্তু এটি প্রদর্শন করা সম্ভব হয়নি।", parse_mode="HTML" ) success_ids.append(user_id_str) except Exception as e: print(f"Broadcast fail to {user_id_str}: {e}") fail_ids.append(user_id_str) await asyncio.sleep(0.05) report_text = ( f"✅ ADMIN NOTICE COMPLETE !\n\n" f"📊 BROADCAST REPORT:\n\n" f"
✅ SUCCESSFULLY SENT: {len(success_ids)} USERS !
\n" f"
❌ FAILED TO SEND: {len(fail_ids)} USERS !
" ) await status_msg.delete() await context.bot.send_message(chat_id=uid, text=report_text, parse_mode="HTML", reply_markup=main_keyboard(uid)) random_suffix = ''.join(random.choices(string.ascii_uppercase + string.digits, k=5)) if success_ids: s_file = io.BytesIO(("\n".join(success_ids)).encode()); s_file.name = f"SUCCESS_{random_suffix}.txt" await context.bot.send_document(chat_id=uid, document=s_file, caption="✅ Success User List") if fail_ids: f_file = io.BytesIO(("\n".join(fail_ids)).encode()); f_file.name = f"FAILED_{random_suffix}.txt" await context.bot.send_document(chat_id=uid, document=f_file, caption="❌ Failed User List") return # ==================== BOT SETTINGS NAVIGATION ==================== if text == "BOT SETTINGS" and context.user_data.get("admin_mode") == "main" and is_admin(uid): context.user_data["bot_settings_mode"] = "main" context.user_data["voltx_config_mode"] = None await update.message.reply_text("⚙️ BOT SETTINGS", parse_mode="HTML", reply_markup=bot_settings_keyboard()) return if text == "BACK TO BOT SETTINGS" and is_admin(uid): context.user_data["bot_settings_mode"] = "main" context.user_data["voltx_config_mode"] = None await update.message.reply_text("⚙️ BOT SETTINGS", parse_mode="HTML", reply_markup=bot_settings_keyboard()) return if text == "VOLTX CONFIG" and context.user_data.get("bot_settings_mode") == "main" and is_admin(uid): context.user_data["voltx_config_mode"] = "main" await update.message.reply_text("📡 VOLTX PANEL CONFIG", parse_mode="HTML", reply_markup=voltx_config_keyboard()) return if text == "SERVICE MANAGEMENT" and context.user_data.get("admin_mode") == "main" and is_admin(uid): context.user_data["service_mgmt_mode"] = "main" await update.message.reply_text("🔧 SERVICE MANAGEMENT", parse_mode="HTML", reply_markup=service_management_keyboard()) return # ==================== ADD / REMOVE ADMIN ==================== if text == "ADD ADMIN" and context.user_data.get("bot_settings_mode") == "main" and is_admin(uid): context.user_data["bot_settings_mode"] = "add_admin" s = load_settings() admin_list = "\n".join(f"• {a}" for a in s.get("admins", [])) await update.message.reply_text( f"➕ ADD ADMIN\n\n
Current admins:\n{admin_list}
\n\n" f"Send the Telegram User ID to add as admin:", parse_mode="HTML", reply_markup=cancel_keyboard()) return if context.user_data.get("bot_settings_mode") == "add_admin" and is_admin(uid): if not text.lstrip("-").isdigit(): await update.message.reply_text("❌ Invalid ID! Send a numeric Telegram ID.") return new_admin_id = int(text) s = load_settings() admins = s.get("admins", []) if new_admin_id in admins: await update.message.reply_text("⚠️ This user is already an admin!", reply_markup=bot_settings_keyboard()) else: admins.append(new_admin_id) s["admins"] = admins save_settings(s) await update.message.reply_text( f"✅ ADMIN ADDED!\n
🆔 ID: {new_admin_id}
", parse_mode="HTML", reply_markup=bot_settings_keyboard()) context.user_data["bot_settings_mode"] = "main" return if text == "REMOVE ADMIN" and context.user_data.get("bot_settings_mode") == "main" and is_admin(uid): context.user_data["bot_settings_mode"] = "remove_admin" s = load_settings() admin_list = "\n".join(f"• {a}" for a in s.get("admins", [])) await update.message.reply_text( f"➖ REMOVE ADMIN\n\n
Current admins:\n{admin_list}
\n\n" f"Send the Telegram User ID to remove from admin:", parse_mode="HTML", reply_markup=cancel_keyboard()) return if context.user_data.get("bot_settings_mode") == "remove_admin" and is_admin(uid): if not text.lstrip("-").isdigit(): await update.message.reply_text("❌ Invalid ID! Send a numeric Telegram ID.") return rem_id = int(text) s = load_settings() admins = s.get("admins", []) owners = s.get("owners", []) if rem_id in owners and rem_id == uid: await update.message.reply_text("❌ Cannot remove yourself (owner)!", reply_markup=bot_settings_keyboard()) elif rem_id not in admins: await update.message.reply_text("⚠️ This user is not an admin!", reply_markup=bot_settings_keyboard()) else: admins.remove(rem_id) s["admins"] = admins save_settings(s) await update.message.reply_text( f"✅ ADMIN REMOVED!\n
🆔 ID: {rem_id}
", parse_mode="HTML", reply_markup=bot_settings_keyboard()) context.user_data["bot_settings_mode"] = "main" return # ==================== SET OTP GROUP LINK ==================== if text == "SET OTP GROUP LINK" and context.user_data.get("bot_settings_mode") == "main" and is_admin(uid): context.user_data["bot_settings_mode"] = "set_otp_link" s = load_settings() cur = s.get("otp_group_url", "Not set") await update.message.reply_text( f"🔗 SET OTP GROUP LINK\n\n
Current: {cur}
\n\n" f"Send the new OTP group invite link (e.g. https://t.me/+xxxxx):", parse_mode="HTML", reply_markup=cancel_keyboard()) return if context.user_data.get("bot_settings_mode") == "set_otp_link" and is_admin(uid): s = load_settings() s["otp_group_url"] = text.strip() save_settings(s) await update.message.reply_text( f"✅ OTP GROUP LINK UPDATED!\n
{html.escape(text.strip())}
", parse_mode="HTML", reply_markup=bot_settings_keyboard()) context.user_data["bot_settings_mode"] = "main" return # ==================== SET FORCE JOIN CHANNEL ==================== if text == "SET FORCE CHANNEL" and context.user_data.get("bot_settings_mode") == "main" and is_admin(uid): context.user_data["bot_settings_mode"] = "set_force_channel" s = load_settings() cur = s.get("force_join_channel") or "Not set (disabled)" await update.message.reply_text( f"📢 SET FORCE JOIN CHANNEL\n\n
Current: {cur}
\n\n" f"Send channel username (e.g. @mychannel) or DISABLE to turn off:", parse_mode="HTML", reply_markup=cancel_keyboard()) return if context.user_data.get("bot_settings_mode") == "set_force_channel" and is_admin(uid): s = load_settings() val = text.strip() if val.upper() == "DISABLE": s["force_join_channel"] = None await update.message.reply_text("✅ Force Join DISABLED!", parse_mode="HTML", reply_markup=bot_settings_keyboard()) else: if not val.startswith("@") and not val.lstrip("-").isdigit(): val = "@" + val s["force_join_channel"] = val await update.message.reply_text( f"✅ FORCE JOIN CHANNEL SET!\n
{html.escape(val)}
", parse_mode="HTML", reply_markup=bot_settings_keyboard()) save_settings(s) context.user_data["bot_settings_mode"] = "main" return # ==================== SET OTP FORWARD CHAT ID ==================== if text == "SET OTP CHAT ID" and context.user_data.get("bot_settings_mode") == "main" and is_admin(uid): context.user_data["bot_settings_mode"] = "set_otp_chat_id" s = load_settings() cur = s.get("otp_group_chat_id") or "Not set" await update.message.reply_text( f"📋 SET OTP FORWARD CHAT ID\n\n
Current: {cur}
\n\n" f"Send the Chat ID where OTPs are forwarded (e.g. -1001234567890):\n" f"Or send DISABLE to clear:", parse_mode="HTML", reply_markup=cancel_keyboard()) return if context.user_data.get("bot_settings_mode") == "set_otp_chat_id" and is_admin(uid): s = load_settings() val = text.strip() if val.upper() == "DISABLE": s["otp_group_chat_id"] = None await update.message.reply_text("✅ OTP Chat ID CLEARED!", parse_mode="HTML", reply_markup=bot_settings_keyboard()) elif val.lstrip("-").isdigit(): s["otp_group_chat_id"] = int(val) await update.message.reply_text( f"✅ OTP CHAT ID SET!\n
{val}
", parse_mode="HTML", reply_markup=bot_settings_keyboard()) else: await update.message.reply_text("❌ Invalid! Send a numeric chat ID (e.g. -1001234567890)") return save_settings(s) context.user_data["bot_settings_mode"] = "main" return # ==================== VOLTX CONFIG HANDLERS ==================== if text == "SET API KEY" and context.user_data.get("voltx_config_mode") == "main" and is_admin(uid): context.user_data["voltx_config_mode"] = "set_api_key" s = load_settings() cur = s.get("voltx_api_key", "Not set") await update.message.reply_text( f"🔑 SET VOLTX API KEY\n\n
Current: {cur[:20]}...
\n\nSend new API key:", parse_mode="HTML", reply_markup=cancel_keyboard()) return if context.user_data.get("voltx_config_mode") == "set_api_key" and is_admin(uid): s = load_settings() s["voltx_api_key"] = text.strip() save_settings(s) await update.message.reply_text( f"✅ VOLTX API KEY UPDATED!\n
{html.escape(text.strip()[:20])}...
", parse_mode="HTML", reply_markup=voltx_config_keyboard()) context.user_data["voltx_config_mode"] = "main" return if text == "SET BASE URL" and context.user_data.get("voltx_config_mode") == "main" and is_admin(uid): context.user_data["voltx_config_mode"] = "set_base_url" s = load_settings() cur = s.get("voltx_base_url", "Not set") await update.message.reply_text( f"🌐 SET VOLTX BASE URL\n\n
Current: {cur}
\n\nSend new base URL (e.g. https://api.2oo9.cloud/MXS47FLFX0U/tnevs/@public/api):", parse_mode="HTML", reply_markup=cancel_keyboard()) return if context.user_data.get("voltx_config_mode") == "set_base_url" and is_admin(uid): s = load_settings() s["voltx_base_url"] = text.strip().rstrip("/") save_settings(s) await update.message.reply_text( f"✅ BASE URL UPDATED!\n
{html.escape(s['voltx_base_url'])}
", parse_mode="HTML", reply_markup=voltx_config_keyboard()) context.user_data["voltx_config_mode"] = "main" return if text == "SET ALLOWED SERVICES" and context.user_data.get("voltx_config_mode") == "main" and is_admin(uid): context.user_data["voltx_config_mode"] = "set_services" s = load_settings() cur = ", ".join(s.get("allowed_services", [])) await update.message.reply_text( f"📋 SET ALLOWED VOLTX SERVICES\n\n
Current:\n{cur}
\n\n" f"Send comma-separated list:\ne.g. Instagram,Facebook,WhatsApp,TikTok", parse_mode="HTML", reply_markup=cancel_keyboard()) return if context.user_data.get("voltx_config_mode") == "set_services" and is_admin(uid): services = [x.strip() for x in text.split(",") if x.strip()] s = load_settings() s["allowed_services"] = services save_settings(s) _ranges_cache["data"] = {} _ranges_cache["updated_at"] = 0 svc_text = "\n".join(f"• {sv}" for sv in services) await update.message.reply_text( f"✅ ALLOWED SERVICES UPDATED!\n\n
{svc_text}
", parse_mode="HTML", reply_markup=voltx_config_keyboard()) context.user_data["voltx_config_mode"] = "main" return if text == "VIEW VOLTX CONFIG" and context.user_data.get("voltx_config_mode") == "main" and is_admin(uid): s = load_settings() api_key = s.get("voltx_api_key", "N/A") base_url = s.get("voltx_base_url", "N/A") services = ", ".join(s.get("allowed_services", [])) otp_link = s.get("otp_group_url", "N/A") force_ch = s.get("force_join_channel") or "Disabled" otp_chat = s.get("otp_group_chat_id") or "Not set" msg = ( f"📡 VOLTX PANEL CONFIGURATION\n━━━━━━━━━━━━━━━━━━━━━━\n\n" f"
🔑 API KEY: {html.escape(api_key[:30])}...
\n" f"
🌐 BASE URL: {html.escape(base_url)}
\n" f"
📋 ALLOWED SERVICES:\n{html.escape(services)}
\n" f"
🔗 OTP GROUP LINK: {html.escape(otp_link)}
\n" f"
📢 FORCE CHANNEL: {html.escape(str(force_ch))}
\n" f"
📋 OTP CHAT ID: {otp_chat}
" ) await update.message.reply_text(msg, parse_mode="HTML", reply_markup=voltx_config_keyboard()) return # ==================== SERVICE MANAGEMENT HANDLERS ==================== if text == "LIST SERVICES" and context.user_data.get("service_mgmt_mode") == "main" and is_admin(uid): s = load_settings() manual = s.get("manual_services", []) if not manual: await update.message.reply_text("📋 No manual services added yet.", reply_markup=service_management_keyboard()) else: lines = [] for i, svc in enumerate(manual): countries = svc.get("countries", []) clines = "\n".join( f" {c.get('flag','🌍')} {c.get('name','?')} — {', '.join(c.get('ranges',[]))}" for c in countries ) lines.append(f"{i+1}. {html.escape(svc['name'])}\n{clines}") msg = f"📋 MANUAL SERVICES ({len(manual)})\n━━━━━━━━━━━━━━━━━━━━━━\n\n" + "\n\n".join(lines) await update.message.reply_text(msg, parse_mode="HTML", reply_markup=service_management_keyboard()) return # ── ADD SERVICE: Step 1 — Service Name ── if text == "ADD SERVICE" and context.user_data.get("service_mgmt_mode") == "main" and is_admin(uid): context.user_data["service_mgmt_mode"] = "add_name" await update.message.reply_text( "➕ ADD MANUAL SERVICE\n\n" "
Step 1: Send the Service Name\n" "e.g. FACEBOOK, WHATSAPP, INSTAGRAM
", parse_mode="HTML", reply_markup=cancel_keyboard()) return if context.user_data.get("service_mgmt_mode") == "add_name" and is_admin(uid): context.user_data["new_svc_name"] = text.strip().upper() context.user_data["new_svc_countries"] = [] context.user_data["service_mgmt_mode"] = "add_country" await update.message.reply_text( f"➕ {html.escape(context.user_data['new_svc_name'])}\n\n" f"
Step 2: Send the Country Name\n" f"e.g. Bangladesh, Nigeria, India
\n\n" f"Send country name ↓", parse_mode="HTML", reply_markup=cancel_keyboard()) return # ── ADD SERVICE: DONE — save service (must be checked BEFORE add_country handler) ── if text == "DONE" and context.user_data.get("service_mgmt_mode") == "add_country" and is_admin(uid): svc_name = context.user_data.get("new_svc_name") countries_done = context.user_data.get("new_svc_countries", []) if not svc_name or not countries_done: await update.message.reply_text("❌ No data to save. Start again.", reply_markup=service_management_keyboard()) context.user_data["service_mgmt_mode"] = "main" return s = load_settings() manual = s.get("manual_services", []) manual.append({"name": svc_name, "countries": countries_done}) s["manual_services"] = manual save_settings(s) done_lines = "\n".join(f" {c['flag']} {c['name']} — {', '.join(c['ranges'])}" for c in countries_done) await update.message.reply_text( f"✅ SERVICE SAVED!\n\n" f"
📱 {html.escape(svc_name)}\n{done_lines}
", parse_mode="HTML", reply_markup=service_management_keyboard()) context.user_data["service_mgmt_mode"] = "main" for k in ["new_svc_name", "new_svc_countries", "new_svc_cur_country"]: context.user_data.pop(k, None) return # ── ADD SERVICE: Step 2 — Country Name ── if context.user_data.get("service_mgmt_mode") == "add_country" and is_admin(uid): country_name = text.strip().title() context.user_data["new_svc_cur_country"] = country_name context.user_data["service_mgmt_mode"] = "add_range" svc_name = context.user_data.get("new_svc_name", "?") countries_done = context.user_data.get("new_svc_countries", []) done_text = "" if countries_done: done_text = "\n\n
✅ Already added:\n" + "\n".join( f" {c['flag']} {c['name']}" for c in countries_done) + "
" await update.message.reply_text( f"➕ {html.escape(svc_name)} — 🌍 {html.escape(country_name)}{done_text}\n\n" f"
Step 3: Send the Range for {html.escape(country_name)}\n\n" f"Format: Country Code + XXX\n" f"🇧🇩 Bangladesh → 880XXX\n" f"🇳🇬 Nigeria → 234XXX\n" f"🇮🇳 India → 91XXXXX\n" f"🇲🇾 Malaysia → 60XXXXX\n" f"🇮🇩 Indonesia → 62XXXXX\n\n" f"Multiple ranges: 880XXX, 8801XXX
", parse_mode="HTML", reply_markup=cancel_keyboard()) return # ── ADD SERVICE: Step 3 — Ranges for that country ── if context.user_data.get("service_mgmt_mode") == "add_range" and is_admin(uid): raw_ranges = [r.strip().upper() for r in text.split(",") if r.strip()] country_name = context.user_data.get("new_svc_cur_country", "Unknown") # Detect flag from first range flag, detected = "🌍", country_name if raw_ranges: import re as _re prefix = _re.sub(r'[xX]+$', '', raw_ranges[0]).strip() pfx_d = _re.sub(r'\D', '', prefix) flag, detected = get_country_info(pfx_d) countries_done = context.user_data.get("new_svc_countries", []) countries_done.append({"name": country_name, "flag": flag, "ranges": raw_ranges}) context.user_data["new_svc_countries"] = countries_done context.user_data["service_mgmt_mode"] = "add_country" context.user_data.pop("new_svc_cur_country", None) ranges_text = ", ".join(raw_ranges) done_lines = "\n".join(f" {c['flag']} {c['name']} — {', '.join(c['ranges'])}" for c in countries_done) await update.message.reply_text( f"✅ {flag} {html.escape(country_name)} added!\n" f"
Ranges: {html.escape(ranges_text)}
\n\n" f"
Countries so far:\n{done_lines}
\n\n" f"Send another Country Name to add more,\n" f"or send DONE to save the service.", parse_mode="HTML", reply_markup=cancel_keyboard()) return if text == "REMOVE SERVICE" and context.user_data.get("service_mgmt_mode") == "main" and is_admin(uid): s = load_settings() manual = s.get("manual_services", []) if not manual: await update.message.reply_text("📋 No services to remove.", reply_markup=service_management_keyboard()) return lines = "\n".join(f"{i+1}. {html.escape(svc['name'])}" for i, svc in enumerate(manual)) context.user_data["service_mgmt_mode"] = "remove" await update.message.reply_text( f"➖ REMOVE SERVICE\n\n
{lines}
\n\n" f"Send the number of the service to remove:", parse_mode="HTML", reply_markup=cancel_keyboard()) return if context.user_data.get("service_mgmt_mode") == "remove" and is_admin(uid): if not text.isdigit(): await update.message.reply_text("❌ Send a valid number from the list.") return idx = int(text) - 1 s = load_settings() manual = s.get("manual_services", []) if idx < 0 or idx >= len(manual): await update.message.reply_text(f"❌ Invalid number! Choose 1-{len(manual)}.") return removed = manual.pop(idx) s["manual_services"] = manual save_settings(s) await update.message.reply_text( f"✅ SERVICE REMOVED!\n
📱 {html.escape(removed['name'])}
", parse_mode="HTML", reply_markup=service_management_keyboard()) context.user_data["service_mgmt_mode"] = "main" return return # Force join check for regular users if not is_admin(uid): if not await check_force_join(update, context): return await update.message.reply_text("🔹 PLEASE USE THE BUTTONS BELOW:", reply_markup=main_keyboard(uid)) # ==================== COMMAND HANDLERS SECTION ==================== async def get1number_command(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id if is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return await show_app_selection(update, context) async def searchotp_command(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id if is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return context.user_data["mode"] = "search_otp" await update.message.reply_text("🔍 **ENTER THE NUMBER TO SEARCH OTP:**", parse_mode="Markdown") async def balance_command(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id if is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return balance = get_user(uid)['balance'] await update.message.reply_text(f"💰 BALANCE: `{format_balance(balance)} BDT`", parse_mode="Markdown", reply_markup=main_keyboard(uid)) async def profile_command(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id if is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return user_data = get_user(uid) stats = get_user_stats(uid) user = update.effective_user profile_text = ( f"👤 **YOUR PROFILE**\n━━━━━━━━━━━━━━━━━━━━━━\n\n" f"🏷️ NAME: `{user.full_name}`\n" f"🆔 USERNAME: @{user.username or 'No username'}\n" f"🗝️ ID: `{uid}`\n\n" f"💵 BALANCE: {format_balance(user_data.get('balance', 0))} BDT\n\n" f"✨ TODAY: 📱 {stats['today_numbers']} | 🔑 {stats['today_otps']}\n" f"🔥 7 DAYS: 📱 {stats['last7d_numbers']} | 🔑 {stats['last7d_otps']}\n" f"🌐 ALL TIME: 📱 {stats['total_numbers']} | 🔑 {stats['total_otps']}" ) await update.message.reply_text(profile_text, parse_mode="Markdown") async def refer_command_slash(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id if is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return await refer_command(update, context) async def leaderboard_command_slash(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id if is_user_banned(uid): await update.message.reply_text("🚫 YOU ARE BANNED 🚫", reply_markup=main_keyboard(uid)) return await leaderboard_command(update, context) # ==================== START & CALLBACK SECTION ==================== async def check_force_join(update, context): """Returns True if user is allowed to proceed. False if they need to join first.""" s = load_settings() channel = s.get("force_join_channel") if not channel: return True uid = update.effective_user.id if is_admin(uid): return True try: member = await context.bot.get_chat_member(channel, uid) if member.status in ("member", "administrator", "creator", "restricted"): return True except Exception: pass channel_clean = str(channel).lstrip("@") try: chat = await context.bot.get_chat(channel) invite_url = chat.invite_link or f"https://t.me/{channel_clean}" except Exception: invite_url = f"https://t.me/{channel_clean}" btn = InlineKeyboardMarkup([[ InlineKeyboardButton("✅ JOIN CHANNEL", url=invite_url, style="primary") ]]) await update.message.reply_text( f"⚠️ FORCE JOIN REQUIRED!\n\n" f"
বট ব্যবহার করতে আগে আমাদের চ্যানেলে জয়েন করুন।\n" f"জয়েন করার পর আবার চেষ্টা করুন।
", parse_mode="HTML", reply_markup=btn ) return False async def start(update: Update, context: ContextTypes.DEFAULT_TYPE): uid = update.effective_user.id uid_str = str(uid) existing_data = load_data(USER_DATA_FILE) is_new_user = uid_str not in existing_data if is_new_user: get_user(uid) args = context.args if args: param = args[0] if is_range_request(param): await request_queue.put({'type': 'auto_number', 'update': update, 'context': context, 'range_text': param}) return elif is_referral_request(param) and is_new_user: try: referrer_id = int(param) if referrer_id != uid and str(referrer_id) in existing_data: current_count = get_referral_count(referrer_id) new_count = current_count + 1 update_referral_count(referrer_id, new_count) await update_db_balance(referrer_id, REFERRAL_PRICE) log_global_activity(referrer_id, "REFERRAL_JOINED", {"referred_user": uid}) try: await context.bot.send_message( referrer_id, f"🎉 NEW REFERRAL!\n\n
🗝️ ID: {uid}\n💰 REWARD: {format_balance(REFERRAL_PRICE)} BDT\n👥 TOTAL REFERS: {new_count}
", parse_mode="HTML" ) except: pass except Exception as e: print(f"Referral error: {e}") if not await check_force_join(update, context): return context.user_data.clear() await update.message.reply_text(WELCOME_MESSAGE, parse_mode="Markdown") await update.message.reply_text("🔹 PLEASE USE THE BUTTONS BELOW:", reply_markup=main_keyboard(uid)) async def button_callback(update: Update, context: ContextTypes.DEFAULT_TYPE): query = update.callback_query uid = query.from_user.id data = query.data await query.answer() if not is_admin(uid) and is_user_banned(uid): await query.edit_message_text("🚫 YOU ARE BANNED 🚫") return # Admin support reply button. if data.startswith("support_reply_"): if not is_admin(uid): await query.answer("Only admins can reply to support messages.", show_alert=True) return target_uid_text = data.replace("support_reply_", "", 1) if not target_uid_text.isdigit(): await query.answer("Invalid support user.", show_alert=True) return target_uid = int(target_uid_text) context.user_data["support_reply_uid"] = target_uid await query.message.reply_text( f"✍️ REPLYING TO USER {target_uid}\n\n" "এখন আপনার reply লিখে পাঠান।", parse_mode="HTML", reply_markup=cancel_keyboard(), ) return # VOLTX — APP SELECTION if data.startswith("sel_app_"): app_name = data[8:] top = context.user_data.get("top_ranges_by_app") or (_ranges_cache.get("data") or {}) if not top or app_name not in top: await query.answer("App not found. Please try again.", show_alert=True); return ranges = top[app_name].get("ranges", []) if not ranges: await query.answer("No ranges available for this app right now.", show_alert=True); return context.user_data["sel_app"] = app_name context.user_data["sel_ranges"] = ranges btns, seen = [], {} clrs = ["primary"] ci = 0 for i, r in enumerate(ranges[:24]): prefix = re.sub(r'[xX]+$', '', str(r)).strip() pfx_d = re.sub(r'\D', '', prefix) flag, cname = get_country_info(pfx_d) label = f"{flag} {cname}" if label not in seen: seen[label] = i btns.append(InlineKeyboardButton(label, callback_data=f"sel_rng_{i}", api_kwargs={"style": clrs[ci % len(clrs)]})) ci += 1 rows = [btns[j:j+2] for j in range(0, len(btns), 2)] rows.append([InlineKeyboardButton("\u25c0\ufe0f BACK", callback_data="back_apps", api_kwargs={"style": "primary"})]) await query.message.edit_text( f'{get_tg_emoji("get_number_btn")} SELECT COUNTRY\n' f'\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\n' f'
\U0001f4f1 App: {html.escape(app_name)}
\n' f'
\U0001f30d Select your Country:
', parse_mode="HTML", reply_markup=InlineKeyboardMarkup(rows)) return # VOLTX — RANGE SELECTION if data.startswith("sel_rng_"): idx = int(data[8:]) ranges = context.user_data.get("sel_ranges", []) app_name = context.user_data.get("sel_app", "") if idx >= len(ranges): await query.answer("Range not found. Please try again.", show_alert=True); return asyncio.create_task(fast_allocate_number(query, context, ranges[idx], app_name)) return # CUSTOM RANGE if data == "custom_range": context.user_data["mode"] = "custom_range" await query.message.edit_text( "\u2699\ufe0f CUSTOM RANGE\n\n" "
\U0001f4f6 Type your custom range.\n" "Example: 234XXX or 225XXX
\n\n" "
\u2328\ufe0f Type range below and Send:
", parse_mode="HTML", reply_markup=InlineKeyboardMarkup([[ InlineKeyboardButton("\u25c0\ufe0f BACK", callback_data="back_apps", api_kwargs={"style": "primary"}) ]])) return # MANUAL SERVICE — Step 1: show countries if data.startswith("manual_svc_"): idx = int(data[len("manual_svc_"):]) s = load_settings() manual = s.get("manual_services", []) if idx >= len(manual): await query.answer("Service not found.", show_alert=True); return svc = manual[idx] countries = svc.get("countries", []) if not countries: await query.answer("No countries added for this service yet.", show_alert=True); return clrs = ["primary"] btns = [] for ci, c in enumerate(countries): flag = c.get("flag", "🌍") cname = c.get("name", "Unknown") btns.append(InlineKeyboardButton( f"{flag} {cname}", callback_data=f"manual_cnt_{idx}_{ci}", api_kwargs={"style": clrs[ci % len(clrs)]} )) rows = [btns[j:j+2] for j in range(0, len(btns), 2)] rows.append([InlineKeyboardButton( "\u25c0\ufe0f BACK", callback_data="back_apps", api_kwargs={"style": "primary"} )]) await query.message.edit_text( f'\U0001f527 {html.escape(svc["name"])}\n' f'\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\n' f'
\U0001f4f1 App: {html.escape(svc["name"])}
\n' f'
\U0001f30d Select your Country:
', parse_mode="HTML", reply_markup=InlineKeyboardMarkup(rows) ) return # MANUAL SERVICE — Step 2: country selected → directly allocate number if data.startswith("manual_cnt_"): parts = data.split("_") svc_idx = int(parts[2]) cnt_idx = int(parts[3]) s = load_settings() manual = s.get("manual_services", []) if svc_idx >= len(manual): await query.answer("Service not found.", show_alert=True); return svc = manual[svc_idx] countries = svc.get("countries", []) if cnt_idx >= len(countries): await query.answer("Country not found.", show_alert=True); return country = countries[cnt_idx] ranges = country.get("ranges", []) if not ranges: await query.answer("No ranges for this country.", show_alert=True); return import random range_text = random.choice(ranges).strip().upper() svc_name = svc["name"] asyncio.create_task(fast_allocate_number(query, context, range_text, svc_name)) return # MANUAL SERVICE — Step 3: range selected → allocate number if data.startswith("manual_rng_"): parts = data.split("_") svc_idx = int(parts[2]) cnt_idx = int(parts[3]) rng_idx = int(parts[4]) s = load_settings() manual = s.get("manual_services", []) if svc_idx >= len(manual): await query.answer("Service not found.", show_alert=True); return countries = manual[svc_idx].get("countries", []) if cnt_idx >= len(countries): await query.answer("Country not found.", show_alert=True); return ranges = countries[cnt_idx].get("ranges", []) if rng_idx >= len(ranges): await query.answer("Range not found.", show_alert=True); return range_text = ranges[rng_idx].strip().upper() svc_name = manual[svc_idx]["name"] asyncio.create_task(fast_allocate_number(query, context, range_text, svc_name)) return # BACK TO APP LIST if data in ("back_apps", "back_services"): top = context.user_data.get("top_ranges_by_app") or (_ranges_cache.get("data") or {}) manual_rows = build_manual_service_buttons() voltx_rows = build_app_buttons_from_cache(top) if top else [] all_rows = voltx_rows + manual_rows all_rows.append([InlineKeyboardButton("\u2699\ufe0f CUSTOM RANGE", callback_data="custom_range", api_kwargs={"style": "primary"})]) msg = f'{get_tg_emoji("get_number_btn")} SELECT APP TO GET NUMBER\n\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501\u2501' await query.message.edit_text(msg, parse_mode="HTML", reply_markup=InlineKeyboardMarkup(all_rows)) return if data == "same_range": r_text = last_range.get(uid) if r_text: try: await query.message.edit_reply_markup(reply_markup=InlineKeyboardMarkup([[ InlineKeyboardButton("📢 OTP GROUP", url="https://t.me/volt_x_lite_otp", style="primary") ]])) except: pass await process_numbers(update, context, r_text, 1) return # WITHDRAW if data == "withdraw_start": balance = get_user(uid)['balance'] min_withdraw = get_min_withdraw() if balance < min_withdraw: await query.message.reply_text( f"
💵 BALANCE: {format_balance(balance)} BDT\n📉 MIN WITHDRAW: {min_withdraw:.2f} BDT
", parse_mode="HTML" ) return context.user_data["withdraw_mode"] = "select_method" await query.message.reply_text("💳 SELECT YOUR PAYMENT METHOD!", reply_markup=withdraw_method_keyboard()) return if data == "withdraw_confirm": await process_withdraw_confirm(update, context) return if data == "withdraw_cancel": await process_withdraw_cancel(update, context) return if data == "withdraw_admin_back": await query.message.edit_text( "💸 WITHDRAWAL MANAGEMENT\n\n" f"📉 Current minimum: {get_min_withdraw():.2f} BDT", parse_mode="HTML", reply_markup=InlineKeyboardMarkup([[ InlineKeyboardButton("🔙 BACK TO ADMIN", callback_data="withdraw_admin_close", style="primary") ]]), ) return if data == "withdraw_admin_close": await query.message.edit_text("🔙 Open the Admin Panel menu to continue.") return if data.startswith("admin_approve_"): if not is_admin(uid): await query.answer("Admin access required.", show_alert=True) return await admin_approve_withdraw(update, context, data.replace("admin_approve_", "")) return if data.startswith("admin_reject_"): if not is_admin(uid): await query.answer("Admin access required.", show_alert=True) return await admin_reject_withdraw(update, context, data.replace("admin_reject_", "")) return # COPY / MISC CALLBACKS if data.startswith("copy_id_"): await query.answer(f"✅ Copied ID: {data.replace('copy_id_', '')}", show_alert=True) return if data.startswith("copy_text_"): await query.answer(f"✅ Copied: {data.replace('copy_text_', '')}", show_alert=True) return if data.startswith("my_ref_"): target_uid = data.replace("my_ref_", "") all_logs = load_data(ACTIVITY_LOGS_FILE) my_referrals = [log for log in all_logs if str(log.get('uid')) == str(target_uid) and log.get('action') == "REFERRAL_JOINED"] content = f"👥 REFERRAL REPORT — {target_uid}\n━━━━━━━━━━━━\nTOTAL: {len(my_referrals)}\n\n" for i, log in enumerate(my_referrals, 1): try: dt_obj = datetime.fromisoformat(log['timestamp']) ref_id = log.get('details', {}).get('referred_user', 'N/A') content += f"{i}. ID: {ref_id} | {dt_obj.strftime('%d/%m/%Y %I:%M %p')}\n" except: continue f = io.BytesIO(content.encode()) f.name = f"REF_{target_uid}.txt" await context.bot.send_document(chat_id=uid, document=f, caption="✅ **REFERRAL DATA**", parse_mode="Markdown") return if data.startswith("full_logs_"): target_uid = data.replace("full_logs_", "") stats = get_user_stats(target_uid) all_logs = load_data(ACTIVITY_LOGS_FILE) user_db = load_data(USER_DATA_FILE) user_info = user_db.get(str(target_uid), {}) user_otps = [log for log in all_logs if str(log.get('uid')) == str(target_uid) and log.get('action') == "OTP_RECEIVED"] content = ( f"📊 USER DATA REPORT — {target_uid}\n" f"💰 BALANCE: {user_info.get('balance', 0):.2f} BDT\n" f"━━━━━━━━━━━━━━━━━━\n" f"TODAY NUMBERS: {stats['today_numbers']}\n" f"TODAY OTPS: {stats['today_otps']}\n" f"7D NUMBERS: {stats['last7d_numbers']}\n" f"7D OTPS: {stats['last7d_otps']}\n" f"TOTAL NUMBERS: {stats['total_numbers']}\n" f"TOTAL OTPS: {stats['total_otps']}\n" f"━━━━━━━━━━━━━━━━━━\n\nOTP LOGS:\n" ) for i, log in enumerate(user_otps, 1): try: dt_obj = datetime.fromisoformat(log['timestamp']) d = log.get('details', {}) content += f"{i}. {dt_obj.strftime('%d/%m/%Y %I:%M %p')}\n 📞 {d.get('number', 'N/A')}\n 🔑 {d.get('otp', 'N/A')}\n\n" except: continue f = io.BytesIO(content.encode()) f.name = f"USER_{target_uid}.txt" await context.bot.send_document( chat_id=uid, document=f, caption=f"✅ DATA FOR USER: {target_uid}", parse_mode="HTML" ) return # ==================== MAIN & POST INIT SECTION ==================== async def post_init(application): for _ in range(MAX_WORKERS): asyncio.create_task(worker()) asyncio.create_task(monitor_loop(application)) asyncio.create_task(_bg_refresh_ranges()) async def post_shutdown(application): await client_async.aclose() def main(): if not BOT_TOKEN or BOT_TOKEN == "PASTE_NEW_TELEGRAM_BOT_TOKEN_HERE": raise RuntimeError( "BOT_TOKEN is not configured. Open bot.py and replace " "PASTE_NEW_TELEGRAM_BOT_TOKEN_HERE with your new token." ) app = ( ApplicationBuilder() .token(BOT_TOKEN) .concurrent_updates(True) .post_init(post_init) .post_shutdown(post_shutdown) .build() ) app.add_handler(CommandHandler("start", start)) app.add_handler(CommandHandler("get1number", get1number_command)) app.add_handler(CommandHandler("searchotp", searchotp_command)) app.add_handler(CommandHandler("balance", balance_command)) app.add_handler(CommandHandler("profile", profile_command)) app.add_handler(CommandHandler("refer", refer_command_slash)) app.add_handler(CommandHandler("leaderboard", leaderboard_command_slash)) app.add_handler(CallbackQueryHandler(button_callback)) app.add_handler(MessageHandler(filters.TEXT & (~filters.COMMAND), handle_message)) print("🚀 BOT RUNNING...") app.run_polling(allowed_updates=Update.ALL_TYPES, drop_pending_updates=True) if __name__ == "__main__": import asyncio asyncio.set_event_loop(asyncio.new_event_loop()) main()