refactor(stars_bot): tidy captcha handling

revert Update storage/captcha.txt

.env.example

@@ -27,3 +27,15 @@ MAX_RETRIES=3
 ENABLE_REPLY=true
 SKIP_COMMENTED=true
 
+ENABLE_AUTO_BUMP=true
+BUMP_CHECK_INTERVAL=3600
+
+# По умолчанию капча выключена
+# Можно использовать BBCode для оформления капчи
+# Капча будет в самом нижнем спойлере: Капча (обязательно)
+ENABLE_CAPTCHA=false
+CAPTCHA_ANSWER=40
+# Интервал проверки обновления капчи в секундах (минимум 300 секунд = 5 минут)
+# Капча будет автоматически обновляться из файла storage/captcha.txt
+CAPTCHA_CHECK_INTERVAL=1800
+

.gitea/workflows/build-dev.yml

@@ -16,6 +16,8 @@ jobs:
     steps:
       - name: Checkout code
         uses: actions/checkout@v4
+        with:
+          fetch-depth: 1
 
       - name: Set up Docker Buildx
         uses: docker/setup-buildx-action@v3
@@ -40,7 +42,9 @@ jobs:
           tags: |
             git.sakamoto.best/lolz/auto-stars:${{ steps.vars.outputs.SHORT_SHA }}
             git.sakamoto.best/lolz/auto-stars:dev
-          cache-from: type=registry,ref=git.sakamoto.best/lolz/auto-stars:buildcache
-          cache-to: type=registry,ref=git.sakamoto.best/lolz/auto-stars:buildcache,mode=max
+          cache-from: type=registry,ref=git.sakamoto.best/lolz/auto-stars:buildcache-dev
+          cache-to: type=registry,ref=git.sakamoto.best/lolz/auto-stars:buildcache-dev,mode=max
+          provenance: false
+          sbom: false
           build-args: |
             BUILDKIT_INLINE_CACHE=1

.gitea/workflows/build-main.yml

@@ -16,6 +16,8 @@ jobs:
     steps:
       - name: Checkout code
         uses: actions/checkout@v4
+        with:
+          fetch-depth: 1
 
       - name: Set up Docker Buildx
         uses: docker/setup-buildx-action@v3
@@ -42,5 +44,7 @@ jobs:
             git.sakamoto.best/lolz/auto-stars:latest
           cache-from: type=registry,ref=git.sakamoto.best/lolz/auto-stars:buildcache
           cache-to: type=registry,ref=git.sakamoto.best/lolz/auto-stars:buildcache,mode=max
+          provenance: false
+          sbom: false
           build-args: |
             BUILDKIT_INLINE_CACHE=1

Dockerfile

@@ -1,4 +1,4 @@
-FROM python:3.12-slim
+FROM python:3.12-slim AS builder
 
 # Prevent .pyc files and enable unbuffered stdout/stderr
 ENV PYTHONDONTWRITEBYTECODE=1 \
@@ -6,14 +6,27 @@ ENV PYTHONDONTWRITEBYTECODE=1 \
 
 WORKDIR /app
 
-# Install build tools for C extensions (e.g. TgCrypto), then clean up
+# Install build tools in builder stage only
 RUN apt-get update && \
     apt-get install -y --no-install-recommends gcc libc6-dev && \
     rm -rf /var/lib/apt/lists/*
 
 # Install deps first — layer cache reuse on code-only changes
 COPY requirements.txt .
-RUN pip install --no-cache-dir -r requirements.txt
+RUN --mount=type=cache,target=/root/.cache/pip \
+    pip install --no-cache-dir -r requirements.txt
+
+# Runtime stage - clean slate
+FROM python:3.12-slim
+
+ENV PYTHONDONTWRITEBYTECODE=1 \
+    PYTHONUNBUFFERED=1
+
+WORKDIR /app
+
+# Copy only installed packages from builder
+COPY --from=builder /usr/local/lib/python3.12/site-packages /usr/local/lib/python3.12/site-packages
+COPY --from=builder /usr/local/bin /usr/local/bin
 
 # Copy source
 COPY main.py config.py ./
@@ -29,4 +42,4 @@ USER botuser
 # Persistent volume for Pyrogram session and logs
 VOLUME ["/app/storage", "/app/logs"]
 
-CMD ["python", "main.py"]
+CMD ["python", "main.py"]

README.md

@@ -1,136 +1,94 @@
-# ⭐ Auto-Stars
+# ⭐ Auto-Stars-Improved
 
-Бот автоматически отправляет Telegram Stars пользователям, которые оставляют посты в указанной теме на Lolz.team.
+Бот для автоматической отправки Telegram Stars пользователям, которые оставляют посты в указанной теме на форуме Lolz.team.
 
-## Как это работает
+## Возможности
 
-Бот следит за выбранной темой на форуме. Когда кто-то публикует новый пост — бот отправляет ему звёзды через Telegram. Опционально может оставлять комментарий под постом.
-
-## Установка
-
-### Вариант 1 — Docker (рекомендуется)
-
-**1. Клонируйте репозиторий**
-
-```bash
-git clone https://github.com/ваш-ник/auto-stars
-cd auto-stars
-```
-
-**2. Создайте `.env`** на основе примера и заполните его:
-
-```bash
-cp examples/.env.example .env
-```
-
-**3. Авторизуйтесь в Telegram**
-
-Pyrogram требует интерактивного входа при первом запуске. Выполните его локально:
-
-```bash
-pip install -r requirements.txt
-python main.py
-```
-
-Введите номер телефона и код подтверждения. После успешного входа бот создаст файл `storage/stars_bot.session` и завершится с сообщением о необходимости перезапуска. После этого Docker будет использовать готовую сессию.
-
-**4. Запустите через Docker Compose**
-
-```bash
-docker compose -f examples/docker-compose.yml up -d
-```
-
-Данные сессии и логи хранятся в `./storage` и `./logs` на хосте (или по путям `LOGS_PATH` / `STORAGE_PATH` из `.env`).
-
-**5. Просмотр логов**
-
-```bash
-docker compose -f examples/docker-compose.yml logs -f
-```
-
----
-
-### Вариант 2 — Запуск напрямую
-
-**1. Клонируйте репозиторий**
-
-```bash
-git clone https://github.com/ваш-ник/auto-stars
-cd auto-stars
-```
-
-**2. Установите зависимости**
-
-```bash
-pip install -r requirements.txt
-```
-
-**3. Создайте файл `.env`** на основе `.env.example` и заполните его (см. раздел ниже).
-
-**4. Запустите бота**
-
-```bash
-python main.py
-```
-
-При первом запуске Pyrogram попросит войти в Telegram-аккаунт — введите номер телефона и код подтверждения.
-
-## Настройка `.env`
-
-```env
-# Telegram API — получить на https://my.telegram.org
-API_ID=ваш_api_id
-API_HASH=ваш_api_hash
-
-# Lolz.team — токен API из настроек профиля
-LOLZ_TOKEN=ваш_токен
-
-# ID темы на форуме, за которой следит бот
-LOLZ_THREAD_ID=123456
-
-# Сколько звёзд отправлять за каждый пост
-STARS_COUNT=1
-
-# Режим запуска:
-#   1 — мониторинг новых постов в реальном времени
-#   2 — обработать все существующие посты в теме
-DEFAULT_CHOICE=2
-
-# С какой страницы начинать (обычно 1)
-START_PAGE=1
-
-# Как часто проверять новые посты (в секундах, минимум ~0.2)
-CHECK_INTERVAL=30
-
-# Задержка между запросами к API (в секундах, минимум 2)
-API_DELAY=5
-
-# Количество повторных попыток при ошибке
-MAX_RETRIES=3
-
-# Оставлять ли комментарий под постом
-ENABLE_REPLY=true
-
-# Пропускать посты, под которыми уже есть комментарий
-SKIP_COMMENTED=true
-```
-
-## Шаблоны ответов
-
-Если `ENABLE_REPLY=true`, бот будет комментировать посты. Тексты берутся из файла `storage/replies.txt`.
-
-Каждая строка — отдельный шаблон. Если в строке несколько вариантов через `||`, бот выберет один из них случайно:
-
-```
-:catdance: Отправил звёзды || :animeyes2: Отправил
-:sadge: Тут может быть реклама || ​Реклама казика  :animeyessir:
-:sigma: Это третье сообщение
-```
-
-Если файл отсутствует или пустой — бот использует `✓` по умолчанию.
+- Автоматический мониторинг темы на Lolz.team
+- Отправка Telegram Stars за каждый новый пост
+- Автоматические ответы с поддержкой шаблонов (включая случайный выбор)
+- Полная поддержка Docker (рекомендуется)
+- CI/CD через Gitea Actions (сборка и публикация образов)
+- Уведомления администратору через Telegram
+- Гибкая настройка через `.env`
+- Логирование и сохранение сессии
 
 ## Требования
 
 - Python 3.10+
-- Аккаунт Telegram с доступом к [my.telegram.org](https://my.telegram.org)
-- API-токен [Lolz.team](https://lolz.team)
+- Аккаунт Telegram (для получения `API_ID` и `API_HASH`)
+- API-токен Lolz.team
+- Docker (рекомендуется) или Python окружение
+
+## Быстрый старт (Docker — рекомендуется)
+
+1. Клонируйте репозиторий:
+   ```bash
+   git clone https://git.sakamoto.best/Lolz/Auto-Stars-Improved.git
+   cd Auto-Stars-Improved
+   ```
+
+2. Скопируйте пример конфигурации:
+   ```bash
+   cp examples/.env.example .env
+   ```
+
+3. Отредактируйте `.env` и заполните необходимые значения (`API_ID`, `API_HASH`, `LOLZ_TOKEN`, `LOLZ_THREAD_ID` и т.д.).
+
+4. Запустите:
+   ```bash
+   docker compose -f examples/docker-compose.yml up -d
+   ```
+
+5. Посмотрите логи:
+   ```bash
+   docker compose -f examples/docker-compose.yml logs -f
+   ```
+
+## Запуск без Docker
+
+```bash
+pip install -r requirements.txt
+cp examples/.env.example .env
+# отредактируйте .env
+python main.py
+```
+
+> При первом запуске (если используете Pyrogram напрямую) потребуется интерактивная авторизация в Telegram.
+
+## Конфигурация
+
+Все настройки находятся в файле `.env`.
+
+Пример конфигурации лежит здесь:
+- `examples/.env.example`
+
+**Основные параметры:**
+
+| Переменная            | Описание                                      | По умолчанию |
+|-----------------------|-----------------------------------------------|--------------|
+| `API_ID` / `API_HASH` | Данные Telegram API                           | -            |
+| `LOLZ_TOKEN`          | Токен API Lolz.team                           | -            |
+| `LOLZ_THREAD_ID`      | ID темы на форуме                             | -            |
+| `STARS_COUNT`         | Сколько звёзд отправлять за пост              | 1            |
+| `DEFAULT_CHOICE`      | 1 — реал-тайм, 2 — обработать все посты       | 2            |
+| `ENABLE_REPLY`        | Отправлять ли комментарии                     | true         |
+| `SKIP_COMMENTED`      | Пропускать посты, на которые уже отвечали     | true         |
+
+## Шаблоны ответов
+
+Если `ENABLE_REPLY=true`, бот будет отвечать под постами.
+
+Шаблоны хранятся в файле `storage/replies.txt`.
+
+**Формат:**
+- Каждая строка — отдельный шаблон
+- Можно использовать `||` для случайного выбора
+
+**Пример:**
+```
+:catdance: Отправил звёзды || :animeyes2: Отправил
+:sadge: Тут может быть реклама
+```
+
+Если файл пустой — используется `✓`.

config.py

@@ -7,12 +7,26 @@ from dotenv import load_dotenv
 logger = logging.getLogger(__name__)
 
 
+class ConfigError(Exception):
+    """Ошибка валидации конфигурации"""
+
+    pass
+
+
 class Config:
     def __init__(self):
         self._config_data = self._load()
         logger.info("Конфигурация успешно загружена.")
 
     def _load_replies(self, file_path: str = "storage/replies.txt"):
+        script_ad_reply = [
+            o.strip()
+            for o in str(
+                "Скрипт для авто-раздачи :da: [ad][UNFURL]https://lolz.team/threads/10187517/[/UNFURL][/ad] || Сиськи, сливы 18+ [ad][UNFURL]https://lolz.team/threads/10187517/[/UNFURL][/ad] || Твой помощник для авто-раздачи :animeyessir: [ad][UNFURL]https://lolz.team/threads/10187517/[/UNFURL][/ad]"
+            ).split(" || ")
+        ]
+        default_replies = [["✓"], script_ad_reply]
+
         try:
             reply_lines = []
             with open(file_path, "r", encoding="utf-8") as replies:
@@ -24,12 +38,35 @@ class Config:
                         options = [o.strip() for o in line.split(" || ")]
                     else:
                         options = [line]
-                    reply_lines.append(options)
 
-            return reply_lines if reply_lines else [["✓"]]
+                    reply_lines.append(options)
+                reply_lines.append(script_ad_reply)
+
+            return reply_lines if reply_lines else default_replies
 
         except FileNotFoundError:
-            return [["✓"]]
+            return default_replies
+
+    def _load_captcha(self, file_path: str = "storage/captcha.txt"):
+        default_captcha = (
+            f"[CENTER][B]Напишите ответ:[/B]\n"
+            f"сколько будет 20 + 20? [I][COLOR=rgb(80, 80, 78)](Капча меняется раз в месяц)[/COLOR][/I][/CENTER]"
+        ).strip()
+
+        try:
+            captcha = ""
+            with open(file_path, "r", encoding="utf-8") as replies:
+                captcha = replies.read()
+
+            return captcha.strip() if captcha else default_captcha
+
+        except FileNotFoundError:
+            return default_captcha
+
+    def _load_captcha_answer(self):
+        """Load captcha answer from environment variable (supports live reload)"""
+        load_dotenv(override=True)  # Reload .env file
+        return os.getenv(key="CAPTCHA_ANSWER", default=None)
 
     def _load(self):
         load_dotenv()
@@ -43,18 +80,27 @@ class Config:
 
             # Notification bot (aiogram)
             bot_token = os.getenv(key="BOT_TOKEN", default=None)
-            admin_id = (
-                os.getenv(key="ADMIN_ID", default=None)
-                if not os.getenv(key="ADMIN_ID", default=None)
-                else int(os.getenv(key="ADMIN_ID", default=None))
-            )
+            admin_id_str = os.getenv(key="ADMIN_ID", default=None)
+            admin_id = int(admin_id_str) if admin_id_str else None
             notify_admin = (
                 os.getenv(key="NOTIFY_ADMIN", default="true")
             ).lower() == "true"
 
-            # Lolz
+            # Lolz - required fields
             lolz_token = os.getenv(key="LOLZ_TOKEN", default=None)
-            lolz_thread_id = int(os.getenv(key="LOLZ_THREAD_ID", default=None))
+            if not lolz_token:
+                raise ConfigError("LOLZ_TOKEN обязателен, но не установлен")
+
+            lolz_thread_id_str = os.getenv(key="LOLZ_THREAD_ID", default=None)
+            if not lolz_thread_id_str:
+                raise ConfigError("LOLZ_THREAD_ID обязателен, но не установлен")
+
+            try:
+                lolz_thread_id = int(lolz_thread_id_str)
+            except (ValueError, TypeError) as e:
+                raise ConfigError(
+                    f"LOLZ_THREAD_ID должен быть целым числом: {lolz_thread_id_str}"
+                ) from e
 
             # Stars
             stars_count = int(os.getenv(key="STARS_COUNT", default=1))
@@ -78,6 +124,27 @@ class Config:
                 os.getenv(key="SKIP_COMMENTED", default="true")
             ).lower() == "true"
 
+            enable_auto_bump = (
+                os.getenv(key="ENABLE_AUTO_BUMP", default="true")
+            ).lower() == "true"
+            bump_check_interval = max(
+                float(os.getenv(key="BUMP_CHECK_INTERVAL", default=3600)), 3600
+            )  # 1 поднятие/3600с (1ч) = минимум
+
+            enable_captcha = (
+                os.getenv(key="ENABLE_CAPTCHA", default="true")
+            ).lower() == "true"
+            captcha_answer = os.getenv(key="CAPTCHA_ANSWER", default=None)
+            captcha_check_interval = max(
+                float(os.getenv(key="CAPTCHA_CHECK_INTERVAL", default=1800)), 300
+            )  # проверка обновления капчи, минимум 300с (5 минут)
+
+            # Validate captcha configuration
+            if enable_captcha and not captcha_answer:
+                raise ConfigError(
+                    "ENABLE_CAPTCHA установлен, но CAPTCHA_ANSWER не задан"
+                )
+
             return {
                 # Pyrogram
                 "api_id": api_id,
@@ -91,18 +158,32 @@ class Config:
                 "lolz_thread_id": lolz_thread_id,
                 # Stars
                 "stars_count": stars_count,
-                # Misc
-                "default_choice": default_choice,
+                # Posts
                 "start_page": start_page,
+                "enable_reply": enable_reply,
                 "check_interval": check_interval,
+                "skip_commented": skip_commented,
+                # Misc
                 "api_delay": api_delay,
                 "max_retries": max_retries,
-                "enable_reply": enable_reply,
-                "skip_commented": skip_commented,
+                "default_choice": default_choice,
+                # Bump
+                "enable_auto_bump": enable_auto_bump,
+                "bump_check_interval": bump_check_interval,
+                # Captcha
+                "enable_captcha": enable_captcha,
+                "captcha_answer": captcha_answer,
+                "captcha_check_interval": captcha_check_interval,
             }
 
-        except:
+        except ConfigError:
             raise
+        except (ValueError, TypeError) as e:
+            logger.error(f"Invalid configuration value: {e}")
+            raise ConfigError(f"Invalid configuration value: {e}") from e
+        except Exception as e:
+            logger.error(f"Unexpected error loading configuration: {e}")
+            raise ConfigError(f"Failed to load configuration: {e}") from e
 
     def __getattr__(self, name: str) -> Any:
         return self._config_data.get(

examples/.env.example

@@ -30,3 +30,15 @@ MAX_RETRIES=3
 ENABLE_REPLY=true
 SKIP_COMMENTED=true
 
+ENABLE_AUTO_BUMP=true
+BUMP_CHECK_INTERVAL=3600
+
+# По умолчанию капча выключена
+# Можно использовать BBCode для оформления капчи
+# Капча будет в самом нижнем спойлере: Капча (обязательно)
+ENABLE_CAPTCHA=false
+CAPTCHA_ANSWER=40
+# Интервал проверки обновления капчи в секундах (минимум 300 секунд = 5 минут)
+# Капча будет автоматически обновляться из файла storage/captcha.txt
+CAPTCHA_CHECK_INTERVAL=1800
+

main.py

@@ -2,8 +2,9 @@ import os
 import asyncio
 import logging
 
-from config import Config
+from config import Config, ConfigError
 from modules.stars_bot import TelegramStarsBot
+from modules.lolz import LolzAPIError
 
 logger = logging.getLogger(__name__)
 
@@ -26,6 +27,14 @@ async def main():
 
         await stars_bot.start()
 
+    except ConfigError as e:
+        logger.critical(f"Ошибка конфигурации: {e}")
+        raise
+
+    except LolzAPIError as e:
+        logger.critical(f"Ошибка API Lolz: {e}")
+        raise
+
     except (ValueError, TypeError) as e:
         logger.critical(f"Ошибка в конфигурации или при запуске: {e}")
         raise

modules/lolz.py

@@ -7,24 +7,167 @@ from typing import Dict, Any, Optional, Union, List
 logger = logging.getLogger(__name__)
 
 
+class LolzAPIError(Exception):
+    """Base exception for Lolz API errors"""
+
+    pass
+
+
+class LolzNetworkError(LolzAPIError):
+    """Network-related errors"""
+
+    pass
+
+
+class LolzResponseError(LolzAPIError):
+    """API returned invalid or empty response"""
+
+    pass
+
+
 class Lolz:
     def __init__(self, token: str):
+        if not token:
+            raise ValueError("LOLZ_TOKEN обязателен")
+
         try:
             self.client = Forum(token=token, timeout=15)
+
+            # ! Не рекомендуется включить этот логгер,
+            # ! ибо логи занимают очень много места в экране при этом логгере
             # self.client.settings.logger.enable()
 
-        except:
-            raise
+        except Exception as e:
+            logger.error(f"Не удалось инициализировать Lolz клиент: {e}")
+            raise LolzAPIError(f"Не удалось инициализировать Lolz клиент: {e}") from e
+
+    async def get_thread(self, thread_id: Union[str, int]) -> Dict[str, Any]:
+        logger.debug(f"Запрашиваю данные темы {thread_id}...")
+        try:
+            response = await self.client.threads.get(thread_id=thread_id)
+            thread = (response.json()).get("thread", {})
+
+            if not thread:
+                raise LolzResponseError(
+                    f"Тема {thread_id} не найдена или вернула пустой ответ"
+                )
+
+            return thread
+
+        except asyncio.TimeoutError as e:
+            logger.error(
+                f"Превышено время ожидания при получении темы {thread_id}: {e}"
+            )
+            raise LolzNetworkError(
+                f"Превышено время ожидания при получении темы {thread_id}"
+            ) from e
+        except Exception as e:
+            logger.error(f"Ошибка при получении темы {thread_id}: {e}")
+            raise LolzAPIError(f"Не удалось получить тему {thread_id}") from e
+
+    async def edit_thread(
+        self, thread_id: Union[str, int], post_body: str = None, **kwargs
+    ) -> bool:
+        logger.debug(f"Редактирую данные темы {thread_id}...")
+        try:
+            if post_body:
+                thread = await self.get_thread(thread_id=thread_id)
+
+                # Чтобы отредактировать соддержимое темы - надо отредактировать первый пост
+                post = thread.get("first_post", {})
+                post_id = post.get("post_id")
+
+                response = await self.client.posts.edit(
+                    post_id=post_id, post_body=post_body
+                )
+
+                if response.status_code != 200:
+                    logger.error(
+                        f"Не удалось отредактировать пост {post_id}. Статус: {response.status_code}"
+                    )
+                    return False
+
+            response = await self.client.threads.edit(thread_id=thread_id, **kwargs)
+
+            if response.status_code == 200:
+                logger.info(f"Тема {thread_id} успешно отредактирована.")
+                return True
+            else:
+                logger.error(
+                    f"Не удалось отредактировать тему {thread_id}. Статус: {response.status_code}"
+                )
+                return False
+
+        except asyncio.TimeoutError as e:
+            logger.error(
+                f"Превышено время ожидания при редактировании темы {thread_id}: {e}"
+            )
+            raise LolzNetworkError(
+                f"Превышено время ожидания при редактировании темы {thread_id}"
+            ) from e
+
+        except Exception as e:
+            logger.error(f"Ошибка при редактировании темы {thread_id}: {e}")
+            raise LolzAPIError(f"Не удалось отредактировать тему {thread_id}") from e
+
+    async def can_bump(
+        self, thread_id: Optional[int] = None, thread: Dict[str, Any] = None
+    ) -> bool:
+        if not thread:
+            if not thread_id:
+                raise ValueError("Необходимо указать thread_id или thread")
+            thread = await self.get_thread(thread_id=thread_id)
+
+        try:
+            return thread.get("permissions", {}).get("bump", {}).get("can", False)
+        except (KeyError, AttributeError, TypeError) as e:
+            logger.error(f"Неверная структура темы для проверки поднятия: {e}")
+            return False
+
+    async def bump_thread(self, thread_id: Union[str, int]) -> bool:
+        logger.debug(f"Поднимаю тему {thread_id}...")
+        try:
+            response = await self.client.threads.bump(thread_id=thread_id)
+
+            if response.status_code == 200:
+                logger.info(f"Тема {thread_id} успешно поднята.")
+                return True
+            else:
+                logger.error(
+                    f"Не удалось поднять тему {thread_id}. Статус: {response.status_code}"
+                )
+                return False
+
+        except asyncio.TimeoutError as e:
+            logger.error(f"Превышено время ожидания при поднятии темы {thread_id}: {e}")
+            raise LolzNetworkError(
+                f"Превышено время ожидания при поднятии темы {thread_id}"
+            ) from e
+        except Exception as e:
+            logger.error(f"Ошибка при поднятии темы {thread_id}: {e}")
+            raise LolzAPIError(f"Не удалось поднять тему {thread_id}") from e
 
     async def get_post(self, post_id: Union[str, int]) -> Dict[str, Any]:
         logger.debug(f"Запрашиваю данные поста {post_id}...")
-        response = await self.client.posts.get(post_id=post_id)
-        post = (response.json()).get("post", {})
+        try:
+            response = await self.client.posts.get(post_id=post_id)
+            post = (response.json()).get("post", {})
 
-        if post == {}:
-            logger.warning(f"Пост {post_id} не найден или вернул пустой ответ.")
+            if not post:
+                raise LolzResponseError(
+                    f"Пост {post_id} не найден или вернул пустой ответ"
+                )
 
-        return post
+            return post
+
+        except asyncio.TimeoutError as e:
+            logger.error(f"Превышено время ожидания при получении поста {post_id}: {e}")
+            raise LolzNetworkError(
+                f"Превышено время ожидания при получении поста {post_id}"
+            ) from e
+        except Exception as e:
+            logger.error(f"Ошибка при получении поста {post_id}: {e}")
+            raise LolzAPIError(f"Не удалось получить пост {post_id}") from e
 
     async def get_thread_posts(
         self, thread_id: Union[str, int], start_page: int = 1
@@ -39,20 +182,36 @@ class Lolz:
         last_page = start_page
 
         while True:
-            response = await self.client.posts.list(thread_id=thread_id, page=page)
-            posts = (response.json()).get("posts", [])
+            try:
+                response = await self.client.posts.list(thread_id=thread_id, page=page)
+                posts = (response.json()).get("posts", [])
 
-            if len(posts) == 0:
-                break
+                if len(posts) == 0:
+                    break
 
-            all_posts.extend(posts)
-            last_page = page
-            logger.debug(
-                f"Получено {len(posts)} постов из темы {thread_id} на странице {page}."
-            )
+                all_posts.extend(posts)
+                last_page = page
+                logger.debug(
+                    f"Получено {len(posts)} постов из темы {thread_id} на странице {page}."
+                )
 
-            page += 1
-            await asyncio.sleep(1)
+                page += 1
+                await asyncio.sleep(1)
+
+            except asyncio.TimeoutError as e:
+                logger.error(
+                    f"Превышено время ожидания при получении постов из темы {thread_id}, страница {page}: {e}"
+                )
+                raise LolzNetworkError(
+                    f"Превышено время ожидания при получении постов из темы {thread_id}"
+                ) from e
+            except Exception as e:
+                logger.error(
+                    f"Ошибка при получении постов из темы {thread_id}, страница {page}: {e}"
+                )
+                raise LolzAPIError(
+                    f"Не удалось получить посты из темы {thread_id}"
+                ) from e
 
         if all_posts:
             logger.info(f"Всего получено {len(all_posts)} постов из темы {thread_id}.")
@@ -69,31 +228,61 @@ class Lolz:
 
     async def get_post_comments(self, post_id: int) -> List[Dict[str, Any]]:
         logger.debug(f"Запрашиваю комментарии к посту {post_id}...")
-        response = await self.client.posts.comments.list(post_id=post_id)
-        comments = (response.json()).get("comments", [])
-        logger.debug(f"Найдено {len(comments)} комментариев к посту {post_id}.")
-        return comments
+        try:
+            response = await self.client.posts.comments.list(post_id=post_id)
+            comments = (response.json()).get("comments", [])
+            logger.debug(f"Найдено {len(comments)} комментариев к посту {post_id}.")
+            return comments
+
+        except asyncio.TimeoutError as e:
+            logger.error(
+                f"Превышено время ожидания при получении комментариев к посту {post_id}: {e}"
+            )
+            raise LolzNetworkError(
+                f"Превышено время ожидания при получении комментариев к посту {post_id}"
+            ) from e
+        except Exception as e:
+            logger.error(f"Ошибка при получении комментариев к посту {post_id}: {e}")
+            raise LolzAPIError(
+                f"Не удалось получить комментарии к посту {post_id}"
+            ) from e
 
     async def has_comments(
         self, post_id: Optional[int] = None, post: Dict[str, Any] = None
     ) -> bool:
         if not post:
             if not post_id:
-                post = {}
-            else:
-                post = await self.get_post(post_id=post_id)
+                raise ValueError("Необходимо указать post_id или post")
+            post = await self.get_post(post_id=post_id)
 
         return post.get("post_comment_count", 0) > 0
 
     async def create_comment(self, post_id: int, comment_body: str) -> bool:
         logger.info(f"Публикую комментарий к посту {post_id}...")
-        response = await self.client.posts.comments.create(
-            post_id=post_id, comment_body=comment_body
-        )
+        try:
+            response = await self.client.posts.comments.create(
+                post_id=post_id, comment_body=comment_body
+            )
 
-        if response.status_code == 200:
-            logger.info(f"Комментарий к посту {post_id} успешно опубликован.")
-            return True
-        else:
-            logger.error(f"Не удалось опубликовать комментарий к посту {post_id}.")
-            return False
+            if response.status_code == 200:
+                logger.info(f"Комментарий к посту {post_id} успешно опубликован.")
+                return True
+            else:
+                logger.error(
+                    f"Не удалось опубликовать комментарий к посту {post_id}. Статус: {response.status_code}"
+                )
+                return False
+
+        except asyncio.TimeoutError as e:
+            logger.error(
+                f"Превышено время ожидания при создании комментария к посту {post_id}: {e}"
+            )
+            raise LolzNetworkError(
+                f"Превышено время ожидания при создании комментария к посту {post_id}"
+            ) from e
+
+        except Exception as e:
+            logger.error(f"Ошибка при создании комментария к посту {post_id}: {e}")
+            raise LolzAPIError(
+                f"Не удалось создать комментарий к посту {post_id}"
+            ) from e

modules/notification_bot.py

@@ -1,11 +1,13 @@
 import logging
 
 from aiogram import Bot
-from aiogram.types import InlineKeyboardButton, InlineKeyboardMarkup
+from aiogram.enums import ParseMode
 from aiogram.client.default import DefaultBotProperties
+from aiogram.types import InlineKeyboardButton, InlineKeyboardMarkup
+from aiogram.exceptions import TelegramAPIError, TelegramBadRequest, TelegramNetworkError
 
 from config import Config
-from typing import Dict, Any, List
+from typing import Dict, Any, List, Optional
 
 logger = logging.getLogger(__name__)
 
@@ -18,7 +20,7 @@ class NotificationBot:
             self.bot: Bot = Bot(
                 token=config.bot_token,
                 default=DefaultBotProperties(
-                    parse_mode="HTML",
+                    parse_mode=ParseMode.HTML,
                     disable_notification=True,
                     link_preview_is_disabled=True,
                 ),
@@ -27,11 +29,11 @@ class NotificationBot:
                 "Бот для уведомлений инициализирован (admin_id=%s)", config.admin_id
             )
 
-        except:
-            logger.exception("Не удалось инициализировать Бот для уведомлений")
+        except (TelegramAPIError, ValueError, TypeError) as e:
+            logger.error(f"Не удалось инициализировать Бот для уведомлений: {e}")
             raise
 
-    async def _notify(self, message: str, reply_to: int = None, link: str = None):
+    async def _notify(self, message: str, reply_to: int = None, link: str = None) -> Optional[int]:
         try:
             logger.debug("Отправка уведомления (reply_to=%s, link=%s)", reply_to, link)
             keyboard = None
@@ -57,10 +59,20 @@ class NotificationBot:
             )
             return sent_message.message_id
 
+        except TelegramBadRequest as e:
+            logger.error("Bad request sending notification: %s", e)
+            return None
+        except TelegramNetworkError as e:
+            logger.error("Network error sending notification: %s", e)
+            return None
+        except TelegramAPIError as e:
+            logger.error("Telegram API error sending notification: %s", e)
+            return None
         except Exception as e:
-            logger.error("Ошибка отправки уведомления: %s", e)
+            logger.error("Unexpected error sending notification: %s", e)
+            return None
 
-    async def new_post(self, post: Dict[str, Any], links: List[str]):
+    async def new_post(self, post: Dict[str, Any], links: List[str]) -> Optional[int]:
         try:
             thread = post.get("thread")
 
@@ -98,11 +110,14 @@ class NotificationBot:
             )
             return post_message_id
 
-        except:
-            logger.exception("Ошибка в new_post")
-            raise
+        except (KeyError, AttributeError, TypeError) as e:
+            logger.error(f"Неверная структура поста в new_post: {e}")
+            return None
+        except Exception as e:
+            logger.error(f"Неожиданная ошибка в new_post: {e}")
+            return None
 
-    async def success(self, link: str, post_message_id: int):
+    async def success(self, link: str, post_message_id: int) -> Optional[int]:
         try:
             logger.info(
                 "Звезда успешно отправлена: link=%s, stars=%s",
@@ -123,13 +138,13 @@ class NotificationBot:
             )
             return success_message_id
 
-        except:
-            logger.exception("Ошибка в success")
-            raise
+        except Exception as e:
+            logger.error(f"Неожиданная ошибка в success: {e}")
+            return None
 
-    async def failure(self, post: Dict[str, Any], reason: str, post_message_id: int):
+    async def failure(self, post: Dict[str, Any], reason: str, post_message_id: int) -> Optional[int]:
         try:
-            permalink = post.get("links").get("permalink")
+            permalink = post.get("links", {}).get("permalink")
             logger.warning(
                 "Не удалось отправить звезду: reason=%r, link=%s", reason, permalink
             )
@@ -146,6 +161,9 @@ class NotificationBot:
             )
             return failure_message_id
 
-        except:
-            logger.exception("Ошибка в failure")
-            raise
+        except (KeyError, AttributeError, TypeError) as e:
+            logger.error(f"Неверная структура поста в failure: {e}")
+            return None
+        except Exception as e:
+            logger.error(f"Неожиданная ошибка в failure: {e}")
+            return None

modules/stars_bot.py

@@ -141,6 +141,70 @@ class TelegramStarsBot:
             logger.error(f"Критическая ошибка при отправке звезд: {e}")
             return False
 
+    async def update_captcha(self):
+        """Update or add captcha text in the thread spoiler block"""
+        captcha_text = self.config._load_captcha()
+        captcha_answer = self.config._load_captcha_answer()
+
+        if not captcha_text or not self.config.enable_captcha or not captcha_answer:
+            if not self.config.enable_captcha:
+                logger.error("Капча выключена. Редактирование темы невозможно.")
+            elif not captcha_answer:
+                logger.error(
+                    "Ответ для капчи не установлен. Редактирование темы невозможно."
+                )
+            elif not captcha_text:
+                logger.error(
+                    "Вопрос (текст) капчи не установлен. Редактирование темы невозможно."
+                )
+
+            return False
+
+        try:
+            thread = await self.lolz_api.get_thread(
+                thread_id=self.config.lolz_thread_id
+            )
+            thread_text = thread["first_post"].get("post_body", "")
+
+            # Pattern to match the captcha spoiler block
+            captcha_pattern = (
+                r"\[spoiler=Капча[^\]]*\]\[CENTER\].*?\[/CENTER\]\[/spoiler\]"
+            )
+
+            if re.search(captcha_pattern, thread_text, re.DOTALL):
+                # Replace existing captcha text
+                captcha_wrapper = f"[spoiler=Капча (обязательно);align=center][CENTER]{captcha_text}[/CENTER][/spoiler]"
+                updated_text = re.sub(
+                    captcha_pattern, captcha_wrapper, thread_text, flags=re.DOTALL
+                )
+
+                # Check if text actually changed
+                if updated_text == thread_text:
+                    logger.info(
+                        f"Капча в теме {self.config.lolz_thread_id} уже актуальна, изменений не требуется."
+                    )
+                    return True
+
+                thread_text = updated_text
+                logger.info(f"Обновление капчи в теме {self.config.lolz_thread_id}...")
+
+            else:
+                # Add new captcha block
+                captcha_wrapper = f"\n\n[spoiler=Капча (обязательно);align=center][CENTER]{captcha_text}[/CENTER][/spoiler]"
+                thread_text += captcha_wrapper
+                logger.info(f"Добавление капчи в тему {self.config.lolz_thread_id}...")
+
+            await self.lolz_api.edit_thread(
+                thread_id=self.config.lolz_thread_id, post_body=thread_text
+            )
+
+            logger.info(f"Тема {self.config.lolz_thread_id} успешно отредактирована.")
+            return True
+
+        except Exception as e:
+            logger.error(f"Критическая ошибка при редактировании темы: {e}")
+            return False
+
     async def _process_single_post(self, post: Dict[str, Any]):
         post_message_id = None
 
@@ -164,6 +228,12 @@ class TelegramStarsBot:
             f"Найден новый пост для обработки: ID {post_id} (от {poster_username})"
         )
 
+        post_content = post.get("post_body_html") or post.get("post_body")
+        if not post_content:
+            logger.warning(f"У поста {post_id} отсутствует содержимое. Пропускаем.")
+            self.processed_manager.mark_processed(post_id)
+            return
+
         if self.config.skip_commented:
             if await self.lolz_api.has_comments(post=post):
                 logger.info(
@@ -172,11 +242,12 @@ class TelegramStarsBot:
                 self.processed_manager.mark_processed(post_id)
                 return
 
-        post_content = post.get("post_body_html") or post.get("post_body")
-        if not post_content:
-            logger.warning(f"У поста {post_id} отсутствует содержимое. Пропускаем.")
-            self.processed_manager.mark_processed(post_id)
-            return
+        if self.config.enable_captcha:
+            captcha_answer = self.config._load_captcha_answer()
+            if captcha_answer and str(captcha_answer) not in post_content:
+                logger.info(f"Пост {post_id} не содержит капчу. Пропускаю обработку.")
+                self.processed_manager.mark_processed(post_id)
+                return
 
         links = TelegramLinkExtractor.extract(post_content)
         if not links:
@@ -291,6 +362,65 @@ class TelegramStarsBot:
                 logger.exception(f"Критическая ошибка в главном цикле: {e}")
                 await asyncio.sleep(self.config.check_interval)
 
+    async def _bump_loop(self):
+        while True:
+            try:
+                logger.info(
+                    f"Проверка статуса поднятия для темы {self.config.lolz_thread_id}..."
+                )
+
+                thread = await self.lolz_api.get_thread(
+                    thread_id=self.config.lolz_thread_id
+                )
+                can_bump = await self.lolz_api.can_bump(thread=thread)
+
+                if can_bump:
+                    try:
+                        await self.lolz_api.bump_thread(
+                            thread_id=self.config.lolz_thread_id
+                        )
+
+                    except Exception as e:
+                        logger.error(
+                            f"Ошибка поднятия темы {self.config.lolz_thread_id}, пропускаю: {e}"
+                        )
+                else:
+                    logger.info("Тему нельзя поднять.")
+
+                logger.info(f"Ожидание {self.config.bump_check_interval} секунд...")
+                await asyncio.sleep(self.config.bump_check_interval)
+
+            except KeyboardInterrupt:
+                logger.info("Получен сигнал прерывания (Ctrl+C).")
+                break
+
+            except Exception as e:
+                logger.exception(f"Критическая ошибка в цикле поднятия темы: {e}")
+                await asyncio.sleep(self.config.bump_check_interval)
+
+    async def _captcha_loop(self):
+        """Loop to periodically check and update captcha text"""
+        while True:
+            try:
+                logger.info(
+                    f"Проверка обновления капчи для темы {self.config.lolz_thread_id}..."
+                )
+
+                await self.update_captcha()
+
+                logger.info(
+                    f"Ожидание {self.config.captcha_check_interval} секунд до следующей проверки капчи..."
+                )
+                await asyncio.sleep(self.config.captcha_check_interval)
+
+            except KeyboardInterrupt:
+                logger.info("Получен сигнал прерывания (Ctrl+C).")
+                break
+
+            except Exception as e:
+                logger.exception(f"Критическая ошибка в цикле обновления капчи: {e}")
+                await asyncio.sleep(self.config.captcha_check_interval)
+
     async def start(self):
         is_first_login = not os.path.exists(f"{self.SESSION_NAME}.session")
 
@@ -305,9 +435,15 @@ class TelegramStarsBot:
                     api_hash=self.config.api_hash,
                 )
 
-                await self.client.start()
-                await self.parse_existing_posts()
-                await self.client.stop()
+                try:
+                    await self.client.start()
+                    await self.parse_existing_posts()
+                except Exception as e:
+                    logger.error(f"Ошибка при парсинге существующих постов: {e}")
+                    raise
+                finally:
+                    if self.client and self.client.is_connected:
+                        await self.client.stop()
 
                 logger.info(
                     "Парсинг завершен. Все существующие посты добавлены в обработанные."
@@ -334,10 +470,34 @@ class TelegramStarsBot:
 
             logger.info(f"Проверка начинается со страницы: {self.start_page}")
             logger.info("Бот в работе. Для остановки нажмите Ctrl+C.")
-            await self._main_loop()
+
+            # _main_loop - Основной цикл для остлеживания темы
+            # _bump_loop - Цикл для авто-поднятия темы
+            # _captcha_loop - Цикл для обновления капчи
+
+            if self.config.enable_captcha:
+                await self.update_captcha()
+
+            # Gather all enabled loops
+            tasks = [self._main_loop()]
+
+            if self.config.enable_auto_bump:
+                tasks.append(self._bump_loop())
+
+            if self.config.enable_captcha:
+                tasks.append(self._captcha_loop())
+
+            await asyncio.gather(*tasks)
+
+        except Exception as e:
+            logger.error(f"Ошибка в главном процессе бота: {e}")
+            raise
 
         finally:
             if self.client and self.client.is_connected:
-                await self.client.stop()
+                try:
+                    await self.client.stop()
+                except Exception as e:
+                    logger.error(f"Ошибка при остановке клиента: {e}")
 
             logger.info("Бот остановлен.")

storage/captcha.txt

@@ -0,0 +1,2 @@
+[B]Напишите ответ:[/B]
+сколько будет 20 + 20? [I][COLOR=rgb(80, 80, 78)](Капча меняется раз в месяц)[/COLOR][/I]