diff --git a/app/(main)/settings/page.tsx b/app/(main)/settings/page.tsx index a7b267c4..c3666c1e 100644 --- a/app/(main)/settings/page.tsx +++ b/app/(main)/settings/page.tsx @@ -32,8 +32,6 @@ import { import { cn } from "@/lib/utils" import { requestJson } from "@/shared/api/http-client" import { downloadSystemDatabaseBackup, restoreSystemDatabaseBackup } from "@/shared/api/system-database" -import { purgeTrafficFlowData } from "@/shared/api/traffic-flow" -import { formatFlowPurgeResult, NetflowPurgeConfirm } from "@/components/traffic/netflow-purge-dialog" import { toast } from "sonner" interface ApiKey { id: string; name: string; prefix: string; created: string; last: string; scopes: string[] } @@ -150,8 +148,6 @@ export default function SettingsPage() { const [dbRestoreBusy, setDbRestoreBusy] = useState(false) const [dbRestoreFile, setDbRestoreFile] = useState(null) const [dbRestoreDialogOpen, setDbRestoreDialogOpen] = useState(false) - const [dbPurgeOpen, setDbPurgeOpen] = useState(false) - const [dbPurgeBusy, setDbPurgeBusy] = useState(false) // notifications const [notifEmail, setNotifEmail] = useState(true) @@ -270,19 +266,7 @@ export default function SettingsPage() { } }, [backendUrl, dbRestoreFile, systemDbAvailable]) - const handleNetflowPurgeConfirm = useCallback(async () => { - if (!systemDbAvailable) return - setDbPurgeBusy(true) - try { - const result = await purgeTrafficFlowData(backendUrl) - toast.success(formatFlowPurgeResult(result)) - setDbPurgeOpen(false) - } catch (e) { - toast.error(e instanceof Error ? e.message : "Не удалось сбросить NetFlow") - } finally { - setDbPurgeBusy(false) - } - }, [backendUrl, systemDbAvailable]) + const renderContent = () => { const ra = DEFAULT_ROUTE_AI_OPTIMIZER_SETTINGS @@ -435,7 +419,7 @@ export default function SettingsPage() { {!systemDbAvailable && ( @@ -452,7 +436,7 @@ export default function SettingsPage() { variant="outline" size="sm" className="h-8" - disabled={!systemDbAvailable || dbBackupBusy || dbRestoreBusy || dbPurgeBusy} + disabled={!systemDbAvailable || dbBackupBusy || dbRestoreBusy} onClick={() => { void handleSystemDatabaseBackup() }} > {dbBackupBusy ? : } @@ -468,7 +452,7 @@ export default function SettingsPage() { variant="outline" size="sm" className="h-8" - disabled={!systemDbAvailable || dbBackupBusy || dbRestoreBusy || dbPurgeBusy} + disabled={!systemDbAvailable || dbBackupBusy || dbRestoreBusy} onClick={() => setDbRestoreDialogOpen(true)} > @@ -481,18 +465,10 @@ export default function SettingsPage() { - + {systemDbAvailable ? Открыть NetFlow : } + @@ -926,13 +902,6 @@ export default function SettingsPage() { /> )} - { void handleNetflowPurgeConfirm() }} - onCancel={() => { if (!dbPurgeBusy) setDbPurgeOpen(false) }} - /> - {invoked++;return {ok:true}}}) +for(const [method,url] of [["GET","/api/traffic/flow/settings"],["GET","/api/traffic/flow/host-files"],["POST","/api/traffic/flow/settings/generate-keys"],["PUT","/api/traffic/flow/settings"],["POST","/api/traffic/flow/purge"]] as const) app.route({method,url,handler:async()=>{invoked++;return {ok:true}}}) for(const permission of ["mm:dashboard:read","mm:traffic:read","mm:traffic:write","mm:traffic:admin","mm:settings:admin"]){ const token=await new SignJWT({sub:"fixture",apps:["mm"],permissions:[permission]}).setProtectedHeader({alg:"HS256"}).setIssuer("https://auth.test.local").setExpirationTime("1h").sign(new TextEncoder().encode("netflow-test-secret")) - for(const [method,url] of [["GET","/api/traffic/flow/settings"],["GET","/api/traffic/flow/host-files"],["POST","/api/traffic/flow/settings/generate-keys"],["PUT","/api/traffic/flow/settings"]] as const){ + for(const [method,url] of [["GET","/api/traffic/flow/settings"],["GET","/api/traffic/flow/host-files"],["POST","/api/traffic/flow/settings/generate-keys"],["PUT","/api/traffic/flow/settings"],["POST","/api/traffic/flow/purge"]] as const){ const before=invoked;const response=await app.inject({method,url,headers:{authorization:"Bearer "+token}}) const allowed=permission==="mm:traffic:write"||permission==="mm:traffic:admin"||(permission==="mm:traffic:read"&&url.endsWith("/settings")&&method==="GET") assert.equal(response.statusCode,allowed?200:403,permission+" "+method+" "+url);assert.equal(invoked,before+(allowed?1:0)) diff --git a/components/traffic/netflow-settings-panel.tsx b/components/traffic/netflow-settings-panel.tsx index a6222c57..0ef13bff 100644 --- a/components/traffic/netflow-settings-panel.tsx +++ b/components/traffic/netflow-settings-panel.tsx @@ -120,6 +120,7 @@ function NetflowSettingsContent({ return ( <> +
+
diff --git a/docs/ux-ui-plan.md b/docs/ux-ui-plan.md index 2f7c105a..1b6dd31b 100644 --- a/docs/ux-ui-plan.md +++ b/docs/ux-ui-plan.md @@ -268,3 +268,5 @@ REST запрос → ожидание → подтверждённый output / Завершён 11Б.3.4.4.7.2: общий NetFlow IP/CIDR/DNS/ports patch, draft и backend проверяют его; инструкция использует фактический порт. 14 E2E, unit/HTTP/JWT, lint и оба builds прошли. Далее 11Б.3.4.4.7.3 — согласованный host export/маска, затем приёмка NetFlow и Evolution. Завершён 11Б.3.4.4.7.3: host export из одного снимка, фактические mask/WG/IPFIX ports, strict keys/peers и безопасные однострочные комментарии. Builder/key/HTTP/JWT/build/lint прошли без запуска host/RouterOS. Далее 11Б.3.4.4.8 — приёмка NetFlow; затем 11Б.3.5 Evolution. Нестандартные prefix allocator не приняты. + +Локальная приёмка NetFlow 11Б.3.4.4.8: 19 основных и 10 source E2E, backend JWT с purge, backend/frontend builds и API tests прошли в описанных блоках. Дублирующий purge Settings заменён переходом к единой панели (link E2E/typecheck). Исходные lint ошибки Settings остаются до его блока. Внешние PG/WG/RouterOS/Portal/нестандартный IPv4 prefix не приняты. Далее 11Б.3.5.1 — строгие Evolution settings/save/test API и затем provider/форма. diff --git a/docs/ux-ui-progress.md b/docs/ux-ui-progress.md index 57802116..b4f9e0cf 100644 --- a/docs/ux-ui-progress.md +++ b/docs/ux-ui-progress.md @@ -28,7 +28,7 @@ | 9 | VPN, Firewall и Filters | Завершён в границах локальной приёмки 2026-09-30; блоки 9.1–9.64, ограничения в 9.64 | | 10 | Маршрутизация, диагностика, карта и терминал | Завершён в границах локальной приёмки 2026-10-01; блоки 10.1–10.71, внешние ограничения в 10.71 | | 11А | Пользователи, контейнеры, сертификаты и резервные копии | Завершён в границах локальной приёмки 2026-10-01; 11А.1–11А.33, внешние ограничения в 11А.33 | -| 11Б | Оповещения, сбор данных, интеграции, релизы и настройки | В работе: 11Б.1–11Б.3.4.4.7.3; scheduler и GeoIP приняты локально; NetFlow API/backend/форма/source/adaptive проверены, далее общий сетевой ввод и Evolution | +| 11Б | Оповещения, сбор данных, интеграции, релизы и настройки | В работе: 11Б.1–11Б.3.4.4.8; scheduler и GeoIP приняты локально; NetFlow принят локально; далее Evolution и общие settings | | 12 | Итоговая доступность, адаптивность, производительность и регрессия | Не начат | @@ -36,6 +36,15 @@ +## Блок 11Б.3.4.4.8 — локальная приёмка NetFlow (2026-10-03) + +- Итоговые 19 основных NetFlow E2E (16 form + 3 responsive) и 10 backend source E2E прошли после общего контракта; добавлены дробный порог без default и GET после подтверждённого PUT. JWT gate дополнен purge: traffic reader не вызывает destructive handler. Backend профили/build и frontend production build приняты в предыдущих блоках; последнее изменение navigation/typecheck проверено отдельно. +- Выявлен второй purge consumer в Settings: его старый toast игнорировал partial warnings. Заменён переходом /data-collection#netflow к единой панели состояния/прав/подтверждения. Link E2E проверил переход без POST; полный typecheck и lint изменённых компонентов/тестов прошли. Preview ссылку из пользовательского описания базы убрали. +- Settings page имеет исходные 2 synchronous-effect lint errors и warnings (backend URL draft, Evolution hydration/dependencies, неиспользованный apiFetch). Это не новая проблема перехода; исправить в следующем settings блоке. Остальные демонстрационные формы, restore/database, Evolution не приняты этим блоком. +- 6 снимков обновлены тестами; верх/действия 320 и ПК проверены ранее, заголовок IPFIX теперь общий. ReUI Frame/Form/Alert/Sheet и theme сохранены, vendor не менялся. +- NetFlow принят в границах локальных DI/HTTP/UI fixtures. Реальные PG транзакции/lock/worker, WG/Linux, RouterOS/Portal не приняты. Unknown guard не durable между reload/navigation; table lock performance и multi-instance ingest отдельно; текущий IPv4 allocator для нестандартных prefix не принят. Автоматические повторные destructive POST не добавлены. +- Далее 11Б.3.5.1 — строгие Evolution settings/save/test API с проверкой сохранённых полей, затем provider known/error/time/context и сохранённая форма. После Evolution — общие Settings/Alerts/Releases/probes schedule по карте этапа. + ## Блок 11Б.3.4.4.7.3 — согласованный host export NetFlow (2026-10-03) - Host export читает одну settings row вместе с peersJson, валидирует один снимок и синхронно генерирует Linux/WG/compose файлы. Нет отдельных запросов между файлами и конфигом внутри script. diff --git a/docs/ux-ui-stage-11b.md b/docs/ux-ui-stage-11b.md index 3127fd14..a18f0fb7 100644 --- a/docs/ux-ui-stage-11b.md +++ b/docs/ux-ui-stage-11b.md @@ -196,3 +196,5 @@ ReUI PRO/base-nova; существующие Frame, Data Grid v9, KpiStatGrid, S Завершён 11Б.3.4.4.7.2: общий NetFlow IP/CIDR/DNS/ports patch, draft и backend проверяют его; инструкция использует фактический порт. 14 E2E, unit/HTTP/JWT, lint и оба builds прошли. Далее 11Б.3.4.4.7.3 — согласованный host export/маска, затем приёмка NetFlow и Evolution. Завершён 11Б.3.4.4.7.3: host export из одного снимка, фактические mask/WG/IPFIX ports, strict keys/peers и безопасные однострочные комментарии. Builder/key/HTTP/JWT/build/lint прошли без запуска host/RouterOS. Далее 11Б.3.4.4.8 — приёмка NetFlow; затем 11Б.3.5 Evolution. Нестандартные prefix allocator не приняты. + +Локальная приёмка NetFlow 11Б.3.4.4.8: 19 основных и 10 source E2E, backend JWT с purge, backend/frontend builds и API tests прошли в описанных блоках. Дублирующий purge Settings заменён переходом к единой панели (link E2E/typecheck). Исходные lint ошибки Settings остаются до его блока. Внешние PG/WG/RouterOS/Portal/нестандартный IPv4 prefix не приняты. Далее 11Б.3.5.1 — строгие Evolution settings/save/test API и затем provider/форма. diff --git a/docs/ux-ui/screens/netflow-1440.png b/docs/ux-ui/screens/netflow-1440.png index ab52d4a4..1a5ffa3e 100644 Binary files a/docs/ux-ui/screens/netflow-1440.png and b/docs/ux-ui/screens/netflow-1440.png differ diff --git a/docs/ux-ui/screens/netflow-320.png b/docs/ux-ui/screens/netflow-320.png index 1b35eb56..00d7b7a4 100644 Binary files a/docs/ux-ui/screens/netflow-320.png and b/docs/ux-ui/screens/netflow-320.png differ diff --git a/docs/ux-ui/screens/netflow-390.png b/docs/ux-ui/screens/netflow-390.png index c12174fd..1a17b6c0 100644 Binary files a/docs/ux-ui/screens/netflow-390.png and b/docs/ux-ui/screens/netflow-390.png differ diff --git a/docs/ux-ui/screens/netflow-actions-1440.png b/docs/ux-ui/screens/netflow-actions-1440.png index 86c25d4d..dadfecbd 100644 Binary files a/docs/ux-ui/screens/netflow-actions-1440.png and b/docs/ux-ui/screens/netflow-actions-1440.png differ diff --git a/docs/ux-ui/screens/netflow-actions-320.png b/docs/ux-ui/screens/netflow-actions-320.png index dfe55b5a..d67e3728 100644 Binary files a/docs/ux-ui/screens/netflow-actions-320.png and b/docs/ux-ui/screens/netflow-actions-320.png differ diff --git a/docs/ux-ui/screens/netflow-actions-390.png b/docs/ux-ui/screens/netflow-actions-390.png index 3cfa69eb..ea3d5bb3 100644 Binary files a/docs/ux-ui/screens/netflow-actions-390.png and b/docs/ux-ui/screens/netflow-actions-390.png differ diff --git a/tests/e2e/netflow-settings.spec.ts b/tests/e2e/netflow-settings.spec.ts index b73aa809..6003c53e 100644 --- a/tests/e2e/netflow-settings.spec.ts +++ b/tests/e2e/netflow-settings.spec.ts @@ -57,3 +57,9 @@ test("NetFlow: сетевой ввод проверяется до HTTP и port await collector.fill("10.255.254.1");const endpoint=page.getByRole("textbox",{name:"Публичный endpoint хоста MM",exact:true});await endpoint.fill("https://host.test");await save(page).click();await expect(page.getByText("Endpoint: укажите IP или DNS-имя без порта и протокола",{exact:true})).toBeVisible();expect(writes).toEqual([]) await endpoint.fill("Collector.EXAMPLE.test.");await field(page).fill("4740");await save(page).click();await expect(page.getByText("Сохранение настроек NetFlow подтверждено",{exact:true})).toBeVisible();expect(writes).toEqual([{collectorIp:"10.255.254.1",flowListenPort:4740,publicEndpoint:"Collector.EXAMPLE.test."}]);await expect(page.getByText(/Firewall: разрешите UDP listen WireGuard. UDP 4740/)).toBeVisible();await expect(page.getByText(/ss -ulnp.*4740/)).toBeVisible() }) + +test("NetFlow: порог включается с явной долей, без default 5",async({page})=>{await setup(page);const writes:object[]=[];await page.route("**/api/traffic/flow/settings",r=>{if(r.request().method()!=="PUT")return r.fallback();const patch=r.request().postDataJSON();writes.push(patch);return r.fulfill({json:{ok:true,settings:{...settings,...patch}}})});await open(page);await page.getByRole("switch",{name:"Порог доли на карте",exact:true}).click();const share=page.getByRole("textbox",{name:"Минимум % окна",exact:true});await expect(share).toHaveValue("0");await save(page).click();await expect(page.getByText("Порог карты: укажите долю больше 0 и не более 100%",{exact:true})).toBeVisible();expect(writes).toEqual([]);await share.fill("0.25");await save(page).click();await expect(page.getByText("Сохранение настроек NetFlow подтверждено",{exact:true})).toBeVisible();expect(writes).toEqual([{mapServiceMinSharePct:0.25}]);await expect(share).toHaveValue("0.25")}) + +test("NetFlow: поздний GET не отменяет подтверждённый PUT",async({page})=>{await setup(page);let pending=false,started=false,completed=false,release!:()=>void;const gate=new Promise(resolve=>release=resolve);await page.route("**/api/traffic/flow/settings",async r=>{if(r.request().method()==="PUT")return r.fulfill({json:{ok:true,settings:{...settings,...r.request().postDataJSON()}}});if(!pending)return r.fallback();started=true;await gate;try{await r.fulfill({json:settings})}catch{}finally{completed=true}});try{await open(page);pending=true;await refresh(page).click();await expect.poll(()=>started).toBe(true);await field(page).fill("4740");await save(page).click();await expect(page.getByText("Сохранение настроек NetFlow подтверждено",{exact:true})).toBeVisible();release();await expect.poll(()=>completed).toBe(true);await expect(field(page)).toHaveValue("4740");await expect(save(page)).toBeDisabled()}finally{release()}}) + +test("NetFlow: Settings ведут к единому подтверждению сброса без POST перехода",async({page})=>{await setup(page);let posts=0;page.on("request",r=>{if(new URL(r.url()).pathname==="/api/traffic/flow/purge")posts++});await page.goto("/settings");const link=page.getByRole("link",{name:"Открыть NetFlow",exact:true});await expect(link).toHaveAttribute("href","/data-collection#netflow");await link.click();await expect(page).toHaveURL(/data-collection#netflow$/);await expect(page.getByRole("region",{name:"Настройки NetFlow",exact:true})).toBeVisible();await expect(field(page)).toHaveValue("4739");expect(posts).toBe(0);await expect(page.getByRole("alertdialog")).toHaveCount(0)})