Basic admin menu (#9)

### Описание PR'ра
Я хочу кричать

### Медиа

![изображение](https://github.com/user-attachments/assets/4306a38d-69d6-4922-be1d-bf6018291903)

![изображение](https://github.com/user-attachments/assets/ce6766ca-c407-4dc5-b87f-7151e6feee7b)

![изображение](https://github.com/user-attachments/assets/d0f04193-b920-4211-82e3-514f541e7e22)

![изображение](https://github.com/user-attachments/assets/c562d9ec-8de9-4f71-bde3-ca05c04b17d7)

### Изменения
changes: NOT

.vscode/launch.json

@@ -2,7 +2,17 @@
     "version": "0.2.0",
     "configurations": [
         {
-            "name": "Start client",
+            "name": "Start client debug",
+            "type": "debugpy",
+            "request": "launch",
+            "program": "Code/main.py",
+            "console": "integratedTerminal",
+            "args": [
+                "--debug"
+            ]
+        },
+        {
+            "name": "Start client release",
             "type": "debugpy",
             "request": "launch",
             "program": "Code/main.py",

Code/api/__init__.py

@@ -1,3 +0,0 @@
-from .chat import ChatModule
-
-__all__ = ['ChatModule']

Code/dpg_tools.py

@@ -19,6 +19,26 @@ def decode_string(instr: str):
     return instr.translate(translation_table)
 
 
+def center_window(tag):
+    """Центрируем окно с тегом tag относительно текущих размеров окна и экрана"""
+    if not dpg.does_item_exist(tag):
+        return
+
+    window_width = dpg.get_item_width(tag)
+    window_height = dpg.get_item_height(tag)
+
+    if window_height is None or window_width is None:
+        return
+
+    vp_width = dpg.get_viewport_client_width()
+    vp_height = dpg.get_viewport_client_height()
+
+    x_pos = (vp_width - window_width) // 2
+    y_pos = (vp_height - window_height) // 2
+
+    dpg.set_item_pos(tag, [x_pos, y_pos])
+
+
 def add_timer(interval, callback, repeat_count=None, *args, **kwargs):
     is_coroutine = inspect.iscoroutinefunction(callback)
     task = asyncio.create_task(

Code/gui/dm_client_app.py

@@ -1,15 +1,25 @@
-import atexit
+import asyncio
+import logging
+import shutil
+import time
+import zipfile
+from pathlib import Path
+
 import dearpygui.dearpygui as dpg
+import dpg_tools
 from dearpygui_async import DearPyGuiAsync
-from pypresence import Presence
+from DMBotNetwork import Client
+from root_path import ROOT_PATH
+from systems.discord_rpc import DiscordRPC
 from systems.loc import Localization as loc
+
 from .fonts_setup import FontManager
+from .windows.admin import admin_main_window
 
 
 class DMClientApp:
     _dpg_async = DearPyGuiAsync()
-    rpc = Presence(1227926138400276561)
-
+
     def __init__(self):
         dpg.create_context()
         FontManager.load_fonts()
@@ -21,38 +31,49 @@ def __init__(self):
             height=400,
             min_height=400,
         )
-        dpg.setup_dearpygui()
-
-        DMClientApp.rpc.connect()
-        DMClientApp.rpc.update(state="Nya~")
 
-        atexit.register(DMClientApp.rpc.close)
+        dpg.setup_dearpygui()
+        dpg.show_viewport()
 
         DMClientApp._create_warning_window()
 
     @classmethod
     def _create_warning_window(cls):
-        """Создание окна предупреждения"""
         with dpg.window(
             label="Warning",
             tag="warning_window",
             no_move=True,
             no_close=True,
             no_collapse=True,
             width=380,
+            height=150,
             no_resize=True,
         ):
-            dpg.add_text(loc.get_string("main_text_warning_window"), wrap=380)
+            dpg.add_text(loc.get_string("main_text_warning_window"), wrap=0)
             dpg.add_button(
                 label=loc.get_string("yes_warning_window"), callback=cls._on_yes
             )
             dpg.add_button(
-                label=loc.get_string("no_warning_window"), callback=cls._on_no
+                label=loc.get_string("no_warning_window"), callback=lambda: cls._on_no()
             )
 
+            dpg_tools.center_window("warning_window")
+
     @classmethod
-    def _create_connect_window(cls):
+    async def _on_yes(cls, *args):
+        dpg.delete_item("warning_window")
+        await DMClientApp._create_connect_window()
+
+    @classmethod
+    def _on_no(cls, *args):
+        cls.stop()
+
+    @classmethod
+    async def _create_connect_window(cls):
         """Создание окна подключения"""
+        await DiscordRPC.connect()
+        await DiscordRPC.update("Connect to server...")
+
         if dpg.does_item_exist("connect_window"):
             dpg.focus_item("connect_window")
             return
@@ -64,44 +85,194 @@ def _create_connect_window(cls):
             no_collapse=True,
             no_move=True,
             width=380,
+            height=380,
         ):
             dpg.add_text(loc.get_string("connect_main_text"))
             dpg.add_input_text(
                 hint=loc.get_string("connect_login_hint"), tag="connect_login"
             )
+
             dpg.add_input_text(
                 hint=loc.get_string("connect_password_hint"),
                 tag="connect_password",
                 password=True,
             )
+
             dpg.add_input_text(
                 hint=loc.get_string("connect_host_hint"), tag="connect_host"
             )
+
             dpg.add_input_int(
-                label=loc.get_string("connect_port_lable"), tag="connect_port"
+                label=loc.get_string("connect_port_lable"),
+                tag="connect_port",
+                min_clamped=True,
+                min_value=0,
             )
-            dpg.add_button(label=loc.get_string("connect_button"))
+
+            dpg.add_button(
+                label=loc.get_string("login_button"),
+                callback=DMClientApp._connect_to_server,
+                user_data=False,
+            )
+            dpg.add_button(
+                label=loc.get_string("register_button"),
+                callback=DMClientApp._connect_to_server,
+                user_data=True,
+            )
+
+            dpg_tools.center_window("connect_window")
 
     @classmethod
-    def _on_yes(cls, *args):
-        """Обработка нажатия кнопки 'Yes' в окне предупреждения"""
-        dpg.delete_item("warning_window")
-        cls._create_connect_window()
+    async def _connect_to_server(cls, sender, app_data, user_data):
+        if Client.is_connected():
+            return
+
+        if not user_data and dpg.is_key_down(dpg.mvKey_Control):  # For debug
+            login = "owner"
+            password = "owner_password"
+            host = "localhost"
+            port = 5000
+
+        else:
+            login = dpg_tools.decode_string(dpg.get_value("connect_login"))
+            password = dpg_tools.decode_string(dpg.get_value("connect_password"))
+            host = dpg_tools.decode_string(dpg.get_value("connect_host"))
+            port = dpg.get_value("connect_port")
+
+        async def _connected():
+            while True:
+                if not Client.is_connected():
+                    await asyncio.sleep(0.5)
+                    continue
+
+                break
+
+        try:
+            Client.setup(
+                login=login,
+                password=password,
+                use_registration=user_data,
+                content_path=Path(ROOT_PATH / "Content" / "Servers"),
+            )
+
+            await Client.connect(host, port)
+            await asyncio.wait_for(_connected(), 15)
+
+        except TimeoutError:
+            msg = loc.get_string("timeout_error")
+            cls._err_window(msg)
+            return
+
+        except ValueError:
+            msg = loc.get_string("null_values_set")
+            cls._err_window(msg)
+            return
+
+        except Exception as err:
+            msg = loc.get_string("error_msg", err=str(err))
+            cls._err_window(msg)
+            return
+
+        await DiscordRPC.update(
+            f'Connect to "{Client.get_server_name()}" as "{login}"',
+            start=int(time.time()),
+        )
+
+        dpg.delete_item("connect_window")
+
+        await cls.setup_start_windows()
 
     @classmethod
-    def _on_no(cls, *args):
-        """Обработка нажатия кнопки 'No' в окне предупреждения"""
-        cls.stop()
+    def _err_window(cls, msg):
+        with dpg.window(
+            label="Error",
+            tag="error_connect_window",
+            no_collapse=True,
+            modal=True,
+            width=400,
+            height=200,
+        ) as err_window:
+            dpg.add_text(msg, wrap=0)
+            dpg.add_button(
+                label=loc.get_string("ok"), callback=lambda: dpg.delete_item(err_window)
+            )
+
+            dpg_tools.center_window(err_window)
+
+    @classmethod
+    async def setup_start_windows(cls) -> None:
+        await cls.download_content_from_server()
+        loc.load_translations(
+            Path(
+                ROOT_PATH
+                / "Content"
+                / "Servers"
+                / Client.get_server_name()
+                / "loc"
+                / "rus"
+            )
+        )
+        access = await Client.req_get_data("get_access", None, login=Client.get_login())
+        dpg.add_viewport_menu_bar(tag="main_bar")
+
+        dpg.add_menu_item(
+            label=loc.get_string("cur_login", login=Client.get_login()),
+            parent="main_bar",
+            enabled=False,
+        )
+
+        # При всём желании, проверка прав проходит на сервере. Даже не пытайтесь.
+        if "full_access" in access:
+            await admin_main_window()
+
+    @classmethod
+    async def download_content_from_server(cls) -> None:
+        server_content_path: Path = (
+            Path(ROOT_PATH) / "Content" / "Servers" / Client.get_server_name()
+        )
+        local_hash_path = server_content_path / "content_hash"
+
+        if local_hash_path.exists():
+            with local_hash_path.open("r") as file:
+                local_hash = file.read().strip()
+        else:
+            local_hash = None
+
+        server_hash = await Client.req_get_data("get_server_content_hash", None)
+
+        if local_hash == server_hash:
+            return
+
+        else:
+            if server_content_path.exists():
+                for item in server_content_path.iterdir():
+                    if item.is_file():
+                        item.unlink()
+                    elif item.is_dir():
+                        shutil.rmtree(item)
+
+        answer = await Client.req_get_data("download_server_content", None)
+        if answer != "done":
+            logging.error(f"Error while download content: {answer}")
+            return
+
+        file_path = server_content_path / "server_content.zip"
+        extract_path = server_content_path
+
+        with zipfile.ZipFile(file_path, "r") as zip_ref:
+            zip_ref.extractall(extract_path)
+
+        file_path.unlink()
+
+        with local_hash_path.open("w") as file:
+            file.write(server_hash)
 
     @classmethod
     def run(cls):
-        """Запуск основного цикла приложения"""
-        dpg.show_viewport()
         cls._dpg_async.run()
         dpg.start_dearpygui()
         dpg.destroy_context()
 
     @classmethod
     def stop(cls):
-        """Остановка основного цикла приложения"""
         dpg.stop_dearpygui()

Code/gui/windows/admin/__init__.py

@@ -0,0 +1 @@
+from .main import admin_main_window

Code/gui/windows/admin/main.py

@@ -0,0 +1,25 @@
+import dearpygui.dearpygui as dpg
+from systems.loc import Localization as loc
+
+from .manage_server_settings import manage_server_settings
+from .manage_users import user_management
+
+
+async def admin_main_window():
+    dpg.add_menu(
+        label=loc.get_string("admin_control_menu"),
+        tag="admin_control_menu_bar",
+        parent="main_bar",
+    )
+
+    dpg.add_menu_item(
+        label=loc.get_string("user_management_label"),
+        parent="admin_control_menu_bar",
+        callback=user_management,
+    )
+
+    dpg.add_menu_item(
+        label=loc.get_string("manage_server_settings_lable"),
+        parent="admin_control_menu_bar",
+        callback=manage_server_settings,
+    )