Blame for bot.js

/**
 * ╔══════════════════════════════════════════════════════════════════════════╗
 * ║                                                                          ║
 * ║   ████████╗██╗██╗  ██╗████████╗ ██████╗ ██╗  ██╗    ██████╗  █████╗     ║
 * ║   ╚══██╔══╝██║██║ ██╔╝╚══██╔══╝██╔═══██╗██║ ██╔╝    ██╔══██╗██╔══██╗    ║
 * ║      ██║   ██║█████╔╝    ██║   ██║   ██║█████╔╝     ██████╔╝███████║    ║
 * ║      ██║   ██║██╔═██╗    ██║   ██║   ██║██╔═██╗     ██╔══██╗██╔══██║    ║
 * ║      ██║   ██║██║  ██╗   ██║   ╚██████╔╝██║  ██╗    ██║  ██║██║  ██║    ║
 * ║      ╚═╝   ╚═╝╚═╝  ╚═╝   ╚═╝    ╚═════╝ ╚═╝  ╚═╝    ╚═╝  ╚═╝╚═╝  ╚═╝    ║
 * ║                                                                          ║
 * ║                    🎯 TikTok Radar Bot v8.0 Premium 🎯                   ║
 * ║                  Based on Official Documentation                         ║
 * ║              https://github.com/zerodytrash/TikTok-Live-Connector        ║
 * ║                                                                          ║
 * ╚══════════════════════════════════════════════════════════════════════════╝
 */

const http = require('http');
const axios = require('axios');

// ═══════════════════════════════════════════════════════════════════════════
// 🔐 AUTHENTICATION SETUP
// ═══════════════════════════════════════════════════════════════════════════
process.env.WHITELIST_AUTHENTICATED_SESSION_ID_HOST = 'tiktok.eulerstream.com';

const PORT = process.env.PORT || 7860;

// ═══════════════════════════════════════════════════════════════════════════
// ⚙️ CONFIGURATION
// ═══════════════════════════════════════════════════════════════════════════
const CONFIG = {
    TIKTOK_USERNAME: (process.env.TIKTOK_USERNAME || 'a200_89').trim(),
    SESSION_ID: (process.env.SESSION_ID || '').trim(),
    TT_TARGET_IDC: (process.env.TT_TARGET_IDC || 'alisg').trim(),
    TELEGRAM_TOKEN: (process.env.TELEGRAM_TOKEN || '').trim(),
    TELEGRAM_CHAT_ID: (process.env.TELEGRAM_CHAT_ID || '').trim(),
    PROXY_URL: (process.env.PROXY_URL || '').trim().replace(/\/$/, ''),
    REPORT_INTERVAL: parseInt(process.env.REPORT_INTERVAL || '10'),
};

// ═══════════════════════════════════════════════════════════════════════════
// 📊 STATE VARIABLES
// ═══════════════════════════════════════════════════════════════════════════
let isConnected = false;
let tiktokConnection = null;
let totalGifts = 0;
let totalDiamonds = 0;
let totalLikes = 0;
let totalComments = 0;
let totalFollows = 0;
let totalShares = 0;
let maxViewers = 0;
let currentViewers = 0;
let startTime = null;
let giftersMap = {};
let followersMap = {};
let reconnectTimer = null;
let reportInterval = null;

// ⚔️ PK Battle State
let pkActive = false;
let pkInfo = {
    battleId: '',
    participants: [],
    participantDetails: [],
    ourScore: 0,
    theirScore: 0,
    startTime: null,
    pkGifts: {},
};

// ═══════════════════════════════════════════════════════════════════════════
// 🌐 HTTP SERVER
// ═══════════════════════════════════════════════════════════════════════════
const server = http.createServer((req, res) => {
    res.writeHead(200, { 'Content-Type': 'text/html; charset=utf-8' });
    
    const topGiftersHtml = Object.values(giftersMap)
        .sort((a, b) => b.coins - a.coins)
        .slice(0, 5)
        .map((g, i) => `<div style="padding:5px;background:#1a1a2e;margin:3px;border-radius:5px">
            ${['🥇','🥈','🥉','🏅','🎖'][i]} ${g.name}: ${g.coins}💎
        </div>`)
        .join('') || '<div style="color:#666">لا يوجد داعمين بعد</div>';
    
    res.end(`
    <!DOCTYPE html>
    <html dir="rtl">
    <head>
        <title>📡 TikTok Radar v8.0</title>
        <meta charset="UTF-8">
        <style>
            * { margin: 0; padding: 0; box-sizing: border-box; }
            body { 
                background: linear-gradient(135deg, #0a0a0a 0%, #1a1a2e 50%, #0a0a0a 100%);
                color: #fff; 
                font-family: 'Segoe UI', Tahoma, sans-serif;
                min-height: 100vh;
                padding: 20px;
            }
            .container { max-width: 600px; margin: 0 auto; }
            .header { 
                text-align: center; 
                padding: 30px;
                background: linear-gradient(135deg, #667eea 0%, #764ba2 100%);
                border-radius: 20px;
                margin-bottom: 20px;
                box-shadow: 0 10px 40px rgba(102, 126, 234, 0.3);
            }
            .status { 
                font-size: 28px; 
                padding: 15px;
                background: ${isConnected ? 'linear-gradient(135deg, #11998e 0%, #38ef7d 100%)' : 'linear-gradient(135deg, #eb3349 0%, #f45c43 100%)'};
                border-radius: 15px;
                margin: 20px 0;
                box-shadow: 0 5px 20px rgba(0,0,0,0.3);
            }
            .stats { 
                display: grid; 
                grid-template-columns: repeat(3, 1fr); 
                gap: 10px; 
                margin: 20px 0; 
            }
            .stat { 
                background: linear-gradient(135deg, #1a1a2e 0%, #16213e 100%);
                padding: 15px; 
                border-radius: 15px; 
                text-align: center;
                border: 1px solid #333;
            }
            .stat-value { font-size: 24px; font-weight: bold; color: #667eea; }
            .stat-label { font-size: 12px; color: #888; margin-top: 5px; }
            .gifters { 
                background: linear-gradient(135deg, #1a1a2e 0%, #16213e 100%);
                padding: 20px; 
                border-radius: 15px;
                border: 1px solid #333;
            }
            .pk-badge { 
                background: linear-gradient(135deg, #f093fb 0%, #f5576c 100%);
                padding: 10px 20px;
                border-radius: 25px;
                display: inline-block;
                margin-top: 10px;
                animation: pulse 2s infinite;
            }
            @keyframes pulse {
                0%, 100% { transform: scale(1); }
                50% { transform: scale(1.05); }
            }
        </style>
    </head>
    <body>
        <div class="container">
            <div class="header">
                <h1>📡 TikTok Radar</h1>
                <p style="opacity:0.8">v8.0 Premium Edition</p>
            </div>
            
            <div class="status">
                ${isConnected ? '🟢 متصل بالبث المباشر' : '🔴 في انتظار البث'}
            </div>
            
            <div style="text-align:center;padding:15px;background:#1a1a2e;border-radius:15px;margin-bottom:20px">
                <div style="font-size:20px">👤 @${CONFIG.TIKTOK_USERNAME}</div>
                <div style="color:#888;font-size:14px;margin-top:5px">⏰ ${new Date().toLocaleString('ar-IQ', {timeZone:'Asia/Baghdad'})}</div>
            </div>
            
            ${isConnected ? `
                <div class="stats">
                    <div class="stat">
                        <div class="stat-value">👁 ${currentViewers}</div>
                        <div class="stat-label">المشاهدين</div>
                    </div>
                    <div class="stat">
                        <div class="stat-value">🔝 ${maxViewers}</div>
                        <div class="stat-label">الأعلى</div>
                    </div>
                    <div class="stat">
                        <div class="stat-value">💎 ${totalDiamonds}</div>
                        <div class="stat-label">الماسات</div>
                    </div>
                    <div class="stat">
                        <div class="stat-value">🎁 ${totalGifts}</div>
                        <div class="stat-label">الهدايا</div>
                    </div>
                    <div class="stat">
                        <div class="stat-value">❤️ ${totalLikes}</div>
                        <div class="stat-label">الإعجابات</div>
                    </div>
                    <div class="stat">
                        <div class="stat-value">💬 ${totalComments}</div>
                        <div class="stat-label">التعليقات</div>
                    </div>
                </div>
                
                <div class="gifters">
                    <h3 style="margin-bottom:15px;color:#667eea">🏆 أفضل الداعمين</h3>
                    ${topGiftersHtml}
                </div>
                
                ${pkActive ? '<div class="pk-badge">⚔️ جولة PK نشطة!</div>' : ''}
            ` : ''}
        </div>
    </body>
    </html>
    `);
});

server.listen(PORT, '0.0.0.0', () => {
    console.log('');
    console.log('╔══════════════════════════════════════════════════════════════╗');
    console.log('║         🎯 TikTok Radar Bot v8.0 Premium Edition 🎯          ║');
    console.log('╠══════════════════════════════════════════════════════════════╣');
    console.log(`║  🌐 Server:    http://localhost:${PORT}                        ║`);
    console.log(`║  👤 TikTok:    @${CONFIG.TIKTOK_USERNAME.padEnd(40)}║`);
    console.log(`║  📱 Telegram:  ${CONFIG.TELEGRAM_TOKEN ? '✅ Connected' : '❌ Not Set'}                              ║`);
    console.log(`║  🔑 Session:   ${CONFIG.SESSION_ID ? '✅ Authenticated' : '⚠️  Public Mode'}                         ║`);
    console.log(`║  🌐 Proxy:     ${CONFIG.PROXY_URL ? '✅ Enabled' : '❌ Direct'}                               ║`);
    console.log('╚══════════════════════════════════════════════════════════════╝');
    console.log('');
    setTimeout(startBot, 2000);
});

// ═══════════════════════════════════════════════════════════════════════════
// 📱 TELEGRAM API (Direct & Buttons)
// ═══════════════════════════════════════════════════════════════════════════
async function sendTg(text, silent = false, buttons = null) {
    if (!CONFIG.TELEGRAM_TOKEN || !CONFIG.TELEGRAM_CHAT_ID) return false;
    
    const urls = [];
    if (CONFIG.PROXY_URL) urls.push(`${CONFIG.PROXY_URL}/bot${CONFIG.TELEGRAM_TOKEN}`);
    urls.push(`https://api.telegram.org/bot${CONFIG.TELEGRAM_TOKEN}`);
    
    for (const baseUrl of urls) {
        try {
            const payload = { 
                chat_id: CONFIG.TELEGRAM_CHAT_ID, 
                text, 
                parse_mode: 'HTML', 
                disable_notification: silent,
                disable_web_page_preview: true
            };
            if (buttons) payload.reply_markup = { inline_keyboard: buttons };
            
            const res = await axios.post(`${baseUrl}/sendMessage`, payload, { timeout: 15000 });
            if (res.data?.ok) { 
                console.log(`[Telegram] ✅ Message sent successfully`); 
                return true; 
            }
        } catch (e) { 
            console.log(`[Telegram] ⚠️ Failed to send message`); 
        }
    }
    return false;
}

// ═══════════════════════════════════════════════════════════════════════════
// 🛠️ UTILITY FUNCTIONS
// ═══════════════════════════════════════════════════════════════════════════
function esc(t) { 
    return t ? String(t).replace(/&/g,'&amp;').replace(/</g,'&lt;').replace(/>/g,'&gt;') : ''; 
}

function formatK(n) { 
    n = Number(n) || 0;
    if (n >= 1000000) return (n/1000000).toFixed(1) + 'M';
    if (n >= 1000) return (n/1000).toFixed(1) + 'K';
    return n.toString(); 
}

function formatDuration(s) { 
    if (!s) return '00:00:00'; 
    const d = Math.floor((Date.now() - s.getTime()) / 1000); 
    const h = Math.floor(d / 3600);
    const m = Math.floor((d % 3600) / 60);
    const sec = d % 60;
    return `${String(h).padStart(2,'0')}:${String(m).padStart(2,'0')}:${String(sec).padStart(2,'0')}`; 
}

function getTime() { 
    return new Date().toLocaleString('ar-IQ', {
        timeZone: 'Asia/Baghdad', 
        hour: '2-digit', 
        minute: '2-digit', 
        hour12: true
    }); 
}

function getDate() { 
    return new Date().toLocaleString('ar-IQ', {
        timeZone: 'Asia/Baghdad', 
        year: 'numeric',
        month: '2-digit',
        day: '2-digit'
    }); 
}

// 🏆 Top Gifters Formatter
function getTopGifters(limit = 5) {
    const gifters = Object.values(giftersMap)
        .sort((a, b) => b.coins - a.coins)
        .slice(0, limit);
    
    if (gifters.length === 0) return '• لا يوجد داعمين بعد';
    
    const medals = ['🥇', '🥈', '🥉', '🏅', '🎖️', '⭐', '✨', '💫', '🌟', '⚡'];
    
    return gifters.map((g, i) => {
        const medal = medals[i] || '•';
        const name = esc(g.name);
        const username = g.username ? `\n     ┗ <code>@${g.username}</code>` : '';
        const coins = formatK(g.coins);
        return `${medal} <b>${name}</b>: ${coins} 💎${username}`;
    }).join('\n\n');
}

// ➕ Top Followers Formatter
function getTopFollowers(limit = 5) {
    const followers = Object.values(followersMap)
        .sort((a, b) => b.time - a.time)
        .slice(0, limit);
    
    if (followers.length === 0) return '• لا يوجد متابعين جدد';
    
    return followers.map((f, i) => {
        const name = esc(f.name);
        const username = f.username ? `<code>@${f.username}</code>` : '';
        return `${i + 1}. <b>${name}</b>\n     ┗ ${username || 'يوزر غير معروف'}`;
    }).join('\n\n');
}

// ═══════════════════════════════════════════════════════════════════════════
// 📊 PERIODIC REPORTS
// ═══════════════════════════════════════════════════════════════════════════
function startReports() {
    if (reportInterval) clearInterval(reportInterval);
    reportInterval = setInterval(() => {
        if (!isConnected) return;
        
        const liveLink = `https://www.tiktok.com/@${CONFIG.TIKTOK_USERNAME}/live`;
        
        const msg = 
            `📊 <b>تقرير البث المباشر</b>\n` +
            `━━━━━━━━━━━━━━━━━━━━━━\n\n` +
            
            `👤 <b>المُضيف:</b> ${CONFIG.TIKTOK_USERNAME}\n` +
            `🔗 <code>@${CONFIG.TIKTOK_USERNAME}</code>\n\n` +
            
            `⏱ <b>المدة:</b> ${formatDuration(startTime)}\n` +
            `📅 <b>التاريخ:</b> ${getDate()}\n\n` +
            
            `━━━━ 📈 الإحصائيات ━━━━\n\n` +
            
            `👁 المشاهدين الحاليين: <b>${formatK(currentViewers)}</b>\n` +
            `🔝 أعلى مشاهدة: <b>${formatK(maxViewers)}</b>\n` +
            `💎 إجمالي الماسات: <b>${formatK(totalDiamonds)}</b>\n` +
            `🎁 عدد الهدايا: <b>${formatK(totalGifts)}</b>\n` +
            `❤️ الإعجابات: <b>${formatK(totalLikes)}</b>\n` +
            `💬 التعليقات: <b>${formatK(totalComments)}</b>\n` +
            `➕ المتابعين الجدد: <b>${formatK(totalFollows)}</b>\n` +
            `↪️ المشاركات: <b>${formatK(totalShares)}</b>\n\n` +
            
            `━━━━ 🏆 الداعمين ━━━━\n\n` +
            `${getTopGifters(5)}`;
        
        sendTg(msg, false, [
            [{ text: '🔴 دخول البث المباشر', url: liveLink }]
        ]);
    }, CONFIG.REPORT_INTERVAL * 60000);
}

// ═══════════════════════════════════════════════════════════════════════════
// 🤖 MAIN BOT
// ═══════════════════════════════════════════════════════════════════════════
async function startBot() {
    console.log(`\n[Bot] 🔎 Searching for @${CONFIG.TIKTOK_USERNAME}...`);
    
    let TikTokLiveConnection, WebcastEvent, ControlEvent;
    try {
        const lib = require('tiktok-live-connector');
        TikTokLiveConnection = lib.TikTokLiveConnection;
        WebcastEvent = lib.WebcastEvent;
        ControlEvent = lib.ControlEvent;
        console.log('[Bot] ✅ Library loaded successfully');
    } catch (e) { 
        console.error('[Bot] ❌ Library error:', e.message);
        setTimeout(startBot, 30000); 
        return; 
    }

    try {
        const options = { 
            processInitialData: true, 
            enableExtendedGiftInfo: true,
            fetchRoomInfoOnConnect: true,
        };

        if (CONFIG.SESSION_ID && CONFIG.SESSION_ID.length > 10) {
            options.session = {
                cookie: {
                    type: 'cookie',
                    value: {
                        sessionId: CONFIG.SESSION_ID,
                        ttTargetIdc: CONFIG.TT_TARGET_IDC
                    }
                }
            };
            options.authenticateWs = true;
            console.log('[Bot] 🔑 Using authenticated connection');
        } else {
            console.log('[Bot] 🔓 Using public connection');
        }

        tiktokConnection = new TikTokLiveConnection(CONFIG.TIKTOK_USERNAME, options);

        // ═══════════════════════════════════════════════════════════════
        // 🎮 CONTROL EVENTS
        // ═══════════════════════════════════════════════════════════════
        
        // ✅ Connected
        tiktokConnection.on(ControlEvent.CONNECTED, (state) => {
            isConnected = true; 
            startTime = new Date();
            
            // Reset all stats
            totalGifts = 0; 
            totalDiamonds = 0;
            totalLikes = 0; 
            totalComments = 0; 
            totalFollows = 0; 
            totalShares = 0; 
            maxViewers = 0;
            currentViewers = 0; 
            giftersMap = {}; 
            followersMap = {};
            pkActive = false;
            
            console.log(`[Bot] ✅ Connected to room: ${state.roomId}`);
            
            const liveLink = `https://www.tiktok.com/@${CONFIG.TIKTOK_USERNAME}/live`;
            
            sendTg(
                `📡 <b>البث المباشر بدأ الآن!</b>\n` +
                `━━━━━━━━━━━━━━━━━━━━━━\n\n` +
                
                `🎬 <b>معلومات البث:</b>\n\n` +
                
                `👤 <b>المُضيف:</b> ${CONFIG.TIKTOK_USERNAME}\n` +
                `🔗 <b>اليوزر:</b> <code>@${CONFIG.TIKTOK_USERNAME}</code>\n` +
                `⏰ <b>وقت البدء:</b> ${getTime()}\n` +
                `📅 <b>التاريخ:</b> ${getDate()}\n\n` +
                
                `━━━━━━━━━━━━━━━━━━━━━━\n` +
                `🎉 <b>البث بدأ! انضم الآن وادعم!</b>`,
                false,
                [
                    [{ text: '🔴 دخول البث المباشر', url: liveLink }],
                    [{ text: '📊 الإحصائيات', url: `https://www.tiktok.com/@${CONFIG.TIKTOK_USERNAME}` }]
                ]
            );
            
            startReports();
        });

        // 📴 Disconnected
        tiktokConnection.on(ControlEvent.DISCONNECTED, ({ code, reason }) => { 
            isConnected = false; 
            console.log(`[Bot] 📴 Disconnected (code: ${code}, reason: ${reason || 'unknown'})`);
            if (reportInterval) clearInterval(reportInterval); 
            scheduleReconnect(30000); 
        });

        // ⚠️ Error
        tiktokConnection.on(ControlEvent.ERROR, (err) => {
            console.error('[Bot] ⚠️ Error:', err?.info || err?.message || err);
        });

        // ═══════════════════════════════════════════════════════════════
        // 📺 WEBCAST EVENTS
        // ═══════════════════════════════════════════════════════════════

        // 🔴 Stream End
        tiktokConnection.on(WebcastEvent.STREAM_END, ({ action }) => {
            isConnected = false; 
            console.log(`[Bot] 🔴 Stream ended (action: ${action})`);
            if (reportInterval) clearInterval(reportInterval);
            
            sendTg(
                `🔴 <b>انتهى البث المباشر</b>\n` +
                `━━━━━━━━━━━━━━━━━━━━━━\n\n` +
                
                `👤 <b>المُضيف:</b> ${CONFIG.TIKTOK_USERNAME}\n` +
                `🔗 <code>@${CONFIG.TIKTOK_USERNAME}</code>\n\n` +
                
                `━━━━ 📊 ملخص البث ━━━━\n\n` +
                
                `⏱ <b>مدة البث:</b> ${formatDuration(startTime)}\n` +
                `👁 <b>أعلى مشاهدة:</b> ${formatK(maxViewers)}\n` +
                `💎 <b>إجمالي الماسات:</b> ${formatK(totalDiamonds)}\n` +
                `🎁 <b>عدد الهدايا:</b> ${formatK(totalGifts)}\n` +
                `❤️ <b>الإعجابات:</b> ${formatK(totalLikes)}\n` +
                `💬 <b>التعليقات:</b> ${formatK(totalComments)}\n` +
                `➕ <b>المتابعين الجدد:</b> ${formatK(totalFollows)}\n\n` +
                
                `━━━━ 🏆 أفضل الداعمين ━━━━\n\n` +
                `${getTopGifters(5)}\n\n` +
                
                `━━━━━━━━━━━━━━━━━━━━━━\n` +
                `🙏 <b>شكراً لكل من حضر ودعم!</b>`
            );
            
            scheduleReconnect(60000);
        });

        // 💬 Chat
        tiktokConnection.on(WebcastEvent.CHAT, (data) => {
            totalComments++;
            const nickname = data.user?.nickname || data.user?.uniqueId || '?';
            const comment = data.comment || '';
            console.log(`[Chat] 💬 ${nickname}: ${comment}`);
        });

        // 🎁 Gift - FIXED!
        tiktokConnection.on(WebcastEvent.GIFT, (data) => {
            // User info
            const uniqueId = data.user?.uniqueId || data.uniqueId || '';
            const oderId = data.user?.userId || data.userId || uniqueId || 'unknown';
            const nickname = data.user?.nickname || data.nickname || uniqueId || '?';
            
            // Gift info - check ALL possible sources
            const giftId = data.giftId || data.gift?.gift_id || 0;
            const giftName = data.giftName 
                || data.extendedGiftInfo?.name 
                || data.gift?.name
                || data.describe?.replace('Sent ', '') 
                || `Gift#${giftId}`;
            
            // Gift type
            const giftType = data.giftType ?? data.gift?.gift_type ?? 0;
            const repeatCount = data.repeatCount ?? data.gift?.repeat_count ?? 1;
            const repeatEnd = data.repeatEnd ?? data.gift?.repeat_end ?? true;
            
            // 💎 Diamond count - FIXED: Check all sources correctly
            let diamondCount = 0;
            
            // Priority order for finding diamond count
            if (data.diamondCount && data.diamondCount > 0) {
                diamondCount = data.diamondCount;
            } else if (data.extendedGiftInfo?.diamondCount && data.extendedGiftInfo.diamondCount > 0) {
                diamondCount = data.extendedGiftInfo.diamondCount;
            } else if (data.extendedGiftInfo?.diamond_count && data.extendedGiftInfo.diamond_count > 0) {
                diamondCount = data.extendedGiftInfo.diamond_count;
            } else if (data.gift?.diamond_count && data.gift.diamond_count > 0) {
                diamondCount = data.gift.diamond_count;
            } else if (data.giftDetails?.diamondCount && data.giftDetails.diamondCount > 0) {
                diamondCount = data.giftDetails.diamondCount;
            }
            
            // Log for debugging
            console.log(`[Gift] 🎁 ${nickname} -> ${giftName}`);
            console.log(`[Gift]    💎 Diamonds: ${diamondCount} x ${repeatCount} = ${diamondCount * repeatCount}`);
            console.log(`[Gift]    Type: ${giftType}, RepeatEnd: ${repeatEnd}`);

            // Skip streak gifts until they end
            if (giftType === 1 && repeatEnd === false) {
                console.log(`[Gift]    ⏳ Streak in progress...`);
                return;
            }

            // Calculate total
            const totalCost = diamondCount * repeatCount;
            
            // Update totals
            totalGifts++;
            totalDiamonds += totalCost;
            
            // Track gifter
            if (!giftersMap[oderId]) {
                giftersMap[oderId] = { 
                    name: nickname, 
                    username: uniqueId,
                    coins: 0, 
                    count: 0 
                };
            }
            giftersMap[oderId].coins += totalCost;
            giftersMap[oderId].count++;

            // Track PK gifts
            if (pkActive) {
                if (!pkInfo.pkGifts[oderId]) {
                    pkInfo.pkGifts[oderId] = { name: nickname, username: uniqueId, coins: 0 };
                }
                pkInfo.pkGifts[oderId].coins += totalCost;
            }

            console.log(`[Gift] ✅ Recorded: ${nickname} = ${totalCost}💎 (Total in map: ${giftersMap[oderId].coins}💎)`);
            
            // Send notification
            let emoji = '🎁';
            if (totalCost >= 10000) emoji = '💎🔥';
            else if (totalCost >= 5000) emoji = '💎✨';
            else if (totalCost >= 1000) emoji = '💎';
            else if (totalCost >= 100) emoji = '🎁✨';
            
            const userLink = uniqueId ? `\n🔗 <code>@${uniqueId}</code>` : '';
            
            sendTg(
                `${emoji} <b>هدية جديدة!</b>\n` +
                `━━━━━━━━━━━━━━━\n\n` +
                `👤 <b>${esc(nickname)}</b>${userLink}\n\n` +
                `🎁 أرسل: <b>${esc(giftName)}</b>\n` +
                `💎 القيمة: <b>${formatK(totalCost)}</b> ماسة` +
                (repeatCount > 1 ? ` (x${repeatCount})` : ''),
                totalCost < 50
            );
        });

        // ❤️ Like
        tiktokConnection.on(WebcastEvent.LIKE, (data) => { 
            const likes = data.likeCount || data.totalLikeCount || 1;
            totalLikes += likes;
        });

        // ➕ Follow - Enhanced
        tiktokConnection.on(WebcastEvent.FOLLOW, (data) => { 
            totalFollows++;
            
            const uniqueId = data.user?.uniqueId || '';
            const nickname = data.user?.nickname || uniqueId || '?';
            const oderId = data.user?.userId || uniqueId || Date.now().toString();
            
            // Track follower
            followersMap[oderId] = {
                name: nickname,
                username: uniqueId,
                time: Date.now()
            };
            
            console.log(`[Follow] ➕ ${nickname} (@${uniqueId})`);
            
            const userLink = uniqueId ? `\n🔗 <code>@${uniqueId}</code>` : '';
            
            sendTg(
                `➕ <b>متابع جديد!</b>\n` +
                `━━━━━━━━━━━━━━━\n\n` +
                `👤 <b>${esc(nickname)}</b>${userLink}\n\n` +
                `🎉 شكراً على المتابعة!`,
                true
            ); 
        });

        // ↪️ Share
        tiktokConnection.on(WebcastEvent.SHARE, (data) => { 
            totalShares++;
            const nickname = data.user?.nickname || data.user?.uniqueId || '?';
            console.log(`[Share] ↪️ ${nickname} shared the stream`);
        });

        // 👁 Viewer Count
        tiktokConnection.on(WebcastEvent.ROOM_USER, (data) => { 
            currentViewers = data.viewerCount || 0;
            if (currentViewers > maxViewers) maxViewers = currentViewers;
        });

        // 👤 Member Join
        tiktokConnection.on(WebcastEvent.MEMBER, (data) => {
            const nickname = data.user?.nickname || data.user?.uniqueId || '?';
            console.log(`[Member] 👤 ${nickname} joined`);
        });

        // 📦 Envelope
        tiktokConnection.on(WebcastEvent.ENVELOPE, (data) => {
            if (data.envelopeInfo) {
                const sender = data.envelopeInfo.sendUserName || '?';
                const diamonds = data.envelopeInfo.diamondCount || 0;
                console.log(`[Envelope] 📦 ${sender} sent treasure box (${diamonds}💎)`);
                sendTg(
                    `📦 <b>صندوق كنز!</b>\n` +
                    `━━━━━━━━━━━━━━━\n\n` +
                    `👤 <b>${esc(sender)}</b>\n` +
                    `💎 القيمة: <b>${formatK(diamonds)}</b> ماسة`
                );
            }
        });

        // ⚔️ PK Battle Start - Enhanced
        tiktokConnection.on(WebcastEvent.LINK_MIC_BATTLE, (data) => {
            pkActive = true;
            pkInfo = {
                battleId: data.battleId || '',
                participants: [],
                participantDetails: [],
                ourScore: 0,
                theirScore: 0,
                startTime: new Date(),
                pkGifts: {},
            };
            
            console.log(`[PK] 📦 Raw data:`, JSON.stringify(data.anchorInfo || {}).substring(0, 500));
            
            // Extract participants
            const participantDetails = [];
            const anchorInfo = data.anchorInfo || {};
            
            for (const [key, info] of Object.entries(anchorInfo)) {
                const user = info.user || info || {};
                const displayId = user.displayId || user.display_id || user.uniqueId || user.unique_id || '';
                const nickName = user.nickName || user.nickname || user.nick_name || displayId || 'مجهول';
                const oderId = user.userId || user.user_id || user.id || key || '';
                
                if (displayId || nickName !== 'مجهول') {
                    participantDetails.push({
                        name: nickName,
                        username: displayId,
                        oderId: oderId,
                    });
                }
            }
            
            pkInfo.participantDetails = participantDetails;
            pkInfo.participants = participantDetails.map(p => p.name);
            
            console.log(`[PK] ⚔️ Battle started: ${data.battleId}`);
            console.log(`[PK] 👥 Participants:`, participantDetails);
            
            // Find opponent
            const host = participantDetails.find(p => 
                p.username === CONFIG.TIKTOK_USERNAME || p.name === CONFIG.TIKTOK_USERNAME
            ) || participantDetails[0] || null;
            
            const opponent = participantDetails.find(p => 
                p.username !== CONFIG.TIKTOK_USERNAME && p.name !== CONFIG.TIKTOK_USERNAME
            ) || participantDetails[1] || null;
            
            const liveLink = `https://www.tiktok.com/@${CONFIG.TIKTOK_USERNAME}/live`;
            
            let pkMsg = 
                `⚔️🔥 <b>بدأت جولة PK جديدة!</b>\n` +
                `━━━━━━━━━━━━━━━━━━━━━━\n\n`;
            
            // Host info
            pkMsg += `🏠 <b>صاحب البث:</b>\n` +
                `     👤 <b>${esc(CONFIG.TIKTOK_USERNAME)}</b>\n` +
                `     🔗 <code>@${CONFIG.TIKTOK_USERNAME}</code>\n\n`;
            
            pkMsg += `          🆚\n\n`;
            
            // Opponent info
            if (opponent) {
                pkMsg += `🥊 <b>المنافس:</b>\n` +
                    `     👤 <b>${esc(opponent.name)}</b>\n` +
                    `     🔗 <code>@${opponent.username || 'غير معروف'}</code>\n\n`;
            } else {
                pkMsg += `🥊 <b>المنافس:</b>\n` +
                    `     ⏳ جاري تحميل البيانات...\n\n`;
            }
            
            pkMsg += `━━━━━━━━━━━━━━━━━━━━━━\n` +
                `🚀 <b>ادعموا البث وساهموا بالفوز!</b>\n` +
                `💎 <b>كل هدية تحسب في النتيجة!</b>`;
            
            sendTg(pkMsg, false, [
                [{ text: '🔴 ادخل البث وادعم الآن!', url: liveLink }]
            ]);
        });

        // 📊 PK Update
        tiktokConnection.on(WebcastEvent.LINK_MIC_ARMIES, (data) => {
            if (!pkActive) return;
            
            if (data.totalDiamondCount) {
                pkInfo.ourScore = data.totalDiamondCount;
                console.log(`[PK] 📊 Score update: ${data.totalDiamondCount}💎`);
            }
        });

        // 🎬 Live Intro
        tiktokConnection.on(WebcastEvent.LIVE_INTRO, (data) => {
            const host = data.host?.nickname || data.host?.uniqueId || '';
            const desc = data.description || '';
            if (host || desc) {
                console.log(`[Intro] 🎬 Host: ${host}, Description: ${desc}`);
            }
        });

        // ═══════════════════════════════════════════════════════════════
        // 🔌 CONNECT
        // ═══════════════════════════════════════════════════════════════
        console.log('[Bot] 🔌 Connecting to TikTok...');
        await tiktokConnection.connect();

    } catch (err) { 
        const errMsg = err.message || String(err);
        console.error('[Bot] ❌ Connection failed:', errMsg);
        isConnected = false;
        
        if (errMsg.includes('offline') || errMsg.includes('not online')) {
            console.log('[Bot] 📴 User is not live, will retry...');
        }
        
        scheduleReconnect(60000); 
    }
}

// ═══════════════════════════════════════════════════════════════════════════
// 🔄 RECONNECTION
// ═══════════════════════════════════════════════════════════════════════════
function scheduleReconnect(delay) {
    if (reconnectTimer) clearTimeout(reconnectTimer);
    console.log(`[Bot] 🔄 Reconnecting in ${delay/1000} seconds...`);
    reconnectTimer = setTimeout(() => { 
        reconnectTimer = null; 
        if (!isConnected) startBot(); 
    }, delay);
}

// ═══════════════════════════════════════════════════════════════════════════
// 🛡️ ERROR HANDLING & KEEP ALIVE
// ═══════════════════════════════════════════════════════════════════════════
process.on('uncaughtException', (e) => {
    console.error('[FATAL] Uncaught Exception:', e.message);
});

process.on('unhandledRejection', (r) => {
    console.error('[FATAL] Unhandled Rejection:', r);
});

// Keep alive ping
setInterval(() => { 
    http.get(`http://localhost:${PORT}`, r => r.resume()).on('error', () => {}); 
}, 60000);

// Graceful shutdown
process.on('SIGINT', async () => {
    console.log('\n[Bot] 👋 Shutting down gracefully...');
    if (tiktokConnection) {
        try { await tiktokConnection.disconnect(); } catch(e) {}
    }
    await sendTg(
        `💤 <b>البوت توقف مؤقتاً</b>\n` +
        `━━━━━━━━━━━━━━━\n` +
        `⏰ ${getTime()}\n` +
        `📅 ${getDate()}`
    );
    process.exit(0);
});

console.log('[Bot] 🚀 TikTok Radar v8.0 Premium initialized!');