Update index.js

index.js

@@ -2,15 +2,14 @@ const { WebcastPushConnection } = require('tiktok-live-connector');
 const axios = require('axios');
 const dns = require('dns');
 
-// --- الإعدادات الأساسية ⚙️ ---
+// --- الإعدادات ⚙️ ---
 const TIKTOK_USERNAME = "ah_md107"; 
 const TELEGRAM_TOKEN = "8576498050:AAHB51H9vLwFhDUFqYWttPaSa5qhPLzQVWE"; 
 const TELEGRAM_CHAT_ID = "-1002856018359"; 
 
 dns.setServers(['8.8.8.8']);
 
-// متغير لحفظ أعلى مستوى "مئات" تم الوصول إليه 🏰
-let highestHundredReached = 0;
+let highestHundred = 0;
 
 async function sendToTelegram(text) {
     try {
@@ -21,7 +20,7 @@ async function sendToTelegram(text) {
             parse_mode: 'HTML',
             disable_web_page_preview: false 
         }, { headers: { 'Host': 'api.telegram.org' } });
-    } catch (e) { console.log("خطأ في إرسال التلجرام"); }
+    } catch (e) { console.log("خطأ في التلجرام"); }
 }
 
 let tiktokConnection = new WebcastPushConnection(TIKTOK_USERNAME, {
@@ -33,41 +32,60 @@ let tiktokConnection = new WebcastPushConnection(TIKTOK_USERNAME, {
     }
 });
 
-// 1. تنبيه عند فتح البث 🚀
+// 1. إشعار بداية البث 🚀
 tiktokConnection.connect().then(state => {
-    highestHundredReached = 0; // تصفير القمة عند بداية كل بث جديد
+    highestHundred = 0;
     const liveLink = `https://www.tiktok.com/@${TIKTOK_USERNAME}/live`;
-    const msg = `🔴 <b>بدأ البث المباشر الآن!</b>\n\n` +
-                `👤 الحساب: <code>${TIKTOK_USERNAME}</code>\n` +
-                `🔗 الرابط: ${liveLink}`;
-    sendToTelegram(msg);
-}).catch(err => {
-    console.log("🔎 جاري البحث عن بث نشط...");
-});
+    sendToTelegram(`🚀 <b>بدأ البث المباشر الآن!</b>\n👤 الحساب: <code>${TIKTOK_USERNAME}</code>\n🔗 الرابط: ${liveLink}`);
+}).catch(err => console.log("بحث..."));
 
-// 2. مراقبة الصعود فقط (نظام القمة) 🏔️
+// 2. منطق إشعار "القمة الجديدة" 🏔️
 tiktokConnection.on('roomUser', (data) => {
-    const currentViewers = data.viewerCount;
+    const viewers = data.viewerCount;
     const liveLink = `https://www.tiktok.com/@${TIKTOK_USERNAME}/live`;
+    let currentHundred = Math.floor(viewers / 100) * 100;
 
-    // حساب مستوى المئات الحالي
-    let currentHundredLevel = Math.floor(currentViewers / 100) * 100;
-
-    // الشرط: يرسل فقط إذا كسرنا رقماً قياسياً جديداً في هذا البث 🏆
-    if (currentHundredLevel >= 100 && currentHundredLevel > highestHundredReached) {
-        const msg = `🚀 <b>مستوى قياسي جديد في البث!</b>\n\n` +
-                    `👁️ عدد المشاهدين الآن: <b>${currentViewers}</b>\n` +
-                    `📈 تجاوزنا عتبة: <b>${currentHundredLevel}</b>\n` +
+    if (currentHundred >= 100 && currentHundred > highestHundred) {
+        highestHundred = currentHundred;
+        const msg = `🎊 <b>إنجاز جديد في البث!</b>\n\n` +
+                    `👁️ عدد المشاهدين الآن: <b>${viewers}</b>\n` +
+                    `📈 تجاوزنا عتبة الـ <b>${currentHundred}</b> مشاهد\n` +
                     `🔗 الرابط: ${liveLink}`;
-        
         sendToTelegram(msg);
-        highestHundredReached = currentHundredLevel; // تحديث القمة الجديدة
-        console.log(`✅ تم تسجيل قمة جديدة: ${currentHundredLevel}`);
     }
 });
 
+// 3. إشعار انتهاء البث (توقيت بغداد 🇮🇶) 🏁
 tiktokConnection.on('disconnected', () => {
-    setTimeout(() => tiktokConnection.connect(), 15000);
+    const now = new Date();
+    
+    // إعداد التنسيق لمدينة بغداد
+    const options = { 
+        timeZone: 'Asia/Baghdad', 
+        year: 'numeric', 
+        month: 'numeric', 
+        day: 'numeric', 
+        hour: '2-digit', 
+        minute: '2-digit', 
+        hour12: true 
+    };
+
+    const formatter = new Intl.DateTimeFormat('ar-IQ', options);
+    const parts = formatter.formatToParts(now);
+    
+    // استخراج التاريخ والوقت من التنسيق العراقي
+    const dateStr = `${parts.find(p => p.type === 'day').value}/${parts.find(p => p.type === 'month').value}/${parts.find(p => p.type === 'year').value}`;
+    const timeStr = `${parts.find(p => p.type === 'hour').value}:${parts.find(p => p.type === 'minute').value} ${parts.find(p => p.type === 'dayPeriod').value}`;
+
+    const endMsg = `🏁 <b>انتهى البث المباشر</b>\n\n` +
+                   `👤 الحساب: <code>${TIKTOK_USERNAME}</code>\n` +
+                   `📅 التاريخ: ${dateStr}\n` +
+                   `⏰ الوقت (بغداد): ${timeStr}\n` +
+                   `🏆 أعلى قمة مشاهدين: ${highestHundred}`;
+    
+    sendToTelegram(endMsg);
+    
+    setTimeout(() => tiktokConnection.connect(), 30000);
 });
 
 require('http').createServer((req, res) => res.end('Radar Active')).listen(7860);