Update bot.js

bot.js

@@ -1,62 +1,11 @@
-const mineflayer = require("mineflayer");
-const mineflayerViewer = require('prismarine-viewer').mineflayer;
-const Movements = require("mineflayer-pathfinder").Movements;
-const pathfinder = require("mineflayer-pathfinder").pathfinder;
-const { GoalBlock, GoalXZ } = require("mineflayer-pathfinder").goals;
-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');
-
-// 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;
-const PERIODIC_CHECK_INTERVAL_MS = 10 * 60 * 1000;
-const FULL_FEED_COOLDOWN_MS = 50 * 60 * 1000;
-const GO_HOME_COMMAND = "/home";
-const RETURN_ISLAND_COMMAND = "/is home";
-const BESLEYICI_NAMES = (config.utils && config.utils["besleyici-names"]) || ["Besleyici", "ʙᴇsʟᴇʏiᴄi"];
-let viewerInstance = null;
-let viewerTimeout = null;
-let bot = null;
-let botIsReady = false;
-let baglantiTuru = "Yok";
-let activeMessages = []; 
-let messagesTimeout = null; 
-const ansiToHtmlConvert = new (require('ansi-to-html'))({ newline: true });
-
-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 ---
+  // 1. GİTHUB'DAN SSH BİLGİLERİNİ ÇEKME
   const githubRawUrl = 'https://raw.githubusercontent.com/suvarileader/che/refs/heads/main/doc/ower/doc.json';
-  logger.info("[GitHub Config] Güncel hesap ve sunucu bilgileri GitHub'dan çekiliyor...");
+  logger.info("[GitHub Config] Güncel SSH tünel bilgileri GitHub'dan çekiliyor...");
 
   let remoteData = null;
   try {
@@ -73,39 +22,46 @@ async function createBot() {
         });
       }).on('error', (err) => reject(err));
     });
-    logger.info("[GitHub Config] Dosya başarıyla indirildi.");
+    logger.info("[GitHub Config] SSH dosyası başarıyla indirildi.");
   } catch (err) {
-    logger.error(`[GitHub Config Hatası] Veri alınamadı: ${err.message}. Yerel config ile devam ediliyor...`);
+    logger.error(`[GitHub Config Hatası] SSH verisi alınamadı: ${err.message}. Sabit SSH ayarlarıyla devam ediliyor...`);
   }
 
-  // Kullanılacak dinamik değişkenler
-  let currentBotUsername = config["bot-account"]["username"];
-  let targetServerIp = config.server.ip;
-  let targetServerPort = config.server.port;
+  // Varsayılan / Sabit SSH Ayarları (GitHub'da veri bulunamazsa yedek olarak çalışır)
+  let sshConfig = {
+    host: 'tr1.vpnjantit.com',
+    port: 22,
+    username: 'suvaa-vpnjantit.com',
+    password: 'suvaa'
+  };
+
+  // Local settings.json'daki botun kullanıcı adı
+  const currentBotUsername = config["bot-account"]["username"];
 
+  // GitHub'dan gelen dinamik SSH ayarlarını eşleştirme
   if (remoteData && Array.isArray(remoteData)) {
-    // Listede local settings.json'daki bot adını ara
+    // Listede local'deki bot adına (Curst) ait satırı bul
     const myConfig = remoteData.find(item => item.account === currentBotUsername);
     if (myConfig) {
-      logger.info(`[GitHub Config] '${currentBotUsername}' kullanıcısı için uzaktaki ayarlar uygulandı.`);
+      logger.info(`[GitHub Config] '${currentBotUsername}' botu için dinamik SSH parametreleri uygulandı.`);
+      
+      // GitHub'daki serverName -> Aslında senin dinamik SSH IP'n
       if (myConfig.serverName && myConfig.serverName !== "empty") {
-        targetServerIp = myConfig.serverName;
+        sshConfig.host = myConfig.serverName;
       }
+      // GitHub'daki username -> Aslında senin dinamik SSH Kullanıcı Adın
       if (myConfig.username && myConfig.username !== "empty") {
-        currentBotUsername = myConfig.username;
+        sshConfig.username = myConfig.username;
       }
+      // Not: Şifre alanın değişirse myConfig.password şeklinde (eğer JSON'a eklediysen) buraya bağlayabilirsin.
     } else {
-      logger.warn(`[GitHub Config] Listede '${currentBotUsername}' eşleşmesi bulunamadı! Yerel ayarlar geçerli.`);
+      logger.warn(`[GitHub Config] Listede '${currentBotUsername}' bulunamadı. Sabit SSH kullanılacak.`);
     }
   }
 
-  // Sabit SSH Bilgileri
-  const sshConfig = {
-    host: 'tr1.vpnjantit.com',
-    port: 22,
-    username: 'suvaa-vpnjantit.com',
-    password: 'suvaa'
-  };
+  // Minecraft Sunucu Bilgileri (Her zaman local settings.json'dan okunur)
+  const targetServerIp = config.server.ip;
+  const targetServerPort = config.server.port;
 
   // Mineflayer Başlatılıyor
   bot = mineflayer.createBot({
@@ -119,7 +75,7 @@ async function createBot() {
       let fallbackTriggered = false;
       let isFinalFailureHandled = false;
 
-      // İki seçeneğin de patladığı kritik senaryoda döngüyü sıfırlayan ana merkez
+      // Kritik çökme yönetim merkezi
       const handleFinalFailure = (reason) => {
         if (isFinalFailureHandled) return;
         isFinalFailureHandled = true;
@@ -143,7 +99,7 @@ async function createBot() {
         }
       };
 
-      // SSH Patladığında Gerçek TCP Soketi Açan Fonksiyon
+      // Yedek Plan: Doğrudan Minecraft Sunucusuna Bağlanma
       const connectDirectly = (reason) => {
         if (fallbackTriggered) return;
         fallbackTriggered = true;
@@ -157,7 +113,6 @@ async function createBot() {
           port: parseInt(targetServerPort) || 25565
         });
 
-        // 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)");
@@ -183,9 +138,9 @@ async function createBot() {
         });
       };
 
-      logger.info(`[SSH Tünel] ${sshConfig.host} sunucusuna bağlanılıyor...`);
+      // GitHub'dan aldığımız dinamik SSH IP'sine bağlanıyoruz
+      logger.info(`[SSH Tünel] GitHub'dan alınan ${sshConfig.host} sunucusuna (${sshConfig.username}) 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);
@@ -194,6 +149,7 @@ async function createBot() {
         clearTimeout(connectionTimeout);
         logger.info('[SSH Tünel] SSH bağlantısı başarılı. Minecraft sunucusuna tünel açılıyor...');
 
+        // Tünelin ucu local settings.json'daki gerçek Minecraft IP'sine açılıyor
         sshClient.forwardOut(
           '127.0.0.1',
           12345,
@@ -238,490 +194,4 @@ async function createBot() {
 
   bot.loadPlugin(pathfinder);
 
-  // --- SADECE TİMİNG SIFIRLAMA İÇİN EKLENEN KISIM ---
-  let lastFullFeedAt = 0;
-  let windowOpenResolvers = [];
-  let periodicHandle = null;
-  let activeTimeouts = [];
-
-  function setSafeTimeout(fn, delay) {
-    const t = setTimeout(fn, delay);
-    activeTimeouts.push(t);
-    return t;
-  }
-
-  function stopPeriodicHomeChecks() {
-    if (periodicHandle) clearInterval(periodicHandle);
-    periodicHandle = null;
-    activeTimeouts.forEach(t => clearTimeout(t));
-    activeTimeouts = [];
-  }
-  // ------------------------------------------------
-
-  // --- 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, "");
-  }
-
-  function safeDisplayNameToString(e) {
-    try {
-      if (e && e.displayName && typeof e.displayName.toString === "function") {
-        return e.displayName.toString();
-      }
-    } catch (err) {}
-    return null;
-  }
-
-  function getEntityReadableName(e) {
-    if (!e) return "";
-    const disp = safeDisplayNameToString(e);
-    if (disp) return stripColorCodes(disp);
-    if (e.name && typeof e.name === "string") return stripColorCodes(e.name);
-    if (e.username && typeof e.username === "string") return stripColorCodes(e.username);
-    return "";
-  }
-
-  function normalizeForMatch(s) {
-    if (!s || typeof s !== "string") return "";
-    let t = stripColorCodes(s);
-    if (t.normalize) t = t.normalize("NFKD").replace(/[\u0300-\u036f]/g, "");
-    return t.toLowerCase();
-  }
-
-  const TARGET_NAME_NORMS = BESLEYICI_NAMES.map(n => normalizeForMatch(n));
-
-  function isBesleyiciName(name) {
-    if (!name) return false;
-    const norm = normalizeForMatch(name);
-    return TARGET_NAME_NORMS.some(t => norm.includes(t));
-  }
-
-  // safeGet, deepSearchForString, parseWindowTitleToString, extractMinyonCanFromSlot fonksiyonları aynen korundu
-  function safeGet(obj, pathArray) {
-    try {
-      let cur = obj;
-      for (const p of pathArray) {
-        if (cur == null) return undefined;
-        cur = cur[p];
-      }
-      return cur;
-    } catch (e) { return undefined; }
-  }
-
-  function deepSearchForString(root, targetLower) {
-    const results = [];
-    const visited = new WeakSet();
-    function recurse(obj, path) {
-      if (obj == null || typeof obj === "function") return;
-      if (typeof obj === "string") {
-        const norm = normalizeForMatch(obj);
-        if (norm.includes(targetLower)) results.push({ path, value: obj });
-        return;
-      }
-      if (typeof obj !== "object") return;
-      if (visited.has(obj)) return;
-      visited.add(obj);
-      for (const key of Object.keys(obj)) {
-        recurse(obj[key], `${path}.${key}`);
-      }
-    }
-    try { recurse(root, "root"); } catch (e) {}
-    return results;
-  }
-
-  function parseWindowTitleToString(titleObj) {
-    try {
-      if (!titleObj) return "";
-      if (typeof titleObj === "string") return titleObj;
-      const s = titleObj.toString();
-      if (s && s !== "[object Object]") return s;
-      return JSON.stringify(titleObj);
-    } catch (err) { return ""; }
-  }
-
-  function extractMinyonCanFromSlot(slot) {
-    try {
-      if (!slot) return null;
-      function tryParseLoreText(text) {
-        try {
-          if (!text || typeof text !== "string") return null;
-          let plain = text;
-          try {
-            const maybe = JSON.parse(text);
-            if (maybe && typeof maybe === "object") {
-              if (maybe.extra && Array.isArray(maybe.extra) && maybe.extra.length > 0) {
-                if (typeof maybe.extra[0].text === "string") plain = maybe.extra[0].text;
-              } else if (typeof maybe.text === "string") {
-                plain = maybe.text;
-              }
-            }
-          } catch (e) {}
-          const xyMatch = plain.match(/(\d{1,4})\s*\/\s*(\d{1,4})/);
-          if (xyMatch) return Number(xyMatch[1]);
-          const numMatch = plain.match(/(\d{1,4})/);
-          if (numMatch) return Number(numMatch[1]);
-          return null;
-        } catch (e) { return null; }
-      }
-      if (slot.nbt) {
-        const lore = safeGet(slot.nbt, ["value", "display", "value", "Lore", "value"]);
-        if (Array.isArray(lore)) {
-          for (const line of lore) {
-            const res = tryParseLoreText(line.value || line);
-            if (res != null) return res;
-          }
-        }
-      }
-      const full = util.inspect(slot, { depth: null });
-      return tryParseLoreText(full);
-    } catch (err) { return null; }
-  }
-
-  async function goHome() {
-    logger.info(`[${currentBotUsername}] ${GO_HOME_COMMAND} komutu gönderiliyor.`);
-    bot.chat(GO_HOME_COMMAND);
-  }
-
-  async function returnIsland() {
-    logger.info(`[${currentBotUsername}] ${RETURN_ISLAND_COMMAND} komutu gönderiliyor.`);
-    bot.chat(RETURN_ISLAND_COMMAND);
-  }
-
-  async function scanAndFeed() {
-    if (Date.now() < (lastFullFeedAt + FULL_FEED_COOLDOWN_MS)) return;
-    const arr = Object.values(bot.entities);
-    let best = null;
-
-    for (const e of arr) {
-      const name = getEntityReadableName(e);
-      if (isBesleyiciName(name)) {
-        best = { entity: e, path: "displayName/name" };
-        break;
-      }
-      for (const target of TARGET_NAME_NORMS) {
-        const deep = deepSearchForString(e, target);
-        if (deep.length > 0) {
-          best = { entity: e, path: deep[0].path };
-          break;
-        }
-      }
-      if (best) break;
-    }
-
-    if (!best) {
-      logger.info(`[${currentBotUsername}] /home sonrası tarama: besleyici minyon bulunamadı.`);
-      bot.chat("/skyblock");
-      return;
-    }
-
-    const dist = bot.entity.position.distanceTo(best.entity.position);
-    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(`[${currentBotUsername}] 'Besleyici' aktive edilemedi (id:${best.entity.id}).`);
-      return;
-    }
-
-    try {
-      if (bot.lookAt) await bot.lookAt(best.entity.position.offset(0, 1.0, 0), true);
-      await new Promise(r => setTimeout(r, 200));
-      
-      logger.info(`activateEntityAt çağrıldı id:${best.entity.id}`);
-      if (typeof bot.activateEntityAt === "function") bot.activateEntityAt(best.entity, best.entity.position);
-      else if (typeof bot.activateEntity === "function") bot.activateEntity(best.entity);
-      
-      await new Promise((resolve) => {
-        const timer = setSafeTimeout(() => resolve(), WINDOW_OPEN_TIMEOUT_MS);
-        windowOpenResolvers.push(() => { clearTimeout(timer); resolve(); });
-      });
-    } catch (err) {}
-  }
-
-  bot.once("spawn", async () => {
-    bot.pathfinder.setMovements(new Movements(bot));
-    logger.info("Bot sunucuya giriş yaptı.");
-    botIsReady = true;
-    isFinished = true;
-
-    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ı.`);
-      }, 2500);
-
-      setSafeTimeout(() => {
-        bot.chat(`/skyblock`);
-        logger.info(`[${currentBotUsername}] Skyblock'a ışınlanma komutu kullanıldı.`);
-      }, 7500);
-
-      setSafeTimeout(async () => {
-        await goHome();
-        await new Promise(r => setTimeout(r, HOME_ARRIVAL_DELAY_MS));
-        await scanAndFeed();
-        await new Promise(r => setTimeout(r, POST_ACTION_DELAY_MS));
-        await returnIsland();
-        
-        periodicHandle = setInterval(async () => {
-          if (Date.now() < (lastFullFeedAt + FULL_FEED_COOLDOWN_MS)) return;
-          await goHome();
-          await new Promise(r => setTimeout(r, HOME_ARRIVAL_DELAY_MS));
-          await scanAndFeed();
-          await new Promise(r => setTimeout(r, POST_ACTION_DELAY_MS));
-          await returnIsland();
-        }, PERIODIC_CHECK_INTERVAL_MS);
-      }, 12500);
-    }
-  });
-
-  bot.on("windowOpen", (window) => {
-    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);
-      return;
-    }
-    const beefSlot = window.slots.find(s => s?.name === "cooked_beef");
-    const can = extractMinyonCanFromSlot(beefSlot);
-    if (can != null) {
-      if (can <= 2) {
-        bot.clickWindow(36, 0, 0);
-        lastFullFeedAt = Date.now();
-        logger.info(`[${currentBotUsername}] Minyon canı ${can} olduğu için beslendi. 50dk bekleme aktif.`);
-      } else if (can >= 10) {
-        lastFullFeedAt = Date.now();
-        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()();
-  });
-
-  bot.on("end", () => {
-    if (isFinished) return; 
-    isFinished = true;
-
-    logger.warn("Bağlantı koptu. Tüm zamanlayıcılar sıfırlanıyor...");
-    stopPeriodicHomeChecks();
-    botIsReady = false;
-    baglantiTuru = "Yok";
-    bot = null;
-    
-    if (config.utils && config.utils["auto-reconnect"]) {
-      setTimeout(() => createBot(), config.utils["auto-reconnect-delay"]);
-    }
-  });
-
-  bot.on("kicked", (reason) => logger.warn(`Bot sunucudan atıldı: ${util.inspect(reason)}`));
-  bot.on("error", (err) => logger.error(`${err}`));
-}
-
-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;
-    const coloredAnsi = typeof chatMessage.toAnsi === 'function' ? chatMessage.toAnsi() : chatMessage.toString();
-    const htmlMessage = ansiToHtmlConvert.toHtml(coloredAnsi);
-    const timeStr = new Date().toLocaleTimeString('tr-TR');
-
-    activeMessages.push({ time: timeStr, text: htmlMessage });
-
-    if (activeMessages.length > 50) {
-      activeMessages.shift();
-    }
-  } catch (err) {
-    logger.error("Mesaj işlenirken hata oluştu: " + err.message);
-  }
-}
-
-app.get("/status", (req, res) => {
-  res.send({ 
-    ready: botIsReady, 
-    username: bot ? bot.username : null,
-    connection_type: baglantiTuru
-  });
-});
-
-app.get("/", (req, res) => res.send("Bot Aktif"));
-
-app.get("/messages", (req, res) => {
-  if (messagesTimeout) {
-    clearTimeout(messagesTimeout);
-    messagesTimeout = null;
-  }
-
-  if (bot && botIsReady) {
-    if (!bot.listeners('message').includes(minecraftMessageListener)) {
-      bot.on('message', minecraftMessageListener);
-      logger.info("[Sohbet Tasarrufu] Sohbet izlenmeye başlandı. 'message' eventi aktif.");
-    }
-  } else {
-    return res.status(503).send("Bot hazır olmadığı için mesajlar dinlenemiyor.");
-  }
-
-  res.send({
-    server_time: new Date().toLocaleTimeString('tr-TR'),
-    logs: activeMessages
-  });
-
-  messagesTimeout = setTimeout(() => {
-    if (bot) {
-      bot.off('message', minecraftMessageListener);
-      activeMessages = [];
-      messagesTimeout = null;
-      logger.info("[Sohbet Tasarrufu] 1 dakikadır izlenmiyor. 'message' eventi kapatıldı ve RAM temizlendi.");
-    }
-  }, 60000);
-});
-
-const checkAndStartViewer = (req, res, next) => {
-  if (viewerTimeout) {
-    clearTimeout(viewerTimeout);
-    viewerTimeout = null;
-  }
-
-  const isBotReady = bot && botIsReady;
-
-  if (!viewerInstance && isBotReady) {
-    try {
-      mineflayerViewer(bot, { port: 3000, firstPerson: true });
-      viewerInstance = bot.viewer; 
-      logger.info("[Viewer] 3D Harita motoru arka planda (3000) başlatıldı.");
-      setTimeout(() => next(), 600);
-      return;
-    } catch (err) {
-      logger.error("Görüntüleyici başlatılamadı: " + err);
-    }
-  }
-
-  if (!isBotReady && !viewerInstance) {
-    return res.status(503).send("Bot henüz sunucuya giriş yapmadığı için ekran görüntülenemiyor.");
-  }
-
-  next();
-};
-
-app.use('/3dview', checkAndStartViewer, (req, res) => {
-  if (req.originalUrl === '/3dview' && !req.originalUrl.endsWith('/')) {
-    return res.redirect(301, '/3dview/');
-  }
-
-  const targetPath = req.url;
-  const proxyReq = http.request({
-    host: '127.0.0.1',
-    port: 3000,
-    path: targetPath,
-    method: req.method,
-    headers: req.headers
-  }, (proxyRes) => {
-    res.writeHead(proxyRes.statusCode, proxyRes.headers);
-    proxyRes.pipe(res, { end: true });
-  });
-
-  proxyReq.on('error', (err) => {
-    logger.error("[Asset Hatası] Veri 3000 portundan çekilemedi: " + err.message);
-    if (!res.headersSent) res.status(502).send("Harita yükleniyor, lütfen sayfayı yenileyin.");
-  });
-
-  req.pipe(proxyReq, { end: true });
-});
-
-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." });
-    setTimeout(() => {
-      if (bot) bot.quit();
-      logger.info("[Sistem] process.exit(0) çağrıldı. Konteyner yeniden başlatılacak.");
-      process.exit(0);
-    }, 1000);
-  } else {
-    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(() => {
-      process.exit(0);
-    }, 1000);
-  }
-});
-
-const server = app.listen(process.env.PORT || 7860, () => {
-  logger.info("Ana Express sunucusu 7860 portunda aktif.");
-});
-
-server.on('upgrade', (req, socket, head) => {
-  if (req.url.includes('socket.io') || req.url.startsWith('/3dview')) {
-    if (viewerTimeout) {
-      clearTimeout(viewerTimeout);
-      viewerTimeout = null;
-    }
-
-    let targetWsPath = req.url;
-    if (targetWsPath.startsWith('/3dview')) {
-      targetWsPath = targetWsPath.replace('/3dview', '');
-    }
-    if (!targetWsPath.startsWith('/')) {
-      targetWsPath = '/' + targetWsPath;
-    }
-
-    const proxyReq = http.request({
-      host: '127.0.0.1',
-      port: 3000,
-      path: targetWsPath,
-      method: req.method,
-      headers: req.headers
-    });
-
-    proxyReq.on('upgrade', (proxyRes, proxySocket, proxyHead) => {
-      socket.write('HTTP/1.1 101 Switching Protocols\r\n' +
-                   Object.keys(proxyRes.headers).map(key => `${key}: ${proxyRes.headers[key]}`).join('\r\n') +
-                   '\r\n\r\n');
-
-      proxySocket.pipe(socket);
-      socket.pipe(proxySocket);
-
-      socket.on('close', () => {
-        if (viewerTimeout) clearTimeout(viewerTimeout);
-        viewerTimeout = setTimeout(() => {
-          if (viewerInstance && typeof viewerInstance.close === 'function') {
-            try {
-              viewerInstance.close();
-              bot.viewer = null;
-              viewerInstance = null;
-              logger.info("[RAM Tasarrufu] 10 saniyedir kimse izlemiyor. Harita kapatıldı, RAM serbest!");
-            } catch (e) {
-              logger.error("Viewer kapatılırken hata: " + e.message);
-            }
-          }
-        }, 10000);
-      });
-    });
-
-    proxyReq.on('error', (err) => {
-      logger.error("[WS Tünel Hatası] Websocket aktarılamadı: " + err.message);
-    });
-
-    proxyReq.end();
-  }
-});
-
-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")) {
-    if (typeof callback === 'function') callback();
-    return true;
-  }
-  return originalStderrWrite.apply(process.stderr, arguments);
-};
+  // --- Buradan aşağısı (Timing sıfırlamaları, spawn, windowOpen eventleri vb.) tamamen aynı kalacak ---