Исправлен субскрпи

handlers/__init__.py

@@ -2,6 +2,15 @@ from .start import router as start_router
 from .profile import router as profile_router
 from .subscriptions import router as subscriptions_router
 from .support import router as support_router
+from .referrals import router as referrals_router
 
-# Экспортируем все маршрутизаторы
+# Список всех роутеров бота
-routers = [start_router,profile_router,subscriptions_router,support_router]
+routers = [
+    start_router,
+    profile_router,
+    subscriptions_router,
+    support_router,
+    referrals_router,
+]
+
+__all__ = ["routers"]

handlers/profile.py

@@ -1,5 +1,12 @@
-from aiogram import Router, types
+# Профиль. последнее изменение 24.11.2025
-from aiogram.types import CallbackQuery
+
+from aiogram import Router, types, F
+from aiogram.types import (
+    CallbackQuery,
+    LabeledPrice,
+    Message,
+    PreCheckoutQuery,
+)
 import logging
 from datetime import datetime
 from aiogram.enums.parse_mode import ParseMode
@@ -13,6 +20,7 @@ from keyboard.keyboards import (
     confirm_popup_keyboard,
     guide_keyboard,
     balance_keyboard,
+    payment_methods_keyboard,
 )
 
 locale.setlocale(locale.LC_TIME, "ru_RU.UTF-8")
@@ -21,18 +29,24 @@ router = Router()
 logger = logging.getLogger(__name__)
 
 
-async def call_api(method, endpoint, data=None):
+async def call_api(method, endpoint, data=None, base_url=BASE_URL_FASTAPI):
     """
     Выполняет HTTP-запрос к FastAPI.
     """
-    url = f"{BASE_URL_FASTAPI}{endpoint}"
+    url = f"{base_url}{endpoint}"
     logger.info(f"Инициализация запроса: {method} {url} с данными {data}")
 
     try:
         async with aiohttp.ClientSession() as session:
-            async with session.request(method, url, json=data) as response:
+            async with session.request(
+                method,
+                url,
+                json=data,
+                headers={"Content-Type": "application/json"}
+            ) as response:
                 logger.info(
-                    f"Получен ответ от {url}: статус {response.status}")
+                    f"Получен ответ от {url}: статус {response.status}"
+                )
 
                 if response.status in {200, 201}:
                     result = await response.json()
@@ -54,7 +68,7 @@ async def call_api(method, endpoint, data=None):
 async def profile_callback_handler(callback: CallbackQuery):
     """
     Профиль пользователя.
-    Логика работы с API сохранена, переписан только текст/визуал.
+    Логика работы с API сохранена, изменён только текст/визуал.
     """
     try:
         user_data = await call_api("GET", f"/user/{callback.from_user.id}")
@@ -65,55 +79,47 @@ async def profile_callback_handler(callback: CallbackQuery):
             await callback.answer()
             return
 
-        sub_data = await call_api("GET", f"/subscription/{user_data['telegram_id']}/last")
+        # Последняя подписка пользователя
+        sub_data = await call_api(
+            "GET", f"/subscription/{user_data['telegram_id']}/last"
+        )
         if sub_data == "ERROR" or not isinstance(sub_data, dict):
             sub_data = None
 
-        balance_text = f"💰 Баланс: {user_data['balance']} ₽"
+        username = callback.from_user.username or "-"
+        balance = user_data.get("balance", 0)
 
-        username = callback.from_user.username or "пользователь"
+        # Статус подписки: Активна / Нет активных
+        sub_status = "⚫ Нет активных"
 
-        # Нет подписки
+        if sub_data:
-        if not sub_data:
+            end_date_str = sub_data.get("end_date")  # Исправил
-            text = (
+            if end_date_str:
-                f"📜 Профиль {username}\n\n"
+                try:
-                f"{balance_text}\n\n"
+                    is_expired = (
-                "У тебя пока нет активной подписки.\n"
+                        datetime.fromisoformat(end_date_str) < datetime.now()
-                "Пополняй баланс и подключай тариф Lark, чтобы получить статус 🐣 или 🦅."
+                    )
-            )
+                except ValueError:
-        else:
+                    is_expired = True
-            expiry_date = sub_data.get("end_date")
-            formatted_date = (
-                datetime.fromisoformat(expiry_date).strftime("%d %B %Y г.")
-                if expiry_date
-                else None
-            )
-            is_expired = (
-                datetime.fromisoformat(expiry_date) < datetime.now()
-                if expiry_date
-                else True
-            )
-            status_icon = "✖️" if is_expired else "☑️"
-            profile_status = "🦅" if "Pro" in sub_data.get("plan", "") else "🐣"
-
-            if not is_expired and formatted_date:
-                sub_text = (
-                    f"Подписка активна до {formatted_date} {status_icon}\n"
-                    f"Текущий статус: {profile_status}"
-                )
             else:
-                sub_text = (
+                is_expired = True
-                    f"Подписка неактивна {status_icon}\n"
-                    "Ты можешь продлить её в разделе подписок."
-                )
 
-            text = (
+            if not is_expired:
-                f"📜 Профиль {username} {profile_status}\n\n"
+                sub_status = "🟢 Активна"
-                f"{sub_text}\n\n"
-                f"{balance_text}"
-            )
 
-        await callback.message.edit_text(text, reply_markup=account_keyboard())
+        text = (
+            "🥚 <b>Профиль</b>\n\n"
+            f"Пользователь: @{username}\n"
+            f"Баланс: {balance} ₽\n"
+            f"Статус подписки: {sub_status}\n\n"
+            "Выберите действие:"
+        )
+
+        await callback.message.edit_text(
+            text,
+            parse_mode=ParseMode.HTML,
+            reply_markup=account_keyboard(),
+        )
     except Exception as e:
         logger.exception(f"Ошибка в обработчике профиля: {e}")
         await callback.message.answer("Произошла ошибка. Попробуйте позже.")
@@ -124,20 +130,11 @@ async def profile_callback_handler(callback: CallbackQuery):
 @router.callback_query(lambda callback: callback.data == "balance")
 async def balance_callback_handler(callback: CallbackQuery):
     """
-    Обработчик callback_query для баланса.
+    При нажатии «Пополнить баланс» показываем выбор суммы пополнения.
     """
-    user_data = await call_api("GET", f"/user/{callback.from_user.id}")
-    if not user_data:
-        await callback.message.answer(
-            "Произошла ошибка, попробуйте позже или свяжитесь с администрацией."
-        )
-        await callback.answer()
-        return
-
     await callback.message.edit_text(
-        f"💰 Текущий баланс: {user_data['balance']} ₽\n\n"
+        "💳 Выберите сумму пополнения:",
-        "Выбери сумму, на которую хочешь пополнить счёт.",
+        reply_markup=popup_keyboard(),
-        reply_markup=balance_keyboard(),
     )
     await callback.answer()
 
@@ -175,7 +172,9 @@ async def tranhist_callback_handler(callback: CallbackQuery):
         return
 
     try:
-        transactions = await call_api("GET", f"/user/{user_data['telegram_id']}/transactions")
+        transactions = await call_api(
+            "GET", f"/user/{user_data['telegram_id']}/transactions"
+        )
         if not transactions:
             await callback.message.edit_text(
                 "У вас нет транзакций.", reply_markup=tranhist_keyboard()
@@ -200,7 +199,9 @@ async def tranhist_callback_handler(callback: CallbackQuery):
         )
     except Exception as e:
         logger.error(f"Ошибка обработки транзакций: {e}")
-        await callback.message.edit_text("Произошла ошибка. Попробуйте позже.")
+        await callback.message.edit_text(
+            "Произошла ошибка. Попробуйте позже."
+        )
     finally:
         await callback.answer()
 
@@ -208,25 +209,210 @@ async def tranhist_callback_handler(callback: CallbackQuery):
 @router.callback_query(lambda callback: callback.data.startswith("popup:"))
 async def popup_confirm_callback_handler(callback: CallbackQuery):
     """
-    Обработчик подтверждения пополнения баланса.
+    После выбора суммы показываем варианты оплаты.
+    Разрешены только суммы 200, 300, 600, 1000 ₽.
     """
-    data = callback.data.split(":")
+    try:
-    popup_info = data[1]
+        _, amount_raw = callback.data.split(":", maxsplit=1)
-    result = await call_api(
+        amount = int(float(amount_raw))
-        "POST",
+    except Exception:
-        f"/user/{callback.from_user.id}/balance/{float(popup_info)}",
+        await callback.message.answer("Некорректная сумма пополнения.")
-    )
+        await callback.answer()
-    if result == "ERROR":
+        return
+
+    if amount not in {200, 300, 600, 1000}:
         await callback.message.answer(
-            "Произошла ошибка, попробуйте позже или свяжитесь с администрацией."
+            "Эта сумма пополнения недоступна. Выбери вариант от 200 до 1000 ₽."
         )
         await callback.answer()
         return
 
-    text = f"✅ Баланс пополнен на {popup_info} ₽. Спасибо, что остаёшься с Lark."
+    text = (
-    await callback.message.edit_text(
+        f"💰 Сумма пополнения: {amount} ₽\n\n"
-        text=text, reply_markup=confirm_popup_keyboard()
+        "Выбери способ оплаты:"
     )
+
+    await callback.message.edit_text(
+        text=text,
+        reply_markup=payment_methods_keyboard(amount),
+    )
+    await callback.answer()
+
+
+# ===== Telegram Stars =====
+
+@router.callback_query(lambda callback: callback.data.startswith("method_stars_"))
+async def method_stars_handler(callback: CallbackQuery):
+    """
+    Оплата через Telegram Stars.
+    Формируем invoice прямо из бота, без отдельного биллинга.
+    """
+    try:
+        amount_str = callback.data.split("_")[-1]
+        amount_rub = int(float(amount_str))
+    except Exception:
+        await callback.message.answer("Некорректная сумма для оплаты.")
+        await callback.answer()
+        return
+
+    # Внутренний payload, чтобы при успешной оплате понять, что это пополнение баланса
+    payload = f"stars_topup:{callback.from_user.id}:{amount_rub}"
+
+    # 1 ₽ == 1 Star, если нужна другая конвертация — меняй тут
+    stars_amount = amount_rub
+
+    prices = [
+        LabeledPrice(
+            label=f"Пополнение баланса на {amount_rub} ₽",
+            amount=stars_amount,
+        )
+    ]
+
+    try:
+        await callback.message.answer_invoice(
+            title="Пополнение баланса Lark VPN",
+            description=(
+                f"Пополнение баланса на {amount_rub} ₽ через Telegram Stars.\n\n"
+                "После успешной оплаты баланс будет зачислен автоматически."
+            ),
+            payload=payload,
+            provider_token="",  # для Stars провайдер пустой
+            currency="XTR",
+            prices=prices,
+        )
+        await callback.answer()
+    except Exception as e:
+        logger.exception(f"Ошибка при отправке invoice Telegram Stars: {e}")
+        await callback.message.answer(
+            "Не удалось создать счёт в Telegram Stars. Попробуй позже или выбери другой способ оплаты."
+        )
+        await callback.answer()
+
+
+@router.callback_query(lambda callback: callback.data.startswith("method_ykassa_"))
+async def method_ykassa_handler(callback: CallbackQuery):
+    """
+    Обработчик оплаты через YooKassa.
+    """
+    amount = callback.data.split("_")[-1]
+
+    # Сразу отвечаем на callback, чтобы Telegram не считал запрос "старым"
+    try:
+        await callback.answer()
+    except Exception:
+        # Если по какой-то причине уже отвечали — просто игнорируем
+        pass
+
+    # Формируем URL с query parameters вместо JSON body
+    endpoint = (
+        f"/billing/payments/init?"
+        f"user_id={callback.from_user.id}&amount={float(amount)}&provider=yookassa"
+    )
+
+    logger.info(f"Отправка запроса на инициализацию платежа: {endpoint}")
+
+    # Отправляем POST запрос с пустым телом (параметры в URL)
+    result = await call_api("POST", endpoint, None, "http://billing:8000")
+
+    # Биллинг вообще не ответил/упал
+    if result == "ERROR" or not isinstance(result, dict):
+        await callback.message.edit_text(
+            "❌ Произошла ошибка при создании платежа. Попробуйте позже."
+        )
+        return
+
+    # Биллинг вернул ошибку (success = False)
+    if not result.get("success", False):
+        error_msg = (
+            result.get("error")
+            or result.get("detail")
+            or "Неизвестная ошибка"
+        )
+        await callback.message.edit_text(f"❌ Ошибка: {error_msg}")
+        return
+
+    payment_url = result.get("confirmation_url", "#")
+    payment_id = result.get("payment_id", "")
+
+    await callback.message.edit_text(
+        f"💵 <b>Оплата через YooKassa</b>\n\n"
+        f"💰 Сумма: <code>{amount}</code> руб\n"
+        f"📋 ID платежа: <code>{payment_id}</code>\n\n"
+        f"➡️ <a href='{payment_url}'>Перейти к оплате</a>\n\n"
+        f"<i>После оплаты нажмите кнопку 'Проверить оплату'</i>",
+        parse_mode=ParseMode.HTML,
+        disable_web_page_preview=True,
+        reply_markup=types.InlineKeyboardMarkup(
+            inline_keyboard=[[
+                types.InlineKeyboardButton(
+                    text="🔄 Проверить оплату",
+                    callback_data=f"check_payment:{payment_id}",
+                )
+            ]]
+        ),
+    )
+
+    await callback.answer()
+
+
+@router.callback_query(lambda callback: callback.data.startswith("method_crypto_"))
+async def method_crypto_handler(callback: CallbackQuery):
+    """
+    Оплата через CryptoBot.
+    """
+    amount = callback.data.split("_")[-1]
+
+    # Сразу отвечаем на callback, чтобы избежать таймаута
+    try:
+        await callback.answer()
+    except Exception:
+        pass
+
+    endpoint = (
+        f"/billing/payments/init?"
+        f"user_id={callback.from_user.id}&amount={float(amount)}&provider=cryptobot"
+    )
+
+    logger.info(f"Отправка запроса на инициализацию платежа: {endpoint}")
+
+    result = await call_api("POST", endpoint, None, "http://billing:8000")
+
+    if result == "ERROR" or not isinstance(result, dict):
+        await callback.message.edit_text(
+            "❌ Произошла ошибка при создании платежа. Попробуйте позже."
+        )
+        return
+
+    if not result.get("success", False):
+        error_msg = (
+            result.get("error")
+            or result.get("detail")
+            or "Неизвестная ошибка"
+        )
+        await callback.message.edit_text(f"❌ Ошибка: {error_msg}")
+        return
+
+    payment_url = result.get("confirmation_url", "#")
+    payment_id = result.get("payment_id", "")
+
+    await callback.message.edit_text(
+        f"💵 <b>Оплата через Сryptobot</b>\n\n"
+        f"💰 Сумма: <code>{amount}</code> руб\n"
+        f"📋 ID платежа: <code>{payment_id}</code>\n\n"
+        f"➡️ <a href='{payment_url}'>Перейти к оплате</a>\n\n"
+        f"<i>После оплаты нажмите кнопку 'Проверить оплату'</i>",
+        parse_mode=ParseMode.HTML,
+        disable_web_page_preview=True,
+        reply_markup=types.InlineKeyboardMarkup(
+            inline_keyboard=[[
+                types.InlineKeyboardButton(
+                    text="🔄 Проверить оплату",
+                    callback_data=f"check_payment:{payment_id}",
+                )
+            ]]
+        ),
+    )
+
     await callback.answer()
 
 
@@ -240,3 +426,87 @@ async def guide_callback_handler(callback: CallbackQuery):
         reply_markup=guide_keyboard(),
     )
     await callback.answer()
+
+
+# ===== Служебные хендлеры для платежей Telegram Stars =====
+
+@router.pre_checkout_query()
+async def pre_checkout_query_handler(pre_checkout_query: PreCheckoutQuery):
+    """
+    Обязательный шаг для Telegram Payments:
+    подтверждаем pre_checkout_query, иначе платёж не пройдёт.
+    """
+    try:
+        await pre_checkout_query.bot.answer_pre_checkout_query(
+            pre_checkout_query.id,
+            ok=True,
+        )
+    except Exception as e:
+        logger.exception(f"Ошибка при answer_pre_checkout_query: {e}")
+
+
+async def _process_stars_topup(message: Message):
+    """
+    Логика зачисления средств после успешной оплаты Stars.
+    """
+    sp = message.successful_payment
+    if not sp:
+        return
+
+    payload = sp.invoice_payload or ""
+    parts = payload.split(":")
+    if len(parts) != 3 or parts[0] != "stars_topup":
+        logger.info(
+            "successful_payment не относится к пополнению баланса Stars.")
+        return
+
+    _, telegram_id_str, amount_str = parts
+
+    try:
+        amount_rub = int(amount_str)
+    except ValueError:
+        # На всякий случай fallback к total_amount
+        amount_rub = sp.total_amount
+
+    data = {
+        "telegram_id": telegram_id_str,
+        "amount": amount_rub,
+        "currency": sp.currency,
+        "provider": "telegram_stars",
+        "telegram_payment_charge_id": sp.telegram_payment_charge_id,
+    }
+
+    logger.info(
+        f"Обработка успешного платежа Telegram Stars: "
+        f"user={telegram_id_str}, amount={amount_rub}, currency={sp.currency}"
+    )
+
+    result = await call_api("POST", "/user/deposit", data)
+
+    if result == "ERROR" or result is None:
+        await message.answer(
+            "⭐ Оплата через Telegram Stars прошла, но не удалось автоматически обновить баланс.\n"
+            "Если баланс не изменился — напиши, пожалуйста, в поддержку и укажи время платежа."
+        )
+        return
+
+    await message.answer(
+        f"⭐ Оплата через Telegram Stars успешно проведена.\n"
+        f"На твой баланс зачислено {amount_rub} ₽."
+    )
+
+
+@router.message(F.successful_payment)
+async def successful_payment_handler(message: Message):
+    """
+    Глобальный хендлер успешных платежей.
+    Сейчас используем только для пополнения баланса через Stars.
+    """
+    try:
+        await _process_stars_topup(message)
+    except Exception as e:
+        logger.exception(f"Ошибка при обработке successful_payment: {e}")
+        await message.answer(
+            "Оплата прошла, но произошла ошибка при обработке. "
+            "Если баланс не изменился — напиши, пожалуйста, в поддержку."
+        )

handlers/referrals.py

@@ -0,0 +1,63 @@
+from aiogram import Router, types
+from aiogram.filters import Command
+from aiogram.enums.parse_mode import ParseMode
+import logging
+
+from .start import call_api
+
+router = Router()
+logger = logging.getLogger(__name__)
+
+
+async def _build_referral_text(bot, user_id: int) -> str:
+    me = await bot.get_me()
+    bot_username = me.username or "LarkVPN_bot"
+
+    link = f"https://t.me/{bot_username}?start=ref_{user_id}"
+
+    invited_count = "—"
+    try:
+        data = await call_api("GET", f"/user/{user_id}/referrals")
+        if isinstance(data, dict):
+            invited_count = str(data.get("invited_count", 0))
+    except Exception as e:
+        logger.exception(
+            f"Ошибка при получении количества рефералов для {user_id}: {e}"
+        )
+
+    text = (
+        "👥 <b>Реферальная программа</b>\n\n"
+        "Зови друзей в Lark VPN и получай бонусы на баланс.\n\n"
+        f"🔗 Твоя ссылка:\n<code>{link}</code>\n\n"
+        f"👤 Приглашено: {invited_count}\n\n"
+    )
+    return text
+
+
+@router.message(Command("referrals"))
+async def referrals_command(message: types.Message):
+    logger.info(f"Получена команда /referrals от {message.from_user.id}")
+    try:
+        text = await _build_referral_text(message.bot, message.from_user.id)
+        await message.answer(text, parse_mode=ParseMode.HTML)
+    except Exception as e:
+        logger.exception(f"Ошибка в обработчике /referrals: {e}")
+        await message.answer("Произошла ошибка. Попробуй позже.")
+
+
+@router.callback_query(lambda callback: callback.data == "referral")
+async def referrals_callback(callback: types.CallbackQuery):
+    try:
+        text = await _build_referral_text(
+            callback.message.bot,
+            callback.from_user.id,
+        )
+        await callback.message.edit_text(
+            text,
+            parse_mode=ParseMode.HTML,
+        )
+    except Exception as e:
+        logger.exception(f"Ошибка в обработчике callback 'referral': {e}")
+        await callback.message.answer("Произошла ошибка. Попробуй позже.")
+    finally:
+        await callback.answer()

handlers/start.py

@@ -1,90 +1,162 @@
 from aiogram import Router, types
-from aiogram.filters import Command
 from aiogram.types import Message, CallbackQuery
+from aiogram.filters import Command
+from aiogram.enums.parse_mode import ParseMode
 import logging
-from instences.config import BASE_URL_FASTAPI
 import aiohttp
+
+from instences.config import BASE_URL_FASTAPI
 from keyboard.keyboards import main_keyboard
 
 router = Router()
 logger = logging.getLogger(__name__)
 
 
-async def call_api(method, endpoint, data=None):
+async def call_api(method: str, endpoint: str, data: dict | None = None):
     """
-    Выполняет HTTP-запрос к FastAPI.
+    Мини-обёртка для запросов к backend API.
-    :param method: HTTP метод (GET, POST, и т.д.)
-    :param endpoint: конечная точка API
-    :param data: тело запроса (если необходимо)
-    :return: JSON-ответ или "ERROR" при неуспехе
     """
     url = f"{BASE_URL_FASTAPI}{endpoint}"
-    logger.info(f"Инициализация запроса: {method} {url} с данными {data}")
+    logger.info(f"API {method} {url} data={data}")
 
     try:
         async with aiohttp.ClientSession() as session:
-            async with session.request(method, url, json=data) as response:
+            async with session.request(method, url, json=data) as resp:
-                logger.info(
+                logger.info(f"API response {resp.status} {resp.reason}")
-                    f"Получен ответ от {url}: статус {response.status}")
+                if resp.status in {200, 201}:
-
+                    return await resp.json()
-                if response.status in {200, 201}:
+                if resp.status in {400, 404}:
-                    result = await response.json()
+                    try:
-                    logger.debug(f"Ответ JSON: {result}")
+                        return await resp.json()
-                    return result
+                    except Exception:
-                if response.status == 404:
+                        return None
-                    logger.debug(f"Код {response.status}, возвращаю ничего")
+                logger.error(f"Unexpected status {resp.status}: {await resp.text()}")
-                    return None
-                logger.error(
-                    f"Ошибка в запросе: статус {response.status}, причина {response.reason}")
                 return "ERROR"
     except Exception as e:
-        logger.exception(f"Исключение при выполнении запроса к {url}: {e}")
+        logger.exception(f"API exception {url}: {e}")
         return "ERROR"
 
 
 def _welcome_text(username: str | None) -> str:
-    uname = username or "птенец"
+    """
-    return (
+    Текст приветствия в /start и в главном меню.
-        f"🪽 Добро пожаловать в Lark VPN, {uname}!\n\n"
+    """
-        "Здесь ты получаешь стабильный доступ к TikTok, YouTube, Discord, Instagram "
+    return "🥚 Lark Security\n\nВыберите действие из меню ниже."
-        "и другим сервисам без ограничений.\n\n"
+
-        "1️⃣ Пополни баланс\n"
+
-        "2️⃣ Выбери подходящий тариф\n"
+def _parse_referrer_id(message: Message) -> int | None:
-        "3️⃣ Подключай конфиг на своих устройствах и забудь про блокировки.\n\n"
+    """
-        "Следи за акциями и розыгрышами в канале:\n"
+    Достаём ref_<telegram_id> из /start.
-        "https://t.me/+0z5xqn3F1m02OTJi\n\n"
+
-        "Lark держит связь. 🐣🦅"
+    Примеры:
-    )
+      /start
+      /start ref_123456789
+    """
+    text = message.text or ""
+    parts = text.split(maxsplit=1)
+    if len(parts) < 2:
+        return None
+
+    arg = parts[1].strip()
+    if not arg.startswith("ref_"):
+        return None
+
+    raw_id = arg[4:]
+    if not raw_id.isdigit():
+        return None
+
+    try:
+        return int(raw_id)
+    except ValueError:
+        return None
 
 
 @router.message(Command("start"))
 async def start_command(message: Message):
     """
-    Обработчик команды /start.
+    /start c обработкой реферального параметра.
-    Визуал и текст — обновлены, логика работы с API не тронута.
+
+    Логика:
+    - проверяем, есть ли пользователь в БД по telegram_id;
+    - если нет — создаём /user/create;
+    - если есть корректный ref_ и пользователь новый — вызываем
+      /user/{referrer_id}/add_referral с invited_id = telegram_id.
     """
+    user_id = message.from_user.id
+    username = message.from_user.username
+    referrer_id = _parse_referrer_id(message)
+
     logger.info(
-        f"Получена команда /start от пользователя: "
+        f"[start] Команда /start от {user_id} (@{username}), "
-        f"{message.from_user.id} ({message.from_user.username})"
+        f"text={message.text!r}, referrer_id={referrer_id}"
     )
 
     try:
-        user_data = await call_api("GET", f"/user/{message.from_user.id}")
+        existing = await call_api("GET", f"/user/{user_id}")
-        if not user_data:
+        user_exists = isinstance(
-            logger.debug(
+            existing, dict) and existing.get("id") is not None
-                "Пользователь не найден в базе, создаем новую запись.")
+        if not user_exists:
-            await call_api("POST", "/user/create", {"telegram_id": message.from_user.id})
+            logger.debug(f"[start] Пользователь {user_id} не найден, создаю.")
+            create_result = await call_api(
+                "POST",
+                "/user/create",
+                {"telegram_id": user_id},
+            )
+            if create_result == "ERROR":
+                logger.error(
+                    f"[start] Не удалось создать пользователя {user_id} в БД"
+                )
+
+        if referrer_id is not None:
+            if referrer_id == user_id:
+                logger.info(
+                    f"[start] Пользователь {user_id} попытался зайти "
+                    f"по своей реферальной ссылке."
+                )
+                await message.answer(
+                    "Нельзя переходить по своей же реферальной ссылке."
+                )
+
+            elif user_exists:
+                logger.info(
+                    f"[start] Пользователь {user_id} уже есть в БД, "
+                    f"реферальная ссылка {referrer_id} не сработает."
+                )
+                await message.answer(
+                    "Вы уже зарегистрированы в боте, "
+                    "реферальная ссылка не сработает."
+                )
+
+            else:
+                payload = {
+                    "invited_id": user_id,
+                }
+                logger.info(
+                    f"[start] Фиксирую реферала в бекенде: "
+                    f"referrer_id={referrer_id}, payload={payload}"
+                )
+                result = await call_api(
+                    "POST",
+                    f"/user/{referrer_id}/add_referral",
+                    payload,
+                )
+                if result == "ERROR":
+                    logger.error(
+                        f"[start] Ошибка при фиксации реферала через "
+                        f"/user/{referrer_id}/add_referral: referrer={referrer_id}, "
+                        f"invited={user_id}"
+                    )
+                await message.answer("Вы вошли по реферальной ссылке.")
 
-        logger.debug("Отправка приветственного сообщения пользователю.")
         await message.answer(
-            _welcome_text(message.from_user.username),
+            _welcome_text(username),
             reply_markup=main_keyboard(),
         )
-        logger.info("Приветственное сообщение отправлено.")
+        logger.info(f"[start] Главное меню отправлено пользователю {user_id}.")
+
     except Exception as e:
         logger.exception(
-            f"Ошибка при обработке команды /start для пользователя "
+            f"[start] Ошибка при обработке /start для пользователя {user_id}: {e}"
-            f"{message.from_user.id}: {e}"
         )
         await message.answer("Произошла ошибка. Попробуйте позже.")
 
@@ -92,24 +164,27 @@ async def start_command(message: Message):
 @router.callback_query(lambda callback: callback.data == "base")
 async def start_callback_handler(callback: CallbackQuery):
     """
-    Обработчик callback_query с data="base".
+    Callback с data="base" — возврат в главное меню.
-    Возвращает пользователя в главное меню.
     """
     try:
-        user_data = await call_api("GET", f"/user/{callback.from_user.id}")
+        user_id = callback.from_user.id
-        if not user_data:
+        username = callback.from_user.username
+        logger.info(f"[start] callback 'base' от {user_id} (@{username})")
+
+        user_data = await call_api("GET", f"/user/{user_id}")
+        if user_data in (None, "ERROR"):
             await call_api(
                 "POST",
                 "/user/create",
-                {"telegram_id": callback.from_user.id},
+                {"telegram_id": user_id},
             )
 
         await callback.message.edit_text(
-            _welcome_text(callback.from_user.username),
+            _welcome_text(username),
             reply_markup=main_keyboard(),
         )
     except Exception as e:
-        logger.exception(f"Ошибка при обработке callback с data='base': {e}")
+        logger.exception(f"[start] Ошибка при обработке callback 'base': {e}")
         await callback.message.answer("Произошла ошибка. Попробуйте позже.")
     finally:
         await callback.answer()

handlers/subscriptions.py

@@ -1,168 +1,498 @@
 from aiogram import Router, types
-import logging
-from instences.config import BASE_URL_FASTAPI
-import aiohttp
 from aiogram.enums.parse_mode import ParseMode
 from aiogram.filters import Command
-from keyboard.keyboards import tarif_Lark_pro_keyboard, tarif_Lark_keyboard, tarif_confirm_keyboard,buy_keyboard
+import logging
+from datetime import datetime
+import aiohttp
+
+from instences.config import BASE_URL_FASTAPI
+from keyboard.keyboards import (
+    buy_keyboard,
+    tarif_Lark_keyboard,
+    tarif_Lark_pro_keyboard,
+    tarif_Lark_family_keyboard,
+    tarif_confirm_keyboard,
+    subscriptions_card_keyboard,
+)
 
 router = Router()
 logger = logging.getLogger(__name__)
 
-async def call_api(method, endpoint, data=None):
+
+async def call_api(method: str, endpoint: str, data: dict | None = None):
     """
-    Выполняет HTTP-запрос к FastAPI.
+    Унифицированный вызов backend API.
     """
     url = f"{BASE_URL_FASTAPI}{endpoint}"
-    logger.info(f"Инициализация запроса: {method} {url} с данными {data}")
+    logger.info(f"API {method} {url} data={data}")
 
     try:
         async with aiohttp.ClientSession() as session:
-            async with session.request(method, url, json=data) as response:
+            async with session.request(method, url, json=data) as resp:
-                logger.info(f"Получен ответ от {url}: статус {response.status}")
+                logger.info(f"API response {resp.status} {resp.reason}")
-
+                if resp.status in {200, 201}:
-                if response.status in {200, 201}:
+                    return await resp.json()
-                    result = await response.json()
+                if resp.status in {400, 404}:
-                    logger.debug(f"Ответ JSON: {result}")
+                    # Возвращаем JSON с detail, чтобы разобрать ошибку
-                    return result
+                    try:
-                if response.status in {404,400}:
+                        return await resp.json()
-                    result = await response.json()
+                    except Exception:
-                    logger.debug(f"Код {response.status}, возвращаю {result}")
+                        return None
-                    return result
+                logger.error(f"Unexpected status {resp.status}: {await resp.text()}")
-                logger.error(f"Ошибка в запросе: статус {response.status}, причина {response.reason}")
                 return "ERROR"
     except Exception as e:
-        logger.exception(f"Исключение при выполнении запроса к {url}: {e}")
+        logger.exception(f"API exception {url}: {e}")
         return "ERROR"
 
+
 def escape_markdown_v2(text: str) -> str:
     """
-    Экранирует специальные символы для Markdown_V2.
+    Экранирует спецсимволы для Markdown_V2.
     """
-    special_chars = r"_*[]()~`>#+-=|{}.!"
+    special_chars = r"_*[]()~`>#+-=|{}.!\\"
-    for char in special_chars:
+    for ch in special_chars:
-        text = text.replace(char, f"\\{char}")
+        text = text.replace(ch, f"\\{ch}")
     return text
 
 
+def _plan_human_title(plan: str) -> str:
+    """
+    Красивое имя тарифа по plan-строке из БД.
+    """
+    if not plan:
+        return "—"
+    if plan.startswith("Lark_Standart"):
+        return "Lark Basic"
+    if plan.startswith("Lark_Pro"):
+        return "Lark Pro"
+    if plan.startswith("Lark_Family"):
+        return "Lark Family"
+    return plan
+
+
+async def _fetch_user_and_subs(telegram_id: int):
+    user = await call_api("GET", f"/user/{telegram_id}")
+    if not isinstance(user, dict):
+        return None, []
+    user_id = user.get("id") or user.get("telegram_id") or user.get("user_id")
+    if not user_id:
+        return None, []
+    subs = await call_api("GET", f"/subscriptions/{user_id}")
+    if subs == "ERROR" or not isinstance(subs, list):
+        subs = []
+    return user, subs
+
+
+async def _show_subscriptions_view(
+    msg: types.Message,
+    telegram_id: int,
+    index: int = 0,
+    edit: bool = False,
+):
+    """
+    Рендер карточки подписки: навигация + конфиг + продление.
+    """
+    user, subs = await _fetch_user_and_subs(telegram_id)
+
+    if not user:
+        text = "Не удалось получить данные пользователя. Попробуй чуть позже."
+        if edit:
+            await msg.edit_text(text)
+        else:
+            await msg.answer(text)
+        return
+
+    if not subs:
+        text = (
+            "⚪ У тебя пока нет активных подписок.\n\n"
+            "Можешь подключить тариф через меню подписок."
+        )
+        if edit:
+            await msg.edit_text(
+                text,
+                parse_mode=ParseMode.HTML,
+                reply_markup=buy_keyboard(),
+            )
+        else:
+            await msg.answer(
+                text,
+                parse_mode=ParseMode.HTML,
+                reply_markup=buy_keyboard(),
+            )
+        return
+
+    # Нормализуем индекс
+    index = max(0, min(index, len(subs) - 1))
+    sub = subs[index]
+
+    plan_title = _plan_human_title(sub.get("plan_name"))
+    end_raw = sub.get("end_date")  # Исправил
+    date_str = "—"
+    days_left = None
+    status_emoji = "🟢"
+
+    if end_raw:
+        try:
+            dt = datetime.fromisoformat(end_raw)
+            date_str = dt.strftime("%d.%m.%Y")
+            now = datetime.now(dt.tzinfo) if dt.tzinfo else datetime.now()
+            days_left = (dt.date() - now.date()).days
+            if days_left < 0:
+                status_emoji = "⚫"
+            else:
+                status_emoji = "🟢"
+        except ValueError:
+            status_emoji = "⚪"
+
+    lines = [
+        f"{status_emoji} <b>Подписка</b>",
+        f"Тариф: {plan_title}",
+    ]
+
+    if days_left is None:
+        lines.append(f"Действует до {date_str}")
+    else:
+        if days_left >= 0:
+            lines.append(f"Действует до {date_str} (ещё {days_left} дн.)")
+        else:
+            lines.append(f"Истекла {date_str}")
+
+    lines.append("")
+    lines.append(f"{index + 1} из {len(subs)}")
+
+    text = "\n".join(lines)
+
+    kb = subscriptions_card_keyboard(
+        sub_id=sub["id"],
+        index=index,
+        total=len(subs),
+    )
+
+    if edit:
+        await msg.edit_text(text, parse_mode=ParseMode.HTML, reply_markup=kb)
+    else:
+        await msg.answer(text, parse_mode=ParseMode.HTML, reply_markup=kb)
+
+
+# ===== Мои подписки / карточка =====
 
 @router.message(Command("subscriptions"))
-async def supp(message: types.Message):
+async def cmd_subscriptions(message: types.Message):
     """
-    Меню системы подписок
+    /subscriptions — открыть карточку подписок.
     """
-    text = ""
+    await _show_subscriptions_view(
-    uri = None  # Инициализация переменной
+        msg=message,
-    try:
+        telegram_id=message.from_user.id,
-        # Вызов API для получения URI
+        index=0,
-        result = await call_api("GET", f"/uri?telegram_id={message.from_user.id}")
+        edit=False,
-        uri = result.get('detail', "Error")  # Получаем URI из ответа или "Error", если ключ отсутствует
-
-        # Проверка результата
-        if uri == "Error":
-            text = escape_markdown_v2("Произошла ошибка при получении URI")
-        elif uri == "SUB_ERROR":
-            text = escape_markdown_v2("Вы ещё не приобрели подписки!!")
-        elif "trojan" in uri:
-            escaped_uri = escape_markdown_v2(uri)  # Экранирование URI
-            text = f"Ваша подписка: ```{escaped_uri}```"
-        else:
-            text = escape_markdown_v2("Произошла ошибка при обработке URI")
-    except Exception as e:
-        # Логирование ошибок
-        logger.error(f"Ошибка при вызове API для подписки: {e}")
-        text = escape_markdown_v2("Произошла неожиданная ошибка при получении подписки.")
-
-    # Ответ пользователю
-    await message.answer(
-        text,
-        parse_mode=ParseMode.MARKDOWN_V2
     )
 
+
+@router.callback_query(lambda c: c.data == "go_subscriptions")
+async def cb_go_subscriptions(callback: types.CallbackQuery):
+    """
+    Кнопка из других экранов — перейти в 'Мои подписки'.
+    """
+    await _show_subscriptions_view(
+        msg=callback.message,
+        telegram_id=callback.from_user.id,
+        index=0,
+        edit=True,
+    )
+    await callback.answer()
+
+
+@router.callback_query(lambda c: c.data.startswith("sub_prev:"))
+async def cb_sub_prev(callback: types.CallbackQuery):
+    """
+    Навигация: предыдущая подписка.
+    """
+    try:
+        index = int(callback.data.split(":")[1])
+    except (IndexError, ValueError):
+        index = 0
+
+    await _show_subscriptions_view(
+        msg=callback.message,
+        telegram_id=callback.from_user.id,
+        index=index,
+        edit=True,
+    )
+    await callback.answer()
+
+
+@router.callback_query(lambda c: c.data.startswith("sub_next:"))
+async def cb_sub_next(callback: types.CallbackQuery):
+    """
+    Навигация: следующая подписка.
+    """
+    try:
+        index = int(callback.data.split(":")[1])
+    except (IndexError, ValueError):
+        index = 0
+
+    await _show_subscriptions_view(
+        msg=callback.message,
+        telegram_id=callback.from_user.id,
+        index=index,
+        edit=True,
+    )
+    await callback.answer()
+
+
+@router.callback_query(lambda c: c.data.startswith("sub_cfg:"))
+async def cb_sub_cfg(callback: types.CallbackQuery):
+    """
+    Кнопка 'Конфиг' в карточке подписки.
+    Тянем URI через /uri?telegram_id=...
+    """
+    result = await call_api(
+        "GET",
+        f"/uri?telegram_id={callback.from_user.id}",
+    )
+
+    if result == "ERROR" or not isinstance(result, dict):
+        await callback.message.answer(
+            "Не удалось получить конфиг. Попробуй позже."
+        )
+        await callback.answer()
+        return
+
+    detail = result.get("detail")
+
+    if detail == "SUB_ERROR":
+        await callback.message.answer(
+            "У тебя нет активной подписки для генерации конфига."
+        )
+        await callback.answer()
+        return
+
+    uri = None
+    if isinstance(detail, str):
+        uri = detail.strip()
+    elif isinstance(detail, list) and detail:
+        uri = str(detail[0]).strip()
+
+    if not uri:
+        await callback.message.answer(
+            "Что-то пошло не так при выдаче конфига."
+        )
+        await callback.answer()
+        return
+
+    await callback.message.answer(
+        f"Твой конфиг:\n<code>{uri}</code>",
+        parse_mode=ParseMode.HTML,
+    )
+    await callback.answer()
+
+
+@router.callback_query(lambda c: c.data.startswith("sub_renew:"))
+async def cb_sub_renew(callback: types.CallbackQuery):
+    sub_id = callback.data.split(":", maxsplit=1)[
+        1] if ":" in callback.data else None
+    user, subs = await _fetch_user_and_subs(callback.from_user.id)
+
+    if not user or not subs:
+        await callback.message.answer("Подписка не найдена.")
+        await callback.answer()
+        return
+
+    target = next((s for s in subs if s.get("id") == sub_id), None)
+    if not target:
+        await callback.message.answer("Подписка не найдена.")
+        await callback.answer()
+        return
+
+    plan_name = target.get("plan_name")
+    if not plan_name:
+        await callback.message.answer("Не удалось определить тариф для продления.")
+        await callback.answer()
+        return
+
+    result = await call_api(
+        "POST",
+        "/subscription/buy",
+        {"telegram_id": str(callback.from_user.id), "plan_name": plan_name},
+    )
+
+    if result == "ERROR" or not isinstance(result, dict):
+        await callback.message.answer("Ошибка при продлении. Попробуй позже.")
+        await callback.answer()
+        return
+
+    detail = result.get("detail")
+    if detail == "INSUFFICIENT_FUNDS":
+        await callback.message.answer("Недостаточно средств на балансе.")
+        await callback.answer()
+        return
+    if detail == "TARIFF_NOT_FOUND":
+        await callback.message.answer("Тариф не найден.")
+        await callback.answer()
+        return
+    if detail == "ACTIVE_SUBSCRIPTION_EXISTS":
+        await callback.message.answer("У тебя уже есть активная подписка этого типа.")
+        await callback.answer()
+        return
+
+    uri = result.get("message")
+    if isinstance(uri, str) and uri:
+        await callback.message.answer(
+            "Подписка успешно продлена.\n"
+            f"Твой конфиг:\n<code>{uri}</code>",
+            parse_mode=ParseMode.HTML,
+        )
+    else:
+        await callback.message.answer("Подписка успешно продлена.")
+
+    await _show_subscriptions_view(
+        msg=callback.message,
+        telegram_id=callback.from_user.id,
+        index=0,
+        edit=True,
+    )
+    await callback.answer()
+
+# ===== Меню покупки подписки (Basic / Pro / Family) =====
+
+
 @router.callback_query(lambda callback: callback.data == "buy_subscription")
 async def buy_subscription_callback_handler(callback: types.CallbackQuery):
     """
-    Обработчик callback_query с data="buy_subscription".
+    Меню выбора тарифа: Basic / Pro / Family + показ баланса.
     """
-    await callback.message.edit_text(
+    user_data = await call_api("GET", f"/user/{callback.from_user.id}")
-        f"Ознакомься с условиями в вкладке \"О тарифах\" и выбери подходящий 🦅",
+    balance = user_data.get("balance", 0) if user_data else "?"
-        reply_markup=buy_keyboard()
+
+    text = (
+        "➕ <b>Подключить новую подписку</b>\n\n"
+        "🐣 Lark Basic - 200 ₽ / мес\n"
+        "🦅 Lark Pro - 400 ₽ / мес\n"
+        "👨‍👩‍👧 Lark Family - 700 ₽ / мес\n\n"
+        f"💰 Баланс: {balance} ₽\n\n"
+        "Выбери тариф:"
     )
 
+    await callback.message.edit_text(
+        text,
+        parse_mode=ParseMode.HTML,
+        reply_markup=buy_keyboard(),
+    )
+    await callback.answer()
+
+
 @router.callback_query(lambda callback: callback.data == "subs")
 async def subs_callback_handler(callback: types.CallbackQuery):
     """
-    Обработчик callback_query с data="subs".
+    Кнопка 'Lark Basic' — раскрываем варианты сроков.
-    """   
+    """
     await callback.message.edit_text(
-        "Подписки птенчик",
+        "Тариф Lark Basic — выбери срок:",
-        reply_markup=tarif_Lark_keyboard()
+        reply_markup=tarif_Lark_keyboard(),
     )
+    await callback.answer()
+
 
 @router.callback_query(lambda callback: callback.data == "subs_pro")
 async def subs_pro_callback_handler(callback: types.CallbackQuery):
     """
-    Обработчик callback_query с data="subs_pro".
+    Кнопка 'Lark Pro'.
-    """   
+    """
     await callback.message.edit_text(
-        "Подписки птенчик ПРО",
+        "Тариф Lark Pro — выбери срок:",
-        reply_markup=tarif_Lark_pro_keyboard()
+        reply_markup=tarif_Lark_pro_keyboard(),
     )
+    await callback.answer()
+
+
+@router.callback_query(lambda callback: callback.data == "subs_family")
+async def subs_family_callback_handler(callback: types.CallbackQuery):
+    """
+    Кнопка 'Lark Family'.
+    """
+    await callback.message.edit_text(
+        "Тариф Lark Family — выбери срок:",
+        reply_markup=tarif_Lark_family_keyboard(),
+    )
+    await callback.answer()
+
 
 @router.callback_query(lambda callback: callback.data.startswith("Lark:"))
 async def lark_tariff_callback_handler(callback: types.CallbackQuery):
     """
-    Обработчик для выбора тарифа Lark.
+    Обработчик выбора конкретного тарифа Lark.
+    callback_data: Lark:<Class>:<months>
     """
-    data = callback.data.split(":")
+    try:
-    tariff_name = data[0]
+        _, tariff_class, months_str = callback.data.split(":")
-    tariff_class = data[1]
+        months = int(months_str)
-    tariff_time = int(data[2])
+    except Exception:
+        await callback.message.answer("Некорректные данные тарифа.")
+        await callback.answer()
+        return
 
-    # Определение окончания для месяцев
+    if months == 1:
-    if tariff_time == 1:
+        months_label = "1 месяц"
-        months = f"{tariff_time} месяц"
+    elif 2 <= months <= 4:
-    elif 2 <= tariff_time <= 4:
+        months_label = f"{months} месяца"
-        months = f"{tariff_time} месяца"
     else:
-        months = f"{tariff_time} месяцев"
+        months_label = f"{months} месяцев"
 
-    text = f"Тариф {tariff_name} на {months}. Продолжите покупку..."
+    text = f"Тариф Lark {tariff_class} на {months_label}. Продолжить покупку?"
-    
+
-    # Рендеринг клавиатуры
+    keyboard = tarif_confirm_keyboard("Lark", months, tariff_class)
-    keyboard = tarif_confirm_keyboard(tariff_name, tariff_time, tariff_class)
     await callback.message.edit_text(text=text, reply_markup=keyboard)
+    await callback.answer()
+
 
 @router.callback_query(lambda callback: callback.data.startswith("confirm:"))
 async def confirm_callback_handler(callback: types.CallbackQuery):
-    """
-    Обработчик подтверждения подписки.
-    """
     try:
-        data = callback.data.split(":")[1]
+        data = callback.data.split(":", maxsplit=1)[1]
-        tariff_info = data.split("_")
+        name, classif, amount_str = data.split("_")
-        plan_id = f"{tariff_info[0]}_{tariff_info[1]}_{tariff_info[2]}"
+        plan_name = f"{name}_{classif}_{amount_str}"
-        result = await call_api("POST", "/subscription/buy", {"telegram_id": callback.from_user.id, "plan_name": "basic"})
+    except Exception:
-        detail = result.get("detail", {})
+        await callback.message.edit_text("Некорректные данные тарифа.")
-
-        if detail == "ERROR":
-            await callback.message.edit_text("Произошла ошибка при оформлении подписки.")
-        elif detail == "INSUFFICIENT_FUNDS":
-            await callback.message.edit_text("Денег на вашем балансе не достаточно.")
-        elif detail == "TARIFF_NOT_FOUND":
-            await callback.message.edit_text("Ваш тариф не найден.")
-        elif detail == "ACTIVE_SUBSCRIPTION_EXISTS":
-            await callback.message.edit_text("Вы уже имеете активную подписку.")
-        else:
-            uri = result.get("uri", {})
-            escaped_text = escape_markdown_v2(f"Подписка успешно оформлена!")
-            answer_text = f"Ваш конфиг для подключения: ```{uri}```"
-            await callback.message.edit_text(escaped_text)
-            await callback.message.answer(answer_text, parse_mode=ParseMode.MARKDOWN_V2)
-    except Exception as e:
-        logger.exception(f"Ошибка при обработке подтверждения подписки: {e}")
-        await callback.message.edit_text("Произошла ошибка при оформлении подписки.")
-    finally:
         await callback.answer()
+        return
 
+    result = await call_api(
+        "POST",
+        "/subscription/buy",
+        {"telegram_id": str(callback.from_user.id), "plan_name": plan_name},
+    )
 
+    if result == "ERROR" or not isinstance(result, dict):
+        await callback.message.edit_text("Ошибка при оформлении подписки.")
+        await callback.answer()
+        return
+
+    detail = result.get("detail")
+
+    if detail == "INSUFFICIENT_FUNDS":
+        await callback.message.edit_text(
+            "Недостаточно средств. Попробуй пополнить баланс."
+        )
+        await callback.answer()
+        return
+    if detail == "TARIFF_NOT_FOUND":
+        await callback.message.edit_text("Тариф не найден.")
+        await callback.answer()
+        return
+    if detail == "ACTIVE_SUBSCRIPTION_EXISTS":
+        await callback.message.edit_text("У тебя уже есть активная подписка.")
+        await callback.answer()
+        return
+
+    uri = result.get("message", "")
+    if uri:
+        await callback.message.edit_text("Подписка успешно оформлена.")
+        await callback.message.answer(
+            f"Подписка успешно оформлена!\n\nТвой конфиг:\n<code>{uri}</code>",
+            parse_mode=ParseMode.HTML,
+        )
+    else:
+        await callback.message.edit_text("Подписка успешно оформлена.")
+
+    await callback.answer()

handlers/support.py

@@ -1,20 +1,26 @@
 from aiogram import Router, types
 from aiogram.filters import Command
 import logging
-from datetime import datetime
 from instences.config import BASE_URL_FASTAPI
 import aiohttp
 from aiogram.fsm.context import FSMContext
 from aiogram.fsm.state import State, StatesGroup
-from keyboard.keyboards import faq_keyboard, sup_keyboard, ticket_list_keyboard, ticket_keyboard
+from keyboard.keyboards import (
+    faq_keyboard,
+    sup_keyboard,
+    ticket_list_keyboard,
+    ticket_keyboard,
+)
 
 logger = logging.getLogger(__name__)
 router = Router()
 
+
 class TicketState(StatesGroup):
     subject = State()
     message = State()
 
+
 async def call_api(method, endpoint, data=None):
     """
     Выполняет HTTP-запрос к FastAPI.
@@ -25,7 +31,8 @@ async def call_api(method, endpoint, data=None):
     try:
         async with aiohttp.ClientSession() as session:
             async with session.request(method, url, json=data) as response:
-                logger.info(f"Получен ответ от {url}: статус {response.status}")
+                logger.info(
+                    f"Получен ответ от {url}: статус {response.status}")
 
                 if response.status in {200, 201}:
                     result = await response.json()
@@ -34,59 +41,80 @@ async def call_api(method, endpoint, data=None):
                 if response.status == 404:
                     logger.debug(f"Код {response.status}, возвращаю ничего")
                     return None
-                logger.error(f"Ошибка в запросе: статус {response.status}, причина {response.reason}")
+                logger.error(
+                    f"Ошибка в запросе: статус {response.status}, причина {response.reason}"
+                )
                 return "ERROR"
     except Exception as e:
         logger.exception(f"Исключение при выполнении запроса к {url}: {e}")
         return "ERROR"
 
+
 @router.callback_query(lambda callback: callback.data == "faq")
 async def faq_callback_handler(callback: types.CallbackQuery):
     """
     Обработчик callback_query с data="faq".
-    """   
+    """
     await callback.message.edit_text(
         "FAQ YOU",
-        reply_markup=faq_keyboard()
+        reply_markup=faq_keyboard(),
     )
+    await callback.answer()
+
 
 @router.message(Command("support"))
 async def supp(message: types.Message):
     """
-    Меню сапп системы
+    Меню сапп системы (через команду).
     """
     await message.answer(
         "Добро пожаловать в саппорт систему!",
-        reply_markup=sup_keyboard()
+        reply_markup=sup_keyboard(),
     )
 
+
 @router.callback_query(lambda callback: callback.data == "main_sup")
 async def supp_callback(callback: types.CallbackQuery):
     """
-    Меню сапп системы (callback версия)
+    Меню сапп системы (callback-версия).
     """
-    await callback.message.answer(
+    await callback.message.edit_text(
         "Добро пожаловать в саппорт систему!",
-        reply_markup=sup_keyboard()
+        reply_markup=sup_keyboard(),
     )
+    await callback.answer()
+
 
 @router.callback_query(lambda callback: callback.data == "my_tickets")
 async def list_tickets_callback(callback: types.CallbackQuery):
     user_id = callback.from_user.id
     user_data = await call_api("GET", f"/user/{user_id}")
     if not user_data:
-        user_data = await call_api("POST", f"/user/create", {"telegram_id": f"{user_id}"})
+        user_data = await call_api(
+            "POST",
+            "/user/create",
+            {"telegram_id": f"{user_id}"},
+        )
 
-    tickets = await call_api("GET", f"/support/tickets?user_id={user_data['id']}")
+    tickets = await call_api(
+        "GET",
+        f"/support/tickets?user_id={user_data['id']}",
+    )
 
     if tickets == "ERROR" or not tickets:
-        await callback.message.edit_text("У вас нет тикетов.", reply_markup=sup_keyboard())
+        await callback.message.edit_text(
+            "У вас нет тикетов.",
+            reply_markup=sup_keyboard(),
+        )
+        await callback.answer()
         return
 
     await callback.message.edit_text(
         "Ваши тикеты:",
-        reply_markup=ticket_list_keyboard(tickets)
+        reply_markup=ticket_list_keyboard(tickets),
     )
+    await callback.answer()
+
 
 @router.callback_query(lambda callback: callback.data == "make_ticket")
 async def start_ticket_creation(callback: types.CallbackQuery, state: FSMContext):
@@ -95,9 +123,11 @@ async def start_ticket_creation(callback: types.CallbackQuery, state: FSMContext
     """
     await callback.message.answer(
         "Введите тему тикета (или нажмите 'Отмена', чтобы выйти):",
-        reply_markup=ticket_keyboard()
+        reply_markup=ticket_keyboard(),
     )
     await state.set_state(TicketState.subject)
+    await callback.answer()
+
 
 @router.message()
 async def handle_ticket_input(message: types.Message, state: FSMContext):
@@ -107,7 +137,10 @@ async def handle_ticket_input(message: types.Message, state: FSMContext):
     current_state = await state.get_state()
     if current_state == TicketState.subject:
         await state.update_data(subject=message.text)
-        await message.answer("Введите описание проблемы:", reply_markup=ticket_keyboard())
+        await message.answer(
+            "Введите описание проблемы:",
+            reply_markup=ticket_keyboard(),
+        )
         await state.set_state(TicketState.message)
 
     elif current_state == TicketState.message:
@@ -117,14 +150,23 @@ async def handle_ticket_input(message: types.Message, state: FSMContext):
         await create_ticket(message, subject, message_text, state)
         await state.clear()
 
-async def create_ticket(message: types.Message, subject: str, message_text: str, state: FSMContext):
+
+async def create_ticket(
+    message: types.Message,
+    subject: str,
+    message_text: str,
+    state: FSMContext,
+):
     """
     Отправляет запрос на создание тикета через FastAPI.
     """
     user_id = message.from_user.id
 
     try:
-        logger.info(f"Создание тикета для пользователя {user_id}: Тема - {subject}, Сообщение - {message_text}")
+        logger.info(
+            f"Создание тикета для пользователя {user_id}: "
+            f"Тема - {subject}, Сообщение - {message_text}"
+        )
 
         user_data = await call_api("GET", f"/user/{user_id}")
         if not user_data:
@@ -134,12 +176,12 @@ async def create_ticket(message: types.Message, subject: str, message_text: str,
         ticket_data = await call_api(
             "POST",
             f"/support/tickets?user_id={user_data['id']}",
-            data={"subject": subject, "message": message_text}
+            data={"subject": subject, "message": message_text},
         )
 
         if ticket_data != "ERROR":
             await message.answer(
-                f"✅ Тикет успешно создан!\n"
+                "✅ Тикет успешно создан!\n"
                 f"📌 Тема: {ticket_data['subject']}\n"
                 f"📊 Статус: {ticket_data['status']}\n"
                 f"📅 Дата создания: {ticket_data['created_at']}"
@@ -148,13 +190,20 @@ async def create_ticket(message: types.Message, subject: str, message_text: str,
             await message.answer("❌ Ошибка создания тикета. Попробуйте позже.")
 
     except Exception as e:
-        logger.exception(f"Ошибка при создании тикета для пользователя {user_id}: {e}")
+        logger.exception(
+            f"Ошибка при создании тикета для пользователя {user_id}: {e}"
+        )
         await message.answer("❌ Произошла ошибка при создании тикета.")
 
+
 @router.callback_query(lambda callback: callback.data == "cancel_ticket")
 async def cancel_ticket_creation(callback: types.CallbackQuery, state: FSMContext):
     """
     Отмена создания тикета.
     """
     await state.clear()
-    await callback.message.answer("Создание тикета отменено.", reply_markup=types.ReplyKeyboardRemove())
+    await callback.message.answer(
+        "Создание тикета отменено.",
+        reply_markup=types.ReplyKeyboardRemove(),
+    )
+    await callback.answer()

keyboard/keyboards.py

@@ -4,17 +4,25 @@ from aiogram.types import InlineKeyboardButton, KeyboardButton
 
 def main_keyboard():
     """
-    Главное меню (только визуал перетянут под твой стиль)
+    Главное меню
     """
     builder = InlineKeyboardBuilder()
-    builder.row(InlineKeyboardButton(
+    builder.row(
-        text="📜 Профиль", callback_data="profile"))
+        InlineKeyboardButton(
-    builder.row(InlineKeyboardButton(text="❔ FAQ ❔", callback_data="faq"))
+            text="📜 Профиль",
-    # Оставляем URL как у Вовы, меняем только текст
+            callback_data="profile",
+        )
+    )
+    builder.row(
+        InlineKeyboardButton(
+            text="❔ FAQ ❔",
+            callback_data="faq",
+        )
+    )
     builder.row(
         InlineKeyboardButton(
             text="ℹ️ О нас",
-            url="https://www.youtube.com/watch?v=Zirn-CKck-c"
+            url="https://www.youtube.com/watch?v=Zirn-CKck-c",
         )
     )
     return builder.as_markup()
@@ -22,26 +30,14 @@ def main_keyboard():
 
 def account_keyboard():
     """
-    Аккаунт / профиль
+    Клавиатура профиля:
-    Визуал — твой, callback_data — как у Вовы.
+    пополнить баланс, история транзакций, назад в главное меню.
     """
     builder = InlineKeyboardBuilder()
     builder.row(
         InlineKeyboardButton(
             text="🪙 Пополнить баланс",
-            callback_data="popup",
+            callback_data="balance",
-        )
-    )
-    builder.row(
-        InlineKeyboardButton(
-            text="🦴 Мои подписки",
-            callback_data="buy_subscription",
-        )
-    )
-    builder.row(
-        InlineKeyboardButton(
-            text="📡 Руководство по подключению",
-            callback_data="guide",
         )
     )
     builder.row(
@@ -59,6 +55,90 @@ def account_keyboard():
     return builder.as_markup()
 
 
+def balance_keyboard():
+    """
+    Экран баланса
+    """
+    builder = InlineKeyboardBuilder()
+    builder.row(
+        InlineKeyboardButton(
+            text="🪙 Пополнить баланс",
+            callback_data="popup",
+        )
+    )
+    builder.row(
+        InlineKeyboardButton(
+            text="🧾 История транзакций",
+            callback_data="tranhist",
+        )
+    )
+    builder.row(
+        InlineKeyboardButton(
+            text="🔙 Назад",
+            callback_data="profile",
+        )
+    )
+    return builder.as_markup()
+
+
+def popup_keyboard():
+    """
+    Суммы пополнения: 200, 300, 600, 1000 ₽.
+    """
+    builder = InlineKeyboardBuilder()
+    builder.row(
+        InlineKeyboardButton(text="200 ₽", callback_data="popup:200"),
+    )
+    builder.row(
+        InlineKeyboardButton(text="300 ₽", callback_data="popup:300"),
+    )
+    builder.row(
+        InlineKeyboardButton(text="600 ₽", callback_data="popup:600"),
+    )
+    builder.row(
+        InlineKeyboardButton(text="1000 ₽", callback_data="popup:1000"),
+    )
+    builder.row(
+        InlineKeyboardButton(
+            text="🔙 Назад",
+            callback_data="profile",
+        )
+    )
+    return builder.as_markup()
+
+
+def payment_methods_keyboard(amount: int):
+    """
+    Способы оплаты для выбранной суммы.
+    """
+    builder = InlineKeyboardBuilder()
+    builder.row(
+        InlineKeyboardButton(
+            text="⭐ Telegram Stars",
+            callback_data=f"method_stars_{amount}",
+        )
+    )
+    builder.row(
+        InlineKeyboardButton(
+            text="💵 СБП",
+            callback_data=f"method_ykassa_{amount}",
+        )
+    )
+    builder.row(
+        InlineKeyboardButton(
+            text="🪙 CryptoBot",
+            callback_data=f"method_crypto_{amount}",
+        )
+    )
+    builder.row(
+        InlineKeyboardButton(
+            text="🔙 Назад",
+            callback_data="popup",
+        )
+    )
+    return builder.as_markup()
+
+
 def ticket_list_keyboard(tickets):
     builder = InlineKeyboardBuilder()
     for ticket in tickets:
@@ -99,7 +179,7 @@ def ticket_keyboard():
     builder.row(
         InlineKeyboardButton(
             text="🔙 Отмена",
-            callback_data="cancel",
+            callback_data="cancel_ticket",  # БЫЛО "cancel"
         )
     )
     return builder.as_markup()
@@ -108,12 +188,11 @@ def ticket_keyboard():
 def buy_keyboard():
     """
     Меню выбора тарифа.
-    Лейблы ближе к твоему стилю, но callback’и остаются старые.
     """
     builder = InlineKeyboardBuilder()
     builder.row(
         InlineKeyboardButton(
-            text="🐣 Lark (Basic)",
+            text="🐣 Lark Basic",
             callback_data="subs",
         )
     )
@@ -125,74 +204,8 @@ def buy_keyboard():
     )
     builder.row(
         InlineKeyboardButton(
-            text="ℹ️ О тарифах",
+            text="👨‍👩‍👧 Lark Family",
-            url="https://t.me/proxylark/19",
+            callback_data="subs_family",
-        )
-    )
-    builder.row(
-        InlineKeyboardButton(
-            text="🔙 Назад",
-            callback_data="profile",
-        )
-    )
-    return builder.as_markup()
-
-
-def subhist_keyboard():
-    """
-    Подписки — история/список
-    """
-    builder = InlineKeyboardBuilder()
-    builder.row(
-        InlineKeyboardButton(
-            text="🔙 Назад",
-            callback_data="profile",
-        )
-    )
-    return builder.as_markup()
-
-
-def popup_keyboard():
-    """
-    Пополнение (суммы, стиль как в твоём topup_menu)
-    """
-    builder = InlineKeyboardBuilder()
-    builder.row(
-        InlineKeyboardButton(text="200 ₽", callback_data="popup:200"),
-        InlineKeyboardButton(text="500 ₽", callback_data="popup:500"),
-    )
-    builder.row(
-        InlineKeyboardButton(text="1000 ₽", callback_data="popup:1000"),
-        InlineKeyboardButton(text="2000 ₽", callback_data="popup:2000"),
-    )
-    builder.row(
-        InlineKeyboardButton(text="3000 ₽", callback_data="popup:3000"),
-        InlineKeyboardButton(text="5000 ₽", callback_data="popup:5000"),
-    )
-    builder.row(
-        InlineKeyboardButton(
-            text="🔙 Назад",
-            callback_data="profile",
-        )
-    )
-    return builder.as_markup()
-
-
-def balance_keyboard():
-    """
-    Баланс
-    """
-    builder = InlineKeyboardBuilder()
-    builder.row(
-        InlineKeyboardButton(
-            text="🪙 Пополнить баланс",
-            callback_data="popup",
-        )
-    )
-    builder.row(
-        InlineKeyboardButton(
-            text="🧾 История транзакций",
-            callback_data="tranhist",
         )
     )
     builder.row(
@@ -206,7 +219,7 @@ def balance_keyboard():
 
 def tarif_Lark_keyboard():
     """
-    Тариф Lark (Standart) — только подписи меняем.
+    Тариф Lark Basic (Standart)
     """
     builder = InlineKeyboardBuilder()
     builder.row(
@@ -268,6 +281,83 @@ def tarif_Lark_pro_keyboard():
     return builder.as_markup()
 
 
+def tarif_Lark_family_keyboard():
+    """
+    Тариф Lark Family.
+    """
+    builder = InlineKeyboardBuilder()
+    builder.row(
+        InlineKeyboardButton(
+            text="👨‍👩‍👧 Lark Family 1 месяц",
+            callback_data="Lark:Family:1",
+        )
+    )
+    builder.row(
+        InlineKeyboardButton(
+            text="👨‍👩‍👧 Lark Family 6 месяцев",
+            callback_data="Lark:Family:6",
+        )
+    )
+    builder.row(
+        InlineKeyboardButton(
+            text="👨‍👩‍👧 Lark Family 12 месяцев",
+            callback_data="Lark:Family:12",
+        )
+    )
+    builder.row(
+        InlineKeyboardButton(
+            text="🔙 Назад",
+            callback_data="buy_subscription",
+        )
+    )
+    return builder.as_markup()
+
+
+def subscriptions_card_keyboard(sub_id: str, index: int, total: int):
+    """
+    Карточка подписки:
+    навигация, конфиг, назад в главное меню.
+    """
+    builder = InlineKeyboardBuilder()
+
+    # Навигация по подпискам
+    nav = []
+    if index > 0:
+        nav.append(
+            InlineKeyboardButton(
+                text="⬅️",
+                callback_data=f"sub_prev:{index-1}",
+            )
+        )
+    if index < total - 1:
+        nav.append(
+            InlineKeyboardButton(
+                text="➡️",
+                callback_data=f"sub_next:{index+1}",
+            )
+        )
+    if nav:
+        builder.row(*nav)
+
+    # Конфиг
+    builder.row(
+        InlineKeyboardButton(
+            text="🔑 Конфиг",
+            callback_data=f"sub_cfg:{sub_id}",
+        )
+    )
+
+    # Назад в главное меню
+    builder.row(
+        InlineKeyboardButton(
+            text="🔙 Назад",
+            callback_data="base",  # было "profile" изменил
+        )
+    )
+
+    return builder.as_markup()
+
+
 def guide_keyboard():
     """
     Руководство по подключению
@@ -322,7 +412,7 @@ def tranhist_keyboard():
     return builder.as_markup()
 
 
-def tarif_confirm_keyboard(name, amount, classif):
+def tarif_confirm_keyboard(name: str, amount: int, classif: str):
     """
     Подтверждение покупки тарифа
     """
@@ -344,7 +434,7 @@ def tarif_confirm_keyboard(name, amount, classif):
 
 def confirm_popup_keyboard():
     """
-    Подтверждение пополнения — без «иди нахуй», мы же под босса господина ларк это красим....
+    Подтверждение пополнения.
     """
     builder = InlineKeyboardBuilder()
     builder.row(

main.py

@@ -11,7 +11,8 @@ import logging
 BOT_TOKEN = os.getenv("TOKEN")
 
 if not BOT_TOKEN:
-    raise ValueError("Не задан токен бота. Убедитесь, что переменная окружения 'TOKEN' установлена.")
+    raise ValueError(
+        "Не задан токен бота. Убедитесь, что переменная окружения 'TOKEN' установлена.")
 
 bot = Bot(token=BOT_TOKEN)
 dp = Dispatcher()
@@ -23,9 +24,10 @@ dp.message.middleware(AntiSpamMiddleware(rate_limit=1))
 async def set_commands():
     """Устанавливает команды для бота."""
     commands = [
-        BotCommand(command="/start", description="🥚Главное меню"),
+        BotCommand(command="start", description="Запуск бота"),
-        BotCommand(command="/subscriptions", description="🦴Мои подписки"),
+        BotCommand(command="subscriptions", description="Мои подписки"),
-        BotCommand(command="/support", description="❕Поддержка❕"),
+        BotCommand(command="support", description="Техподдержка"),
+        BotCommand(command="referrals", description="Реферальная программа"),
     ]
     await bot.set_my_commands(commands)