Prevent restoring invalidated session files - mark and skip AUTH_KEY_DUPLICATED sessions

utils/clients.py

@@ -92,13 +92,17 @@ async def initialize_clients():
                     multi_clients[client_id] = client
                     work_loads[client_id] = 0
                 except AuthKeyDuplicated as e:
-                    # Delete the invalidated session file first
+                    # Delete the invalidated session file and mark it as invalidated
                     session_file = None
                     try:
                         session_file = session_cache_path / f"{client_name}.session"
                         if session_file.exists():
                             session_file.unlink()
                             logger.info(f"Deleted invalidated session file: {session_file}")
+                            # Create a marker file so we don't restore this session on next restart
+                            invalidated_marker = session_cache_path / f"{client_name}.session.invalidated"
+                            invalidated_marker.touch()
+                            logger.info(f"Marked session file as invalidated: {invalidated_marker}")
                     except Exception as cleanup_error:
                         logger.error(f"Failed to delete session file: {cleanup_error}")
                     

utils/extra.py

@@ -63,10 +63,17 @@ def reset_cache_dir():
     cache_dir = Path("./cache")
     downloads_dir = Path("./downloads")
     
-    # Save session files before deleting cache
+    # Save session files before deleting cache (but skip invalidated ones)
     session_files = {}
     if cache_dir.exists():
         for session_file in cache_dir.glob("*.session"):
+            # Check if this session file was marked as invalidated
+            invalidated_marker = cache_dir / f"{session_file.name}.invalidated"
+            if invalidated_marker.exists():
+                logger.warning(f"Skipping invalidated session file: {session_file.name} (was marked as AUTH_KEY_DUPLICATED)")
+                # Delete the marker file so it can be retried on next restart
+                invalidated_marker.unlink(missing_ok=True)
+                continue
             session_files[session_file.name] = session_file.read_bytes()
             logger.info(f"Preserving session file: {session_file.name}")