From 03580debc677d9a2431a78c2e2d586038c805a49 Mon Sep 17 00:00:00 2001 From: smail Date: Sat, 3 Oct 2026 02:59:03 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E5=85=AC=E5=85=B1=E6=81=A2?= =?UTF-8?q?=E5=A4=8D=E5=AE=A1=E8=AE=A1=E5=9B=9E=E5=BD=92=E6=B5=8B=E8=AF=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit 让日志迁移测试符合连续版本校验，并避免测试清理任务与角色更新产生 SQLite 锁竞争。 --- backend/services/recovery/public_flow_test.go | 13 ++++++------- 1 file changed, 6 insertions(+), 7 deletions(-) diff --git a/backend/services/recovery/public_flow_test.go b/backend/services/recovery/public_flow_test.go index 09abd00..dfc9a71 100644 --- a/backend/services/recovery/public_flow_test.go +++ b/backend/services/recovery/public_flow_test.go @@ -20,11 +20,10 @@ func TestPublicFlowEmailResetAndRoleBoundary(t *testing.T) { for _, role := range []access.Role{access.RoleSuperAdmin, access.RoleAdmin, access.RoleUser} { t.Run(string(role), func(t *testing.T) { s, verify, engine, user := newRecoveryFixture(t) - var migrations []migration.Migration - for _, item := range migration.DefaultMigrations() { - if item.Name == "create_managed_logs" || item.Name == "expand_operation_log_actor_role" { - migrations = append(migrations, item) - } + migrations := migration.DefaultMigrations()[16:18] + + for index := range migrations { + migrations[index].Version = int64(index + 1) } runner := migration.Runner{DB: engine.DB().DB, Dialect: migration.DialectSQLite, Migrations: migrations} if _, err := runner.Run(context.Background()); err != nil { @@ -34,8 +33,6 @@ func TestPublicFlowEmailResetAndRoleBoundary(t *testing.T) { if err != nil { t.Fatal(err) } - runtime := logstore.Start(logs) - defer runtime.Stop() assertAudit := func(want int, secrets ...string) { t.Helper() entries, err := logs.Query(context.Background(), logstore.Query{Kind: "operation"}) @@ -64,6 +61,8 @@ func TestPublicFlowEmailResetAndRoleBoundary(t *testing.T) { if _, err := engine.ID(user.ID).Cols("role").Update(user); err != nil { t.Fatal(err) } + runtime := logstore.Start(logs) + defer runtime.Stop() var code string verify.Send = func(_ verification.Challenge, value string) error { code = value; return nil } flow, err := s.IdentifyPublicFlow(user.Account)