"use client" import Link from "next/link" import { useCallback, useEffect, useMemo, useState } from "react" import { PageHeader } from "@/components/page-header" import { Badge } from "@/components/ui/badge" import { Button, buttonVariants } from "@/components/ui/button" import { Card, CardContent, CardDescription, CardHeader, CardTitle } from "@/components/ui/card" import { Alert, AlertDescription, AlertTitle } from "@/components/ui/alert" import { Collapsible, CollapsibleContent, CollapsibleTrigger, } from "@/components/ui/collapsible" import { Input } from "@/components/ui/input" import { Separator } from "@/components/ui/separator" import { useDataSource } from "@/lib/data-source" import { SCHEDULER_JOB_DESCRIPTIONS, SCHEDULER_JOB_KEYS, SCHEDULER_JOB_LABELS, type CollectorSettingsDto, type SchedulerJobStatusDto, type SchedulerRunRowDto, type UptimeSettingsDto, } from "@/lib/scheduler-settings" import { requestJson } from "@/shared/api/http-client" import { parseSchedulerRunSnapshot, type AlertEngineRuleDiagSnapshot, type AlertEngineRunSnapshot, type GreBgpSnapshotRunSnapshot, type InternetPathRunSnapshot, type PingRunSnapshot, type ResourcesRunSnapshot, type SchedulerRunSnapshot, type ServersRestPingRunSnapshot, type SpeedScheduledRunSnapshot, type TrafficRunSnapshot, } from "@/lib/scheduler-run-snapshot" import { cn } from "@/lib/utils" import { AlertCircleIcon, CalendarClockIcon, CheckCircleIcon, ChevronDownIcon, DatabaseIcon, LoaderCircleIcon, RefreshCwIcon, XCircleIcon, } from "lucide-react" function makeApiFetch(backendUrl: string) { return async function apiFetch(path: string, init?: RequestInit): Promise { return requestJson(backendUrl, path, init) } } function Toggle({ checked, onChange }: { checked: boolean; onChange: (v: boolean) => void }) { return ( ) } function fmtMs(ms: number): string { if (ms < 1000) return `${ms} мс` const s = ms / 1000 return s < 60 ? `${s.toFixed(1)} с` : `${Math.floor(s / 60)} м ${Math.round(s % 60)} с` } function fmtUptimeSec(sec: number): string { if (sec <= 0) return "—" const d = Math.floor(sec / 86400) const h = Math.floor((sec % 86400) / 3600) const m = Math.floor((sec % 3600) / 60) if (d > 0) return `${d}д ${h}ч` if (h > 0) return `${h}ч ${m}м` return `${m}м` } function SnapshotTables({ snap }: { snap: SchedulerRunSnapshot }) { if (snap.job === "traffic") { const t = snap as TrafficRunSnapshot return (
{t.skipped ? (

Прогон пропущен: предыдущий сбор трафика ещё выполнялся.

) : null} {t.fatalError ? ( Критическая ошибка: {t.fatalError} ) : null}

Сэмплы на момент {new Date(t.sampledAt).toLocaleString("ru-RU")}

{t.servers.map((s) => ( ))}
Сервер Хост Результат IF Σ RX Σ TX Ошибка
{s.name} {s.host} {s.ok ? ( ok ) : ( ошибка )} {s.interfaces ?? "—"} {s.sumRxMbps != null ? `${s.sumRxMbps} Мбит/с` : "—"} {s.sumTxMbps != null ? `${s.sumTxMbps} Мбит/с` : "—"} {s.error ?? "—"}
) } if (snap.job === "uptime_resources") { const u = snap as ResourcesRunSnapshot return (
{u.skipped ? (

Прогон пропущен: сбор ресурсов уже выполняется.

) : null} {u.fatalError ? ( Критическая ошибка: {u.fatalError} ) : null}

Сэмплы на {new Date(u.sampledAt).toLocaleString("ru-RU")}

{u.servers.map((s) => ( ))}
Сервер Статус CPU % Память % RAM Диск своб. Uptime Плата / ROS Ошибка
{s.name} {s.host} {s.status} {s.cpuLoadPct ?? "—"} {s.memUsedMb != null && s.memTotalMb != null ? `${s.memUsedMb} / ${s.memTotalMb} МБ` : "—"} {s.memUsedPct != null ? `${s.memUsedPct}%` : "—"} {s.diskFreeMb != null && s.diskTotalMb != null ? `${s.diskFreeMb} / ${s.diskTotalMb} МБ` : "—"} {s.uptimeSeconds != null ? fmtUptimeSec(s.uptimeSeconds) : "—"} {s.boardName || "—"} {s.rosVersion || ""} {s.error ?? "—"}
) } if (snap.job === "servers_rest_ping") { const s = snap as ServersRestPingRunSnapshot return (
{s.skipped ? (

Прогон пропущен: предыдущая проверка API ещё выполнялась.

) : null} {s.fatalError ? ( Критическая ошибка: {s.fatalError} ) : null}

GET /system/identity на{" "} {new Date(s.sampledAt).toLocaleString("ru-RU")}

{s.servers.map((row) => ( ))}
Сервер Хост Результат RTT REST Ошибка
{row.name} {row.host} {row.ok ? ( ok ) : ( недоступен )} {row.latencyMs != null ? `${row.latencyMs} мс` : "—"} {row.error ?? "—"}
) } if (snap.job === "uptime_ping") { const p = snap as PingRunSnapshot return (
{p.skipped ? (

Прогон пропущен: сбор ping уже выполняется.

) : null} {p.fatalError ? ( Критическая ошибка: {p.fatalError} ) : null} {p.skippedByInterval != null && p.skippedByInterval > 0 ? (

Пропущено по интервалу проб: {p.skippedByInterval}

) : null}

Сэмплы на {new Date(p.sampledAt).toLocaleString("ru-RU")} — только пробы, для которых записан замер в этом тике

{p.probes.map((x) => ( ))}
Проба Цель Источник IF RTT Loss Статус Ошибка
{x.name} {x.probeId} {x.target} {x.srcServerName} {x.srcInterface || "—"} {x.rttMs != null ? `${x.rttMs} мс` : "—"} {x.lossPct}% {x.status} {x.error ?? "—"}
) } if (snap.job === "uptime_speed") { const s = snap as SpeedScheduledRunSnapshot return (

Прогоны speed на {new Date(s.sampledAt).toLocaleString("ru-RU")} — по очереди для каждой включённой пробы

{s.runs.map((x) => ( ))}
Проба Маршрут Интерфейсы Протокол TX RX Ping RTT Loss Результат Ошибка
{x.probeId} {x.srcServerName} {x.dstServerName} {x.srcInterface || "—"} {x.dstInterface || "—"} {x.protocol} / {x.direction} / {x.durationSec}s {x.txAvgMbps != null ? `${Number(x.txAvgMbps).toFixed(1)}` : "—"} {x.rxAvgMbps != null ? `${Number(x.rxAvgMbps).toFixed(1)}` : "—"} {x.pingRttMs != null ? `${x.pingRttMs} мс` : "—"} {x.pingLossPct != null ? `${x.pingLossPct}%` : "—"} {x.ok ? ( ok ) : ( ошибка )} {x.error ?? ""} {x.pingError ? ( ping: {x.pingError} ) : null}
) } if (snap.job === "gre_bgp") { const g = snap as GreBgpSnapshotRunSnapshot return (
{g.skipped ? (

Прогон пропущен: предыдущий сбор GRE/BGP ещё выполнялся.

) : null} {g.fatalError ? ( Критическая ошибка: {g.fatalError} ) : null}

Запись в SQLite на{" "} {new Date(g.sampledAt).toLocaleString("ru-RU")} {" "}— строки GRE и BGP для движка оповещений.

Строк GRE
{g.greWritten}
Строк BGP
{g.bgpWritten}
{g.errors?.length ? (
{g.errors.map((e, i) => (

{e}

))}
) : null}
) } if (snap.job === "internet_path") { const p = snap as InternetPathRunSnapshot return (

Снимок internet-path на{" "} {new Date(p.sampledAt).toLocaleString("ru-RU")}

Home routers
{p.homes}
Сохранение snapshot
{p.snapshotSaved ? "ok" : "no"}
{p.fatalError ? ( Критическая ошибка: {p.fatalError} ) : null}
) } if (snap.job === "alert_engine") { const a = snap as AlertEngineRunSnapshot const transitionRu = (t: AlertEngineRuleDiagSnapshot["hitTransition"]) => { switch (t) { case "problem": return "проблема" case "recovery": return "восстановление" case "neutral": return "нейтрально" default: return "—" } } const blockedRu = (b: AlertEngineRuleDiagSnapshot["blocked"]) => { switch (b) { case "no_hit": return "условие не выполнено" case "stability": return "стабильность (confirmStabilitySec)" case "cooldown": return "cooldown" case "no_telegram": return "нет Telegram" case "dedupe_positive": return "дедуп восстановления" case "in_group": return "в группе (отдельно не шлём)" default: return "—" } } return (

Снимок на{" "} {new Date(a.sampledAt).toLocaleString("ru-RU")} . Данные для правил берутся из SQLite после джоб сбора (трафик, uptime, REST, GRE+BGP и т.д.).

Правил проверено
{a.rulesChecked}
Отправок (правила)
{a.standaloneFires}
Отправок (группы)
{a.groupFires}
Без Telegram
{a.skippedNoTelegram ? "да" : "нет"}
{a.errors?.length ? ( {a.errors.map((e, i) => (

{e}

))}
) : null} {a.ruleDiag && a.ruleDiag.length > 0 ? (

По правилам (почему не ушло в Telegram)

{a.ruleDiag.map((d) => ( ))}
ID правила Сработало Тип срабатывания Стабильность Кулдаун Telegram Сообщение Причина блока
{d.ruleId} {d.evalHit ? "Да" : "Нет"} {transitionRu(d.hitTransition)} {d.stabilityOk ? "Да" : "Нет"} {d.cooldownOk ? "Да" : "Нет"} {d.telegramOk ? "Да" : "Нет"} {d.hitMessage ?? "—"} {blockedRu(d.blocked)}
) : null}
) } return null } function RunRowDetail({ r }: { r: SchedulerRunRowDto }) { const jobTitle = SCHEDULER_JOB_LABELS[r.jobKey] ?? r.jobKey const jobDesc = SCHEDULER_JOB_DESCRIPTIONS[r.jobKey] ?? "—" const snapshot = useMemo(() => parseSchedulerRunSnapshot(r.resultJson ?? null), [r.resultJson]) return (
ID записи
{r.id}
Ключ задачи
{r.jobKey}
Название и назначение
{jobTitle}

{jobDesc}

Старт
{new Date(r.startedAt).toLocaleString("ru-RU")}
Завершение
{new Date(r.finishedAt).toLocaleString("ru-RU")}
Длительность
{r.durationMs} мс ({fmtMs(r.durationMs)})
Результат
{r.status}
{r.error ? (

Текст ошибки

            {r.error}
          
) : (

Ошибка не записывалась (статус ok).

)}

Результаты измерений

{snapshot ? ( ) : (

Снимок отсутствует (запись до обновления бекенда или задача без детализации).

)}
) } export default function DataCollectionPage() { const { mode, backendUrl } = useDataSource() const isLive = mode === "live" const apiFetch = useMemo(() => makeApiFetch(backendUrl), [backendUrl]) const [trafficCollector, setTrafficCollector] = useState(null) const [serversApiCollector, setServersApiCollector] = useState(null) const [uptimeCollector, setUptimeCollector] = useState(null) const [internetPathCollector, setInternetPathCollector] = useState(null) const [trafficIntervalDraft, setTrafficIntervalDraft] = useState("30") const [trafficRetentionDraft, setTrafficRetentionDraft] = useState("14") const [uptimeResourceIntervalDraft, setUptimeResourceIntervalDraft] = useState("300") const [uptimeIntervalDraft, setUptimeIntervalDraft] = useState("15") const [uptimeSpeedIntervalDraft, setUptimeSpeedIntervalDraft] = useState("60") const [uptimeRetentionDraft, setUptimeRetentionDraft] = useState("14") const [draftTrafficEnabled, setDraftTrafficEnabled] = useState(true) const [draftServersApiEnabled, setDraftServersApiEnabled] = useState(false) const [serversApiIntervalDraft, setServersApiIntervalDraft] = useState("120") const [draftResourcesEnabled, setDraftResourcesEnabled] = useState(true) const [draftPingEnabled, setDraftPingEnabled] = useState(true) const [draftSpeedEnabled, setDraftSpeedEnabled] = useState(true) const [draftInternetPathEnabled, setDraftInternetPathEnabled] = useState(true) const [internetPathIntervalDraft, setInternetPathIntervalDraft] = useState("300") const [schedulerRuns, setSchedulerRuns] = useState([]) const [runFilterJobKey, setRunFilterJobKey] = useState("") const [runNowJobKey, setRunNowJobKey] = useState(null) const [schedulerSaveBusy, setSchedulerSaveBusy] = useState(false) const [pageBusy, setPageBusy] = useState(false) const [collectorError, setCollectorError] = useState(null) const [openRunIds, setOpenRunIds] = useState>(() => new Set()) const toggleRunOpen = useCallback((id: string, open: boolean) => { setOpenRunIds((prev) => { const next = new Set(prev) if (open) next.add(id) else next.delete(id) return next }) }, []) const schedulerJobsByKey = useMemo(() => { const jobs = uptimeCollector?.scheduler?.jobs ?? [] return Object.fromEntries(jobs.map((j) => [j.jobKey, j])) as Record }, [uptimeCollector?.scheduler?.jobs]) const loadCollectors = useCallback(async () => { if (!isLive) return setCollectorError(null) setPageBusy(true) try { const runsQuery = runFilterJobKey && SCHEDULER_JOB_KEYS.includes(runFilterJobKey as (typeof SCHEDULER_JOB_KEYS)[number]) ? `?limit=80&jobKey=${encodeURIComponent(runFilterJobKey)}` : "?limit=80" const [traffic, serversApi, uptime, internetPath, runsRes] = await Promise.all([ apiFetch("/api/traffic/settings"), apiFetch("/api/servers-api-ping/settings"), apiFetch("/api/uptime/settings"), apiFetch("/api/internet-path/settings"), apiFetch<{ runs: SchedulerRunRowDto[] }>(`/api/scheduler/runs${runsQuery}`), ]) setTrafficCollector(traffic) setServersApiCollector(serversApi) setUptimeCollector(uptime) setInternetPathCollector(internetPath) setSchedulerRuns(runsRes.runs ?? []) setTrafficIntervalDraft(String(traffic.intervalSec)) setTrafficRetentionDraft(String(traffic.retentionDays)) setUptimeResourceIntervalDraft(String(uptime.intervalSec ?? 300)) setUptimeIntervalDraft(String(uptime.probeIntervalSec ?? 15)) setUptimeSpeedIntervalDraft(String(uptime.speedIntervalSec ?? 60)) setUptimeRetentionDraft(String(uptime.retentionDays)) setDraftTrafficEnabled(!!traffic.enabled) setDraftServersApiEnabled(!!serversApi.enabled) setServersApiIntervalDraft(String(serversApi.intervalSec ?? 120)) setDraftResourcesEnabled(!!(uptime.resourcesEnabled ?? uptime.enabled)) setDraftPingEnabled(!!(uptime.pingEnabled ?? uptime.enabled)) setDraftSpeedEnabled(!!(uptime.speedEnabled ?? uptime.enabled)) setDraftInternetPathEnabled(!!internetPath.enabled) setInternetPathIntervalDraft(String(internetPath.intervalSec ?? 300)) } catch (e) { setCollectorError(e instanceof Error ? e.message : "Не удалось загрузить данные") } finally { setPageBusy(false) } }, [apiFetch, isLive, runFilterJobKey]) useEffect(() => { if (!isLive) { setTrafficCollector(null) setServersApiCollector(null) setUptimeCollector(null) setInternetPathCollector(null) setSchedulerRuns([]) return } void loadCollectors() }, [isLive, loadCollectors]) useEffect(() => { setOpenRunIds(new Set()) }, [runFilterJobKey]) const handleRefreshScheduler = async () => { if (!isLive) return setCollectorError(null) try { await apiFetch("/api/scheduler/refresh", { method: "POST" }) await loadCollectors() } catch (e) { setCollectorError(e instanceof Error ? e.message : "Не удалось обновить планировщик") } } const enabledJobsCount = useMemo(() => { let n = draftTrafficEnabled ? 1 : 0 if (draftServersApiEnabled) n += 1 if (draftResourcesEnabled) n += 1 if (draftPingEnabled) n += 1 if (draftSpeedEnabled) n += 1 if (draftInternetPathEnabled) n += 1 return n }, [ draftInternetPathEnabled, draftPingEnabled, draftResourcesEnabled, draftServersApiEnabled, draftSpeedEnabled, draftTrafficEnabled, ]) const schedulerJobCount = SCHEDULER_JOB_KEYS.length const runningJobsCount = useMemo( () => (uptimeCollector?.scheduler?.jobs ?? []).filter((j) => j.running).length, [uptimeCollector?.scheduler?.jobs], ) const errorRunsInView = useMemo(() => schedulerRuns.filter((r) => r.status === "error").length, [schedulerRuns]) const stats = useMemo( () => [ { label: "Включено задач", value: `${enabledJobsCount} / ${schedulerJobCount}`, sub: "По переключателям на этой странице (до сохранения)", icon: , }, { label: "Сейчас выполняется", value: String(runningJobsCount), sub: "Фоновые прогоны планировщика", icon: , }, { label: "Трафик — последний сбор", value: trafficCollector?.lastCollectedAt ? new Date(trafficCollector.lastCollectedAt).toLocaleString("ru-RU", { hour: "2-digit", minute: "2-digit", day: "2-digit", month: "2-digit" }) : "—", sub: trafficCollector?.lastError ? trafficCollector.lastError : trafficCollector?.lastDurationMs != null ? `${trafficCollector.lastDurationMs} мс` : "нет данных", icon: trafficCollector?.lastError ? ( ) : ( ), }, { label: "Журнал (в списке)", value: String(schedulerRuns.length), sub: errorRunsInView ? `${errorRunsInView} с ошибкой` : "ошибок в показанных — нет", icon: , }, ], [ enabledJobsCount, schedulerJobCount, runningJobsCount, trafficCollector?.lastCollectedAt, trafficCollector?.lastDurationMs, trafficCollector?.lastError, schedulerRuns.length, errorRunsInView, ], ) return (
Настройки
} />
{!isLive && ( Нужен live-режим Планировщик и журнал читаются только с бекенда. Включите «Живые» данные и проверьте URL бекенда в настройках. Открыть настройки )} {isLive && collectorError && ( Ошибка загрузки статуса коллекторов {collectorError} )} {isLive && ( <>
{stats.map((s) => (

{s.label}

{s.value}

{s.sub}

{s.icon}
))}
Планировщик сбора данных Интервалы и вкл/выкл по задачам. Сохранение отправляет настройки на бекенд и перезапускает таймеры.
{SCHEDULER_JOB_KEYS.map((jobKey) => { const j = schedulerJobsByKey[jobKey] const fixedSchedule = jobKey === "gre_bgp" || jobKey === "alert_engine" const en = fixedSchedule ? Boolean(j?.enabled ?? true) : jobKey === "traffic" ? draftTrafficEnabled : jobKey === "servers_rest_ping" ? draftServersApiEnabled : jobKey === "uptime_resources" ? draftResourcesEnabled : jobKey === "uptime_ping" ? draftPingEnabled : jobKey === "uptime_speed" ? draftSpeedEnabled : draftInternetPathEnabled const iv = fixedSchedule ? String(j?.intervalSec ?? (jobKey === "gre_bgp" ? 30 : 20)) : jobKey === "traffic" ? trafficIntervalDraft : jobKey === "servers_rest_ping" ? serversApiIntervalDraft : jobKey === "uptime_resources" ? uptimeResourceIntervalDraft : jobKey === "uptime_ping" ? uptimeIntervalDraft : jobKey === "uptime_speed" ? uptimeSpeedIntervalDraft : internetPathIntervalDraft const setIv = fixedSchedule ? () => {} : jobKey === "traffic" ? setTrafficIntervalDraft : jobKey === "servers_rest_ping" ? setServersApiIntervalDraft : jobKey === "uptime_resources" ? setUptimeResourceIntervalDraft : jobKey === "uptime_ping" ? setUptimeIntervalDraft : jobKey === "uptime_speed" ? setUptimeSpeedIntervalDraft : setInternetPathIntervalDraft const defSec = fixedSchedule ? Number(j?.intervalSec ?? (jobKey === "gre_bgp" ? 30 : 20)) : jobKey === "traffic" ? 30 : jobKey === "servers_rest_ping" ? 120 : jobKey === "uptime_resources" ? 300 : jobKey === "uptime_ping" ? 15 : jobKey === "uptime_speed" ? 60 : 300 return ( ) })}
Задача Вкл Интервал (с) Последний прогон Статус Сейчас
{SCHEDULER_JOB_LABELS[jobKey] ?? jobKey}

{SCHEDULER_JOB_DESCRIPTIONS[jobKey]}

{jobKey}

{ if (fixedSchedule) return if (jobKey === "traffic") setDraftTrafficEnabled(v) else if (jobKey === "servers_rest_ping") setDraftServersApiEnabled(v) else if (jobKey === "uptime_resources") setDraftResourcesEnabled(v) else if (jobKey === "uptime_ping") setDraftPingEnabled(v) else if (jobKey === "uptime_speed") setDraftSpeedEnabled(v) else setDraftInternetPathEnabled(v) }} /> setIv(e.target.value)} className="h-8 text-sm tabular-nums" inputMode="numeric" readOnly={fixedSchedule} disabled={!en && !fixedSchedule} placeholder={String(defSec)} /> {j?.lastFinishedAt ? new Date(j.lastFinishedAt).toLocaleString("ru-RU") : "—"} {j?.lastDurationMs != null && ( {j.lastDurationMs} мс )}
{j?.running ? ( выполняется ) : null} {j?.lastStatus ? ( {j.lastStatus} ) : null} {j?.lastError ? ( {j.lastError} ) : null}

Хранение сэмплов трафика (дней)

setTrafficRetentionDraft(e.target.value)} className="h-8 text-sm" inputMode="numeric" />

Хранение сэмплов uptime (дней)

setUptimeRetentionDraft(e.target.value)} className="h-8 text-sm" inputMode="numeric" />

Для ping-проб у отдельных записей в мониторинге можно задать свой интервал (0 = глобальный «Интервал ping» в таблице).

Трафик — последний сбор:{" "} {trafficCollector?.lastCollectedAt ? new Date(trafficCollector.lastCollectedAt).toLocaleString("ru-RU") : "—"}{" "} · {trafficCollector?.lastDurationMs != null ? `${trafficCollector.lastDurationMs} мс` : "—"} {trafficCollector?.collectorRunning ? ( коллектор занят ) : null}

{trafficCollector?.lastError ? `Трафик: ${trafficCollector.lastError}` : "Трафик: ошибок нет"}

REST API (серверы):{" "} {serversApiCollector?.lastCollectedAt ? new Date(serversApiCollector.lastCollectedAt).toLocaleString("ru-RU") : "—"}{" "} · {serversApiCollector?.lastDurationMs != null ? `${serversApiCollector.lastDurationMs} мс` : "—"} {serversApiCollector?.collectorRunning ? ( проверка занята ) : null}

{serversApiCollector?.lastError ? `REST API (серверы): ${serversApiCollector.lastError}` : "REST API (серверы): ошибок нет"}

Uptime (агрегат в настройках):{" "} {uptimeCollector?.lastCollectedAt ? new Date(uptimeCollector.lastCollectedAt).toLocaleString("ru-RU") : "—"}{" "} · {uptimeCollector?.lastDurationMs != null ? `${uptimeCollector.lastDurationMs} мс` : "—"}

{uptimeCollector?.lastError ? `Uptime: ${uptimeCollector.lastError}` : "Uptime: ошибок нет"}

Internet Path snapshot:{" "} {internetPathCollector?.lastCollectedAt ? new Date(internetPathCollector.lastCollectedAt).toLocaleString("ru-RU") : "—"}{" "} · {internetPathCollector?.lastDurationMs != null ? `${internetPathCollector.lastDurationMs} мс` : "—"}

{internetPathCollector?.lastError ? `Internet Path: ${internetPathCollector.lastError}` : "Internet Path: ошибок нет"}

Журнал прогонов SQLite `scheduler_runs` — до 80 записей; раскройте строку для полей и текста ошибки.
{schedulerRuns.length === 0 ? (

Пока нет прогонов

) : (
{schedulerRuns.map((r) => ( toggleRunOpen(r.id, open)} >
{SCHEDULER_JOB_LABELS[r.jobKey] ?? r.jobKey} {r.jobKey}
{new Date(r.finishedAt).toLocaleString("ru-RU")}
{r.durationMs} мс {r.status}
))}
)}
)}
) }