From 1e96d3440f92b3617d6c3e251cd235dcb1351b04 Mon Sep 17 00:00:00 2001
From: kitiketov <roskets801@gmail.com>
Date: Wed, 26 Nov 2025 03:07:14 +0500
Subject: [PATCH] =?UTF-8?q?=D0=BF=D1=83=D0=BF=D1=83=D0=BF=D1=83?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/handlers/admin_command.py | 62 +++++++++++++++++++++++++++++++++++
 1 file changed, 62 insertions(+)
 create mode 100644 src/handlers/admin_command.py

diff --git a/src/handlers/admin_command.py b/src/handlers/admin_command.py
new file mode 100644
index 0000000..fdb913b
--- /dev/null
+++ b/src/handlers/admin_command.py
@@ -0,0 +1,62 @@
+import shutil
+import tempfile
+from pathlib import Path
+
+from aiogram import Router
+from aiogram.filters import Command
+from aiogram.types import Message, FSInputFile
+
+from src.config import settings, logger
+from src.db import db
+
+router = Router(name=__name__)
+
+
+def _is_admin(msg: Message):
+    return msg.from_user and msg.from_user.id == settings.admin_id
+
+
+@router.message(Command("backup"))
+async def backup(msg: Message):
+    if not _is_admin(msg):
+        return
+
+    db_file = Path(db.DB_PATH)
+    log_file = Path("py_log.log").resolve()
+
+    async def _send_file(file_path: Path, caption: str):
+        if not file_path.exists():
+            await msg.answer(f"{caption}: файл не найден.")
+            return
+        tmp_dir = Path(tempfile.mkdtemp())
+        tmp_file = tmp_dir / file_path.name
+        try:
+            shutil.copy(file_path, tmp_file)
+            await msg.answer_document(FSInputFile(tmp_file), caption=caption)
+        except Exception as e:
+            logger.error(f"Backup error for {file_path}: {e}")
+            await msg.answer(f"Не удалось отправить {caption}.")
+        finally:
+            try:
+                tmp_file.unlink()
+                tmp_dir.rmdir()
+            except Exception:
+                pass
+
+    await _send_file(db_file, "database.db")
+    await _send_file(log_file, "py_log.log")
+
+
+@router.message(Command("status"))
+async def status(msg: Message):
+    if not _is_admin(msg):
+        return
+
+    users_total, participants, rooms_total, started_rooms = await db.get_stats()
+    await msg.answer(
+        "Статус:\n"
+        f"Пользователей в базе: {users_total}\n"
+        f"Участников с комнатами: {participants}\n"
+        f"Комнат всего: {rooms_total}\n"
+        f"Комнат с запущенным ивентом: {started_rooms}"
+    )