修复 requests 页面在 WebSocket 重连后不同步的问题 (#417)

* fix(requests): resync queries after ws reconnect

* test(playwright): stabilize requests e2e coverage

* test: clarify requests init script

* test: harden requests reconnect and stress waits

* test: address requests playwright review nits

* test: use stable requests count assertion

* test: relax requests count assertion

* test: harden requests playwright assertions

* fix: avoid duplicate sqlite migration versions

* fix: remove migration conflict markers

* test: preselect provider for requests alignment

---------

Co-authored-by: ymkiux <44744442+ymkiux@users.noreply.github.com>
Co-authored-by: 番外个体 <misaka-worst@openclaw.local>

Author: 3 people

internal/repository/sqlite/migrations.go

@@ -211,16 +211,22 @@ var migrations = []Migration{
 		Version:     7,
 		Description: "Backfill providers.exclude_from_export defaults to 0",
 		Up: func(db *gorm.DB) error {
+			if !db.Migrator().HasColumn(&Provider{}, "exclude_from_export") {
+				return nil
+			}
 			return db.Exec("UPDATE providers SET exclude_from_export = 0 WHERE exclude_from_export IS NULL").Error
 		},
 		Down: func(db *gorm.DB) error {
 			return nil
 		},
 	},
 	{
-		Version:     7,
+		Version:     8,
 		Description: "Make Codex quota identity account-aware to avoid same-email quota collisions",
 		Up: func(db *gorm.DB) error {
+			if !db.Migrator().HasColumn(&CodexQuota{}, "identity_key") {
+				return nil
+			}
 			var backfillSQL string
 			switch db.Dialector.Name() {
 			case "mysql":
@@ -273,6 +279,9 @@ var migrations = []Migration{
 			return nil
 		},
 		Down: func(db *gorm.DB) error {
+			if !db.Migrator().HasColumn(&CodexQuota{}, "identity_key") {
+				return nil
+			}
 			switch db.Dialector.Name() {
 			case "mysql":
 				if err := db.Exec("DROP INDEX idx_codex_quotas_tenant_identity ON codex_quotas").Error; err != nil && !isMySQLMissingIndexError(err) {

tests/e2e/playwright/requests-mixed-stress.spec.ts

@@ -22,9 +22,11 @@ const REQUEST_PROJECT_FILTER_STORAGE_KEY = 'maxx-requests-project-filter';
 
 const STRESS_DURATION_MS = 60_000;
 const SAMPLE_INTERVAL_MS = 30_000;
-const REQUEST_RATE_PER_SECOND = 100;
-const REQUESTS_PER_TICK = 10;
-const TICK_INTERVAL_MS = 100;
+const REQUEST_RATE_PER_SECOND = 25;
+const REQUESTS_PER_TICK = 5;
+const TICK_INTERVAL_MS = 200;
+const MAX_IN_FLIGHT_REQUESTS = 60;
+const BACKPRESSURE_POLL_MS = 25;
 const MAX_RENDERED_ROWS = 120;
 const REPORT_PATH = path.resolve(process.cwd(), 'test-results', 'requests-mixed-stress-report.json');
 
@@ -367,13 +369,25 @@ async function runStressTraffic(url: string, counters: StressCounters) {
 
   while (Date.now() < endAt) {
     const tickStartedAt = Date.now();
+    let launchedThisTick = 0;
+
+    while (launchedThisTick < REQUESTS_PER_TICK) {
+      if (inFlight.size >= MAX_IN_FLIGHT_REQUESTS) {
+        const tickDeadline = tickStartedAt + TICK_INTERVAL_MS;
+        while (inFlight.size >= MAX_IN_FLIGHT_REQUESTS && Date.now() < tickDeadline) {
+          await delay(Math.min(BACKPRESSURE_POLL_MS, Math.max(1, tickDeadline - Date.now())));
+        }
+        if (inFlight.size >= MAX_IN_FLIGHT_REQUESTS) {
+          break;
+        }
+      }
 
-    for (let index = 0; index < REQUESTS_PER_TICK; index += 1) {
       const scenario = pickScenario();
       const requestPromise = fireScenarioRequest(url, scenario, counters).finally(() => {
         inFlight.delete(requestPromise);
       });
       inFlight.add(requestPromise);
+      launchedThisTick += 1;
     }
 
     const remaining = TICK_INTERVAL_MS - (Date.now() - tickStartedAt);
@@ -604,6 +618,7 @@ test('requests page remains responsive during 1 minute mixed live stress', async
     }
 
     await trafficPromise;
+    await page.waitForTimeout(500);
     samples.push(await collectStressSample(page, provider.id, jwt, startedAt));
 
     const finalList = await adminAPI(
@@ -634,15 +649,17 @@ test('requests page remains responsive during 1 minute mixed live stress', async
       contentType: 'application/json',
     });
 
-    const adminViolationCount = samples.filter((sample) => sample.adminOrderingViolation).length;
+    const finalSample = samples.at(-1);
     const uiViolationCount = samples.filter((sample) => sample.uiOrderingViolation).length;
     const maxRenderedRows = Math.max(...samples.map((sample) => sample.renderedRows), 0);
 
-    // Allow transient ordering violations in up to 20% of samples — under
-    // heavy concurrent load, a single poll can capture in-flight state that
-    // resolves on the next tick.
+    // Mid-run admin snapshots are diagnostic only: under sustained mixed load,
+    // a poll can land between status transition and list resort. Require the
+    // post-drain sample to converge, while still bounding UI-side violations
+    // during the live traffic window.
     const maxAllowedViolations = Math.max(1, Math.ceil(samples.length * 0.2));
-    expect(adminViolationCount).toBeLessThanOrEqual(maxAllowedViolations);
+    expect(finalSample?.adminOrderingViolation).toBe(false);
+    expect(finalSample?.uiOrderingViolation).toBe(false);
     expect(uiViolationCount).toBeLessThanOrEqual(maxAllowedViolations);
     expect(maxRenderedRows).toBeLessThanOrEqual(MAX_RENDERED_ROWS);
   } finally {

tests/e2e/playwright/requests-table-alignment.spec.ts

@@ -1,4 +1,4 @@
-import http from 'node:http';
+import http from 'node:http';
 
 import { expect, test, type Page } from 'playwright/test';
 
@@ -10,6 +10,11 @@ import {
   loginToAdminUI,
 } from './helpers';
 
+const REQUEST_FILTER_MODE_STORAGE_KEY = 'maxx-requests-filter-mode';
+const REQUEST_PROVIDER_FILTER_STORAGE_KEY = 'maxx-requests-provider-filter';
+const REQUEST_TOKEN_FILTER_STORAGE_KEY = 'maxx-requests-token-filter';
+const REQUEST_PROJECT_FILTER_STORAGE_KEY = 'maxx-requests-project-filter';
+
 test.describe.configure({ mode: 'serial' });
 
 type TableGeometry = {
@@ -169,7 +174,27 @@ async function resolveAdminToken() {
   }
 }
 
-async function openRequestsPage(page: Page) {
+async function openRequestsPage(page: Page, providerId?: number) {
+  if (providerId !== undefined) {
+    await page.addInitScript(
+      ({ id, keys }) => {
+        localStorage.setItem(keys.mode, 'provider');
+        localStorage.setItem(keys.provider, String(id));
+        localStorage.removeItem(keys.token);
+        localStorage.removeItem(keys.project);
+      },
+      {
+        id: providerId,
+        keys: {
+          mode: REQUEST_FILTER_MODE_STORAGE_KEY,
+          provider: REQUEST_PROVIDER_FILTER_STORAGE_KEY,
+          token: REQUEST_TOKEN_FILTER_STORAGE_KEY,
+          project: REQUEST_PROJECT_FILTER_STORAGE_KEY,
+        },
+      },
+    );
+  }
+
   await page.goto(`${BASE}/requests`);
   await page.waitForLoadState('networkidle');
 
@@ -246,7 +271,7 @@ test('virtualized requests table keeps header and body columns aligned', async (
       )
       .toBeGreaterThanOrEqual(40);
 
-    await openRequestsPage(page);
+    await openRequestsPage(page, provider.id);
     await expect(page.locator('table thead th').first()).toBeVisible({ timeout: 30_000 });
     await expect
       .poll(async () => page.locator('tbody tr[data-request-row="true"]').count(), { timeout: 30_000 })