diff --git a/main.py b/main.py index c3292b2b..e600106e 100644 --- a/main.py +++ b/main.py @@ -17,6 +17,7 @@ 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 +from app.services.backup_service import backup_service class GracefulExit: @@ -89,6 +90,20 @@ async def main(): logger.info(f"πŸ“¦ ВСкущая вСрсия: {version_service.current_version}") logger.info("πŸ”— Π‘ΠΎΡ‚ ΠΏΠΎΠ΄ΠΊΠ»ΡŽΡ‡Π΅Π½ ΠΊ сСрвисам ΠΌΠΎΠ½ΠΈΡ‚ΠΎΡ€ΠΈΠ½Π³Π° ΠΈ Ρ‚Π΅Ρ…Ρ€Π°Π±ΠΎΡ‚") + + logger.info("πŸ—„οΈ Π˜Π½ΠΈΡ†ΠΈΠ°Π»ΠΈΠ·Π°Ρ†ΠΈΡ сСрвиса Π±Π΅ΠΊΠ°ΠΏΠΎΠ²...") + try: + backup_service.bot = bot + + # ЗапускаСм Π°Π²Ρ‚ΠΎΠ±Π΅ΠΊΠ°ΠΏΡ‹ Ссли ΠΎΠ½ΠΈ Π²ΠΊΠ»ΡŽΡ‡Π΅Π½Ρ‹ + settings_obj = await backup_service.get_backup_settings() + if settings_obj.auto_backup_enabled: + await backup_service.start_auto_backup() + logger.info("βœ… АвтобСкапы Π·Π°ΠΏΡƒΡ‰Π΅Π½Ρ‹") + + logger.info("βœ… БСрвис Π±Π΅ΠΊΠ°ΠΏΠΎΠ² ΠΈΠ½ΠΈΡ†ΠΈΠ°Π»ΠΈΠ·ΠΈΡ€ΠΎΠ²Π°Π½") + except Exception as e: + logger.error(f"❌ Ошибка ΠΈΠ½ΠΈΡ†ΠΈΠ°Π»ΠΈΠ·Π°Ρ†ΠΈΠΈ сСрвиса Π±Π΅ΠΊΠ°ΠΏΠΎΠ²: {e}") payment_service = PaymentService(bot) @@ -221,6 +236,12 @@ async def main(): await version_check_task except asyncio.CancelledError: pass + + logger.info("ℹ️ ΠžΡΡ‚Π°Π½ΠΎΠ²ΠΊΠ° сСрвиса Π±Π΅ΠΊΠ°ΠΏΠΎΠ²...") + try: + await backup_service.stop_auto_backup() + except Exception as e: + logger.error(f"Ошибка остановки сСрвиса Π±Π΅ΠΊΠ°ΠΏΠΎΠ²: {e}") if polling_task and not polling_task.done(): logger.info("ℹ️ ΠžΡΡ‚Π°Π½ΠΎΠ²ΠΊΠ° polling...")