// monitor.js — collecteur Écosystème Groupe KA // Health checks HTTPS (45 s) + certificats TLS, sweep des nœuds (5 min : // charge, RAM, disque, PM2, dernier commit), incidents, historique SQLite, // push temps réel via le WebSocket du backend. import https from 'node:https'; import path from 'node:path'; import { execFile } from 'node:child_process'; import { DatabaseSync } from 'node:sqlite'; // Sites du Groupe KA (source : cluster-deployments.json 2026-08-19) export const SITES = [ { app: 'lou-ka', label: 'Lou·Ka', domain: 'www.lou-ka.com', node: 'M3U96b', pm2: 'lou-ka-web', dir: '~/apps/lou-ka', deployed: '2026-08' }, { app: 'immo-ka', label: 'Immo·Ka', domain: 'www.immo-ka.com', node: 'M4M64a', pm2: 'immo-ka-web', dir: '~/apps/immo-ka', deployed: '2026-08' }, { app: 'vrai-prix', label: 'Vrai-Prix', domain: 'www.vrai-prix.com', node: 'M3U96a', pm2: 'vrai-prix', dir: '~/apps/vrai-prix', deployed: '2026-08' }, { app: 'valoplex', label: 'ValoPlex', domain: 'www.valoplex.com', node: 'M3U96a', pm2: 'valoplex', dir: '~/apps/valoplex', deployed: '2026-08' }, { app: 'auto-ka', label: 'Auto·Ka', domain: 'www.auto-ka.com', node: 'M4M64b', pm2: 'auto-ka-web', dir: '~/auto-ka', deployed: '2026-08' }, { app: 'fabri-ka', label: 'Fabri·Ka', domain: 'www.fabri-ka.com', node: 'M4M64a', pm2: 'fabri-ka-web', dir: '~/fabri-ka', deployed: '2026-08' }, { app: 'food-ka', label: 'Food·Ka', domain: 'www.food-ka.com', node: 'M4M64b', pm2: 'food-ka-web', dir: '~/apps/food-ka', deployed: '2026-08' }, { app: 'resto-ka', label: 'Resto·Ka', domain: 'www.resto-ka.com', node: 'M3U96b', pm2: 'resto-ka', dir: '~/apps/resto-ka', deployed: '2026-08' }, { app: 'sorti-ka', label: 'Sorti·Ka', domain: 'www.sorti-ka.com', node: 'M3U96a', pm2: 'sorti-ka-web', dir: '~/apps/sorti-ka', deployed: '2026-08' }, { 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' }, { app: 'job-ka', label: 'Job·Ka', domain: 'www.job-ka.com', node: 'M3U96a', pm2: 'job-ka-web', dir: '~/apps/job-ka', deployed: '2026-08' }, { app: 'trouve-ka', label: 'Trouve·Ka', domain: 'www.trouve-ka.com', node: 'M2M32', pm2: 'tk-web', dir: '~/trouve-ka', deployed: '2026-08' }, { app: 'groupe-ka', label: 'Groupe·Ka', domain: 'www.groupe-ka.com', node: 'M3U96b', pm2: 'groupe-ka', dir: '~/apps/groupe-ka', deployed: '2026-08' }, ]; const NODES = ['M3U96a', 'M3U96b', 'M4M64a', 'M4M64b', 'M2M32']; const SELF_NODE = 'M3U96a'; const CHECK_MS = 45_000; const SWEEP_MS = 5 * 60_000; const SLOW_MS = 4000; // seuil "lent" (▲) const FAILS_FOR_INCIDENT = 2; // échecs consécutifs avant incident let db, emit; const consecFails = {}; export function startMonitor({ dataDir, onEvent }) { emit = onEvent || (() => {}); db = new DatabaseSync(path.join(dataDir, 'eco.sqlite')); db.exec(` CREATE TABLE IF NOT EXISTS checks(site TEXT, ts INTEGER, ms INTEGER, code INTEGER, ok INTEGER, err TEXT); CREATE INDEX IF NOT EXISTS idx_checks ON checks(site, ts); CREATE TABLE IF NOT EXISTS incidents(id INTEGER PRIMARY KEY AUTOINCREMENT, site TEXT, started INTEGER, ended INTEGER, reason TEXT); CREATE TABLE IF NOT EXISTS cert(site TEXT PRIMARY KEY, expires INTEGER, issuer TEXT, checked INTEGER); CREATE TABLE IF NOT EXISTS nodestats(node TEXT, ts INTEGER, load1 REAL, mem_used INTEGER, mem_total INTEGER, disk_pct INTEGER); CREATE INDEX IF NOT EXISTS idx_nodestats ON nodestats(node, ts); CREATE TABLE IF NOT EXISTS appstats(app TEXT, ts INTEGER, cpu REAL, mem INTEGER, status TEXT, restarts INTEGER, last_commit INTEGER); CREATE INDEX IF NOT EXISTS idx_appstats ON appstats(app, ts); `); checkAll(); sweepNodes(); setInterval(checkAll, CHECK_MS); setInterval(sweepNodes, SWEEP_MS); setInterval(cleanup, 6 * 3600_000); } // ---------- health checks ---------- function checkOne(site) { return new Promise((resolve) => { const t0 = Date.now(); const req = https.get({ host: site.domain, path: '/', timeout: 12_000, headers: { 'User-Agent': 'admin-ka-monitor/2.0' } }, (res) => { const ms = Date.now() - t0; const cert = res.socket.getPeerCertificate?.(); if (cert && cert.valid_to) { 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') .run(site.app, Date.parse(cert.valid_to), cert.issuer?.O || '', Date.now()); } res.resume(); resolve({ site: site.app, ts: Date.now(), ms, code: res.statusCode, ok: res.statusCode >= 200 && res.statusCode < 400 ? 1 : 0, err: null }); }); req.on('timeout', () => { req.destroy(new Error('timeout')); }); 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) })); }); } async function checkAll() { const results = await Promise.all(SITES.map(checkOne)); const ins = db.prepare('INSERT INTO checks(site,ts,ms,code,ok,err) VALUES(?,?,?,?,?,?)'); for (const r of results) { ins.run(r.site, r.ts, r.ms, r.code, r.ok, r.err); handleIncident(r); } emit({ type: 'eco', kind: 'checks', items: results }); } function handleIncident(r) { const open = db.prepare('SELECT id FROM incidents WHERE site=? AND ended IS NULL').get(r.site); if (!r.ok) { consecFails[r.site] = (consecFails[r.site] || 0) + 1; if (consecFails[r.site] >= FAILS_FOR_INCIDENT && !open) { db.prepare('INSERT INTO incidents(site,started,reason) VALUES(?,?,?)') .run(r.site, r.ts, r.err || `HTTP ${r.code}`); emit({ type: 'eco_alert', kind: 'down', site: r.site, reason: r.err || `HTTP ${r.code}`, ts: r.ts }); } } else { consecFails[r.site] = 0; if (open) { db.prepare('UPDATE incidents SET ended=? WHERE id=?').run(r.ts, open.id); emit({ type: 'eco_alert', kind: 'up', site: r.site, ts: r.ts }); } } } // ---------- sweep des nœuds (charge, RAM, disque, PM2, dernier commit) ---------- function sweepNode(node) { return new Promise((resolve) => { const gitCmds = SITES.filter(s => s.node === node) .map(s => `echo "GIT ${s.app} $(git -C ${s.dir} log -1 --format=%ct 2>/dev/null || echo 0)"`).join('; '); const script = `export PATH=/opt/homebrew/bin:/usr/local/bin:$PATH echo "LOAD $(sysctl -n vm.loadavg 2>/dev/null)" echo "MEMTOTAL $(sysctl -n hw.memsize 2>/dev/null)" echo "PAGESIZE $(sysctl -n hw.pagesize 2>/dev/null)" vm_stat 2>/dev/null | egrep "active|wired|occupied" | tr -d '.' echo "DISK $(df -k / | tail -1 | awk '{print $5}' | tr -d '%')" echo "PM2JSON $(pm2 jlist 2>/dev/null | tail -1)" ${gitCmds}`; const args = node === SELF_NODE ? ['-c', script] : ['-o', 'BatchMode=yes', '-o', 'ConnectTimeout=12', node, script]; const bin = node === SELF_NODE ? '/bin/bash' : 'ssh'; 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) => { if (err && !stdout) return resolve(null); try { parseSweep(node, stdout); } catch {} resolve(null); }); }); } function parseSweep(node, out) { const ts = Date.now(); const load = out.match(/^LOAD \{?\s*([\d.]+)/m); const memTotal = Number(out.match(/^MEMTOTAL (\d+)/m)?.[1] || 0); const pageSize = Number(out.match(/^PAGESIZE (\d+)/m)?.[1] || 16384); let pages = 0; for (const m of out.matchAll(/Pages (?:active|wired down|occupied by compressor):\s+(\d+)/g)) pages += Number(m[1]); const memUsed = pages * pageSize; const disk = Number(out.match(/^DISK (\d+)/m)?.[1] || 0); db.prepare('INSERT INTO nodestats(node,ts,load1,mem_used,mem_total,disk_pct) VALUES(?,?,?,?,?,?)') .run(node, ts, load ? Number(load[1]) : 0, memUsed, memTotal, disk); const commits = {}; for (const m of out.matchAll(/^GIT (\S+) (\d+)/gm)) commits[m[1]] = Number(m[2]) * 1000; const pm2raw = out.match(/^PM2JSON (\[.*\])\s*$/m); const ins = db.prepare('INSERT INTO appstats(app,ts,cpu,mem,status,restarts,last_commit) VALUES(?,?,?,?,?,?,?)'); if (pm2raw) { let list = []; try { list = JSON.parse(pm2raw[1]); } catch {} for (const site of SITES.filter(s => s.node === node)) { const p = list.find(x => x.name === site.pm2) || list.find(x => (x.name || '').startsWith(site.app)); ins.run(site.app, ts, p ? (p.monit?.cpu ?? 0) : 0, p ? (p.monit?.memory ?? 0) : 0, p ? (p.pm2_env?.status || 'inconnu') : 'introuvable', p ? (p.pm2_env?.restart_time ?? 0) : 0, commits[site.app] || 0); } } else { for (const site of SITES.filter(s => s.node === node)) { ins.run(site.app, ts, 0, 0, 'inconnu', 0, commits[site.app] || 0); } } } async function sweepNodes() { await Promise.all(NODES.map(sweepNode)); emit({ type: 'eco', kind: 'sweep', ts: Date.now() }); } function cleanup() { const cut = Date.now() - 35 * 24 * 3600_000; db.prepare('DELETE FROM checks WHERE ts < ?').run(cut); db.prepare('DELETE FROM nodestats WHERE ts < ?').run(cut); db.prepare('DELETE FROM appstats WHERE ts < ?').run(cut); } // ---------- requêtes ---------- function uptime(site, sinceMs) { const r = db.prepare('SELECT COUNT(*) n, SUM(ok) up FROM checks WHERE site=? AND ts>?').get(site, Date.now() - sinceMs); return r.n ? Math.round((r.up / r.n) * 1000) / 10 : null; } function p95(site, sinceMs) { const rows = db.prepare('SELECT ms FROM checks WHERE site=? AND ts>? AND ok=1 ORDER BY ms').all(site, Date.now() - sinceMs); if (!rows.length) return null; return rows[Math.min(rows.length - 1, Math.floor(rows.length * 0.95))].ms; } export function ecoSummary() { const out = []; for (const s of SITES) { const last = db.prepare('SELECT ts,ms,code,ok,err FROM checks WHERE site=? ORDER BY ts DESC LIMIT 1').get(s.app); const spark = db.prepare('SELECT ts,ms,ok FROM checks WHERE site=? ORDER BY ts DESC LIMIT 40').all(s.app).reverse(); 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); const cert = db.prepare('SELECT expires FROM cert WHERE site=?').get(s.app); const inc = db.prepare('SELECT started,reason FROM incidents WHERE site=? AND ended IS NULL').get(s.app); 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); 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); out.push({ app: s.app, label: s.label, domain: s.domain, node: s.node, last, spark, uptime24: uptime(s.app, 24 * 3600_000), uptime7: uptime(s.app, 7 * 24 * 3600_000), uptime30: uptime(s.app, 30 * 24 * 3600_000), avg24: avg?.a ? Math.round(avg.a) : null, p95_24: p95(s.app, 24 * 3600_000), certExpires: cert?.expires || null, incident: inc || null, proc: stat || null, nodeStat: nodeStat || null, }); } return { sites: out, ts: Date.now() }; } export function ecoSite(app) { const s = SITES.find(x => x.app === app); if (!s) return null; const since = Date.now() - 24 * 3600_000; // ~200 seaux sur 24 h pour le graphique const bucket = Math.ceil((24 * 3600_000) / 200); const series = db.prepare(` SELECT (ts/${bucket})*${bucket} AS t, AVG(ms) ms, MIN(ok) ok, COUNT(*) n FROM checks WHERE site=? AND ts>? GROUP BY t ORDER BY t`).all(app, since); const incidents = db.prepare('SELECT started,ended,reason FROM incidents WHERE site=? AND started>? ORDER BY started DESC LIMIT 30') .all(app, Date.now() - 30 * 24 * 3600_000); const errors = db.prepare('SELECT ts,code,err,ms FROM checks WHERE site=? AND ok=0 ORDER BY ts DESC LIMIT 20').all(app); // uptime quotidien 14 jours pour la barre const days = []; for (let i = 13; i >= 0; i--) { const d0 = new Date(); d0.setHours(0, 0, 0, 0); const start = d0.getTime() - i * 24 * 3600_000; const r = db.prepare('SELECT COUNT(*) n, SUM(ok) up FROM checks WHERE site=? AND ts>=? AND ts? ORDER BY ts').all(node, Date.now() - 24 * 3600_000); const apps = SITES.filter(s => s.node === node).map(s => { const p = db.prepare('SELECT cpu,mem,status,restarts FROM appstats WHERE app=? ORDER BY ts DESC LIMIT 1').get(s.app); return { app: s.app, label: s.label, ...p }; }); out.push({ node, last: last || null, hist, apps }); } return { nodes: out, ts: Date.now() }; }