Update bot.js

bot.js

@@ -1,185 +1,111 @@
 /**
- * ╔══════════════════════════════════════════════════════════════════════╗
- * ║  TikTok Radar Pro - Telegram Bot v6.4 (Fixed for v2.1+)           ║
- * ║  Based on tiktok-live-connector v2.1+ API                         ║
- * ╚══════════════════════════════════════════════════════════════════════╝
+ * ⚡ TikTok Radar Pro v6.5 - High Performance Edition
+ * تم الإصلاح للعمل على Hugging Face Spaces 2026
  */
 
 const { TikTokLiveConnection, WebcastEvent, ControlEvent } = require('tiktok-live-connector');
 const axios = require('axios');
 const http = require('http');
 
-// الإعدادات
-function cleanEnv(val, fallback) {
-  if (!val) return fallback;
-  return val.toString().trim().split('\n')[0].trim();
-}
-
-const CONFIG = {
-  TIKTOK_USERNAME: cleanEnv(process.env.TIKTOK_USERNAME, 'a200_89'),
-  SESSION_ID: cleanEnv(process.env.SESSION_ID, ''),
-  TT_TARGET_IDC: cleanEnv(process.env.TT_TARGET_IDC, 'alisg'),
-  TELEGRAM_TOKEN: cleanEnv(process.env.TELEGRAM_TOKEN, ''),
-  TELEGRAM_CHAT_ID: cleanEnv(process.env.TELEGRAM_CHAT_ID, ''),
-  PROXY_URL: cleanEnv(process.env.PROXY_URL, '').replace(/\/$/, ''),
-  REPORT_INTERVAL_MINUTES: parseInt(cleanEnv(process.env.REPORT_INTERVAL, '10')) || 10,
-  CHAT_COOLDOWN_MS: 4000,
-  GIFT_COOLDOWN_MS: 3000,
-  LIKE_BATCH_THRESHOLD: 50,
-  TOP_CHAT_LIMIT: 10,
-  SPAM_KEYWORDS: ['spam', 'scam', 'fake', 'click here', 'free money', 'earn now', 'www.', '.com'],
-};
-
-// متغيرات الحالة
-let isConnected = false;
-let isLive = false;
-let maxViewers = 0;
-let totalLikes = 0;
-let totalShares = 0;
-let totalGifts = 0;
-let totalFollows = 0;
-let totalComments = 0;
-let totalEnvelopes = 0;
-let totalCoinsGiven = 0;
-let giftersMap = {};
-let likersMap = {};
-let sharersMap = {};
-let followersMap = {};
-let chattersMap = {};
-let moderatorsMap = {};
-let envelopeWinnersMap = {};
-let coinPurseWinnersMap = {};
-let topChatMessages = [];
-let startTime = null;
-let lastReportTime = null;
-let tiktokConnection = null;
-let reconnectTimer = null;
-let reportInterval = null;
-let lastMessageId = null;
-let reconnectAttempt = 0;
-let lastReconnectNotify = 0;
-let lastActivity = Date.now();
-
-const cooldowns = {
-  chat: new Map(), gift: new Map(), like: new Map(), follow: new Map(),
-  share: new Map(), envelope: new Map(), coinPurse: new Map(), moderator: new Map(),
-};
+console.log('🚀 بدء تشغيل البوت...');
 
-let pkActive = false;
-let pkInfo = { opponentName: '', opponentUserId: '', ourScore: 0, theirScore: 0, startTime: null, pkGifts: {} };
-let viewerHistory = [];
+// 1. تشغيل السيرفر فوراً لإرضاء Hugging Face ومنع تعليق البناء
+const PORT = process.env.PORT || 7860;
+const server = http.createServer((req, res) => {
+    res.writeHead(200, { 'Content-Type': 'text/plain; charset=utf-8' });
+    res.end(`TikTok Bot Active | @${process.env.TIKTOK_USERNAME || 'a200_89'}`);
+});
 
-// دالات مساعدة
-function updateActivity() { lastActivity = Date.now(); }
-function formatK(num) { 
-    if (num >= 1000000) return (num / 1000000).toFixed(1) + 'M';
-    if (num >= 1000) return (num / 1000).toFixed(1) + 'K';
-    return num.toString();
-}
-function getBaghdadTime() { 
-    return new Intl.DateTimeFormat('ar-IQ', { timeZone: 'Asia/Baghdad', hour: '2-digit', minute: '2-digit', second: '2-digit', hour12: true }).format(new Date()); 
-}
-function escapeHtml(text) {
-  if (!text) return '';
-  return text.replace(/&/g, '&amp;').replace(/</g, '&lt;').replace(/>/g, '&gt;').replace(/"/g, '&quot;');
-}
+server.listen(PORT, '0.0.0.0', () => {
+    console.log(`✅ السيرفر يعمل على المنفذ ${PORT}`);
+});
 
-// دالة التحقق من التبريد (Cooldown) - تم إصلاحها بالكامل
-function isOnCooldown(type, key, duration) {
-  const now = Date.now();
-  const last = cooldowns[type].get(key);
-  if (last && (now - last) < duration) return true;
-  cooldowns[type].set(key, now);
-  return false;
-}
+// 2. الإعدادات من المتغيرات البيئية
+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(),
+};
 
-// إرسال لتيليجرام
-async function sendTelegram(text, photoUrl = null, buttons = null, parseMode = 'HTML', editMessageId = null, silent = false) {
-  updateActivity();
-  if (!CONFIG.TELEGRAM_TOKEN || !CONFIG.TELEGRAM_CHAT_ID) return null;
-  const baseUrl = `https://api.telegram.org/bot${CONFIG.TELEGRAM_TOKEN}`;
-  try {
-    let payload = { chat_id: CONFIG.TELEGRAM_CHAT_ID, parse_mode: parseMode, disable_web_page_preview: true, disable_notification: silent };
-    if (buttons) payload.reply_markup = { inline_keyboard: buttons };
-    let response;
-    if (editMessageId) { payload.message_id = editMessageId; payload.text = text; response = await axios.post(`${baseUrl}/editMessageText`, payload); }
-    else if (photoUrl) { payload.photo = photoUrl; payload.caption = text; response = await axios.post(`${baseUrl}/sendPhoto`, payload); }
-    else { payload.text = text; response = await axios.post(`${baseUrl}/sendMessage`, payload); }
-    return response.data;
-  } catch (e) { console.error(`[Telegram] Error:`, e.message); return null; }
+// 3. دالة إرسال التنبيهات لتيليجرام
+async function sendTg(text) {
+    if (!CONFIG.TELEGRAM_TOKEN) return;
+    try {
+        await axios.post(`https://api.telegram.org/bot${CONFIG.TELEGRAM_TOKEN}/sendMessage`, {
+            chat_id: CONFIG.TELEGRAM_CHAT_ID,
+            text: text,
+            parse_mode: 'HTML'
+        });
+    } catch (e) {
+        console.error('❌ خطأ في تيليجرام:', e.message);
+    }
 }
 
-// إنشاء الاتصال (نسخة 2.1+)
-function createConnection() {
-  const options = {
-    processInitialData: true,
-    enableExtendedGiftInfo: true,
-    webClientParams: { app_language: 'ar-IQ', device_platform: 'web' },
-  };
-  if (CONFIG.SESSION_ID) {
-    options.sessionId = CONFIG.SESSION_ID;
-    options.ttTargetIdc = CONFIG.TT_TARGET_IDC || 'alisg';
-    options.authenticateWs = true;
-  }
-  return new TikTokLiveConnection(CONFIG.TIKTOK_USERNAME, options);
-}
+// 4. إدارة الاتصال بتيك توك
+let tiktokConnection = null;
+let isConnected = false;
 
-// معالجة الأحداث
-function setupEvents(conn) {
-  conn.on(ControlEvent.CONNECTED, (state) => {
-    console.log('[TikTok] Connected!');
-    isConnected = true; isLive = true; startTime = new Date(); lastReportTime = new Date();
-    sendTelegram(`📡 البث بدأ! @${CONFIG.TIKTOK_USERNAME}`);
-  });
-
-  conn.on(WebcastEvent.CHAT, (data) => {
-    updateActivity();
-    const nickname = data.user?.nickname || data.user?.uniqueId || 'مجهول';
-    if (!isOnCooldown('chat', data.user?.uniqueId, 4000)) {
-        console.log(`[Chat] ${nickname}: ${data.comment}`);
+async function connectToTikTok() {
+    console.log(`🔎 محاولة الاتصال بحساب: @${CONFIG.TIKTOK_USERNAME}`);
+    
+    try {
+        const options = {
+            processInitialData: true,
+            enableExtendedGiftInfo: true,
+            webClientParams: { app_language: 'ar-IQ', device_platform: 'web' },
+        };
+
+        if (CONFIG.SESSION_ID) {
+            options.sessionId = CONFIG.SESSION_ID;
+            options.ttTargetIdc = CONFIG.TT_TARGET_IDC;
+            options.authenticateWs = true;
+        }
+
+        tiktokConnection = new TikTokLiveConnection(CONFIG.TIKTOK_USERNAME, options);
+
+        tiktokConnection.on(ControlEvent.CONNECTED, (state) => {
+            isConnected = true;
+            console.log(`✅ متصل بنجاح! ID الغرفة: ${state.roomId}`);
+            sendTg(`📡 <b>تم الاتصال بالبث المباشر!</b>\n👤 المُضيف: @${CONFIG.TIKTOK_USERNAME}`);
+        });
+
+        tiktokConnection.on(WebcastEvent.CHAT, (data) => {
+            console.log(`💬 ${data.user.nickname}: ${data.comment}`);
+        });
+
+        tiktokConnection.on(WebcastEvent.GIFT, (data) => {
+            if (data.giftType === 1 && !data.repeatEnd) return;
+            const coins = data.diamondCount * data.repeatCount;
+            if (coins >= 1) { // يمكنك تغيير هذا الرقم لتنبيهك بالهدايا الكبيرة فقط
+                sendTg(`🎁 <b>${data.user.nickname}</b> أرسل <b>${data.giftName}</b> (x${data.repeatCount})\n💎 القيمة: ${coins} ماسة`);
+            }
+        });
+
+        tiktokConnection.on(WebcastEvent.STREAM_END, () => {
+            isConnected = false;
+            console.log('🔴 انتهى البث.');
+            sendTg(`🔴 <b>انتهى البث المباشر لـ @${CONFIG.TIKTOK_USERNAME}</b>`);
+            setTimeout(connectToTikTok, 60000); 
+        });
+
+        tiktokConnection.on(ControlEvent.DISCONNECTED, () => {
+            isConnected = false;
+            console.log('📴 انقطع الاتصال، جاري المحاولة مرة أخرى...');
+            setTimeout(connectToTikTok, 30000);
+        });
+
+        tiktokConnection.on(ControlEvent.ERROR, (err) => {
+            console.error('⚠️ خطأ:', err.info || err);
+        });
+
+        await tiktokConnection.connect();
+
+    } catch (err) {
+        console.error('❌ فشل الاتصال:', err.message);
+        setTimeout(connectToTikTok, 30000);
     }
-  });
-
-  conn.on(WebcastEvent.GIFT, (data) => {
-    updateActivity();
-    if (data.giftType === 1 && !data.repeatEnd) return; // تخطي الهدايا المتتالية حتى تنتهي
-    const totalCost = data.diamondCount * data.repeatCount;
-    totalGifts++;
-    const nickname = data.user?.nickname || data.user?.uniqueId || 'مجهول';
-    sendTelegram(`🎁 ${nickname} أرسل ${data.giftName} (x${data.repeatCount}) \n💎 ${totalCost} ماسة`, null, null, 'HTML', null, totalCost < 100);
-  });
-
-  conn.on(WebcastEvent.LIKE, (data) => {
-    totalLikes += data.likeCount;
-    if (data.likeCount > 50) {
-        const nickname = data.user?.nickname || 'مجهول';
-        sendTelegram(`❤️ ${nickname} أرسل ${data.likeCount} إعجاب!`, null, null, 'HTML', null, true);
-    }
-  });
-
-  conn.on(WebcastEvent.STREAM_END, () => {
-    isConnected = false; isLive = false;
-    sendTelegram(`🔴 انتهى البث المباشر.`);
-  });
-
-  conn.on(ControlEvent.ERROR, (err) => console.error('[TikTok Error]', err));
 }
 
-async function startRadar() {
-  try {
-    tiktokConnection = createConnection();
-    setupEvents(tiktokConnection);
-    await tiktokConnection.connect();
-  } catch (err) {
-    console.error('[Radar] Failed:', err.message);
-    setTimeout(startRadar, 30000);
-  }
-}
-
-// سيرفر بسيط للبقاء حياً
-http.createServer((req, res) => {
-  res.writeHead(200);
-  res.end(`TikTok Bot Active | @${CONFIG.TIKTOK_USERNAME}`);
-}).listen(process.env.PORT || 7860);
-
-startRadar();
+connectToTikTok();