feat(PingServicesScheduler): implement ping services scheduler endpoints and cache refresh logic for improved service monitoring

2026-02-22 20:40:57 +07:00
parent 4c7af43be7
commit 431314b973
4 changed files with 249 additions and 50 deletions
@@ -368,6 +368,88 @@ async function loadUiSettingsSync() {

 const PING_SERVICES_CACHE_KEY_PREFIX = 'ping-services/cache_';

+/**
+ * Обновить кеш пинг-сервисов: выполнить пинги по списку из настроек и записать результат в S3.
+ * Используется планировщиком и при промахе кеша в getPingServices.
+ * @returns {Promise<Record<string, { id: string, name: string, host: string, ms: number|null }>>} byId
+ */
+async function refreshPingServicesCache() {
+  const uiSettings = await loadUiSettingsSync();
+  const servicesList = getPingServicesListFromSettings(uiSettings);
+  const fallbackPayload = {};
+  servicesList.forEach((s) => { fallbackPayload[s.id] = { id: s.id, name: s.name, host: s.host, ms: null }; });
+
+  const viaRouter = String(uiSettings.pingServicesSource || 'web').toLowerCase() === 'router';
+  const cacheSeconds = Math.max(0, parseInt(uiSettings.pingServicesCacheSeconds, 10) || 0);
+
+  let serverId = null;
+  let gatewayIp = null;
+  if (viaRouter) {
+    const { readServersFromS3 } = require('./serversRoutes');
+    const servers = await readServersFromS3();
+    const routerServers = servers.filter(
+      (s) => s && (String(s.type || '').toLowerCase() === 'jumphost' || String(s.type || '').toLowerCase() === 'home')
+    );
+    serverId = (uiSettings.pingServicesServerId && String(uiSettings.pingServicesServerId).trim()) || (routerServers[0] && (routerServers[0].id || routerServers[0].dns || routerServers[0].ip));
+    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;
+
+  if (viaRouter) {
+    const { runPingViaRouter } = require('./mikrotikConfigRoutes');
+    const { readServersFromS3 } = require('./serversRoutes');
+    const servers = await readServersFromS3();
+    const routerServers = servers.filter(
+      (s) => s && (String(s.type || '').toLowerCase() === 'jumphost' || String(s.type || '').toLowerCase() === 'home')
+    );
+    let gatewayIpResolved = gatewayIp;
+    if (!gatewayIpResolved && serverId && routerServers.length > 0) {
+      const server = routerServers.find((s) => (s.id || s.dns || s.ip) === serverId) || routerServers[0];
+      const gateways = Array.isArray(server.gateways) ? server.gateways : [];
+      const primary = gateways.find((g) => g && g.primary) || gateways[0];
+      gatewayIpResolved = primary && (primary.ip || primary.remoteIp) ? (primary.ip || primary.remoteIp) : null;
+    }
+    if (!serverId) {
+      console.warn('[ping-services] router mode: no serverId (no jumphost/home in settings or in servers list)');
+      return fallbackPayload;
+    }
+    const results = await Promise.all(
+      servicesList.map(async (svc) => {
+        try {
+          const result = await runPingViaRouter(serverId, gatewayIpResolved || null, svc.host, 3);
+          const ms = typeof result.avgMs === 'number' ? Math.round(result.avgMs) : null;
+          return { id: svc.id, name: svc.name, host: svc.host, ms };
+        } catch (err) {
+          console.warn('[ping-services] runPingViaRouter failed for', svc.host, err?.message || err);
+          return { id: svc.id, name: svc.name, host: svc.host, ms: null };
+        }
+      })
+    );
+    const byId = {};
+    results.forEach((r) => { byId[r.id] = r; });
+    if (cacheKey) {
+      writeS3JsonObject(cacheKey, { byId, cachedAt: Date.now() }).catch((err) => console.warn('[ping-services] cache write failed:', err?.message));
+    }
+    return byId;
+  }
+
+  const results = await Promise.all(
+    servicesList.map(async (svc) => {
+      const ms = await measureTcpRtt(svc.host, svc.port, 6000);
+      return { id: svc.id, name: svc.name, host: svc.host, ms };
+    })
+  );
+  const byId = {};
+  results.forEach((r) => { byId[r.id] = r; });
+  if (cacheKey) {
+    writeS3JsonObject(cacheKey, { byId, cachedAt: Date.now() }).catch((err) => console.warn('[ping-services] cache write failed:', err?.message));
+  }
+  return byId;
+}
+
 // GET /api/ping-services-list — список сервисов для пинга из настроек (для дашборда и редактора)
 async function getPingServicesList(req, res) {
  try {
@@ -420,56 +502,8 @@ async function getPingServices(req, res) {
      } catch (_) {}
    }

-    if (viaRouter) {
-      const { runPingViaRouter } = require('./mikrotikConfigRoutes');
-      const { readServersFromS3 } = require('./serversRoutes');
-      const servers = await readServersFromS3();
-      const routerServers = servers.filter(
-        (s) => s && (String(s.type || '').toLowerCase() === 'jumphost' || String(s.type || '').toLowerCase() === 'home')
-      );
-      let gatewayIpResolved = gatewayIp;
-      if (!gatewayIpResolved && serverId && routerServers.length > 0) {
-        const server = routerServers.find((s) => (s.id || s.dns || s.ip) === serverId) || routerServers[0];
-        const gateways = Array.isArray(server.gateways) ? server.gateways : [];
-        const primary = gateways.find((g) => g && g.primary) || gateways[0];
-        gatewayIpResolved = primary && (primary.ip || primary.remoteIp) ? (primary.ip || primary.remoteIp) : null;
-      }
-      if (!serverId) {
-        console.warn('[ping-services] router mode: no serverId (no jumphost/home in settings or in servers list)');
-        return res.json(fallbackPayload);
-      }
-      const results = await Promise.all(
-        servicesList.map(async (svc) => {
-          try {
-            const result = await runPingViaRouter(serverId, gatewayIpResolved || null, svc.host, 3);
-            const ms = typeof result.avgMs === 'number' ? Math.round(result.avgMs) : null;
-            return { id: svc.id, name: svc.name, host: svc.host, ms };
-          } catch (err) {
-            console.warn('[ping-services] runPingViaRouter failed for', svc.host, err?.message || err);
-            return { id: svc.id, name: svc.name, host: svc.host, ms: null };
-          }
-        })
-      );
-      const byId = {};
-      results.forEach((r) => { byId[r.id] = r; });
-      if (cacheKey) {
-        writeS3JsonObject(cacheKey, { byId, cachedAt: Date.now() }).catch((err) => console.warn('[ping-services] cache write failed:', err?.message));
-      }
-      return res.json(byId);
-    }
-
-    const results = await Promise.all(
-      servicesList.map(async (svc) => {
-        const ms = await measureTcpRtt(svc.host, svc.port, 6000);
-        return { id: svc.id, name: svc.name, host: svc.host, ms };
-      })
-    );
-    const byId = {};
-    results.forEach((r) => { byId[r.id] = r; });
-    if (cacheKey) {
-      writeS3JsonObject(cacheKey, { byId, cachedAt: Date.now() }).catch((err) => console.warn('[ping-services] cache write failed:', err?.message));
-    }
-    res.json(byId);
+    const byId = await refreshPingServicesCache();
+    return res.json(byId);
  } catch (e) {
    console.error('ping-services error', e);
    const fallback = {};
@@ -695,5 +729,6 @@ module.exports = {
  postUiSettings,
  getPingServicesList,
  getPingServices,
+  refreshPingServicesCache,
 };