From 36ea55a10d45ff6a981b073d75ffabd83f2e083b Mon Sep 17 00:00:00 2001 From: Vladless Date: Wed, 16 Jul 2025 22:08:20 +0300 Subject: [PATCH] add change domain for remnawave link --- handlers/admin/management/management_handler.py | 14 ++++++++++---- 1 file changed, 10 insertions(+), 4 deletions(-) diff --git a/handlers/admin/management/management_handler.py b/handlers/admin/management/management_handler.py index e456c444..66ebb1f5 100644 --- a/handlers/admin/management/management_handler.py +++ b/handlers/admin/management/management_handler.py @@ -98,8 +98,14 @@ async def process_new_domain( try: stmt = ( update(Key) - .where(~Key.key.startswith(new_domain_url)) - .values(key=func.regexp_replace(Key.key, r"^https://[^/]+", new_domain_url)) + .values( + key=func.regexp_replace(Key.key, r"^https://[^/]+", new_domain_url), + remnawave_link=func.regexp_replace(Key.remnawave_link, r"^https://[^/]+", new_domain_url), + ) + .where( + (Key.key.startswith("https://") & ~Key.key.startswith(new_domain_url)) | + (Key.remnawave_link.startswith("https://") & ~Key.remnawave_link.startswith(new_domain_url)) + ) ) await session.execute(stmt) await session.commit() @@ -113,8 +119,8 @@ async def process_new_domain( return try: - sample = await session.execute(select(Key.key).limit(1)) - example = sample.scalar() + sample = await session.execute(select(Key.key, Key.remnawave_link).limit(1)) + example = sample.fetchone() logger.info(f"[DomainChange] Пример обновленной записи: {example}") except Exception as e: logger.error(f"[DomainChange] Ошибка при выборке обновленной записи: {e}")