Update bot.js

bot.js

@@ -27,16 +27,22 @@ let viewerTimeout = null;
 let bot = null;
 let botIsReady = false;
 let baglantiTuru = "Yok";
-let activeMessages = []; // Canlı mesajların tutulacağı dizi
-let messagesTimeout = null; // 1 dakikalık kapatma sayacı
+let activeMessages = []; 
+let messagesTimeout = null; 
 const ansiToHtmlConvert = new (require('ansi-to-html'))({ newline: true });
 
-// --- GARANTİ BAĞLANTI VE SOKET KONTROLÜ İÇİN GLOBAL DEĞİŞKENLER ---
-let isConnecting = false;       // Çift tünel açılmasını engelleyen kesin kilit (State)
-let reconnectTimeout = null;    // Çakışan mükerrer timeout'ları temizlemek için global referans
-let currentSshClient = null;    // Aktif SSH nesnesinin imhası için global referans
-let currentStream = null;       // Aktif Tünel stream imhası için global referans
-let currentSocket = null;       // Aktif Normal TCP soket imhası için global referans
+// --- GÜVENLİ BAĞLANTI DEĞİŞKENLERİ ---
+let isConnecting = false;       
+let isDestroying = false;       
+let reconnectTimeout = null;    
+let currentSshClient = null;    
+let currentStream = null;       
+let currentSocket = null;       
+
+// --- PANEL METRİKLERİ ---
+let botUptimeStart = null;         
+let lastFullFeedTimeStr = "Henüz besleme yapılmadı"; 
+let lastCheckTimeStr = "Henüz kontrol yapılmadı";    
 
 // Dış IP tespiti
 https.get('https://api.ipify.org?format=json', (res) => {
@@ -46,89 +52,26 @@ https.get('https://api.ipify.org?format=json', (res) => {
     try {
       const ipInfo = JSON.parse(data);
       console.log(`Dış IP adresin: ${ipInfo.ip}`);
-    } catch (err) {
-      console.error('JSON parse hatası:', err);
-    }
+    } catch (err) {}
   });
-}).on('error', (err) => {
-  console.error('İstek hatası:', err);
-});
+}).on('error', () => {});
 
 async function createBot() {
-  // MÜKERRER BAĞLANTI ENGELLEME: Eğer zaten bir bağlantı süreci aktifse fonksiyonu anında durdur.
   if (isConnecting) {
     logger.warn("[Sistem] Zaten aktif bir bağlantı süreci yürütülüyor. Mükerrer istek engellendi.");
     return;
   }
-  isConnecting = true; // Kilidi kapat
+  isConnecting = true; 
+  isDestroying = false; 
 
   const net = require('net');
   const sshClient = new Client();
-  currentSshClient = sshClient; // Global referansa eşitle
-
-  // --- GİTHUB CONFIG ÇEKME AŞAMASI (DİNAMİK SSH) ---
-  const githubRawUrl = 'https://raw.githubusercontent.com/suvarileader/che/refs/heads/main/doc/ower/doc.json';
-  logger.info("[GitHub Config] Güncel SSH tünel bilgileri GitHub'dan çekiliyor...");
-
-  let remoteData = null;
-  try {
-    remoteData = await new Promise((resolve, reject) => {
-      https.get(githubRawUrl, (res) => {
-        let body = '';
-        res.on('data', chunk => body += chunk);
-        res.on('end', () => {
-          try {
-            resolve(JSON.parse(body));
-          } catch (e) {
-            reject(new Error("JSON Ayrıştırma Hatası: " + e.message));
-          }
-        });
-      }).on('error', (err) => reject(err));
-    });
-    logger.info("[GitHub Config] SSH dosyası başarıyla indirildi.");
-  } catch (err) {
-    logger.error(`[GitHub Config Hatası] SSH verisi alınamadı: ${err.message}. Sabit SSH ayarlarıyla devam ediliyor...`);
-  }
-
-  // Varsayılan / Sabit SSH Ayarları (Yedek)
-  let sshConfig = {
-    host: 'tr1.vpnjantit.com',
-    port: 22,
-    username: 'suvaa-vpnjantit.com',
-    password: 'suvaa'
-  };
-
-  // Yerel config'den bot kullanıcı adı
-  const currentBotUsername = config["bot-account"]["username"];
+  currentSshClient = sshClient; 
 
-  // GitHub'dan gelen verilerle SSH konfigürasyonunu eşleştirme
-  if (remoteData && Array.isArray(remoteData)) {
-    const myConfig = remoteData.find(item => item.account === currentBotUsername);
-    if (myConfig) {
-      logger.info(`[GitHub Config] '${currentBotUsername}' botu için dinamik SSH parametreleri uygulandı.`);
-      if (myConfig.serverName && myConfig.serverName !== "empty") {
-        sshConfig.host = myConfig.serverName;
-      }
-      if (myConfig.username && myConfig.username !== "empty") {
-        sshConfig.username = myConfig.username;
-      }
-      
-      // SSH Şifre ataması
-      if (myConfig.pass && myConfig.pass !== "empty") {
-        sshConfig.password = myConfig.pass;
-      } else {
-        sshConfig.password = config.utils["auto-auth"].password;
-      }
-    } else {
-      logger.warn(`[GitHub Config] Listede '${currentBotUsername}' bulunamadı. Sabit/Yedek SSH kullanılacak.`);
-    }
-  }
-
-  // Minecraft Sunucu Hedef Bilgileri (Yerel config'den)
   const targetServerIp = config.server.ip;
   const targetServerPort = config.server.port;
+  const currentBotUsername = config["bot-account"]["username"];
 
-  // Mineflayer Başlatılıyor
   bot = mineflayer.createBot({
     username: currentBotUsername,
     auth: config["bot-account"]["type"],
@@ -136,70 +79,141 @@ async function createBot() {
     port: targetServerPort,
     version: config.server.version,
 
-    connect: (client) => {
+    connect: async (client) => {
       let fallbackTriggered = false;
       let isFinalFailureHandled = false;
 
-      // Kritik Çökme Yönetim Merkezi
       const handleFinalFailure = (reason) => {
         if (isFinalFailureHandled) return;
         isFinalFailureHandled = true;
 
-        logger.error(`[Kritik Hata] ${reason}. 2 alternatif de başarısız oldu! Sistem en başa döndürülüyor...`);
+        logger.error(`[Kritik Hata] ${reason}. Bağlantı sağlanamadı! Sistem en başa döndürülüyor...`);
         
         baglantiTuru = "Yok";
         botIsReady = false;
+        botUptimeStart = null; 
 
         stopPeriodicHomeChecks();
-        safeDestroyAllConnections(); // Tüm asılı soketleri işletim sistemi seviyesinde imha et
+        safeDestroyAllConnections(); 
 
         if (config.utils && config.utils["auto-reconnect"]) {
           triggerSafeReconnect();
         }
       };
 
-      // Yedek Plan: Doğrudan Minecraft Sunucusuna Bağlanma
       const connectDirectly = (reason) => {
         if (fallbackTriggered) return;
         fallbackTriggered = true;
 
-        logger.warn(`[Bağlantı Yedekleme] SSH Tüneli başarısız oldu (${reason}). Normal IP üzerinden GERÇEK TCP bağlantısı kuruluyor...`);
+        logger.warn(`[Bağlantı Yedekleme] Doğrudan IP moduna geçiliyor (Sebep: ${reason}). Kendi (Yurt dışı) IP'miz üzerinden GERÇEK TCP bağlantısı kuruluyor...`);
 
-        try { sshClient.end(); } catch (e) {}
+        if (sshClient) {
+          try { sshClient.destroy(); } catch (e) {} 
+        }
 
         const socket = net.connect({
           host: targetServerIp,
           port: parseInt(targetServerPort) || 25565
         });
-        currentSocket = socket; // Global referansa eşitle
+        currentSocket = socket; 
+
+        // KESİN ÇÖZÜM KİLİDİ: 1 dakikalık süreçte hem sunucu hatasının hem de timeout'un aynı anda çift tetiklenmesini engeller
+        let isDirectHandled = false;
 
+        // İstediğin gibi: Kendi IP'si için zaman aşımı toleransını tam 1 dakikaya (60.000 ms) çıkardık
         const directTimeout = setTimeout(() => {
+          if (isDirectHandled) return;
+          isDirectHandled = true;
+          
           socket.destroy();
-          handleFinalFailure("Normal IP bağlantısı zaman aşımına uğradı (Sunucu yanıt vermiyor)");
-        }, 10000);
+          handleFinalFailure("Kendi IP bağlantısı 1 dakikalık süre içinde zaman aşımına uğradı (Sunucu yanıt vermedi)");
+        }, 60000);
 
         socket.on('connect', () => {
+          if (isDirectHandled) return;
+          isDirectHandled = true;
+          
           clearTimeout(directTimeout);
-          logger.info("[Bağlantı Yedekleme] Normal IP üzerinden GERÇEK TCP bağlantısı başarıyla kuruldu!");
+          logger.info("[Bağlantı Yedekleme] Kendi IP'miz üzerinden GERÇEK TCP bağlantısı başarıyla kuruldu!");
           baglantiTuru = "Normal";
-          client.setSocket(socket);
-          client.emit('connect');
+          if (client && typeof client.setSocket === 'function') {
+            client.setSocket(socket);
+            client.emit('connect');
+          }
         });
 
         socket.on('error', (err) => {
+          if (isDirectHandled) return;
+          isDirectHandled = true;
+
           clearTimeout(directTimeout);
-          logger.error(`[Bağlantı Yedekleme Hatası] Normal IP ile de sunucuya bağlanılamadı: ${err.message}`);
-          handleFinalFailure(`Normal IP hatası: ${err.message}`);
+          logger.error(`[Bağlantı Yedekleme Hatası] Sunucu bağlantıyı reddetti veya olumsuz yanıt verdi: ${err.message}`);
+          handleFinalFailure(`Kendi IP hatası: ${err.message}`);
         });
         
         socket.on('close', () => {
+          if (isDirectHandled) return;
+          isDirectHandled = true;
+
           clearTimeout(directTimeout);
           handleFinalFailure("Normal TCP soketi kapandı");
         });
       };
 
-      // Dinamik SSH Sunucusuna Bağlanılıyor
-      logger.info(`[SSH Tünel] SSH üzerinden ${sshConfig.host} sunucusuna (${sshConfig.username}) bağlanılıyor...`);
+      const githubRawUrl = 'https://raw.githubusercontent.com/suvarileader/che/refs/heads/main/doc/ower/doc.json';
+      logger.info("[GitHub Config] Güncel SSH tünel bilgileri GitHub'dan çekiliyor...");
+
+      let remoteData = null;
+      try {
+        remoteData = await new Promise((resolve, reject) => {
+          const reqTimeout = setTimeout(() => {
+            reject(new Error("GitHub bağlantısı 6 saniye içinde yanıt vermedi (Timeout)"));
+          }, 6000);
+
+          https.get(githubRawUrl, (res) => {
+            clearTimeout(reqTimeout);
+            let body = '';
+            res.on('data', chunk => body += chunk);
+            res.on('end', () => {
+              try {
+                resolve(JSON.parse(body));
+              } catch (e) {
+                reject(new Error("JSON Ayrıştırma Hatası"));
+              }
+            });
+          }).on('error', (err) => {
+            clearTimeout(reqTimeout);
+            reject(err);
+          });
+        });
+      } catch (err) {
+        connectDirectly(`GitHub verisi alınamadı veya sayfa çöktü (${err.message})`);
+        return;
+      }
+
+      let sshConfig = null;
+      if (remoteData && Array.isArray(remoteData)) {
+        const myConfig = remoteData.find(item => item && item.account === currentBotUsername);
+        if (myConfig) {
+          sshConfig = {
+            host: (myConfig.serverName && myConfig.serverName !== "empty") ? myConfig.serverName : null,
+            port: 22,
+            username: (myConfig.username && myConfig.username !== "empty") ? myConfig.username : null,
+            password: (myConfig.pass && myConfig.pass !== "empty") ? myConfig.pass : config.utils["auto-auth"].password
+          };
+
+          if (!sshConfig.host || !sshConfig.username) {
+            sshConfig = null;
+          }
+        }
+      }
+
+      if (!sshConfig) {
+        connectDirectly(`GitHub listesinde '${currentBotUsername}' botu ile uyumlu geçerli SSH verisi bulunamadı`);
+        return;
+      }
+
+      logger.info(`[SSH Tünel] GitHub'dan alınan ${sshConfig.host} sunucusuna (${sshConfig.username}) bağlanılıyor...`);
 
       const connectionTimeout = setTimeout(() => {
         connectDirectly("SSH Bağlantı Zaman Aşımı (10 saniye yanıt alınamadı)");
@@ -222,25 +236,33 @@ async function createBot() {
 
             logger.info("[SSH Tünel] Tünel başarıyla kuruldu! Mineflayer sokete bağlanıyor.");
             baglantiTuru = "SSH";
-            currentStream = stream; // Global referansa eşitle
+            currentStream = stream; 
 
-            stream.on('close', () => {
-              connectDirectly("Tünel stream kapandı");
+            stream.once('close', () => {
+              if (!fallbackTriggered && !isDestroying) {
+                connectDirectly("Tünel stream kapandı");
+              }
             });
             
-            stream.on('error', (e) => {
-              connectDirectly(`Stream hatası: ${e.message}`);
+            stream.once('error', (e) => {
+              if (!fallbackTriggered && !isDestroying) {
+                connectDirectly(`Stream hatası: ${e.message}`);
+              }
             });
 
-            client.setSocket(stream);
-            client.emit('connect');
+            if (client && typeof client.setSocket === 'function') {
+              client.setSocket(stream);
+              client.emit('connect');
+            }
           }
         );
       });
 
       sshClient.on('error', (err) => {
         clearTimeout(connectionTimeout);
-        connectDirectly(`SSH Sunucu Hatası: ${err.message}`);
+        if (!fallbackTriggered && !isDestroying) {
+          connectDirectly(`SSH Sunucu Hatası: ${err.message}`);
+        }
       });
 
       try {
@@ -254,7 +276,6 @@ async function createBot() {
 
   bot.loadPlugin(pathfinder);
 
-  // --- TİMİNG SIFIRLAMA İÇİN YARDIMCI PARAMETRELER ---
   let lastFullFeedAt = 0;
   let windowOpenResolvers = [];
   let periodicHandle = null;
@@ -273,7 +294,13 @@ async function createBot() {
     activeTimeouts = [];
   }
 
-  // --- YARDIMCI FONKSİYONLAR ---
+  function getExtendedDateTimeString() {
+    const now = new Date();
+    const dateStr = now.toLocaleDateString('tr-TR', { day: '2-digit', month: '2-digit', year: 'numeric' });
+    const timeStr = now.toLocaleTimeString('tr-TR');
+    return `${dateStr} - ${timeStr}`;
+  }
+
   function stripColorCodes(s) {
     if (!s || typeof s !== "string") return s;
     return s.replace(/§[0-9a-fk-or]/gi, "");
@@ -393,16 +420,19 @@ async function createBot() {
   }
 
   async function goHome() {
+    if (!bot || !botIsReady) return;
     logger.info(`[${currentBotUsername}] ${GO_HOME_COMMAND} komutu gönderiliyor.`);
     bot.chat(GO_HOME_COMMAND);
   }
 
   async function returnIsland() {
+    if (!bot || !botIsReady) return;
     logger.info(`[${currentBotUsername}] ${RETURN_ISLAND_COMMAND} komutu gönderiliyor.`);
     bot.chat(RETURN_ISLAND_COMMAND);
   }
 
   async function scanAndFeed() {
+    if (!bot || !botIsReady) return;
     if (Date.now() < (lastFullFeedAt + FULL_FEED_COOLDOWN_MS)) return;
     const arr = Object.values(bot.entities);
     let best = null;
@@ -453,31 +483,35 @@ async function createBot() {
     } catch (err) {}
   }
 
-  // --- BOT SPAWN / EVENT DİNLEYİCİLERİ ---
   bot.once("spawn", async () => {
-    // BOT BAŞARIYLA SUNUCUYA GİRDİ: Kilidi kaldır ve durumu güncelle
     isConnecting = false; 
+    if (!bot) return;
     bot.pathfinder.setMovements(new Movements(bot));
     logger.info("Bot sunucuya giriş yaptı.");
     botIsReady = true;
+    botUptimeStart = Date.now(); 
 
-    // EXPRESS CHAT ENTEGRASYONU: Her yeni bot doğduğunda tek bir temiz event dinleyici eklenir.
     bot.on('message', globalMinecraftMessageListener);
 
     if (config.utils && config.utils["auto-auth"] && config.utils["auto-auth"].enabled) {
       const password = config.utils["auto-auth"].password;
       
       setSafeTimeout(() => {
-        bot.chat(`/login ${password}`);
-        logger.info(`[${currentBotUsername}] Login komutu kullanıldı.`);
+        if (bot && botIsReady) {
+          bot.chat(`/login ${password}`);
+          logger.info(`[${currentBotUsername}] Login komutu kullanıldı.`);
+        }
       }, 2500);
 
       setSafeTimeout(() => {
-        bot.chat(`/skyblock`);
-        logger.info(`[${currentBotUsername}] Skyblock'a ışınlanma komutu kullanıldı.`);
+        if (bot && botIsReady) {
+          bot.chat(`/skyblock`);
+          logger.info(`[${currentBotUsername}] Skyblock'a ışınlanma komutu kullanıldı.`);
+        }
       }, 7500);
 
       setSafeTimeout(async () => {
+        if (!bot || !botIsReady) return;
         await goHome();
         await new Promise(r => setTimeout(r, HOME_ARRIVAL_DELAY_MS));
         await scanAndFeed();
@@ -485,6 +519,7 @@ async function createBot() {
         await returnIsland();
         
         periodicHandle = setInterval(async () => {
+          if (!bot || !botIsReady) return;
           if (Date.now() < (lastFullFeedAt + FULL_FEED_COOLDOWN_MS)) return;
           await goHome();
           await new Promise(r => setTimeout(r, HOME_ARRIVAL_DELAY_MS));
@@ -497,37 +532,48 @@ async function createBot() {
   });
 
   bot.on("windowOpen", (window) => {
+    if (!bot) return;
     const title = parseWindowTitleToString(window.title).toLowerCase();
     if (!title.includes("besleyici") && !parseWindowTitleToString(window.title).includes("ʙᴇsʟᴇʏiᴄi")) {
       logger.info(`[${currentBotUsername}] Bi chest açıldı ama window title ı uyuşmadığı için kapatıldı. ${parseWindowTitleToString(window.title)}`);
-      bot.closeWindow(window);
+      try { bot.closeWindow(window); } catch(e){}
       return;
     }
     const beefSlot = window.slots.find(s => s?.name === "cooked_beef");
     const can = extractMinyonCanFromSlot(beefSlot);
+    
     if (can != null) {
+      const currentStamp = getExtendedDateTimeString();
+      lastCheckTimeStr = `${currentStamp} (Okunan Can: ${can})`;
+
       if (can <= 2) {
-        bot.clickWindow(36, 0, 0);
+        try { bot.clickWindow(36, 0, 0); } catch(e){}
         lastFullFeedAt = Date.now();
+        lastFullFeedTimeStr = `${currentStamp} (Minyon canı ${can} iken başarıyla beslendi)`; 
         logger.info(`[${currentBotUsername}] Minyon canı ${can} olduğu için beslendi. 50dk bekleme aktif.`);
       } else if (can >= 10) {
         lastFullFeedAt = Date.now();
+        lastFullFeedTimeStr = `${currentStamp} (Canı ${can} olduğu için besleme gerekmedi)`; 
         logger.info(`[${currentBotUsername}] Minyon canı ${can} (tam). 50dk bekleme aktif.`);
       } else {
         logger.info(`[${currentBotUsername}] Minyon canı ${can} olduğu için yenilenmedi.`);
       }
     }
-    setSafeTimeout(() => { try { bot.closeWindow(window); } catch(e){} }, 500);
-    while (windowOpenResolvers.length > 0) windowOpenResolvers.shift()();
+    setSafeTimeout(() => { if (bot) { try { bot.closeWindow(window); } catch(e){} } }, 500);
+    while (windowOpenResolvers.length > 0) {
+      const fn = windowOpenResolvers.shift();
+      if (typeof fn === 'function') fn();
+    }
   });
 
   bot.on("end", () => {
-    logger.warn("Bağlantı koptu. Tüm zamanlayıcılar sıfırlanıyor...");
+    logger.warn("Bağlantı koptu. Tüm zamanlayıcılar sıfırlanıyor ve YENİDEN BAĞLANMA SÜRECİ BAŞLIYOR...");
     stopPeriodicHomeChecks();
     botIsReady = false;
     baglantiTuru = "Yok";
+    botUptimeStart = null; 
     
-    safeDestroyAllConnections(); // Tüm asılı soketleri ve eski bot referanslarını tamamen imha et
+    safeDestroyAllConnections(); 
 
     if (config.utils && config.utils["auto-reconnect"]) {
       triggerSafeReconnect();
@@ -535,43 +581,46 @@ async function createBot() {
   });
 
   bot.on("kicked", (reason) => logger.warn(`Bot sunucudan atıldı: ${util.inspect(reason)}`));
-  bot.on("error", (err) => logger.error(`${err}`));
+  bot.on("error", (err) => logger.error(`Mineflayer Hatası: ${err}`));
 }
 
-// --- GARANTİ SOKET VE BAĞLANTI İMHA FONKSİYONU ---
 function safeDestroyAllConnections() {
-  isConnecting = false; // Kilidi serbest bırak ki yeni döngü başlayabilsin
+  if (isDestroying) return;
+  isDestroying = true; 
+  isConnecting = false; 
   
-  // 3D Görüntüleyiciyi kapat ve RAM'den düşür
   if (viewerInstance && typeof viewerInstance.close === 'function') {
-    try { viewerInstance.close(); } catch(e){}
+    try { 
+      if (viewerInstance.ws && typeof viewerInstance.ws.close === 'function') {
+        viewerInstance.ws.close();
+      }
+      viewerInstance.close(); 
+    } catch(e){}
   }
   viewerInstance = null;
   if (bot) { bot.viewer = null; }
 
-  // Tüm soket bacaklarını ve tünelleri işletim sistemi seviyesinde imha et (Kibarlık yok, direkt destroy)
   if (currentStream && typeof currentStream.destroy === 'function') {
     try { currentStream.destroy(); } catch(e){}
   }
   if (currentSocket && typeof currentSocket.destroy === 'function') {
     try { currentSocket.destroy(); } catch(e){}
   }
-  if (currentSshClient && typeof currentSshClient.end === 'function') {
-    try { currentSshClient.end(); } catch(e){}
+  if (currentSshClient && typeof currentSshClient.destroy === 'function') {
+    try { currentSshClient.destroy(); } catch(e){} 
   }
 
   currentStream = null;
   currentSocket = null;
   currentSshClient = null;
 
-  // Eski bot nesnesinin event listener'larını temizle ve Garbage Collector'a teslim et
   if (bot) {
-    try { bot.removeAllListeners(); } catch(e){}
+    try { bot.removeListener('message', globalMinecraftMessageListener); } catch(e){}
+    try { bot.quit(); } catch(e){} 
     bot = null;
   }
 }
 
-// --- RECONNECT ÇAKIŞMALARINI ENGELLEYEN GÜVENLİ ZAMANLAYICI ---
 function triggerSafeReconnect() {
   if (reconnectTimeout) {
     clearTimeout(reconnectTimeout);
@@ -580,11 +629,10 @@ function triggerSafeReconnect() {
   logger.info(`[Sistem] ${delay} ms sonra tekil bir hat üzerinden sistem sıfırdan başlatılacak...`);
   
   reconnectTimeout = setTimeout(() => {
-    createBot();
+    createBot(); // SONSUZ DÖNGÜ GARANTİSİ: Ne olursa olsun bu fonksiyon taze kilitlerle tekrar tetiklenir
   }, delay);
 }
 
-// --- EXPRESS VE BOTU BİRBİRİNDEN AYIRAN GLOBAL SOHBET DİNLEYİCİSİ (RAM SIZINTISI GARANTİ ÇÖZÜMÜ) ---
 function globalMinecraftMessageListener(jsonMsg) {
   try {
     if (!bot) return;
@@ -611,16 +659,30 @@ const app = express();
 const http = require('http');
 
 app.get("/status", (req, res) => {
+  let uptimeString = "Bağlı Değil";
+  if (botIsReady && botUptimeStart) {
+    const diffMs = Date.now() - botUptimeStart;
+    const diffSecs = Math.floor(diffMs / 1000);
+    const days = Math.floor(diffSecs / 86400);
+    const hours = Math.floor((diffSecs % 86400) / 3600);
+    const mins = Math.floor((diffSecs % 3600) / 60);
+    const secs = diffSecs % 60;
+    
+    uptimeString = `${days} Gün, ${hours} Saat, ${mins} Dakika, ${secs} Saniye`;
+  }
+
   res.send({ 
     ready: botIsReady, 
     username: bot ? bot.username : null,
-    connection_type: baglantiTuru
+    connection_type: baglantiTuru,
+    bot_uptime: uptimeString,
+    last_minyon_check: lastCheckTimeStr,     
+    last_minyon_feed: lastFullFeedTimeStr    
   });
 });
 
 app.get("/", (req, res) => res.send("Bot Aktif"));
 
-// EXPRESS /messages YENİDEN YAPILANDIRILDI: Express artık bota doğrudan 'on' kancası atmaz. RAM sızıntısı bitti.
 app.get("/messages", (req, res) => {
   if (messagesTimeout) {
     clearTimeout(messagesTimeout);
@@ -636,7 +698,6 @@ app.get("/messages", (req, res) => {
     logs: activeMessages
   });
 
-  // Sohbet paneli 1 dakika izlenmezse RAM koruması için eski mesaj havuzunu temizle
   messagesTimeout = setTimeout(() => {
     activeMessages = [];
     messagesTimeout = null;
@@ -702,7 +763,7 @@ app.get("/restart", (req, res) => {
     try { bot.chat("Bot web paneli uzerinden tum kodlariyla yeniden baslatiliyor..."); } catch(e){}
     res.send({ success: true, message: "Tüm proje kapatıldı. Hugging Face sistemi birkaç saniye içinde kodu sıfırdan başlatacak." });
     setTimeout(() => {
-      if (bot) bot.quit();
+      if (bot) { try { bot.quit(); } catch(e){} }
       logger.info("[Sistem] process.exit(0) çağrıldı. Konteyner yeniden başlatılacak.");
       process.exit(0);
     }, 1000);
@@ -755,6 +816,9 @@ server.on('upgrade', (req, socket, head) => {
         viewerTimeout = setTimeout(() => {
           if (viewerInstance && typeof viewerInstance.close === 'function') {
             try {
+              if (viewerInstance.ws && typeof viewerInstance.ws.close === 'function') {
+                viewerInstance.ws.close();
+              }
               viewerInstance.close();
               if (bot) bot.viewer = null;
               viewerInstance = null;