Update bot.js

bot.js

@@ -6,27 +6,32 @@ const fs = require('fs');
 const path = require('path');
 const axios = require('axios');
 
-const token = '8141535657:AAHpD6GNWncBD9lEdfEuiJExwEVuROIodAI';
+const token = '7963845783:AAF7T5PdDKTrzENm4Kno-4PihY1DXdrROMU';
 const ADMIN_USER_ID = '7708913693';
-const WATERMARK_DIR = path.join(__dirname, 'watermarks');
-const activeStreams = new Map();
 
+const WATERMARK_DIR = path.join(__dirname, 'watermarks');
 if (!fs.existsSync(WATERMARK_DIR)) fs.mkdirSync(WATERMARK_DIR);
 
+const activeStreams = new Map();
+
 const bot = new TelegramBot(token, { polling: true });
 
-function log(msg) {
-  console.log(`[${new Date().toISOString()}] ${msg}`);
+// Logger with timestamp
+function log(message) {
+  console.log(`[${new Date().toISOString()}] ${message}`);
 }
 
-function isAdmin(id) {
-  return id.toString() === ADMIN_USER_ID;
+// Check admin
+function isAdmin(userId) {
+  return userId.toString() === ADMIN_USER_ID;
 }
 
+// Generate 4-digit stream ID
 function generateStreamId() {
   return Math.floor(1000 + Math.random() * 9000).toString();
 }
 
+// Download watermark image from URL and save
 async function downloadWatermark(url, name) {
   const filePath = path.join(WATERMARK_DIR, `${name}.png`);
   const response = await axios({ url, method: 'GET', responseType: 'stream' });
@@ -38,80 +43,116 @@ async function downloadWatermark(url, name) {
   });
 }
 
-// /start
+// /start command
 bot.onText(/\/start/, (msg) => {
-  const id = msg.from.id;
-  if (!isAdmin(id)) return bot.sendMessage(msg.chat.id, '❌ غير مصرح لك.');
-  bot.sendMessage(msg.chat.id, `
-مرحبًا! أوامر البوت:
-🟢 /stream <fbkey> <m3u8> [watermark] [cc] - بدء البث
-📷 /watermark <url> <name> - تحميل شعار
-🔁 /urlchange <id> <new_m3u8> - تغيير المصدر
-✍️ /cchange <id> <new_text> - تغيير النص
-📴 /stop <id> - إيقاف البث
-📟 /check - معلومات النظام`);
+  const userId = msg.from.id;
+  const chatId = msg.chat.id;
+  if (!isAdmin(userId)) {
+    bot.sendMessage(chatId, '❌ غير مصرح لك باستخدام هذا البوت.');
+    log(`Unauthorized /start from user ${userId}`);
+    return;
+  }
+  const message = `
+مرحبًا! هذه أوامر البوت:
+🟢 /stream <fbkey> <m3u8> [watermark] [cc] - بدء بث جديد
+📷 /watermark <url> <name> - تحميل شعار جديد
+🔁 /urlchange <id> <new_m3u8> - تغيير رابط البث
+✍️ /cchange <id> <new_text> - تغيير نص CC المتحرك
+🛑 /stop <id> - إيقاف بث
+📟 /check - معلومات النظام
+`;
+  bot.sendMessage(chatId, message.trim());
+  log(`Admin ${userId} used /start`);
 });
 
-// /watermark
-bot.onText(/\/watermark (.+) (.+)/, async (msg, [_, url, name]) => {
-  if (!isAdmin(msg.from.id)) return bot.sendMessage(msg.chat.id, '❌ غير مصرح.');
+// /watermark <url> <name>
+bot.onText(/\/watermark (.+) (.+)/, async (msg, match) => {
+  const userId = msg.from.id;
+  const chatId = msg.chat.id;
+  if (!isAdmin(userId)) {
+    bot.sendMessage(chatId, '❌ غير مصرح.');
+    log(`Unauthorized /watermark from user ${userId}`);
+    return;
+  }
+  const url = match[1].trim();
+  const name = match[2].trim();
+
   try {
-    const filePath = await downloadWatermark(url.trim(), name.trim());
-    bot.sendMessage(msg.chat.id, `✅ تم تحميل الشعار: ${filePath}`);
-  } catch (e) {
-    bot.sendMessage(msg.chat.id, `❌ خطأ في التحميل: ${e.message}`);
+    const filePath = await downloadWatermark(url, name);
+    bot.sendMessage(chatId, `✅ تم تحميل الشعار وحفظه باسم: ${name}.png`);
+    log(`Watermark downloaded by user ${userId}: ${filePath}`);
+  } catch (error) {
+    bot.sendMessage(chatId, `❌ خطأ في تحميل الشعار: ${error.message}`);
+    log(`Watermark download failed for user ${userId}: ${error.message}`);
   }
 });
 
-// /stream with single success/failure message
+// /stream <fbkey> <m3u8> [watermark] [cc]
 bot.onText(/\/stream (.+?) (.+?)(?: (.+?))?(?: (.+))?/, async (msg, match) => {
-  const [_, fbKey, m3u8Url, watermarkName, ccText = ''] = match;
-  const chatId = msg.chat.id;
   const userId = msg.from.id;
+  const chatId = msg.chat.id;
+  if (!isAdmin(userId)) {
+    bot.sendMessage(chatId, '❌ غير مصرح.');
+    log(`Unauthorized /stream from user ${userId}`);
+    return;
+  }
 
-  if (!isAdmin(userId)) return bot.sendMessage(chatId, '❌ غير مصرح.');
+  const fbKey = match[1].trim();
+  const m3u8Url = match[2].trim();
+  const watermarkName = match[3] ? match[3].trim() : null;
+  const ccText = match[4] ? match[4].trim() : '';
 
-  const rtmpsUrl = `rtmps://live-api-s.facebook.com:443/rtmp/${fbKey.trim()}`;
+  const rtmpsUrl = `rtmps://live-api-s.facebook.com:443/rtmp/${fbKey}`;
   let watermarkPath = null;
 
   if (watermarkName) {
     watermarkPath = path.join(WATERMARK_DIR, `${watermarkName}.png`);
     if (!fs.existsSync(watermarkPath)) {
-      return bot.sendMessage(chatId, `❌ الشعار ${watermarkName}.png غير موجود`);
+      bot.sendMessage(chatId, `❌ الشعار ${watermarkName}.png غير موجود.`);
+      log(`Watermark ${watermarkName}.png not found for user ${userId}`);
+      return;
     }
   }
 
   if (!m3u8Url.startsWith('http') || !rtmpsUrl.startsWith('rtmps')) {
-    return bot.sendMessage(chatId, '❌ رابط M3U8 أو مفتاح فيسبوك غير صالح.');
+    bot.sendMessage(chatId, '❌ رابط M3U8 أو مفتاح فيسبوك غير صالح.');
+    log(`Invalid stream URLs from user ${userId}: ${m3u8Url}, ${rtmpsUrl}`);
+    return;
   }
 
+  // Generate unique stream ID
   let streamId;
   do streamId = generateStreamId(); while (activeStreams.has(streamId));
 
+  // Build FFmpeg command
   let cmd = `${ffmpegPath} -reconnect 1 -reconnect_streamed 1 -reconnect_delay_max 5 -itsoffset 5 -re -i "${m3u8Url}" `;
+
   if (watermarkPath) {
     cmd += `-i "${watermarkPath}" -filter_complex "[0:v][1:v]overlay=10:10[vt];`;
   } else {
     cmd += `-filter_complex "[0:v]copy[vt];`;
   }
+
   cmd += `[vt]drawtext=fontfile=/usr/share/fonts/truetype/dejavu/DejaVuSans-Bold.ttf:text='${ccText}':fontcolor=white:fontsize=24:x=w-tw-10*t:y=h-th-10,`;
   cmd += `drawtext=fontfile=/usr/share/fonts/truetype/dejavu/DejaVuSans-Bold.ttf:text='Vanilla X':fontcolor=white:fontsize=16:x=10:y=10:box=1:boxcolor=black@0.5:boxborderw=5[outv]" `;
   cmd += `-map "[outv]" -map 0:a -c:v libx264 -preset veryfast -b:v 3000k -c:a aac -f flv "${rtmpsUrl}"`;
 
   const proc = spawn(cmd, { shell: true });
+
   let hasResponded = false;
 
+  // Error detection & early failure message
   proc.stderr.on('data', (data) => {
-    const err = data.toString();
-    log(`FFmpeg stderr (Stream ${streamId}): ${err}`);
+    const errorText = data.toString();
+    log(`FFmpeg stderr (Stream ${streamId}): ${errorText}`);
 
     if (!hasResponded) {
-      if (err.includes('Server error') || err.includes('Invalid data')) {
-        bot.sendMessage(chatId, `❌ فشل بدء البث ${streamId}: مفتاح RTMPS غير صالح`);
-      } else if (err.includes('No such file') || err.includes('Invalid argument')) {
-        bot.sendMessage(chatId, `❌ فشل بدء البث ${streamId}: رابط M3U8 غير صالح`);
+      if (errorText.includes('Server error') || errorText.includes('Invalid data')) {
+        bot.sendMessage(chatId, `❌ فشل بدء البث ${streamId}: مفتاح RTMPS غير صالح.`);
+      } else if (errorText.includes('No such file') || errorText.includes('Invalid argument')) {
+        bot.sendMessage(chatId, `❌ فشل بدء البث ${streamId}: رابط M3U8 غير صالح.`);
       } else {
-        bot.sendMessage(chatId, `❌ فشل بدء البث ${streamId}: خطأ غير معروف`);
+        bot.sendMessage(chatId, `❌ فشل بدء البث ${streamId}: خطأ غير معروف.`);
       }
       hasResponded = true;
       proc.kill('SIGTERM');
@@ -119,13 +160,20 @@ bot.onText(/\/stream (.+?) (.+?)(?: (.+?))?(?: (.+))?/, async (msg, match) => {
     }
   });
 
+  // On process spawn, wait 3 sec then confirm success if no errors
   proc.on('spawn', () => {
-    // Wait 3 seconds to catch early errors before confirming success
     setTimeout(() => {
       if (!hasResponded) {
         bot.sendMessage(chatId, `✅ تم بدء البث: ${streamId}`);
         hasResponded = true;
-        activeStreams.set(streamId, { process: proc, chatId, rtmpsUrl, m3u8Url, cc: ccText, watermark: watermarkName });
+        activeStreams.set(streamId, {
+          process: proc,
+          chatId,
+          rtmpsUrl,
+          m3u8Url,
+          cc: ccText,
+          watermark: watermarkName,
+        });
         log(`Stream ${streamId} started for user ${userId}`);
       }
     }, 3000);
@@ -134,7 +182,7 @@ bot.onText(/\/stream (.+?) (.+?)(?: (.+?))?(?: (.+))?/, async (msg, match) => {
   proc.on('close', (code) => {
     log(`FFmpeg closed (Stream ${streamId}) with code ${code}`);
     if (!hasResponded && code !== 0) {
-      bot.sendMessage(chatId, `❌ فشل بدء البث ${streamId}: FFmpeg أغلق بالكود ${code}`);
+      bot.sendMessage(chatId, `❌ فشل بدء البث ${streamId}: FFmpeg أغلق بالكود ${code}.`);
       activeStreams.delete(streamId);
     } else {
       activeStreams.delete(streamId);
@@ -151,57 +199,118 @@ bot.onText(/\/stream (.+?) (.+?)(?: (.+?))?(?: (.+))?/, async (msg, match) => {
   });
 });
 
-// /urlchange
+// /urlchange <streamId> <new_m3u8>
 bot.onText(/\/urlchange (\d{4}) (.+)/, (msg, match) => {
-  const [_, id, newUrl] = match;
-  const stream = activeStreams.get(id);
-  if (!isAdmin(msg.from.id)) return bot.sendMessage(msg.chat.id, '❌ غير مصرح.');
-  if (!stream) return bot.sendMessage(msg.chat.id, `❌ لا يوجد بث ${id}`);
+  const userId = msg.from.id;
+  const chatId = msg.chat.id;
+  if (!isAdmin(userId)) {
+    bot.sendMessage(chatId, '❌ غير مصرح.');
+    log(`Unauthorized /urlchange from user ${userId}`);
+    return;
+  }
+  const streamId = match[1];
+  const newM3u8Url = match[2].trim();
 
+  if (!activeStreams.has(streamId)) {
+    bot.sendMessage(chatId, `❌ لا يوجد بث برقم ${streamId}.`);
+    return;
+  }
+
+  if (!newM3u8Url.startsWith('http')) {
+    bot.sendMessage(chatId, '❌ رابط M3U8 جديد غير صالح.');
+    return;
+  }
+
+  const stream = activeStreams.get(streamId);
   stream.process.kill('SIGTERM');
+  bot.sendMessage(chatId, `⏳ جاري تحديث رابط البث ${streamId}...`);
+
+  // Re-run stream with new URL but same other parameters
   bot.emit('text', {
     ...msg,
-    text: `/stream ${stream.rtmpsUrl.split('/').pop()} ${newUrl} ${stream.watermark || ''} ${stream.cc}`
+    text: `/stream ${stream.rtmpsUrl.split('/').pop()} ${newM3u8Url} ${stream.watermark || ''} ${stream.cc}`,
   });
 });
 
-// /cchange
+// /cchange <streamId> <new_cc>
 bot.onText(/\/cchange (\d{4}) (.+)/, (msg, match) => {
-  const [_, id, newCC] = match;
-  const stream = activeStreams.get(id);
-  if (!isAdmin(msg.from.id)) return bot.sendMessage(msg.chat.id, '❌ غير مصرح.');
-  if (!stream) return bot.sendMessage(msg.chat.id, `❌ لا يوجد بث ${id}`);
+  const userId = msg.from.id;
+  const chatId = msg.chat.id;
+  if (!isAdmin(userId)) {
+    bot.sendMessage(chatId, '❌ غير مصرح.');
+    log(`Unauthorized /cchange from user ${userId}`);
+    return;
+  }
+  const streamId = match[1];
+  const newCcText = match[2].trim();
 
+  if (!activeStreams.has(streamId)) {
+    bot.sendMessage(chatId, `❌ لا يوجد بث برقم ${streamId}.`);
+    return;
+  }
+
+  const stream = activeStreams.get(streamId);
   stream.process.kill('SIGTERM');
+  bot.sendMessage(chatId, `⏳ جاري تحديث النص المتحرك للبث ${streamId}...`);
+
+  // Re-run stream with new CC text but same other parameters
   bot.emit('text', {
     ...msg,
-    text: `/stream ${stream.rtmpsUrl.split('/').pop()} ${stream.m3u8Url} ${stream.watermark || ''} ${newCC}`
+    text: `/stream ${stream.rtmpsUrl.split('/').pop()} ${stream.m3u8Url} ${stream.watermark || ''} ${newCcText}`,
   });
 });
 
-// /stop
+// /stop <streamId>
 bot.onText(/\/stop (\d{4})/, (msg, match) => {
-  const id = match[1];
-  const stream = activeStreams.get(id);
-  if (!isAdmin(msg.from.id)) return bot.sendMessage(msg.chat.id, '❌ غير مصرح.');
-  if (!stream) return bot.sendMessage(msg.chat.id, `❌ لا يوجد بث ${id}`);
+  const userId = msg.from.id;
+  const chatId = msg.chat.id;
+  const streamId = match[1];
+  if (!isAdmin(userId)) {
+    bot.sendMessage(chatId, '❌ غير مصرح.');
+    log(`Unauthorized /stop from user ${userId}`);
+    return;
+  }
+  if (!activeStreams.has(streamId)) {
+    bot.sendMessage(chatId, `❌ لا يوجد بث برقم ${streamId}.`);
+    return;
+  }
 
+  const stream = activeStreams.get(streamId);
   stream.process.kill('SIGTERM');
-  activeStreams.delete(id);
-  bot.sendMessage(msg.chat.id, `🛑 تم إيقاف البث ${id}`);
+  activeStreams.delete(streamId);
+  bot.sendMessage(chatId, `🛑 تم إيقاف البث ${streamId}.`);
+  log(`Stream ${streamId} stopped by user ${userId}`);
 });
 
-// /check
+// /check system info (RAM in GB, uptime, loadavg)
 bot.onText(/\/check/, (msg) => {
-  if (!isAdmin(msg.from.id)) return bot.sendMessage(msg.chat.id, '❌ غير مصرح.');
+  const userId = msg.from.id;
+  const chatId = msg.chat.id;
+  if (!isAdmin(userId)) {
+    bot.sendMessage(chatId, '❌ غير مصرح.');
+    log(`Unauthorized /check from user ${userId}`);
+    return;
+  }
+
   const mem = process.memoryUsage();
+  const totalMem = os.totalmem();
+  const freeMem = os.freemem();
   const load = os.loadavg();
   const uptime = process.uptime();
-  bot.sendMessage(msg.chat.id, `📟 النظام:
-- Uptime: ${(uptime / 60).toFixed(1)} min
-- RAM: ${(mem.rss / 1024 / 1024).toFixed(1)} MB
-- Load Avg: ${load.map(v => v.toFixed(2)).join(', ')}`);
+
+  const usedGB = (mem.rss / 1024 / 1024 / 1024).toFixed(2);
+  const freeGB = (freeMem / 1024 / 1024 / 1024).toFixed(2);
+  const totalGB = (totalMem / 1024 / 1024 / 1024).toFixed(2);
+
+  bot.sendMessage(chatId, `
+📟 معلومات النظام:
+- وقت التشغيل: ${(uptime / 60).toFixed(1)} دقيقة
+- ذاكرة البوت المستخدمة: ${usedGB} جيجابايت
+- الذاكرة الحرة للنظام: ${freeGB} جيجابايت
+- إجمالي ذاكرة النظام: ${totalGB} جيجابايت
+- معدل تحميل النظام: ${load.map(v => v.toFixed(2)).join(', ')}
+`.trim());
+  log(`System info sent to user ${userId}`);
 });
 
-// Bot startup log
-console.log(`✅ Bot is running and polling for updates...`);
+console.log(`✅ Bot started and polling...`);