Update index.js

index.js

@@ -1,37 +1,38 @@
 const { WebcastPushConnection } = require('tiktok-live-connector');
 const axios = require('axios');
 const dns = require('dns');
+const http = require('http');
 
-// --- الإعدادات ⚙️ ---
+// ⚙️ --- الإعدادات ---
 const TIKTOK_USERNAME = "ah_md107"; 
 const TELEGRAM_TOKEN = "8576498050:AAHB51H9vLwFhDUFqYWttPaSa5qhPLzQVWE"; 
 const TELEGRAM_CHAT_ID = "-1003584586221"; 
 const SESSION_ID = "b00764f9693c9ee7482fea8d005837a8"; 
+const FIXED_COUNTRY = "العراق 🇮🇶";
 
-// إعداد DNS (لحل مشاكل الاتصال في بعض السيرفرات)
+// تحسين الاتصال بالسيرفرات
 dns.setServers(['8.8.8.8']);
 
-// --- المتغيرات العامة 📊 ---
+// 📊 --- المتغيرات العامة ---
 let highestHundred = 0; 
 let maxViewers = 0;     
 let totalLikes = 0;     
-let totalShares = 0;    // عدد المشاركات
-let totalGiftsCount = 0; // عدد الهدايا المستلمة
-let giftersMap = {};    // لتخزين الداعمين وحساب نقاطهم
-let bestGift = { name: "لا يوجد", cost: 0, sender: "" }; // أقوى هدية
-let startTime = null;   // وقت بداية البث
-const FIXED_COUNTRY = "العراق 🇮🇶";
+let totalShares = 0;    
+let totalGiftsCount = 0; 
+let giftersMap = {};    // سجل الداعمين
+let bestGift = { name: "لا يوجد", cost: 0, sender: "" }; 
+let startTime = null;   
 
-// --- دوال مساعدة 🛠️ ---
+// 🛠️ --- دوال مساعدة ---
 
-// 1. دالة تنسيق الأرقام (1000 -> 1K)
+// تنسيق الأرقام (1000 => 1K)
 function formatK(num) {
     if (num >= 1000000) return (num / 1000000).toFixed(1) + 'M';
     if (num >= 1000) return (num / 1000).toFixed(1) + 'K';
     return num.toString();
 }
 
-// 2. دالة جلب وقت وتاريخ بغداد
+// توقيت بغداد
 function getBaghdadTime() {
     return new Intl.DateTimeFormat('ar-IQ', { 
         timeZone: 'Asia/Baghdad', 
@@ -41,7 +42,7 @@ function getBaghdadTime() {
     }).format(new Date());
 }
 
-// 3. دالة إرسال الرسائل إلى تلجرام
+// إرسال للتلجرام
 async function sendToTelegram(text) {
     try {
         const addrs = await new Promise(r => dns.resolve4('api.telegram.org', (e, a) => r(a)));
@@ -49,12 +50,12 @@ async function sendToTelegram(text) {
             chat_id: TELEGRAM_CHAT_ID,
             text: text,
             parse_mode: 'HTML',
-            disable_web_page_preview: false 
+            disable_web_page_preview: true // منع ظهور معاينة الرابط لجعل الرسالة أنظف
         }, { headers: { 'Host': 'api.telegram.org' } });
-    } catch (e) { console.log("⚠️ خطأ في إرسال رسالة التلجرام:", e.message); }
+    } catch (e) { console.log("⚠️ خطأ في التلجرام:", e.message); }
 }
 
-// إعداد الاتصال
+// إعداد اتصال التيك توك
 let tiktokConnection = new WebcastPushConnection(TIKTOK_USERNAME, {
     processInitialData: true,
     enableWebsocketUpgrade: true,
@@ -66,25 +67,27 @@ let tiktokConnection = new WebcastPushConnection(TIKTOK_USERNAME, {
 });
 
 // ==========================================
-// 🚀 1. عند بداية البث والاتصال
+// 🚀 1. عند بداية البث
 // ==========================================
 tiktokConnection.connect().then(state => {
-    // تصفير العدادات
+    // تصفير جميع العدادات
     highestHundred = 0; maxViewers = 0; totalLikes = 0; 
     totalShares = 0; totalGiftsCount = 0;
     giftersMap = {}; 
     bestGift = { name: "لا يوجد", cost: 0, sender: "" };
-    startTime = new Date(); // تسجيل وقت البداية الفعلي
+    startTime = new Date();
 
     const liveLink = `https://www.tiktok.com/@${TIKTOK_USERNAME}/live`;
     const userImage = state.roomInfo?.owner?.avatar_thumb?.url_list[0] || "";
     const startStr = getBaghdadTime();
 
-    const msg = `<a href="${userImage}">‏‏‎ ‎</a>🔴 <b>بدأ البث المباشر!</b>\n\n` +
-                `👤 الحساب: <code>${TIKTOK_USERNAME}</code>\n` +
-                `🌍 الدولة: <b>${FIXED_COUNTRY}</b>\n` +
-                `📅 البدء: ${startStr}\n` +
-                `🔗 الرابط: ${liveLink}`;
+    const msg = `🔴 <b>انطلاق البث المباشر</b>\n` +
+                `─────────────────\n` +
+                `👤 <b>الحساب:</b> <code>${TIKTOK_USERNAME}</code>\n` +
+                `🌍 <b>الدولة:</b> ${FIXED_COUNTRY}\n` +
+                `📅 <b>الوقت :</b> <code>${startStr}</code>\n` +
+                `─────────────────\n` +
+                `🔗 <a href="${liveLink}"><b>اضغط هنا للدخول للبث</b></a>`;
 
     sendToTelegram(msg);
     console.log(`✅ تم الاتصال بحساب ${TIKTOK_USERNAME}.`);
@@ -93,7 +96,7 @@ tiktokConnection.connect().then(state => {
 });
 
 // ==========================================
-// 🏔️ 2. مراقبة المشاهدين
+// 🏔️ 2. مراقبة المشاهدين (تنبيه كل 100)
 // ==========================================
 tiktokConnection.on('roomUser', (data) => {
     const viewers = data.viewerCount;
@@ -104,10 +107,10 @@ tiktokConnection.on('roomUser', (data) => {
         highestHundred = currentHundred;
         const liveLink = `https://www.tiktok.com/@${TIKTOK_USERNAME}/live`;
         
-        const msg = `📈 <b>إنجاز جديد في المشاهدات!</b>\n\n` +
-                    `👁️ العدد الحالي: <b>${formatK(viewers)}</b>\n` +
-                    `🚀 تجاوزنا عتبة: <b>${formatK(currentHundred)}</b>\n` +
-                    `🔗 الرابط: ${liveLink}`;
+        const msg = `🚀 <b>إنجاز جديد في المشاهدات!</b>\n\n` +
+                    `🔢 <b>العدد الحالي:</b> <code>${formatK(viewers)}</code> 👀\n` +
+                    `🔝 <b>تجاوزنا رقم:</b> <code>${formatK(currentHundred)}</code> 🔥\n` +
+                    `🔗 <a href="${liveLink}">شاهد البث الآن</a>`;
         sendToTelegram(msg);
     }
 });
@@ -120,35 +123,29 @@ tiktokConnection.on('like', (data) => {
 });
 
 tiktokConnection.on('social', (data) => {
-    // social type 1 means share
     if (data.displayType === 'pm_mt_guidance_share') {
         totalShares++;
     }
 });
 
 // ==========================================
-// 🎁 4. الهدايا والداعمين (المنطق المطور)
+// 🎁 4. معالجة الهدايا والداعمين
 // ==========================================
 tiktokConnection.on('gift', (data) => {
-    if (data.giftType === 1 && !data.repeatEnd) return; // تجاهل الهدايا المتكررة حتى تنتهي
+    // تجاهل الهدية إذا كانت مجرد تكرار لنفس الهدية السابقة (لعدم تكرار الحساب)
+    if (data.giftType === 1 && !data.repeatEnd) return; 
 
-    // تحديث إجمالي الهدايا
     totalGiftsCount += 1;
-
-    // حساب تكلفة الهدية (عدد الماسات * التكرار)
     let giftCost = data.diamondCount * data.repeatCount;
     
-    // 1. تحديث قائمة الداعمين (Top 3 Logic)
+    // تسجيل الداعم (Top 3)
     let userId = data.userId;
     if (!giftersMap[userId]) {
-        giftersMap[userId] = { 
-            name: data.nickname, 
-            coins: 0 
-        };
+        giftersMap[userId] = { name: data.nickname, coins: 0 };
     }
     giftersMap[userId].coins += giftCost;
 
-    // 2. تحديث أقوى هدية (Best Gift Logic)
+    // تسجيل أقوى هدية (Best Gift)
     if (giftCost > bestGift.cost) {
         bestGift = {
             name: data.giftName,
@@ -159,12 +156,12 @@ tiktokConnection.on('gift', (data) => {
 });
 
 // ==========================================
-// 🏁 5. إشعار نهاية البث (التقرير الشامل)
+// 🏁 5. نهاية البث والتقرير الشامل
 // ==========================================
 tiktokConnection.on('disconnected', () => {
     const endTimeStr = getBaghdadTime();
     
-    // حساب مدة البث
+    // حساب المدة
     let durationStr = "غير محدد";
     if (startTime) {
         const diffMs = new Date() - startTime;
@@ -172,36 +169,55 @@ tiktokConnection.on('disconnected', () => {
         durationStr = `${diffMins} دقيقة`;
     }
 
-    // استخراج أفضل 3 داعمين
+    // ترتيب أفضل 3 داعمين
     let sortedGifters = Object.values(giftersMap).sort((a, b) => b.coins - a.coins);
+    
+    // تجهيز نص الداعمين
     let top3Msg = "";
     if (sortedGifters.length > 0) {
-        top3Msg += `\n🥇 <b>${sortedGifters[0].name}</b> (${formatK(sortedGifters[0].coins)} 🪙)`;
-        if (sortedGifters[1]) top3Msg += `\n🥈 <b>${sortedGifters[1].name}</b> (${formatK(sortedGifters[1].coins)} 🪙)`;
-        if (sortedGifters[2]) top3Msg += `\n🥉 <b>${sortedGifters[2].name}</b> (${formatK(sortedGifters[2].coins)} 🪙)`;
+        // الأول
+        top3Msg += `🥇 <code>${sortedGifters[0].name}</code> : <b>${formatK(sortedGifters[0].coins)}</b>\n`;
+        // الثاني
+        if (sortedGifters[1]) top3Msg += `🥈 <code>${sortedGifters[1].name}</code> : <b>${formatK(sortedGifters[1].coins)}</b>\n`;
+        // الثالث
+        if (sortedGifters[2]) top3Msg += `🥉 <code>${sortedGifters[2].name}</code> : <b>${formatK(sortedGifters[2].coins)}</b>\n`;
     } else {
-        top3Msg = "لا يوجد داعمين";
+        top3Msg = "<i>لا يوجد داعمين في هذا البث</i>";
     }
 
-    const endMsg = `🏁 <b>ملخص نهاية البث</b>\n\n` +
-                   `👤 الحساب: <code>${TIKTOK_USERNAME}</code>\n` +
-                   `📅 انتهى في: ${endTimeStr}\n` +
-                   `⏱️ المدة: ${durationStr}\n\n` +
-                   `📊 <b>الإحصائيات:</b>\n` +
-                   `👁️ أقصى مشاهدات: <b>${formatK(maxViewers)}</b>\n` +
-                   `❤️ الإعجابات: <b>${formatK(totalLikes)}</b>\n` +
-                   `🔄 المشاركات: <b>${formatK(totalShares)}</b>\n\n` +
-                   `🎁 <b>أقوى هدية:</b>\n` +
-                   `📦 ${bestGift.name} (بقيمة ${formatK(bestGift.cost)})\n` +
-                   `👤 من: ${bestGift.sender}\n\n` +
-                   `🏆 <b>أفضل 3 داعمين:</b>\n${top3Msg}`;
+    const endMsg = `🏁 <b>ملخص نهاية البث</b>\n` +
+                   `─────────────────\n` +
+                   `👤 <b>المستخدم:</b> <code>${TIKTOK_USERNAME}</code>\n` +
+                   `⏱️ <b>المدة   :</b> ${durationStr}\n` +
+                   `📅 <b>انتهى في:</b> ${endTimeStr}\n` +
+                   `─────────────────\n` +
+                   `📊 <b>الإحصائيات العامة:</b>\n` +
+                   `👁️ <code>${formatK(maxViewers)}</code> مشاهدة\n` +
+                   `❤️ <code>${formatK(totalLikes)}</code> إعجاب\n` +
+                   `🔄 <code>${formatK(totalShares)}</code> مشاركة\n\n` +
+                   `💎 <b>أقوى هدية وصلت:</b>\n` +
+                   `🎁 الهدية: <b>${bestGift.name}</b>\n` +
+                   `💰 القيمة: <code>${formatK(bestGift.cost)}</code>\n` +
+                   `👤 المرسل: <code>${bestGift.sender}</code>\n\n` +
+                   `🏆 <b>أفضل 3 داعمين:</b>\n` +
+                   `${top3Msg}`;
     
     sendToTelegram(endMsg);
     
-    // إعادة الاتصال بعد 30 ثانية
-    console.log("⚠️ تم قطع الاتصال، سيتم المحاولة مرة أخرى خلال 30 ثانية...");
+    console.log("⚠️ انتهى البث. إعادة الاتصال خلال 30 ثانية...");
     setTimeout(() => tiktokConnection.connect(), 30000);
 });
 
-// سيرفر بسيط لإبقاء البوت يعمل
-require('http').createServer((req, res) => res.end('Radar Active (Iraq Version)')).listen(7860);
+// معالجة الأخطاء العامة
+tiktokConnection.on('error', err => {
+    console.error('Error:', err);
+});
+
+// سيرفر ويب بسيط (لإبقاء البوت يعمل 24/7)
+const server = http.createServer((req, res) => {
+    res.writeHead(200, { 'Content-Type': 'text/plain' });
+    res.end('TikTok Radar is Active 24/7');
+});
+server.listen(7860, () => {
+    console.log("🌐 السيرفر يعمل على المنفذ 7860");
+});