Update docker-registry.yml

Проверка обновлений

.env.example

@@ -12,19 +12,26 @@ ADMIN_NOTIFICATIONS_ENABLED=true
 ADMIN_NOTIFICATIONS_CHAT_ID=-1001234567890   # Замени на ID твоего канала (-100) - ПРЕФИКС ЗАКРЫТОГО КАНАЛА! ВСТАВИТЬ СВОЙ ID СРАЗУ ПОСЛЕ (-100) БЕЗ ПРОБЕЛОВ!
 ADMIN_NOTIFICATIONS_TOPIC_ID=123             # Опционально: ID топика
 
-# ===== DATABASE =====
-# Для Docker используйте PostgreSQL:
-DATABASE_URL=postgresql+asyncpg://remnawave_user:secure_password_123@postgres:5432/remnawave_bot
-# Для локального запуска без Docker используйте SQLite: sqlite+aiosqlite:///./bot.db 
-# DATABASE_URL=postgresql+asyncpg://remnawave_user:secure_password_123@postgres:5432/remnawave_bot
+# ===== DATABASE CONFIGURATION =====
+# Режим базы данных: "auto", "postgresql", "sqlite"
+DATABASE_MODE=auto
 
-REDIS_URL=redis://redis:6379/0
+# Основной URL (можно оставить пустым для автоматического выбора)
+DATABASE_URL=
 
-# Пароли для Docker (PostgreSQL/Redis)
+# PostgreSQL настройки (для Docker и кастомных установок)
+POSTGRES_HOST=postgres
+POSTGRES_PORT=5432
 POSTGRES_DB=remnawave_bot
 POSTGRES_USER=remnawave_user
 POSTGRES_PASSWORD=secure_password_123
 
+# SQLite настройки (для локального запуска)
+SQLITE_PATH=./data/bot.db
+
+# Redis
+REDIS_URL=redis://redis:6379/0
+
 # ===== REMNAWAVE API =====
 REMNAWAVE_API_URL=https://panel.example.com
 REMNAWAVE_API_KEY=
@@ -215,3 +222,7 @@ WEBHOOK_PATH=/webhook
 APP_CONFIG_PATH=app-config.json
 ENABLE_DEEP_LINKS=true
 APP_CONFIG_CACHE_TTL=3600
+
+VERSION_CHECK_ENABLED=true
+VERSION_CHECK_REPO=fr1ngg/remnawave-bedolaga-telegram-bot
+VERSION_CHECK_INTERVAL_HOURS=1

.github/workflows/docker-hub.yml

@@ -1,28 +1,111 @@
 name: BedolagaBot
+
 on:
   push:
     branches:
-      - main  
+      - main
+      - dev
+    tags:
+      - 'v*'
+  pull_request:
+    branches:
+      - main
+
 jobs:
   build:
     runs-on: ubuntu-latest
     steps:
     - name: Checkout code
       uses: actions/checkout@v4
+      with:
+        fetch-depth: 0  
+
     - name: Set up Docker Buildx
       uses: docker/setup-buildx-action@v3
+
+    - name: Get version info
+      id: version
+      run: |
+        echo "short_sha=$(git rev-parse --short HEAD)" >> $GITHUB_OUTPUT
+        
+        echo "build_date=$(date -u +'%Y-%m-%dT%H:%M:%SZ')" >> $GITHUB_OUTPUT
+        
+        # Определяем версию и теги
+        if [[ $GITHUB_REF == refs/tags/* ]]; then
+          VERSION=${GITHUB_REF#refs/tags/}
+          TAGS="fr1ngg/remnawave-bedolaga-telegram-bot:latest,fr1ngg/remnawave-bedolaga-telegram-bot:${VERSION}"
+          echo "🏷️ Собираем релизную версию: $VERSION"
+        elif [[ $GITHUB_REF == refs/heads/main ]]; then
+          VERSION="v2.2.4-$(git rev-parse --short HEAD)"
+          TAGS="fr1ngg/remnawave-bedolaga-telegram-bot:latest,fr1ngg/remnawave-bedolaga-telegram-bot:${VERSION}"
+          echo "🚀 Собираем версию из main: $VERSION"
+        elif [[ $GITHUB_REF == refs/heads/dev ]]; then
+          VERSION="v2.2.4-dev-$(git rev-parse --short HEAD)"
+          TAGS="fr1ngg/remnawave-bedolaga-telegram-bot:dev,fr1ngg/remnawave-bedolaga-telegram-bot:${VERSION}"
+          echo "🧪 Собираем dev версию: $VERSION"
+        else
+          VERSION="v2.2.3-pr-$(git rev-parse --short HEAD)"
+          TAGS="fr1ngg/remnawave-bedolaga-telegram-bot:pr-$(git rev-parse --short HEAD)"
+          echo "🔀 Собираем PR версию: $VERSION"
+        fi
+        
+        echo "version=$VERSION" >> $GITHUB_OUTPUT
+        echo "tags=$TAGS" >> $GITHUB_OUTPUT
+        echo "should_push=${{ github.event_name != 'pull_request' }}" >> $GITHUB_OUTPUT
+        
+        echo "=== Информация о сборке ==="
+        echo "Версия: $VERSION"
+        echo "Коммит: $(git rev-parse --short HEAD)"
+        echo "Теги: $TAGS"
+        echo "Push: ${{ github.event_name != 'pull_request' }}"
+        echo "==========================="
+
     - name: Login to Docker Hub
+      if: github.event_name != 'pull_request'
       uses: docker/login-action@v3
       with:
         username: ${{ secrets.DOCKER_USERNAME }}
         password: ${{ secrets.DOCKER_PASSWORD }}
+
     - name: Build and push Docker image
       uses: docker/build-push-action@v5
       with:
         context: .
         file: ./Dockerfile
         platforms: linux/amd64,linux/arm64
-        push: true
-        tags: fr1ngg/remnawave-bedolaga-telegram-bot:latest
+        push: ${{ steps.version.outputs.should_push }}
+        tags: ${{ steps.version.outputs.tags }}
+        build-args: |
+          VERSION=${{ steps.version.outputs.version }}
+          BUILD_DATE=${{ steps.version.outputs.build_date }}
+          VCS_REF=${{ steps.version.outputs.short_sha }}
         cache-from: type=gha
         cache-to: type=gha,mode=max
+        labels: |
+          org.opencontainers.image.version=${{ steps.version.outputs.version }}
+          org.opencontainers.image.created=${{ steps.version.outputs.build_date }}
+          org.opencontainers.image.revision=${{ steps.version.outputs.short_sha }}
+          org.opencontainers.image.title=Bedolaga RemnaWave Bot
+          org.opencontainers.image.description=Telegram bot for RemnaWave VPN service
+          org.opencontainers.image.source=https://github.com/${{ github.repository }}
+
+    - name: Build Summary
+      if: github.event_name != 'pull_request'
+      run: |
+        echo "## 🚀 Docker Hub Build Summary" >> $GITHUB_STEP_SUMMARY
+        echo "| Параметр | Значение |" >> $GITHUB_STEP_SUMMARY
+        echo "|----------|----------|" >> $GITHUB_STEP_SUMMARY
+        echo "| **Версия** | \`${{ steps.version.outputs.version }}\` |" >> $GITHUB_STEP_SUMMARY
+        echo "| **Коммит** | \`${{ steps.version.outputs.short_sha }}\` |" >> $GITHUB_STEP_SUMMARY
+        echo "| **Дата сборки** | \`${{ steps.version.outputs.build_date }}\` |" >> $GITHUB_STEP_SUMMARY
+        echo "| **Registry** | Docker Hub |" >> $GITHUB_STEP_SUMMARY
+        echo "| **Ветка** | \`${{ github.ref_name }}\` |" >> $GITHUB_STEP_SUMMARY
+        echo "| **Статус** | ✅ Опубликован |" >> $GITHUB_STEP_SUMMARY
+        echo "" >> $GITHUB_STEP_SUMMARY
+        echo "### 📋 Опубликованные теги:" >> $GITHUB_STEP_SUMMARY
+        echo "\`\`\`" >> $GITHUB_STEP_SUMMARY
+        echo "${{ steps.version.outputs.tags }}" | tr ',' '\n' >> $GITHUB_STEP_SUMMARY
+        echo "\`\`\`" >> $GITHUB_STEP_SUMMARY
+        echo "" >> $GITHUB_STEP_SUMMARY
+        echo "### 🔗 Ссылки:" >> $GITHUB_STEP_SUMMARY
+        echo "- [Docker Hub Repository](https://hub.docker.com/r/fr1ngg/remnawave-bedolaga-telegram-bot)" >> $GITHUB_STEP_SUMMARY

.github/workflows/docker-registry.yml

@@ -1,20 +1,21 @@
 name: Build and Publish Docker Image
+
 on:
   push:
     branches:
       - main
-      - master
       - dev 
     tags:
       - 'v*'
   pull_request:
     branches:
       - main
-      - master
       - dev 
+
 env:
   REGISTRY: ghcr.io
   IMAGE_NAME: fr1ngg/remnawave-bedolaga-telegram-bot
+
 jobs:
   build-and-push:
     runs-on: ubuntu-latest
@@ -24,14 +25,47 @@ jobs:
     steps:
       - name: Checkout repository
         uses: actions/checkout@v4
+        with:
+          fetch-depth: 0  
+
       - name: Set up Docker Buildx
         uses: docker/setup-buildx-action@v3
+
       - name: Log in to Container Registry
         uses: docker/login-action@v3
         with:
           registry: ${{ env.REGISTRY }}
           username: ${{ github.actor }}
           password: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Get version info
+        id: version
+        run: |
+          echo "short_sha=$(git rev-parse --short HEAD)" >> $GITHUB_OUTPUT
+          
+          echo "build_date=$(date -u +'%Y-%m-%dT%H:%M:%SZ')" >> $GITHUB_OUTPUT
+          
+          if [[ $GITHUB_REF == refs/tags/* ]]; then
+            VERSION=${GITHUB_REF#refs/tags/}
+            echo "🏷️ Собираем релизную версию: $VERSION"
+          elif [[ $GITHUB_REF == refs/heads/main ]]; then
+            VERSION="v2.2.4"
+            echo "🚀 Собираем версию из main: $VERSION"
+          elif [[ $GITHUB_REF == refs/heads/dev ]]; then
+            VERSION="v2.2.4-dev-$(git rev-parse --short HEAD)"
+            echo "🧪 Собираем dev версию: $VERSION"
+          else
+            VERSION="v2.2.4-pr-$(git rev-parse --short HEAD)"
+            echo "🔀 Собираем PR версию: $VERSION"
+          fi
+          echo "version=$VERSION" >> $GITHUB_OUTPUT
+          
+          echo "=== Информация о сборке ==="
+          echo "Версия: $VERSION"
+          echo "Коммит: $(git rev-parse --short HEAD)"
+          echo "Ветка/Тег: $GITHUB_REF"
+          echo "==========================="
+
       - name: Extract metadata
         id: meta
         uses: docker/metadata-action@v5
@@ -45,6 +79,8 @@ jobs:
             type=semver,pattern={{major}}
             type=raw,value=latest,enable={{is_default_branch}}
             type=raw,value=dev,enable=${{ github.ref == 'refs/heads/dev' }}
+            type=raw,value=${{ steps.version.outputs.version }}
+
       - name: Build and push Docker image
         uses: docker/build-push-action@v5
         with:
@@ -54,8 +90,13 @@ jobs:
           push: true
           tags: ${{ steps.meta.outputs.tags }}
           labels: ${{ steps.meta.outputs.labels }}
+          build-args: |
+            VERSION=${{ steps.version.outputs.version }}
+            BUILD_DATE=${{ steps.version.outputs.build_date }}
+            VCS_REF=${{ steps.version.outputs.short_sha }}
           cache-from: type=gha
           cache-to: type=gha,mode=max
+
       - name: Generate security report
         uses: docker/scout-action@v1
         if: github.event_name == 'pull_request'
@@ -67,3 +108,22 @@ jobs:
           only-severities: critical,high
           write-comment: true
           github-token: ${{ secrets.GITHUB_TOKEN }}
+
+      - name: Build Summary
+        if: github.event_name != 'pull_request'
+        run: |
+          echo "## 🚀 Docker Build Summary" >> $GITHUB_STEP_SUMMARY
+          echo "| Параметр | Значение |" >> $GITHUB_STEP_SUMMARY
+          echo "|----------|----------|" >> $GITHUB_STEP_SUMMARY
+          echo "| **Версия** | \`${{ steps.version.outputs.version }}\` |" >> $GITHUB_STEP_SUMMARY
+          echo "| **Коммит** | \`${{ steps.version.outputs.short_sha }}\` |" >> $GITHUB_STEP_SUMMARY
+          echo "| **Дата сборки** | \`${{ steps.version.outputs.build_date }}\` |" >> $GITHUB_STEP_SUMMARY
+          echo "| **Registry** | \`${{ env.REGISTRY }}\` |" >> $GITHUB_STEP_SUMMARY
+          echo "| **Образ** | \`${{ env.IMAGE_NAME }}\` |" >> $GITHUB_STEP_SUMMARY
+          echo "| **Ветка** | \`${{ github.ref_name }}\` |" >> $GITHUB_STEP_SUMMARY
+          echo "| **Статус** | ✅ Опубликован |" >> $GITHUB_STEP_SUMMARY
+          echo "" >> $GITHUB_STEP_SUMMARY
+          echo "### 📋 Доступные теги:" >> $GITHUB_STEP_SUMMARY
+          echo "\`\`\`" >> $GITHUB_STEP_SUMMARY
+          echo "${{ steps.meta.outputs.tags }}" >> $GITHUB_STEP_SUMMARY
+          echo "\`\`\`" >> $GITHUB_STEP_SUMMARY

Dockerfile

@@ -1,4 +1,9 @@
 FROM python:3.11-slim
+
+ARG VERSION="v2.2.4"
+ARG BUILD_DATE
+ARG VCS_REF
+
 WORKDIR /app
 
 RUN apt-get update && apt-get install -y \
@@ -13,16 +18,30 @@ RUN groupadd -g 1000 app && \
     useradd -u 1000 -g 1000 -m -s /bin/bash app
 
 COPY . .
+
 RUN mkdir -p logs data && \
-    chown -R app:app /app
+    chown -R app:app /app && \
+    chown -R 1000:1000 ./logs ./data
 
 USER app
 
 ENV PYTHONPATH=/app
 ENV PYTHONUNBUFFERED=1
+ENV VERSION=${VERSION}
+ENV BUILD_DATE=${BUILD_DATE}
+ENV VCS_REF=${VCS_REF}
 
 EXPOSE 8081 8082
 
+LABEL org.opencontainers.image.title="Bedolaga RemnaWave Bot"
+LABEL org.opencontainers.image.description="Telegram bot for RemnaWave VPN service"
+LABEL org.opencontainers.image.version="${VERSION}"
+LABEL org.opencontainers.image.created="${BUILD_DATE}"
+LABEL org.opencontainers.image.revision="${VCS_REF}"
+LABEL org.opencontainers.image.source="https://github.com/fr1ngg/remnawave-bedolaga-telegram-bot"
+LABEL org.opencontainers.image.url="https://github.com/fr1ngg/remnawave-bedolaga-telegram-bot"
+LABEL org.opencontainers.image.vendor="fr1ngg"
+
 HEALTHCHECK --interval=30s --timeout=10s --start-period=30s --retries=3 \
     CMD wget --no-verbose --tries=1 --spider http://localhost:8081/health || exit 1
 

README.md

@@ -1007,22 +1007,22 @@ REMNAWAVE_SECRET_KEY=XXXXXXX:DDDDDDDD
 
 <tr>
 <td>🥇</td>
-<td><strong>Илья (@ispanec_nn)</strong></td>
-<td>$30</td>
+<td><strong>@pilot_737800</strong></td>
+<td>₽2,750</td>
 <td>За веру в проект с самого начала</td>
 </tr>
 
 <tr>
 <td>🥈</td>
 <td><strong>@Legacyyy777</strong></td>
-<td>₽2,400</td>
+<td>₽2,600</td>
 <td>За ценные предложения по улучшению</td>
 </tr>
 
 <tr>
 <td>🥉</td>
-<td><strong>@pilot_737800</strong></td>
-<td>₽2,250</td>
+<td><strong>Илья (@ispanec_nn)</strong></td>
+<td>$30</td>
 <td>За активное тестирование и фидбек</td>
 </tr>
 

app/bot.py

@@ -24,7 +24,8 @@ from app.handlers.admin import (
     rules as admin_rules, remnawave as admin_remnawave,
     statistics as admin_statistics, servers as admin_servers,
     maintenance as admin_maintenance,
-    user_messages as admin_user_messages 
+    user_messages as admin_user_messages,
+    updates as admin_updates 
 )
 from app.handlers.stars_payments import register_stars_handlers
 
@@ -68,6 +69,7 @@ async def setup_bot() -> tuple[Bot, Dispatcher]:
         storage = MemoryStorage()
     
     dp = Dispatcher(storage=storage)
+    
     dp.message.middleware(LoggingMiddleware())
     dp.callback_query.middleware(LoggingMiddleware())
     dp.message.middleware(AuthMiddleware())
@@ -79,6 +81,7 @@ async def setup_bot() -> tuple[Bot, Dispatcher]:
     dp.callback_query.middleware(ThrottlingMiddleware())
     dp.message.middleware(SubscriptionStatusMiddleware())
     dp.callback_query.middleware(SubscriptionStatusMiddleware())
+    
     start.register_handlers(dp)
     menu.register_handlers(dp)
     subscription.register_handlers(dp)
@@ -86,6 +89,7 @@ async def setup_bot() -> tuple[Bot, Dispatcher]:
     promocode.register_handlers(dp)
     referral.register_handlers(dp)
     support.register_handlers(dp)
+    
     admin_main.register_handlers(dp)
     admin_users.register_handlers(dp)
     admin_subscriptions.register_handlers(dp)
@@ -98,12 +102,13 @@ async def setup_bot() -> tuple[Bot, Dispatcher]:
     admin_remnawave.register_handlers(dp)
     admin_statistics.register_handlers(dp)
     admin_maintenance.register_handlers(dp)
-    admin_user_messages.register_handlers(dp) 
+    admin_user_messages.register_handlers(dp)
+    admin_updates.register_handlers(dp)
 
     common.register_handlers(dp)
     
     register_stars_handlers(dp)
-    logger.info("🌟 Зарегистрированы обработчики Telegram Stars платежей")
+    logger.info("⭐ Зарегистрированы обработчики Telegram Stars платежей")
     
     try:
         await maintenance_service.start_monitoring()

app/config.py

@@ -15,7 +15,18 @@ class Settings(BaseSettings):
     ADMIN_NOTIFICATIONS_CHAT_ID: Optional[str] = None
     ADMIN_NOTIFICATIONS_TOPIC_ID: Optional[int] = None
     
-    DATABASE_URL: str
+    DATABASE_URL: str = ""
+    
+    POSTGRES_HOST: str = "postgres"
+    POSTGRES_PORT: int = 5432
+    POSTGRES_DB: str = "remnawave_bot"
+    POSTGRES_USER: str = "remnawave_user" 
+    POSTGRES_PASSWORD: str = "secure_password_123"
+    
+    SQLITE_PATH: str = "./data/bot.db"
+    
+    DATABASE_MODE: str = "auto"
+    
     REDIS_URL: str = "redis://localhost:6379/0"
     
     REMNAWAVE_API_URL: str
@@ -114,7 +125,6 @@ class Settings(BaseSettings):
     PAYMENT_BALANCE_TEMPLATE: str = "{service_name} - {description}"
     PAYMENT_SUBSCRIPTION_TEMPLATE: str = "{service_name} - {description}"
 
-
     CONNECT_BUTTON_MODE: str = "guide"
     MINIAPP_CUSTOM_URL: str = ""
     
@@ -131,6 +141,10 @@ class Settings(BaseSettings):
     APP_CONFIG_PATH: str = "app-config.json"
     ENABLE_DEEP_LINKS: bool = True
     APP_CONFIG_CACHE_TTL: int = 3600 
+
+    VERSION_CHECK_ENABLED: bool = True
+    VERSION_CHECK_REPO: str = "fr1ngg/remnawave-bedolaga-telegram-bot"
+    VERSION_CHECK_INTERVAL_HOURS: int = 1
     
     @field_validator('LOG_FILE', mode='before')
     @classmethod
@@ -139,6 +153,48 @@ class Settings(BaseSettings):
         log_path.parent.mkdir(parents=True, exist_ok=True)
         return str(log_path)
     
+    def get_database_url(self) -> str:
+        if self.DATABASE_URL and self.DATABASE_URL.strip():
+            return self.DATABASE_URL
+            
+        mode = self.DATABASE_MODE.lower()
+        
+        if mode == "sqlite":
+            return self._get_sqlite_url()
+        elif mode == "postgresql":
+            return self._get_postgresql_url()
+        elif mode == "auto":
+            if os.getenv("DOCKER_ENV") == "true" or os.path.exists("/.dockerenv"):
+                return self._get_postgresql_url()
+            else:
+                return self._get_sqlite_url()
+        else:
+            return self._get_auto_database_url()
+    
+    def _get_sqlite_url(self) -> str:
+        sqlite_path = Path(self.SQLITE_PATH)
+        sqlite_path.parent.mkdir(parents=True, exist_ok=True)
+        return f"sqlite+aiosqlite:///{sqlite_path.absolute()}"
+    
+    def _get_postgresql_url(self) -> str:
+        return (f"postgresql+asyncpg://{self.POSTGRES_USER}:{self.POSTGRES_PASSWORD}"
+                f"@{self.POSTGRES_HOST}:{self.POSTGRES_PORT}/{self.POSTGRES_DB}")
+    
+    def _get_auto_database_url(self) -> str:
+        if (os.getenv("DOCKER_ENV") == "true" or 
+            os.path.exists("/.dockerenv")):
+            return self._get_postgresql_url()
+        else:
+            return self._get_sqlite_url()
+    
+    def is_postgresql(self) -> bool:
+        """Проверяет, используется ли PostgreSQL"""
+        return "postgresql" in self.get_database_url()
+    
+    def is_sqlite(self) -> bool:
+        """Проверяет, используется ли SQLite"""
+        return "sqlite" in self.get_database_url()
+    
     def is_admin(self, user_id: int) -> bool:
         return user_id in self.get_admin_ids()
     
@@ -179,8 +235,8 @@ class Settings(BaseSettings):
             return ["ru", "en"]
     
     def format_price(self, price_kopeks: int) -> str:
-        rubles = price_kopeks / 100
-        return f"{rubles:.2f} ₽"
+        rubles = price_kopeks // 100
+        return f"{rubles} ₽"
     
     def kopeks_to_rubles(self, kopeks: int) -> float:
         return kopeks / 100
@@ -251,7 +307,7 @@ class Settings(BaseSettings):
                 period_str = period_str.strip()
                 if period_str:
                     period = int(period_str)
-                    if period in PERIOD_PRICES:
+                    if hasattr(self, f'PRICE_{period}_DAYS'):
                         periods.append(period)
             
             return periods if periods else [30, 90, 180]
@@ -270,7 +326,7 @@ class Settings(BaseSettings):
                 period_str = period_str.strip()
                 if period_str:
                     period = int(period_str)
-                    if period in PERIOD_PRICES:
+                    if hasattr(self, f'PRICE_{period}_DAYS'):
                         periods.append(period)
             
             return periods if periods else [30, 90, 180]
@@ -375,6 +431,15 @@ class Settings(BaseSettings):
         except Exception as e:
             logger.info(f"ERROR PARSING CONFIG: {e}")
             return self._get_fallback_traffic_packages()
+
+    def is_version_check_enabled(self) -> bool:
+        return self.VERSION_CHECK_ENABLED
+    
+    def get_version_check_repo(self) -> str:
+        return self.VERSION_CHECK_REPO
+    
+    def get_version_check_interval(self) -> int:
+        return self.VERSION_CHECK_INTERVAL_HOURS
     
     def _get_fallback_traffic_packages(self) -> List[Dict]:
         try:
@@ -455,13 +520,13 @@ class Settings(BaseSettings):
     
     model_config = {
         "env_file": ".env",
-        "env_file_encoding": "utf-8"
+        "env_file_encoding": "utf-8",
+        "extra": "ignore"  
     }
 
 
 settings = Settings()
 
-
 PERIOD_PRICES = {
     14: settings.PRICE_14_DAYS,
     30: settings.PRICE_30_DAYS,
@@ -482,3 +547,6 @@ def refresh_traffic_prices():
     TRAFFIC_PRICES = get_traffic_prices()
 
 refresh_traffic_prices()
+
+settings._original_database_url = settings.DATABASE_URL
+settings.DATABASE_URL = settings.get_database_url()

app/external/telegram_stars.py

@@ -45,8 +45,8 @@ class TelegramStarsService:
             )
             
             logger.info(
-                f"Создан Stars invoice на {stars_amount} звезд (~{amount_rubles:.2f}₽) "
-                f"для {chat_id}, курс: {settings.get_stars_rate():.2f}₽/⭐"
+                f"Создан Stars invoice на {stars_amount} звезд (~{int(amount_rubles)}₽) "
+                f"для {chat_id}, курс: {int(settings.get_stars_rate())}₽/⭐"
             )
             return invoice_link
             
@@ -80,7 +80,7 @@ class TelegramStarsService:
             
             logger.info(
                 f"Отправлен Stars invoice {message.message_id} на {stars_amount} звезд "
-                f"(~{amount_rubles:.2f}₽), курс: {settings.get_stars_rate():.2f}₽/⭐"
+                f"(~{int(amount_rubles)}₽), курс: {int(settings.get_stars_rate())}₽/⭐"
             )
             return {
                 "message_id": message.message_id,

app/handlers/admin/servers.py

@@ -37,7 +37,7 @@ async def show_servers_menu(
 • С подключениями: {stats['servers_with_connections']}
 
 💰 <b>Выручка от серверов:</b>
-• Общая: {stats['total_revenue_rubles']:.2f} ₽
+• Общая: {int(stats['total_revenue_rubles'])} ₽
 
 Выберите действие:
 """
@@ -83,7 +83,7 @@ async def show_servers_list(
         
         for i, server in enumerate(servers, 1 + (page - 1) * 10):
             status_emoji = "✅" if server.is_available else "❌"
-            price_text = f"{server.price_rubles:.2f} ₽" if server.price_kopeks > 0 else "Бесплатно"
+            price_text = f"{int(server.price_rubles)} ₽" if server.price_kopeks > 0 else "Бесплатно"
             
             text += f"{i}. {status_emoji} {server.display_name}\n"
             text += f"   💰 Цена: {price_text}"
@@ -222,7 +222,7 @@ async def show_server_edit_menu(
         return
     
     status_emoji = "✅ Доступен" if server.is_available else "❌ Недоступен"
-    price_text = f"{server.price_rubles:.2f} ₽" if server.price_kopeks > 0 else "Бесплатно"
+    price_text = f"{int(server.price_rubles)} ₽" if server.price_kopeks > 0 else "Бесплатно"
     
     text = f"""
 🌐 <b>Редактирование сервера</b>
@@ -304,7 +304,7 @@ async def toggle_server_availability(
     server = await get_server_squad_by_id(db, server_id)
     
     status_emoji = "✅ Доступен" if server.is_available else "❌ Недоступен"
-    price_text = f"{server.price_rubles:.2f} ₽" if server.price_kopeks > 0 else "Бесплатно"
+    price_text = f"{int(server.price_rubles)} ₽" if server.price_kopeks > 0 else "Бесплатно"
     
     text = f"""
 🌐 <b>Редактирование сервера</b>
@@ -378,7 +378,7 @@ async def start_server_edit_price(
     await state.set_data({'server_id': server_id})
     await state.set_state(AdminStates.editing_server_price)
     
-    current_price = f"{server.price_rubles:.2f} ₽" if server.price_kopeks > 0 else "Бесплатно"
+    current_price = f"{int(server.price_rubles)} ₽" if server.price_kopeks > 0 else "Бесплатно"
     
     await callback.message.edit_text(
         f"💰 <b>Редактирование цены</b>\n\n"
@@ -424,7 +424,7 @@ async def process_server_price_edit(
             
             await cache.delete("available_countries")
             
-            price_text = f"{price_rubles:.2f} ₽" if price_kopeks > 0 else "Бесплатно"
+            price_text = f"{int(price_rubles)} ₽" if price_kopeks > 0 else "Бесплатно"
             await message.answer(
                 f"✅ Цена сервера изменена на: <b>{price_text}</b>",
                 reply_markup=types.InlineKeyboardMarkup(inline_keyboard=[
@@ -613,8 +613,8 @@ async def show_server_detailed_stats(
 • С активными подключениями: {stats['servers_with_connections']}
 
 <b>💰 Финансовая статистика:</b>
-• Общая выручка: {stats['total_revenue_rubles']:.2f} ₽
-• Средняя цена за сервер: {(stats['total_revenue_rubles'] / max(stats['servers_with_connections'], 1)):.2f} ₽
+• Общая выручка: {int(stats['total_revenue_rubles'])} ₽
+• Средняя цена за сервер: {int(stats['total_revenue_rubles'] / max(stats['servers_with_connections'], 1))} ₽
 
 <b>🔥 Топ серверов по цене:</b>
 """
@@ -622,7 +622,7 @@ async def show_server_detailed_stats(
     sorted_servers = sorted(available_servers, key=lambda x: x.price_kopeks, reverse=True)
     
     for i, server in enumerate(sorted_servers[:5], 1):
-        price_text = f"{server.price_rubles:.2f} ₽" if server.price_kopeks > 0 else "Бесплатно"
+        price_text = f"{int(server.price_rubles)} ₽" if server.price_kopeks > 0 else "Бесплатно"
         text += f"{i}. {server.display_name} - {price_text}\n"
     
     if not sorted_servers:

app/handlers/admin/updates.py

@@ -0,0 +1,274 @@
+import logging
+from aiogram import Dispatcher, types, F
+from aiogram.types import InlineKeyboardMarkup, InlineKeyboardButton
+from sqlalchemy.ext.asyncio import AsyncSession
+
+from app.config import settings
+from app.database.models import User
+from app.services.version_service import version_service
+from app.utils.decorators import admin_required, error_handler
+
+logger = logging.getLogger(__name__)
+
+
+def get_updates_keyboard(language: str = "ru") -> InlineKeyboardMarkup:
+    buttons = [
+        [
+            InlineKeyboardButton(
+                text="🔄 Проверить обновления",
+                callback_data="admin_updates_check"
+            )
+        ],
+        [
+            InlineKeyboardButton(
+                text="📋 Информация о версии",
+                callback_data="admin_updates_info"
+            )
+        ],
+        [
+            InlineKeyboardButton(
+                text="🔗 Открыть репозиторий",
+                url=f"https://github.com/{version_service.repo}/releases"
+            )
+        ],
+        [
+            InlineKeyboardButton(
+                text="◀️ Назад",
+                callback_data="admin_panel"
+            )
+        ]
+    ]
+    
+    return InlineKeyboardMarkup(inline_keyboard=buttons)
+
+
+def get_version_info_keyboard(language: str = "ru") -> InlineKeyboardMarkup:
+    buttons = [
+        [
+            InlineKeyboardButton(
+                text="🔄 Обновить",
+                callback_data="admin_updates_info"
+            )
+        ],
+        [
+            InlineKeyboardButton(
+                text="◀️ К обновлениям",
+                callback_data="admin_updates"
+            )
+        ]
+    ]
+    
+    return InlineKeyboardMarkup(inline_keyboard=buttons)
+
+
+@admin_required
+@error_handler
+async def show_updates_menu(
+    callback: types.CallbackQuery,
+    db_user: User,
+    db: AsyncSession
+):
+    try:
+        version_info = await version_service.get_version_info()
+        
+        current_version = version_info['current_version']
+        has_updates = version_info['has_updates']
+        total_newer = version_info['total_newer']
+        last_check = version_info['last_check']
+        
+        status_icon = "🆕" if has_updates else "✅"
+        status_text = f"Доступно {total_newer} обновлений" if has_updates else "Актуальная версия"
+        
+        last_check_text = ""
+        if last_check:
+            last_check_text = f"\n🕐 Последняя проверка: {last_check.strftime('%d.%m.%Y %H:%M')}"
+        
+        message = f"""🔄 <b>СИСТЕМА ОБНОВЛЕНИЙ</b>
+
+📦 <b>Текущая версия:</b> <code>{current_version}</code>
+{status_icon} <b>Статус:</b> {status_text}
+
+🔗 <b>Репозиторий:</b> {version_service.repo}{last_check_text}
+
+ℹ️ Система автоматически проверяет обновления каждый час и отправляет уведомления о новых версиях."""
+        
+        await callback.message.edit_text(
+            message,
+            reply_markup=get_updates_keyboard(db_user.language),
+            parse_mode="HTML"
+        )
+        await callback.answer()
+        
+    except Exception as e:
+        logger.error(f"Ошибка показа меню обновлений: {e}")
+        await callback.answer("❌ Ошибка загрузки меню обновлений", show_alert=True)
+
+
+@admin_required
+@error_handler
+async def check_updates(
+    callback: types.CallbackQuery,
+    db_user: User,
+    db: AsyncSession
+):
+    await callback.answer("🔄 Проверяю обновления...")
+    
+    try:
+        has_updates, newer_releases = await version_service.check_for_updates(force=True)
+        
+        if not has_updates:
+            message = f"""✅ <b>ОБНОВЛЕНИЯ НЕ НАЙДЕНЫ</b>
+
+📦 <b>Текущая версия:</b> <code>{version_service.current_version}</code>
+🎯 <b>Статус:</b> У вас установлена последняя версия
+
+🔗 <b>Репозиторий:</b> {version_service.repo}"""
+            
+        else:
+            updates_list = []
+            for i, release in enumerate(newer_releases[:5]): 
+                icon = version_service.format_version_display(release).split()[0]
+                updates_list.append(
+                    f"{i+1}. {icon} <code>{release.tag_name}</code> • {release.formatted_date}"
+                )
+            
+            updates_text = "\n".join(updates_list)
+            more_text = f"\n\n📋 И еще {len(newer_releases) - 5} обновлений..." if len(newer_releases) > 5 else ""
+            
+            message = f"""🆕 <b>НАЙДЕНЫ ОБНОВЛЕНИЯ</b>
+
+📦 <b>Текущая версия:</b> <code>{version_service.current_version}</code>
+🎯 <b>Доступно обновлений:</b> {len(newer_releases)}
+
+📋 <b>Последние версии:</b>
+{updates_text}{more_text}
+
+🔗 <b>Репозиторий:</b> {version_service.repo}"""
+        
+        keyboard = get_updates_keyboard(db_user.language)
+        
+        if has_updates:
+            keyboard.inline_keyboard.insert(-2, [
+                InlineKeyboardButton(
+                    text="📋 Подробнее о версиях",
+                    callback_data="admin_updates_info"
+                )
+            ])
+        
+        await callback.message.edit_text(
+            message,
+            reply_markup=keyboard,
+            parse_mode="HTML"
+        )
+        
+    except Exception as e:
+        logger.error(f"Ошибка проверки обновлений: {e}")
+        await callback.message.edit_text(
+            f"❌ <b>ОШИБКА ПРОВЕРКИ ОБНОВЛЕНИЙ</b>\n\n"
+            f"Не удалось связаться с сервером GitHub.\n"
+            f"Попробуйте позже.\n\n"
+            f"📦 <b>Текущая версия:</b> <code>{version_service.current_version}</code>",
+            reply_markup=get_updates_keyboard(db_user.language),
+            parse_mode="HTML"
+        )
+
+
+@admin_required
+@error_handler
+async def show_version_info(
+    callback: types.CallbackQuery,
+    db_user: User,
+    db: AsyncSession
+):
+    await callback.answer("📋 Загружаю информацию о версиях...")
+    
+    try:
+        version_info = await version_service.get_version_info()
+        
+        current_version = version_info['current_version']
+        current_release = version_info['current_release']
+        newer_releases = version_info['newer_releases']
+        has_updates = version_info['has_updates']
+        last_check = version_info['last_check']
+        repo_url = version_info['repo_url']
+        
+        current_info = f"📦 <b>ТЕКУЩАЯ ВЕРСИЯ</b>\n\n"
+        
+        if current_release:
+            current_info += f"🏷️ <b>Версия:</b> <code>{current_release.tag_name}</code>\n"
+            current_info += f"📅 <b>Дата релиза:</b> {current_release.formatted_date}\n"
+            if current_release.short_description:
+                current_info += f"📝 <b>Описание:</b>\n{current_release.short_description}\n"
+        else:
+            current_info += f"🏷️ <b>Версия:</b> <code>{current_version}</code>\n"
+            current_info += f"ℹ️ <b>Статус:</b> Информация о релизе недоступна\n"
+        
+        message_parts = [current_info]
+        
+        if has_updates and newer_releases:
+            updates_info = f"\n🆕 <b>ДОСТУПНЫЕ ОБНОВЛЕНИЯ</b>\n\n"
+            
+            for i, release in enumerate(newer_releases):
+                icon = "🔥" if i == 0 else "📦"
+                if release.prerelease:
+                    icon = "🧪"
+                elif release.is_dev:
+                    icon = "🔧"
+                
+                updates_info += f"{icon} <b>{release.tag_name}</b>\n"
+                updates_info += f"   📅 {release.formatted_date}\n"
+                if release.short_description:
+                    updates_info += f"   📝 {release.short_description}\n"
+                updates_info += "\n"
+            
+            message_parts.append(updates_info.rstrip())
+        
+        system_info = f"\n🔧 <b>СИСТЕМА ОБНОВЛЕНИЙ</b>\n\n"
+        system_info += f"🔗 <b>Репозиторий:</b> {version_service.repo}\n"
+        system_info += f"⚡ <b>Автопроверка:</b> {'Включена' if version_service.enabled else 'Отключена'}\n"
+        system_info += f"🕐 <b>Интервал:</b> Каждый час\n"
+        
+        if last_check:
+            system_info += f"🕐 <b>Последняя проверка:</b> {last_check.strftime('%d.%m.%Y %H:%M')}\n"
+        
+        message_parts.append(system_info.rstrip())
+        
+        final_message = "\n".join(message_parts)
+        
+        if len(final_message) > 4000:
+            final_message = final_message[:3900] + "\n\n... (информация обрезана)"
+        
+        await callback.message.edit_text(
+            final_message,
+            reply_markup=get_version_info_keyboard(db_user.language),
+            parse_mode="HTML",
+            disable_web_page_preview=True
+        )
+        
+    except Exception as e:
+        logger.error(f"Ошибка получения информации о версиях: {e}")
+        await callback.message.edit_text(
+            f"❌ <b>ОШИБКА ЗАГРУЗКИ</b>\n\n"
+            f"Не удалось получить информацию о версиях.\n\n"
+            f"📦 <b>Текущая версия:</b> <code>{version_service.current_version}</code>",
+            reply_markup=get_version_info_keyboard(db_user.language),
+            parse_mode="HTML"
+        )
+
+
+def register_handlers(dp: Dispatcher):
+    
+    dp.callback_query.register(
+        show_updates_menu,
+        F.data == "admin_updates"
+    )
+    
+    dp.callback_query.register(
+        check_updates,
+        F.data == "admin_updates_check"
+    )
+    
+    dp.callback_query.register(
+        show_version_info,
+        F.data == "admin_updates_info"
+    )

app/handlers/admin/users.py

@@ -636,9 +636,9 @@ async def process_balance_edit(
         
         description = f"Изменение баланса администратором {db_user.full_name}"
         if amount_kopeks > 0:
-            description = f"Пополнение администратором: +{amount_rubles} ₽"
+            description = f"Пополнение администратором: +{int(amount_rubles)} ₽"
         else:
-            description = f"Списание администратором: {amount_rubles} ₽"
+            description = f"Списание администратором: {int(amount_rubles)} ₽"
         
         success = await user_service.update_user_balance(
             db, user_id, amount_kopeks, description, db_user.id

app/handlers/balance.py

@@ -381,7 +381,7 @@ async def process_stars_payment_amount(
             f"⭐ <b>Оплата через Telegram Stars</b>\n\n"
             f"💰 Сумма: {texts.format_price(amount_kopeks)}\n"
             f"⭐ К оплате: {stars_amount} звезд\n"
-            f"📊 Курс: {settings.get_stars_rate():.2f}₽ за звезду\n\n"
+            f"📊 Курс: {int(settings.get_stars_rate())}₽ за звезду\n\n"
             f"Нажмите кнопку ниже для оплаты:",
             reply_markup=keyboard,
             parse_mode="HTML"
@@ -465,7 +465,7 @@ async def process_yookassa_payment_amount(
         await state.clear()
         
         logger.info(f"Создан платеж YooKassa для пользователя {db_user.telegram_id}: "
-                   f"{amount_kopeks/100}₽, ID: {payment_result['yookassa_payment_id']}")
+                   f"{amount_kopeks//100}₽, ID: {payment_result['yookassa_payment_id']}")
         
     except Exception as e:
         logger.error(f"Ошибка создания YooKassa платежа: {e}")

app/handlers/referral.py

@@ -1,12 +1,21 @@
 import logging
-from aiogram import Dispatcher, types, F
+from pathlib import Path
+
+import qrcode
+from aiogram import Dispatcher, F, types
+from aiogram.exceptions import TelegramBadRequest
+from aiogram.types import FSInputFile
 from sqlalchemy.ext.asyncio import AsyncSession
 
 from app.config import settings
 from app.database.models import User
-from app.keyboards.inline import get_referral_keyboard, get_back_keyboard
+from app.keyboards.inline import get_referral_keyboard
 from app.localization.texts import get_texts
-from app.utils.user_utils import get_user_referral_summary, get_detailed_referral_list, get_referral_analytics
+from app.utils.user_utils import (
+    get_detailed_referral_list,
+    get_referral_analytics,
+    get_user_referral_summary,
+)
 
 logger = logging.getLogger(__name__)
 
@@ -82,11 +91,59 @@ async def show_referral_info(
     
     referral_text += "📢 Приглашайте друзей и зарабатывайте!"
     
-    await callback.message.edit_text(
-        referral_text,
-        reply_markup=get_referral_keyboard(db_user.language),
-        parse_mode="HTML"
+    if callback.message.text:
+        await callback.message.edit_text(
+            referral_text,
+            reply_markup=get_referral_keyboard(db_user.language),
+            parse_mode="HTML"
+        )
+    else:
+        await callback.message.delete()
+        await callback.message.answer(
+            referral_text,
+            reply_markup=get_referral_keyboard(db_user.language),
+            parse_mode="HTML"
+        )
+    await callback.answer()
+
+
+async def show_referral_qr(
+    callback: types.CallbackQuery,
+    db_user: User,
+):
+    texts = get_texts(db_user.language)
+
+    bot_username = (await callback.bot.get_me()).username
+    referral_link = f"https://t.me/{bot_username}?start={db_user.referral_code}"
+
+    qr_dir = Path("data") / "referral_qr"
+    qr_dir.mkdir(parents=True, exist_ok=True)
+
+    file_path = qr_dir / f"{db_user.id}.png"
+    if not file_path.exists():
+        img = qrcode.make(referral_link)
+        img.save(file_path)
+
+    photo = FSInputFile(file_path)
+    keyboard = types.InlineKeyboardMarkup(
+        inline_keyboard=[[types.InlineKeyboardButton(text=texts.BACK, callback_data="menu_referrals")]]
     )
+
+    try:
+        await callback.message.edit_media(
+            types.InputMediaPhoto(
+                media=photo,
+                caption=f"🔗 Ваша реферальная ссылка:\n{referral_link}",
+            ),
+            reply_markup=keyboard,
+        )
+    except TelegramBadRequest:
+        await callback.message.delete()
+        await callback.message.answer_photo(
+            photo,
+            caption=f"🔗 Ваша реферальная ссылка:\n{referral_link}",
+            reply_markup=keyboard,
+        )
     await callback.answer()
 
 
@@ -243,6 +300,11 @@ def register_handlers(dp: Dispatcher):
         create_invite_message,
         F.data == "referral_create_invite"
     )
+
+    dp.callback_query.register(
+        show_referral_qr,
+        F.data == "referral_show_qr"
+    )
     
     dp.callback_query.register(
         show_detailed_referral_list,

app/handlers/stars_payments.py

@@ -92,7 +92,7 @@ async def handle_successful_payment(
             await message.answer(
                 f"🎉 <b>Платеж успешно обработан!</b>\n\n"
                 f"⭐ Потрачено звезд: {payment.total_amount}\n"
-                f"💰 Зачислено на баланс: {rubles_amount:.2f} ₽\n"
+                f"💰 Зачислено на баланс: {int(rubles_amount)} ₽\n"
                 f"🆔 ID транзакции: {payment.telegram_payment_charge_id[:8]}...\n\n"
                 f"Спасибо за пополнение! 🚀",
                 parse_mode="HTML"
@@ -100,7 +100,7 @@ async def handle_successful_payment(
             
             logger.info(
                 f"✅ Stars платеж успешно обработан: "
-                f"пользователь {user.id}, {payment.total_amount} звезд → {rubles_amount:.2f}₽"
+                f"пользователь {user.id}, {payment.total_amount} звезд → {int(rubles_amount)}₽"
             )
         else:
             logger.error(f"Ошибка обработки Stars платежа для пользователя {user.id}")

app/handlers/start.py

@@ -521,10 +521,10 @@ async def complete_registration_from_callback(
     except Exception as e:
         logger.error(f"Ошибка при отправке главного меню: {e}")
         try:
-            balance_rubles = user.balance_kopeks / 100
+            balance_rubles = user.balance_kopeks // 100
             await callback.message.answer(
                 f"Добро пожаловать, {user.full_name}!\n"
-                f"Баланс: {balance_rubles:.2f} ₽\n"
+                f"Баланс: {balance_rubles} ₽\n"
                 f"Подписка: Нет активной подписки",
                 reply_markup=get_main_menu_keyboard(
                     language=user.language,
@@ -684,10 +684,10 @@ async def complete_registration(
     except Exception as e:
         logger.error(f"Ошибка при отправке главного меню: {e}")
         try:
-            balance_rubles = user.balance_kopeks / 100
+            balance_rubles = user.balance_kopeks // 100
             await message.answer(
                 f"Добро пожаловать, {user.full_name}!\n"
-                f"Баланс: {balance_rubles:.2f} ₽\n"
+                f"Баланс: {balance_rubles} ₽\n"
                 f"Подписка: Нет активной подписки",
                 reply_markup=get_main_menu_keyboard(
                     language=user.language,

app/handlers/subscription.py

@@ -34,7 +34,8 @@ from app.keyboards.inline import (
     get_manage_countries_keyboard,
     get_device_selection_keyboard, get_connection_guide_keyboard,
     get_app_selection_keyboard, get_specific_app_keyboard,
-    get_subscription_settings_keyboard, get_extend_subscription_keyboard_with_prices
+    get_subscription_settings_keyboard, get_extend_subscription_keyboard_with_prices,
+    get_insufficient_balance_keyboard
 )
 from app.localization.texts import get_texts
 from app.services.remnawave_service import RemnaWaveService
@@ -1415,13 +1416,13 @@ async def get_traffic_packages_info() -> str:
             info_lines.append("\n✅ Активные:")
             for pkg in enabled_packages:
                 gb_text = "♾️ Безлимит" if pkg['gb'] == 0 else f"{pkg['gb']} ГБ"
-                info_lines.append(f"   • {gb_text}: {pkg['price']/100}₽")
+                info_lines.append(f"   • {gb_text}: {pkg['price']//100}₽")
         
         if disabled_packages:
             info_lines.append("\n❌ Отключенные:")
             for pkg in disabled_packages:
                 gb_text = "♾️ Безлимит" if pkg['gb'] == 0 else f"{pkg['gb']} ГБ"
-                info_lines.append(f"   • {gb_text}: {pkg['price']/100}₽")
+                info_lines.append(f"   • {gb_text}: {pkg['price']//100}₽")
         
         info_lines.append(f"\n📊 Всего пакетов: {len(packages)}")
         info_lines.append(f"🟢 Активных: {len(enabled_packages)}")
@@ -1796,9 +1797,10 @@ async def confirm_purchase(
     logger.info(f"   ИТОГО: {final_price/100}₽")
     
     if db_user.balance_kopeks < final_price:
+        missing_kopeks = final_price - db_user.balance_kopeks
         await callback.message.edit_text(
-            texts.INSUFFICIENT_BALANCE,
-            reply_markup=get_back_keyboard(db_user.language)
+            texts.INSUFFICIENT_BALANCE.format(amount=texts.format_price(missing_kopeks)),
+            reply_markup=get_insufficient_balance_keyboard(db_user.language),
         )
         await callback.answer()
         return
@@ -1810,9 +1812,10 @@ async def confirm_purchase(
         )
         
         if not success:
+            missing_kopeks = final_price - db_user.balance_kopeks
             await callback.message.edit_text(
-                texts.INSUFFICIENT_BALANCE,
-                reply_markup=get_back_keyboard(db_user.language)
+                texts.INSUFFICIENT_BALANCE.format(amount=texts.format_price(missing_kopeks)),
+                reply_markup=get_insufficient_balance_keyboard(db_user.language),
             )
             await callback.answer()
             return
@@ -1918,9 +1921,9 @@ async def confirm_purchase(
         
         if remnawave_user and hasattr(subscription, 'subscription_url') and subscription.subscription_url:
             success_text = f"{texts.SUBSCRIPTION_PURCHASED}\n\n"
-            success_text += f"Ваша ссылка для импорта в VPN приложение:\n"
+            success_text += f"🔗 <b>Ваша ссылка для импорта в VPN приложение:</b>\n"
             success_text += f"<code>{subscription.subscription_url}</code>\n\n"
-            success_text += f"Нажмите кнопку ниже, чтобы получить инструкцию по настройке VPN на вашем устройстве"
+            success_text += f"📱 Нажмите кнопку ниже, чтобы получить инструкцию по настройке VPN на вашем устройстве"
 
             connect_mode = settings.CONNECT_BUTTON_MODE
 
@@ -1928,12 +1931,12 @@ async def confirm_purchase(
                 connect_keyboard = InlineKeyboardMarkup(inline_keyboard=[
                     [
                         InlineKeyboardButton(
-                            text="Подключиться",
+                            text="🔗 Подключиться",
                             web_app=types.WebAppInfo(url=subscription.subscription_url),
                         )
                     ],
-                    [InlineKeyboardButton(text="Моя подписка", callback_data="menu_subscription")],
-                    [InlineKeyboardButton(text="В главное меню", callback_data="back_to_menu")],
+                    [InlineKeyboardButton(text="📱 Моя подписка", callback_data="menu_subscription")],
+                    [InlineKeyboardButton(text="⬅️ В главное меню", callback_data="back_to_menu")],
                 ])
             elif connect_mode == "miniapp_custom":
                 if not settings.MINIAPP_CUSTOM_URL:
@@ -1943,18 +1946,18 @@ async def confirm_purchase(
                 connect_keyboard = InlineKeyboardMarkup(inline_keyboard=[
                     [
                         InlineKeyboardButton(
-                            text="Подключиться",
+                            text="🔗 Подключиться",
                             web_app=types.WebAppInfo(url=settings.MINIAPP_CUSTOM_URL),
                         )
                     ],
-                    [InlineKeyboardButton(text="Моя подписка", callback_data="menu_subscription")],
-                    [InlineKeyboardButton(text="В главное меню", callback_data="back_to_menu")],
+                    [InlineKeyboardButton(text="📱 Моя подписка", callback_data="menu_subscription")],
+                    [InlineKeyboardButton(text="⬅️ В главное меню", callback_data="back_to_menu")],
                 ])
             else:
                 connect_keyboard = InlineKeyboardMarkup(inline_keyboard=[
-                    [InlineKeyboardButton(text="Подключиться", callback_data="subscription_connect")],
-                    [InlineKeyboardButton(text="Моя подписка", callback_data="menu_subscription")],
-                    [InlineKeyboardButton(text="В главное меню", callback_data="back_to_menu")],
+                    [InlineKeyboardButton(text="🔗 Подключиться", callback_data="subscription_connect")],
+                    [InlineKeyboardButton(text="📱 Моя подписка", callback_data="menu_subscription")],
+                    [InlineKeyboardButton(text="⬅️ В главное меню", callback_data="back_to_menu")],
                 ])
     
             await callback.message.edit_text(

app/keyboards/admin.py

@@ -29,7 +29,8 @@ def get_admin_main_keyboard(language: str = "ru") -> InlineKeyboardMarkup:
             InlineKeyboardButton(text="🔧 Техработы", callback_data="maintenance_panel")
         ],
         [
-            InlineKeyboardButton(text="📢 Сообщения в меню", callback_data="user_messages_panel")
+            InlineKeyboardButton(text="📢 Сообщения в меню", callback_data="user_messages_panel"),
+            InlineKeyboardButton(text="🔄 Обновления", callback_data="admin_updates")
         ],
         [
             InlineKeyboardButton(text=texts.BACK, callback_data="back_to_menu")

app/keyboards/inline.py

@@ -104,6 +104,19 @@ def get_back_keyboard(language: str = "ru") -> InlineKeyboardMarkup:
     ])
 
 
+def get_insufficient_balance_keyboard(language: str = "ru") -> InlineKeyboardMarkup:
+    texts = get_texts(language)
+    return InlineKeyboardMarkup(inline_keyboard=[
+        [
+            InlineKeyboardButton(
+                text=texts.GO_TO_BALANCE_TOP_UP,
+                callback_data="balance_topup",
+            )
+        ],
+        [InlineKeyboardButton(text=texts.BACK, callback_data="back_to_menu")],
+    ])
+
+
 def get_subscription_keyboard(
     language: str = "ru", 
     has_subscription: bool = False, 
@@ -415,15 +428,7 @@ def get_balance_keyboard(language: str = "ru") -> InlineKeyboardMarkup:
 def get_payment_methods_keyboard(amount_kopeks: int, language: str = "ru") -> InlineKeyboardMarkup:
     texts = get_texts(language)
     keyboard = []
-    
-    if settings.TELEGRAM_STARS_ENABLED:
-        keyboard.append([
-            InlineKeyboardButton(
-                text="⭐ Telegram Stars", 
-                callback_data="topup_stars"
-            )
-        ])
-    
+ 
     if settings.is_yookassa_enabled():
         keyboard.append([
             InlineKeyboardButton(
@@ -435,11 +440,19 @@ def get_payment_methods_keyboard(amount_kopeks: int, language: str = "ru") -> In
     if settings.TRIBUTE_ENABLED:
         keyboard.append([
             InlineKeyboardButton(
-                text="💎 Банковская карта (Tribute)", 
+                text="💳 Банковская карта (Tribute)", 
                 callback_data="topup_tribute"
             )
         ])
-    
+
+    if settings.TELEGRAM_STARS_ENABLED:
+        keyboard.append([
+            InlineKeyboardButton(
+                text="⭐ Telegram Stars", 
+                callback_data="topup_stars"
+            )
+        ])
+
     keyboard.append([
         InlineKeyboardButton(
             text="🛠️ Через поддержку", 
@@ -533,6 +546,12 @@ def get_referral_keyboard(language: str = "ru") -> InlineKeyboardMarkup:
                 callback_data="referral_create_invite"
             )
         ],
+        [
+            InlineKeyboardButton(
+                text="📱 Показать QR код",
+                callback_data="referral_show_qr"
+            )
+        ],
         [
             InlineKeyboardButton(
                 text="👥 Список рефералов",
@@ -715,14 +734,14 @@ def get_add_traffic_keyboard(language: str = "ru", subscription_end_date: dateti
         
         if gb == 0:
             if language == "ru":
-                text = f"♾️ Безлимитный трафик - {total_price/100:.2f} ₽{period_text}"
+                text = f"♾️ Безлимитный трафик - {total_price//100} ₽{period_text}"
             else:
-                text = f"♾️ Unlimited traffic - {total_price/100:.2f} ₽{period_text}"
+                text = f"♾️ Unlimited traffic - {total_price//100} ₽{period_text}"
         else:
             if language == "ru":
-                text = f"📊 +{gb} ГБ трафика - {total_price/100:.2f} ₽{period_text}"
+                text = f"📊 +{gb} ГБ трафика - {total_price//100} ₽{period_text}"
             else:
-                text = f"📊 +{gb} GB traffic - {total_price/100:.2f} ₽{period_text}"
+                text = f"📊 +{gb} GB traffic - {total_price//100} ₽{period_text}"
         
         buttons.append([
             InlineKeyboardButton(text=text, callback_data=f"add_traffic_{gb}")
@@ -761,9 +780,9 @@ def get_add_devices_keyboard(current_devices: int, language: str = "ru", subscri
         total_price = price_per_month * months_multiplier
         
         if language == "ru":
-            text = f"📱 +{count} устройство(а) (итого: {new_total}) - {total_price/100:.2f} ₽{period_text}"
+            text = f"📱 +{count} устройство(а) (итого: {new_total}) - {total_price//100} ₽{period_text}"
         else:
-            text = f"📱 +{count} device(s) (total: {new_total}) - {total_price/100:.2f} ₽{period_text}"
+            text = f"📱 +{count} device(s) (total: {new_total}) - {total_price//100} ₽{period_text}"
         
         buttons.append([
             InlineKeyboardButton(text=text, callback_data=f"add_devices_{count}")
@@ -835,10 +854,10 @@ def get_manage_countries_keyboard(
         if uuid not in current_subscription_countries and uuid in selected:
             total_price = price_per_month * months_multiplier
             if months_multiplier > 1:
-                price_text = f" ({price_per_month/100:.2f}₽/мес × {months_multiplier} = {total_price/100:.2f}₽)"
+                price_text = f" ({price_per_month//100}₽/мес × {months_multiplier} = {total_price//100}₽)"
                 logger.info(f"🔍 Сервер {name}: {price_per_month/100}₽/мес × {months_multiplier} мес = {total_price/100}₽")
             else:
-                price_text = f" ({total_price/100:.2f}₽)"
+                price_text = f" ({total_price//100}₽)"
             display_name = f"{icon} {name}{price_text}"
         else:
             display_name = f"{icon} {name}"
@@ -851,7 +870,7 @@ def get_manage_countries_keyboard(
         ])
     
     if total_cost > 0:
-        apply_text = f"✅ Применить изменения ({total_cost/100:.2f} ₽)"
+        apply_text = f"✅ Применить изменения ({total_cost//100} ₽)"
         logger.info(f"🔍 Общая стоимость новых серверов: {total_cost/100}₽")
     else:
         apply_text = "✅ Применить изменения"

app/localization/texts.py

@@ -57,7 +57,7 @@ class Texts:
     
     @staticmethod
     def format_price(kopeks: int) -> str:
-        return f"{kopeks / 100:.2f} ₽"
+        return f"{int(kopeks / 100)} ₽"
     
     @staticmethod
     def format_traffic(gb: float) -> str:
@@ -125,7 +125,7 @@ class RussianTexts(Texts):
     MENU_LANGUAGE = "🌐 Язык"
     MENU_ADMIN = "⚙️ Админ-панель"
     BALANCE_BUTTON = "💰 Баланс: {balance}"
-    BALANCE_BUTTON_ZERO = "💰 Баланс: 0.00 ₽"
+    BALANCE_BUTTON_ZERO = "💰 Баланс: 0 ₽"
     
     SUBSCRIPTION_NONE = "❌ Нет активной подписки"
     SUBSCRIPTION_TRIAL = "🧪 Тестовая подписка"
@@ -204,7 +204,11 @@ class RussianTexts(Texts):
 Подтвердить покупку?
 """
     
-    INSUFFICIENT_BALANCE = "❌ Недостаточно средств на балансе. Пополните баланс и попробуйте снова."
+    INSUFFICIENT_BALANCE = """❌ Недостаточно средств на балансе.  
+    
+    <b>Пополните баланс на {amount} и попробуйте снова.</b>
+    """
+    GO_TO_BALANCE_TOP_UP = "💳 Перейти к пополнению баланса"
     SUBSCRIPTION_PURCHASED = "🎉 Подписка успешно приобретена!"
     
     BALANCE_INFO = """
@@ -443,10 +447,14 @@ To get started, select interface language:
     CONTINUE = "➡️ Continue"
     YES = "✅ Yes"
     NO = "❌ No"
-    
+
     MENU_BALANCE = "💰 Balance"
     MENU_SUBSCRIPTION = "📱 Subscription"
     MENU_TRIAL = "🎁 Trial subscription"
+    INSUFFICIENT_BALANCE = """❌ Insufficient balance. " \
+    
+    Top up {amount} and try again."""
+    GO_TO_BALANCE_TOP_UP = "💳 Go to balance top up"
     
 
 LANGUAGES = {

app/services/admin_notification_service.py

@@ -130,6 +130,78 @@ class AdminNotificationService:
         except Exception as e:
             logger.error(f"Ошибка отправки уведомления о покупке: {e}")
             return False
+
+    async def send_version_update_notification(
+        self,
+        current_version: str,
+        latest_version, 
+        total_updates: int
+    ) -> bool:
+        """Отправляет уведомление о новых обновлениях"""
+        if not self._is_enabled():
+            return False
+        
+        try:
+            if latest_version.prerelease:
+                update_type = "🧪 ПРЕДВАРИТЕЛЬНАЯ ВЕРСИЯ"
+                type_icon = "🧪"
+            elif latest_version.is_dev:
+                update_type = "🔧 DEV ВЕРСИЯ"
+                type_icon = "🔧"
+            else:
+                update_type = "📦 НОВАЯ ВЕРСИЯ"
+                type_icon = "📦"
+            
+            description = latest_version.short_description
+            if len(description) > 200:
+                description = description[:197] + "..."
+            
+            message = f"""{type_icon} <b>{update_type} ДОСТУПНА</b>
+    
+    📦 <b>Текущая версия:</b> <code>{current_version}</code>
+    🆕 <b>Новая версия:</b> <code>{latest_version.tag_name}</code>
+    📅 <b>Дата релиза:</b> {latest_version.formatted_date}
+    
+    📝 <b>Описание:</b>
+    {description}
+    
+    🔢 <b>Всего доступно обновлений:</b> {total_updates}
+    🔗 <b>Репозиторий:</b> https://github.com/{getattr(self, 'repo', 'fr1ngg/remnawave-bedolaga-telegram-bot')}
+    
+    ℹ️ Для обновления перезапустите контейнер с новым тегом или обновите код из репозитория.
+    
+    ⚙️ <i>Автоматическая проверка обновлений • {datetime.now().strftime('%d.%m.%Y %H:%M:%S')}</i>"""
+            
+            return await self._send_message(message)
+            
+        except Exception as e:
+            logger.error(f"Ошибка отправки уведомления об обновлении: {e}")
+            return False
+    
+    async def send_version_check_error_notification(
+        self,
+        error_message: str,
+        current_version: str
+    ) -> bool:
+        if not self._is_enabled():
+            return False
+        
+        try:
+            message = f"""⚠️ <b>ОШИБКА ПРОВЕРКИ ОБНОВЛЕНИЙ</b>
+    
+    📦 <b>Текущая версия:</b> <code>{current_version}</code>
+    ❌ <b>Ошибка:</b> {error_message}
+    
+    🔄 Следующая попытка через час.
+    ⚙️ Проверьте доступность GitHub API и настройки сети.
+    
+    ⚙️ <i>Система автоматических обновлений • {datetime.now().strftime('%d.%m.%Y %H:%M:%S')}</i>"""
+            
+            return await self._send_message(message)
+            
+        except Exception as e:
+            logger.error(f"Ошибка отправки уведомления об ошибке проверки версий: {e}")
+            return False
     
     async def send_balance_topup_notification(
         self,

app/services/payment_service.py

@@ -48,7 +48,7 @@ class PaymentService:
                 prices=[LabeledPrice(label="Пополнение", amount=stars_amount)]
             )
             
-            logger.info(f"Создан Stars invoice на {stars_amount} звезд (~{amount_rubles:.2f}₽)")
+            logger.info(f"Создан Stars invoice на {stars_amount} звезд (~{int(amount_rubles)}₽)")
             return invoice_link
             
         except Exception as e:
@@ -90,7 +90,7 @@ class PaymentService:
                 
                 logger.info(f"💰 Баланс пользователя {user.telegram_id} изменен: {old_balance} → {user.balance_kopeks} (изменение: +{amount_kopeks})")
                 
-                description_for_referral = f"Пополнение Stars: {rubles_amount:.2f}₽ ({stars_amount} ⭐)"
+                description_for_referral = f"Пополнение Stars: {int(rubles_amount)}₽ ({stars_amount} ⭐)"
                 logger.info(f"🔍 Проверка реферальной логики для описания: '{description_for_referral}'")
                 
                 if any(word in description_for_referral.lower() for word in ["пополнение", "stars", "yookassa", "topup"]) and not any(word in description_for_referral.lower() for word in ["комиссия", "бонус"]):
@@ -125,13 +125,15 @@ class PaymentService:
                             f"Баланс пополнен автоматически!",
                             parse_mode="HTML"
                         )
-                        logger.info(f"✅ Отправлено уведомление пользователю {user.telegram_id} о пополнении на {rubles_amount:.2f}₽")
+                        logger.info(
+                            f"✅ Отправлено уведомление пользователю {user.telegram_id} о пополнении на {int(rubles_amount)}₽"
+                        )
                     except Exception as e:
                         logger.error(f"Ошибка отправки уведомления о пополнении Stars: {e}")
                 
                 logger.info(
                     f"✅ Обработан Stars платеж: пользователь {user_id}, "
-                    f"{stars_amount} звезд → {rubles_amount:.2f}₽"
+                    f"{stars_amount} звезд → {int(rubles_amount)}₽"
                 )
                 return True
             else:
@@ -313,7 +315,7 @@ class PaymentService:
                                 f"Баланс пополнен автоматически!",
                                 parse_mode="HTML"
                             )
-                            logger.info(f"✅ Отправлено уведомление пользователю {user.telegram_id} о пополнении на {updated_payment.amount_kopeks/100:.2f}₽")
+                            logger.info(f"✅ Отправлено уведомление пользователю {user.telegram_id} о пополнении на {updated_payment.amount_kopeks//100}₽")
                         except Exception as e:
                             logger.error(f"Ошибка отправки уведомления о пополнении: {e}")
                 else:
@@ -352,7 +354,7 @@ class PaymentService:
             
             user = await get_user_by_id(db, payment.user_id)
             if user:
-                await add_user_balance(db, user, payment.amount_kopeks, f"Пополнение YooKassa: {payment.amount_kopeks/100:.2f}₽")
+                await add_user_balance(db, user, payment.amount_kopeks, f"Пополнение YooKassa: {payment.amount_kopeks//100}₽")
             
             logger.info(f"Успешно обработан платеж YooKassa {payment.yookassa_payment_id}: "
                        f"пользователь {payment.user_id} получил {payment.amount_kopeks/100}₽")

app/services/referral_service.py

@@ -63,7 +63,8 @@ async def process_referral_registration(
                 f"👥 <b>Новый реферал!</b>\n\n"
                 f"По вашей ссылке зарегистрировался пользователь <b>{new_user.full_name}</b>!\n\n"
                 f"💰 Когда он пополнит баланс от {settings.format_price(settings.REFERRAL_MINIMUM_TOPUP_KOPEKS)}, "
-                f"вы получите {settings.format_price(settings.REFERRAL_INVITER_BONUS_KOPEKS)}\n\n"
+                f"вы получите минимум {settings.format_price(settings.REFERRAL_INVITER_BONUS_KOPEKS)} или "
+                f"{settings.REFERRAL_COMMISSION_PERCENT}% от суммы (что больше).\n\n"
                 f"📈 С каждого последующего пополнения вы будете получать {settings.REFERRAL_COMMISSION_PERCENT}% комиссии."
             )
             await send_referral_notification(bot, referrer.telegram_id, inviter_notification)
@@ -131,27 +132,30 @@ async def process_referral_topup(
                     )
                     await send_referral_notification(bot, user.telegram_id, bonus_notification)
             
-            if settings.REFERRAL_INVITER_BONUS_KOPEKS > 0:
+            commission_amount = int(topup_amount_kopeks * settings.REFERRAL_COMMISSION_PERCENT / 100)
+            inviter_bonus = max(settings.REFERRAL_INVITER_BONUS_KOPEKS, commission_amount)
+
+            if inviter_bonus > 0:
                 await add_user_balance(
-                    db, referrer, settings.REFERRAL_INVITER_BONUS_KOPEKS,
+                    db, referrer, inviter_bonus,
                     f"Бонус за первое пополнение реферала {user.full_name}",
                     bot=bot
                 )
-                
+
                 await create_referral_earning(
                     db=db,
                     user_id=referrer.id,
-                    referral_id=user.id, 
-                    amount_kopeks=settings.REFERRAL_INVITER_BONUS_KOPEKS,
+                    referral_id=user.id,
+                    amount_kopeks=inviter_bonus,
                     reason="referral_first_topup"
                 )
-                logger.info(f"💰 Реферер {referrer.telegram_id} получил бонус {settings.REFERRAL_INVITER_BONUS_KOPEKS/100}₽")
-                
+                logger.info(f"💰 Реферер {referrer.telegram_id} получил бонус {inviter_bonus/100}₽")
+
                 if bot:
                     inviter_bonus_notification = (
                         f"💰 <b>Реферальная награда!</b>\n\n"
                         f"Ваш реферал <b>{user.full_name}</b> сделал первое пополнение!\n\n"
-                        f"🎁 Вы получили награду: {settings.format_price(settings.REFERRAL_INVITER_BONUS_KOPEKS)}\n\n"
+                        f"🎁 Вы получили награду: {settings.format_price(inviter_bonus)}\n\n"
                         f"📈 Теперь с каждого его пополнения вы будете получать {settings.REFERRAL_COMMISSION_PERCENT}% комиссии."
                     )
                     await send_referral_notification(bot, referrer.telegram_id, inviter_bonus_notification)

app/services/tribute_service.py

@@ -221,7 +221,7 @@ class TributeService:
             
             text = (
                 f"✅ **Платеж успешно получен!**\n\n"
-                f"💰 Сумма: {amount_rubles:.2f} ₽\n"
+                f"💰 Сумма: {int(amount_rubles)} ₽\n"
                 f"💳 Способ оплаты: Tribute\n"
                 f"🎉 Средства зачислены на баланс!\n\n"
                 f"Спасибо за оплату! 🙏"
@@ -277,7 +277,7 @@ class TributeService:
             
             text = (
                 f"🔄 **Возврат средств**\n\n"
-                f"💰 Сумма возврата: {amount_rubles:.2f} ₽\n"
+                f"💰 Сумма возврата: {int(amount_rubles)} ₽\n"
                 f"💳 Способ: Tribute\n\n"
                 f"Средства будут возвращены на вашу карту в течение 3-5 рабочих дней.\n\n"
                 f"Если у вас есть вопросы, обратитесь в поддержку."

app/services/version_service.py

@@ -0,0 +1,267 @@
+import asyncio
+import logging
+from datetime import datetime, timedelta
+from typing import Dict, List, Optional, Tuple
+import aiohttp
+from packaging import version
+import re
+
+from app.config import settings
+
+logger = logging.getLogger(__name__)
+
+
+class VersionInfo:
+    def __init__(self, tag_name: str, published_at: str, name: str, body: str, prerelease: bool = False):
+        self.tag_name = tag_name
+        self.published_at = datetime.fromisoformat(published_at.replace('Z', '+00:00'))
+        self.name = name or tag_name
+        self.body = body
+        self.prerelease = prerelease
+        self.is_dev = 'dev' in tag_name.lower()
+    
+    @property
+    def clean_version(self) -> str:
+        return re.sub(r'^v', '', self.tag_name)
+    
+    @property
+    def version_obj(self):
+        try:
+            clean_ver = self.clean_version
+            if 'dev' in clean_ver:
+                base_ver = clean_ver.split('-dev')[0]
+                return version.parse(f"{base_ver}.dev")
+            return version.parse(clean_ver)
+        except Exception:
+            return version.parse("0.0.0")
+    
+    @property
+    def formatted_date(self) -> str:
+        return self.published_at.strftime('%d.%m.%Y %H:%M')
+    
+    @property
+    def short_description(self) -> str:
+        if not self.body:
+            return "Без описания"
+        
+        description = self.body.strip()
+        if len(description) > 350:
+            description = description[:347] + "..."
+        
+        return description
+
+
+class VersionService:
+    def __init__(self, bot=None):
+        self.bot = bot
+        self.repo = getattr(settings, 'VERSION_CHECK_REPO', 'fr1ngg/remnawave-bedolaga-telegram-bot')
+        self.enabled = getattr(settings, 'VERSION_CHECK_ENABLED', True)
+        self.current_version = self._get_current_version()
+        self.cache_ttl = 3600  
+        self._cache: Dict = {}
+        self._last_check: Optional[datetime] = None
+        self._notification_service = None
+    
+    async def get_latest_stable_version(self) -> str:
+        try:
+            url = f"https://api.github.com/repos/{self.repo}/releases/latest"
+            async with aiohttp.ClientSession() as session:
+                async with session.get(url) as response:
+                    if response.status == 200:
+                        data = await response.json()
+                        return data['tag_name']
+        except Exception:
+            pass
+        return "UNKNOW"
+    
+    def _get_current_version(self) -> str:
+        import os
+        
+        current = os.getenv('VERSION', '').strip()
+        
+        if current:
+            if '-' in current and current.startswith('v'):
+                base_version = current.split('-')[0] 
+                if base_version.count('.') == 2: 
+                    return base_version
+            return current
+        
+        return "UNKNOW"
+    
+    def set_notification_service(self, notification_service):
+        self._notification_service = notification_service
+    
+    async def check_for_updates(self, force: bool = False) -> Tuple[bool, List[VersionInfo]]:
+        if not self.enabled:
+            return False, []
+        
+        try:
+            releases = await self._fetch_releases(force)
+            if not releases:
+                return False, []
+            
+            current_ver = self._parse_version(self.current_version)
+            newer_releases = []
+            
+            for release in releases:
+                release_ver = release.version_obj
+                if release_ver > current_ver:
+                    newer_releases.append(release)
+            
+            newer_releases.sort(key=lambda x: x.version_obj, reverse=True)
+            
+            has_updates = len(newer_releases) > 0
+            
+            if has_updates and not force:
+                await self._send_update_notification(newer_releases)
+            
+            return has_updates, newer_releases
+            
+        except Exception as e:
+            logger.error(f"Ошибка проверки обновлений: {e}")
+            return False, []
+    
+    async def _fetch_releases(self, force: bool = False) -> List[VersionInfo]:
+        if not force and self._cache and self._last_check:
+            if datetime.now() - self._last_check < timedelta(seconds=self.cache_ttl):
+                return self._cache.get('releases', [])
+        
+        url = f"https://api.github.com/repos/{self.repo}/releases"
+        
+        try:
+            timeout = aiohttp.ClientTimeout(total=10)
+            async with aiohttp.ClientSession(timeout=timeout) as session:
+                async with session.get(url) as response:
+                    if response.status == 200:
+                        data = await response.json()
+                        releases = []
+                        
+                        for release_data in data[:20]: 
+                            release = VersionInfo(
+                                tag_name=release_data['tag_name'],
+                                published_at=release_data['published_at'],
+                                name=release_data['name'],
+                                body=release_data['body'] or '',
+                                prerelease=release_data['prerelease']
+                            )
+                            releases.append(release)
+                        
+                        self._cache['releases'] = releases
+                        self._last_check = datetime.now()
+                        
+                        logger.info(f"Получено {len(releases)} релизов из GitHub")
+                        return releases
+                    else:
+                        logger.warning(f"GitHub API вернул статус {response.status}")
+                        return []
+                        
+        except asyncio.TimeoutError:
+            logger.warning("Таймаут при запросе к GitHub API")
+            return []
+        except Exception as e:
+            logger.error(f"Ошибка запроса к GitHub API: {e}")
+            return []
+    
+    def _parse_version(self, version_str: str):
+        try:
+            clean_ver = re.sub(r'^v', '', version_str)
+            if 'dev' in clean_ver:
+                base_ver = clean_ver.split('-dev')[0]
+                return version.parse(f"{base_ver}.dev")
+            if 'unknow' in clean_ver.lower(): 
+                return version.parse("0.0.0")
+            return version.parse(clean_ver)
+        except Exception:
+            return version.parse("0.0.0")
+    
+    async def _send_update_notification(self, newer_releases: List[VersionInfo]):
+        if not self._notification_service or not newer_releases:
+            return
+        
+        try:
+            latest_version = newer_releases[0]
+            cache_key = f"notified_{latest_version.tag_name}"
+            
+            if self._cache.get(cache_key):
+                return
+            
+            await self._notification_service.send_version_update_notification(
+                current_version=self.current_version,
+                latest_version=latest_version,
+                total_updates=len(newer_releases)
+            )
+            
+            self._cache[cache_key] = True
+            
+        except Exception as e:
+            logger.error(f"Ошибка отправки уведомления об обновлении: {e}")
+    
+    async def get_version_info(self) -> Dict:
+        try:
+            has_updates, newer_releases = await self.check_for_updates()
+            all_releases = await self._fetch_releases()
+            
+            current_release = None
+            current_ver = self._parse_version(self.current_version)
+            
+            for release in all_releases:
+                if release.version_obj == current_ver:
+                    current_release = release
+                    break
+            
+            return {
+                'current_version': self.current_version,
+                'current_release': current_release,
+                'has_updates': has_updates,
+                'newer_releases': newer_releases[:5],
+                'total_newer': len(newer_releases),
+                'last_check': self._last_check,
+                'repo_url': f"https://github.com/{self.repo}"
+            }
+            
+        except Exception as e:
+            logger.error(f"Ошибка получения информации о версиях: {e}")
+            return {
+                'current_version': self.current_version,
+                'current_release': None,
+                'has_updates': False,
+                'newer_releases': [],
+                'total_newer': 0,
+                'last_check': None,
+                'repo_url': f"https://github.com/{self.repo}",
+                'error': str(e)
+            }
+    
+    async def start_periodic_check(self):
+        if not self.enabled:
+            logger.info("Проверка версий отключена")
+            return
+        
+        logger.info(f"Запуск периодической проверки обновлений для {self.repo}")
+        logger.info(f"Текущая версия: {self.current_version}")
+        
+        while True:
+            try:
+                await asyncio.sleep(3600) 
+                await self.check_for_updates()
+                
+            except asyncio.CancelledError:
+                logger.info("Остановка проверки обновлений")
+                break
+            except Exception as e:
+                logger.error(f"Ошибка в периодической проверке обновлений: {e}")
+                await asyncio.sleep(300) 
+    
+    def format_version_display(self, version_info: VersionInfo) -> str:
+        status_icon = ""
+        if version_info.prerelease:
+            status_icon = "🧪"
+        elif version_info.is_dev:
+            status_icon = "🔧"
+        else:
+            status_icon = "📦"
+        
+        return f"{status_icon} {version_info.tag_name}"
+
+
+version_service = VersionService()

app/utils/validators.py

@@ -11,8 +11,7 @@ ALLOWED_HTML_TAGS = {
     'code',                 
     'pre',                
     'a',                  
-    'blockquote',           
-    'spoiler', 'tg-spoiler' 
+    'blockquote'
 }
 
 def validate_email(email: str) -> bool:
@@ -203,6 +202,5 @@ def get_html_help_text() -> str:
 - <code>&lt;pre&gt;блок кода&lt;/pre&gt;</code>
 - <code>&lt;a href="url"&gt;ссылка&lt;/a&gt;</code>
 - <code>&lt;blockquote&gt;цитата&lt;/blockquote&gt;</code>
-- <code>&lt;spoiler&gt;спойлер&lt;/spoiler&gt;</code>
 
-<b>Неподдерживаемые теги:</b> &lt;br&gt;, &lt;p&gt;, &lt;div&gt;, &lt;span&gt; и другие"""
+<b>Неподдерживаемые теги:</b> &lt;br&gt;, &lt;p&gt;, &lt;div&gt;, &lt;span&gt;, &lt;spoiler&gt; и другие"""

docker-compose.yml

@@ -7,7 +7,7 @@ services:
       POSTGRES_DB: ${POSTGRES_DB:-remnawave_bot}
       POSTGRES_USER: ${POSTGRES_USER:-remnawave_user}
       POSTGRES_PASSWORD: ${POSTGRES_PASSWORD:-secure_password_123}
-      POSTGRES_INITDB_ARGS: "--encoding=UTF8"
+      POSTGRES_INITDB_ARGS: "--encoding=UTF8 --locale=C"
     volumes:
       - postgres_data:/var/lib/postgresql/data
     networks:
@@ -23,7 +23,7 @@ services:
     image: redis:7-alpine
     container_name: remnawave_bot_redis
     restart: unless-stopped
-    command: redis-server --appendonly yes
+    command: redis-server --appendonly yes --maxmemory 256mb --maxmemory-policy allkeys-lru
     volumes:
       - redis_data:/data
     networks:
@@ -35,9 +35,7 @@ services:
       retries: 3
 
   bot:
-    build:
-      context: .   # директория где лежит Dockerfile
-      dockerfile: Dockerfile
+    image: fr1ngg/remnawave-bedolaga-telegram-bot:latest
     container_name: remnawave_bot
     restart: unless-stopped
     depends_on:
@@ -48,11 +46,25 @@ services:
     env_file:
       - .env
     environment:
-      DATABASE_URL: postgresql+asyncpg://${POSTGRES_USER:-remnawave_user}:${POSTGRES_PASSWORD:-secure_password_123}@postgres:5432/${POSTGRES_DB:-remnawave_bot}
-      REDIS_URL: redis://redis:6379/0
+      DOCKER_ENV: "true"
+      DATABASE_MODE: "auto"
+      POSTGRES_HOST: "postgres"
+      POSTGRES_PORT: "5432"
+      POSTGRES_DB: "${POSTGRES_DB:-remnawave_bot}"
+      POSTGRES_USER: "${POSTGRES_USER:-remnawave_user}"
+      POSTGRES_PASSWORD: "${POSTGRES_PASSWORD:-secure_password_123}"
+      
+      REDIS_URL: "redis://redis:6379/0"
+      
+      TZ: "Europe/Moscow"
     volumes:
+      # Логи
       - ./logs:/app/logs:rw
+      # Данные приложения (для SQLite в случае переключения)
       - ./data:/app/data:rw
+      # Конфигурация приложения
+      # - ./app-config.json:/app/app-config.json:ro
+      # Timezone
       - /etc/timezone:/etc/timezone:ro
       - /etc/localtime:/etc/localtime:ro
     ports:
@@ -60,10 +72,18 @@ services:
       - "${YOOKASSA_WEBHOOK_PORT:-8082}:8082"
     networks:
       - bot_network
+    healthcheck:
+      test: ["CMD-SHELL", "python -c 'import requests; requests.get(\"http://localhost:8081/health\", timeout=5)' || exit 1"]
+      interval: 60s
+      timeout: 10s
+      retries: 3
+      start_period: 30s
 
 volumes:
   postgres_data:
+    driver: local
   redis_data:
+    driver: local
 
 networks:
   bot_network:
@@ -71,3 +91,4 @@ networks:
     ipam:
       config:
         - subnet: 172.20.0.0/16
+          gateway: 172.20.0.1

main.py

@@ -13,6 +13,7 @@ from app.database.database import init_db
 from app.services.monitoring_service import monitoring_service
 from app.services.maintenance_service import maintenance_service
 from app.services.payment_service import PaymentService
+from app.services.version_service import version_service
 from app.external.webhook_server import WebhookServer
 from app.external.yookassa_webhook import start_yookassa_webhook_server
 from app.database.universal_migration import run_universal_migration
@@ -49,6 +50,7 @@ async def main():
     yookassa_server_task = None
     monitoring_task = None
     maintenance_task = None
+    version_check_task = None
     polling_task = None
     
     try:
@@ -77,7 +79,15 @@ async def main():
         bot, dp = await setup_bot()
         
         monitoring_service.bot = bot
-        maintenance_service.set_bot(bot) 
+        maintenance_service.set_bot(bot)
+        
+        from app.services.admin_notification_service import AdminNotificationService
+        admin_notification_service = AdminNotificationService(bot)
+        version_service.bot = bot
+        version_service.set_notification_service(admin_notification_service)
+        logger.info(f"🔄 Сервис версий настроен для репозитория: {version_service.repo}")
+        logger.info(f"📦 Текущая версия: {version_service.current_version}")
+        
         logger.info("🔗 Бот подключен к сервисам мониторинга и техработ")
         
         payment_service = PaymentService(bot)
@@ -108,7 +118,13 @@ async def main():
             logger.info("🔧 Служба техработ уже запущена")
             maintenance_task = None
         
-        logger.info("🔄 Запуск polling...")
+        if settings.is_version_check_enabled():
+            logger.info("🔄 Запуск сервиса проверки версий...")
+            version_check_task = asyncio.create_task(version_service.start_periodic_check())
+        else:
+            logger.info("ℹ️ Проверка версий отключена")
+        
+        logger.info("📄 Запуск polling...")
         polling_task = asyncio.create_task(dp.start_polling(bot, skip_updates=True))
         
         logger.info("=" * 50)
@@ -117,6 +133,10 @@ async def main():
             logger.info(f"   Tribute: {settings.WEBHOOK_URL}:{settings.TRIBUTE_WEBHOOK_PORT}{settings.TRIBUTE_WEBHOOK_PATH}")
         if settings.is_yookassa_enabled():
             logger.info(f"   YooKassa: {settings.WEBHOOK_URL}:{settings.YOOKASSA_WEBHOOK_PORT}{settings.YOOKASSA_WEBHOOK_PATH}")
+        logger.info("🔄 Активные фоновые сервисы:")
+        logger.info(f"   Мониторинг: {'Включен' if monitoring_task else 'Отключен'}")
+        logger.info(f"   Техработы: {'Включен' if maintenance_task else 'Отключен'}")
+        logger.info(f"   Проверка версий: {'Включен' if version_check_task else 'Отключен'}")
         logger.info("=" * 50)
         
         try:
@@ -143,6 +163,14 @@ async def main():
                     if exception:
                         logger.error(f"Служба техработ завершилась с ошибкой: {exception}")
                         maintenance_task = asyncio.create_task(maintenance_service.start_monitoring())
+                
+                if version_check_task and version_check_task.done():
+                    exception = version_check_task.exception()
+                    if exception:
+                        logger.error(f"Сервис проверки версий завершился с ошибкой: {exception}")
+                        if settings.is_version_check_enabled():
+                            logger.info("🔄 Перезапуск сервиса проверки версий...")
+                            version_check_task = asyncio.create_task(version_service.start_periodic_check())
                         
                 if polling_task.done():
                     exception = polling_task.exception()
@@ -186,6 +214,14 @@ async def main():
             except asyncio.CancelledError:
                 pass
         
+        if version_check_task and not version_check_task.done():
+            logger.info("ℹ️ Остановка сервиса проверки версий...")
+            version_check_task.cancel()
+            try:
+                await version_check_task
+            except asyncio.CancelledError:
+                pass
+        
         if polling_task and not polling_task.done():
             logger.info("ℹ️ Остановка polling...")
             polling_task.cancel()

requirements.txt

@@ -25,3 +25,7 @@ APScheduler==3.10.4
 python-dateutil==2.8.2
 pytz==2023.4
 cryptography>=41.0.0
+qrcode[pil]==7.4.2
+
+# Для работы с версиями
+packaging==23.2