Update bot/proxy_manager.py

bot/proxy_manager.py

@@ -4,6 +4,7 @@ import asyncio
 import aiohttp
 from utils.logger import log
 from bot.database import db
+from bot.state import state
 
 class ProxyManager:
     def __init__(self):
@@ -123,17 +124,26 @@ class ProxyManager:
     def handle_runtime_routing_fault(self, dead_hostname: str):
         """
         Executes an instant, hot-swap redirection sequence.
-        Rotates out a failing proxy from the pool path dynamically.
+        Rotates out a failing proxy from the pool path dynamically, avoiding active locks.
         """
         log(f"🛡️ Dynamic Routing Fault Caught on route: {dead_hostname}")
         best_nodes = self.get_best_proxies(len(self.proxies))
+        allocated_proxies = state.get("allocated_proxies", set())
         
         fallback_node = None
+        # Priority 1: Find an alive proxy that is not currently locked by another camper thread
         for p in best_nodes:
-            if p["hostname"] != dead_hostname:
+            if p["hostname"] != dead_hostname and p["hostname"] not in allocated_proxies:
                 fallback_node = p
                 break
                 
+        # Priority 2: Fallback to any unlocked or available alive node if allocation limits are saturated
+        if not fallback_node:
+            for p in best_nodes:
+                if p["hostname"] != dead_hostname:
+                    fallback_node = p
+                    break
+                
         if fallback_node:
             log(f"🔄 Hot-Swap Target Selected: {fallback_node['hostname']} ({fallback_node['ping']}ms)")
             return {