refactor: improve code readability by formatting list comprehensions and enhancing batch append syntax in database operations

Author: dev-leva1

src/automod.py

@@ -50,7 +50,8 @@ def _cleanup_old_entries(self) -> None:
         for user_key in list(self.spam_counter.keys()):
             # Фильтруем старые временные метки
             self.spam_counter[user_key] = [
-                t for t in self.spam_counter[user_key]
+                t
+                for t in self.spam_counter[user_key]
                 if (now - t).total_seconds() <= spam_interval * 2
             ]
             # Удаляем пустые записи

src/database/db.py

@@ -177,10 +177,18 @@ async def _check_and_update_schema(self):
 
             # Создание индексов для оптимизации запросов
             await conn.execute("CREATE INDEX IF NOT EXISTS idx_levels_guild ON levels(guild_id)")
-            await conn.execute("CREATE INDEX IF NOT EXISTS idx_levels_user_guild ON levels(user_id, guild_id)")
-            await conn.execute("CREATE INDEX IF NOT EXISTS idx_warnings_guild_user ON warnings(guild_id, user_id)")
-            await conn.execute("CREATE INDEX IF NOT EXISTS idx_warnings_issued_at ON warnings(issued_at)")
-            await conn.execute("CREATE INDEX IF NOT EXISTS idx_tickets_channel ON tickets(channel_id)")
+            await conn.execute(
+                "CREATE INDEX IF NOT EXISTS idx_levels_user_guild ON levels(user_id, guild_id)"
+            )
+            await conn.execute(
+                "CREATE INDEX IF NOT EXISTS idx_warnings_guild_user ON warnings(guild_id, user_id)"
+            )
+            await conn.execute(
+                "CREATE INDEX IF NOT EXISTS idx_warnings_issued_at ON warnings(issued_at)"
+            )
+            await conn.execute(
+                "CREATE INDEX IF NOT EXISTS idx_tickets_channel ON tickets(channel_id)"
+            )
             await conn.execute("CREATE INDEX IF NOT EXISTS idx_tickets_guild ON tickets(guild_id)")
             logger.info("Созданы индексы для оптимизации запросов")
 

src/infrastructure/db/levels_repository.py

@@ -78,13 +78,15 @@ async def migrate_from_json(self, data: Dict) -> None:
         batch = []
         for guild_id, guild_data in data.items():
             for user_id, user_data in guild_data.items():
-                batch.append((
-                    int(user_id),
-                    int(guild_id),
-                    user_data["xp"],
-                    user_data["level"],
-                    current_time,
-                ))
+                batch.append(
+                    (
+                        int(user_id),
+                        int(guild_id),
+                        user_data["xp"],
+                        user_data["level"],
+                        current_time,
+                    )
+                )
 
         # Вставляем все записи одним запросом (игнорируем дубликаты)
         if batch:

src/infrastructure/db/warnings_repository.py

@@ -65,14 +65,16 @@ async def migrate_from_json(self, data: Dict) -> None:
         for guild_id, guild_data in data.items():
             for user_id, warnings in guild_data.items():
                 for warning in warnings:
-                    batch.append((
-                        int(user_id),
-                        int(guild_id),
-                        warning.get("reason", ""),
-                        int(warning.get("moderator", 0)),
-                        warning.get("timestamp"),
-                        None,
-                    ))
+                    batch.append(
+                        (
+                            int(user_id),
+                            int(guild_id),
+                            warning.get("reason", ""),
+                            int(warning.get("moderator", 0)),
+                            warning.get("timestamp"),
+                            None,
+                        )
+                    )
 
         # Вставляем все записи одним запросом
         if batch:

src/leveling_system.py

@@ -339,7 +339,8 @@ async def get_leaderboard(
             if cached:
                 try:
                     import json
-                    return json.loads(cached.decode('utf-8'))
+
+                    return json.loads(cached.decode("utf-8"))
                 except Exception as e:
                     logger.warning(f"Failed to load cached leaderboard: {e}")
         # Use DB if available
@@ -349,6 +350,7 @@ async def get_leaderboard(
                 if redis_client:
                     try:
                         import json
+
                         redis_client.setex(cache_key, 60, json.dumps(result))
                     except Exception as e:
                         logger.warning(f"Failed to cache leaderboard: {e}")

src/utils/discord_helpers.py

@@ -52,7 +52,10 @@ def check_role_hierarchy(
         tuple[bool, str | None]: (Можно ли выполнить действие, Сообщение об ошибке)
     """
     if target.top_role >= moderator.top_role:
-        return False, "Вы не можете выполнить это действие на пользователе с равной или более высокой ролью!"
+        return (
+            False,
+            "Вы не можете выполнить это действие на пользователе с равной или более высокой ролью!",
+        )
 
     if target.guild.owner_id == target.id:
         return False, "Вы не можете выполнить это действие на владельце сервера!"