Рефакторинг кода

Author: PyRusAdmin

README.md

@@ -22,7 +22,4 @@ accounts/<id_user>/<account_name>.session
 * <id_user> — Telegram ID пользователя, который загрузил аккаунт в бота;
 * <account_name>.session — сессия Telegram-аккаунта, используемого для мониторинга сообщений.
 
-Группы для парсинга вносятся в формате @username
-
-
-Если подключен 1 аккаунт, то второй подключен не может быть. Бот удаляет аккаунты из папки и обновляет новым аккаунтом.
+Группы для парсинга вносятся в формате @username

database/database.py

@@ -1,5 +1,6 @@
 # -*- coding: utf-8 -*-
-from peewee import Model, SqliteDatabase, IntegerField, CharField
+from peewee import Model, CharField, AutoField
+from peewee import SqliteDatabase, IntegerField
 
 db = SqliteDatabase('bot.db')
 
@@ -30,6 +31,7 @@ class Meta:
 def create_keywords_model(user_id):
     class Keywords(Model):
         """Модель для хранения ключевых слов"""
+        id = AutoField()  # <-- добавляем первичный ключ (иначе всё пишется в одну строку)
         user_keyword = CharField(unique=True)  # Поле для хранения ключевого слова
 
         class Meta:

handlers/handlers.py

@@ -1,5 +1,4 @@
 # -*- coding: utf-8 -*-
-
 from aiogram import F
 from aiogram.filters import CommandStart
 from aiogram.fsm.context import FSMContext

main.py

@@ -5,7 +5,6 @@
 
 from loguru import logger
 
-from handlers.connect_account import register_connect_account_handler
 from handlers.entering_keyword import register_entering_keyword_handler
 from handlers.handlers import register_greeting_handler
 from system.dispatcher import dp, bot
@@ -19,7 +18,7 @@ async def main() -> None:
     :return: None
     """
     register_greeting_handler()
-    register_connect_account_handler()  # Регистрация обработчика для подключения аккаунта
+
     register_entering_keyword_handler()  # Регистрация обработчика для ввода и записи в БД ключевых слов
 
     await dp.start_polling(bot)

parsing/parser.py

@@ -88,8 +88,11 @@ async def join_required_channels(client: TelegramClient, user_id):
             if e.seconds:
                 logger.warning(f"⚠️ Превышено ограничение на количество запросов в секунду. Ожидание {e.seconds} секунд...")
                 await asyncio.sleep(e.seconds)
-                await client(JoinChannelRequest(channel))
-            logger.success(f"✅ Подписка на {channel} выполнена")
+                try:
+                    await client(JoinChannelRequest(channel))
+                    logger.success(f"✅ Подписка на {channel} выполнена")
+                except InviteRequestSentError:
+                    logger.error(f"❌ Невозможно подписаться на {channel} (приглашение уже отправлено)")
         except ValueError:
             logger.error(f"❌ Не удалось подписаться на {channel} (невалидная ссылка)")
             # Удаляем невалидную запись из базы