Upload 2 files

app.py

@@ -1333,6 +1333,7 @@ def _build_video(vpath, cmb, mpath, ad, vd, crop, flip, col, wmk, out_file,
         f'-filter_complex "{filter_complex}" '
         f'-map "[v_final]" -map "[outa]" '
         f'-c:v libx264 -crf 24 -preset ultrafast -pix_fmt yuv420p '
+        f'-threads 0 '
         f'-c:a aac -ar 44100 -b:a 128k '
         f'-t {ad:.3f} -movflags +faststart "{out_file}"'
     )

bot.py

@@ -1,536 +1,968 @@
 """
 Recap Studio — Telegram Bot
-Features:
-  • User: Login, Auto-process, Voice, Settings, Coins, Payment submit, Payment history
-  • Admin: Pending payments, Approve/Reject, Add/Set coins, User list, Broadcast
 """
-
-import os, json, uuid, re, time, logging, threading
-import urllib.request, urllib.parse
-from datetime import datetime
+import os, sys, json, uuid, glob, shutil, logging, threading, time, re, subprocess
 from pathlib import Path
 
-logging.basicConfig(level=logging.INFO, format='%(asctime)s %(levelname)s %(message)s')
-log = logging.getLogger(__name__)
-
-# ══════════════════════════════════════════════
-#  CONFIG
-# ══════════════════════════════════════════════
-BOT_TOKEN      = os.getenv('TELEGRAM_BOT_TOKEN', '')
-ADMIN_CHAT_ID  = os.getenv('ADMIN_TELEGRAM_CHAT_ID', '')   # numeric chat id
-APP_BASE_URL   = os.getenv('APP_BASE_URL', 'https://ai.psonline.shop')
-ADMIN_USERNAME = os.getenv('ADMIN_USERNAME', '')
-ADMIN_PASSWORD = os.getenv('ADMIN_PASSWORD', '')
-
-BASE_DIR         = Path(__file__).parent
-DB_FILE          = str(BASE_DIR / 'users_db.json')
-PAYMENTS_DB_FILE = str(BASE_DIR / 'payments_db.json')
+logging.basicConfig(format='%(asctime)s [%(levelname)s] %(name)s: %(message)s', level=logging.INFO)
+logger = logging.getLogger(__name__)
+
+from telegram import Update, InlineKeyboardButton, InlineKeyboardMarkup, ReplyKeyboardMarkup, KeyboardButton
+from telegram.ext import Application, CommandHandler, MessageHandler, CallbackQueryHandler, ConversationHandler, filters, ContextTypes
+from telegram.constants import ParseMode
+
+sys.path.insert(0, str(Path(__file__).parent))
+from app import (
+    login_user, get_coins, deduct, load_db, save_db,
+    gen_uname, create_user_fn, add_coins_fn, set_coins_fn,
+    call_api, parse_out, split_txt, dur,
+    run_tts_sync, run_gemini_tts_sync,
+    #ytdlp_download, cpu_queue_wait, upd_stat,
+    _build_video, ADMIN_U, SYS_MOVIE, SYS_MED, BASE_DIR, OUTPUT_DIR,
+    NUM_TO_MM_RULE, run_stage, ytdlp_download, upd_stat,
+    load_payments_db, save_payments_db,
+    TELEGRAM_BOT_TOKEN, ADMIN_TELEGRAM_CHAT_ID,
+)
+
+try:
+    import whisper as whisper_mod
+except ImportError:
+    whisper_mod = None
+
+BOT_TOKEN = os.getenv('TELEGRAM_BOT_TOKEN', '')
+ADMIN_TG_USERNAME = os.getenv('ADMIN_TG_USERNAME', 'PhoeShan2001')
+WEB_BASE_URL = os.getenv('WEB_BASE_URL', 'https://recap.psonline.shop')
+TG_MAX_FILE_BYTES = 49 * 1024 * 1024  # 49 MB — Telegram bot upload limit
+
+(ST_MAIN, ST_LOGIN_USER, ST_LOGIN_PASS, ST_AWAIT_VIDEO) = range(4)
+
+sessions = {}
+_whisper_model = [None]
+_wm_lock = threading.Lock()
+cancel_flags = {}
+
+# ── Per-user busy flag (one job at a time) ──
+user_busy   = {}   # cid -> bool
+_busy_lock  = threading.Lock()
+
+def is_processing(cid):
+    with _busy_lock:
+        return user_busy.get(cid, False)
+
+def set_processing(cid, val):
+    with _busy_lock:
+        user_busy[cid] = val
+
+def start_job(bot, cid, pending_url, pending_file_id, prog_msg_id):
+    """Start processing in background thread."""
+    threading.Thread(
+        target=_process_thread,
+        args=(bot, cid, prog_msg_id, pending_url, pending_file_id),
+        daemon=True
+    ).start()
+
+MS_VOICES = [
+    ('Thiha (ကျား)', 'my-MM-ThihaNeural', 'ms'),
+    ('Nilar (မိန်း)', 'my-MM-NilarNeural', 'ms'),
+]
 
-API = f'https://api.telegram.org/bot{BOT_TOKEN}'
+GEMINI_VOICES = [
+    ('Kore','Kore','gemini'),('Charon','Charon','gemini'),('Fenrir','Fenrir','gemini'),
+    ('Leda','Leda','gemini'),('Orus','Orus','gemini'),('Puck','Puck','gemini'),
+    ('Aoede','Aoede','gemini'),('Zephyr','Zephyr','gemini'),('Achelois','Achelois','gemini'),
+    ('Pegasus','Pegasus','gemini'),('Perseus','Perseus','gemini'),('Schedar','Schedar','gemini'),
+]
 
 PACKAGES = [
-    {'coins': 10,  'price': '10,000 MMK'},
-    {'coins': 30,  'price': '28,000 MMK'},
-    {'coins': 60,  'price': '58,000 MMK'},
-    {'coins': 100, 'price': '95,000 MMK'},
+    (10, 10000, 'Process 5 ကြိမ်'),
+    (20, 18000, 'Process 10 ကြိမ် — အကောင်းဆုံး'),
+    (30, 28000, 'Process 15 ကြိမ်'),
 ]
-KBZ_NAME   = 'PHOE SHAN'
-KBZ_NUMBER = '09679871352'
-
-# Per-user state: {'step': ..., 'data': {...}}
-_state: dict = {}
-_state_lock = threading.Lock()
 
-def get_state(cid):
-    with _state_lock:
-        return _state.get(str(cid), {})
+# pending_payment[cid] = {'coins': int, 'price': int}  — slip စောင့်နေစဉ်
+pending_payment = {}
+
+# ── HELPERS ──
+
+def sess(cid):
+    if cid not in sessions:
+        sessions[cid] = {
+            'username': None, 'coins': 0, 'is_admin': False,
+            'voice': 'my-MM-ThihaNeural', 'engine': 'ms',
+            'speed': 30, 'crop': 'original',
+            'flip': False, 'color': False,
+            'watermark': '', 'content_type': 'Movie Recap',
+            'ai_model': 'Gemini',
+            'pending_url': None, 'pending_file_id': None,
+            'music_file_id': None,
+        }
+    s = sessions[cid]
+    # Auto-sync coins from DB so admin top-ups reflect without re-login
+    if s.get('username'):
+        try:
+            fresh = get_coins(s['username'])
+            if fresh is not None:
+                s['coins'] = fresh
+        except Exception:
+            pass
+    return s
+
+def is_logged(cid): return sess(cid).get('username') is not None
+def fmt_coins(c): return '∞' if c == -1 else str(c)
+
+def main_kb(cid):
+    s = sess(cid)
+    rows = [
+        [KeyboardButton('🎬 Auto Process'), KeyboardButton('🔊 အသံ')],
+        [KeyboardButton('⚙️ Settings'),     KeyboardButton('👤 အကောင့်')],
+        [KeyboardButton('🛒 Coins ဝယ်ရန်'), KeyboardButton('🔄 Reset')],
+    ]
+    if s.get('is_admin'):
+        rows.append([KeyboardButton('👑 Admin')])
+    rows.append([KeyboardButton('🚪 Logout')])
+    return ReplyKeyboardMarkup(rows, resize_keyboard=True)
+
+def ensure_whisper():
+    with _wm_lock:
+        if _whisper_model[0] is None and whisper_mod:
+            _whisper_model[0] = whisper_mod.load_model('tiny', device='cpu')
+    return _whisper_model[0]
+
+def settings_kb(cid):
+    s = sess(cid)
+    crop_labels = {'original':'🎬 Original','9:16':'📱 9:16','16:9':'🖥️ 16:9','1:1':'⬛ 1:1'}
+    return InlineKeyboardMarkup([
+        [InlineKeyboardButton(f"📐 Crop: {crop_labels.get(s['crop'],s['crop'])}", callback_data='set|crop')],
+        [InlineKeyboardButton(f"🤖 AI: {s['ai_model']}", callback_data='set|ai'),
+         InlineKeyboardButton(f"📺 {s['content_type'].split('/')[0]}", callback_data='set|ct')],
+        [InlineKeyboardButton(f"Flip: {'ON' if s['flip'] else 'OFF'}", callback_data='set|flip'),
+         InlineKeyboardButton(f"Color: {'ON' if s['color'] else 'OFF'}", callback_data='set|color')],
+        [InlineKeyboardButton(f"Speed: {s['speed']}%", callback_data='set|speed')],
+        [InlineKeyboardButton(f"Watermark: {s['watermark'] or 'မရှိ'}", callback_data='set|wmk')],
+        [InlineKeyboardButton(f"🎵 BG Music: {'✅ ပါမည်' if s.get('music_file_id') else '❌ မပါ'}", callback_data='set|music'),
+         InlineKeyboardButton('🗑️ Music ဖျက်', callback_data='set|music_del')],
+        [InlineKeyboardButton('✅ သိမ်းမည်', callback_data='set|done')],
+    ])
+
+def voice_kb():
+    btns = [[InlineKeyboardButton('── Microsoft TTS ──', callback_data='noop')]]
+    row = []
+    for name, vid, eng in MS_VOICES:
+        row.append(InlineKeyboardButton(name, callback_data=f'voice|{vid}|{eng}'))
+    btns.append(row)
+    btns.append([InlineKeyboardButton('── Gemini TTS ──', callback_data='noop')])
+    row = []
+    for name, vid, eng in GEMINI_VOICES:
+        row.append(InlineKeyboardButton(name, callback_data=f'voice|{vid}|{eng}'))
+        if len(row) == 3:
+            btns.append(row); row = []
+    if row: btns.append(row)
+    return InlineKeyboardMarkup(btns)
+
+def package_kb():
+    btns = []
+    for coins, price, desc in PACKAGES:
+        btns.append([InlineKeyboardButton(
+            f"🪙 {coins} Coins — {price:,} MMK  ({desc})",
+            callback_data=f'pkg|{coins}|{price}'
+        )])
+    return InlineKeyboardMarkup(btns)
+
+PAYMENT_INFO = (
+    "💳 *ငွေလွဲနည်း*\n\n"
+    "📱 KBZPay / Wave / AYA Pay\n\n"
+    "👤 *Phoe Shan*\n"
+    "📞 *09679871352* (Kapy)\n\n"
+    "ငွေလွဲပြီးနောက် slip ကို Admin ထံ ပို့ပေးပါ"
+)
+
+def cancel_kb():
+    return InlineKeyboardMarkup([[InlineKeyboardButton('❌ ဖျက်သိမ်းမည်', callback_data='cancel|process')]])
+
+# ── AUTH ──
+
+async def cmd_start(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    if is_logged(cid):
+        s = sess(cid)
+        await update.message.reply_text(
+            f"👋 ပြန်လာသည့်အတွက် ကြိုဆိုပါတယ် *{s['username']}*!\n🪙 Coins: *{fmt_coins(s['coins'])}*",
+            parse_mode=ParseMode.MARKDOWN, reply_markup=main_kb(cid))
+        return ST_MAIN
+    await update.message.reply_text(
+        "🎬 *Recap Studio Bot*\n\n"
+        "AI-Powered Video Recap Tool\n\n"
+        "━━━━━━━━━━━━━━━━━━━\n"
+        "👨‍💻 *Developer* — @PhoeShan2001\n"
+        "━━━━━━━━━━━━━━━━━━━\n\n"
+        "သင့် *username* ထည့်ပါ —",
+        parse_mode=ParseMode.MARKDOWN,
+        reply_markup=ReplyKeyboardMarkup(
+            [[KeyboardButton('/start')]],
+            resize_keyboard=True
+        ))
+    return ST_LOGIN_USER
+
+async def recv_login_user(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    ctx.user_data['login_user'] = update.message.text.strip()
+    await update.message.reply_text("🔑 *Password* ထည့်ပါ\n_(မရှိရင် `-` ပို့ပါ)_", parse_mode=ParseMode.MARKDOWN)
+    return ST_LOGIN_PASS
+
+async def recv_login_pass(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    u = ctx.user_data.get('login_user', '')
+    p = update.message.text.strip()
+    if p == '-': p = ''
+    ok, msg, coins = login_user(u, p)
+    if not ok:
+        await update.message.reply_text(f"❌ {msg}\n\n*Username* ထပ်ထည့်ပါ —", parse_mode=ParseMode.MARKDOWN)
+        return ST_LOGIN_USER
+    s = sess(cid)
+    s['username'] = u; s['coins'] = coins; s['is_admin'] = (u == ADMIN_U)
+    # Save Telegram chat ID for payment approve notifications
+    try:
+        db = load_db(); db['users'][u]['tg_chat_id'] = cid; save_db(db)
+    except: pass
+    await update.message.reply_text(
+        f"✅ *{u}* အနေဖြင့် ဝင်ရောက်ပြီးပါပြီ\n🪙 Coins: *{fmt_coins(coins)}*",
+        parse_mode=ParseMode.MARKDOWN, reply_markup=main_kb(cid))
+    return ST_MAIN
+
+async def cmd_logout(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    sessions.pop(update.effective_chat.id, None)
+    await update.message.reply_text("👋 Logout လုပ်ပြီးပါပြီ\n/start နှိပ်ပြီး ပြန်ဝင်ပါ",
+        reply_markup=ReplyKeyboardMarkup([[]], resize_keyboard=True))
+    return ConversationHandler.END
+
+# ── MENU BUTTONS ──
+
+async def btn_auto_process(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    if not is_logged(cid):
+        await update.message.reply_text("❌ /start နှိပ်ပြီး ဦးစွာ login ဝင်ပါ")
+        return ST_MAIN
+    s = sess(cid)
+    if s['coins'] != -1 and s['coins'] < 2:
+        await update.message.reply_text(
+            f"❌ Coins မလုံလောက်ဘူး\nသင့်မှာ *{s['coins']}* ရှိတယ် — *2* လိုတယ်\n\n🛒 Coins ဝယ်ရန် ခလုတ်နှိပ်ပါ",
+            parse_mode=ParseMode.MARKDOWN, reply_markup=main_kb(cid))
+        return ST_MAIN
+    cancel_flags[cid] = False
+    await update.message.reply_text(
+        "📥 *Auto Process* — 2 Coins ကုန်မည်\n\n"
+        "အောက်ပါ link တစ်ခုခု ပို့ပါ သို့မဟုတ် Video File တင်ပါ —\n\n"
+        "• YouTube\n• TikTok\n• Facebook\n• Instagram\n\n"
+        "_(ဖျက်သိမ်းလိုရင် ❌ နှိပ်ပါ)_",
+        parse_mode=ParseMode.MARKDOWN,
+        reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton('❌ ဖျက်သိမ်းမည်', callback_data='cancel|await')]]))
+    return ST_AWAIT_VIDEO
+
+async def btn_voice(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    s = sess(cid)
+    await update.message.reply_text(
+        f"🔊 *အသံ ရွေးချယ်ရန်*\n\nလက်ရှိ — *{s['voice']}* ({s['engine'].upper()})",
+        parse_mode=ParseMode.MARKDOWN, reply_markup=voice_kb())
+    return ST_MAIN
+
+async def btn_settings(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    await update.message.reply_text("⚙️ *Settings*", parse_mode=ParseMode.MARKDOWN, reply_markup=settings_kb(cid))
+    return ST_MAIN
+
+async def btn_account(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    if not is_logged(cid):
+        await update.message.reply_text("❌ /start နှိပ်ပါ")
+        return ST_MAIN
+    s = sess(cid); db = load_db(); u = db['users'].get(s['username'], {})
+    await update.message.reply_text(
+        f"👤 *ကိုယ့်အကောင့်*\n\nUsername: `{s['username']}`\n🪙 Coins: *{fmt_coins(s['coins'])}*\n"
+        f"🎬 Video: {u.get('total_videos',0)} ကြိမ်\n📝 Transcript: {u.get('total_transcripts',0)} ကြိမ်\n"
+        f"📅 စတင်သောနေ့: {u.get('created_at','')[:10]}",
+        parse_mode=ParseMode.MARKDOWN, reply_markup=main_kb(cid))
+    return ST_MAIN
+
+async def btn_reset(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    # Cancel any running process
+    if is_processing(cid):
+        cancel_flags[cid] = True
+    # Clear session state but keep login
+    s = sess(cid)
+    s['pending_url']     = None
+    s['pending_file_id'] = None
+    await update.message.reply_text(
+        "🔄 *Reset လုပ်ပြီးပါပြီ*\n\nဘာလုပ်မလဲ?",
+        parse_mode=ParseMode.MARKDOWN,
+        reply_markup=main_kb(cid)
+    )
+    return ST_MAIN
+
+async def btn_buy(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    s = sess(cid)
+    await update.message.reply_text(
+        f"🛒 *Coins ဝယ်ရန်*\n\n"
+        f"လက်ရှိ Coins: *{fmt_coins(s['coins'])}*\n\n"
+        f"{PAYMENT_INFO}\n\n"
+        f"Package တစ်ခု ရွေးပါ —",
+        parse_mode=ParseMode.MARKDOWN, reply_markup=package_kb())
+    return ST_MAIN
+
+async def btn_admin(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    s = sess(cid)
+    if not s.get('is_admin'):
+        await update.message.reply_text("❌ Admin သာ ဝင်ခွင့်ရှိသည်")
+        return ST_MAIN
+    db = load_db(); users = db.get('users', {})
+    lines = [f"👑 *Admin Panel* — {len(users)} ယောက်\n"]
+    for uname, udata in list(users.items())[:20]:
+        lines.append(f"• `{uname}` — 🪙{udata.get('coins',0)}")
+    await update.message.reply_text('\n'.join(lines), parse_mode=ParseMode.MARKDOWN,
+        reply_markup=InlineKeyboardMarkup([
+            [InlineKeyboardButton('➕ User ဖန်တီး', callback_data='adm|create'),
+             InlineKeyboardButton('🪙 Coins ထည့်', callback_data='adm|coins')],
+            [InlineKeyboardButton('🗑️ User ဖျက်', callback_data='adm|delete'),
+             InlineKeyboardButton('🔄 Refresh', callback_data='adm|refresh')],
+        ]))
+    return ST_MAIN
+
+# ── VIDEO INPUT ──
+
+async def recv_video_input(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    s = sess(cid)
+    if cancel_flags.get(cid):
+        await update.message.reply_text("⛔ ဖျက်သိမ်းပြီးပါပြီ", reply_markup=main_kb(cid))
+        return ST_MAIN
+    if update.message.text:
+        url = update.message.text.strip()
+        if not re.match(r'https?://', url):
+            await update.message.reply_text("❌ URL မမှန်ဘူး\nYouTube / TikTok / Facebook / Instagram link ပို့ပါ")
+            return ST_AWAIT_VIDEO
+        s['pending_url'] = url; s['pending_file_id'] = None
+    elif update.message.video or update.message.document:
+        media = update.message.video or update.message.document
+        s['pending_file_id'] = media.file_id; s['pending_url'] = None
+    else:
+        await update.message.reply_text("❌ URL သို့မဟုတ် Video File ပို့ပါ")
+        return ST_AWAIT_VIDEO
+    # ── Reject if already processing ──
+    if is_processing(cid):
+        await update.message.reply_text(
+            "⏳ *လုပ်ဆောင်နေဆဲဖြစ်သည်*\n\nပြီးမှ ထပ်ပို့ပါ",
+            parse_mode=ParseMode.MARKDOWN
+        )
+        return ST_MAIN
+
+    # ── Coin check before starting ──
+    fresh_coins = get_coins(s['username'])
+    if fresh_coins is not None:
+        s['coins'] = fresh_coins
+    if not s['is_admin'] and s['coins'] != -1 and s['coins'] < 2:
+        await update.message.reply_text(
+            f"❌ *Coins မလုံလောက်ဘူး*\n\n"
+            f"သင့်မှာ *{s['coins']}* ရှိတယ် — *2* လိုတယ်\n\n"
+            f"🛒 Coins ဝယ်ရန် ခလုတ်နှိပ်ပါ",
+            parse_mode=ParseMode.MARKDOWN, reply_markup=main_kb(cid)
+        )
+        return ST_MAIN
 
-def set_state(cid, step, **data):
-    with _state_lock:
-        _state[str(cid)] = {'step': step, 'data': data}
+    cancel_flags[cid] = False
+    prog_msg = await update.message.reply_text(
+        "⏳ *စတင်နေပါသည်…* ခနစောင့်ပါ",
+        parse_mode=ParseMode.MARKDOWN, reply_markup=cancel_kb()
+    )
+    start_job(ctx.bot, cid, s.get('pending_url'), s.get('pending_file_id'), prog_msg.message_id)
+    return ST_MAIN
 
-def clear_state(cid):
-    with _state_lock:
-        _state.pop(str(cid), None)
+# ── PROCESSING ──
 
-# ══════════════════════════════════════════════
-#  DB HELPERS
-# ══════════════════════════════════════════════
-def load_db():
+def _process_thread(bot, cid, prog_msg_id, pending_url=None, pending_file_id=None):
+    set_processing(cid, True)
+    import asyncio as _asyncio
+    loop = _asyncio.new_event_loop()
+    _asyncio.set_event_loop(loop)
     try:
-        with open(DB_FILE, encoding='utf-8') as f:
-            return json.load(f)
-    except:
-        return {'users': {}}
+        loop.run_until_complete(_do_process(bot, cid, prog_msg_id, pending_url, pending_file_id))
+    finally:
+        loop.close()
+        set_processing(cid, False)
+
+async def _do_process(bot, cid, prog_msg_id, pending_url=None, pending_file_id=None):
+    s = sess(cid)
+    tid = uuid.uuid4().hex[:8]
+    tmp_dir = str(BASE_DIR / f'temp_{tid}')
+    out_file = str(OUTPUT_DIR / f'final_{tid}.mp4')
+    os.makedirs(tmp_dir, exist_ok=True)
+
+    async def prog(text, show_cancel=False):
+        try:
+            await bot.edit_message_text(chat_id=cid, message_id=prog_msg_id, text=text,
+                parse_mode=ParseMode.MARKDOWN, reply_markup=cancel_kb() if show_cancel else None)
+        except Exception: pass
 
-def save_db(db):
-    with open(DB_FILE, 'w', encoding='utf-8') as f:
-        json.dump(db, f, ensure_ascii=False, indent=2)
+    def is_cancelled(): return cancel_flags.get(cid, False)
 
-def load_payments():
-    try:
-        with open(PAYMENTS_DB_FILE, encoding='utf-8') as f:
-            return json.load(f)
-    except:
-        return {'payments': []}
-
-def save_payments(db):
-    with open(PAYMENTS_DB_FILE, 'w', encoding='utf-8') as f:
-        json.dump(db, f, ensure_ascii=False, indent=2)
-
-def get_tg_session(cid):
-    """Return username linked to this telegram chat_id, or None."""
-    db = load_db()
-    cid_str = str(cid)
-    for uname, udata in db['users'].items():
-        if str(udata.get('tg_chat_id', '')) == cid_str:
-            return uname
-    return None
-
-def link_tg(username, cid):
-    db = load_db()
-    if username in db['users']:
-        db['users'][username]['tg_chat_id'] = str(cid)
-        save_db(db)
-
-def get_coins(username):
-    db = load_db()
-    return db['users'].get(username, {}).get('coins', 0)
-
-def add_coins(username, n):
-    db = load_db()
-    if username not in db['users']:
-        return False, 0
-    db['users'][username]['coins'] = db['users'][username].get('coins', 0) + int(n)
-    save_db(db)
-    return True, db['users'][username]['coins']
-
-def set_coins(username, n):
-    db = load_db()
-    if username not in db['users']:
-        return False, 0
-    db['users'][username]['coins'] = int(n)
-    save_db(db)
-    return True, int(n)
-
-import hashlib
-def hp(p): return hashlib.sha256(p.encode()).hexdigest()
-
-def verify_login(username, password):
-    if username == ADMIN_USERNAME and password == ADMIN_PASSWORD:
-        return True, True   # ok, is_admin
-    db = load_db()
-    if username not in db['users']:
-        return False, False
-    stored = db['users'][username].get('password', '')
-    if stored and stored != hp(password):
-        return False, False
-    return True, False
-
-# ══════════════════════════════════════════════
-#  TELEGRAM API HELPERS
-# ══════════════════════════════════════════════
-def tg(method, **params):
-    url = f'{API}/{method}'
-    data = json.dumps(params).encode()
-    req = urllib.request.Request(url, data=data, headers={'Content-Type': 'application/json'})
     try:
-        with urllib.request.urlopen(req, timeout=15) as r:
-            return json.loads(r.read())
+        # ── Coin check at start of each job (important for queued jobs) ──
+        if not s['is_admin']:
+            fresh = get_coins(s['username'])
+            if fresh is not None:
+                s['coins'] = fresh
+            if s['coins'] != -1 and s['coins'] < 2:
+                await prog(
+                    f"❌ *Coins မလုံလောက်ဘူး*\n\n"
+                    f"သင့်မှာ *{fmt_coins(s['coins'])}* ရှိတယ် — *2* လိုတယ်\n"
+                    f"🛒 Coins ဝယ်ပြီးနောက် ထပ်ကြိုးစားပါ"
+                )
+                return
+
+        await prog("📥 *အဆင့် 1/5* — Video ဒေါင်းလုပ် လုပ်နေသည်…", show_cancel=True)
+        vpath = None
+        if pending_file_id:
+            file_obj = await bot.get_file(pending_file_id)
+            vpath = f'{tmp_dir}/input.mp4'
+            await file_obj.download_to_drive(vpath)
+        elif pending_url:
+          #  cpu_queue_wait()
+            if is_cancelled(): await prog("⛔ ဖျက်သိမ်းပြီးပါပြီ"); return
+            ytdlp_download(f'{tmp_dir}/input.%(ext)s', pending_url)
+            found = glob.glob(f'{tmp_dir}/input.*')
+            if found: vpath = found[0]
+        if not vpath or not os.path.exists(vpath):
+            await prog("❌ Video ဒေါင်းလုပ် မအောင်မြင်ပါ"); return
+        if is_cancelled(): await prog("⛔ ဖျက်သိမ်းပြီးပါပြီ"); return
+
+        # Download background music if set
+        mpath = None
+        if s.get('music_file_id'):
+            try:
+                mfile = await bot.get_file(s['music_file_id'])
+                mpath = f'{tmp_dir}/bgmusic.mp3'
+                await mfile.download_to_drive(mpath)
+            except Exception:
+                mpath = None
+
+        await prog("🎙️ *အဆင့် 2/5* — Whisper ဖြင့် ကူးယူနေသည်…", show_cancel=True)
+        if whisper_mod is None: await prog("❌ Whisper မ install ရသေးပါ"); return
+        model = ensure_whisper()
+        res = run_stage('whisper', model.transcribe, 'bot', lambda p,m: None, '⏳ Whisper စောင့်နေသည်', '🎙️ Transcribing…', vpath, fp16=False)
+        tr = res['text']; src_lang = res.get('language', 'en')
+        if is_cancelled(): await prog("⛔ ဖျက်သိမ်းပြီးပါပြီ"); return
+
+        await prog(f"🤖 *အဆင့် 3/5* — {s['ai_model']} ဖြင့် Script ရေးနေသည်…", show_cancel=True)
+        sys_p = SYS_MED if s['content_type'] == 'Medical/Health' else SYS_MOVIE
+        sys_p = sys_p + '\n' + NUM_TO_MM_RULE
+        out_txt, _ = run_stage('ai', call_api, 'bot', lambda p,m: None, '⏳ AI စောင့်နေသည်', '🤖 AI Script…', [{'role':'system','content':sys_p},{'role':'user','content':f'Language:{src_lang}\n\n{tr}'}], api=s['ai_model'])
+        sc, caption_text, hashtags = parse_out(out_txt)
+        if is_cancelled(): await prog("⛔ ဖျက်သိမ်းပြီးပါပြီ"); return
+
+        await prog("🔊 *အဆင့် 4/5* — အသံ ထုတ်နေသည်…", show_cancel=True)
+        sentences = split_txt(sc)
+        import asyncio as _aio, functools as _ft
+        loop = _aio.get_running_loop()
+        if s['engine'] == 'gemini':
+            parts = await loop.run_in_executor(None, _ft.partial(
+                run_stage, 'tts', run_gemini_tts_sync, 'bot', lambda p,m: None, '⏳ TTS စောင့်နေသည်', '🔊 TTS…',
+                sentences, s['voice'], tmp_dir, speed=s['speed']))
+        else:
+            parts = await loop.run_in_executor(None, _ft.partial(
+                run_stage, 'tts', run_tts_sync, 'bot', lambda p,m: None, '⏳ TTS စောင့်နေသည်', '🔊 TTS…',
+                sentences, s['voice'], f'+{s["speed"]}%', tmp_dir))
+        cmb = f'{tmp_dir}/combined.mp3'; lst = f'{tmp_dir}/list.txt'
+        with open(lst, 'w') as lf:
+            for a in parts: lf.write(f"file '{os.path.abspath(a)}'\n")
+        subprocess.run(f'ffmpeg -y -f concat -safe 0 -i "{lst}" -af "silenceremove=start_periods=1:stop_periods=-1:stop_duration=0.1:stop_threshold=-50dB" -c:a libmp3lame -q:a 2 "{cmb}"', shell=True, check=True)
+        if is_cancelled(): await prog("⛔ ဖျက်သိမ်းပြီးပါပြီ"); return
+
+        await prog("🎬 *အဆင့် 5/5* — Video ပေါင်းစပ်နေသည်…")
+        vd = dur(vpath); ad = dur(cmb)
+        if vd <= 0: await prog("❌ Video duration ဖတ်မရပါ"); return
+        if ad <= 0: await prog("❌ Audio duration ဖတ်မရပါ"); return
+        _build_video(vpath, cmb, mpath, ad, vd, s['crop'], s['flip'], s['color'], s['watermark'], out_file)
+
+        if not s['is_admin']:
+            ok2, rem = deduct(s['username'], 2)
+            if ok2:
+                s['coins'] = rem; upd_stat(s['username'], 'tr'); upd_stat(s['username'], 'vd')
+
+        await prog("✅ ပြီးပါပြီ! ပို့နေသည်…")
+        file_size = os.path.getsize(out_file)
+        caption = (
+            f"🎬 *{caption_text}*\n\n{hashtags}\n\n"
+            f"🪙 ကျန် Coins: *{fmt_coins(s['coins'])}*"
+        )
+
+        send_file = out_file  # file to actually send
+
+        if file_size > TG_MAX_FILE_BYTES:
+            size_mb = file_size / (1024 * 1024)
+            await prog(f"📦 File ကြီးနေသည် ({size_mb:.1f} MB) — Compress လုပ်နေသည်…")
+            compressed_file = out_file.replace('.mp4', '_compressed.mp4')
+            try:
+                # Two-pass target: aim for 45 MB to stay safely under 49 MB limit
+                target_size_kb = 45 * 1024
+                # Get video duration for bitrate calculation
+                probe = subprocess.run(
+                    ['ffprobe', '-v', 'error', '-show_entries', 'format=duration',
+                     '-of', 'default=noprint_wrappers=1:nokey=1', out_file],
+                    capture_output=True, text=True
+                )
+                video_duration = float(probe.stdout.strip()) if probe.stdout.strip() else 60.0
+                # Target total bitrate (kbps), reserve 128kbps for audio
+                target_total_kbps = int((target_size_kb * 8) / video_duration)
+                video_kbps = max(target_total_kbps - 128, 200)
+                compress_cmd = (
+                    f'ffmpeg -y -i "{out_file}" '
+                    f'-c:v libx264 -b:v {video_kbps}k -preset fast -maxrate {video_kbps*2}k -bufsize {video_kbps*4}k '
+                    f'-c:a aac -b:a 128k '
+                    f'"{compressed_file}"'
+                )
+                subprocess.run(compress_cmd, shell=True, check=True,
+                               stdout=subprocess.DEVNULL, stderr=subprocess.DEVNULL)
+                compressed_size = os.path.getsize(compressed_file)
+                if compressed_size <= TG_MAX_FILE_BYTES:
+                    send_file = compressed_file
+                    logger.info(f"[{tid}] Compressed {size_mb:.1f}MB → {compressed_size/1024/1024:.1f}MB")
+                else:
+                    logger.warning(f"[{tid}] Compress မ��ောင်မြင် — {compressed_size/1024/1024:.1f}MB ကျန်နေသေးသည်")
+                    send_file = None  # fall through to link
+            except Exception as ce:
+                logger.warning(f"[{tid}] Compress error: {ce}")
+                send_file = None
+
+            if send_file is None:
+                # Compression failed or still too large — send link
+                file_name = Path(out_file).name
+                dl_url = f"{WEB_BASE_URL}/outputs/{file_name}"
+                await bot.send_message(
+                    chat_id=cid,
+                    text=(
+                        f"🎬 *{caption_text}*\n\n"
+                        f"{hashtags}\n\n"
+                        f"📦 File ကြီးသောကြောင့် ({size_mb:.1f} MB) တိုက်ရိုက် ပို့၍မရပါ\n\n"
+                        f"🔗 *Download Link:*\n`{dl_url}`\n\n"
+                        f"🪙 ကျန် Coins: *{fmt_coins(s['coins'])}*"
+                    ),
+                    parse_mode=ParseMode.MARKDOWN,
+                )
+                send_file = None  # skip video send below
+
+        if send_file is not None:
+            with open(send_file, 'rb') as vf:
+                await bot.send_video(
+                    chat_id=cid, video=vf, caption=caption,
+                    parse_mode=ParseMode.MARKDOWN, supports_streaming=True,
+                    read_timeout=300, write_timeout=300,
+                )
+        await bot.delete_message(chat_id=cid, message_id=prog_msg_id)
     except Exception as e:
-        log.error(f'tg({method}) error: {e}')
-        return {}
-
-def send(cid, text, markup=None, parse_mode='HTML'):
-    params = {'chat_id': cid, 'text': text, 'parse_mode': parse_mode}
-    if markup:
-        params['reply_markup'] = markup
-    return tg('sendMessage', **params)
-
-def send_photo(cid, photo_bytes, caption='', markup=None):
-    """Send photo via multipart upload."""
-    boundary = uuid.uuid4().hex
-    body = (
-        f'--{boundary}\r\n'
-        f'Content-Disposition: form-data; name="chat_id"\r\n\r\n'
-        f'{cid}\r\n'
-        f'--{boundary}\r\n'
-        f'Content-Disposition: form-data; name="caption"\r\n\r\n'
-        f'{caption}\r\n'
-        f'--{boundary}\r\n'
-        f'Content-Disposition: form-data; name="parse_mode"\r\n\r\nHTML\r\n'
-        f'--{boundary}\r\n'
-        f'Content-Disposition: form-data; name="photo"; filename="slip.jpg"\r\n'
-        f'Content-Type: image/jpeg\r\n\r\n'
-    ).encode() + photo_bytes + f'\r\n--{boundary}--\r\n'.encode()
-    if markup:
-        body = body[:-len(f'\r\n--{boundary}--\r\n'.encode())]
-        body += (
-            f'\r\n--{boundary}\r\n'
-            f'Content-Disposition: form-data; name="reply_markup"\r\n\r\n'
-            f'{json.dumps(markup)}\r\n'
-            f'--{boundary}--\r\n'
-        ).encode()
-    req = urllib.request.Request(
-        f'{API}/sendPhoto',
-        data=body,
-        headers={'Content-Type': f'multipart/form-data; boundary={boundary}'}
-    )
+        logger.exception(f'[{tid}] Error: {e}')
+        await prog(f"❌ Error: {e}")
+    finally:
+        shutil.rmtree(tmp_dir, ignore_errors=True)
+        s['pending_url'] = None; s['pending_file_id'] = None
+        cancel_flags.pop(cid, None)
+
+# ── CALLBACKS ──
+
+async def on_callback(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    q = update.callback_query
+    cid = q.message.chat_id
+    s = sess(cid)
     try:
-        with urllib.request.urlopen(req, timeout=20) as r:
-            return json.loads(r.read())
-    except Exception as e:
-        log.error(f'send_photo error: {e}')
-
-def edit(cid, mid, text, markup=None, parse_mode='HTML'):
-    params = {'chat_id': cid, 'message_id': mid, 'text': text, 'parse_mode': parse_mode}
-    if markup:
-        params['reply_markup'] = markup
-    tg('editMessageText', **params)
-
-def answer_cb(cb_id, text=''):
-    tg('answerCallbackQuery', callback_query_id=cb_id, text=text)
-
-def kb(*rows):
-    """Inline keyboard. Each row is list of (text, callback_data) tuples."""
-    return {'inline_keyboard': [[{'text': t, 'callback_data': d} for t, d in row] for row in rows]}
-
-def rkb(*rows):
-    """Reply keyboard."""
-    return {'keyboard': [[{'text': t} for t in row] for row in rows],
-            'resize_keyboard': True, 'one_time_keyboard': True}
-
-# ══════════════════════════════════════════════
-#  MENU BUILDERS
-# ══════════════════════════════════════════════
-def main_menu(cid):
-    uname = get_tg_session(cid)
-    is_admin = (uname == ADMIN_USERNAME)
-    if not uname:
-        send(cid, '👋 <b>Recap Studio Bot</b>\n\nသင့် account ကို ချိတ်ဆက်ပါ:',
-             rkb(['🔑 Login'], ['ℹ️ About']))
-        return
-    coins = get_coins(uname) if not is_admin else -1
-    coin_txt = '∞' if is_admin else str(coins)
-    txt = (f'👋 မင်္ဂလာပါ <b>{uname}</b>!\n'
-           f'🪙 Coins: <b>{coin_txt}</b>\n\n'
-           f'ဘာများ ကူညီပေးရမလဲ?')
-    rows = [['🎬 Video Process', '💰 Coins ဝယ်ရန်'],
-            ['📋 Payment မှတ်တမ်း', '⚙️ Settings'],
-            ['🚪 Logout']]
-    if is_admin:
-        rows.insert(1, ['👑 Admin Panel'])
-    send(cid, txt, rkb(*rows))
-
-def admin_menu(cid):
-    send(cid, '👑 <b>Admin Panel</b>\n\nဘာများ လုပ်မလဲ?',
-         rkb(['💳 Pending Payments', '👥 User List'],
-             ['➕ Add Coins', '📢 Broadcast'],
-             ['🔙 Main Menu']))
-
-# ══════════════════════════════════════════════
-#  PAYMENT HELPERS
-# ══════════════════════════════════════════════
-def fmt_payment(p, include_slip_hint=False):
-    status_emoji = {'pending': '⏳', 'approved': '✅', 'rejected': '❌'}.get(p['status'], '❓')
-    txt = (f'{status_emoji} <b>{p["status"].upper()}</b>\n'
-           f'🆔 <code>{p["id"]}</code>\n'
-           f'👤 <code>{p["username"]}</code>\n'
-           f'🪙 {p["coins"]} Coins — {p["price"]}\n'
-           f'📅 {p["created_at"][:16].replace("T"," ")}')
-    if p.get('admin_note'):
-        txt += f'\n📝 {p["admin_note"]}'
-    return txt
-
-def notify_admin_payment(p, slip_bytes=None):
-    """Send payment notification to admin."""
-    if not ADMIN_CHAT_ID:
-        return
-    markup = kb(
-        [(f'✅ Approve {p["coins"]} Coins', f'apv:{p["id"]}')],
-        [('❌ Reject', f'rej:{p["id"]}')]
-    )
-    caption = (f'💰 <b>New Payment Request</b>\n\n'
-               f'👤 User: <code>{p["username"]}</code>\n'
-               f'🪙 {p["coins"]} Coins — {p["price"]}\n'
-               f'🆔 <code>{p["id"]}</code>\n'
-               f'📅 {p["created_at"][:16].replace("T"," ")}')
-    if slip_bytes:
-        send_photo(ADMIN_CHAT_ID, slip_bytes, caption=caption, markup=markup)
-    else:
-        send(ADMIN_CHAT_ID, caption, markup=markup)
-
-def notify_user_payment(p, approved):
-    """Notify user when payment is approved/rejected."""
-    db = load_db()
-    udata = db['users'].get(p['username'], {})
-    cid = udata.get('tg_chat_id')
-    if not cid:
+        await q.answer()
+    except Exception:
+        pass
+    data = q.data
+
+    if data == 'noop': return
+
+    # ── Admin payment approve / reject (from admin chat) ──
+    if data.startswith('adm_pay|'):
+        parts = data.split('|')
+        action = parts[1]  # approve / reject
+        payment_id = parts[2]
+        username = parts[3]
+        from datetime import datetime as _dt
+        pdb = load_payments_db()
+        pay = next((p for p in pdb['payments'] if p['id'] == payment_id), None)
+        if not pay:
+            await q.answer("❌ Payment မတွေ့ပါ", show_alert=True)
+            return
+        if pay['status'] != 'pending':
+            await q.answer(f"⚠️ ဒီ payment {pay['status']} ဖြစ်ပြီးပြီ", show_alert=True)
+            return
+        if action == 'approve':
+            coins = int(parts[4])
+            pay['status'] = 'approved'
+            pay['updated_at'] = _dt.now().isoformat()
+            save_payments_db(pdb)
+            # Add coins to user
+            add_coins_fn(username, coins, 'bot_admin')
+            await q.edit_message_caption(
+                caption=q.message.caption + f"\n\n✅ <b>Approved!</b> +{coins} coins → {username}",
+                parse_mode=ParseMode.HTML
+            )
+            # Notify user if online (best effort)
+            try:
+                db = load_db()
+                tg_cid = db['users'].get(username, {}).get('tg_chat_id')
+                if tg_cid:
+                    await ctx.bot.send_message(
+                        chat_id=tg_cid,
+                        text=f"✅ *Coins ထည့်ပြီးပါပြီ!*\n\n🪙 *+{coins} Coins* သင့်အကောင့်ထဲ ရောက်ပြီ\n🆔 ID: `{payment_id}`",
+                        parse_mode=ParseMode.MARKDOWN
+                    )
+            except: pass
+        else:
+            pay['status'] = 'rejected'
+            pay['updated_at'] = _dt.now().isoformat()
+            save_payments_db(pdb)
+            await q.edit_message_caption(
+                caption=q.message.caption + f"\n\n❌ <b>Rejected</b>",
+                parse_mode=ParseMode.HTML
+            )
+            try:
+                db = load_db()
+                tg_cid = db['users'].get(username, {}).get('tg_chat_id')
+                if tg_cid:
+                    await ctx.bot.send_message(
+                        chat_id=tg_cid,
+                        text=f"❌ *Payment ငြင်းပယ်ခြင်းခံရသည်*\n\n🆔 ID: `{payment_id}`\n\nမေးမြန်းရန် — @{ADMIN_TG_USERNAME}",
+                        parse_mode=ParseMode.MARKDOWN
+                    )
+            except: pass
+        await q.answer()
         return
-    if approved:
-        coins = get_coins(p['username'])
-        send(cid, f'✅ <b>Payment Approved!</b>\n\n'
-                  f'🪙 {p["coins"]} Coins ထည့်ပြီးပါပြီ။\n'
-                  f'💼 လက်ကျန် Coins: <b>{coins}</b>\n\n'
-                  f'ကျေးဇူးတင်ပါသည် 🙏')
-    else:
-        note = p.get('admin_note', '')
-        send(cid, f'❌ <b>Payment Rejected</b>\n\n'
-                  f'🪙 {p["coins"]} Coins — {p["price"]}\n'
-                  + (f'📝 အကြောင်းပြချက်: {note}\n' if note else '') +
-                  f'\nထပ်မံ ဆက်သွယ်ပါ 🙏')
-
-# ══════════════════════════════════════════════
-
-def is_admin_chat(cid):
-    return str(cid) == str(ADMIN_CHAT_ID)
-
-def show_pending(cid):
-    pdb = load_payments()
-    pending = [p for p in pdb['payments'] if p['status'] == 'pending']
-    if not pending:
-        send(cid, '✅ Pending payments မရှိပါ'); admin_menu(cid); return
-    send(cid, f'⏳ <b>Pending Payments ({len(pending)})</b>')
-    for p in pending[:10]:
-        markup = kb(
-            [(f'✅ Approve {p["coins"]} Coins', f'apv:{p["id"]}')],
-            [('❌ Reject', f'rej:{p["id"]}'), ('🖼 Slip', f'slip:{p["id"]}')]
-        )
-        send(cid, fmt_payment(p), markup)
-
-def show_payments(cid, status='all'):
-    pdb = load_payments()
-    pmts = pdb['payments'] if status == 'all' else [p for p in pdb['payments'] if p['status'] == status]
-    pmts = sorted(pmts, key=lambda x: x['created_at'], reverse=True)[:10]
-    if not pmts:
-        send(cid, f'📭 {status} payments မရှိပါ'); admin_menu(cid); return
-    for p in pmts:
-        send(cid, fmt_payment(p))
-
-def show_users(cid):
-    db = load_db()
-    users = sorted(db['users'].items(), key=lambda x: x[1].get('coins', 0), reverse=True)[:20]
-    lines = ['👥 <b>User List</b>\n']
-    for uname_, udata in users:
-        c = udata.get('coins', 0); v = udata.get('total_videos', 0)
-        lines.append(f'• <code>{uname_}</code> — 🪙{c} | 🎬{v}')
-    send(cid, '\n'.join(lines))
-
-# ══════════════════════════════════════════════
-#  ADMIN-ONLY MESSAGE HANDLER
-# ══════════════════════════════════════════════
-def handle_message(msg):
-    cid  = msg['chat']['id']
-    text = msg.get('text', '').strip()
-
-    if not is_admin_chat(cid):
-        send(cid, '🔒 ဤ Bot သည် Admin အတွက်သာ ဖြစ်ပါသည်')
+
+    if data.startswith('cancel|'):
+        cancel_flags[cid] = True
+        await q.edit_message_text("⛔ ဖျက်သိမ်းနေသည်…" if data == 'cancel|process' else "⛔ ဖျက်သိမ်းပြီးပါပြီ")
         return
 
-    state = get_state(cid)
-    step  = state.get('step', '')
-    sdata = state.get('data', {})
-
-    # ── /start ──
-    if text in ('/start', '/menu', '🔙 Main Menu'):
-        clear_state(cid); admin_menu(cid); return
-
-    if text in ('💳 Pending Payments', '/pending'):
-        show_pending(cid); return
-
-    if text in ('📋 All Payments', '/all'):
-        show_payments(cid, 'all'); return
-
-    if text in ('👥 User List', '/users'):
-        show_users(cid); return
-
-    # ── Add Coins ──
-    if text in ('➕ Add Coins', '/addcoins'):
-        set_state(cid, 'adm_add_user')
-        send(cid, '➕ <b>Add Coins</b>\n\nUsername ထည့်ပါ:', rkb(['❌ Cancel'])); return
-
-    if step == 'adm_add_user':
-        if text == '❌ Cancel': clear_state(cid); admin_menu(cid); return
-        set_state(cid, 'adm_add_n', target=text)
-        send(cid, f'👤 <code>{text}</code>\n\nCoins အရေအတွက်:', rkb(['❌ Cancel'])); return
-
-    if step == 'adm_add_n':
-        if text == '❌ Cancel': clear_state(cid); admin_menu(cid); return
-        target = sdata.get('target', '')
-        try: n = int(text)
-        except: send(cid, '❌ ဂဏန်း ထည့်ပါ'); return
-        ok, total = add_coins(target, n)
-        clear_state(cid)
-        send(cid, f'✅ <code>{target}</code> — +{n} 🪙\n💼 လက်ကျန်: <b>{total}</b>' if ok else '❌ User မတွေ့ပါ')
-        admin_menu(cid); return
-
-    # ── Set Coins ──
-    if text in ('🔧 Set Coins', '/setcoins'):
-        set_state(cid, 'adm_set_user')
-        send(cid, '🔧 <b>Set Coins</b>\n\nUsername ထည့်ပါ:', rkb(['❌ Cancel'])); return
-
-    if step == 'adm_set_user':
-        if text == '❌ Cancel': clear_state(cid); admin_menu(cid); return
-        set_state(cid, 'adm_set_n', target=text)
-        send(cid, f'👤 <code>{text}</code>\n\nCoins တန်ဖိုး (ကန့်သတ်ချ):', rkb(['❌ Cancel'])); return
-
-    if step == 'adm_set_n':
-        if text == '❌ Cancel': clear_state(cid); admin_menu(cid); return
-        target = sdata.get('target', '')
-        try: n = int(text)
-        except: send(cid, '❌ ဂဏန်း ထည့်ပါ'); return
-        ok, total = set_coins(target, n)
-        clear_state(cid)
-        send(cid, f'✅ <code>{target}</code> Coins = <b>{total}</b>' if ok else '❌ User မတွေ့ပါ')
-        admin_menu(cid); return
-
-    # ── Delete User ──
-    if text in ('🗑 Delete User', '/deluser'):
-        set_state(cid, 'adm_del_user')
-        send(cid, '🗑 <b>Delete User</b>\n\nUsername ထည့်ပါ:', rkb(['❌ Cancel'])); return
-
-    if step == 'adm_del_user':
-        if text == '❌ Cancel': clear_state(cid); admin_menu(cid); return
-        db = load_db()
-        if text not in db['users']: send(cid, '❌ User မတွေ့ပါ'); clear_state(cid); return
-        set_state(cid, 'adm_del_confirm', target=text)
-        send(cid, f'⚠️ <code>{text}</code> ကို ဖျက်မှာ သေချာပါသလား?',
-             rkb([f'✅ Yes, Delete', '❌ Cancel'])); return
-
-    if step == 'adm_del_confirm':
-        if text == '❌ Cancel': clear_state(cid); admin_menu(cid); return
-        target = sdata.get('target', '')
-        db = load_db()
-        if target in db['users']:
-            del db['users'][target]; save_db(db)
-            send(cid, f'✅ <code>{target}</code> ဖျက်ပြီးပါပြီ')
-        else:
-            send(cid, '❌ User မတွေ့ပါ')
-        clear_state(cid); admin_menu(cid); return
-
-    # ── Broadcast ──
-    if text in ('📢 Broadcast', '/broadcast'):
-        set_state(cid, 'adm_broadcast')
-        send(cid, '📢 <b>Broadcast</b>\n\nMessage ရိုက်ပါ:', rkb(['❌ Cancel'])); return
-
-    if step == 'adm_broadcast':
-        if text == '❌ Cancel': clear_state(cid); admin_menu(cid); return
-        clear_state(cid)
-        db = load_db(); sent = 0
-        for udata in db['users'].values():
-            tcid = udata.get('tg_chat_id')
-            if tcid:
-                try: send(tcid, f'📢 <b>Recap Studio</b>\n\n{text}'); sent += 1; time.sleep(0.1)
-                except: pass
-        send(cid, f'✅ {sent} users ထံ ပို့ပြီးပါပြီ')
-        admin_menu(cid); return
-
-    # ── Approve/Reject note flows ──
-    if step == 'adm_approve_note':
-        pid = sdata.get('pid', '')
-        _do_approve(cid, pid, text if text.lower() != 'skip' else ''); return
-
-    if step == 'adm_reject_note':
-        pid = sdata.get('pid', '')
-        _do_reject(cid, pid, text if text.lower() != 'skip' else ''); return
-
-    admin_menu(cid)
-
-
-# ══════════════════════════════════════════════
-#  CALLBACK QUERY HANDLER
-# ══════════════════════════════════════════════
-def handle_callback(cb):
-    cid   = cb['message']['chat']['id']
-    mid   = cb['message']['message_id']
-    cb_id = cb['id']
-    data  = cb.get('data', '')
-
-    answer_cb(cb_id)
-
-    if not is_admin_chat(cid):
+    if data.startswith('pkg|'):
+        if data == 'pkg|back':
+            await q.edit_message_text(f"🛒 *Coins ဝယ်ရန်*\n\nPackage ရွေးပါ —", parse_mode=ParseMode.MARKDOWN, reply_markup=package_kb())
+            return
+        _, coins, price = data.split('|')
+        coins = int(coins); price = int(price)
+        # Save selected package for slip upload
+        pending_payment[cid] = {'coins': coins, 'price': price}
+        ctx.user_data['await_slip'] = True
+        await q.edit_message_text(
+            f"🪙 *{coins} Coins* — {price:,} MMK\n\n"
+            f"{PAYMENT_INFO}\n\n"
+            f"📸 ငွေလွဲပြီးနောက် *Slip ဓာတ်ပုံ* ဒီ chat ထဲ တိုက်ရိုက်ပို့ပါ",
+            parse_mode=ParseMode.MARKDOWN,
+            reply_markup=InlineKeyboardMarkup([
+                [InlineKeyboardButton('🔙 ပြန်သွားမည်', callback_data='pkg|back')],
+            ]))
         return
 
-    if data.startswith('apv:'):
-        pid = data.split(':', 1)[1]
-        set_state(cid, 'adm_approve_note', pid=pid)
-        send(cid, f'✅ Approve note ထည့်ပါ (<code>skip</code> = မလိုပါ):\n🆔 <code>{pid}</code>')
+    if data.startswith('voice|'):
+        _, vid, eng = data.split('|')
+        s['voice'] = vid; s['engine'] = eng
+        await q.edit_message_text(f"✅ အသံ သတ်မှတ်ပြီး — *{vid}* ({'Microsoft' if eng=='ms' else 'Gemini'})", parse_mode=ParseMode.MARKDOWN)
         return
 
-    if data.startswith('rej:'):
-        pid = data.split(':', 1)[1]
-        set_state(cid, 'adm_reject_note', pid=pid)
-        send(cid, f'❌ Reject reason ထည့်ပါ (<code>skip</code> = မလိုပါ):\n🆔 <code>{pid}</code>')
+    if data.startswith('set|'):
+        key = data.split('|')[1]
+        if key == 'flip': s['flip'] = not s['flip']
+        elif key == 'color': s['color'] = not s['color']
+        elif key == 'crop':
+            crops = ['original','9:16','16:9','1:1']
+            s['crop'] = crops[(crops.index(s['crop'])+1) % len(crops)] if s['crop'] in crops else 'original'
+        elif key == 'ai': s['ai_model'] = 'DeepSeek' if s['ai_model'] == 'Gemini' else 'Gemini'
+        elif key == 'ct': s['content_type'] = 'Medical/Health' if s['content_type'] == 'Movie Recap' else 'Movie Recap'
+        elif key == 'speed':
+            speeds = [0,10,20,30,40,50,60,80]
+            cur = s['speed']
+            s['speed'] = speeds[(speeds.index(cur)+1) % len(speeds)] if cur in speeds else 30
+        elif key == 'wmk':
+            ctx.user_data['await_wmk'] = True
+            await q.edit_message_text("💧 Watermark စာသားပို့ပါ (ဥပမာ — @username):")
+            return
+        elif key == 'music':
+            ctx.user_data['await_music'] = True
+            await q.edit_message_text(
+                "🎵 *Background Music*\n\n"
+                "MP3 / Audio file တင်ပါ\n"
+                "_(ဖိုင်တင်ပြီးနောက် auto သိမ်းမည်)_",
+                parse_mode=ParseMode.MARKDOWN)
+            return
+        elif key == 'music_del':
+            s['music_file_id'] = None
+            await q.answer("🗑️ Music ဖျက်ပြီး", show_alert=False)
+        elif key == 'done':
+            await q.edit_message_text("✅ Settings သိမ်းပြီးပါပြီ"); return
+        await q.edit_message_reply_markup(reply_markup=settings_kb(cid))
         return
 
-    if data.startswith('slip:'):
-        pid = data.split(':', 1)[1]
-        pdb = load_payments()
-        for p in pdb['payments']:
-            if p['id'] == pid:
-                slip_b64 = p.get('slip_image', '')
-                if not slip_b64:
-                    send(cid, '❌ Slip မရှိပါ'); return
-                import base64
-                slip_bytes = base64.b64decode(slip_b64.split(',')[-1])
-                markup = kb(
-                    [(f'✅ Approve {p["coins"]} Coins', f'apv:{pid}')],
-                    [('❌ Reject', f'rej:{pid}')]
-                )
-                send_photo(cid, slip_bytes,
-                           caption=f'🖼 {p["username"]} — {p["coins"]} Coins\n🆔 <code>{pid}</code>',
-                           markup=markup)
-                return
-        send(cid, '❌ Payment not found')
+    if data.startswith('adm|'):
+        if not s.get('is_admin'): await q.edit_message_text("❌ Admin only"); return
+        action = data.split('|')[1]
+        if action == 'refresh':
+            db = load_db(); users = db.get('users', {})
+            lines = [f"👑 *Admin Panel* — {len(users)} ယောက်\n"]
+            for uname, udata in list(users.items())[:20]:
+                lines.append(f"• `{uname}` — 🪙{udata.get('coins',0)}")
+            await q.edit_message_text('\n'.join(lines), parse_mode=ParseMode.MARKDOWN,
+                reply_markup=InlineKeyboardMarkup([
+                    [InlineKeyboardButton('➕ User ဖန်တီး', callback_data='adm|create'),
+                     InlineKeyboardButton('🪙 Coins ထည့်', callback_data='adm|coins')],
+                    [InlineKeyboardButton('🗑️ User ဖျက်', callback_data='adm|delete'),
+                     InlineKeyboardButton('🔄 Refresh', callback_data='adm|refresh')],
+                ]))
+        elif action == 'create':
+            ctx.user_data['adm_action'] = 'create'
+            await q.edit_message_text("➕ *User ဖန်တီးရန်*\n\n`username coins` ပို့ပါ\nဥပမာ — `CoolUser 10`", parse_mode=ParseMode.MARKDOWN)
+        elif action == 'coins':
+            ctx.user_data['adm_action'] = 'coins'
+            await q.edit_message_text("🪙 *Coins စီမံရန်*\n\n`username amount add|set` ပို့ပါ\nဥပမာ — `CoolUser 20 add`", parse_mode=ParseMode.MARKDOWN)
+        elif action == 'delete':
+            ctx.user_data['adm_action'] = 'delete'
+            await q.edit_message_text("🗑️ ဖျက်မည့် *username* ပို့ပါ —", parse_mode=ParseMode.MARKDOWN)
+        return
 
+# ── TEXT HANDLER ──
+
+# ── MUSIC INPUT HANDLER ──
+
+async def recv_music_input(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    s = sess(cid)
+    if not ctx.user_data.get('await_music'):
+        # Not expecting music — ignore audio uploads
+        return ST_MAIN
+    media = update.message.audio or update.message.document
+    if not media:
+        await update.message.reply_text("❌ Audio file မဟုတ်ပါ")
+        return ST_MAIN
+    s['music_file_id'] = media.file_id
+    ctx.user_data['await_music'] = False
+    await update.message.reply_text(
+        "✅ Background music သိမ်းပြီးပါပြီ\n"
+        "⚙️ Settings ထဲမှာ ပြနေမည်",
+        reply_markup=main_kb(cid)
+    )
+    return ST_MAIN
+
+
+async def recv_slip_photo(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    """Handle payment slip photo upload → save pending payment → notify admin."""
+    cid = update.effective_chat.id
+    s = sess(cid)
+
+    if not ctx.user_data.get('await_slip'):
+        # Not expecting slip — treat as video if it's a photo? Just ignore.
+        await update.message.reply_text("❌ Slip မမျှော်လင့်ထားပါ။ Package အရင်ရွေးပါ 🛒", reply_markup=main_kb(cid))
+        return ST_MAIN
+
+    if not update.message.photo:
+        await update.message.reply_text("❌ ဓာတ်ပုံ (Photo) ပို့ပါ — Document မဟုတ်ပါနဲ့", reply_markup=main_kb(cid))
+        return ST_MAIN
+
+    pkg = pending_payment.get(cid)
+    if not pkg:
+        await update.message.reply_text("❌ Package မရွေးရသေးပါ — Coins ဝယ်ရန် ကိုနှိပ်ပါ", reply_markup=main_kb(cid))
+        ctx.user_data['await_slip'] = False
+        return ST_MAIN
+
+    coins = pkg['coins']
+    price = pkg['price']
+    username = s.get('username', '')
+
+    # Download slip photo (largest size)
+    photo = update.message.photo[-1]
+    file = await ctx.bot.get_file(photo.file_id)
+
+    import io, base64, urllib.request as _ur
+    buf = io.BytesIO()
+    await file.download_to_memory(buf)
+    slip_b64 = base64.b64encode(buf.getvalue()).decode()
+    slip_data_url = f"data:image/jpeg;base64,{slip_b64}"
+
+    # Save to payments_db
+    import uuid as _uuid
+    from datetime import datetime as _dt
+    payment_id = _uuid.uuid4().hex[:10]
+    now = _dt.now().isoformat()
+    pdb = load_payments_db()
+    pdb['payments'].append({
+        'id': payment_id,
+        'username': username,
+        'coins': coins,
+        'price': price,
+        'status': 'pending',
+        'created_at': now,
+        'updated_at': now,
+        'slip_image': slip_data_url,
+        'admin_note': '',
+    })
+    save_payments_db(pdb)
+
+    ctx.user_data['await_slip'] = False
+    pending_payment.pop(cid, None)
+
+    # Notify admin via Telegram (send slip photo directly)
+    caption = (
+        f"💰 <b>Payment Request</b>\n"
+        f"👤 User: <code>{username}</code>\n"
+        f"🪙 Coins: {coins}\n"
+        f"💵 Price: {price:,} MMK\n"
+        f"🆔 ID: <code>{payment_id}</code>\n"
+        f"⏰ {now[:19]}\n\n"
+        f"✅ Approve:\n<code>/approve {payment_id} {username} {coins}</code>\n"
+        f"❌ Reject:\n<code>/reject {payment_id}</code>"
+    )
 
-# ══════════════════════════════════════════════
-#  POLLING LOOP  (409 Conflict safe)
-# ══════════════════════════════════════════════
-def poll():
-    for attempt in range(5):
+    if ADMIN_TELEGRAM_CHAT_ID and TELEGRAM_BOT_TOKEN:
         try:
-            tg('deleteWebhook', drop_pending_updates=True)
-            log.info('✅ Webhook cleared')
-            break
+            buf.seek(0)
+            await ctx.bot.send_photo(
+                chat_id=ADMIN_TELEGRAM_CHAT_ID,
+                photo=buf,
+                caption=caption,
+                parse_mode=ParseMode.HTML,
+                reply_markup=InlineKeyboardMarkup([
+                    [InlineKeyboardButton(f"✅ Approve {coins} coins", callback_data=f"adm_pay|approve|{payment_id}|{username}|{coins}")],
+                    [InlineKeyboardButton("❌ Reject", callback_data=f"adm_pay|reject|{payment_id}|{username}")],
+                ])
+            )
         except Exception as e:
-            log.warning(f'deleteWebhook attempt {attempt+1}: {e}')
-            time.sleep(3)
+            logger.error(f"Admin notify failed: {e}")
+
+    await update.message.reply_text(
+        f"✅ *Slip လက်ခံပြီးပါပြီ!*\n\n"
+        f"🪙 Package: *{coins} Coins* — {price:,} MMK\n"
+        f"🆔 ID: `{payment_id}`\n\n"
+        f"Admin စစ်ဆေးပြီး Coins ထည့်ပေးပါမည် ⏳",
+        parse_mode=ParseMode.MARKDOWN,
+        reply_markup=main_kb(cid)
+    )
+    return ST_MAIN
+
+
+async def recv_text(update: Update, ctx: ContextTypes.DEFAULT_TYPE):
+    cid = update.effective_chat.id
+    text = update.message.text.strip()
+    s = sess(cid)
+
+    # Music file handled via recv_music_input — text fallback
+    if ctx.user_data.get('await_wmk'):
+        s['watermark'] = text; ctx.user_data['await_wmk'] = False
+        await update.message.reply_text(f"✅ Watermark — `{text}`", parse_mode=ParseMode.MARKDOWN, reply_markup=main_kb(cid))
+        return ST_MAIN
+
+    if ctx.user_data.get('adm_action') == 'create' and s.get('is_admin'):
+        parts = text.split()
+        uname = parts[0] if parts else ''
+        coins = int(parts[1]) if len(parts) > 1 and parts[1].isdigit() else 10
+        msg, created = create_user_fn(uname, coins, s['username'])
+        ctx.user_data.pop('adm_action', None)
+        await update.message.reply_text(
+            f"✅ User ဖန်တီးပြီး!\nUsername: `{created}`\nCoins: {coins}" if created else f"❌ {msg}",
+            parse_mode=ParseMode.MARKDOWN, reply_markup=main_kb(cid))
+        return ST_MAIN
+
+    if ctx.user_data.get('adm_action') == 'coins' and s.get('is_admin'):
+        parts = text.split()
+        if len(parts) >= 3:
+            msg = set_coins_fn(parts[0], int(parts[1])) if parts[2] == 'set' else add_coins_fn(parts[0], int(parts[1]))
+            ctx.user_data.pop('adm_action', None)
+            await update.message.reply_text(f"✅ {msg}", reply_markup=main_kb(cid))
+        else:
+            await update.message.reply_text("❌ Format: `username amount add|set`", parse_mode=ParseMode.MARKDOWN)
+        return ST_MAIN
 
-    offset = 0
-    log.info('🤖 Admin-only bot polling started')
-    while True:
-        try:
-            r = tg('getUpdates', offset=offset, timeout=30,
-                   allowed_updates=['message', 'callback_query'])
-            for upd in r.get('result', []):
-                offset = upd['update_id'] + 1
-                try:
-                    if 'message' in upd:
-                        handle_message(upd['message'])
-                    elif 'callback_query' in upd:
-                        handle_callback(upd['callback_query'])
-                except Exception as e:
-                    log.error(f'Handler error: {e}', exc_info=True)
-        except Exception as e:
-            err = str(e)
-            if '409' in err:
-                log.warning('⚠️ 409 Conflict — waiting 15s then retrying…')
-                time.sleep(15)
-                try: tg('deleteWebhook', drop_pending_updates=True)
-                except: pass
-            else:
-                log.error(f'Poll error: {e}')
-                time.sleep(5)
+    if ctx.user_data.get('adm_action') == 'delete' and s.get('is_admin'):
+        db = load_db()
+        if text in db['users']:
+            del db['users'][text]; save_db(db)
+            await update.message.reply_text(f"✅ `{text}` ဖျက်ပြီးပါပြီ", parse_mode=ParseMode.MARKDOWN, reply_markup=main_kb(cid))
+        else:
+            await update.message.reply_text(f"❌ `{text}` မတွေ့ပါ", parse_mode=ParseMode.MARKDOWN, reply_markup=main_kb(cid))
+        ctx.user_data.pop('adm_action', None)
+        return ST_MAIN
+
+    if re.match(r'https?://', text):
+        s['pending_url'] = text; s['pending_file_id'] = None
+        if s['coins'] != -1 and s['coins'] < 2:
+            await update.message.reply_text(f"❌ Coins မလုံလောက်ဘူး ({s['coins']}) — 2 လိုသည်")
+            return ST_MAIN
+        # Busy check
+        if is_processing(cid):
+            await update.message.reply_text(
+                "⛔ *Process လုပ်နေဆဲဖြစ်သည်*\n\n"
+                "လက်ရှိ video ပြီးမှ နောက်တစ်ခု ပို့ပါ\n"
+                "_(ဖျက်သိမ်းလိုရင် ❌ နှိပ်ပါ)_",
+                parse_mode=ParseMode.MARKDOWN,
+                reply_markup=InlineKeyboardMarkup([[InlineKeyboardButton('❌ ဖျက်သိမ်းမည်', callback_data='cancel|process')]])
+            )
+            return ST_MAIN
+        # Coin check
+        fresh_coins2 = get_coins(s['username'])
+        if fresh_coins2 is not None:
+            s['coins'] = fresh_coins2
+        if not s['is_admin'] and s['coins'] != -1 and s['coins'] < 2:
+            await update.message.reply_text(
+                f"❌ Coins မလုံလောက်ဘူး ({s['coins']}) — 2 လိုသည်"
+            )
+            return ST_MAIN
+        cancel_flags[cid] = False
+        prog_msg = await update.message.reply_text(
+            "⏳ *စတင်နေပါသည်…*",
+            parse_mode=ParseMode.MARKDOWN, reply_markup=cancel_kb()
+        )
+        start_job(ctx.bot, cid, text, None, prog_msg.message_id)
+        return ST_MAIN
+
+    await update.message.reply_text("ဘာလုပ်မလဲ?", reply_markup=main_kb(cid))
+    return ST_MAIN
 
+# ── MAIN ──
 
 def main():
-    """Entry point — called by run_bot.py"""
     if not BOT_TOKEN:
-        log.error('❌ TELEGRAM_BOT_TOKEN not set'); return
-    if not ADMIN_CHAT_ID:
-        log.warning('⚠️ ADMIN_TELEGRAM_CHAT_ID not set — bot will reject all messages')
-    poll()
+        logger.error('❌ TELEGRAM_BOT_TOKEN မသတ်��ှတ်ရသေးပါ!'); return
+
+    application = Application.builder().token(BOT_TOKEN).build()
+    conv = ConversationHandler(
+        entry_points=[CommandHandler('start', cmd_start)],
+        states={
+            ST_LOGIN_USER: [MessageHandler(filters.TEXT & ~filters.COMMAND, recv_login_user)],
+            ST_LOGIN_PASS: [MessageHandler(filters.TEXT & ~filters.COMMAND, recv_login_pass)],
+            ST_MAIN: [
+                MessageHandler(filters.Regex('^🎬 Auto Process$'), btn_auto_process),
+                MessageHandler(filters.Regex('^🔊 အသံ$'), btn_voice),
+                MessageHandler(filters.Regex('^⚙️ Settings$'), btn_settings),
+                MessageHandler(filters.Regex('^👤 အကောင့်$'), btn_account),
+                MessageHandler(filters.Regex('^🛒 Coins ဝယ်ရန်$'), btn_buy),
+                MessageHandler(filters.Regex('^🔄 Reset$'), btn_reset),
+                MessageHandler(filters.Regex('^👑 Admin$'), btn_admin),
+                MessageHandler(filters.Regex('^🚪 Logout$'), cmd_logout),
+                MessageHandler(filters.VIDEO | filters.Document.VIDEO, recv_video_input),
+                MessageHandler(filters.AUDIO | filters.Document.AUDIO, recv_music_input),
+                MessageHandler(filters.PHOTO, recv_slip_photo),
+                MessageHandler(filters.TEXT & ~filters.COMMAND, recv_text),
+                CallbackQueryHandler(on_callback),
+            ],
+            ST_AWAIT_VIDEO: [
+                MessageHandler(filters.TEXT & ~filters.COMMAND, recv_video_input),
+                MessageHandler(filters.VIDEO | filters.Document.VIDEO, recv_video_input),
+                CallbackQueryHandler(on_callback),
+            ],
+        },
+        fallbacks=[CommandHandler('start', cmd_start), CommandHandler('logout', cmd_logout)],
+        per_chat=True, allow_reentry=True,
+    )
+    application.add_handler(conv)
+    logger.info('🤖 Recap Studio Bot အသင့်ဖြစ်ပြီ!')
+    application.run_polling(drop_pending_updates=True)
 
 if __name__ == '__main__':
     main()