Delete bot_modules

bot_modules/__init__.py

@@ -1,2 +0,0 @@
-# bot_modules package
- 

bot_modules/network_patch.py

@@ -1,83 +0,0 @@
-"""
-Блок 0: Глобальные сетевые патчи для HF Spaces.
-
-Решает 3 инфраструктурные проблемы:
-1. Отсутствие системных CA-сертификатов → SSL-ошибки при HTTPS-запросах
-2. Корпоративные прокси в env → aiohttp их игнорирует по умолчанию
-3. Блокировка api.telegram.org в РФ → aiogram не может отправлять сообщения
-
-Патчи применяются как side-effect при импорте модуля.
-Импортировать ДО создания любых aiohttp-сессий (aiogram, YooKassa, etc.).
-
-ВНИМАНИЕ: Monkey-patching — это крайняя мера. Используется только потому,
-что HF Spaces не предоставляет системных CA-сертификатов, а aiogram
-не позволяет явно указать SSL-контекст для внутренних запросов.
-"""
-import os
-import ssl
-import logging
-
-import certifi
-import aiohttp
-
-
-# ═══════════════════════════════════════════════════════════════════
-# SSL-контекст для внешних HTTPS-запросов (OpenAI, Telegram API)
-# ═══════════════════════════════════════════════════════════════════
-# НЕ подменяем глобальный ssl._create_default_https_context — это ломает PostgreSQL
-custom_ssl = ssl.create_default_context(cafile=certifi.where())
-custom_ssl.check_hostname = True
-custom_ssl.verify_mode = ssl.CERT_REQUIRED
-
-
-# ═══════════════════════════════════════════════════════════════════
-# Патч 1: TCPConnector — certifi SSL для всех HTTPS-соединений
-# ═══════════════════════════════════════════════════════════════════
-# HF Spaces не имеет системных CA-сертификатов.
-# Без этого патча все HTTPS-запросы падают с SSLCertVerificationError.
-# Условие `ssl is not False` сохраняет возможность явно отключить SSL
-# для HTTP-запросов (например, к локальным сервисам).
-_orig_tcp_init = aiohttp.TCPConnector.__init__
-
-
-def _patched_tcp_init(self, *args, **kwargs):
-    if kwargs.get('ssl') is not False:
-        kwargs['ssl'] = custom_ssl
-    _orig_tcp_init(self, *args, **kwargs)
-
-
-aiohttp.TCPConnector.__init__ = _patched_tcp_init
-
-
-# ═══════════════════════════════════════════════════════════════════
-# Патч 2: ClientSession — trust_env для прокси из окружения
-# ═══════════════════════════════════════════════════════════════════
-# HF Spaces может проксировать трафик через HTTP_PROXY/HTTPS_PROXY.
-# По умолчанию aiohttp игнорирует эти переменные.
-# trust_env=True заставляет aiohttp читать прокси из env.
-_orig_session_init = aiohttp.ClientSession.__init__
-
-
-def _patched_session_init(self, *args, **kwargs):
-    kwargs['trust_env'] = True
-    _orig_session_init(self, *args, **kwargs)
-
-
-aiohttp.ClientSession.__init__ = _patched_session_init
-
-
-# Патч 3: _request — переадресация ИСХОДЯЩИХ запросов к api.telegram.org через прокси
-# ВАЖНО: Проверяем метод и хост, чтобы не сломать входящие webhook-запросы к нашему серверу
-_orig_request = aiohttp.ClientSession._request
-async def _patched_request(self, method, url, *args, **kwargs):
-    proxy_server = os.getenv("TELEGRAM_API_SERVER")
-    # Защита: патчим только исходящие POST/GET к Telegram API от имени бота
-    if proxy_server and isinstance(url, (str, aiohttp.client.URL)) and "api.telegram.org" in str(url) and str(method).upper() in ("POST", "GET"):
-        clean_proxy = proxy_server.strip().rstrip('/')
-        # Убеждаемся, что это не внутренний редирект нашего сервера
-        if "bot" in str(url): 
-            str_url = str(url).replace("https://api.telegram.org", clean_proxy)
-            logging.info(f"🔀 Умная переадресация запроса aiogram через прокси ➡️ {str_url[:80]}...")
-            url = str_url
-    return await _orig_request(self, method, url, *args, **kwargs)
-aiohttp.ClientSession._request = _patched_request

bot_modules/utils.py

@@ -1,126 +0,0 @@
-"""
-Утилиты: блокировки, защита от спама, санитизация, фоновые задачи.
-
-Содержит переиспользуемые компоненты, не привязанные к конкретной
-доменной области (БД, AI, хендлеры). Все сущности — чистая логика
-без побочных эффектов при импорте.
-"""
-import asyncio
-import logging
-import re
-from datetime import date
-from typing import Dict
-
-
-# ═══════════════════════════════════════════════════════════════════
-# USER LOCK MANAGER (Thread-safe, без утечки памяти)
-# ═══════════════════════════════════════════════════════════════════
-class UserLockManager:
-    """Безопасный менеджер блокировок per-user с атомарным созданием лока.
-    
-    Бизнес-контекст: предотвращает Race Condition при параллельной генерации 
-    документов одним пользователем. Глобальный лок защищает dict _locks 
-    от одновременного создания двух asyncio.Lock для одного user_id.
-    """
-    def __init__(self):
-        self._locks: Dict[int, asyncio.Lock] = {}
-        self._global_lock = asyncio.Lock()
-
-    async def get(self, user_id: int) -> asyncio.Lock:
-        """Атомарно получает или создаёт asyncio.Lock для user_id.
-        
-        Использует _global_lock для исключения race condition при создании.
-        Все вызовы должны использовать await: lock = await user_lock_manager.get(user_id)
-        """
-        async with self._global_lock:
-            if user_id not in self._locks:
-                self._locks[user_id] = asyncio.Lock()
-            return self._locks[user_id]
-
-    async def release(self, user_id: int):
-        """Очистка лока из памяти ТОЛЬКО если он не захвачен.
-        Вызывать строго ПОСЛЕ выхода из async with lock."""
-        async with self._global_lock:
-            if user_id in self._locks and not self._locks[user_id].locked():
-                del self._locks[user_id]
-
-
-# ═══════════════════════════════════════════════════════════════════
-# GLOBAL SPAM PROTECTOR (Free-tier daily limit)
-# ═══════════════════════════════════════════════════════════════════
-class GlobalSpamProtector:
-    """Глобальный дневной лимит на бесплатные генерации.
-    
-    Бизнес-контекст: защита от API-абуза и ботов, снижает TCO на OpenAI-токены.
-    При превышении лимита — graceful degradation с понятным сообщением юзеру.
-    """
-    def __init__(self, daily_limit: int = 1000):
-        self.daily_limit = daily_limit
-        self.current_count = 0
-        self.current_date = date.today()
-
-    def can_generate(self) -> bool:
-        today = date.today()
-        if today != self.current_date:
-            self.current_date = today
-            self.current_count = 0
-
-        if self.current_count >= self.daily_limit:
-            return False
-
-        self.current_count += 1
-        return True
-
-
-# ═══════════════════════════════════════════════════════════════════
-# OPENAI SEMAPHORE (ограничение конкурентных запросов)
-# ═══════════════════════════════════════════════════════════════════
-# Глобальный семафор для ограничения конкурентных запросов к OpenAI API.
-# Бизнес-контекст: защита от cascading failure при всплесках нагрузки,
-# предотвращает исчерпание лимитов RPM и connection pool httpx.
-openai_semaphore = asyncio.Semaphore(10)
-
-
-# ═══════════════════════════════════════════════════════════════════
-# MEMORY SYSTEM HELPERS (Sanitize)
-# ═══════════════════════════════════════════════════════════════════
-def _sanitize_memory_key(key: str) -> str:
-    """Strict snake_case sanitize: только a-z, 0-9, _."""
-    if not key:
-        return ""
-    key = key.lower().strip()
-    sanitized = re.sub(r'[^a-z0-9_]', '_', key)
-    sanitized = re.sub(r'_+', '_', sanitized)
-    sanitized = sanitized.strip('_')
-    return sanitized[:50]
-
-
-def _sanitize_memory_value(value: str) -> str:
-    """Удаление управляющих символов и truncation до 200 символов."""
-    if not value:
-        return ""
-    value = value.strip()
-    value = re.sub(r'[\x00-\x08\x0b\x0c\x0e-\x1f\x7f]', '', value)
-    return value[:200]
-
-
-# ═══════════════════════════════════════════════════════════════════
-# SAFE BACKGROUND TASK (обёртка для asyncio.create_task)
-# ═══════════════════════════════════════════════════════════════════
-def safe_background_task(coro, name: str = "background_task"):
-    """Обёртка для asyncio.create_task с гарантированным логированием исключений.
-    
-    Бизнес-контекст: предотвращает silent failures фоновых задач
-    (memory extraction, cleanup), которые иначе теряли бы traceback.
-    """
-    task = asyncio.create_task(coro)
-    def _on_task_done(t):
-        try:
-            t.result()
-        except asyncio.CancelledError:
-            pass
-        except Exception as e:
-            logging.error(f"❌ [Background Task '{name}'] Необработанное исключение: {e}", exc_info=True)
-    task.add_done_callback(_on_task_done)
-    return task
-