Update index.js

index.js

@@ -2,16 +2,17 @@ const WebSocket = require('ws');
 const axios = require('axios');
 const http = require('http');
 
-// --- إعداداتك الثابتة ---
+// --- بياناتك الشخصية المستخرجة من الصور ---
 const EULER_API_KEY = "Euler_Y2FlYTIyODYzNDQ0OTcxZjYyNGExZTkyMDM2NTMwZWE1ZjUzYmZmMDVmMGNlYjg0YzkzY2Vk"; 
 const TELEGRAM_TOKEN = "8576498050:AAHB51H9vLwFhDUFqYWttPaSa5qhPLzQVWE"; 
 const TELEGRAM_CHAT_ID = "-1002856018359"; 
 const TIKTOK_USERNAME = "ah_md107";
+const ACCOUNT_ID = "7158"; // معرف حسابك الظاهر في الصورة الأولى
 
-// إنشاء سيرفر بسيط لضمان استقرار الاستضافة
+// خادم وهمي لضمان استقرار الاستضافة على Hugging Face
 http.createServer((req, res) => {
     res.writeHead(200);
-    res.end('System Status: Online');
+    res.end('Bot Monitoring: ah_md107');
 }).listen(7860);
 
 async function sendToTelegram(text) {
@@ -20,54 +21,52 @@ async function sendToTelegram(text) {
             chat_id: TELEGRAM_CHAT_ID,
             text: text,
             parse_mode: 'HTML'
-        });
-    } catch (e) { console.error("Telegram Error"); }
+        }, { timeout: 10000 });
+    } catch (e) {
+        console.log("⚠️ Telegram Error: Connection Timeout");
+    }
 }
 
 function connect() {
-    // تحديث الرابط ليكون متوافقاً مع أحدث تعليمات السوكيت
-    const wsUrl = `wss://ws.eulerstream.com/v1/webcast?uniqueId=${TIKTOK_USERNAME}`;
+    // الرابط الرسمي المباشر وفقاً لأحدث تحديثات الموقع
+    const wsUrl = `wss://ws.eulerstream.com/v1/webcast?uniqueId=${TIKTOK_USERNAME}&apiKey=${EULER_API_KEY}&accountId=${ACCOUNT_ID}`;
     
-    const ws = new WebSocket(wsUrl, {
-        headers: {
-            "Authorization": `Bearer ${EULER_API_KEY}`,
-            "Content-Type": "application/json"
-        }
-    });
+    const ws = new WebSocket(wsUrl);
 
     ws.on('open', () => {
         console.log("✅ تم الربط بنجاح مع EulerStream");
-        sendToTelegram(`📡 <b>تم العثور على البث!</b>\nجارٍ سحب التعليقات من: <code>${TIKTOK_USERNAME}</code>`);
+        sendToTelegram(`📡 <b>تم بدء المراقبة بنجاح!</b>\nالحساب: <code>${TIKTOK_USERNAME}</code>`);
     });
 
     ws.on('message', (data) => {
         try {
             const event = JSON.parse(data);
             
-            // التعامل مع التعليقات
-            if (event.type === 'comment' || event.method === 'chat') {
-                const name = event.nickname || event.user?.nickname || "مستخدم";
-                const msg = event.comment || event.text;
-                sendToTelegram(`💬 <b>${name}:</b> ${msg}`);
-            }
-
-            // التعامل مع الهدايا
-            if (event.type === 'gift') {
-                sendToTelegram(`🎁 <b>${event.nickname}</b> أرسل هدية: ${event.giftName}`);
+            // معالجة بيانات البث
+            if (event.type === 'comment') {
+                sendToTelegram(`💬 <b>${event.nickname}:</b> ${event.comment}`);
+            } else if (event.type === 'gift') {
+                sendToTelegram(`🎁 <b>${event.nickname}</b> أرسل: ${event.giftName} (x${event.repeatCount})`);
+            } else if (event.type === 'social') {
+                sendToTelegram(`👤 <b>${event.nickname}</b> قام بمتابعة الحساب!`);
             }
-        } catch (e) { }
+        } catch (e) {
+            // تجاهل البيانات غير النصية
+        }
     });
 
     ws.on('close', (code) => {
-        console.log(`❌ انقطع، الكود: ${code}`);
+        console.log(`❌ انقطع الاتصال، الكود: ${code}`);
         
-        // معالجة الخطأ 4556 - المحاولة مرة أخرى بعد فترة أطول قليلاً
-        if (code === 4556) {
-            console.log("⚠️ السيرفر لم يستجب لبيانات البث، جاري المحاولة بعد 20 ثانية...");
-            setTimeout(connect, 20000);
-        } else {
-            setTimeout(connect, 5000);
+        let delay = 5000;
+        if (code === 4400) {
+            console.log("⚠️ مشكلة في صياغة الطلب، جاري المحاولة برابط بديل...");
+        } else if (code === 4556) {
+            console.log("ℹ️ بانتظار استقرار بيانات البث من تيك توك...");
+            delay = 15000;
         }
+
+        setTimeout(connect, delay);
     });
 
     ws.on('error', (err) => {