feat(PingServices): implement history tracking for ping results and update API responses to include historical data

backend/routes/miscRoutes.js

@@ -367,6 +367,35 @@ async function loadUiSettingsSync() {
 }
 
 const PING_SERVICES_CACHE_KEY_PREFIX = 'ping-services/cache_';
+const PING_SERVICES_HISTORY_KEY_PREFIX = 'ping-services/history_';
+const PING_HISTORY_MAX = 30;
+
+function pingServicesStorageSuffix(viaRouter, serverId, gatewayIp) {
+  return (viaRouter ? 'router' : 'web') + '_' + String(serverId || '').replace(/[^a-zA-Z0-9.-]/g, '_') + '_' + String(gatewayIp || '').replace(/[^a-zA-Z0-9.]/g, '_');
+}
+
+/**
+ * Прочитать историю замеров пингов из S3. Формат: { byId: { [serviceId]: number[] } }.
+ */
+async function readPingServicesHistory(suffix) {
+  const key = PING_SERVICES_HISTORY_KEY_PREFIX + suffix;
+  try {
+    const raw = await readS3TextObject(key).catch(() => null);
+    if (!raw?.body) return {};
+    const parsed = JSON.parse(raw.body);
+    return parsed?.byId && typeof parsed.byId === 'object' ? parsed.byId : {};
+  } catch {
+    return {};
+  }
+}
+
+/**
+ * Записать историю замеров пингов в S3.
+ */
+async function writePingServicesHistory(suffix, byId) {
+  const key = PING_SERVICES_HISTORY_KEY_PREFIX + suffix;
+  await writeS3JsonObject(key, { byId }).catch((err) => console.warn('[ping-services] history write failed:', err?.message));
+}
 
 /**
  * Обновить кеш пинг-сервисов: выполнить пинги по списку из настроек и записать результат в S3.
@@ -394,9 +423,8 @@ async function refreshPingServicesCache() {
     gatewayIp = (uiSettings.pingServicesGatewayIp && String(uiSettings.pingServicesGatewayIp).trim()) || null;
   }
 
-  const cacheKey = cacheSeconds > 0
-    ? PING_SERVICES_CACHE_KEY_PREFIX + (viaRouter ? 'router' : 'web') + '_' + String(serverId || '').replace(/[^a-zA-Z0-9.-]/g, '_') + '_' + String(gatewayIp || '').replace(/[^a-zA-Z0-9.]/g, '_')
-    : null;
+  const suffix = pingServicesStorageSuffix(viaRouter, serverId, gatewayIp);
+  const cacheKey = cacheSeconds > 0 ? PING_SERVICES_CACHE_KEY_PREFIX + suffix : null;
 
   if (viaRouter) {
     const { runPingViaRouter } = require('./mikrotikConfigRoutes');
@@ -433,6 +461,14 @@ async function refreshPingServicesCache() {
     if (cacheKey) {
       writeS3JsonObject(cacheKey, { byId, cachedAt: Date.now() }).catch((err) => console.warn('[ping-services] cache write failed:', err?.message));
     }
+    const history = await readPingServicesHistory(suffix);
+    Object.keys(byId).forEach((id) => {
+      const ms = byId[id]?.ms;
+      if (typeof ms !== 'number') return;
+      const list = Array.isArray(history[id]) ? history[id] : [];
+      history[id] = [...list, ms].slice(-PING_HISTORY_MAX);
+    });
+    await writePingServicesHistory(suffix, history);
     return byId;
   }
 
@@ -447,6 +483,14 @@ async function refreshPingServicesCache() {
   if (cacheKey) {
     writeS3JsonObject(cacheKey, { byId, cachedAt: Date.now() }).catch((err) => console.warn('[ping-services] cache write failed:', err?.message));
   }
+  const history = await readPingServicesHistory(suffix);
+  Object.keys(byId).forEach((id) => {
+    const ms = byId[id]?.ms;
+    if (typeof ms !== 'number') return;
+    const list = Array.isArray(history[id]) ? history[id] : [];
+    history[id] = [...list, ms].slice(-PING_HISTORY_MAX);
+  });
+  await writePingServicesHistory(suffix, history);
   return byId;
 }
 
@@ -485,9 +529,8 @@ async function getPingServices(req, res) {
       gatewayIp = (uiSettings.pingServicesGatewayIp && String(uiSettings.pingServicesGatewayIp).trim()) || null;
     }
 
-    const cacheKey = cacheSeconds > 0
-      ? PING_SERVICES_CACHE_KEY_PREFIX + (viaRouter ? 'router' : 'web') + '_' + String(serverId || '').replace(/[^a-zA-Z0-9.-]/g, '_') + '_' + String(gatewayIp || '').replace(/[^a-zA-Z0-9.]/g, '_')
-      : null;
+    const suffix = pingServicesStorageSuffix(viaRouter, serverId, gatewayIp);
+    const cacheKey = cacheSeconds > 0 ? PING_SERVICES_CACHE_KEY_PREFIX + suffix : null;
     const skipCache = ['1', 'true', 'yes'].includes(String(req.query?.refresh || req.query?.nocache || '').toLowerCase());
     if (cacheKey && !skipCache) {
       try {
@@ -497,19 +540,21 @@ async function getPingServices(req, res) {
           const cachedAt = typeof cached.cachedAt === 'number' ? cached.cachedAt : 0;
           const ttlMs = cacheSeconds * 1000;
           if (cachedAt && Date.now() - cachedAt < ttlMs && cached.byId && typeof cached.byId === 'object') {
-            return res.json(cached.byId);
+            const history = await readPingServicesHistory(suffix);
+            return res.json({ byId: cached.byId, history });
           }
         }
       } catch (_) {}
     }
 
     const byId = await refreshPingServicesCache();
-    return res.json(byId);
+    const history = await readPingServicesHistory(suffix);
+    return res.json({ byId, history });
   } catch (e) {
     console.error('ping-services error', e);
     const fallback = {};
     PING_SERVICES_DEFAULT.forEach((s) => { fallback[s.id] = { id: s.id, name: s.name, host: s.host, ms: null }; });
-    res.status(500).json(fallback);
+    res.status(500).json({ byId: fallback, history: {} });
   }
 }