Update bot.js

bot.js

@@ -56,6 +56,23 @@ const KAZICI_CYCLE_INTERVAL_MS = 5 * 60 * 1000; // 5 dakika
 // --- ÇİFTÇİ PERİYODİK DÖNGÜ AYARLARI (bağımsız, 1 dakikada bir) ---
 const CIFTCI_CYCLE_INTERVAL_MS = 60 * 1000; // 1 dakika
 
+// --- KAZICI FAILOVER (YEDEK HESAP) AYARLARI ---
+const STALL_CHECK_INTERVAL_MS = 15 * 1000;      // pose kontrolü ne sıklıkla yapılsın
+const STALL_TIMEOUT_MS = 60 * 1000;             // bu süre hareketsiz kalırsa "durdu" say
+const FAILOVER_HOME_ARRIVAL_DELAY_MS = 4000;    // yedek hesapta /is go sonrası varış beklemesi
+const FAILOVER_LOGIN_DELAY_MS = 2500;
+const FAILOVER_SKYBLOCK_DELAY_MS = 7500;
+const FAILOVER_ISGO_DELAY_MS = 12500;
+const FAILOVER_RECHECK_INTERVAL_MS = 20 * 1000; // yedek hesapta minyonları tekrar kontrol aralığı
+const FAILOVER_MAX_WAIT_MS = 60 * 60 * 1000;    // güvenlik: 1 saatte hâlâ aktifleşmediyse pes et, ana hesaba dön
+const FAILOVER_SPAWN_TIMEOUT_MS = 30 * 1000;    // yedek hesap 30 sn içinde spawn olmazsa vazgeç
+
+// İzlenen (KAZICI_NAMES ile eşleşmeyen, başka hesaptan konan) kazıcı minyonların
+// skin texture hash'i. Bu skin + elde iron_pickaxe olan armor stand'ler izlenir.
+const WATCHED_KAZICI_SKIN_HASHES = new Set([
+  "eyJ0ZXh0dXJlcyI6eyJTS0lOIjp7InVybCI6Imh0dHA6Ly90ZXh0dXJlcy5taW5lY3JhZnQubmV0L3RleHR1cmUvNDQ4ODcwY2E3N2FhNjk5ZDAxNzA5M2I4Mjc3OWQwYTU5OGRjNGYzZjQ5ZDM1MTUzMmFlNGQ5NjMzZGNjMmE1YSJ9fX0=",
+]);
+
 let viewerInstance = null;
 let viewerTimeout = null;
 let bot = null;
@@ -98,6 +115,13 @@ let kaziciIntervalHandle = null;   // Kazıcı bağımsız döngü zamanlayıcı
 let ciftciIntervalHandle = null;   // Çiftçi bağımsız döngü zamanlayıcısı (1 dk)
 let isMainCycleRunning = false;    // Besleyici (goToIsland->besle) ana döngüsü sürüyor mu
 
+// --- KAZICI FAILOVER (YEDEK HESAP) DURUM DEĞİŞKENLERİ ---
+let poseTracker = new Map();          // entityId -> { poseKey, lastChangeAt, uuid }
+let stallCheckIntervalHandle = null;
+let failoverModeActive = false;       // true iken ana botun periyodik işlemleri fiilen durur (bot=null olduğu için)
+let failoverBot = null;               // yedek hesabın mineflayer instance'ı
+let failoverInProgress = false;       // aynı anda 2 kez tetiklenmesin diye kilit
+
 // --- DİNAMİK IP VE KONUM BİLGİLERİ ---
 let activeConnectionIp = "Bilinmiyor";
 let activeConnectionLocation = "Bilinmiyor";
@@ -114,20 +138,10 @@ function setSafeTimeout(fn, delay) {
 }
 
 // --- ÖNCELİKLİ GUI KİLİDİ (MUTEX) ---
-// Besleyici, kazıcı ve çiftçi menüleri hepsi aynı windowOpen/tıklama mekanizmasını
-// paylaştığı için ASLA aynı anda çalışmamalılar. Bu kilit ikisi arasında ayrım yapar:
-//  - tryAcquire(): periyodik/otomatik döngüler için. Kilit doluysa BEKLEMEZ, hemen
-//    false döner ve o tur sessizce atlanır (bir sonraki periyotta tekrar dener).
-//  - acquire(): Express panelinden (manuel) gelen istekler için. Kilit doluysa
-//    KUYRUĞA GİRER ve önceliklidir — mevcut işlem bitince, kuyrukta bekleyen varsa
-//    bile (ki otomatik döngüler hiç kuyruğa girmediği için pratikte tek bekleyen
-//    genelde manuel istek olur) ilk manuel istek işi devralır. Böylece kullanıcı
-//    panelden bir istek yaptığında, o sırada süren otomatik bir işlem varsa önce
-//    o tamamlanır, hemen ardından kullanıcının isteği en öncelikli şekilde işlenir.
 class PriorityGuiMutex {
   constructor() {
     this._locked = false;
-    this._waiters = []; // manuel (öncelikli) bekleyenler, FIFO
+    this._waiters = [];
   }
   isLocked() { return this._locked; }
   tryAcquire() {
@@ -147,7 +161,6 @@ class PriorityGuiMutex {
   release() {
     if (this._waiters.length > 0) {
       const next = this._waiters.shift();
-      // Kilit devrediliyor (locked=true kalır), bir sonraki bekleyen devralır.
       next();
     } else {
       this._locked = false;
@@ -156,22 +169,15 @@ class PriorityGuiMutex {
 }
 const guiMutex = new PriorityGuiMutex();
 
-// Express panelinden diğer bot fonksiyonlarına erişim için (createBot() closure'ı
-// dışından çağrılabilmeleri için köprü). Bot her (yeniden) bağlandığında doldurulur.
 let botActions = {
   scanAndFeedManual: null,
   scanAndCollectMinersManual: null,
   openCiftciAndSellAllManual: null,
   goToIslandManual: null,
   sendSkyblockManual: null,
+  antiBotMove: null
 };
 
-// --- ORTAK SÜRE FORMATLAMA FONKSİYONU ---
-// Tüm loglardaki "X dk sonra", "Y saat sonra" gibi elle yazılmış ifadelerin yerine
-// bu fonksiyon kullanılır. Böylece yukarıdaki ayar sabitleri (KAZICI_CYCLE_INTERVAL_MS,
-// CIFTCI_CYCLE_INTERVAL_MS, DEFAULT_CHECK_INTERVAL_MS, vb.) değiştirildiğinde,
-// loglara yansıyan süre ifadeleri OTOMATİK olarak güncellenir; elle metin
-// değiştirmeye gerek kalmaz.
 function formatDurationMs(ms) {
   if (ms == null || isNaN(ms) || ms < 0) return "0 saniye";
   let totalSeconds = Math.round(ms / 1000);
@@ -267,6 +273,295 @@ https.get('https://api.ipify.org?format=json', (res) => {
   });
 }).on('error', () => {});
 
+// =====================================================================
+// KAZICI FAILOVER (YEDEK HESAP) YARDIMCI FONKSİYONLARI
+// Bunlar module-level (createBot() dışında) çünkü bot bağlantısı kesilip
+// yeniden kurulduğunda bile (createBot() tekrar çağrıldığında) hayatta
+// kalmaları gerekiyor.
+// =====================================================================
+
+// Entity'nin skin texture değerini (player_head equipment'inden) çıkarır.
+function getEntitySkinHash(entity) {
+  try {
+    const equipment = entity.equipment || [];
+    for (const item of equipment) {
+      if (item && item.name === "player_head" && item.components) {
+        for (const comp of item.components) {
+          if (comp && comp.type === "profile" && comp.data && Array.isArray(comp.data.properties)) {
+            const texProp = comp.data.properties.find(p => p.name === "textures");
+            if (texProp && texProp.value) {
+              return texProp.value;
+            }
+          }
+        }
+      }
+    }
+  } catch (e) {}
+  return null;
+}
+
+// Entity'nin elinde (equipment[0] = main hand) iron_pickaxe olup olmadığını kontrol eder.
+function hasIronPickaxeEquipped(entity) {
+  try {
+    const equipment = entity.equipment || [];
+    const mainHand = equipment[0];
+    return !!(mainHand && mainHand.name === "iron_pickaxe");
+  } catch (e) {
+    return false;
+  }
+}
+
+// Skin + iron_pickaxe ikisi birden tutuyorsa bu entity izlenen kazıcı minyondur.
+function isWatchedKaziciEntity(entity) {
+  if (!entity || entity.name !== "armor_stand") return false;
+  const skinHash = getEntitySkinHash(entity);
+  if (!skinHash || !WATCHED_KAZICI_SKIN_HASHES.has(skinHash)) return false;
+  return hasIronPickaxeEquipped(entity);
+}
+
+// metadata içindeki pose (kol/kafa açıları) + pozisyonu birleştirip bir imza çıkarır.
+function getPoseKey(entity) {
+  try {
+    const md = entity.metadata || [];
+    const parts = [];
+    for (const m of md) {
+      if (m && typeof m === "object" && "pitch" in m && "yaw" in m && "roll" in m) {
+        parts.push(`${m.pitch.toFixed(2)},${m.yaw.toFixed(2)},${m.roll.toFixed(2)}`);
+      }
+    }
+    if (entity.position) {
+      parts.push(`${entity.position.x.toFixed(2)}_${entity.position.y.toFixed(2)}_${entity.position.z.toFixed(2)}`);
+    }
+    return parts.join("|");
+  } catch (e) {
+    return null;
+  }
+}
+
+// bot.on('entityMoved', ...) ve bot.on('entitySpawn', ...) içinden çağrılır.
+// İzlenen kazıcı minyonun pose'unu takip eder.
+function trackKaziciPoseIfWatched(entity) {
+  if (!entity) return;
+  if (!isWatchedKaziciEntity(entity)) return;
+
+  const poseKey = getPoseKey(entity);
+  if (poseKey == null) return;
+
+  const prev = poseTracker.get(entity.id);
+  if (!prev) {
+    poseTracker.set(entity.id, { poseKey, lastChangeAt: Date.now(), uuid: entity.uuid });
+    return;
+  }
+
+  if (prev.poseKey !== poseKey) {
+    prev.poseKey = poseKey;
+    prev.lastChangeAt = Date.now();
+  }
+  // poseKey aynıysa lastChangeAt GÜNCELLENMEZ -> hareketsizlik süresi büyümeye devam eder.
+}
+
+// Artık dünyada olmayan entity kayıtlarını temizler.
+function pruneStaleTrackedEntities() {
+  if (!bot || !bot.entities) return;
+  for (const id of poseTracker.keys()) {
+    if (!bot.entities[id]) poseTracker.delete(id);
+  }
+}
+
+function startStallWatcher() {
+  if (stallCheckIntervalHandle) return;
+  stallCheckIntervalHandle = setInterval(() => {
+    if (!bot || !botIsReady || failoverModeActive) return;
+    pruneStaleTrackedEntities();
+
+    const now = Date.now();
+    let anyStalled = false;
+    for (const [id, info] of poseTracker.entries()) {
+      if (now - info.lastChangeAt >= STALL_TIMEOUT_MS) {
+        anyStalled = true;
+        logger.warn(`[Failover] İzlenen kazıcı minyon (entityId:${id}) ${formatDurationMs(now - info.lastChangeAt)} boyunca hareketsiz.`);
+      }
+    }
+
+    if (anyStalled && !failoverInProgress) {
+      triggerFailoverSequence().catch(err => {
+        logger.error(`[Failover Hatası] ${err && err.stack ? err.stack : err}`);
+        failoverInProgress = false;
+      });
+    }
+  }, STALL_CHECK_INTERVAL_MS);
+  logger.info("[Failover] Pose izleme döngüsü başlatıldı.");
+}
+
+function stopStallWatcher() {
+  if (stallCheckIntervalHandle) {
+    clearInterval(stallCheckIntervalHandle);
+    stallCheckIntervalHandle = null;
+  }
+  poseTracker.clear();
+}
+
+// Ana hesabı geçici düşürüp yedek hesabı (kullaniciadi1) devreye alan, izlenen
+// kazıcı minyonlar tekrar hareket edene kadar bekleyen, sonra ana hesabı
+// yeniden bağlayan tam akış.
+async function triggerFailoverSequence() {
+  if (failoverInProgress) return;
+  failoverInProgress = true;
+  failoverModeActive = true;
+
+  const mainUsername = config["bot-account"]["username"];
+  const backupUsername = `${mainUsername}1`;
+
+  logger.warn(`[Failover] İzlenen kazıcı(lar) durdu. Ana hesap (${mainUsername}) geçici olarak düşürülüp yedek hesap (${backupUsername}) devreye alınıyor.`);
+
+  manualStopRequested = true; // mevcut auto-reconnect mantığını geçici olarak devre dışı bırakır
+  stopPeriodicHomeChecks();
+  safeDestroyAllConnections();
+
+  try {
+    await runBackupAccountAndWaitForRecovery(backupUsername);
+  } catch (err) {
+    logger.error(`[Failover] Yedek hesap akışında hata: ${err && err.stack ? err.stack : err}`);
+  }
+
+  logger.info(`[Failover] İzlenen kazıcı(lar) tekrar aktif (ya da azami bekleme süresi doldu). Ana hesap (${mainUsername}) yeniden bağlanıyor.`);
+  manualStopRequested = false;
+  failoverModeActive = false;
+  poseTracker.clear();
+  createBot();
+
+  failoverInProgress = false;
+}
+
+// Yedek hesapla ayrı bir mineflayer bot'u başlatır: /login, /skyblock, /is go
+// atar (ana hesaptaki ile AYNI gecikme süreleriyle), sonra izlenen minyonların
+// hareketine bakar. Hareket geri gelince bağlantıyı kapatıp resolve eder.
+function runBackupAccountAndWaitForRecovery(backupUsername) {
+  return new Promise((resolve) => {
+    const backupPoseTracker = new Map();
+    let recheckHandle = null;
+    let safetyTimeoutHandle = null;
+    let spawnTimeoutHandle = null;
+    let finished = false;
+
+    const finish = () => {
+      if (finished) return;
+      finished = true;
+      if (recheckHandle) clearInterval(recheckHandle);
+      if (safetyTimeoutHandle) clearTimeout(safetyTimeoutHandle);
+      if (spawnTimeoutHandle) clearTimeout(spawnTimeoutHandle);
+      try {
+        if (failoverBot) {
+          failoverBot.removeAllListeners();
+          failoverBot.quit();
+        }
+      } catch (e) {}
+      failoverBot = null;
+      resolve();
+    };
+
+    try {
+      failoverBot = mineflayer.createBot({
+        username: backupUsername,
+        auth: config["bot-account"]["type"],
+        host: config.server.ip,
+        port: config.server.port,
+        version: config.server.version,
+      });
+    } catch (err) {
+      logger.error(`[Failover - Yedek Hesap] Bot oluşturulamadı: ${err && err.message ? err.message : err}`);
+      finish();
+      return;
+    }
+
+    spawnTimeoutHandle = setTimeout(() => {
+      logger.error(`[Failover - Yedek Hesap] ${backupUsername} ${formatDurationMs(FAILOVER_SPAWN_TIMEOUT_MS)} içinde spawn olamadı, vazgeçiliyor (bir sonraki kontrolde tekrar denenecek).`);
+      finish();
+    }, FAILOVER_SPAWN_TIMEOUT_MS);
+
+    failoverBot.once("spawn", () => {
+      clearTimeout(spawnTimeoutHandle);
+      logger.info(`[Failover - Yedek Hesap] ${backupUsername} sunucuya girdi.`);
+
+      setTimeout(() => {
+        try { failoverBot.chat(`/login ${config.utils["auto-auth"].password}`); } catch (e) {}
+        logger.info(`[Failover - Yedek Hesap] ${backupUsername} Login komutu kullanıldı.`);
+      }, FAILOVER_LOGIN_DELAY_MS);
+
+      setTimeout(() => {
+        try { failoverBot.chat("/skyblock"); } catch (e) {}
+        logger.info(`[Failover - Yedek Hesap] ${backupUsername} Skyblock'a ışınlanma komutu kullanıldı.`);
+      }, FAILOVER_SKYBLOCK_DELAY_MS);
+
+      setTimeout(() => {
+        try { failoverBot.chat(GO_ISLAND_COMMAND); } catch (e) {}
+        logger.info(`[Failover - Yedek Hesap] ${GO_ISLAND_COMMAND} gönderildi, izlenen minyonların tekrar hareket etmesi bekleniyor...`);
+      }, FAILOVER_ISGO_DELAY_MS);
+
+      // Adaya varış + izleme başlatma
+      setTimeout(() => {
+        recheckHandle = setInterval(() => {
+          try {
+            const arr = Object.values(failoverBot.entities || {});
+            let allRecovered = true;
+            let sawAnyWatched = false;
+
+            for (const e of arr) {
+              if (!isWatchedKaziciEntity(e)) continue;
+
+              sawAnyWatched = true;
+              const poseKey = getPoseKey(e);
+              const prev = backupPoseTracker.get(e.id);
+
+              if (!prev) {
+                backupPoseTracker.set(e.id, { poseKey, lastChangeAt: Date.now() });
+                allRecovered = false; // henüz yeterince veri yok, bir tur daha bekle
+                continue;
+              }
+
+              if (prev.poseKey !== poseKey) {
+                prev.poseKey = poseKey;
+                prev.lastChangeAt = Date.now();
+              } else if (Date.now() - prev.lastChangeAt < STALL_TIMEOUT_MS) {
+                // son 1 dk içinde bir değişiklik olmuş demek ki hareket ediyor
+              } else {
+                allRecovered = false;
+              }
+            }
+
+            if (sawAnyWatched && allRecovered) {
+              logger.info("[Failover - Yedek Hesap] İzlenen minyonlar tekrar hareket ediyor. Yedek hesaptan çıkılıyor.");
+              finish();
+            }
+          } catch (e) {}
+        }, FAILOVER_RECHECK_INTERVAL_MS);
+      }, FAILOVER_HOME_ARRIVAL_DELAY_MS + FAILOVER_ISGO_DELAY_MS);
+    });
+
+    failoverBot.on("error", (err) => {
+      logger.error(`[Failover - Yedek Hesap] Hata: ${err && err.message ? err.message : err}`);
+    });
+
+    failoverBot.on("kicked", (reason) => {
+      logger.warn(`[Failover - Yedek Hesap] Sunucudan atıldı: ${util.inspect(reason)}`);
+      finish();
+    });
+
+    failoverBot.on("end", () => {
+      if (!finished) {
+        logger.warn("[Failover - Yedek Hesap] Bağlantı beklenmedik şekilde koptu.");
+        finish();
+      }
+    });
+
+    // Güvenlik: sonsuza kadar beklemesin
+    safetyTimeoutHandle = setTimeout(() => {
+      logger.warn(`[Failover - Yedek Hesap] Azami bekleme süresi (${formatDurationMs(FAILOVER_MAX_WAIT_MS)}) doldu, ana hesaba geri dönülüyor.`);
+      finish();
+    }, FAILOVER_MAX_WAIT_MS);
+  });
+}
+
 async function createBot() {
   if (isConnecting) {
     logger.warn("[Sistem] Zaten aktif bir bağlantı süreci yürütülüyor. Mükerrer istek engellendi.");
@@ -765,7 +1060,36 @@ async function createBot() {
     }
   }
 
-  // --- DİNAMİK PLANLAMA MOTORU (SADECE BESLEYİCİ İÇİN) ---
+  async function antiBotMove() {
+    if (!bot || !botIsReady) return;
+    try {
+    const moves = ['forward', 'left', 'right', 'jump'];
+  
+    const moveCount = Math.floor(Math.random() * 4) + 2; // 2-5 hareket
+  
+    for (let i = 0; i < moveCount; i++) {
+      const move = moves[Math.floor(Math.random() * moves.length)];
+      const duration = 150 + Math.floor(Math.random() * 500);
+  
+      bot.setControlState(move, true);
+      await new Promise(r => setTimeout(r, duration));
+      bot.setControlState(move, false);
+  
+      await new Promise(r => setTimeout(r, 100 + Math.random() * 300));
+      
+    }
+  
+    // Rastgele kafa hareketi
+    await bot.look(
+      bot.entity.yaw + ((Math.random() - 0.5) * 1.5),
+      bot.entity.pitch + ((Math.random() - 0.5) * 0.3),
+      true
+    );
+  } catch (err) {
+    logger.error(`[antiBotMove Hatası] Komut gönderilemedi: ${err && err.message ? err.message : err}`);
+  }
+  };
+
   function scheduleNextCheck(delayMs) {
     if (periodicTimeoutHandle) {
       clearTimeout(periodicTimeoutHandle);
@@ -782,9 +1106,6 @@ async function createBot() {
         await goToIsland();
         await new Promise(r => setTimeout(r, HOME_ARRIVAL_DELAY_MS));
         await scanAndFeed();
-        // NOT: Kazıcı ve çiftçi toplama artık BURADA çağrılmıyor. Her ikisi de
-        // besleyiciden tamamen bağımsız kendi zamanlayıcılarında çalışır
-        // (bkz. startKaziciPeriodic / startCiftciPeriodic).
       } catch (err) {
         logger.error(`[Planlayıcı Hatası] Periyodik döngüde beklenmeyen hata: ${err && err.stack ? err.stack : err}`);
         try { scheduleNextCheck(DEFAULT_CHECK_INTERVAL_MS); } catch (e2) {}
@@ -806,7 +1127,6 @@ function activateEntityAtNoLook(entity, position) {
   });
 }
 
-  // --- BESLEYİCİ (scanAndFeedCore = asıl mantık, kilit içermez) ---
   async function scanAndFeedCore() {
     if (!bot || !botIsReady) return;
     if (!guiMutex.isLocked()) {
@@ -919,15 +1239,9 @@ function activateEntityAtNoLook(entity, position) {
     });
   }
 
-  // Kilit meşgulken (kazıcı/çiftçi turu sürerken) besleyicinin bu kısa süreliğine
-  // beklemesi için yeniden deneme aralığı. Gerçek besleme zamanlamasını bozmaz,
-  // sadece kilidin boşalmasını birkaç kez kontrol eder.
   const FEED_LOCK_RETRY_DELAY_MS = 15 * 1000;
-  const FEED_LOCK_MAX_RETRIES = 8; // 8 x 15sn = 2 dk boyunca dener
+  const FEED_LOCK_MAX_RETRIES = 8;
 
-  // Periyodik (otomatik) kullanım: kilit doluysa hemen pes etmez, kısa aralıklarla
-  // yeniden dener (kazıcı/çiftçi turu birkaç saniye içinde biter). Sonuçta kilidi
-  // hâlâ alamazsa, döngünün tamamen ölmemesi için normal aralıkla tekrar planlar.
   async function scanAndFeed(retryCount) {
     retryCount = retryCount || 0;
     if (!guiMutex.tryAcquire()) {
@@ -950,8 +1264,6 @@ function activateEntityAtNoLook(entity, position) {
     }
   }
 
-  // Manuel (Express panelinden) kullanım: kilit doluysa ÖNCELİKLİ olarak kuyruğa
-  // girer, mevcut işlem bitince hemen devralır.
   async function scanAndFeedManual() {
     logger.info("[Besleyici - Manuel] Panelden istek geldi, sırasını bekliyor (öncelikli)...");
     await guiMutex.acquire();
@@ -965,7 +1277,6 @@ function activateEntityAtNoLook(entity, position) {
     }
   }
 
-  // --- KAZICI MİNYON DEPO AKTARIMI ---
   async function activateEntityAndAwaitWindow(entity, labelForLogs) {
     if (!bot || !botIsReady || !entity || !entity.position) {
       return { success: false, reason: "Bot veya entity hazır değil" };
@@ -1063,8 +1374,6 @@ function activateEntityAtNoLook(entity, position) {
     return matches;
   }
 
-  // scanAndCollectMinersCore: asıl mantık, kilit İÇERMEZ (dışarıdan kilitlenmiş
-  // olarak çağrılması beklenir).
   async function scanAndCollectMinersCore() {
     if (!bot || !botIsReady) return;
     if (!guiMutex.isLocked()) {
@@ -1115,7 +1424,6 @@ function activateEntityAtNoLook(entity, position) {
     logger.info(`[${currentBotUsername}] Kazıcı minyon depo aktarım turu tamamlandı.`);
   }
 
-  // Tekil/periyodik kullanım (kendi başına çağrılırsa kilidi kendisi alır)
   async function scanAndCollectMiners() {
     if (!guiMutex.tryAcquire()) {
       logger.warn("[Kazıcı Toplama] Zaten bir GUI işlemi sürüyor (besleyici/kazıcı/çiftçi). Bu tur atlanıyor.");
@@ -1130,7 +1438,6 @@ function activateEntityAtNoLook(entity, position) {
     }
   }
 
-  // Manuel (Express panelinden) kullanım: öncelikli kuyruk.
   async function scanAndCollectMinersManual() {
     logger.info("[Kazıcı Toplama - Manuel] Panelden istek geldi, sırasını bekliyor (öncelikli)...");
     await guiMutex.acquire();
@@ -1145,11 +1452,6 @@ function activateEntityAtNoLook(entity, position) {
     }
   }
 
-  // --- ÇİFTÇİ (HEPSİNİ SAT) MENÜSÜ ---
-  // openCiftciAndSellAllCore: asıl mantık, kilit İÇERMEZ (dışarıdan kilitli çağrılır).
-  // NOT: Asıl "hepsini sat" tıklaması artık burada DEĞİL, windowOpen olayında,
-  // pencere açıldıktan CIFTCI_CLICK_DELAY_AFTER_OPEN_MS kadar bekledikten sonra
-  // ve CIFTCI_CLICK_REPEAT_COUNT kez tekrar tıklanarak yapılıyor (bkz. windowOpen).
   async function openCiftciAndSellAllCore() {
     if (!bot || !botIsReady) return;
     if (!guiMutex.isLocked()) {
@@ -1165,10 +1467,6 @@ function activateEntityAtNoLook(entity, position) {
       await new Promise(r => setTimeout(r, 300));
     }
 
-    // Komut yalnızca BİR KEZ gönderilir. Eskiden birkaç saniyede bir tekrar
-    // gönderiliyordu; bu, sunucunun aynı komutu art arda işleyip menüyü birden
-    // fazla kez açmasına (ve dolayısıyla tıklama/satış tutarsızlıklarına) yol
-    // açabiliyordu. Şimdi sadece pencerenin açılmasını timeout süresince bekliyoruz.
     let timedOut = false;
 
     await new Promise((resolve) => {
@@ -1207,7 +1505,6 @@ function activateEntityAtNoLook(entity, position) {
     }
   }
 
-  // Tekil/periyodik kullanım.
   async function openCiftciAndSellAll() {
     if (!guiMutex.tryAcquire()) {
       logger.warn("[Çiftçi] Zaten bir GUI işlemi sürüyor (besleyici/kazıcı/çiftçi). Bu tur atlanıyor.");
@@ -1222,7 +1519,6 @@ function activateEntityAtNoLook(entity, position) {
     }
   }
 
-  // Manuel (Express panelinden) kullanım: öncelikli kuyruk.
   async function openCiftciAndSellAllManual() {
     logger.info("[Çiftçi - Manuel] Panelden istek geldi, sırasını bekliyor (öncelikli)...");
     await guiMutex.acquire();
@@ -1237,11 +1533,8 @@ function activateEntityAtNoLook(entity, position) {
     }
   }
 
-  // --- KAZICI BAĞIMSIZ PERİYODİK DÖNGÜ (5 dakikada bir) ---
-  // Besleyici ve çiftçi durumundan hiçbir şekilde etkilenmez. Sadece paylaşılan
-  // guiMutex ile çakışmayı önler; kilit doluysa bu turu sessizce atlar.
   function startKaziciPeriodic() {
-    if (kaziciIntervalHandle) return; // zaten çalışıyor
+    if (kaziciIntervalHandle) return;
 
     const runCycle = async () => {
       if (!bot || !botIsReady) return;
@@ -1272,9 +1565,8 @@ function activateEntityAtNoLook(entity, position) {
     logger.info(`[Kazıcı Periyodik] Bağımsız döngü başlatıldı (her ${formatDurationMs(KAZICI_CYCLE_INTERVAL_MS)}).`);
   }
 
-  // --- ÇİFTÇİ BAĞIMSIZ PERİYODİK DÖNGÜ (1 dakikada bir) ---
   function startCiftciPeriodic() {
-    if (ciftciIntervalHandle) return; // zaten çalışıyor
+    if (ciftciIntervalHandle) return;
 
     const runCycle = async () => {
       if (!bot || !botIsReady) return;
@@ -1314,17 +1606,16 @@ function activateEntityAtNoLook(entity, position) {
       botIsReady = true;
       botUptimeStart = Date.now();
 
-      // Express panelinin bu bot örneğine erişebilmesi için köprüyü doldur.
       botActions.scanAndFeedManual = scanAndFeedManual;
       botActions.scanAndCollectMinersManual = scanAndCollectMinersManual;
       botActions.openCiftciAndSellAllManual = openCiftciAndSellAllManual;
       botActions.goToIslandManual = goToIsland;
       botActions.sendSkyblockManual = sendSkyblockCommand;
+      botActions.antiBotMove = antiBotMove();
 
-      // Kazıcı ve Çiftçi bağımsız döngülerini başlat (birbirlerinden ve besleyiciden
-      // bağımsız zamanlayıcılar; sadece guiMutex ile çakışma önlenir).
       startKaziciPeriodic();
       startCiftciPeriodic();
+      startStallWatcher();
 
       if (config.utils && config.utils["auto-auth"] && config.utils["auto-auth"].enabled) {
         const password = config.utils["auto-auth"].password;
@@ -1351,7 +1642,6 @@ function activateEntityAtNoLook(entity, position) {
           }
         }, 7500);
 
-        // İlk çalıştırma: Girişten 12.5 saniye sonra ilk besleyici kontrolünü yap
         setSafeTimeout(async () => {
           if (!bot || !botIsReady) return;
           isMainCycleRunning = true;
@@ -1359,8 +1649,6 @@ function activateEntityAtNoLook(entity, position) {
             await goToIsland();
             await new Promise(r => setTimeout(r, HOME_ARRIVAL_DELAY_MS));
             await scanAndFeed();
-            // NOT: Kazıcı ve çiftçi toplama burada da çağrılmıyor; kendi bağımsız
-            // döngüleri zaten spawn olur olmaz başladı.
           } catch (err) {
             logger.error(`[Spawn Hatası] İlk kontrol döngüsünde beklenmeyen hata: ${err && err.stack ? err.stack : err}`);
             try { scheduleNextCheck(DEFAULT_CHECK_INTERVAL_MS); } catch (e2) {}
@@ -1374,6 +1662,14 @@ function activateEntityAtNoLook(entity, position) {
     }
   });
 
+  bot.on("entityMoved", (entity) => {
+    try { trackKaziciPoseIfWatched(entity); } catch (e) {}
+  });
+
+  bot.on("entitySpawn", (entity) => {
+    try { trackKaziciPoseIfWatched(entity); } catch (e) {}
+  });
+
   bot.on("windowOpen", async (window) => {
     if (!bot) return;
     try {
@@ -1403,11 +1699,6 @@ function activateEntityAtNoLook(entity, position) {
         try { bot.closeWindow(window); } catch(e){}
 
       } else if (isCiftciWindow) {
-        // Pencere açılır açılmaz hemen tıklamak yerine, sunucunun menü içeriğini
-        // (lore/slot verisini) tam yerleştirmesi için önce kısa bir süre beklenir,
-        // ardından "hepsini sat" slotuna birkaç kez art arda tıklanır. Bu, bazen
-        // satışın hiç gerçekleşmemesi sorununu (erken tıklama nedeniyle sunucunun
-        // isteği görmezden gelmesi) engellemek içindir.
         try {
           logger.info(`[${currentBotUsername}] Çiftçi (Hepsini Sat) menüsü açıldı. ${formatDurationMs(CIFTCI_CLICK_DELAY_AFTER_OPEN_MS)} bekleniyor, sonra slot ${CIFTCI_SELL_ALL_SLOT}'e ${CIFTCI_CLICK_REPEAT_COUNT} kez tıklanacak...`);
           await new Promise(r => setTimeout(r, CIFTCI_CLICK_DELAY_AFTER_OPEN_MS));
@@ -1492,6 +1783,7 @@ function activateEntityAtNoLook(entity, position) {
     try {
       logger.warn(manualStopRequested ? "Bağlantı koptu. Manuel durdurma istendiği için yeniden bağlanılmayacak." : "Bağlantı koptu. Tüm zamanlayıcılar sıfırlanıyor ve YENİDEN BAĞLANMA SÜRECİ BAŞLIYOR...");
       stopPeriodicHomeChecks();
+      stopStallWatcher();
       lastCheckAtMs = null;
       botIsReady = false;
       baglantiTuru = "Yok";
@@ -1778,7 +2070,8 @@ app.get("/status", (req, res) => {
     next_ciftci_sell: nextCiftciTimeStr,
     gui_lock_busy: guiMutex.isLocked(),
     manually_stopped: manualStopRequested,
-    is_connecting: isConnecting
+    is_connecting: isConnecting,
+    failover_mode_active: failoverModeActive
   });
 });
 
@@ -1801,12 +2094,6 @@ app.get("/bot/restart", (req, res) => {
   res.send({ success: true, message: "Bot tamamen sıfırdan yeniden başlatılıyor (soket/SSH dahil)." });
 });
 
-// --- YENİ: MANUEL GUI/AKSİYON TETİKLEME ENDPOINT'LERİ ---
-// Bu endpoint'ler istek geldiği anda hemen yanıt döner (fire-and-forget), asıl
-// işlem arka planda ÖNCELİKLİ olarak (guiMutex.acquire ile kuyruğa öncelikli
-// girerek) yürütülür. O sırada otomatik bir döngü (besleyici, kazıcı veya çiftçi)
-// zaten çalışıyorsa, önce o tamamlanır, HEMEN ARDINDAN bu istek işlenir.
-
 app.get("/bot/kazici-kontrol", (req, res) => {
   if (!bot || !botIsReady || !botActions.scanAndCollectMinersManual) {
     return res.status(503).send({ success: false, message: "Bot hazır değil." });
@@ -1847,6 +2134,40 @@ app.get("/bot/is-go", (req, res) => {
   res.send({ success: true, message: `${GO_ISLAND_COMMAND} komutu gönderildi.` });
 });
 
+app.get("/bot/sendmsg", (req, res) => {
+  if (!bot || !botIsReady) {
+    return res.status(503).send({ success: false, message: "Bot hazır değil." });
+  }
+
+  const message = req.query.message;
+  if (!message || typeof message !== "string" || message.trim().length === 0) {
+    return res.status(400).send({ success: false, message: "message query parametresi zorunlu." });
+  }
+
+  try {
+    bot.chat(message);
+    logger.info(`[${bot.username}] /sendmsg üzerinden chat mesajı gönderildi: ${message}`);
+    res.send({ success: true, message: "Mesaj gönderildi.", sent: message });
+  } catch (err) {
+    logger.error(`[/bot/sendmsg Hatası] ${err && err.message ? err.message : err}`);
+    res.status(500).send({ success: false, message: "Mesaj gönderilirken hata oluştu." });
+  }
+});
+
+app.get("/bot/antibotmove", (req, res) => {
+  if (!bot || !botIsReady) {
+    return res.status(503).send({ success: false, message: "Bot hazır değil." });
+  }
+
+  try {
+    botActions.antiBotMove().catch(e => logger.error(`[/bot/antibotmove Hatası] ${e && e.stack ? e.stack : e}`));
+    res.send({ success: true, message: "Anti Bot Yürüyüşü Yapıldı."});
+  } catch (err) {
+    logger.error(`[/bot/antibotmove Hatası] ${err && err.message ? err.message : err}`);
+    res.status(500).send({ success: false, message: "Anti Bot Move sırasında hata oluştu." });
+  }
+});
+
 app.get("/", (req, res) => res.send("Bot Aktif"));
 
 app.get("/messages", (req, res) => {