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,16 @@ 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,
+  sendMoneyToNick: 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 +274,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 +1061,119 @@ async function createBot() {
     }
   }
 
-  // --- DİNAMİK PLANLAMA MOTORU (SADECE BESLEYİCİ İÇİN) ---
+  // --- SENDMONEY: /money oku, bakiyeden 1000 eksiğini ilgili nick'e /pay ile gönder ---
+  const MONEY_BALANCE_REGEX = /bakiyen:\s*([\d.,]+)\s*TL/i;
+  const MONEY_RESPONSE_TIMEOUT_MS = 8000;
+
+  function parseBalanceToAdjustedAmount(rawBalanceStr) {
+    // "444,626.89" -> virgülleri kaldır -> "444626.89" -> noktadan öncesini al -> "444626"
+    const noCommas = rawBalanceStr.replace(/,/g, "");
+    const beforeDot = noCommas.split(".")[0];
+    const intValue = parseInt(beforeDot, 10);
+    if (isNaN(intValue)) return null;
+    return intValue - 1000;
+  }
+
+  async function sendMoneyToNick(nick) {
+    if (!bot || !botIsReady) {
+      return { success: false, message: "Bot hazır değil." };
+    }
+    if (!nick || typeof nick !== "string" || nick.trim().length === 0) {
+      return { success: false, message: "nick parametresi zorunlu." };
+    }
+
+    return new Promise((resolve) => {
+      let finished = false;
+      let timeoutHandle = null;
+
+      const cleanup = () => {
+        if (finished) return;
+        finished = true;
+        clearTimeout(timeoutHandle);
+        bot.removeListener('message', onMessage);
+      };
+
+      const onMessage = (jsonMsg) => {
+        try {
+          const chatMessage = bot.chat.ChatMessage ? new bot.chat.ChatMessage(jsonMsg) : jsonMsg;
+          const text = typeof chatMessage.toString === 'function' ? chatMessage.toString() : String(jsonMsg);
+          const plain = stripColorCodes(text);
+
+          const match = plain.match(MONEY_BALANCE_REGEX);
+          if (match) {
+            const adjusted = parseBalanceToAdjustedAmount(match[1]);
+            cleanup();
+
+            if (adjusted == null) {
+              logger.error(`[Sendmoney] Bakiye ayrıştırılamadı: "${plain}"`);
+              resolve({ success: false, message: "Bakiye mesajı ayrıştırılamadı." });
+              return;
+            }
+
+            try {
+              const payCommand = `/pay ${nick} ${adjusted}`;
+              bot.chat(payCommand);
+              logger.info(`[Sendmoney] Bakiye okundu: ${match[1]} -> Gönderilecek: ${adjusted}. Komut: ${payCommand}`);
+              resolve({ success: true, message: "Para gönderildi.", balance_raw: match[1], amount_sent: adjusted, nick });
+            } catch (err) {
+              logger.error(`[Sendmoney] /pay komutu gönderilemedi: ${err && err.message ? err.message : err}`);
+              resolve({ success: false, message: "/pay komutu gönderilirken hata oluştu." });
+            }
+          }
+        } catch (err) {
+          logger.error(`[Sendmoney] Mesaj işlenirken hata: ${err && err.message ? err.message : err}`);
+        }
+      };
+
+      bot.on('message', onMessage);
+
+      timeoutHandle = setTimeout(() => {
+        cleanup();
+        logger.warn(`[Sendmoney] ${formatDurationMs(MONEY_RESPONSE_TIMEOUT_MS)} içinde bakiye mesajı gelmedi.`);
+        resolve({ success: false, message: "Zaman aşımı: bakiye mesajı alınamadı." });
+      }, MONEY_RESPONSE_TIMEOUT_MS);
+
+      try {
+        bot.chat("/money");
+        logger.info(`[Sendmoney] /money komutu gönderildi, bakiye mesajı bekleniyor...`);
+      } catch (err) {
+        cleanup();
+        logger.error(`[Sendmoney] /money komutu gönderilemedi: ${err && err.message ? err.message : err}`);
+        resolve({ success: false, message: "/money komutu gönderilirken hata oluştu." });
+      }
+    });
+  }
+
+  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 +1190,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 +1211,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 +1323,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 +1348,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 +1361,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 +1458,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 +1508,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 +1522,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 +1536,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 +1551,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 +1589,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 +1603,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 +1617,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 +1649,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 +1690,17 @@ 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;
+      botActions.sendMoneyToNick = sendMoneyToNick;
 
-      // 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 +1727,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 +1734,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 +1747,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 +1784,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 +1868,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";
@@ -1508,6 +1885,8 @@ function activateEntityAtNoLook(entity, position) {
       botActions.openCiftciAndSellAllManual = null;
       botActions.goToIslandManual = null;
       botActions.sendSkyblockManual = null;
+      botActions.antiBotMove = null;
+      botActions.sendMoneyToNick = null;
 
       safeDestroyAllConnections();
 
@@ -1778,7 +2157,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 +2181,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 +2221,64 @@ 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("/bot/sendmoney", (req, res) => {
+  if (!bot || !botIsReady || !botActions.sendMoneyToNick) {
+    return res.status(503).send({ success: false, message: "Bot hazır değil." });
+  }
+
+  const nick = req.query.nick;
+  if (!nick || typeof nick !== "string" || nick.trim().length === 0) {
+    return res.status(400).send({ success: false, message: "nick query parametresi zorunlu." });
+  }
+
+  botActions.sendMoneyToNick(nick)
+    .then((result) => {
+      if (result.success) {
+        res.send(result);
+      } else {
+        res.status(500).send(result);
+      }
+    })
+    .catch((err) => {
+      logger.error(`[/bot/sendmoney Hatası] ${err && err.stack ? err.stack : err}`);
+      res.status(500).send({ success: false, message: "Beklenmeyen bir hata oluştu." });
+    });
+});
+
 app.get("/", (req, res) => res.send("Bot Aktif"));
 
 app.get("/messages", (req, res) => {
@@ -2082,4 +2514,4 @@ process.stderr.write = function (chunk, encoding, callback) {
     return true;
   }
   return originalStderrWrite.apply(process.stderr, arguments);
-};
+};