Update bot.js

bot.js

@@ -3,7 +3,7 @@ const ffmpegInstaller = require('@ffmpeg-installer/ffmpeg');
 const ffmpeg = require('fluent-ffmpeg');
 const si = require('systeminformation');
 
-const TOKEN = '7963845783:AAG_6-x0GTpKqNWLSlOVFgloSnZftA_K5Qo';
+const TOKEN = '7963845783:AAG_6-x0GTpKqNWLSlOVFGloSnZftA_K5Qo';
 const ADMIN_ID = 7708913693;
 
 ffmpeg.setFfmpegPath(ffmpegInstaller.path);
@@ -40,7 +40,7 @@ function getSystemSettings() {
 
 function usageExample(chatId) {
   return bot.sendMessage(chatId,
-    `❌ الأمر غير صحيح أو غير مكتمل.\n\n` +
+    `❌ الأمر غير صحيح أو gير مكتمل.\n\n` +
     `استخدم أحد الأوامر التالية:\n\n` +
     `/stream streamkey m3u8_url [cc_text]\n` +
     `مثال:\n` +
@@ -92,14 +92,15 @@ bot.onText(/^\/stream(?:\s+(.+))?$/, async (msg, match) => {
     const rtmpUrl = `rtmps://live-api-s.facebook.com:443/rtmp/${key}`;
     command = command.output(rtmpUrl);
 
-    const proc = command.spawn();
+    // Use run() instead of spawn()
+    command.run();
 
     if (!userStreams[chatId]) userStreams[chatId] = {};
-    userStreams[chatId][streamId] = { proc };
+    userStreams[chatId][streamId] = { proc: command };
 
     const timeout = setTimeout(() => {
-      if (proc && !proc.killed) {
-        proc.kill('SIGTERM');
+      if (userStreams[chatId] && userStreams[chatId][streamId]) {
+        command.kill('SIGTERM');
         bot.sendMessage(chatId, `⏹️ تم إيقاف البث معرف ${streamId} تلقائياً بعد 4 ساعات.`);
         delete userStreams[chatId][streamId];
       }
@@ -116,20 +117,16 @@ bot.onText(/^\/stream(?:\s+(.+))?$/, async (msg, match) => {
       `⏳ سيتم إيقاف البث تلقائياً بعد 4 ساعات`
     );
 
-    proc.on('error', err => {
+    command.on('error', err => {
       bot.sendMessage(chatId, `❌ حدث خطأ في البث معرف ${streamId}:\n${err.message}`);
       clearTimeout(timeout);
-      delete userStreams[chatId][streamId];
+      if (userStreams[chatId]) delete userStreams[chatId][streamId];
     });
 
-    proc.on('exit', (code, signal) => {
-      if (signal === 'SIGTERM') {
-        bot.sendMessage(chatId, `⏹️ تم إيقاف البث معرف ${streamId}.`);
-      } else if (code !== 0) {
-        bot.sendMessage(chatId, `⚠️ البث معرف ${streamId} انتهى برمز خروج ${code}.`);
-      }
+    command.on('end', () => {
+      bot.sendMessage(chatId, `⏹️ تم إيقاف البث معرف ${streamId}.`);
       clearTimeout(timeout);
-      delete userStreams[chatId][streamId];
+      if (userStreams[chatId]) delete userStreams[chatId][streamId];
     });
 
   } catch (e) {
@@ -148,14 +145,10 @@ bot.onText(/^\/stop(?:\s+(\d+))?$/, (msg, match) => {
   }
 
   const { proc, timeout } = userStreams[chatId][streamId];
-  if (proc && !proc.killed) {
-    proc.kill('SIGTERM');
-    clearTimeout(timeout);
-    bot.sendMessage(chatId, `⏹️ تم إيقاف البث معرف ${streamId} من قبلك.`);
-    delete userStreams[chatId][streamId];
-  } else {
-    bot.sendMessage(chatId, `⚠️ البث معرف ${streamId} متوقف بالفعل.`);
-  }
+  proc.kill('SIGTERM');
+  clearTimeout(timeout);
+  bot.sendMessage(chatId, `⏹️ تم إيقاف البث معرف ${streamId} من قبلك.`);
+  delete userStreams[chatId][streamId];
 });
 
 // /check
@@ -178,7 +171,7 @@ bot.onText(/\/check/, async (msg) => {
   }
 });
 
-// رد افتراضي
+// Default response
 bot.on('message', (msg) => {
   const chatId = msg.chat.id;
   const text = msg.text || "";