From 584f86f796e5d4c8ed8a8effff8dac8bf5540922 Mon Sep 17 00:00:00 2001
From: GGlamer <52128225+Gamer201760@users.noreply.github.com>
Date: Sun, 27 Sep 2026 22:29:57 +0300
Subject: [PATCH] =?UTF-8?q?test:=20=D1=81=D0=BC=D0=BE=D1=83=D0=BA=20=D0=B4?=
 =?UTF-8?q?=D0=BE=D0=BA=D0=B0=D0=B7=D1=8B=D0=B2=D0=B0=D0=B5=D1=82=20=D1=80?=
 =?UTF-8?q?=D0=B0=D0=B7=D0=BE=D0=B2=D1=83=D1=8E=20=D0=BF=D1=80=D0=BE=D0=B2?=
 =?UTF-8?q?=D0=B5=D1=80=D0=BA=D1=83=20=D0=BB=D0=BE=D0=B3=D0=B8=D0=BD=D0=B0?=
 =?UTF-8?q?=20=D0=BD=D0=B0=20B=20=D0=BF=D0=BE=20=D0=B6=D1=83=D1=80=D0=BD?=
 =?UTF-8?q?=D0=B0=D0=BB=D1=83,=20=D0=B2=D1=80=D0=B5=D0=BC=D1=8F=20=D0=BE?=
 =?UTF-8?q?=D1=82=20=D1=81=D0=BE=D0=B7=D0=B4=D0=B0=D0=BD=D0=B8=D1=8F=20?=
 =?UTF-8?q?=D1=83=D1=87=D1=91=D1=82=D0=BE=D0=BA?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 scripts/test_cluster_failover.py | 15 +++++++++++----
 1 file changed, 11 insertions(+), 4 deletions(-)

diff --git a/scripts/test_cluster_failover.py b/scripts/test_cluster_failover.py
index a907266..6864f92 100644
--- a/scripts/test_cluster_failover.py
+++ b/scripts/test_cluster_failover.py
@@ -209,7 +209,7 @@ async def main(args: argparse.Namespace) -> int:
     from sqlalchemy.ext.asyncio import async_sessionmaker, create_async_engine
     from sqlalchemy.pool import NullPool
 
-    from app.api.auth import hash_password
+    from app.api.auth import hash_password, login_log_marker
     from app.db.models import AuditLog, Session, Trainee, User
 
     database_url = (
@@ -250,19 +250,26 @@ async def main(args: argparse.Namespace) -> int:
                      trainee_id=trainee.id, blocked=False),
             ])
             await db.commit()
+        users_committed_at = time.monotonic()
 
         instructor_cookie = login(backend, instructor_login, instructor_password)
-        login_completed_at = time.monotonic()
         trainee_cookie = login(backend, trainee_login, trainee_password)
         control_sent_at = await send_control(ws_base, session_id, instructor_cookie, {
             "type": "scenario.start", "scenario_id": args.scenario,
             "trainee": trainee.name, "trainee_id": str(trainee.id),
             "mode": "training", "exercise": "dds",
         })
-        result["login_to_control_seconds"] = round(control_sent_at - login_completed_at, 4)
+        result["users_commit_to_control_seconds"] = round(control_sent_at - users_committed_at, 4)
         if args.expect_initial_owner == "backend-b":
             result["checks"]["control_sent_within_first_second"] = (
-                result["login_to_control_seconds"] < 1
+                result["users_commit_to_control_seconds"] < 1
+            )
+            # Сверка B идёт раз в секунду в случайной фазе, и время само по себе
+            # не доказывает, что B не знал логин. Доказательство — запись B о
+            # разовой проверке именно этого логина.
+            result["checks"]["backend_b_resolved_login_one_shot"] = (
+                login_log_marker(instructor_login)
+                in compose(args, "logs", "--no-color", "backend-b")
             )
 
         async def session_row():