Compare commits
2
Commits
896f1ee3a7
...
6a90f4079d
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
6a90f4079d | ||
|
|
1651700609 |
@@ -3,8 +3,9 @@
|
||||
* Использует RouterOS REST API — требует RouterOS 7.1+ с www-ssl (443) или www (80)
|
||||
*/
|
||||
|
||||
const crypto = require('crypto');
|
||||
const { GetObjectCommand } = require('@aws-sdk/client-s3');
|
||||
const { s3, BUCKET_NAME, streamToString, readS3TextObject } = require('../services/s3Service');
|
||||
const { s3, BUCKET_NAME, streamToString, readS3TextObject, writeS3JsonObject } = require('../services/s3Service');
|
||||
const { sendError, sendOk } = require('../middleware/errorHandler');
|
||||
const { decrypt } = require('../utils/encryption');
|
||||
const { readServersFromS3 } = require('./serversRoutes');
|
||||
@@ -18,6 +19,25 @@ const { createRosClient, applyBlock } = require('../services/mikrotikApplyServic
|
||||
|
||||
const IPSEC_PASSWORDS_KEY = 'network-config/ipsec-passwords.json';
|
||||
const NETWORK_CONFIG_KEY = 'network-config.json';
|
||||
const UI_SETTINGS_KEY = 'bgp_data/rt_ui_settings.json';
|
||||
const PING_CACHE_PREFIX = 'ping-cache/';
|
||||
|
||||
/** Загрузить UI-настройки из S3 (для pingDomain, pingCacheMinutes и др.) */
|
||||
async function loadUiSettings() {
|
||||
try {
|
||||
const data = await readS3TextObject(UI_SETTINGS_KEY).catch(() => ({ body: '{}' }));
|
||||
const parsed = JSON.parse(data?.body || '{}');
|
||||
return parsed && typeof parsed === 'object' ? parsed : {};
|
||||
} catch (_) {
|
||||
return {};
|
||||
}
|
||||
}
|
||||
|
||||
/** Ключ кеша пинга по serverId, gatewayIp, target */
|
||||
function pingCacheKey(serverId, gatewayIp, target) {
|
||||
const payload = `${serverId}|${gatewayIp || ''}|${target || ''}`;
|
||||
return PING_CACHE_PREFIX + crypto.createHash('sha256').update(payload, 'utf8').digest('hex') + '.json';
|
||||
}
|
||||
|
||||
/** Загрузить network-config из S3 */
|
||||
async function loadNetworkConfig() {
|
||||
@@ -287,11 +307,11 @@ async function applyMikrotikConfig(req, res) {
|
||||
*/
|
||||
async function pingViaInterface(req, res) {
|
||||
try {
|
||||
const {
|
||||
let {
|
||||
serverId,
|
||||
gatewayIp,
|
||||
interfaceName,
|
||||
target = 'www.gstatic.com',
|
||||
target,
|
||||
count = 5,
|
||||
} = req.body || {};
|
||||
|
||||
@@ -299,6 +319,41 @@ async function pingViaInterface(req, res) {
|
||||
return sendError(res, 400, 'serverId is required', 'E_BAD_REQUEST');
|
||||
}
|
||||
|
||||
const uiSettings = await loadUiSettings();
|
||||
|
||||
// Цель пинга: из тела запроса, иначе из настроек (Домен для пинга), иначе по умолчанию
|
||||
if (target == null || String(target).trim() === '') {
|
||||
const pingDomain = (uiSettings.pingDomain && String(uiSettings.pingDomain).trim()) || '';
|
||||
target = pingDomain || 'www.gstatic.com';
|
||||
} else {
|
||||
target = String(target).trim();
|
||||
}
|
||||
|
||||
const pingCacheMinutes = Math.max(0, parseInt(uiSettings.pingCacheMinutes, 10) || 0);
|
||||
const cacheKey = pingCacheMinutes > 0 ? pingCacheKey(serverId, gatewayIp, target) : null;
|
||||
|
||||
if (cacheKey) {
|
||||
try {
|
||||
const data = await readS3TextObject(cacheKey).catch(() => null);
|
||||
if (data?.body) {
|
||||
const cached = JSON.parse(data.body);
|
||||
const cachedAt = typeof cached.cachedAt === 'number' ? cached.cachedAt : 0;
|
||||
const ttlMs = pingCacheMinutes * 60 * 1000;
|
||||
if (cachedAt && Date.now() - cachedAt < ttlMs) {
|
||||
return res.json({
|
||||
ok: true,
|
||||
avgMs: cached.avgMs,
|
||||
minMs: cached.minMs,
|
||||
maxMs: cached.maxMs,
|
||||
loss: cached.loss,
|
||||
});
|
||||
}
|
||||
}
|
||||
} catch (_) {
|
||||
// кеш протух или невалиден — выполняем реальный пинг
|
||||
}
|
||||
}
|
||||
|
||||
const servers = await readServersFromS3();
|
||||
const server = servers.find((s) => (s.id || s.dns || s.ip) === serverId);
|
||||
if (!server || server.type !== 'jumphost') {
|
||||
@@ -465,15 +520,19 @@ async function pingViaInterface(req, res) {
|
||||
? Number(String(summary['packet-loss']).replace('%', ''))
|
||||
: null;
|
||||
|
||||
// ВАЖНО: возвращаем данные напрямую, без sendOk,
|
||||
// чтобы фронтенд (EasySwitch) мог читать поля avgMs/minMs/maxMs/loss
|
||||
return res.json({
|
||||
ok: true,
|
||||
avgMs,
|
||||
minMs,
|
||||
maxMs,
|
||||
loss,
|
||||
});
|
||||
const result = { ok: true, avgMs, minMs, maxMs, loss };
|
||||
|
||||
if (cacheKey) {
|
||||
writeS3JsonObject(cacheKey, {
|
||||
avgMs,
|
||||
minMs,
|
||||
maxMs,
|
||||
loss,
|
||||
cachedAt: Date.now(),
|
||||
}).catch((err) => console.warn('[mikrotik][pingViaInterface] cache write failed:', err?.message));
|
||||
}
|
||||
|
||||
return res.json(result);
|
||||
} catch (error) {
|
||||
const msg = error.response?.data?.message || error.message || 'Ping failed';
|
||||
const status = error.response?.status;
|
||||
|
||||
@@ -256,7 +256,7 @@ function EasySwitchManager() {
|
||||
|
||||
/**
|
||||
* Загрузить реальные пинги для комбинаций (сервер, gateway).
|
||||
* Пингуем хост www.gstatic.com через соответствующий MikroTik jumphost.
|
||||
* Цель пинга берётся из настроек интерфейса («Домен для пинга») или по умолчанию.
|
||||
*/
|
||||
const prefetchPings = async (serversList, inventory) => {
|
||||
try {
|
||||
@@ -291,7 +291,6 @@ function EasySwitchManager() {
|
||||
.post('/mikrotik/ping', {
|
||||
serverId: routerId,
|
||||
gatewayIp: ip,
|
||||
target: 'www.gstatic.com',
|
||||
count: 5,
|
||||
})
|
||||
.then(({ data }) => {
|
||||
|
||||
@@ -18,6 +18,8 @@ export default function SettingsModal({ open, onClose }) {
|
||||
const [dohServer, setDohServer] = useState('');
|
||||
const [wsUrl, setWsUrl] = useState('');
|
||||
const [baseAS, setBaseAS] = useState('65001');
|
||||
const [pingDomain, setPingDomain] = useState('');
|
||||
const [pingCacheMinutes, setPingCacheMinutes] = useState('');
|
||||
const [ptrZoneReplaceFrom, setPtrZoneReplaceFrom] = useState('');
|
||||
const [ptrZoneReplaceTo, setPtrZoneReplaceTo] = useState('');
|
||||
|
||||
@@ -35,6 +37,8 @@ export default function SettingsModal({ open, onClose }) {
|
||||
setDohServer(String(data?.dohServer || ''));
|
||||
setWsUrl(String(data?.wsUpdateUrl || ''));
|
||||
setBaseAS(String(data?.baseAS || '65001'));
|
||||
setPingDomain(String(data?.pingDomain || '').trim());
|
||||
setPingCacheMinutes(data?.pingCacheMinutes != null ? String(data.pingCacheMinutes) : '');
|
||||
setPtrZoneReplaceFrom(String(data?.ptrZoneReplaceFrom || ''));
|
||||
setPtrZoneReplaceTo(String(data?.ptrZoneReplaceTo || ''));
|
||||
const e = res?.headers?.etag || res?.headers?.ETag || '';
|
||||
@@ -97,6 +101,8 @@ export default function SettingsModal({ open, onClose }) {
|
||||
dohServer: String(dohServer || '').trim(),
|
||||
wsUpdateUrl: String(wsUrl || '').trim(),
|
||||
baseAS: String(baseAS || '65001').trim(),
|
||||
pingDomain: String(pingDomain || '').trim(),
|
||||
pingCacheMinutes: Math.max(0, parseInt(pingCacheMinutes, 10) || 0),
|
||||
ptrZoneReplaceFrom: String(ptrZoneReplaceFrom || '').trim(),
|
||||
ptrZoneReplaceTo: String(ptrZoneReplaceTo || '').trim(),
|
||||
};
|
||||
@@ -198,6 +204,29 @@ export default function SettingsModal({ open, onClose }) {
|
||||
disabled={loading || saving}
|
||||
/>
|
||||
|
||||
<FormField
|
||||
label="Домен для пинга"
|
||||
name="pingDomain"
|
||||
type="text"
|
||||
value={pingDomain}
|
||||
onChange={setPingDomain}
|
||||
placeholder="8.8.8.8 или ya.ru"
|
||||
helpText="Домен или IP для проверки пинга через MikroTik (например, 8.8.8.8, ya.ru). Если не задан, используется значение по умолчанию."
|
||||
disabled={loading || saving}
|
||||
/>
|
||||
|
||||
<FormField
|
||||
label="Срок кеша пинга (мин)"
|
||||
name="pingCacheMinutes"
|
||||
type="number"
|
||||
value={pingCacheMinutes}
|
||||
onChange={setPingCacheMinutes}
|
||||
placeholder="0"
|
||||
helpText="0 — без кеша. При значении больше 0 результаты пинга кешируются в S3 на указанное количество минут."
|
||||
disabled={loading || saving}
|
||||
min={0}
|
||||
/>
|
||||
|
||||
<div className="mt-4 pt-3 border-top">
|
||||
<h6 className="mb-3">Настройка PTR зоны</h6>
|
||||
<div className="row g-3">
|
||||
|
||||
Reference in New Issue
Block a user