Update index.js

index.js

@@ -2,47 +2,92 @@ const { WebcastPushConnection } = require('tiktok-live-connector');
 const axios = require('axios');
 const http = require('http');
 
-// جلب الإعدادات
+// جلب الإعدادات من Variables
 const { TELEGRAM_TOKEN, TELEGRAM_CHAT_ID, SESSION_ID, ACCOUNTS_LIST } = process.env;
 const ACCOUNTS = ACCOUNTS_LIST ? ACCOUNTS_LIST.split(',') : [];
 
+// مخزن مراقبة السبام
+let spamTracker = {};
+
 function startRadar(username) {
     let user = username.trim();
     
-    // تعريف الاتصال المتوافق مع Node 18
+    // إعداد الاتصال المتوافق مع Node 18
     let connection = new WebcastPushConnection(user, {
         processInitialData: true,
         enableWebsocketUpgrade: true,
-        sessionId: SESSION_ID
+        sessionId: SESSION_ID,
+        clientParams: { "tt_target_idc": "useast1a" }
     });
 
     connection.connect().then(() => {
-        console.log(`✅ متصل: ${user}`);
+        sendToTelegram(`🟢 <b>بدأ الرادار الشامل:</b> <code>${user}</code>`);
     }).catch(err => {
-        console.log(`❌ خطأ في ${user}: ${err.message}`);
+        console.log(`❌ خطأ اتصال ${user}: ${err.message}`);
         setTimeout(() => startRadar(user), 15000);
     });
 
-    // رادار الصناديق والحقائب
+    // 💰 1. رادار الحقائب والصناديق بكل أنواعها
     connection.on('common', (data) => {
-        // في الإصدارات الأقدم، كانت الحقائب تأتي تحت حدث 'common' أحياناً
-        if (data.displayType && data.displayType.includes('box')) {
-             console.log("صندوق محتمل ظهر!");
+        if (data.displayType && (data.displayType.includes('box') || data.displayType.includes('envelope'))) {
+            sendToTelegram(`🎁 <b>ظهور كنز!</b>\n👤 الحساب: @${user}\n🔍 النوع: ${data.displayType}`);
+        }
+    });
+
+    // 👑 2. رادار المشرفين و VIP (لفل 40+)
+    connection.on('member', (data) => {
+        if (data.userLevel >= 40 || data.isModerator) {
+            const role = data.isModerator ? "مشرف 🛡️" : "VIP 👑";
+            sendToTelegram(`✨ <b>دخول ${role}:</b>\n👤 @${data.uniqueId} (Lvl ${data.userLevel})`);
+        }
+    });
+
+    // 🎤 3. رادار المشاهدات العالية (مؤشر الكيست القوي)
+    connection.on('roomUser', (data) => {
+        if (data.viewerCount > 5000) {
+            console.log(`مشاهدات عالية في بث ${user}: ${data.viewerCount}`);
         }
     });
 
-    // رادار الهدايا (الداعمين)
+    // 🎁 4. رادار الداعمين (الهدايا التي تساوي 100 عملة فأكثر)
     connection.on('gift', (data) => {
-        if (data.repeatEnd) {
-            const msg = `🎁 <b>هدية جديدة!</b>\n👤 الداعم: ${data.nickname}\n💝 الهدية: ${data.giftName}\n💎 القيمة: ${data.diamondCount * data.repeatCount}`;
-            axios.post(`https://api.telegram.org/bot${TELEGRAM_TOKEN}/sendMessage`, {
-                chat_id: TELEGRAM_CHAT_ID, text: msg, parse_mode: 'HTML'
-            });
+        if (data.diamondCount >= 100 && data.repeatEnd) {
+            sendToTelegram(`💎 <b>دعم قوي!</b>\n👤 الداعم: ${data.nickname}\n💝 الهدية: ${data.giftName} (x${data.repeatCount})`);
+        }
+    });
+
+    // 🛡️ 5. كاشف السبام (100 رسالة مطابقة في الدقيقة)
+    connection.on('chat', (data) => {
+        const msg = data.comment;
+        const now = Date.now();
+
+        if (!spamTracker[msg]) {
+            spamTracker[msg] = { count: 1, startTime: now };
+        } else {
+            if (now - spamTracker[msg].startTime < 60000) {
+                spamTracker[msg].count++;
+                if (spamTracker[msg].count === 100) {
+                    sendToTelegram(`⚠️ <b>تحذير سبام (100 رسالة/دقيقة):</b>\n💬 النص: "${msg}"\n👤 الحساب: @${user}`);
+                }
+            } else {
+                spamTracker[msg] = { count: 1, startTime: now };
+            }
         }
     });
 
     connection.on('disconnected', () => setTimeout(() => startRadar(user), 10000));
 }
 
+async function sendToTelegram(text) {
+    try {
+        await axios.post(`https://api.telegram.org/bot${TELEGRAM_TOKEN}/sendMessage`, {
+            chat_id: TELEGRAM_CHAT_ID, text: text, parse_mode: 'HTML'
+        });
+    } catch (e) { console.log("خطأ في إرسال التلجرام"); }
+}
+
+// تشغيل الرادار لكل الحسابات
 ACCOUNTS.forEach(user => startRadar(user));
-http.createServer((req, res) => res.end('Radar Stable Active')).listen(7860);
+
+// سيرفر بسيط لإبقاء الخدمة تعمل على Hugging Face
+http.createServer((req, res) => res.end('Radar Mega V7 Online')).listen(7860);