fix(ui): отклонять повреждённые данные live-потока

docs/ux-ui-progress.md

@@ -29,6 +29,14 @@
 | 11Б | Оповещения, сбор данных, интеграции, релизы и настройки | Не начат |
 | 12 | Итоговая доступность, адаптивность, производительность и регрессия | Не начат |
 
+## Блок 8.4В — проверка live-контракта flow (2026-09-24)
+
+- useFlowLive проверяет полный объект через существующую flowAnalyticsDtoSchema, дополнительно отклоняя отрицательные/нечисловые значения рядов RX/TX. Прежняя проверка только uniqueSrc/destinations удалена.
+- Некорректный sample прекращает подписку и сохраняет последнее корректное измерение своего контекста с явной ошибкой. Ошибка не затирается последующим закрытием SSE; error-событие безопасно читает строку из неизвестного JSON.
+- 13 flow-E2E прошли, включая пять повреждённых ответов: неполный объект, отрицательная скорость при остальных корректных полях, null, некорректная строка destinations и отрицательная серия. Каждый проверяет сохранение корректного измерения и отсутствие live-метки. Тесты явно создают новую подписку переходом 15m → 5m, так как вход в раздел уже выбирает 5m.
+- Lint hook/тестов и diff-check чистые; production build/TypeScript прошли (34 страницы). Использовано 57% пятичасового и 71% недельного лимита. Локальный коммит без push.
+- Далее: неизвестные optional-метрики (overlay/wire/mesh), пустые исторические серии и единицы; отдельные проверки смены backend/сервера и позднего SSE. REST-ответы этой проверкой не охвачены; реальный IPFIX/RouterOS не проверен. Этап 8 остаётся в работе.
+
 ## Блок 8.4Б — клиенты, интерфейсы и пустые списки (2026-09-24)
 
 - Длинные идентификаторы переносятся в деталях и строках привязанных интерфейсов; строки адаптированы под телефон. Мини-графики итогов ограничены шириной ячейки: устранено переполнение на 320 px.

hooks/use-flow-live.ts

@@ -1,7 +1,7 @@
 "use client"
 
 import { useEffect, useState } from "react"
-import type { FlowAnalyticsDto } from "@mmapp/contracts/traffic-flow"
+import { flowAnalyticsDtoSchema, type FlowAnalyticsDto } from "@mmapp/contracts/traffic-flow"
 import { resolveApiUrl, withAuthHeaders } from "@/shared/api/http-client"
 import { flowQuery } from "@/shared/api/traffic-flow"
 
@@ -16,9 +16,8 @@ function parseSseBlock(block: string): { event: string; data: string } {
 }
 
 export function isValidFlowLiveSample(value: unknown): value is FlowAnalyticsDto {
-  if (!value || typeof value !== "object") return false
-  const v = value as Partial<FlowAnalyticsDto>
-  return typeof v.uniqueSrc === "number" && Array.isArray(v.destinations)
+  const parsed = flowAnalyticsDtoSchema.safeParse(value)
+  return parsed.success && [...parsed.data.rxSeries, ...parsed.data.txSeries].every(value => Number.isFinite(value) && value >= 0)
 }
 
 export function useFlowLive(opts: {
@@ -81,19 +80,19 @@ export function useFlowLive(opts: {
             if (ev.event === "sample" && ev.data) {
               const parsed = JSON.parse(ev.data) as unknown
               if (!isValidFlowLiveSample(parsed)) {
-                setError("live sample пустой")
-                continue
+                throw new Error("Некорректные данные live-потока")
               }
               setResult({ key, sample: parsed, error: parsed.degraded ? "Коллектор перегружен: упрощённая аналитика" : null })
             } else if (ev.event === "error" && ev.data) {
-              const parsed = JSON.parse(ev.data) as { error?: string }
-              setError(parsed.error ?? "live error")
+              const parsed: unknown = JSON.parse(ev.data)
+              throw new Error(parsed && typeof parsed === "object" && "error" in parsed && typeof parsed.error === "string" ? parsed.error : "Ошибка live-потока")
             }
           }
         }
       } catch (e) {
         if (ac.signal.aborted) return
-        setError(e instanceof Error ? e.message : "live error")
+        setError(e instanceof Error ? e.message : "Ошибка live-потока")
+        ac.abort()
       }
     })()
 

tests/e2e/traffic-flow.spec.ts

@@ -1,7 +1,7 @@
 import { test, expect, type Page } from '@playwright/test'
 
 async function setup(page: Page) {
-  const control = { hold: '', fail: false, failList: false, release: () => {} }
+  const control = { hold: '', fail: false, failList: false, invalidSample: undefined as unknown, mergeSample: false, release: () => {} }
   const gate = new Promise<void>(resolve => { control.release = resolve })
   const card = { id: '1', name: 'Экспортёр тест', subtitle: '', site: 'TEST', country: 'RU', status: 'online', rxNow: 2, txNow: 3, sessions: 1, rxSeries: [1, 2], txSeries: [2, 3], bytes: 200 }
   const data = { bpsNow: 1000000, bytes: 200, packets: 2, conversations: 1, uniqueSrc: 1, uniqueDst: 1, topProto: 'TCP', rxSeries: [1], txSeries: [2], applications: [], protocols: [], sources: [], destinations: [], interfaces: [], conversationsList: [], ifaces: [], live: false }
@@ -14,7 +14,7 @@ async function setup(page: Page) {
       if (control.fail) return route.fulfill({ status: 500, json: { error: 'Срез временно недоступен' } })
       return route.fulfill({ json: { ...data, topCategory: 'Категория ' + range } })
     }
-    if (path === '/api/traffic/flow/live') return route.fulfill({ contentType: 'text/event-stream', body: 'event: sample\ndata: ' + JSON.stringify({ ...data, live: true }) + '\n\n' })
+    if (path === '/api/traffic/flow/live') return route.fulfill({ contentType: 'text/event-stream', body: 'event: sample\ndata: ' + JSON.stringify({ ...data, live: true }) + '\n\n' + (control.invalidSample === undefined ? '' : 'event: sample\ndata: ' + JSON.stringify(control.mergeSample ? { ...data, ...(control.invalidSample as object) } : control.invalidSample) + '\n\n') })
     if (path === '/api/traffic/flow/exporters' && control.failList) return route.fulfill({ status: 403, json: { error: 'Нет доступа к экспортёрам' } })
     const json = path === '/api/auth/config' ? { required: false }
       : path === '/api/traffic/flow/exporters' ? { exporters: [card] }
@@ -123,3 +123,25 @@ for (const width of [320, 390, 1440]) {
     await page.screenshot({ path: `test-results/flow-monthly-${width}.png`, fullPage: true })
   })
 }
+
+
+for (const [name, invalid, merge] of [
+  ['неполный объект', { uniqueSrc: 1, destinations: [] }, false],
+  ['отрицательная скорость', { bpsNow: -1 }, true],
+  ['null', null, false],
+  ['неверная строка таблицы', { destinations: [null] }, true],
+  ['отрицательная серия', { rxSeries: [-1] }, true],
+] as const) {
+  test('Flow: повреждённый sample — ' + name, async ({ page }) => {
+    const control = await setup(page)
+    await page.getByRole("button", { name: "15м", exact: true }).click()
+    await expect(page.getByText("Категория 15m", { exact: true }).filter({ visible: true })).toBeVisible()
+    control.invalidSample = invalid
+    control.mergeSample = merge
+    await page.getByRole('button', { name: '5м', exact: true }).click()
+    await expect(page.getByText('Некорректные данные live-потока', { exact: true })).toBeVisible()
+    await expect(page.getByText('Последние данные · live недоступен', { exact: true }).filter({ visible: true })).toHaveCount(2)
+    await expect(page.getByLabel('Скорость потоков')).toContainText('1.00 Мбит/с')
+    await expect(page.getByText('live', { exact: true })).toHaveCount(0)
+  })
+}