fix: add retry queue to payment webhook and renewal service RemnaWave errors

app/services/payment/stars.py

@@ -286,6 +286,12 @@ class TelegramStarsMixin:
                 sync_error=sync_error,
                 exc_info=True,
             )
+            from app.services.remnawave_retry_queue import remnawave_retry_queue
+            remnawave_retry_queue.enqueue(
+                subscription_id=subscription.id,
+                user_id=subscription.user_id,
+                action='create',
+            )
 
         period_display = period_days
         if not period_display and getattr(subscription, 'start_date', None) and getattr(subscription, 'end_date', None):

app/services/payment/yookassa.py

@@ -680,6 +680,12 @@ class YooKassaPaymentMixin:
                                     await subscription_service.create_remnawave_user(db, subscription)
                                 except Exception as rw_error:
                                     logger.error('Ошибка создания RemnaWave для триала', rw_error=rw_error)
+                                    from app.services.remnawave_retry_queue import remnawave_retry_queue
+                                    remnawave_retry_queue.enqueue(
+                                        subscription_id=subscription.id,
+                                        user_id=subscription.user_id,
+                                        action='create',
+                                    )
 
                                 # Уведомление админам
                                 if getattr(self, 'bot', None):
@@ -991,6 +997,12 @@ class YooKassaPaymentMixin:
                                     sync_error=sync_error,
                                     exc_info=True,
                                 )
+                                from app.services.remnawave_retry_queue import remnawave_retry_queue
+                                remnawave_retry_queue.enqueue(
+                                    subscription_id=subscription.id,
+                                    user_id=subscription.user_id,
+                                    action='create',
+                                )
 
                             # Отправляем уведомление пользователю об активации подписки (только Telegram)
                             if getattr(self, 'bot', None) and user.telegram_id:

app/services/subscription_renewal_service.py

@@ -518,6 +518,12 @@ class SubscriptionRenewalService:
                 subscription_after_id=subscription_after.id,
                 error=error,
             )
+            from app.services.remnawave_retry_queue import remnawave_retry_queue
+            remnawave_retry_queue.enqueue(
+                subscription_id=subscription_after.id,
+                user_id=subscription_after.user_id,
+                action='create' if not getattr(subscription_after, 'remnawave_uuid', None) else 'update',
+            )
 
         transaction: Transaction | None = None
         try: