import os, re, aiohttp
from telegram import Update
from telegram.ext import Application, CommandHandler, MessageHandler, filters, ContextTypes

TOKEN = "8613550531:AAG5zrnvqKCLk9clAAaJjqHPfX34r7e"
API = "https://bind-info-theta.vercel.app/check_bind_info"

def esc(t):
    if not t: return ""
    return re.sub(r"([_*\[\]()~>#+\-=|{}.!])", r"\\\1", str(t))

def fmt(data):
    p = data.get("player", {})
    b = data.get("bind", {})
    uid, nick, reg = esc(p.get("uid","N/A")), esc(p.get("nickname","N/A")), esc(p.get("region","N/A"))
    bound = b.get("success", False)
    cur, pend = b.get("current_email"), b.get("pending_email")
    if bound and cur:
        status = f"✅ Bɪɴᴅ\n   Eᴍᴀɪʟ: `{esc(cur)}`"
    elif pend:
        status = f"⏳ Pᴇɴᴅɪɴɢ Vᴇʀɪғɪᴄᴀᴛɪᴏɴ\n   Pᴇɴᴅɪɴɢ Eᴍᴀɪʟ: `{esc(pend)}`"
    else:
        status = "❌ Nᴏᴛ Bɪɴᴅ"
    res = esc(str(b.get("result_code", "N/A")))
    lines = [
        "🎮 Fʀᴇᴇ Fɪʀᴇ Aᴄᴄᴏᴜɴᴛ Bɪɴᴅ Iɴғᴏ", "",
        "👤 Pʟᴀʏᴇʀ", "━━━━━━━━━━━━",
        f"Uɪᴅ: `{uid}`", f"Nɪᴄᴋɴᴀᴍᴇ: `{nick}`", f"Rᴇɢɪᴏɴ: `{reg}`", "",
        "📧 Eᴍᴀɪʟ Bɪɴᴅɪɴɢ", "━━━━━━━━━━━━",
        status, f"Rᴇsᴜʟᴛ Cᴏᴅᴇ: `{res}`"
    ]
    if data.get("summary"):
        lines += ["", "📝 Sᴜᴍᴍᴀʀʏ", "━━━━━━━━━━━━", f"`{esc(data['summary'])}`"]
    dev, ch, own = data.get("developer"), data.get("main_channel"), data.get("owner")
    if dev or ch or own:
        lines += ["", "🔧 Dᴇᴠᴇʟᴏᴘᴇʀ: " + (esc(dev) if dev else "N/A")]
        if ch: lines.append(f"📢 Cʜᴀɴɴᴇʟ: {esc(ch)}")
        if own: lines.append(f"👑 Oᴡɴᴇʀ: {esc(own)}")
    return "\n".join(lines)

async def start(upd, ctx):
    name = upd.effective_user.first_name or "User"
    await upd.message.reply_text(
        f"🎮 Wᴇʟᴄᴏᴍᴇ Tᴏ Dɢ Dʀɪғᴛ Bɪɴᴅ Iɴғᴏ Bᴏᴛ 🔥\n\n"
        f"👋 Hᴇʏ {name}!\n\n"
        f"🔐 Fʀᴇᴇ Fɪʀᴇ Aᴄᴄᴏᴜɴᴛ Bɪɴᴅ Iɴғᴏ\n"
        f"⚡ Fᴀsᴛ & Sɪᴍᴘʟᴇ Rᴇsᴜʟᴛ\n"
        f"📧 Cʜᴇᴄᴋ Rᴇᴄᴏᴠᴇʀʏ Eᴍᴀɪʟ Sᴛᴀᴛᴜs\n\n"
        f"📝 Sᴇɴᴅ Yᴏᴜʀ Aᴄᴄᴇss Tᴏᴋᴇɴ Tᴏ Cʜᴇᴄᴋ Bɪɴᴅ Iɴғᴏ\n\n"
        f"🔧 Dᴇᴠᴇʟᴏᴘᴇʀ: Dɢ_Dʀɪғᴛ\n📢 Cʜᴀɴɴᴇʟ: @DGDRIFT"
    )

async def token_handler(upd, ctx):
    tok = upd.message.text.strip()
    if not tok: return await upd.message.reply_text("Send a valid access token.")
    await upd.message.chat.send_action("typing")
    try:
        async with aiohttp.ClientSession() as s:
            async with s.get(f"{API}?access_token={tok}") as r:
                if r.status == 200:
                    data = await r.json()
                    await upd.message.reply_text(fmt(data), parse_mode="MarkdownV2")
                else:
                    err = await r.text() if r.text else "No details."
                    await upd.message.reply_text(f"❌ API error {r.status}\n{esc(err)}", parse_mode="MarkdownV2")
    except:
        await upd.message.reply_text("⚠️ API unreachable. Try later.")

app = Application.builder().token(TOKEN).build()
app.add_handler(CommandHandler("start", start))
app.add_handler(MessageHandler(filters.TEXT & ~filters.COMMAND, token_handler))
app.run_polling()