Update bot.js

bot.js

@@ -18,8 +18,8 @@ const https = require('https');
 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 DEFAULT_CHECK_INTERVAL_MS = 10 * 60 * 1000; // Varsayılan 10 dk
+const FULL_FEED_COOLDOWN_MS = 50 * 60 * 1000;     // Besleme sonrası sabit 50 dk
 const GO_HOME_COMMAND = "/home";
 const RETURN_ISLAND_COMMAND = "/is home";
 const BESLEYICI_NAMES = (config.utils && config.utils["besleyici-names"]) || ["Besleyici", "ʙᴇsʟᴇʏiᴄi"];
@@ -46,12 +46,16 @@ let windowOpenResolvers = [];
 let botUptimeStart = null;         
 let lastFullFeedTimeStr = "Henüz besleme yapılmadı"; 
 let lastCheckTimeStr = "Henüz kontrol yapılmadı";    
+let nextScheduledCheckTimeStr = "Botun spawn olması bekleniyor...";
 
 // --- DİNAMİK IP VE KONUM BİLGİLERİ ---
 let activeConnectionIp = "Bilinmiyor";
 let activeConnectionLocation = "Bilinmiyor";
 let localExternalIp = "Bilinmiyor";
 
+// --- DİNAMİK ZAMANLAYICI KONTROLÜ ---
+let periodicTimeoutHandle = null;
+
 function getIpLocation(ip) {
   return new Promise((resolve) => {
     if (!ip || ip === "Bilinmiyor" || ip.startsWith("127.")) {
@@ -62,7 +66,7 @@ function getIpLocation(ip) {
       res.on('data', chunk => data += chunk);
       res.on('end', () => {
         try {
-          const geo = JSON.parse(body || data);
+          const geo = JSON.parse(data);
           if (geo && geo.status === 'success') {
             resolve(`${geo.country} / ${geo.city}`);
           } else {
@@ -322,7 +326,6 @@ async function createBot() {
   bot.loadPlugin(pathfinder);
 
   let lastFullFeedAt = 0;
-  let periodicHandle = null;
   let activeTimeouts = [];
 
   function setSafeTimeout(fn, delay) {
@@ -332,8 +335,10 @@ async function createBot() {
   }
 
   function stopPeriodicHomeChecks() {
-    if (periodicHandle) clearInterval(periodicHandle);
-    periodicHandle = null;
+    if (periodicTimeoutHandle) {
+      clearTimeout(periodicTimeoutHandle);
+      periodicTimeoutHandle = null;
+    }
     activeTimeouts.forEach(t => clearTimeout(t));
     activeTimeouts = [];
   }
@@ -345,6 +350,11 @@ async function createBot() {
     return `${dateStr} - ${timeStr}`;
   }
 
+  function getFutureDateTimeString(delayMs) {
+    const future = new Date(Date.now() + delayMs);
+    return future.toLocaleTimeString('tr-TR');
+  }
+
   function stripColorCodes(s) {
     if (!s || typeof s !== "string") return s;
     return s.replace(/§[0-9a-fk-or]/gi, "");
@@ -475,9 +485,35 @@ async function createBot() {
     bot.chat(RETURN_ISLAND_COMMAND);
   }
 
+  // --- DİNAMİK PLANLAMA MOTORU ---
+  function scheduleNextCheck(delayMs) {
+    if (periodicTimeoutHandle) {
+      clearTimeout(periodicTimeoutHandle);
+    }
+    
+    nextScheduledCheckTimeStr = `${getFutureDateTimeString(delayMs)} (${Math.round(delayMs / 60 / 1000)} dk sonra)`;
+    logger.info(`[Planlayıcı] Bir sonraki döngü planlandı. Zaman: ${nextScheduledCheckTimeStr}`);
+
+    periodicTimeoutHandle = setTimeout(async () => {
+      if (!bot || !botIsReady) 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();
+    }, delayMs);
+  }
+
   async function scanAndFeed() {
     if (!bot || !botIsReady) return;
-    if (Date.now() < (lastFullFeedAt + FULL_FEED_COOLDOWN_MS)) return;
+    
+    // Sunucu lagı yüzünden döngü üst üste tetiklenirse koruma
+    if (Date.now() < (lastFullFeedAt + 30000)) {
+      logger.warn("[Planlayıcı] Çok kısa süre önce işlem yapıldı. Güvenlik kilidi devrede.");
+      return;
+    }
+
     const arr = Object.values(bot.entities);
     let best = null;
 
@@ -500,6 +536,8 @@ async function createBot() {
     if (!best) {
       logger.info(`[${currentBotUsername}] /home sonrası tarama: besleyici minyon bulunamadı.`);
       bot.chat("/skyblock");
+      // Okuyamadığımız için 10 dakika sonra tekrar deneyecek şekilde planla
+      scheduleNextCheck(DEFAULT_CHECK_INTERVAL_MS);
       return;
     }
 
@@ -509,6 +547,7 @@ async function createBot() {
     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}).`);
+      scheduleNextCheck(DEFAULT_CHECK_INTERVAL_MS);
       return;
     }
 
@@ -544,6 +583,7 @@ async function createBot() {
           if (Date.now() > endTime) {
             logger.warn(`[Tıklama Sistemi] ${WINDOW_OPEN_TIMEOUT_MS} ms doldu ancak menü sunucudan gelmedi. Pes ediliyor.`);
             cleanFinish();
+            scheduleNextCheck(DEFAULT_CHECK_INTERVAL_MS);
             return;
           }
 
@@ -588,6 +628,7 @@ async function createBot() {
         }
       }, 7500);
 
+      // İlk çalıştırma: Girişten 12.5 saniye sonra ilk kontrolü yap
       setSafeTimeout(async () => {
         if (!bot || !botIsReady) return;
         await goHome();
@@ -595,21 +636,11 @@ async function createBot() {
         await scanAndFeed();
         await new Promise(r => setTimeout(r, POST_ACTION_DELAY_MS));
         await returnIsland();
-        
-        periodicHandle = setInterval(async () => {
-          if (!bot || !botIsReady) return;
-          if (Date.now() < (lastFullFeedAt + FULL_FEED_COOLDOWN_MS)) return;
-          await goHome();
-          await new Promise(r => setTimeout(r, HOME_ARRIVAL_DELAY_MS));
-          await scanAndFeed();
-          await new Promise(r => setTimeout(r, POST_ACTION_DELAY_MS));
-          await returnIsland();
-        }, PERIODIC_CHECK_INTERVAL_MS);
       }, 12500);
     }
   });
 
-  bot.on("windowOpen", (window) => {
+  bot.on("windowOpen", async (window) => {
     if (!bot) return;
     const title = parseWindowTitleToString(window.title).toLowerCase();
     if (!title.includes("besleyici") && !parseWindowTitleToString(window.title).includes("ʙᴇsʟᴇʏiᴄi")) {
@@ -625,19 +656,43 @@ async function createBot() {
       lastCheckTimeStr = `${currentStamp} (Okunan Can: ${can})`;
 
       if (can <= 2) {
-        try { bot.clickWindow(36, 0, 0); } catch(e){}
-        lastFullFeedAt = Date.now();
-        lastFullFeedTimeStr = `${currentStamp} (Minyon canı ${can} iken başarıyla beslendi)`; 
-        logger.info(`[${currentBotUsername}] Minyon canı ${can} olduğu için beslendi. 50dk bekleme aktif.`);
-      } else if (can >= 10) {
-        lastFullFeedAt = Date.now();
-        lastFullFeedTimeStr = `${currentStamp} (Canı ${can} olduğu için besleme gerekmedi)`; 
-        logger.info(`[${currentBotUsername}] Minyon canı ${can} (tam). 50dk bekleme aktif.`);
+        // CAN 2 VEYA ALTINDA: BESLE VE SABİT 50 DK PLANLA
+        try { 
+          logger.info(`[${currentBotUsername}] Minyon canı ${can} olduğu için besleniyor...`);
+          await bot.clickWindow(36, 0, 0); 
+          lastFullFeedAt = Date.now();
+          lastFullFeedTimeStr = `${currentStamp} (Minyon canı ${can} iken başarıyla beslendi)`; 
+          logger.info(`[${currentBotUsername}] Tıklama onaylandı. Fixed 50dk bekleme aktif.`);
+        } catch(e) {
+          logger.error(`[Arayüz Hatası] Tıklama işlemi sunucu tarafından onaylanmadı: ${e.message}`);
+        }
+        scheduleNextCheck(FULL_FEED_COOLDOWN_MS);
+
       } else {
-        logger.info(`[${currentBotUsername}] Minyon canı ${can} olduğu için yenilenmedi.`);
+        // CAN 3 VEYA DAHA YÜKSEK: DİNAMİK PLANLAMA YAP
+        // Formül: (Can - 2) * 5 dakika. Maksimum 50 dakika.
+        let calculatedMinutes = (can - 2) * 5;
+        if (calculatedMinutes > 50) calculatedMinutes = 50;
+        if (calculatedMinutes < 10) calculatedMinutes = 10;
+        
+        const dynamicDelayMs = calculatedMinutes * 60 * 1000;
+        
+        logger.info(`[${currentBotUsername}] Minyon canı ${can} olarak okundu. Canın 2'ye düşmesi için ${calculatedMinutes} dakika beklenecek.`);
+        
+        if (can >= 10) {
+          lastFullFeedTimeStr = `${currentStamp} (Canı ${can} olduğu için besleme gerekmedi)`;
+        }
+        
+        scheduleNextCheck(dynamicDelayMs);
       }
+    } else {
+      // Can okunamadıysa güvenlik amacıyla 10 dk sonra tekrar kontrol et
+      logger.warn(`[${currentBotUsername}] Menü açıldı ama can okunamadı. 10 dk sonra tekrar denenecek.`);
+      scheduleNextCheck(DEFAULT_CHECK_INTERVAL_MS);
     }
-    setSafeTimeout(() => { if (bot) { try { bot.closeWindow(window); } catch(e){} } }, 500);
+
+    try { bot.closeWindow(window); } catch(e){}
+
     while (windowOpenResolvers.length > 0) {
       const fn = windowOpenResolvers.shift();
       if (typeof fn === 'function') fn();
@@ -653,6 +708,7 @@ async function createBot() {
     isListeningChat = false;
     activeConnectionIp = "Bilinmiyor";
     activeConnectionLocation = "Bilinmiyor";
+    nextScheduledCheckTimeStr = "Bağlantı koptuğu için planlama iptal edildi.";
     
     safeDestroyAllConnections(); 
 
@@ -769,7 +825,8 @@ app.get("/status", (req, res) => {
     connection_geo: activeConnectionLocation,
     bot_uptime: uptimeString,
     last_minyon_check: lastCheckTimeStr,     
-    last_minyon_feed: lastFullFeedTimeStr    
+    last_minyon_feed: lastFullFeedTimeStr,
+    next_scheduled_check: nextScheduledCheckTimeStr // Panel için sonraki kontrol saati
   });
 });