fix(ui): проверять данные VXLAN и гонки загрузки

app/(main)/vxlan/page.tsx

@@ -19,6 +19,7 @@ import {
 } from "lucide-react"
 import { CodeExportSheet } from "@/components/reui-kit/code-export-sheet"
 import { useDataSource } from "@/lib/data-source"
+import { vxlanResponseSchema, vxlanServersSchema } from "@/lib/vxlan-response"
 import { requestJson } from "@/shared/api/http-client"
 import { cn } from "@/lib/utils"
 import { ServerRailLayout, ServerRailMobileButton } from "@/components/server-rail-layout"
@@ -153,19 +154,22 @@ function VxlanPageContent({ selectedServerId, selectedTunnelId, allTunnelsHref,
     setLiveError(null)
     try {
       const [tunnelsRes, serversRes] = await Promise.all([
-        requestJson<VxlanApiResponse>(backendUrl, "/api/vxlan"),
-        requestJson<BackendServer[]>(backendUrl, "/api/servers"),
+        requestJson<unknown>(backendUrl, "/api/vxlan"),
+        requestJson<unknown>(backendUrl, "/api/servers"),
       ])
       if (epoch !== loadEpoch.current) return
-      if (!Array.isArray(tunnelsRes?.tunnels) || !Array.isArray(serversRes)) throw new Error("Некорректный ответ загрузки VXLAN")
-      const nextFailures = tunnelsRes.failures ?? []
-      if (!Array.isArray(nextFailures) || nextFailures.some(f => !f || typeof f.serverId !== "string" || typeof f.error !== "string")) throw new Error("Некорректный ответ загрузки VXLAN")
+      const parsedTunnels = vxlanResponseSchema.safeParse(tunnelsRes)
+      const parsedServers = vxlanServersSchema.safeParse(serversRes)
+      if (!parsedTunnels.success || !parsedServers.success) throw new Error("Некорректный ответ загрузки VXLAN")
+      const nextTunnels = parsedTunnels.data.tunnels
+      const nextServers = parsedServers.data
+      const nextFailures = parsedTunnels.data.failures
       const failedIds = new Set(nextFailures.map(f => f.serverId))
-      const enabledIds = new Set(serversRes.filter(s => s.enabled).map(s => String(s.id)))
-      setLiveTunnels(previous => [...tunnelsRes.tunnels.filter(t => !failedIds.has(t.serverId)), ...previous.filter(t => failedIds.has(t.serverId) && enabledIds.has(t.serverId))])
+      const enabledIds = new Set(nextServers.filter(s => s.enabled).map(s => String(s.id)))
+      setLiveTunnels(previous => [...nextTunnels.filter(t => !failedIds.has(t.serverId)), ...previous.filter(t => failedIds.has(t.serverId) && enabledIds.has(t.serverId))])
       setFailures(nextFailures)
       setHasLoaded(true)
-      setLiveServers(serversRes.filter((s) => s.enabled).map(mapBackendServer))
+      setLiveServers(nextServers.filter((s) => s.enabled).map(mapBackendServer))
     } catch (e) {
       if (epoch !== loadEpoch.current) return
       setLiveError(e instanceof Error ? e.message : "Ошибка загрузки")

docs/ux-ui-plan.md

@@ -80,7 +80,7 @@ flowchart LR
 
 ## Текущая точка продолжения
 
-По журналу этапы 0–8 завершены в границах локальной приёмки; внешние ограничения сохраняются. Этап 9 начат (блоки 9.1–9.23 — операции IPsec/GRE и частичные сбои VXLAN); этапы 10–12 не начаты. Этап 11 разделён: 11А — пользователи, контейнеры, сертификаты, резервирование; 11Б — оповещения, сбор данных, интеграции, релизы, настройки.
+По журналу этапы 0–8 завершены в границах локальной приёмки; внешние ограничения сохраняются. Этап 9 начат (блоки 9.1–9.24 — операции IPsec/GRE и загрузка VXLAN); этапы 10–12 не начаты. Этап 11 разделён: 11А — пользователи, контейнеры, сертификаты, резервирование; 11Б — оповещения, сбор данных, интеграции, релизы, настройки.
 
 Подробные планы: [этап 6](ux-ui-stage-6.md), [этап 7](ux-ui-stage-7.md), [этап 8 и итоговая матрица](ux-ui-stage-8.md), [этап 9](ux-ui-stage-9.md).
 
@@ -88,7 +88,7 @@ flowchart LR
 
 Ближайший оставшийся объём:
 
-1. Этап 9: карта разделов и схема сохранены; удаление, импорт, создание, переключение, контекст экспорта и выбор пира WireGuard исправлены в 9.1–9.7; в 9.8 проверено подтверждение восстановления. В 9.9 исправлены разметка и сохранение подтверждения при ошибке у всех шести потребителей. В 9.10 исправлены ошибки и поздние ответы загрузки истории WireGuard. В 9.11 подтверждение восстановления проверено у остальных пяти потребителей. В 9.12 обработаны ошибка/повтор/поздние ответы истории IPsec. В 9.13 подключены ошибка/повтор/защита поздних ответов остальных четырёх разделов и общая валидация ревизий всех шести. В 9.14 исправлены подтверждение инициализации IPsec, сохранение формы и защита повторной отправки. В 9.15 проверены создание/редактирование пользователей IPsec и сохранение формы. В 9.16 проверены получение/повторный экспорт сертификатов, поздние ответы и соответствие отображаемого пароля архиву. В 9.17 подтверждены ответы удаления четырёх типов объектов IPsec и исправлен диалог повторов. В 9.18 исправлено подтверждение сохранения peer IPsec и поведение формы. В 9.19 исправлено подтверждение удаления GRE и сохранение диалога при ошибке. В 9.20 исправлено подтверждение включения/выключения GRE и защита повторов. В 9.21 исправлены подтверждение создания/сохранения GRE и защита формы. В 9.22 исправлены контейнер ответа, первоначальные KPI и сохранение данных при ошибке VXLAN. В 9.23 backend сообщает частичные сбои VXLAN, UI сохраняет данные неответивших устройств и показывает неизвестное состояние. Далее — валидация payload и тесты гонок VXLAN, затем Firewall/Filters; загрузка данных IPsec и общая приёмка остаются открытыми.
+1. Этап 9: карта разделов и схема сохранены; удаление, импорт, создание, переключение, контекст экспорта и выбор пира WireGuard исправлены в 9.1–9.7; в 9.8 проверено подтверждение восстановления. В 9.9 исправлены разметка и сохранение подтверждения при ошибке у всех шести потребителей. В 9.10 исправлены ошибки и поздние ответы загрузки истории WireGuard. В 9.11 подтверждение восстановления проверено у остальных пяти потребителей. В 9.12 обработаны ошибка/повтор/поздние ответы истории IPsec. В 9.13 подключены ошибка/повтор/защита поздних ответов остальных четырёх разделов и общая валидация ревизий всех шести. В 9.14 исправлены подтверждение инициализации IPsec, сохранение формы и защита повторной отправки. В 9.15 проверены создание/редактирование пользователей IPsec и сохранение формы. В 9.16 проверены получение/повторный экспорт сертификатов, поздние ответы и соответствие отображаемого пароля архиву. В 9.17 подтверждены ответы удаления четырёх типов объектов IPsec и исправлен диалог повторов. В 9.18 исправлено подтверждение сохранения peer IPsec и поведение формы. В 9.19 исправлено подтверждение удаления GRE и сохранение диалога при ошибке. В 9.20 исправлено подтверждение включения/выключения GRE и защита повторов. В 9.21 исправлены подтверждение создания/сохранения GRE и защита формы. В 9.22 исправлены контейнер ответа, первоначальные KPI и сохранение данных при ошибке VXLAN. В 9.23 backend сообщает частичные сбои VXLAN, UI сохраняет данные неответивших устройств и показывает неизвестное состояние. В 9.24 добавлены схемы payload и тесты гонок VXLAN. Далее — операции Firewall и Filters; ограничения счётчика, свежести и записи VXLAN остаются открытыми; загрузка данных IPsec и общая приёмка остаются открытыми.
 2. Сохранять контекст устройства, введённые значения при ошибке и подтверждать результат операций по API; локальные моки проверяют клиентские сценарии, реальные сетевые операции требуют тестового окружения.
 3. В этапе 12 выполнить полный аудит доступности (скринридер, контраст), производительности и сквозную регрессию. Ограничения этапа 8 — удалённые серверы месячного каталога, отсутствие экспорта и автоматического переподключения SSE — остаются явно зафиксированными, без заявления о реализации.
 

docs/ux-ui-progress.md

@@ -25,12 +25,20 @@
 | 6 | Навигация и дашборд | Завершён 2026-09-20 в границах локальной приёмки; ограничения ниже |
 | 7 | Серверы и мониторинг: детали, формы, URL-контекст, права | Завершён в границах локальной приёмки 2026-09-23; внешние ограничения ниже |
 | 8 | Трафик и статистика | Завершён 2026-09-28 в границах локальной приёмки; ограничения в блоке 8.13 |
-| 9 | VPN, Firewall и Filters | В работе: блоки 9.1–9.23 — операции IPsec/GRE и частичные сбои VXLAN |
+| 9 | VPN, Firewall и Filters | В работе: блоки 9.1–9.24 — операции IPsec/GRE и загрузка VXLAN |
 | 10 | Маршрутизация, диагностика, карта и терминал | Не начат |
 | 11А | Пользователи, контейнеры, сертификаты и резервные копии | Не начат |
 | 11Б | Оповещения, сбор данных, интеграции, релизы и настройки | Не начат |
 | 12 | Итоговая доступность, адаптивность, производительность и регрессия | Не начат |
 
+## Блок 9.24 — схема ответа и гонки VXLAN (2026-09-30)
+
+- Добавлены схемы туннелей, failures и записей серверов. Проверяются обязательные строки, булевы поля, статус, диапазоны VNI/портов, массив VTEP и уникальность пары serverId/id. Отсутствующий failures совместим со старым API (пустой список). Неверный ответ сохраняет последние данные и отображает ошибку.
+- Все 16 E2E VXLAN прошли, включая новый сценарий пяти повреждённых payload и два сценария позднего ответа при смене server: успех/ошибка старого запроса не меняют ожидание и результат нового. Тест учитывает повторный mount Next.js development. Первоначальное ожидание ровно двух запросов уточнено до наличия нового запроса; проверки результата сохранены.
+- TypeScript и lint изменённых файлов прошли; diff-check чистый. Build не повторялся, последний — 9.21. Синтаксическая проверка VTEP-адресов и криптографическая/сетевая достоверность RouterOS не проверены схемой. Серверы могут отсутствовать в каталоге: существующая таблица сохраняет строки с неизвестным сервером без подмены ID.
+- Далее — Firewall: аудит записи/перемещения/удаления и ответы backend, сохранение формы при ошибке и защита повторов. Открытые ограничения VXLAN: countVxlanTunnels возвращает ноль при ошибке, timestamp свежести отсутствует, создание/изменение VXLAN не реализованы backend; этап 9 не завершён.
+- Блок начат при 11% расхода пятичасовой и 2% недельной квоты. Локальный коммит без push; чужие изменения сохранены.
+
 ## Блок 9.23 — частичные сбои VXLAN (2026-09-30)
 
 - Общий API VXLAN возвращает tunnels/failures; неответившие устройства не маскируются пустыми списками. Сбой VTEP или повреждённый массив устройства также считается ошибкой опроса. Endpoint отдельного устройства возвращает 502 при ошибке вместо успешного пустого ответа.

docs/ux-ui-stage-9.md

@@ -1,6 +1,6 @@
 # Этап 9: VPN и сетевые операции
 
-Статус: начат 2026-09-28, выполнены блоки 9.1–9.23. Основа — существующие ReUI PRO/base-nova, Frame, ServerTileRail, DataGrid и формы. Правила применения сетевой конфигурации не меняем.
+Статус: начат 2026-09-28, выполнены блоки 9.1–9.24. Основа — существующие ReUI PRO/base-nova, Frame, ServerTileRail, DataGrid и формы. Правила применения сетевой конфигурации не меняем.
 
 ## Схема и референсы принятого плана
 
@@ -133,3 +133,7 @@ PATCH требует ok=true; замок блокирует повтор, ожи
 ## Блок 9.23 — частичный сбой VXLAN (2026-09-30)
 
 API возвращает failures, одиночный endpoint — 502 при сбое; VTEP не маскируется пустым списком. UI сохраняет последние туннели устройства, показывает неизвестное состояние и повтор. Проверены серверная агрегация и 13 E2E, frontend/backend TypeScript и frontend lint прошли. Далее — схема payload и гонки загрузки VXLAN. Счётчик countVxlanTunnels всё ещё возвращает ноль при ошибке, timestamp и запись VXLAN не реализованы; реальные устройства не проверены.
+
+## Блок 9.24 — проверка данных VXLAN (2026-09-30)
+
+Схемы отклоняют повреждённые записи/серверы/failures и дубли пары serverId/id. Все 16 E2E, lint и TypeScript прошли, включая поздний успех/ошибку при смене устройства. Далее — операции Firewall, затем Filters. Счётчик ошибок, timestamp и запись VXLAN остаются открытыми, последний build — 9.21; реальные устройства не проверены.

lib/vxlan-response.ts

@@ -0,0 +1,20 @@
+import { z } from "zod"
+
+export const vxlanResponseSchema = z.object({
+  tunnels: z.array(z.object({
+    id: z.string().min(1), name: z.string().min(1), serverId: z.string().min(1),
+    vni: z.number().int().min(0).max(16777215),
+    port: z.number().int().min(0).max(65535), dstPort: z.number().int().min(1).max(65535),
+    vtepIp: z.string(), remoteVteps: z.array(z.string()), l2mtu: z.number().int().nonnegative(),
+    arpProxy: z.boolean(), macLearning: z.boolean(), comment: z.string(), enabled: z.boolean(),
+    status: z.enum(["up", "down"]),
+  })).refine(rows => new Set(rows.map(row => JSON.stringify([row.serverId, row.id]))).size === rows.length),
+  failures: z.array(z.object({ serverId: z.string().min(1), serverName: z.string().optional(), error: z.string() })).default([]),
+})
+
+export const vxlanServersSchema = z.array(z.object({
+  id: z.number().int().positive(), name: z.string(), host: z.string(), country: z.string(), enabled: z.boolean(),
+  type: z.enum(["jump-host", "exit-node", "home-router"]).optional(), site: z.string().optional(),
+  asn: z.string().optional(), status: z.enum(["online", "offline", "degraded"]).optional(),
+  latency: z.number().finite().nullable().optional(),
+}))

tests/e2e/vxlan-links.spec.ts

@@ -1,7 +1,7 @@
 import { test, expect, type Page } from "@playwright/test"
 
 async function setup(page: Page, url: string, failed = 0) {
-  const control = { malformed: false, partial: false, failed, posts: [] as { path: string; body: unknown }[] }
+  const control = { payload: undefined as unknown, malformed: false, partial: false, failed, posts: [] as { path: string; body: unknown }[] }
   const servers = [{ id: 1, name: "Источник", host: "192.0.2.1", type: "exit-node", enabled: true, country: "RU", site: "TEST", asn: "64512", status: "online", latency: 1, os: "7", model: "CHR", wanUplinks: [] }]
   const tunnels = ["1", "2"].flatMap(serverId => ["*/2", "other"].map(id => ({ id, serverId, name: "vx-same", vni: Number(serverId) * 100 + (id === "other" ? 1 : 0), port: 0, dstPort: 8472, vtepIp: "192.0.2.1", remoteVteps: ["192.0.2.22"], l2mtu: 1500, arpProxy: false, macLearning: true, comment: "", enabled: true, status: "down" })))
   servers.push({ ...servers[0], id: 2, name: "Второй сервер", host: "192.0.2.2" });
@@ -11,6 +11,7 @@ async function setup(page: Page, url: string, failed = 0) {
     const request = route.request()
     const path = new URL(request.url()).pathname
     if (!["GET", "HEAD"].includes(request.method())) control.posts.push({ path, body: request.postDataJSON() })
+    if (path === "/api/vxlan" && control.payload !== undefined) return route.fulfill({ json: control.payload })
     if (path === "/api/vxlan" && control.failed) return route.fulfill({ status: control.failed, json: { error: "Мониторинг недоступен" } })
     if (path === "/api/vxlan" && control.malformed) return route.fulfill({ json: {} })
     const json = path === "/api/auth/config" ? { required: false }
@@ -158,3 +159,56 @@ test("VXLAN: первый частичный сбой не выглядит пу
   await expect(page.getByText("На опрошенных серверах нет VXLAN-интерфейсов", { exact: true })).toHaveCount(0)
   await expect(page.getByLabel("Сводка VXLAN")).toContainText("—")
 })
+
+test("VXLAN: повреждённые записи не заменяют последний список", async ({ page }) => {
+  const control = await setup(page, "/vxlan")
+  const rows = page.locator("tr[data-row-id]")
+  await expect(rows).toHaveCount(4)
+  const valid = { id: "id", serverId: "1", name: "vx", vni: 1, port: 0, dstPort: 8472, vtepIp: "", remoteVteps: [], l2mtu: 1500, arpProxy: false, macLearning: true, comment: "", enabled: true, status: "up" }
+  for (const payload of [
+    { tunnels: [{ ...valid, remoteVteps: null }] },
+    { tunnels: [{ ...valid, vni: 16777216 }] },
+    { tunnels: [{ ...valid, status: "unknown" }] },
+    { tunnels: [valid, valid] },
+    { tunnels: [], failures: [{ serverId: "1", error: null }] },
+  ]) {
+    control.payload = payload
+    await page.getByRole("button", { name: "Обновить", exact: true }).click()
+    await expect(page.getByText("Ошибка загрузки: Некорректный ответ загрузки VXLAN", { exact: true })).toBeVisible()
+    await expect(rows).toHaveCount(4)
+  }
+  control.payload = undefined
+  await page.getByRole("button", { name: "Обновить", exact: true }).click()
+  await expect(page.getByText("Ошибка загрузки:", { exact: false })).toHaveCount(0)
+})
+
+for (const oldFails of [false, true]) {
+  test(`VXLAN: поздний ответ старого устройства игнорируется ${oldFails}`, async ({ page }) => {
+    await setup(page, "/vxlan?server=1")
+    await expect(page.locator("tr[data-row-id]")).toHaveCount(2)
+    let oldRelease: (() => void) | undefined
+    let newRelease: (() => void) | undefined
+    const oldGate = new Promise<void>(resolve => { oldRelease = resolve })
+    const newGate = new Promise<void>(resolve => { newRelease = resolve })
+    let attempts = 0
+    await page.route("**/api/vxlan", async route => {
+      attempts++
+      if (attempts === 1) { await oldGate; return route.fulfill(oldFails ? { status: 500, json: { error: "Поздняя ошибка тест" } } : { json: { tunnels: [] } }) }
+      await newGate
+      return route.fallback()
+    })
+    await page.getByRole("button", { name: "Обновить", exact: true }).click()
+    await expect.poll(() => attempts).toBe(1)
+    await page.getByRole("option").filter({ hasText: "Второй сервер" }).click()
+    await expect.poll(() => attempts).toBeGreaterThanOrEqual(2)
+    const response = page.waitForResponse(r => r.url().endsWith("/api/vxlan"))
+    oldRelease!()
+    await (await response).finished()
+    await page.waitForTimeout(100)
+    await expect(page.getByRole("button", { name: "Обновить", exact: true })).toBeDisabled()
+    await expect(page.getByText("Ошибка загрузки:", { exact: false })).toHaveCount(0)
+    newRelease!()
+    await expect(page.locator("tr[data-row-id]")).toHaveCount(2)
+    await expect(page).toHaveURL(/server=2/)
+  })
+}