Update index.js

index.js

@@ -2,14 +2,17 @@ const { WebcastPushConnection } = require('tiktok-live-connector');
 const axios = require('axios');
 const dns = require('dns');
 
-// --- إعداداتك الخاصة ⚙️ ---
-const TIKTOK_USERNAME = "talalmsa455"; 
+// --- إعدادات الحساب الجديد والتلجرام ⚙️ ---
+const TIKTOK_USERNAME = "ah_md107"; 
 const TELEGRAM_TOKEN = "8576498050:AAHB51H9vLwFhDUFqYWttPaSa5qhPLzQVWE"; 
 const TELEGRAM_CHAT_ID = "-1002856018359"; 
 
 dns.setServers(['8.8.8.8']);
 
-// دالة إرسال الرسائل إلى تلجرام 📨
+// متغيرات لتتبع حالة الإشعارات لضمان عدم التكرار المزعج 🔑
+let notified150 = false;
+let notified200 = false;
+
 async function sendToTelegram(text) {
     try {
         const addrs = await new Promise(r => dns.resolve4('api.telegram.org', (e, a) => r(a)));
@@ -17,12 +20,11 @@ async function sendToTelegram(text) {
             chat_id: TELEGRAM_CHAT_ID,
             text: text,
             parse_mode: 'HTML',
-            disable_web_page_preview: false
+            disable_web_page_preview: false // للسماح بظهور صورة الحساب من الرابط 🖼️
         }, { headers: { 'Host': 'api.telegram.org' } });
     } catch (e) { console.log("خطأ في إرسال التلجرام"); }
 }
 
-// إعداد الاتصال ببث تيك توك 📡
 let tiktokConnection = new WebcastPushConnection(TIKTOK_USERNAME, {
     processInitialData: true,
     enableWebsocketUpgrade: true,
@@ -32,40 +34,41 @@ let tiktokConnection = new WebcastPushConnection(TIKTOK_USERNAME, {
     }
 });
 
-let lastViewerCount = 0;
-
-// 1. حدث: عند اكتشاف بدء البث المباشر 🔴
+// 1. إشعار عند فتح البث مباشرة 🚀
 tiktokConnection.connect().then(state => {
+    // تصفير الحالات عند بداية كل بث جديد
+    notified150 = false;
+    notified200 = false;
+    
     const liveLink = `https://www.tiktok.com/@${TIKTOK_USERNAME}/live`;
     const msg = `🚀 <b>بدأ البث المباشر الآن!</b>\n\n` +
                 `👤 الحساب: <code>${TIKTOK_USERNAME}</code>\n` +
                 `🔗 الرابط: ${liveLink}\n` +
                 `📊 الحالة: متصل وجاري المراقبة`;
     sendToTelegram(msg);
-    console.log("✅ تم إرسال تنبيه بدء البث والرابط");
 }).catch(err => {
-    console.log("🔎 الحساب أوفلاين، سأحاول مجدداً بعد قليل...");
+    console.log("🔎 يبحث عن بث نشط...");
 });
 
-// 2. حدث: تحديث عدد المشاهدين بشكل دوري 👁️
+// 2. مراقبة مستويات المشاهدين (150 و 200) 👁️
 tiktokConnection.on('roomUser', (data) => {
-    const currentViewers = data.viewerCount;
-    console.log(`📈 عدد المشاهدين الحالي: ${currentViewers}`);
+    const viewers = data.viewerCount;
+    const liveLink = `https://www.tiktok.com/@${TIKTOK_USERNAME}/live`;
 
-    // إرسال تحديث للتلجرام فقط إذا تغير العدد بمقدار كبير (مثلاً 50 مشاهد) 
-    // لتجنب إزعاجك بكثرة الرسائل
-    if (Math.abs(currentViewers - lastViewerCount) >= 50) {
-        const liveLink = `https://www.tiktok.com/@${TIKTOK_USERNAME}/live`;
-        sendToTelegram(`📊 <b>تحديث عدد المشاهدين</b>\n\n👁️ العدد الحالي: <b>${currentViewers}</b>\n🔗 الرابط: ${liveLink}`);
-        lastViewerCount = currentViewers;
+    // تنبيه عند وصول المشاهدين إلى 200 فأكثر 🔥
+    if (viewers >= 200 && !notified200) {
+        sendToTelegram(`🔥 <b>إنجاز جديد! البث يتخطى 200 مشاهد</b>\n\n👁️ العدد الحالي: <b>${viewers}</b>\n🔗 الرابط: ${liveLink}`);
+        notified200 = true; // إغلاق التنبيه لمنع التكرار
+    } 
+    // تنبيه عند وصول المشاهدين إلى 150 (ولم يصل للـ 200 بعد) 📈
+    else if (viewers >= 150 && viewers < 200 && !notified150) {
+        sendToTelegram(`📈 <b>تحديث: البث يتخطى 150 مشاهد</b>\n\n👁️ العدد الحالي: <b>${viewers}</b>\n🔗 الرابط: ${liveLink}`);
+        notified150 = true; // إغلاق التنبيه لمنع التكرار
     }
 });
 
-// 3. إعادة الاتصال التلقائي 🔄
 tiktokConnection.on('disconnected', () => {
-    console.log("🔌 انقطع الاتصال، جاري إعادة المحاولة...");
     setTimeout(() => tiktokConnection.connect(), 15000);
 });
 
-// سيرفر للبقاء نشطاً على Hugging Face 🔌
 require('http').createServer((req, res) => res.end('Radar Active')).listen(7860);