From 14be83a869e2b9203f901f1ef40efd5c0d3ac636 Mon Sep 17 00:00:00 2001 From: Denozordec Date: Wed, 30 Sep 2026 09:47:51 +0700 Subject: [PATCH] =?UTF-8?q?fix(ui):=20=D0=BF=D1=80=D0=BE=D0=B2=D0=B5=D1=80?= =?UTF-8?q?=D1=8F=D1=82=D1=8C=20=D0=B4=D0=B0=D0=BD=D0=BD=D1=8B=D0=B5=20VXL?= =?UTF-8?q?AN=20=D0=B8=20=D0=B3=D0=BE=D0=BD=D0=BA=D0=B8=20=D0=B7=D0=B0?= =?UTF-8?q?=D0=B3=D1=80=D1=83=D0=B7=D0=BA=D0=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/(main)/vxlan/page.tsx | 20 ++++++++----- docs/ux-ui-plan.md | 4 +-- docs/ux-ui-progress.md | 10 ++++++- docs/ux-ui-stage-9.md | 6 +++- lib/vxlan-response.ts | 20 +++++++++++++ tests/e2e/vxlan-links.spec.ts | 56 ++++++++++++++++++++++++++++++++++- 6 files changed, 103 insertions(+), 13 deletions(-) create mode 100644 lib/vxlan-response.ts diff --git a/app/(main)/vxlan/page.tsx b/app/(main)/vxlan/page.tsx index 8b971163..ed3dee71 100644 --- a/app/(main)/vxlan/page.tsx +++ b/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(backendUrl, "/api/vxlan"), - requestJson(backendUrl, "/api/servers"), + requestJson(backendUrl, "/api/vxlan"), + requestJson(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 : "Ошибка загрузки") diff --git a/docs/ux-ui-plan.md b/docs/ux-ui-plan.md index dda4b3ca..d85c7da9 100644 --- a/docs/ux-ui-plan.md +++ b/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 — остаются явно зафиксированными, без заявления о реализации. diff --git a/docs/ux-ui-progress.md b/docs/ux-ui-progress.md index 31a1cb67..efa81b7e 100644 --- a/docs/ux-ui-progress.md +++ b/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 при ошибке вместо успешного пустого ответа. diff --git a/docs/ux-ui-stage-9.md b/docs/ux-ui-stage-9.md index 92125243..293f8f67 100644 --- a/docs/ux-ui-stage-9.md +++ b/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; реальные устройства не проверены. diff --git a/lib/vxlan-response.ts b/lib/vxlan-response.ts new file mode 100644 index 00000000..5215af59 --- /dev/null +++ b/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(), +})) diff --git a/tests/e2e/vxlan-links.spec.ts b/tests/e2e/vxlan-links.spec.ts index 1fe365ec..30052c34 100644 --- a/tests/e2e/vxlan-links.spec.ts +++ b/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(resolve => { oldRelease = resolve }) + const newGate = new Promise(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/) + }) +}