Stbemu Codes And | Xtream Codes - Telegram Channel

# Get available code code = db.get_active_xtream_code() if not code: await update.callback_query.edit_message_text( "❌ No Xtream codes available at the moment.\n" "Please try again later." ) return

message = "📋 *Your Active Codes:*\n\n" for code_type, code_id, expires_at in active_codes: if code_type == 'xtream': code_data = db.get_active_xtream_code() if code_data: _, server, username, password, _, _ = code_data message += f"*Xtream Code:*\n" message += f"├ Server: `{server}`\n" message += f"├ User: `{username}`\n" message += f"└ Expires: {expires_at.strftime('%Y-%m-%d %H:%M')}\n\n" else: code_data = db.get_active_stbemu_code() if code_data: _, mac, server, portal, _ = code_data message += f"*STBEmu Code:*\n" message += f"├ MAC: `{mac}`\n" message += f"├ Portal: `{server}`\n" message += f"└ Expires: {expires_at.strftime('%Y-%m-%d %H:%M')}\n\n"

portal_info = f"🎮 *Portal:* {portal_name}" if portal_name else "" Stbemu Codes and Xtream Codes - Telegram channel

def create_tables(self): cursor = self.conn.cursor() # Xtream Codes table cursor.execute(''' CREATE TABLE IF NOT EXISTS xtream_codes ( id INTEGER PRIMARY KEY AUTOINCREMENT, server_url TEXT NOT NULL, username TEXT NOT NULL, password TEXT NOT NULL, max_connections INTEGER DEFAULT 1, expiry_date TIMESTAMP, status TEXT DEFAULT 'active', created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ) ''') # STBEmu Codes table (MAC-based) cursor.execute(''' CREATE TABLE IF NOT EXISTS stbemu_codes ( id INTEGER PRIMARY KEY AUTOINCREMENT, mac_address TEXT UNIQUE NOT NULL, server_url TEXT NOT NULL, portal_name TEXT, expiry_date TIMESTAMP, status TEXT DEFAULT 'active', created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP ) ''') # User requests table cursor.execute(''' CREATE TABLE IF NOT EXISTS user_requests ( id INTEGER PRIMARY KEY AUTOINCREMENT, telegram_id TEXT NOT NULL, code_type TEXT NOT NULL, assigned_code_id INTEGER, assigned_at TIMESTAMP, expires_at TIMESTAMP, status TEXT DEFAULT 'active' ) ''') self.conn.commit()

await update.callback_query.edit_message_text( message, parse_mode='Markdown' ) async def show_help(update: Update, context: ContextTypes.DEFAULT_TYPE): """Show help information""" help_text = """ ❓ Help & Support # Get available code code = db

Validity: Codes are valid for 24 hours from assignment

if update.callback_query: await update.callback_query.edit_message_text(help_text, parse_mode='Markdown') else: await update.message.reply_text(help_text, parse_mode='Markdown') async def add_xtream(update: Update, context: ContextTypes.DEFAULT_TYPE): """Admin: Add new Xtream code (format: /add_xtream url username password days)""" if update.effective_user.id not in ADMIN_IDS: await update.message.reply_text("⛔ Admin only command!") return server_url TEXT NOT NULL

# Check for active codes active_codes = db.get_user_active_codes(user_id) if active_codes: await update.callback_query.edit_message_text( "⚠️ You already have active codes!" ) return