proxy pool race condition fixed

freeplay2api.py

@@ -167,7 +167,7 @@ class FreeplayClient:
             "referer": "https://app.freeplay.ai/signup",
         }
 
-        max_retries = 5
+        max_retries = 10
         for attempt in range(max_retries):
             proxy_info = None
             try:
@@ -224,8 +224,6 @@ class FreeplayClient:
             except Exception as e:
                 logging.error(f"An unexpected error occurred during registration on attempt {attempt + 1}/{max_retries}: {e}. Retrying...")
 
-            time.sleep(1)
-        
         logging.error("Failed to register a new account after multiple retries.")
         return None
 
@@ -364,16 +362,17 @@ class KeyMaintainer(threading.Thread):
                 ]
                 needed = self.config["ACTIVE_KEY_THRESHOLD"] - len(healthy_accounts)
 
-                if needed > 0:
-                    logging.info(f"Healthy accounts ({len(healthy_accounts)}) below threshold. Need to register {needed} new accounts.")
-                    with concurrent.futures.ThreadPoolExecutor(max_workers=self.config["REGISTRATION_CONCURRENCY"]) as executor:
-                        futures = [executor.submit(self.client.register) for _ in range(needed)]
-                        for future in concurrent.futures.as_completed(futures):
-                            new_account = future.result()
-                            if new_account:
-                                self.manager.add_account(new_account)
-                else:
-                    logging.info(f"Sufficient healthy accounts ({len(healthy_accounts)}).")
+                while needed > 0:
+                    logging.info(f"Healthy accounts ({len(healthy_accounts)}) below threshold. Need to register {needed} new accounts. Retrying immediately.")
+                    new_account = self.client.register()
+                    if new_account:
+                        self.manager.add_account(new_account)
+                    
+                    healthy_accounts = [
+                        acc for acc in self.manager.get_all_accounts()
+                        if acc.get("balance", 0) > self.config["LOW_BALANCE_THRESHOLD"]
+                    ]
+                    needed = self.config["ACTIVE_KEY_THRESHOLD"] - len(healthy_accounts)
 
             except Exception as e:
                 logging.error(f"Error in KeyMaintainer cycle: {e}")