Update state.py

state.py

@@ -13,12 +13,14 @@ class AppState:
         
         self.total_words = 0
         self.processed = 0
-        self.counts = {"taken": 0, "unavailable": 0, "sold": 0, "auction": 0, "available": 0, "forsale": 0}
         
-        self.queue = None # Will be initialized in the event loop
+        # Explicit counting metrics mapping registers
+        self.counts = {"taken": 0, "unavailable": 0, "sold": 0, "auction": 0, "available": 0, "forsale": 0, "error": 0}
+        self.fail_counts = {} 
+        
+        self.queue = None 
         self.proxies = []
         
-        # Ensure output directory exists
         if not os.path.exists("results"):
             os.makedirs("results")
 
@@ -31,6 +33,7 @@ class AppState:
         for w in words:
             await self.queue.put(w)
         self.total_words = self.queue.qsize() + self.processed
+        log.info(f"📊 Memory Queue Rebuilt. Active total words count register: {self.total_words}")
 
     async def save_result(self, word, status):
         self.processed += 1
@@ -39,13 +42,11 @@ class AppState:
         if clean_status in self.counts:
             self.counts[clean_status] += 1
             
-        # Append immediately to disk so we never lose data on crash
         filename = f"results/{clean_status}.txt"
         try:
             async with aiofiles.open(filename, "a", encoding="utf-8") as f:
                 await f.write(f"{word}\n")
         except Exception as e:
-            log.error(f"Failed to write {word} to {filename}: {e}")
+            log.error(f"Failed to append result tracking entry for {word} to {filename}: {e}")
 
-# Global singleton instance
 state = AppState()