Update config.py

.env.example

@@ -26,15 +26,24 @@ REMNAWAVE_API_KEY=
 # Для панелей установленных скриптом eGames прописывать ключ в формате XXXXXXX:DDDDDDDD - https://panel.example.com/auth/login?XXXXXXX=DDDDDDDD
 REMNAWAVE_SECRET_KEY=your_secret_key_here
 
+# ========= ПОДПИСКИ =========
 # ===== ТРИАЛ ПОДПИСКА =====
 TRIAL_DURATION_DAYS=3
 TRIAL_TRAFFIC_LIMIT_GB=10
 TRIAL_DEVICE_LIMIT=1
 TRIAL_SQUAD_UUID=
-DEFAULT_TRAFFIC_RESET_STRATEGY=MONTH
+
+# ===== ПЛАТНАЯ ПОДПИСКА =====
+# Сколько устройств доступно по дефолту при покупке платной подписки
+DEFAULT_DEVICE_LIMIT=3
+
+# Дефолт параметры для подписок выданных через админку
 DEFAULT_TRAFFIC_LIMIT_GB=100
 DEFAULT_DEVICE_LIMIT=1
 
+# ===== ГЛОБАЛЬНЫЙ ПАРАМЕТР ДЛЯ ВСЕХ ПОДПИСОК =====
+DEFAULT_TRAFFIC_RESET_STRATEGY=MONTH
+
 # ===== НАСТРОЙКИ ТРАФИКА =====
 # Режим выбора трафика:
 # "selectable" - пользователи выбирают пакеты трафика (по умолчанию)
@@ -88,6 +97,7 @@ MIN_BALANCE_FOR_AUTOPAY_KOPEKS=10000
 
 # Telegram Stars (работает автоматически)
 TELEGRAM_STARS_ENABLED=true
+TELEGRAM_STARS_RATE_RUB=1.3
 
 # Tribute (https://tribute.app)
 TRIBUTE_ENABLED=false

.github/workflows/docker-registry.yml

@@ -4,12 +4,14 @@ on:
     branches:
       - main
       - master
+      - dev 
     tags:
       - 'v*'
   pull_request:
     branches:
       - main
       - master
+      - dev 
 env:
   REGISTRY: ghcr.io
   IMAGE_NAME: fr1ngg/remnawave-bedolaga-telegram-bot
@@ -42,6 +44,7 @@ jobs:
             type=semver,pattern={{major}}.{{minor}}
             type=semver,pattern={{major}}
             type=raw,value=latest,enable={{is_default_branch}}
+            type=raw,value=dev,enable=${{ github.ref == 'refs/heads/dev' }}
       - name: Build and push Docker image
         uses: docker/build-push-action@v5
         with:

README.md

@@ -38,7 +38,7 @@
   
 ### 🎛️ **Гибкость конфигурации**
 - 🌍 **Выбор стран** - пользователи сами выбирают нужные локации
-- 📱 **Управление устройствами** - от 1 до 10 шт
+- 📱 **Управление устройствами** - от 1 до 10 шт (С настройкой кол-ва бесплатных у триальных и платных подписок)
 - 📊 **Гибкие тарифы** - от 5GB до безлимита, от 14 дней до года
 - 🎁 **Промо-система** - коды на деньги, дни подписки, триал-периоды
 - 3 режима показа ссылки подписки: 1) С гайдом по подключению прямо в боте(тянущий данные приложений и ссылок на скачку из app-config.json) 2) Обычное открытие ссылки подписки в миниапе 3) Интеграция сабпейджа maposia - кастомно прописать ссылку можно
@@ -119,15 +119,24 @@ REMNAWAVE_API_KEY=
 # Для панелей установленных скриптом eGames прописывать ключ в формате XXXXXXX:DDDDDDDD - https://panel.example.com/auth/login?XXXXXXX=DDDDDDDD
 REMNAWAVE_SECRET_KEY=your_secret_key_here
 
+# ========= ПОДПИСКИ =========
 # ===== ТРИАЛ ПОДПИСКА =====
 TRIAL_DURATION_DAYS=3
 TRIAL_TRAFFIC_LIMIT_GB=10
 TRIAL_DEVICE_LIMIT=1
 TRIAL_SQUAD_UUID=
-DEFAULT_TRAFFIC_RESET_STRATEGY=MONTH
+
+# ===== ПЛАТНАЯ ПОДПИСКА =====
+# Сколько устройств доступно по дефолту при покупке платной подписки
+DEFAULT_DEVICE_LIMIT=3
+
+# Дефолт параметры для подписок выданных через админку
 DEFAULT_TRAFFIC_LIMIT_GB=100
 DEFAULT_DEVICE_LIMIT=1
 
+# ===== ГЛОБАЛЬНЫЙ ПАРАМЕТР ДЛЯ ВСЕХ ПОДПИСОК =====
+DEFAULT_TRAFFIC_RESET_STRATEGY=MONTH
+
 # ===== НАСТРОЙКИ ТРАФИКА =====
 # Режим выбора трафика:
 # "selectable" - пользователи выбирают пакеты трафика (по умолчанию)
@@ -181,6 +190,7 @@ MIN_BALANCE_FOR_AUTOPAY_KOPEKS=10000
 
 # Telegram Stars (работает автоматически)
 TELEGRAM_STARS_ENABLED=true
+TELEGRAM_STARS_RATE_RUB=1.3
 
 # Tribute (https://tribute.app)
 TRIBUTE_ENABLED=false

app/bot.py

@@ -25,6 +25,7 @@ from app.handlers.admin import (
     statistics as admin_statistics, servers as admin_servers,
     maintenance as admin_maintenance  
 )
+from app.handlers.stars_payments import register_stars_handlers
 
 logger = logging.getLogger(__name__)
 
@@ -70,6 +71,7 @@ async def setup_bot() -> tuple[Bot, Dispatcher]:
     dp.callback_query.middleware(LoggingMiddleware())
     dp.message.middleware(AuthMiddleware())
     dp.callback_query.middleware(AuthMiddleware())
+    dp.pre_checkout_query.middleware(AuthMiddleware())
     dp.message.middleware(MaintenanceMiddleware())
     dp.callback_query.middleware(MaintenanceMiddleware())
     dp.message.middleware(ThrottlingMiddleware())
@@ -98,6 +100,9 @@ async def setup_bot() -> tuple[Bot, Dispatcher]:
 
     common.register_handlers(dp)
     
+    register_stars_handlers(dp)
+    logger.info("🌟 Зарегистрированы обработчики Telegram Stars платежей")
+    
     try:
         await maintenance_service.start_monitoring()
         logger.info("Мониторинг техработ запущен")

app/config.py

@@ -75,6 +75,7 @@ class Settings(BaseSettings):
     MAINTENANCE_MESSAGE: str = "🔧 Ведутся технические работы. Сервис временно недоступен. Попробуйте позже."
     
     TELEGRAM_STARS_ENABLED: bool = True
+    TELEGRAM_STARS_RATE_RUB: float = 1.3
     
     TRIBUTE_ENABLED: bool = False
     TRIBUTE_API_KEY: Optional[str] = None
@@ -281,6 +282,15 @@ class Settings(BaseSettings):
             service_name=self.PAYMENT_SERVICE_NAME,
             description=description
         )
+
+    def get_stars_rate(self) -> float:
+        return self.TELEGRAM_STARS_RATE_RUB
+    
+    def stars_to_rubles(self, stars: int) -> float:
+        return stars * self.get_stars_rate()
+    
+    def rubles_to_stars(self, rubles: float) -> int:
+        return max(1, int(rubles / self.get_stars_rate()))
     
     model_config = {
         "env_file": ".env",

app/external/telegram_stars.py

@@ -13,6 +13,14 @@ class TelegramStarsService:
     def __init__(self, bot: Bot):
         self.bot = bot
     
+    @staticmethod
+    def calculate_stars_from_rubles(rubles: float) -> int:
+        return settings.rubles_to_stars(rubles)
+    
+    @staticmethod
+    def calculate_rubles_from_stars(stars: int) -> float:
+        return settings.stars_to_rubles(stars)
+    
     async def create_invoice(
         self,
         chat_id: int,
@@ -23,7 +31,8 @@ class TelegramStarsService:
         start_parameter: Optional[str] = None
     ) -> Optional[str]:
         try:
-            stars_amount = max(1, amount_kopeks // 100)
+            amount_rubles = amount_kopeks / 100
+            stars_amount = self.calculate_stars_from_rubles(amount_rubles)
             
             invoice_link = await self.bot.create_invoice_link(
                 title=title,
@@ -35,7 +44,10 @@ class TelegramStarsService:
                 start_parameter=start_parameter
             )
             
-            logger.info(f"Создан Stars invoice на {stars_amount} звезд для {chat_id}")
+            logger.info(
+                f"Создан Stars invoice на {stars_amount} звезд (~{amount_rubles:.2f}₽) "
+                f"для {chat_id}, курс: {settings.get_stars_rate():.2f}₽/⭐"
+            )
             return invoice_link
             
         except Exception as e:
@@ -52,7 +64,8 @@ class TelegramStarsService:
         keyboard: Optional[InlineKeyboardMarkup] = None
     ) -> Optional[Dict[str, Any]]:
         try:
-            stars_amount = max(1, amount_kopeks // 100)
+            amount_rubles = amount_kopeks / 100
+            stars_amount = self.calculate_stars_from_rubles(amount_rubles)
             
             message = await self.bot.send_invoice(
                 chat_id=chat_id,
@@ -65,10 +78,14 @@ class TelegramStarsService:
                 reply_markup=keyboard
             )
             
-            logger.info(f"Отправлен Stars invoice {message.message_id} на {stars_amount} звезд")
+            logger.info(
+                f"Отправлен Stars invoice {message.message_id} на {stars_amount} звезд "
+                f"(~{amount_rubles:.2f}₽), курс: {settings.get_stars_rate():.2f}₽/⭐"
+            )
             return {
                 "message_id": message.message_id,
                 "stars_amount": stars_amount,
+                "rubles_amount": amount_rubles,
                 "payload": payload
             }
             
@@ -88,13 +105,8 @@ class TelegramStarsService:
                 ok=ok,
                 error_message=error_message
             )
+            logger.info(f"Ответ на pre_checkout_query: ok={ok}")
             return True
         except Exception as e:
             logger.error(f"Ошибка ответа на pre_checkout_query: {e}")
             return False
-    
-    def calculate_stars_amount(self, rubles: float) -> int:
-        return max(1, int(rubles))
-    
-    def calculate_rubles_from_stars(self, stars: int) -> float:
-        return float(stars)

app/handlers/balance.py

@@ -356,10 +356,15 @@ async def process_stars_payment_amount(
     texts = get_texts(db_user.language)
     
     if not settings.TELEGRAM_STARS_ENABLED:
-        await message.answer("❌ Оплата Stars временно недоступна")
+        await message.answer("⚠ Оплата Stars временно недоступна")
         return
     
     try:
+        from app.external.telegram_stars import TelegramStarsService
+        
+        amount_rubles = amount_kopeks / 100
+        stars_amount = TelegramStarsService.calculate_stars_from_rubles(amount_rubles)
+        
         payment_service = PaymentService(message.bot)
         invoice_link = await payment_service.create_stars_invoice(
             amount_kopeks=amount_kopeks,
@@ -374,7 +379,9 @@ async def process_stars_payment_amount(
         
         await message.answer(
             f"⭐ <b>Оплата через Telegram Stars</b>\n\n"
-            f"Сумма: {texts.format_price(amount_kopeks)}\n\n"
+            f"💰 Сумма: {texts.format_price(amount_kopeks)}\n"
+            f"⭐ К оплате: {stars_amount} звезд\n"
+            f"📊 Курс: {settings.get_stars_rate():.2f}₽ за звезду\n\n"
             f"Нажмите кнопку ниже для оплаты:",
             reply_markup=keyboard,
             parse_mode="HTML"
@@ -384,7 +391,7 @@ async def process_stars_payment_amount(
         
     except Exception as e:
         logger.error(f"Ошибка создания Stars invoice: {e}")
-        await message.answer("❌ Ошибка создания платежа")
+        await message.answer("⚠ Ошибка создания платежа")
 
 
 @error_handler

app/handlers/menu.py

@@ -19,7 +19,6 @@ async def show_main_menu(
     db_user: User, 
     db: AsyncSession
 ):
-    
     texts = get_texts(db_user.language)
     
     from datetime import datetime
@@ -34,7 +33,6 @@ async def show_main_menu(
     
     menu_text = texts.MAIN_MENU.format(
         user_name=db_user.full_name,
-        balance=texts.format_price(db_user.balance_kopeks),
         subscription_status=_get_subscription_status(db_user, texts)
     )
     
@@ -45,7 +43,8 @@ async def show_main_menu(
             is_admin=settings.is_admin(db_user.telegram_id),
             has_had_paid_subscription=db_user.has_had_paid_subscription,
             has_active_subscription=has_active_subscription,
-            subscription_is_active=subscription_is_active  
+            subscription_is_active=subscription_is_active,
+            balance_kopeks=db_user.balance_kopeks 
         )
     )
     await callback.answer()
@@ -109,7 +108,7 @@ async def handle_back_to_menu(
 
 def _get_subscription_status(user: User, texts) -> str:
     if not user.subscription:
-        return "⌐ Отсутствует"
+        return "❌ Отсутствует"
     
     subscription = user.subscription
     current_time = datetime.utcnow()

app/handlers/stars_payments.py

@@ -0,0 +1,132 @@
+import logging
+from aiogram import Dispatcher, types, F
+from sqlalchemy.ext.asyncio import AsyncSession
+
+from app.database.models import User
+from app.services.payment_service import PaymentService
+from app.external.telegram_stars import TelegramStarsService
+from app.database.crud.user import get_user_by_telegram_id
+
+logger = logging.getLogger(__name__)
+
+
+async def handle_pre_checkout_query(query: types.PreCheckoutQuery):
+    try:
+        logger.info(f"📋 Pre-checkout query от {query.from_user.id}: {query.total_amount} XTR, payload: {query.invoice_payload}")
+        
+        if not query.invoice_payload or not query.invoice_payload.startswith("balance_"):
+            logger.warning(f"Невалидный payload: {query.invoice_payload}")
+            await query.answer(
+                ok=False,
+                error_message="Ошибка валидации платежа. Попробуйте еще раз."
+            )
+            return
+        
+        try:
+            from app.database.database import get_db
+            async for db in get_db():
+                user = await get_user_by_telegram_id(db, query.from_user.id)
+                if not user:
+                    logger.warning(f"Пользователь {query.from_user.id} не найден в БД")
+                    await query.answer(
+                        ok=False,
+                        error_message="Пользователь не найден. Обратитесь в поддержку."
+                    )
+                    return
+                break 
+        except Exception as db_error:
+            logger.error(f"Ошибка подключения к БД в pre_checkout_query: {db_error}")
+            await query.answer(
+                ok=False,
+                error_message="Техническая ошибка. Попробуйте позже."
+            )
+            return
+        
+        await query.answer(ok=True)
+        logger.info(f"✅ Pre-checkout одобрен для пользователя {query.from_user.id}")
+        
+    except Exception as e:
+        logger.error(f"Ошибка в pre_checkout_query: {e}", exc_info=True)
+        await query.answer(
+            ok=False,
+            error_message="Техническая ошибка. Попробуйте позже."
+        )
+
+
+async def handle_successful_payment(
+    message: types.Message,
+    db: AsyncSession,
+    **kwargs
+):
+    try:
+        payment = message.successful_payment
+        user_id = message.from_user.id
+        
+        logger.info(
+            f"💳 Успешный Stars платеж от {user_id}: "
+            f"{payment.total_amount} XTR, "
+            f"payload: {payment.invoice_payload}, "
+            f"charge_id: {payment.telegram_payment_charge_id}"
+        )
+        
+        user = await get_user_by_telegram_id(db, user_id)
+        if not user:
+            logger.error(f"Пользователь {user_id} не найден при обработке Stars платежа")
+            await message.answer(
+                "❌ Ошибка: пользователь не найден. Обратитесь в поддержку."
+            )
+            return
+        
+        payment_service = PaymentService(message.bot)
+        success = await payment_service.process_stars_payment(
+            db=db,
+            user_id=user.id,
+            stars_amount=payment.total_amount,
+            payload=payment.invoice_payload,
+            telegram_payment_charge_id=payment.telegram_payment_charge_id
+        )
+        
+        if success:
+            rubles_amount = TelegramStarsService.calculate_rubles_from_stars(payment.total_amount)
+            
+            await message.answer(
+                f"🎉 <b>Платеж успешно обработан!</b>\n\n"
+                f"⭐ Потрачено звезд: {payment.total_amount}\n"
+                f"💰 Зачислено на баланс: {rubles_amount:.2f} ₽\n"
+                f"🆔 ID транзакции: {payment.telegram_payment_charge_id[:8]}...\n\n"
+                f"Спасибо за пополнение! 🚀",
+                parse_mode="HTML"
+            )
+            
+            logger.info(
+                f"✅ Stars платеж успешно обработан: "
+                f"пользователь {user.id}, {payment.total_amount} звезд → {rubles_amount:.2f}₽"
+            )
+        else:
+            logger.error(f"Ошибка обработки Stars платежа для пользователя {user.id}")
+            await message.answer(
+                "❌ Произошла ошибка при зачислении средств. "
+                "Обратитесь в поддержку, платеж будет проверен вручную."
+            )
+        
+    except Exception as e:
+        logger.error(f"Ошибка в successful_payment: {e}", exc_info=True)
+        await message.answer(
+            "❌ Техническая ошибка при обработке платежа. "
+            "Обратитесь в поддержку для решения проблемы."
+        )
+
+
+def register_stars_handlers(dp: Dispatcher):
+    
+    dp.pre_checkout_query.register(
+        handle_pre_checkout_query,
+        F.currency == "XTR" 
+    )
+    
+    dp.message.register(
+        handle_successful_payment,
+        F.successful_payment
+    )
+    
+    logger.info("🌟 Зарегистрированы обработчики Telegram Stars платежей")

app/handlers/start.py

@@ -138,7 +138,6 @@ async def cmd_start(message: types.Message, state: FSMContext, db: AsyncSession,
         await message.answer(
             texts.MAIN_MENU.format(
                 user_name=user.full_name,
-                balance=texts.format_price(user.balance_kopeks),
                 subscription_status=_get_subscription_status(user, texts)
             ),
             reply_markup=get_main_menu_keyboard(
@@ -146,7 +145,8 @@ async def cmd_start(message: types.Message, state: FSMContext, db: AsyncSession,
                 is_admin=settings.is_admin(user.telegram_id),
                 has_had_paid_subscription=user.has_had_paid_subscription,
                 has_active_subscription=has_active_subscription,
-                subscription_is_active=subscription_is_active
+                subscription_is_active=subscription_is_active,
+                balance_kopeks=user.balance_kopeks 
             )
         )
         await state.clear()
@@ -380,6 +380,7 @@ async def process_referral_code_skip(
     await complete_registration_from_callback(callback, state, db)
 
 
+
 async def complete_registration_from_callback(
     callback: types.CallbackQuery,
     state: FSMContext, 
@@ -405,21 +406,24 @@ async def complete_registration_from_callback(
             subscription_is_active = existing_user.subscription.is_active
         
         user_name = existing_user.full_name
+        user_telegram_id = existing_user.telegram_id
+        user_language = existing_user.language
+        has_had_paid_subscription = existing_user.has_had_paid_subscription
         balance_kopeks = existing_user.balance_kopeks
         
         try:
             await callback.message.answer(
                 texts.MAIN_MENU.format(
                     user_name=user_name,
-                    balance=texts.format_price(balance_kopeks),
                     subscription_status=_get_subscription_status(existing_user, texts)
                 ),
                 reply_markup=get_main_menu_keyboard(
-                    language=existing_user.language,
-                    is_admin=settings.is_admin(existing_user.telegram_id),
-                    has_had_paid_subscription=existing_user.has_had_paid_subscription,
+                    language=user_language,
+                    is_admin=settings.is_admin(user_telegram_id),
+                    has_had_paid_subscription=has_had_paid_subscription,
                     has_active_subscription=has_active_subscription,
-                    subscription_is_active=subscription_is_active
+                    subscription_is_active=subscription_is_active,
+                    balance_kopeks=balance_kopeks
                 )
             )
         except Exception as e:
@@ -503,7 +507,6 @@ async def complete_registration_from_callback(
     
     has_active_subscription = False 
     subscription_is_active = False
-    
     user_name = user.full_name
     balance_kopeks = user.balance_kopeks
     user_telegram_id = user.telegram_id
@@ -514,7 +517,6 @@ async def complete_registration_from_callback(
         await callback.message.answer(
             texts.MAIN_MENU.format(
                 user_name=user_name,
-                balance=texts.format_price(balance_kopeks),
                 subscription_status=_get_subscription_status_simple(texts)
             ),
             reply_markup=get_main_menu_keyboard(
@@ -522,7 +524,8 @@ async def complete_registration_from_callback(
                 is_admin=settings.is_admin(user_telegram_id),
                 has_had_paid_subscription=has_had_paid_subscription,
                 has_active_subscription=has_active_subscription,
-                subscription_is_active=subscription_is_active
+                subscription_is_active=subscription_is_active,
+                balance_kopeks=balance_kopeks
             )
         )
         logger.info(f"✅ Главное меню отправлено для пользователя {user_telegram_id}")
@@ -532,24 +535,25 @@ async def complete_registration_from_callback(
             balance_rubles = balance_kopeks / 100
             await callback.message.answer(
                 f"Добро пожаловать, {user_name}!\n"
-                f"Баланс: {balance_rubles} ₽\n"
+                f"Баланс: {balance_rubles:.2f} ₽\n"
                 f"Подписка: Нет активной подписки",
                 reply_markup=get_main_menu_keyboard(
                     language=user_language,
                     is_admin=settings.is_admin(user_telegram_id),
                     has_had_paid_subscription=has_had_paid_subscription,
                     has_active_subscription=has_active_subscription,
-                    subscription_is_active=subscription_is_active
+                    subscription_is_active=subscription_is_active,
+                    balance_kopeks=balance_kopeks
                 )
             )
             logger.info(f"✅ Fallback главное меню отправлено для пользователя {user_telegram_id}")
         except Exception as fallback_error:
-            logger.error(f"❌ Критическая ошибка при отправке fallback меню: {fallback_error}")
+            logger.error(f"⛔ Критическая ошибка при отправке fallback меню: {fallback_error}")
             try:
                 await callback.message.answer(f"Добро пожаловать, {user_name}! Регистрация завершена.")
                 logger.info(f"✅ Простое приветствие отправлено для пользователя {user_telegram_id}")
             except Exception as final_error:
-                logger.error(f"❌ Критическая ошибка при отправке простого сообщения: {final_error}")
+                logger.error(f"⛔ Критическая ошибка при отправке простого сообщения: {final_error}")
     
     logger.info(f"✅ Регистрация завершена для пользователя: {user_telegram_id}")
 
@@ -578,24 +582,30 @@ async def complete_registration(
         if existing_user.subscription:
             subscription_is_active = existing_user.subscription.is_active
         
+        user_name = existing_user.full_name
+        user_telegram_id = existing_user.telegram_id
+        user_language = existing_user.language
+        has_had_paid_subscription = existing_user.has_had_paid_subscription
+        balance_kopeks = existing_user.balance_kopeks
+        
         try:
             await message.answer(
                 texts.MAIN_MENU.format(
-                    user_name=existing_user.full_name,
-                    balance=texts.format_price(existing_user.balance_kopeks),
+                    user_name=user_name,
                     subscription_status=_get_subscription_status(existing_user, texts)
                 ),
                 reply_markup=get_main_menu_keyboard(
-                    language=existing_user.language,
-                    is_admin=settings.is_admin(existing_user.telegram_id),
-                    has_had_paid_subscription=existing_user.has_had_paid_subscription,
+                    language=user_language,
+                    is_admin=settings.is_admin(user_telegram_id),
+                    has_had_paid_subscription=has_had_paid_subscription,
                     has_active_subscription=has_active_subscription,
-                    subscription_is_active=subscription_is_active
+                    subscription_is_active=subscription_is_active,
+                    balance_kopeks=balance_kopeks
                 )
             )
         except Exception as e:
             logger.error(f"Ошибка при показе главного меню существующему пользователю: {e}")
-            await message.answer(f"Добро пожаловать, {existing_user.full_name}!")
+            await message.answer(f"Добро пожаловать, {user_name}!")
         
         await state.clear()
         return
@@ -674,7 +684,6 @@ async def complete_registration(
     
     has_active_subscription = False
     subscription_is_active = False
-    
     user_name = user.full_name
     balance_kopeks = user.balance_kopeks
     user_telegram_id = user.telegram_id
@@ -685,7 +694,6 @@ async def complete_registration(
         await message.answer(
             texts.MAIN_MENU.format(
                 user_name=user_name,
-                balance=texts.format_price(balance_kopeks),
                 subscription_status=_get_subscription_status_simple(texts)
             ),
             reply_markup=get_main_menu_keyboard(
@@ -693,7 +701,8 @@ async def complete_registration(
                 is_admin=settings.is_admin(user_telegram_id),
                 has_had_paid_subscription=has_had_paid_subscription,
                 has_active_subscription=has_active_subscription,
-                subscription_is_active=subscription_is_active
+                subscription_is_active=subscription_is_active,
+                balance_kopeks=balance_kopeks
             )
         )
         logger.info(f"✅ Главное меню отправлено для пользователя {user_telegram_id}")
@@ -703,19 +712,20 @@ async def complete_registration(
             balance_rubles = balance_kopeks / 100
             await message.answer(
                 f"Добро пожаловать, {user_name}!\n"
-                f"Баланс: {balance_rubles} ₽\n"
+                f"Баланс: {balance_rubles:.2f} ₽\n"
                 f"Подписка: Нет активной подписки",
                 reply_markup=get_main_menu_keyboard(
                     language=user_language,
                     is_admin=settings.is_admin(user_telegram_id),
                     has_had_paid_subscription=has_had_paid_subscription,
                     has_active_subscription=has_active_subscription,
-                    subscription_is_active=subscription_is_active
+                    subscription_is_active=subscription_is_active,
+                    balance_kopeks=balance_kopeks
                 )
             )
             logger.info(f"✅ Fallback главное меню отправлено для пользователя {user_telegram_id}")
         except Exception as fallback_error:
-            logger.error(f"❌ Критическая ошибка при отправке fallback меню: {fallback_error}")
+            logger.error(f"⛔ Критическая ошибка при отправке fallback меню: {fallback_error}")
             try:
                 await message.answer(f"Добро пожаловать, {user_name}! Регистрация завершена.")
                 logger.info(f"✅ Простое приветствие отправлено для пользователя {user_telegram_id}")
@@ -726,9 +736,44 @@ async def complete_registration(
 
 
 def _get_subscription_status(user, texts):
-    if user.subscription and user.subscription.is_active:
-        return getattr(texts, 'SUBSCRIPTION_ACTIVE', 'Активна')
-    return getattr(texts, 'SUBSCRIPTION_NONE', 'Нет активной подписки')
+    if not user or not hasattr(user, 'subscription'):
+        return getattr(texts, 'SUBSCRIPTION_NONE', 'Нет активной подписки')
+    
+    if not user.subscription:
+        return getattr(texts, 'SUBSCRIPTION_NONE', 'Нет активной подписки')
+    
+    subscription = user.subscription
+    
+    from datetime import datetime
+    current_time = datetime.utcnow()
+    
+    if hasattr(subscription, 'end_date') and subscription.end_date <= current_time:
+        return f"🔴 Истекла\n📅 {subscription.end_date.strftime('%d.%m.%Y')}"
+    
+    if hasattr(subscription, 'end_date'):
+        days_left = (subscription.end_date - current_time).days
+    else:
+        days_left = 0
+    
+    is_trial = getattr(subscription, 'is_trial', False)
+    
+    if is_trial:
+        if days_left > 1:
+            return f"🎁 Тестовая подписка\n📅 до {subscription.end_date.strftime('%d.%m.%Y')} ({days_left} дн.)"
+        elif days_left == 1:
+            return "🎁 Тестовая подписка\n⚠️ истекает завтра!"
+        else:
+            return "🎁 Тестовая подписка\n⚠️ истекает сегодня!"
+    else: 
+        if days_left > 7:
+            return f"💎 Активна\n📅 до {subscription.end_date.strftime('%d.%m.%Y')} ({days_left} дн.)"
+        elif days_left > 1:
+            return f"💎 Активна\n⚠️ истекает через {days_left} дн."
+        elif days_left == 1:
+            return "💎 Активна\n⚠️ истекает завтра!"
+        else:
+            return "💎 Активна\n⚠️ истекает сегодня!"
+
 
 
 def _get_subscription_status_simple(texts):

app/keyboards/inline.py

@@ -21,20 +21,29 @@ def get_main_menu_keyboard(
     is_admin: bool = False,
     has_had_paid_subscription: bool = False,
     has_active_subscription: bool = False,
-    subscription_is_active: bool = False 
+    subscription_is_active: bool = False,
+    balance_kopeks: int = 0
 ) -> InlineKeyboardMarkup:
     texts = get_texts(language)
     
     if settings.DEBUG:
-        print(f"DEBUG KEYBOARD: language={language}, is_admin={is_admin}, has_had_paid={has_had_paid_subscription}, has_active={has_active_subscription}, sub_active={subscription_is_active}")
+        print(f"DEBUG KEYBOARD: language={language}, is_admin={is_admin}, has_had_paid={has_had_paid_subscription}, has_active={has_active_subscription}, sub_active={subscription_is_active}, balance={balance_kopeks}")
+    
+    if hasattr(texts, 'BALANCE_BUTTON') and balance_kopeks > 0:
+        balance_button_text = texts.BALANCE_BUTTON.format(balance=texts.format_price(balance_kopeks))
+    else:
+        balance_button_text = f"💰 Баланс: {texts.format_price(balance_kopeks)}"
     
     keyboard = [
         [
-            InlineKeyboardButton(text=texts.MENU_BALANCE, callback_data="menu_balance"),
-            InlineKeyboardButton(text=texts.MENU_SUBSCRIPTION, callback_data="menu_subscription")
+            InlineKeyboardButton(text=balance_button_text, callback_data="menu_balance")
         ]
     ]
     
+    if has_active_subscription and subscription_is_active:
+        keyboard.append([
+            InlineKeyboardButton(text=texts.MENU_SUBSCRIPTION, callback_data="menu_subscription")
+        ])
     
     show_trial = not has_had_paid_subscription and not has_active_subscription
     

app/localization/texts.py

@@ -105,10 +105,9 @@ class RussianTexts(Texts):
     REFERRAL_CODE_APPLIED = "🎁 Реферальный код применен! Вы получите бонус после первой покупки."
     REFERRAL_CODE_INVALID = "❌ Неверный реферальный код"
     REFERRAL_CODE_SKIP = "⏭️ Пропустить"
-    
+       
     MAIN_MENU = """👤 <b>{user_name}</b>
 ━━━━━━━━━━━━━━━━━
-💰 <b>Баланс:</b> {balance}
 📱 <b>Подписка:</b> {subscription_status}
 ━━━━━━━━━━━━━━━━━
 
@@ -117,7 +116,7 @@ class RussianTexts(Texts):
     
     MENU_BALANCE = "💰 Баланс"
     MENU_SUBSCRIPTION = "📱 Подписка"
-    MENU_TRIAL = "🎁 Тестовая подписка"
+    MENU_TRIAL = "🧪 Тестовая подписка"
     MENU_BUY_SUBSCRIPTION = "💎 Купить подписку"
     MENU_EXTEND_SUBSCRIPTION = "⏰ Продлить подписку"
     MENU_PROMOCODE = "🎫 Промокод"
@@ -126,9 +125,11 @@ class RussianTexts(Texts):
     MENU_RULES = "📋 Правила сервиса"
     MENU_LANGUAGE = "🌐 Язык"
     MENU_ADMIN = "⚙️ Админ-панель"
+    BALANCE_BUTTON = "💰 Баланс: {balance}"
+    BALANCE_BUTTON_ZERO = "💰 Баланс: 0.00 ₽"
     
     SUBSCRIPTION_NONE = "❌ Нет активной подписки"
-    SUBSCRIPTION_TRIAL = "🎁 Тестовая подписка"
+    SUBSCRIPTION_TRIAL = "🧪 Тестовая подписка"
     SUBSCRIPTION_ACTIVE = "✅ Активна"
     SUBSCRIPTION_EXPIRED = "⏰ Истекла"
     

app/services/payment_service.py

@@ -9,6 +9,7 @@ from sqlalchemy.ext.asyncio import AsyncSession
 
 from app.config import settings
 from app.services.yookassa_service import YooKassaService
+from app.external.telegram_stars import TelegramStarsService
 from app.database.crud.yookassa import create_yookassa_payment, link_yookassa_payment_to_transaction
 from app.database.crud.transaction import create_transaction
 from app.database.crud.user import add_user_balance, get_user_by_id
@@ -22,6 +23,7 @@ class PaymentService:
     def __init__(self, bot: Optional[Bot] = None):
         self.bot = bot
         self.yookassa_service = YooKassaService() if settings.is_yookassa_enabled() else None
+        self.stars_service = TelegramStarsService(bot) if bot else None
     
     async def create_stars_invoice(
         self,
@@ -30,28 +32,90 @@ class PaymentService:
         payload: Optional[str] = None
     ) -> str:
         
-        if not self.bot:
+        if not self.bot or not self.stars_service:
             raise ValueError("Bot instance required for Stars payments")
         
         try:
-            stars_amount = max(1, amount_kopeks // 100)
+            amount_rubles = amount_kopeks / 100
+            stars_amount = TelegramStarsService.calculate_stars_from_rubles(amount_rubles)
             
             invoice_link = await self.bot.create_invoice_link(
                 title="Пополнение баланса VPN",
-                description=description,
+                description=f"{description} (≈{stars_amount} ⭐)",
                 payload=payload or f"balance_topup_{amount_kopeks}",
                 provider_token="", 
                 currency="XTR", 
                 prices=[LabeledPrice(label="Пополнение", amount=stars_amount)]
             )
             
-            logger.info(f"Создан Stars invoice на {stars_amount} звезд")
+            logger.info(f"Создан Stars invoice на {stars_amount} звезд (~{amount_rubles:.2f}₽)")
             return invoice_link
             
         except Exception as e:
             logger.error(f"Ошибка создания Stars invoice: {e}")
             raise
     
+    async def process_stars_payment(
+        self,
+        db: AsyncSession,
+        user_id: int,
+        stars_amount: int,
+        payload: str,
+        telegram_payment_charge_id: str
+    ) -> bool:
+        try:
+            rubles_amount = TelegramStarsService.calculate_rubles_from_stars(stars_amount)
+            amount_kopeks = int(rubles_amount * 100)
+            
+            transaction = await create_transaction(
+                db=db,
+                user_id=user_id,
+                type=TransactionType.DEPOSIT,
+                amount_kopeks=amount_kopeks,
+                description=f"Пополнение через Telegram Stars ({stars_amount} ⭐)",
+                payment_method=PaymentMethod.TELEGRAM_STARS,
+                external_id=telegram_payment_charge_id,
+                is_completed=True
+            )
+            
+            user = await get_user_by_id(db, user_id)
+            if user:
+                await add_user_balance(
+                    db, 
+                    user, 
+                    amount_kopeks, 
+                    f"Пополнение Stars: {rubles_amount:.2f}₽ ({stars_amount} ⭐)"
+                )
+                
+                if self.bot:
+                    try:
+                        await self.bot.send_message(
+                            user.telegram_id,
+                            f"✅ <b>Пополнение успешно!</b>\n\n"
+                            f"⭐ Звезд: {stars_amount}\n"
+                            f"💰 Сумма: {settings.format_price(amount_kopeks)}\n"
+                            f"🏦 Способ: Telegram Stars\n"
+                            f"🆔 Транзакция: {telegram_payment_charge_id[:8]}...\n\n"
+                            f"Баланс пополнен автоматически!",
+                            parse_mode="HTML"
+                        )
+                        logger.info(f"✅ Отправлено уведомление пользователю {user.telegram_id} о пополнении на {rubles_amount:.2f}₽")
+                    except Exception as e:
+                        logger.error(f"Ошибка отправки уведомления о пополнении Stars: {e}")
+                
+                logger.info(
+                    f"✅ Обработан Stars платеж: пользователь {user_id}, "
+                    f"{stars_amount} звезд → {rubles_amount:.2f}₽"
+                )
+                return True
+            else:
+                logger.error(f"Пользователь с ID {user_id} не найден при обработке Stars платежа")
+                return False
+                
+        except Exception as e:
+            logger.error(f"Ошибка обработки Stars платежа: {e}", exc_info=True)
+            return False
+    
     async def create_yookassa_payment(
         self,
         db: AsyncSession,
@@ -196,7 +260,7 @@ class PaymentService:
                                 user.telegram_id,
                                 f"✅ <b>Пополнение успешно!</b>\n\n"
                                 f"💰 Сумма: {settings.format_price(updated_payment.amount_kopeks)}\n"
-                                f"🏦 Способ: Банковская карта\n"
+                                f"🦐 Способ: Банковская карта\n"
                                 f"🆔 Транзакция: {yookassa_payment_id[:8]}...\n\n"
                                 f"Баланс пополнен автоматически!",
                                 parse_mode="HTML"