1// monitor.js — collecteur Écosystème Groupe KA2// Health checks HTTPS (45 s) + certificats TLS, sweep des nœuds (5 min :3// charge, RAM, disque, PM2, dernier commit), incidents, historique SQLite,4// push temps réel via le WebSocket du backend.5import https from 'node:https';6import path from 'node:path';7import { execFile } from 'node:child_process';8import { DatabaseSync } from 'node:sqlite';9import { getSites, getNodes, selfNode, sshTarget } from './registry.js';1011// Les sites surveillés et leurs nœuds viennent du REGISTRE mld (registry.js) —12// plus aucune table figée ici : une app déplacée par `mld move` est suivie13// automatiquement (health checks, sweep du bon nœud, actions pm2/launchd).14// Historique (pour mémoire, table figée du 2026-08-19, devenue fausse le 2026-09-04) :15const _SITES_LEGACY_2026_08 = [16 { app: 'lou-ka', label: 'Lou·Ka', domain: 'www.lou-ka.com', node: 'M3U96b', pm2: 'lou-ka-web', dir: '~/apps/lou-ka', deployed: '2026-08' },17 { app: 'immo-ka', label: 'Immo·Ka', domain: 'www.immo-ka.com', node: 'M4M64a', pm2: 'immo-ka-web', dir: '~/apps/immo-ka', deployed: '2026-08' },18 { app: 'house-ka', label: 'House·Ka', domain: 'www.house-ka.com', node: 'M4M64b', pm2: 'house-ka-web', dir: '~/apps/house-ka', deployed: '2026-08' },19 { app: 'rent-ka', label: 'Rent·Ka', domain: 'www.rent-ka.com', node: 'M4M36', pm2: 'rent-ka-web', dir: '~/apps/rent-ka', deployed: '2026-08' },20 { app: 'vrai-prix', label: 'Vrai-Prix', domain: 'www.vrai-prix.com', node: 'M3U96a', pm2: 'vrai-prix', dir: '~/apps/vrai-prix', deployed: '2026-08' },21 { app: 'valoplex', label: 'ValoPlex', domain: 'www.valoplex.com', node: 'M3U96a', pm2: 'valoplex', dir: '~/apps/valoplex', deployed: '2026-08' },22 { app: 'auto-ka', label: 'Auto·Ka', domain: 'www.auto-ka.com', node: 'M4M64b', pm2: 'auto-ka-web', dir: '~/auto-ka', deployed: '2026-08' },23 { app: 'fabri-ka', label: 'Fabri·Ka', domain: 'www.fabri-ka.com', node: 'M4M64a', pm2: 'fabri-ka-web', dir: '~/fabri-ka', deployed: '2026-08' },24 { app: 'food-ka', label: 'Food·Ka', domain: 'www.food-ka.com', node: 'M4M64b', pm2: 'food-ka-web', dir: '~/apps/food-ka', deployed: '2026-08' },25 { app: 'resto-ka', label: 'Resto·Ka', domain: 'www.resto-ka.com', node: 'M3U96b', pm2: 'resto-ka', dir: '~/apps/resto-ka', deployed: '2026-08' },26 { app: 'sorti-ka', label: 'Sorti·Ka', domain: 'www.sorti-ka.com', node: 'M3U96a', pm2: 'sorti-ka-web', dir: '~/apps/sorti-ka', deployed: '2026-08' },27 { app: 'crea-ka', label: 'Créa·Ka', domain: 'www.crea-ka.com', node: 'M3U96b', pm2: 'crea-ka-web', dir: '~/apps/crea-ka', deployed: '2026-08' },28 { app: 'job-ka', label: 'Job·Ka', domain: 'www.job-ka.com', node: 'M3U96a', pm2: 'job-ka-web', dir: '~/apps/job-ka', deployed: '2026-08' },29 { app: 'trouve-ka', label: 'Trouve·Ka', domain: 'www.trouve-ka.com', node: 'M2M32', pm2: 'tk-web', dir: '~/trouve-ka', deployed: '2026-08' },30 { app: 'groupe-ka', label: 'Groupe·Ka', domain: 'www.groupe-ka.com', node: 'M3U96b', pm2: 'groupe-ka', dir: '~/apps/groupe-ka', deployed: '2026-08' },31 { app: 'ka-stats', label: 'Ka·Stats', domain: 'www.ka-stats.com', node: 'M1M32', pm2: 'ka-stats', dir: '~/apps/ka-stats', deployed: '2026-08' },32 // Agents gardiens KA Guardian — un seul repo sur M4M36, process launchd (unit), pas de pm2 sur ce nœud33 { app: 'ka2', label: 'KA·2 Guardian', domain: 'www.ka2.bot', node: 'M4M36', unit: 'com.ka2.guardian', log: '~/cluster-projects/ka-guardian/logs/ka2.log', dir: '~/cluster-projects/ka-guardian', deployed: '2026-08' },34 { app: 'ka4', label: 'KA·4 Guardian', domain: 'www.ka4.bot', node: 'M4M36', unit: 'com.ka4.guardian', log: '~/cluster-projects/ka-guardian/logs/ka4.log', dir: '~/cluster-projects/ka-guardian', deployed: '2026-08' },35 { app: 'ka6', label: 'KA·6 Guardian', domain: 'www.ka6.bot', node: 'M4M36', unit: 'com.ka6.guardian', log: '~/cluster-projects/ka-guardian/logs/ka6.log', dir: '~/cluster-projects/ka-guardian', deployed: '2026-08' },36];3738void _SITES_LEGACY_2026_08; // conservé comme trace, jamais utilisé39const CHECK_MS = 45_000;40const SWEEP_MS = 5 * 60_000;41const SLOW_MS = 4000; // seuil "lent" (▲)42const FAILS_FOR_INCIDENT = 2; // échecs consécutifs avant incident4344let db, emit;45const consecFails = {};4647// ---------- logos des sites (favicon/apple-touch-icon, mis en cache) ----------48const ICONS = {}; // app -> { buf: Buffer, type: string }49const ICON_CANDIDATES = ['/apple-touch-icon.png', '/apple-touch-icon-precomposed.png', '/favicon.svg', '/icon.svg', '/favicon.png', '/favicon.ico'];50function fetchUrl(host, pathname) {51 return new Promise((resolve) => {52 const req = https.get({ host, path: pathname, timeout: 10_000, headers: { 'User-Agent': 'admin-ka-monitor/2.0' } }, (res) => {53 if (res.statusCode !== 200) { res.resume(); return resolve(null); }54 const ct = res.headers['content-type'] || '';55 if (!/image|svg/.test(ct)) { res.resume(); return resolve(null); }56 const chunks = [];57 let size = 0;58 res.on('data', (c) => { chunks.push(c); size += c.length; if (size > 500_000) { req.destroy(); resolve(null); } });59 res.on('end', () => resolve({ buf: Buffer.concat(chunks), type: ct.split(';')[0] }));60 });61 req.on('timeout', () => req.destroy());62 req.on('error', () => resolve(null));63 });64}65async function fetchIconFor(site) {66 // 1) essaie les chemins standards ; 2) sinon parse le HTML pour <link rel=icon>67 for (const cand of ICON_CANDIDATES) {68 const r = await fetchUrl(site.domain, cand);69 if (r) { ICONS[site.app] = r; return; }70 }71 const html = await new Promise((resolve) => {72 https.get({ host: site.domain, path: '/', timeout: 10_000, headers: { 'User-Agent': 'admin-ka-monitor/2.0' } }, (res) => {73 let d = ''; res.on('data', (c) => { d += c; if (d.length > 200_000) res.destroy(); }); res.on('end', () => resolve(d));74 }).on('error', () => resolve('')).on('timeout', function () { this.destroy(); resolve(''); });75 });76 const m = html.match(/<link[^>]+rel=["'][^"']*(?:apple-touch-icon|icon)[^"']*["'][^>]*href=["']([^"']+)["']/i)77 || html.match(/<link[^>]+href=["']([^"']+)["'][^>]*rel=["'][^"']*icon[^"']*["']/i);78 if (m) {79 let href = m[1];80 let pathname = href.startsWith('http') ? new URL(href).pathname : (href.startsWith('/') ? href : '/' + href);81 const r = await fetchUrl(site.domain, pathname);82 if (r) ICONS[site.app] = r;83 }84}85async function fetchAllIcons() {86 await Promise.all(getSites().map(s => fetchIconFor(s).catch(() => {})));87 emit({ type: 'eco', kind: 'icons', ts: Date.now() });88}89export function getIcon(app) { return ICONS[app] || null; }9091export function startMonitor({ dataDir, onEvent }) {92 emit = onEvent || (() => {});93 db = new DatabaseSync(path.join(dataDir, 'eco.sqlite'));94 db.exec(`95 CREATE TABLE IF NOT EXISTS checks(site TEXT, ts INTEGER, ms INTEGER, code INTEGER, ok INTEGER, err TEXT);96 CREATE INDEX IF NOT EXISTS idx_checks ON checks(site, ts);`);97 try { db.exec('ALTER TABLE checks ADD COLUMN bytes INTEGER DEFAULT 0'); } catch {}98 db.exec(`99 CREATE TABLE IF NOT EXISTS incidents(id INTEGER PRIMARY KEY AUTOINCREMENT, site TEXT, started INTEGER, ended INTEGER, reason TEXT);100 CREATE TABLE IF NOT EXISTS cert(site TEXT PRIMARY KEY, expires INTEGER, issuer TEXT, checked INTEGER);101 CREATE TABLE IF NOT EXISTS nodestats(node TEXT, ts INTEGER, load1 REAL, mem_used INTEGER, mem_total INTEGER, disk_pct INTEGER);102 CREATE INDEX IF NOT EXISTS idx_nodestats ON nodestats(node, ts);103 CREATE TABLE IF NOT EXISTS appstats(app TEXT, ts INTEGER, cpu REAL, mem INTEGER, status TEXT, restarts INTEGER, last_commit INTEGER);104 CREATE INDEX IF NOT EXISTS idx_appstats ON appstats(app, ts);105 `);106 checkAll();107 sweepNodes();108 fetchAllIcons();109 setInterval(checkAll, CHECK_MS);110 setInterval(sweepNodes, SWEEP_MS);111 setInterval(fetchAllIcons, 7 * 24 * 3600_000);112 setInterval(cleanup, 6 * 3600_000);113}114115// ---------- health checks ----------116function checkOne(site) {117 return new Promise((resolve) => {118 const t0 = Date.now();119 const req = https.get({ host: site.domain, path: '/', timeout: 12_000, headers: { 'User-Agent': 'admin-ka-monitor/2.0' } }, (res) => {120 const ms = Date.now() - t0; // ≈ TTFB (réponse reçue avant le corps)121 const cert = res.socket.getPeerCertificate?.();122 if (cert && cert.valid_to) {123 db.prepare('INSERT INTO cert(site,expires,issuer,checked) VALUES(?,?,?,?) ON CONFLICT(site) DO UPDATE SET expires=excluded.expires,issuer=excluded.issuer,checked=excluded.checked')124 .run(site.app, Date.parse(cert.valid_to), cert.issuer?.O || cert.issuer?.CN || '', Date.now());125 }126 const bytes = Number(res.headers['content-length'] || 0);127 res.resume();128 resolve({ site: site.app, ts: Date.now(), ms, code: res.statusCode, ok: res.statusCode >= 200 && res.statusCode < 400 ? 1 : 0, err: null, bytes });129 });130 req.on('timeout', () => { req.destroy(new Error('timeout')); });131 req.on('error', (e) => resolve({ site: site.app, ts: Date.now(), ms: Date.now() - t0, code: 0, ok: 0, err: e.message.slice(0, 120), bytes: 0 }));132 });133}134135async function checkAll() {136 const results = await Promise.all(getSites().map(checkOne));137 const ins = db.prepare('INSERT INTO checks(site,ts,ms,code,ok,err,bytes) VALUES(?,?,?,?,?,?,?)');138 for (const r of results) {139 ins.run(r.site, r.ts, r.ms, r.code, r.ok, r.err, r.bytes || 0);140 handleIncident(r);141 }142 emit({ type: 'eco', kind: 'checks', items: results });143}144145function handleIncident(r) {146 const open = db.prepare('SELECT id FROM incidents WHERE site=? AND ended IS NULL').get(r.site);147 if (!r.ok) {148 consecFails[r.site] = (consecFails[r.site] || 0) + 1;149 if (consecFails[r.site] >= FAILS_FOR_INCIDENT && !open) {150 db.prepare('INSERT INTO incidents(site,started,reason) VALUES(?,?,?)')151 .run(r.site, r.ts, r.err || `HTTP ${r.code}`);152 emit({ type: 'eco_alert', kind: 'down', site: r.site, reason: r.err || `HTTP ${r.code}`, ts: r.ts });153 }154 } else {155 consecFails[r.site] = 0;156 if (open) {157 db.prepare('UPDATE incidents SET ended=? WHERE id=?').run(r.ts, open.id);158 emit({ type: 'eco_alert', kind: 'up', site: r.site, ts: r.ts });159 }160 }161}162163// ---------- sweep des nœuds (charge, RAM, disque, PM2, dernier commit) ----------164function sweepNode(node) {165 return new Promise((resolve) => {166 const gitCmds = getSites().filter(s => s.node === node)167 .map(s => `echo "GIT ${s.app} $(git -C ${s.repoDir || s.dir} log -1 --format=%ct 2>/dev/null || echo 0)"`).join('; ');168 // sites sous launchd (KA Guardian) : PID + cpu/rss via ps169 const lchCmds = getSites().filter(s => s.node === node && s.unit)170 .map(s => `pid=$(launchctl list | awk '$3=="${s.unit}"{print $1}'); [ -z "$pid" ] && pid=-; echo "LCH ${s.app} $pid $(ps -o %cpu=,rss= -p $pid 2>/dev/null | tr -s ' ')"`).join('; ');171 const script = `export PATH=/opt/homebrew/bin:/usr/local/bin:$PATH172echo "LOAD $(sysctl -n vm.loadavg 2>/dev/null)"173echo "MEMTOTAL $(sysctl -n hw.memsize 2>/dev/null)"174echo "PAGESIZE $(sysctl -n hw.pagesize 2>/dev/null)"175vm_stat 2>/dev/null | egrep "active|wired|occupied" | tr -d '.'176echo "DISK $(df -k / | tail -1 | awk '{print $5}' | tr -d '%')"177echo "PM2JSON $(pm2 jlist 2>/dev/null | tail -1)"178${lchCmds}179${gitCmds}`;180 const local = node === selfNode();181 const args = local182 ? ['-c', script]183 : ['-o', 'BatchMode=yes', '-o', 'ConnectTimeout=12', sshTarget(node), script];184 const bin = local ? '/bin/bash' : 'ssh';185 execFile(bin, args, { timeout: 45_000, maxBuffer: 8 * 1024 * 1024, env: { ...process.env, PATH: '/opt/homebrew/bin:/usr/local/bin:/usr/bin:/bin:/usr/sbin:/sbin' } }, (err, stdout) => {186 if (err && !stdout) return resolve(null);187 try { parseSweep(node, stdout); } catch {}188 resolve(null);189 });190 });191}192193function parseSweep(node, out) {194 const ts = Date.now();195 const load = out.match(/^LOAD \{?\s*([\d.]+)/m);196 const memTotal = Number(out.match(/^MEMTOTAL (\d+)/m)?.[1] || 0);197 const pageSize = Number(out.match(/^PAGESIZE (\d+)/m)?.[1] || 16384);198 let pages = 0;199 for (const m of out.matchAll(/Pages (?:active|wired down|occupied by compressor):\s+(\d+)/g)) pages += Number(m[1]);200 const memUsed = pages * pageSize;201 const disk = Number(out.match(/^DISK (\d+)/m)?.[1] || 0);202 db.prepare('INSERT INTO nodestats(node,ts,load1,mem_used,mem_total,disk_pct) VALUES(?,?,?,?,?,?)')203 .run(node, ts, load ? Number(load[1]) : 0, memUsed, memTotal, disk);204205 const commits = {};206 for (const m of out.matchAll(/^GIT (\S+) (\d+)/gm)) commits[m[1]] = Number(m[2]) * 1000;207208 const pm2raw = out.match(/^PM2JSON (\[.*\])\s*$/m);209 let list = [];210 if (pm2raw) { try { list = JSON.parse(pm2raw[1]); } catch {} }211 // sites launchd : "LCH <app> <pid|-> [<%cpu> <rss Ko>]"212 const lch = {};213 for (const m of out.matchAll(/^LCH (\S+) (\S+) ?([\d.]+)? ?(\d+)?/gm)) {214 lch[m[1]] = { pid: m[2], cpu: Number(m[3] || 0), rss: Number(m[4] || 0) };215 }216 const ins = db.prepare('INSERT INTO appstats(app,ts,cpu,mem,status,restarts,last_commit) VALUES(?,?,?,?,?,?,?)');217 for (const site of getSites().filter(s => s.node === node)) {218 if (site.unit) {219 const l = lch[site.app];220 const up = l && l.pid !== '-' && /^\d+$/.test(l.pid);221 ins.run(site.app, ts, l ? l.cpu : 0, l ? l.rss * 1024 : 0,222 l ? (up ? 'online' : 'arrêté') : 'inconnu', 0, commits[site.app] || 0);223 } else if (pm2raw) {224 const p = list.find(x => x.name === site.pm2) || list.find(x => (x.name || '').startsWith(site.app));225 ins.run(site.app, ts,226 p ? (p.monit?.cpu ?? 0) : 0,227 p ? (p.monit?.memory ?? 0) : 0,228 p ? (p.pm2_env?.status || 'inconnu') : 'introuvable',229 p ? (p.pm2_env?.restart_time ?? 0) : 0,230 commits[site.app] || 0);231 } else {232 ins.run(site.app, ts, 0, 0, 'inconnu', 0, commits[site.app] || 0);233 }234 }235}236237async function sweepNodes() {238 await Promise.all(getNodes().map(sweepNode));239 emit({ type: 'eco', kind: 'sweep', ts: Date.now() });240}241242function cleanup() {243 const cut = Date.now() - 35 * 24 * 3600_000;244 db.prepare('DELETE FROM checks WHERE ts < ?').run(cut);245 db.prepare('DELETE FROM nodestats WHERE ts < ?').run(cut);246 db.prepare('DELETE FROM appstats WHERE ts < ?').run(cut);247}248249// ---------- requêtes ----------250function uptime(site, sinceMs) {251 const r = db.prepare('SELECT COUNT(*) n, SUM(ok) up FROM checks WHERE site=? AND ts>?').get(site, Date.now() - sinceMs);252 return r.n ? Math.round((r.up / r.n) * 1000) / 10 : null;253}254function pct(sorted, p) {255 if (!sorted.length) return null;256 return sorted[Math.min(sorted.length - 1, Math.floor(sorted.length * p))];257}258function p95(site, sinceMs) {259 const rows = db.prepare('SELECT ms FROM checks WHERE site=? AND ts>? AND ok=1 ORDER BY ms').all(site, Date.now() - sinceMs);260 return pct(rows.map(r => r.ms), 0.95);261}262// paquet de latence : min/p50/p90/p95/p99/max/avg sur une fenêtre263function latencyStats(site, sinceMs) {264 const rows = db.prepare('SELECT ms FROM checks WHERE site=? AND ts>? AND ok=1 ORDER BY ms').all(site, Date.now() - sinceMs).map(r => r.ms);265 if (!rows.length) return { min: null, p50: null, p90: null, p95: null, p99: null, max: null, avg: null, n: 0 };266 const sum = rows.reduce((a, b) => a + b, 0);267 return { min: rows[0], p50: pct(rows, 0.5), p90: pct(rows, 0.9), p95: pct(rows, 0.95), p99: pct(rows, 0.99), max: rows[rows.length - 1], avg: Math.round(sum / rows.length), n: rows.length };268}269// distribution des codes HTTP sur 24h270function statusDist(site, sinceMs) {271 const rows = db.prepare('SELECT code, COUNT(*) n FROM checks WHERE site=? AND ts>? GROUP BY code').all(site, Date.now() - sinceMs);272 const d = { '2xx': 0, '3xx': 0, '4xx': 0, '5xx': 0, err: 0 };273 for (const r of rows) {274 if (!r.code) d.err += r.n;275 else if (r.code < 300) d['2xx'] += r.n;276 else if (r.code < 400) d['3xx'] += r.n;277 else if (r.code < 500) d['4xx'] += r.n;278 else d['5xx'] += r.n;279 }280 return d;281}282// tendance latence : moyenne dernière heure vs 24h (pour flèche ↑/↓)283function latencyTrend(site) {284 const now = Date.now();285 const h = db.prepare('SELECT AVG(ms) a FROM checks WHERE site=? AND ok=1 AND ts>?').get(site, now - 3600_000)?.a;286 const d = db.prepare('SELECT AVG(ms) a FROM checks WHERE site=? AND ok=1 AND ts>?').get(site, now - 24 * 3600_000)?.a;287 if (!h || !d) return null;288 return Math.round((h - d) / d * 100); // % (négatif = plus rapide)289}290function checkCounts(site, sinceMs) {291 const r = db.prepare('SELECT COUNT(*) n, SUM(ok) up, AVG(bytes) b FROM checks WHERE site=? AND ts>?').get(site, Date.now() - sinceMs);292 return { total: r.n || 0, ok: r.up || 0, fail: (r.n || 0) - (r.up || 0), avgBytes: r.b ? Math.round(r.b) : 0 };293}294// incidents + MTTR (temps moyen de rétablissement) sur 30 j295function incidentStats(site) {296 const rows = db.prepare('SELECT started, ended FROM incidents WHERE site=? AND started>?').all(site, Date.now() - 30 * 24 * 3600_000);297 const closed = rows.filter(r => r.ended);298 const mttr = closed.length ? Math.round(closed.reduce((a, r) => a + (r.ended - r.started), 0) / closed.length / 60000) : null;299 const longest = rows.length ? Math.round(Math.max(...rows.map(r => (r.ended || Date.now()) - r.started)) / 60000) : 0;300 return { count30: rows.length, open: rows.some(r => !r.ended), mttrMin: mttr, longestMin: longest };301}302303export function ecoSummary() {304 const out = [];305 for (const s of getSites()) {306 const last = db.prepare('SELECT ts,ms,code,ok,err FROM checks WHERE site=? ORDER BY ts DESC LIMIT 1').get(s.app);307 const spark = db.prepare('SELECT ts,ms,ok FROM checks WHERE site=? ORDER BY ts DESC LIMIT 40').all(s.app).reverse();308 const avg = db.prepare('SELECT AVG(ms) a FROM checks WHERE site=? AND ok=1 AND ts>?').get(s.app, Date.now() - 24 * 3600_000);309 const cert = db.prepare('SELECT expires FROM cert WHERE site=?').get(s.app);310 const inc = db.prepare('SELECT started,reason FROM incidents WHERE site=? AND ended IS NULL').get(s.app);311 const stat = db.prepare('SELECT cpu,mem,status,restarts,last_commit,ts FROM appstats WHERE app=? ORDER BY ts DESC LIMIT 1').get(s.app);312 const nodeStat = db.prepare('SELECT load1,mem_used,mem_total,disk_pct,ts FROM nodestats WHERE node=? ORDER BY ts DESC LIMIT 1').get(s.node);313 const lat = latencyStats(s.app, 24 * 3600_000);314 const cnt = checkCounts(s.app, 24 * 3600_000);315 out.push({316 app: s.app, label: s.label, domain: s.domain, node: s.node,317 last, spark,318 uptime24: uptime(s.app, 24 * 3600_000),319 uptime7: uptime(s.app, 7 * 24 * 3600_000),320 uptime30: uptime(s.app, 30 * 24 * 3600_000),321 avg24: lat.avg,322 p50_24: lat.p50, p95_24: lat.p95, p99_24: lat.p99, min24: lat.min, max24: lat.max,323 checks24: cnt.total, fails24: cnt.fail, avgBytes24: cnt.avgBytes,324 trend: latencyTrend(s.app),325 status24: statusDist(s.app, 24 * 3600_000),326 incidents30: incidentStats(s.app),327 certExpires: cert?.expires || null,328 incident: inc || null,329 proc: stat || null,330 nodeStat: nodeStat || null,331 });332 }333 // agrégats globaux pour le command center334 const upNow = out.filter(x => x.last && x.last.ok).length;335 const okLat = out.filter(x => x.last?.ok).map(x => x.last.ms);336 const totalChecks = out.reduce((a, x) => a + (x.checks24 || 0), 0);337 const totalFails = out.reduce((a, x) => a + (x.fails24 || 0), 0);338 const upts = out.map(x => x.uptime24).filter(v => v != null);339 return {340 sites: out, ts: Date.now(),341 global: {342 up: upNow, total: out.length, down: out.length - upNow,343 avgLatency: okLat.length ? Math.round(okLat.reduce((a, b) => a + b, 0) / okLat.length) : 0,344 worstLatency: okLat.length ? Math.max(...okLat) : 0,345 uptime24: upts.length ? Math.round(upts.reduce((a, b) => a + b, 0) / upts.length * 10) / 10 : null,346 checks24: totalChecks, fails24: totalFails,347 openIncidents: out.filter(x => x.incident).length,348 },349 };350}351352export function ecoSite(app) {353 const s = getSites().find(x => x.app === app);354 if (!s) return null;355 const since = Date.now() - 24 * 3600_000;356 // ~200 seaux sur 24 h pour le graphique357 const bucket = Math.ceil((24 * 3600_000) / 200);358 const series = db.prepare(`359 SELECT (ts/${bucket})*${bucket} AS t, AVG(ms) ms, MIN(ok) ok, COUNT(*) n360 FROM checks WHERE site=? AND ts>? GROUP BY t ORDER BY t`).all(app, since);361 const incidents = db.prepare('SELECT started,ended,reason FROM incidents WHERE site=? AND started>? ORDER BY started DESC LIMIT 30')362 .all(app, Date.now() - 30 * 24 * 3600_000);363 const errors = db.prepare('SELECT ts,code,err,ms FROM checks WHERE site=? AND ok=0 ORDER BY ts DESC LIMIT 20').all(app);364 // uptime + latence quotidiens 14 jours365 const days = [];366 for (let i = 13; i >= 0; i--) {367 const d0 = new Date(); d0.setHours(0, 0, 0, 0);368 const start = d0.getTime() - i * 24 * 3600_000;369 const r = db.prepare('SELECT COUNT(*) n, SUM(ok) up, AVG(CASE WHEN ok=1 THEN ms END) a FROM checks WHERE site=? AND ts>=? AND ts<?').get(app, start, start + 24 * 3600_000);370 days.push({ day: start, uptime: r.n ? Math.round((r.up / r.n) * 1000) / 10 : null, avgMs: r.a ? Math.round(r.a) : null });371 }372 return {373 app, label: s.label, domain: s.domain, node: s.node, dir: s.dir,374 series, incidents, errors, days,375 lat24: latencyStats(app, 24 * 3600_000),376 lat7: latencyStats(app, 7 * 24 * 3600_000),377 status24: statusDist(app, 24 * 3600_000),378 counts24: checkCounts(app, 24 * 3600_000),379 counts7: checkCounts(app, 7 * 24 * 3600_000),380 incidentStats: incidentStats(app),381 trend: latencyTrend(app),382 };383}384385export function ecoIncidents() {386 return db.prepare(`SELECT site,started,ended,reason FROM incidents ORDER BY started DESC LIMIT 50`).all();387}388389export function ecoNodes() {390 const out = [];391 for (const node of getNodes()) {392 const last = db.prepare('SELECT ts,load1,mem_used,mem_total,disk_pct FROM nodestats WHERE node=? ORDER BY ts DESC LIMIT 1').get(node);393 const hist = db.prepare('SELECT ts,load1,mem_used,mem_total FROM nodestats WHERE node=? AND ts>? ORDER BY ts').all(node, Date.now() - 24 * 3600_000);394 const apps = getSites().filter(s => s.node === node).map(s => {395 const p = db.prepare('SELECT cpu,mem,status,restarts FROM appstats WHERE app=? ORDER BY ts DESC LIMIT 1').get(s.app);396 return { app: s.app, label: s.label, ...p };397 });398 out.push({ node, last: last || null, hist, apps });399 }400 return { nodes: out, ts: Date.now() };401}402