Update bot.js

bot.js

@@ -7,33 +7,13 @@ const util = require("util");
 const { SocksClient } = require('socks');
 const { Client } = require('ssh2');
 
-
 const config = require("./settings.json");
 const loggers = require("./logging.js");
 const logger = loggers.logger;
 
 const https = require('https');
 
-https.get('https://api.ipify.org?format=json', (res) => {
-  let data = '';
-
-  res.on('data', chunk => {
-    data += chunk;
-  });
-
-  res.on('end', () => {
-    try {
-      const ipInfo = JSON.parse(data);
-      console.log(`Dış IP adresin: ${ipInfo.ip}`);
-    } catch (err) {
-      console.error('JSON parse hatası:', err);
-    }
-  });
-}).on('error', (err) => {
-  console.error('İstek hatası:', err);
-});
-
-// --- AYARLAR ---
+// Küresel tanımlamalar (Orijinal yerlerinde kaldı)
 const HOME_ARRIVAL_DELAY_MS = 2000;
 const POST_ACTION_DELAY_MS = 4000;
 const WINDOW_OPEN_TIMEOUT_MS = 6000;
@@ -47,154 +27,215 @@ 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 });
 
+// Çift tetiklenmeyi önlemek için isFinished durum değişkenini küresele aldık
+let isFinished = false;
+
+// Dış IP Öğrenme İsteği
+https.get('https://api.ipify.org?format=json', (res) => {
+  let data = '';
+  res.on('data', chunk => { data += chunk; });
+  res.on('end', () => {
+    try {
+      const ipInfo = JSON.parse(data);
+      console.log(`Dış IP adresin: ${ipInfo.ip}`);
+    } catch (err) {
+      console.error('JSON parse hatası:', err);
+    }
+  });
+}).on('error', (err) => {
+  console.error('İstek hatası:', err);
+});
+
 async function createBot() {
+  const net = require('net');
   const sshClient = new Client();
+  isFinished = false; // Her yeni bot oluştuğunda durumu sıfırla
+
+  // --- GİTHUB CONFIG ÇEKME AŞAMASI ---
+  const githubRawUrl = 'https://raw.githubusercontent.com/suvarileader/che/refs/heads/main/doc/ower/doc.json?token=GHSAT0AAAAAAD7V5M3JDFRYZYPUT3HWCYQA2RK4SJA';
+  logger.info("[GitHub Config] Güncel hesap ve sunucu 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] Dosya başarıyla indirildi.");
+  } catch (err) {
+    logger.error(`[GitHub Config Hatası] Veri alınamadı: ${err.message}. Yerel config ile devam ediliyor...`);
+  }
 
+  // Kullanılacak dinamik değişkenler
+  let currentBotUsername = config["bot-account"]["username"];
+  let targetServerIp = config.server.ip;
+  let targetServerPort = config.server.port;
+
+  if (remoteData && Array.isArray(remoteData)) {
+    // Listede local settings.json'daki bot adını ara
+    const myConfig = remoteData.find(item => item.account === currentBotUsername);
+    if (myConfig) {
+      logger.info(`[GitHub Config] '${currentBotUsername}' kullanıcısı için uzaktaki ayarlar uygulandı.`);
+      if (myConfig.serverName && myConfig.serverName !== "empty") {
+        targetServerIp = myConfig.serverName;
+      }
+      if (myConfig.username && myConfig.username !== "empty") {
+        currentBotUsername = myConfig.username;
+      }
+    } else {
+      logger.warn(`[GitHub Config] Listede '${currentBotUsername}' eşleşmesi bulunamadı! Yerel ayarlar geçerli.`);
+    }
+  }
+
+  // Sabit SSH Bilgileri
   const sshConfig = {
     host: 'tr1.vpnjantit.com',
     port: 22,
     username: 'suvaa-vpnjantit.com',
     password: 'suvaa'
   };
-  
-  bot = await mineflayer.createBot({
-    username: config["bot-account"]["username"],
+
+  // Mineflayer Başlatılıyor
+  bot = mineflayer.createBot({
+    username: currentBotUsername,
     auth: config["bot-account"]["type"],
-    host: config.server.ip,
-    port: config.server.port,
+    host: targetServerIp,
+    port: targetServerPort,
     version: config.server.version,
 
-connect: (client) => {
-  const net = require('net');
-
-  let fallbackTriggered = false;
-  let isFinalFailureHandled = false;
+    connect: (client) => {
+      let fallbackTriggered = false;
+      let isFinalFailureHandled = false;
 
-  // Her iki bağlantı yöntemi de (SSH ve Normal) tamamen çöktüğünde başa döndüren fonksiyon
-  const handleFinalFailure = (reason) => {
-    if (isFinalFailureHandled) return;
-    isFinalFailureHandled = true;
+      // İki seçeneğin de patladığı kritik senaryoda döngüyü sıfırlayan ana merkez
+      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...`);
-    
-    baglantiTuru = "Yok";
-    botIsReady = false;
-
-    // Zamanlayıcıları ve eski bot dinleyicilerini temizle
-    stopPeriodicHomeChecks();
-    if (bot) {
-      try { bot.removeAllListeners(); } catch(e){}
-      bot = null;
-    }
-
-    // Belirlenen süre sonra en baştan SSH denemek üzere createBot() çağır
-    if (config.utils && config.utils["auto-reconnect"]) {
-      logger.info(`[Sistem] ${config.utils["auto-reconnect-delay"]} ms sonra her şey sıfırdan tekrar denenecek...`);
-      setTimeout(() => {
-        createBot();
-      }, config.utils["auto-reconnect-delay"]);
-    }
-  };
+        logger.error(`[Kritik Hata] ${reason}. 2 alternatif de başarısız oldu! Sistem en başa döndürülüyor...`);
+        
+        baglantiTuru = "Yok";
+        botIsReady = false;
 
-  // Gerçek Normal IP Bağlantısını Başlayan Fonksiyon
-  const connectDirectly = (reason) => {
-    if (fallbackTriggered) return;
-    fallbackTriggered = true;
+        stopPeriodicHomeChecks();
+        if (bot) {
+          try { bot.removeAllListeners(); } catch(e){}
+          bot = null;
+        }
 
-    logger.warn(`[Bağlantı Yedekleme] SSH Tüneli başarısız oldu (${reason}). Normal IP üzerinden GERÇEK TCP bağlantısı kuruluyor...`);
+        if (config.utils && config.utils["auto-reconnect"]) {
+          logger.info(`[Sistem] ${config.utils["auto-reconnect-delay"]} ms sonra her şey sıfırdan tekrar denenecek...`);
+          setTimeout(() => {
+            createBot();
+          }, config.utils["auto-reconnect-delay"]);
+        }
+      };
 
-    try { sshClient.end(); } catch (e) {}
+      // SSH Patladığında Gerçek TCP Soketi Açan Fonksiyon
+      const connectDirectly = (reason) => {
+        if (fallbackTriggered) return;
+        fallbackTriggered = true;
 
-    // Sunucunun orijinal IP ve Portuna bağlanmayı dene
-    const socket = net.connect({
-      host: config.server.ip,
-      port: parseInt(config.server.port) || 25565
-    });
+        logger.warn(`[Bağlantı Yedekleme] SSH Tüneli başarısız oldu (${reason}). Normal IP üzerinden GERÇEK TCP bağlantısı kuruluyor...`);
 
-    // Normal IP bağlantısı için 10 saniyelik bir zaman aşımı
-    const directTimeout = setTimeout(() => {
-      socket.destroy();
-      handleFinalFailure("Normal IP bağlantısı zaman aşımına uğradı (Sunucu yanıt vermiyor)");
-    }, 10000);
-
-    socket.on('connect', () => {
-      clearTimeout(directTimeout);
-      logger.info("[Bağlantı Yedekleme] Normal IP üzerinden GERÇEK TCP bağlantısı başarıyla kuruldu!");
-      baglantiTuru = "Normal";
-      client.setSocket(socket);
-      client.emit('connect');
-    });
+        try { sshClient.end(); } catch (e) {}
 
-    socket.on('error', (err) => {
-      clearTimeout(directTimeout);
-      logger.error(`[Bağlantı Yedekleme Hatası] Normal IP ile de sunucuya bağlanılamadı: ${err.message}`);
-      // Normal IP de patladı, her şeyi sıfırla ve başa dön!
-      handleFinalFailure(`Normal IP hatası: ${err.message}`);
-    });
-    
-    socket.on('close', () => {
-      clearTimeout(directTimeout);
-      handleFinalFailure("Normal TCP soketi kapandı");
-    });
-  };
+        const socket = net.connect({
+          host: targetServerIp,
+          port: parseInt(targetServerPort) || 25565
+        });
 
-  logger.info(`[SSH Tünel] ${sshConfig.host} sunucusuna bağlanılıyor...`);
-
-  // SSH için 10 saniyelik zaman aşımı
-  const connectionTimeout = setTimeout(() => {
-    connectDirectly("SSH Bağlantı Zaman Aşımı (10 saniye yanıt alınamadı)");
-  }, 10000);
-
-  sshClient.on('ready', () => {
-    clearTimeout(connectionTimeout);
-    logger.info('[SSH Tünel] SSH bağlantısı başarılı. Minecraft sunucusuna tünel açılıyor...');
-
-    sshClient.forwardOut(
-      '127.0.0.1',
-      12345,
-      config.server.ip,
-      parseInt(config.server.port) || 25565,
-      (err, stream) => {
-        if (err) {
-          connectDirectly(`Tünel yönlendirme hatası: ${err.message}`);
-          return;
-        }
+        // Normal IP bağlantısı için 10 saniye limit
+        const directTimeout = setTimeout(() => {
+          socket.destroy();
+          handleFinalFailure("Normal IP bağlantısı zaman aşımına uğradı (Sunucu yanıt vermiyor)");
+        }, 10000);
 
-        logger.info("[SSH Tünel] Tünel başarıyla kuruldu! Mineflayer sokete bağlanıyor.");
-        baglantiTuru = "SSH";
+        socket.on('connect', () => {
+          clearTimeout(directTimeout);
+          logger.info("[Bağlantı Yedekleme] Normal IP üzerinden GERÇEK TCP bağlantısı başarıyla kuruldu!");
+          baglantiTuru = "Normal";
+          client.setSocket(socket);
+          client.emit('connect');
+        });
 
-        stream.on('close', () => {
-          connectDirectly("Tünel stream kapandı");
+        socket.on('error', (err) => {
+          clearTimeout(directTimeout);
+          logger.error(`[Bağlantı Yedekleme Hatası] Normal IP ile de sunucuya bağlanılamadı: ${err.message}`);
+          handleFinalFailure(`Normal IP hatası: ${err.message}`);
         });
         
-        stream.on('error', (e) => {
-          connectDirectly(`Stream hatası: ${e.message}`);
+        socket.on('close', () => {
+          clearTimeout(directTimeout);
+          handleFinalFailure("Normal TCP soketi kapandı");
         });
+      };
+
+      logger.info(`[SSH Tünel] ${sshConfig.host} sunucusuna bağlanılıyor...`);
+
+      // SSH İlk Bağlantı Zaman Aşımı (10 Saniye)
+      const connectionTimeout = setTimeout(() => {
+        connectDirectly("SSH Bağlantı Zaman Aşımı (10 saniye yanıt alınamadı)");
+      }, 10000);
+
+      sshClient.on('ready', () => {
+        clearTimeout(connectionTimeout);
+        logger.info('[SSH Tünel] SSH bağlantısı başarılı. Minecraft sunucusuna tünel açılıyor...');
+
+        sshClient.forwardOut(
+          '127.0.0.1',
+          12345,
+          targetServerIp,
+          parseInt(targetServerPort) || 25565,
+          (err, stream) => {
+            if (err) {
+              connectDirectly(`Tünel yönlendirme hatası: ${err.message}`);
+              return;
+            }
 
-        client.setSocket(stream);
-        client.emit('connect');
-      }
-    );
-  });
+            logger.info("[SSH Tünel] Tünel başarıyla kuruldu! Mineflayer sokete bağlanıyor.");
+            baglantiTuru = "SSH";
 
-  sshClient.on('error', (err) => {
-    clearTimeout(connectionTimeout);
-    connectDirectly(`SSH Sunucu Hatası: ${err.message}`);
-  });
+            stream.on('close', () => {
+              connectDirectly("Tünel stream kapandı");
+            });
+            
+            stream.on('error', (e) => {
+              connectDirectly(`Stream hatası: ${e.message}`);
+            });
 
-  try {
-    sshClient.connect(sshConfig);
-  } catch (err) {
-    clearTimeout(connectionTimeout);
-    connectDirectly(`Sistem Hatası: ${err.message}`);
-  }
-}
-  });
+            client.setSocket(stream);
+            client.emit('connect');
+          }
+        );
+      });
 
+      sshClient.on('error', (err) => {
+        clearTimeout(connectionTimeout);
+        connectDirectly(`SSH Sunucu Hatası: ${err.message}`);
+      });
+
+      try {
+        sshClient.connect(sshConfig);
+      } catch (err) {
+        clearTimeout(connectionTimeout);
+        connectDirectly(`Sistem Hatası: ${err.message}`);
+      }
+    }
+  });
 
   bot.loadPlugin(pathfinder);
 
@@ -218,7 +259,7 @@ connect: (client) => {
   }
   // ------------------------------------------------
 
-  // --- SENİN ORİJİNAL FONKSİYONLARIN (TAMAMEN AYNI) ---
+  // --- SENİN ORİJİNAL FONKSİYONLARIN ---
   function stripColorCodes(s) {
     if (!s || typeof s !== "string") return s;
     return s.replace(/§[0-9a-fk-or]/gi, "");
@@ -257,6 +298,7 @@ connect: (client) => {
     return TARGET_NAME_NORMS.some(t => norm.includes(t));
   }
 
+  // safeGet, deepSearchForString, parseWindowTitleToString, extractMinyonCanFromSlot fonksiyonları aynen korundu
   function safeGet(obj, pathArray) {
     try {
       let cur = obj;
@@ -338,12 +380,12 @@ connect: (client) => {
   }
 
   async function goHome() {
-    logger.info(`[${config["bot-account"]["username"]}] ${GO_HOME_COMMAND} komutu gönderiliyor.`);
+    logger.info(`[${currentBotUsername}] ${GO_HOME_COMMAND} komutu gönderiliyor.`);
     bot.chat(GO_HOME_COMMAND);
   }
 
   async function returnIsland() {
-    logger.info(`[${config["bot-account"]["username"]}] ${RETURN_ISLAND_COMMAND} komutu gönderiliyor.`);
+    logger.info(`[${currentBotUsername}] ${RETURN_ISLAND_COMMAND} komutu gönderiliyor.`);
     bot.chat(RETURN_ISLAND_COMMAND);
   }
 
@@ -369,17 +411,17 @@ connect: (client) => {
     }
 
     if (!best) {
-      logger.info(`[${config["bot-account"]["username"]}] /home sonrası tarama: besleyici minyon bulunamadı.`);
+      logger.info(`[${currentBotUsername}] /home sonrası tarama: besleyici minyon bulunamadı.`);
       bot.chat("/skyblock");
       return;
     }
 
     const dist = bot.entity.position.distanceTo(best.entity.position);
-    logger.info(`[${config["bot-account"]["username"]}] '${best.entity.name || 'Armor Stand'}' bulundu id:${best.entity.id} path:${best.path} dist:${dist.toFixed(2)} — aktive ediliyor.`);
+    logger.info(`[${currentBotUsername}] '${best.entity.name || 'Armor Stand'}' bulundu id:${best.entity.id} path:${best.path} dist:${dist.toFixed(2)} — aktive ediliyor.`);
 
     if (dist > 7) {
       logger.warn(`safeActivateEntityPreferAt: entity id:${best.entity.id} uzak (${dist.toFixed(2)}). Max 7 blok.`);
-      logger.warn(`[${config["bot-account"]["username"]}] 'Besleyici' aktive edilemedi (id:${best.entity.id}).`);
+      logger.warn(`[${currentBotUsername}] 'Besleyici' aktive edilemedi (id:${best.entity.id}).`);
       return;
     }
 
@@ -408,12 +450,12 @@ connect: (client) => {
       
       setSafeTimeout(() => {
         bot.chat(`/login ${password}`);
-        logger.info(`[${config["bot-account"]["username"]}] Login komutu kullanıldı.`);
+        logger.info(`[${currentBotUsername}] Login komutu kullanıldı.`);
       }, 2500);
 
       setSafeTimeout(() => {
         bot.chat(`/skyblock`);
-        logger.info(`[${config["bot-account"]["username"]}] Skyblock'a ışınlanma komutu kullanıldı.`);
+        logger.info(`[${currentBotUsername}] Skyblock'a ışınlanma komutu kullanıldı.`);
       }, 7500);
 
       setSafeTimeout(async () => {
@@ -438,7 +480,7 @@ connect: (client) => {
   bot.on("windowOpen", (window) => {
     const title = parseWindowTitleToString(window.title).toLowerCase();
     if (!title.includes("besleyici") && !parseWindowTitleToString(window.title).includes("ʙᴇsʟᴇʏiᴄi")) {
-      logger.info(`[${config["bot-account"]["username"]}] Bi chest açıldı ama window title ı uyuşmadığı için kapatıldı. ${parseWindowTitleToString(window.title)}`);
+      logger.info(`[${currentBotUsername}] Bi chest açıldı ama window title ı uyuşmadığı için kapatıldı. ${parseWindowTitleToString(window.title)}`);
       bot.closeWindow(window);
       return;
     }
@@ -448,12 +490,12 @@ connect: (client) => {
       if (can <= 2) {
         bot.clickWindow(36, 0, 0);
         lastFullFeedAt = Date.now();
-        logger.info(`[${config["bot-account"]["username"]}] Minyon canı ${can} olduğu için beslendi. 50dk bekleme aktif.`);
+        logger.info(`[${currentBotUsername}] Minyon canı ${can} olduğu için beslendi. 50dk bekleme aktif.`);
       } else if (can >= 10) {
         lastFullFeedAt = Date.now();
-        logger.info(`[${config["bot-account"]["username"]}] Minyon canı ${can} (tam). 50dk bekleme aktif.`);
+        logger.info(`[${currentBotUsername}] Minyon canı ${can} (tam). 50dk bekleme aktif.`);
       } else {
-        logger.info(`[${config["bot-account"]["username"]}] Minyon canı ${can} olduğu için yenilenmedi.`);
+        logger.info(`[${currentBotUsername}] Minyon canı ${can} olduğu için yenilenmedi.`);
       }
     }
     setSafeTimeout(() => { try { bot.closeWindow(window); } catch(e){} }, 500);
@@ -481,9 +523,11 @@ connect: (client) => {
 
 createBot();
 
+// --- EXPRESS SUNUCUSU VE PANEL ENTEGRASYONU ---
 const express = require("express");
 const app = express();
 const http = require('http');
+
 function minecraftMessageListener(jsonMsg) {
   try {
     const chatMessage = bot.chat.ChatMessage ? new bot.chat.ChatMessage(jsonMsg) : jsonMsg;
@@ -501,18 +545,16 @@ function minecraftMessageListener(jsonMsg) {
   }
 }
 
-// 2. Express Rotaları
 app.get("/status", (req, res) => {
   res.send({ 
     ready: botIsReady, 
     username: bot ? bot.username : null,
-    connection_type: baglantiTuru // Panel için SSH mı yoksa Normal IP mi bilgisi
+    connection_type: baglantiTuru
   });
 });
 
 app.get("/", (req, res) => res.send("Bot Aktif"));
 
-// Canlı Sohbet (Messages) Tasarruf Rotası
 app.get("/messages", (req, res) => {
   if (messagesTimeout) {
     clearTimeout(messagesTimeout);
@@ -533,7 +575,6 @@ app.get("/messages", (req, res) => {
     logs: activeMessages
   });
 
-  // 1 dakika boyunca yeni istek gelmezse eventi kaldır ve hafızayı sil
   messagesTimeout = setTimeout(() => {
     if (bot) {
       bot.off('message', minecraftMessageListener);
@@ -544,7 +585,6 @@ app.get("/messages", (req, res) => {
   }, 60000);
 });
 
-// 3. 3D Görüntüleyici Tetikleyici Middleware
 const checkAndStartViewer = (req, res, next) => {
   if (viewerTimeout) {
     clearTimeout(viewerTimeout);
@@ -572,7 +612,6 @@ const checkAndStartViewer = (req, res, next) => {
   next();
 };
 
-// 4. HTTP Asset Dağıtıcı (Yönlendirici)
 app.use('/3dview', checkAndStartViewer, (req, res) => {
   if (req.originalUrl === '/3dview' && !req.originalUrl.endsWith('/')) {
     return res.redirect(301, '/3dview/');
@@ -601,19 +640,14 @@ app.use('/3dview', checkAndStartViewer, (req, res) => {
 app.get("/restart", (req, res) => {
   if (bot && botIsReady) {
     logger.info("[Sistem] Web paneli üzerinden tam restart isteği geldi. Proje kapatılıyor...");
-    
     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." });
-    
-    // Tarayıcıya yanıtın sorunsuz gitmesi için 1 saniye bekleyip süreci öldürüyoruz
     setTimeout(() => {
       if (bot) bot.quit();
       logger.info("[Sistem] process.exit(0) çağrıldı. Konteyner yeniden başlatılacak.");
-      process.exit(0); // Projeyi kökten kapatır.
+      process.exit(0);
     }, 1000);
   } else {
-    // Bot bağlı olmasa bile web panelinden tüm projeyi resetleyebilmek için fallback
     logger.info("[Sistem] Bot bağlı değilken web panelinden tam restart istendi.");
     res.send({ success: true, message: "Bot bağlı değildi ancak tüm proje kökten kapatıldı, yeniden başlatılıyor." });
     setTimeout(() => {
@@ -622,15 +656,12 @@ app.get("/restart", (req, res) => {
   }
 });
 
-// 5. Hugging Face Ana Port Dinleyicisi (Tek Çıkış Kapısı)
 const server = app.listen(process.env.PORT || 7860, () => {
   logger.info("Ana Express sunucusu 7860 portunda aktif.");
 });
 
-// 6. RAM Tasarruflu Ham WebSocket Tüneli
 server.on('upgrade', (req, socket, head) => {
   if (req.url.includes('socket.io') || req.url.startsWith('/3dview')) {
-    
     if (viewerTimeout) {
       clearTimeout(viewerTimeout);
       viewerTimeout = null;
@@ -662,7 +693,6 @@ server.on('upgrade', (req, socket, head) => {
 
       socket.on('close', () => {
         if (viewerTimeout) clearTimeout(viewerTimeout);
-        
         viewerTimeout = setTimeout(() => {
           if (viewerInstance && typeof viewerInstance.close === 'function') {
             try {
@@ -690,7 +720,6 @@ const originalStderrWrite = process.stderr.write;
 process.stderr.write = function (chunk, encoding, callback) {
   const message = chunk.toString();
   if (message.includes("Ignoring block entities as chunk failed to load")) {
-    // Bu uyarıyı yut ve konsola basma
     if (typeof callback === 'function') callback();
     return true;
   }