Update index.js

index.js

@@ -2,11 +2,11 @@ const WebSocket = require('ws');
 const axios = require('axios');
 const dns = require('dns');
 
-// --- بياناتك الأساسية ---
+// --- بياناتك ---
 const EULER_API_KEY = "Euler_Y2FlYTIyODYzNDQ0OTcxZjYyNGExZTkyMDM2NTMwZWE1ZjUzYmZmMDVmMGNlYjg0YzkzY2Vk"; 
 const TELEGRAM_TOKEN = "8576498050:AAHB51H9vLwFhDUFqYWttPaSa5qhPLzQVWE"; 
 const TELEGRAM_CHAT_ID = "-1002856018359"; 
-const TIKTOK_USERNAME = "talalmsa455"; // اليوزر الجديد الذي جربته
+const TIKTOK_USERNAME = "talalmsa455"; 
 
 dns.setServers(['8.8.8.8']);
 
@@ -23,47 +23,50 @@ async function sendToTelegram(text) {
             text: text,
             parse_mode: 'HTML'
         }, { headers: { 'Host': 'api.telegram.org' }, timeout: 10000 });
-    } catch (e) { console.log("Telegram Send Error"); }
+    } catch (e) { console.log("Telegram Error"); }
 }
 
 function connect() {
-    // أضفنا &msToken=1 للحصول على صلاحيات أعلى في استلام البيانات
-    const wsUrl = `wss://ws.eulerstream.com/v1/webcast?uniqueId=${TIKTOK_USERNAME}&apiKey=${EULER_API_KEY}&msToken=1`;
+    // استخدمنا رابطاً يجلب معلومات الغرفة (Room) لمراقبة العدد
+    const wsUrl = `wss://ws.eulerstream.com/v1/webcast?uniqueId=${TIKTOK_USERNAME}&apiKey=${EULER_API_KEY}`;
     
-    console.log(`📡 جاري مراقبة بث: ${TIKTOK_USERNAME}...`);
+    console.log(`🔎 مراقبة حالة بث: ${TIKTOK_USERNAME}`);
     const ws = new WebSocket(wsUrl);
 
     ws.on('open', () => {
-        console.log("✅ متصل بـ EulerStream");
-        sendToTelegram(`🔔 <b>بدأ البوت بمراقبة بث:</b> ${TIKTOK_USERNAME}\nانتظر وصول التعليقات...`);
+        console.log("✅ متصل بنظام التنبيهات");
+        sendToTelegram(`📡 <b>بدأت مراقبة البث لـ:</b> ${TIKTOK_USERNAME}\nسأخطرك عند وجود تحديثات.`);
     });
 
     ws.on('message', (data) => {
-        const msg = JSON.parse(data);
-        
-        // طباعة الحدث في الـ Logs للتأكد من وصوله
-        console.log(`📩 حدث جديد: ${msg.type}`);
+        try {
+            const msg = JSON.parse(data);
+            
+            // 1. مراقبة عدد المشاهدين (تحديث كلما تغير الرقم)
+            if (msg.viewerCount !== undefined) {
+                console.log(`📈 عدد المشاهدين الحالي: ${msg.viewerCount}`);
+                // يمكنك تفعيل الإرسال لتلجرام هنا إذا أردت تحديثاً مستمراً للعدد
+            }
 
-        if (msg.type === 'comment') {
-            sendToTelegram(`💬 <b>${msg.nickname}:</b>\n${msg.comment}`);
-        } 
-        else if (msg.type === 'gift') {
-            sendToTelegram(`🎁 <b>${msg.nickname}</b> أرسل هدية: <b>${msg.giftName}</b>`);
-        }
-        else if (msg.type === 'social') { // متابعة أو مشاركة
-            sendToTelegram(`👤 <b>${msg.nickname}</b> قام بمتابعة البث!`);
+            // 2. تنبيه عند بدء البث أو تغير حالته
+            if (msg.type === 'roomUser' || msg.type === 'member') {
+                 // هذه الأحداث تشير إلى نشاط المشاهدين داخل الغرفة
+                 console.log("👤 نشاط جديد في الغرفة");
+            }
+
+            // لتصحيح الـ undefined ومعرفة الأنواع المتاحة
+            console.log("📥 نوع الحدث المستلم:", msg.type || "غير معروف");
+
+        } catch (e) {
+            console.log("❌ خطأ في تحليل البيانات");
         }
     });
 
     ws.on('close', (code) => {
-        console.log(`❌ انقطع الاتصال، الكود: ${code}`);
-        // إذا كان الكود 4556، سنحاول إعادة الاتصال بعد فترة وجيزة
-        let delay = (code === 4556) ? 10000 : 5000;
-        setTimeout(connect, delay);
+        console.log(`❌ انقطع الاتصال (${code})، إعادة المحاولة...`);
+        setTimeout(connect, 10000);
     });
-
-    ws.on('error', (err) => console.log("Socket Error:", err.message));
 }
 
 connect();
-require('http').createServer((r, s) => s.end('OK')).listen(7860);
+require('http').createServer((req, res) => res.end('Monitor Active')).listen(7860);