/** * Analytics Dashboard Module * Cross-mode summary, sparklines, alerts, correlations, geofence management, export. */ const Analytics = (function () { 'use strict'; let refreshTimer = null; function init() { refresh(); if (!refreshTimer) { refreshTimer = setInterval(refresh, 5000); } } function destroy() { if (refreshTimer) { clearInterval(refreshTimer); refreshTimer = null; } } function refresh() { Promise.all([ fetch('/analytics/summary').then(r => r.json()).catch(() => null), fetch('/analytics/activity').then(r => r.json()).catch(() => null), fetch('/analytics/insights').then(r => r.json()).catch(() => null), fetch('/analytics/patterns').then(r => r.json()).catch(() => null), fetch('/alerts/events?limit=20').then(r => r.json()).catch(() => null), fetch('/correlation').then(r => r.json()).catch(() => null), fetch('/analytics/geofences').then(r => r.json()).catch(() => null), ]).then(([summary, activity, insights, patterns, alerts, correlations, geofences]) => { if (summary) renderSummary(summary); if (activity) renderSparklines(activity.sparklines || {}); if (insights) renderInsights(insights); if (patterns) renderPatterns(patterns.patterns || []); if (alerts) renderAlerts(alerts.events || []); if (correlations) renderCorrelations(correlations); if (geofences) renderGeofences(geofences.zones || []); }); } function renderSummary(data) { const counts = data.counts || {}; _setText('analyticsCountAdsb', counts.adsb || 0); _setText('analyticsCountAis', counts.ais || 0); _setText('analyticsCountWifi', counts.wifi || 0); _setText('analyticsCountBt', counts.bluetooth || 0); _setText('analyticsCountDsc', counts.dsc || 0); _setText('analyticsCountAcars', counts.acars || 0); _setText('analyticsCountVdl2', counts.vdl2 || 0); _setText('analyticsCountAprs', counts.aprs || 0); _setText('analyticsCountMesh', counts.meshtastic || 0); // Health const health = data.health || {}; const container = document.getElementById('analyticsHealth'); if (container) { let html = ''; const modeLabels = { pager: 'Pager', sensor: '433MHz', adsb: 'ADS-B', ais: 'AIS', acars: 'ACARS', vdl2: 'VDL2', aprs: 'APRS', wifi: 'WiFi', bluetooth: 'BT', dsc: 'DSC' }; for (const [mode, info] of Object.entries(health)) { if (mode === 'sdr_devices') continue; const running = info && info.running; const label = modeLabels[mode] || mode; html += '
' + _esc(label) + '
'; } container.innerHTML = html; } // Squawks const squawks = data.squawks || []; const sqSection = document.getElementById('analyticsSquawkSection'); const sqList = document.getElementById('analyticsSquawkList'); if (sqSection && sqList) { if (squawks.length > 0) { sqSection.style.display = ''; sqList.innerHTML = squawks.map(s => '
' + _esc(s.squawk) + ' ' + _esc(s.meaning) + ' — ' + _esc(s.callsign || s.icao) + '
' ).join(''); } else { sqSection.style.display = 'none'; } } } function renderSparklines(sparklines) { const map = { adsb: 'analyticsSparkAdsb', ais: 'analyticsSparkAis', wifi: 'analyticsSparkWifi', bluetooth: 'analyticsSparkBt', dsc: 'analyticsSparkDsc', acars: 'analyticsSparkAcars', vdl2: 'analyticsSparkVdl2', aprs: 'analyticsSparkAprs', meshtastic: 'analyticsSparkMesh', }; for (const [mode, elId] of Object.entries(map)) { const el = document.getElementById(elId); if (!el) continue; const data = sparklines[mode] || []; if (data.length < 2) { el.innerHTML = ''; continue; } const max = Math.max(...data, 1); const w = 100; const h = 24; const step = w / (data.length - 1); const points = data.map((v, i) => (i * step).toFixed(1) + ',' + (h - (v / max) * (h - 2)).toFixed(1) ).join(' '); el.innerHTML = ''; } } function renderInsights(data) { const cards = data.cards || []; const topChanges = data.top_changes || []; const cardsEl = document.getElementById('analyticsInsights'); const changesEl = document.getElementById('analyticsTopChanges'); if (cardsEl) { if (!cards.length) { cardsEl.innerHTML = '
No insight data available
'; } else { cardsEl.innerHTML = cards.map(c => { const sev = _esc(c.severity || 'low'); const title = _esc(c.title || 'Insight'); const value = _esc(c.value || '--'); const label = _esc(c.label || ''); const detail = _esc(c.detail || ''); return '
' + '
' + title + '
' + '
' + value + '
' + '
' + label + '
' + '
' + detail + '
' + '
'; }).join(''); } } if (changesEl) { if (!topChanges.length) { changesEl.innerHTML = '
No change signals yet
'; } else { changesEl.innerHTML = topChanges.map(item => { const mode = _esc(item.mode_label || item.mode || ''); const deltaRaw = Number(item.delta || 0); const trendClass = deltaRaw > 0 ? 'up' : (deltaRaw < 0 ? 'down' : 'flat'); const delta = _esc(item.signed_delta || String(deltaRaw)); const recentAvg = _esc(item.recent_avg); const prevAvg = _esc(item.previous_avg); return '
' + '' + mode + '' + '' + delta + '' + 'avg ' + recentAvg + ' vs ' + prevAvg + '' + '
'; }).join(''); } } } function renderPatterns(patterns) { const container = document.getElementById('analyticsPatternList'); if (!container) return; if (!patterns || patterns.length === 0) { container.innerHTML = '
No recurring patterns detected
'; return; } const modeLabels = { adsb: 'ADS-B', ais: 'AIS', wifi: 'WiFi', bluetooth: 'Bluetooth', dsc: 'DSC', acars: 'ACARS', vdl2: 'VDL2', aprs: 'APRS', meshtastic: 'Meshtastic', }; const sorted = patterns .slice() .sort((a, b) => (b.confidence || 0) - (a.confidence || 0)) .slice(0, 20); container.innerHTML = sorted.map(p => { const confidencePct = Math.round((Number(p.confidence || 0)) * 100); const mode = modeLabels[p.mode] || (p.mode || '--').toUpperCase(); const period = _humanPeriod(Number(p.period_seconds || 0)); const occurrences = Number(p.occurrences || 0); const deviceId = _shortId(p.device_id || '--'); return '
' + '
' + '' + _esc(mode) + '' + '' + _esc(deviceId) + '' + '
' + '
' + 'Period: ' + _esc(period) + '' + 'Hits: ' + _esc(occurrences) + '' + '' + _esc(confidencePct) + '%' + '
' + '
'; }).join(''); } function renderAlerts(events) { const container = document.getElementById('analyticsAlertFeed'); if (!container) return; if (!events || events.length === 0) { container.innerHTML = '
No recent alerts
'; return; } container.innerHTML = events.slice(0, 20).map(e => { const sev = e.severity || 'medium'; const title = e.title || e.event_type || 'Alert'; const time = e.created_at ? new Date(e.created_at).toLocaleTimeString() : ''; return '
' + '' + _esc(sev) + '' + '' + _esc(title) + '' + '' + _esc(time) + '' + '
'; }).join(''); } function renderCorrelations(data) { const container = document.getElementById('analyticsCorrelations'); if (!container) return; const pairs = (data && data.correlations) || []; if (pairs.length === 0) { container.innerHTML = '
No correlations detected
'; return; } container.innerHTML = pairs.slice(0, 20).map(p => { const conf = Math.round((p.confidence || 0) * 100); return '
' + '' + _esc(p.wifi_mac || '') + '' + '' + '' + _esc(p.bt_mac || '') + '' + '
' + '' + conf + '%' + '
'; }).join(''); } function renderGeofences(zones) { const container = document.getElementById('analyticsGeofenceList'); if (!container) return; if (!zones || zones.length === 0) { container.innerHTML = '
No geofence zones defined
'; return; } container.innerHTML = zones.map(z => '
' + '' + _esc(z.name) + '' + '' + z.radius_m + 'm' + '' + '
' ).join(''); } function addGeofence() { const name = prompt('Zone name:'); if (!name) return; const lat = parseFloat(prompt('Latitude:', '0')); const lon = parseFloat(prompt('Longitude:', '0')); const radius = parseFloat(prompt('Radius (meters):', '1000')); if (isNaN(lat) || isNaN(lon) || isNaN(radius)) { alert('Invalid input'); return; } fetch('/analytics/geofences', { method: 'POST', headers: { 'Content-Type': 'application/json' }, body: JSON.stringify({ name, lat, lon, radius_m: radius }), }) .then(r => r.json()) .then(() => refresh()); } function deleteGeofence(id) { if (!confirm('Delete this geofence zone?')) return; fetch('/analytics/geofences/' + id, { method: 'DELETE' }) .then(r => r.json()) .then(() => refresh()); } function exportData(mode) { const m = mode || (document.getElementById('exportMode') || {}).value || 'adsb'; const f = (document.getElementById('exportFormat') || {}).value || 'json'; window.open('/analytics/export/' + encodeURIComponent(m) + '?format=' + encodeURIComponent(f), '_blank'); } // Helpers function _setText(id, val) { const el = document.getElementById(id); if (el) el.textContent = val; } function _esc(s) { if (typeof s !== 'string') s = String(s == null ? '' : s); return s.replace(/&/g, '&').replace(//g, '>').replace(/"/g, '"'); } function _shortId(value) { const text = String(value || ''); if (text.length <= 18) return text; return text.slice(0, 8) + '...' + text.slice(-6); } function _humanPeriod(seconds) { if (!isFinite(seconds) || seconds <= 0) return '--'; if (seconds < 60) return Math.round(seconds) + 's'; const mins = seconds / 60; if (mins < 60) return mins.toFixed(mins < 10 ? 1 : 0) + 'm'; const hours = mins / 60; return hours.toFixed(hours < 10 ? 1 : 0) + 'h'; } return { init, destroy, refresh, addGeofence, deleteGeofence, exportData }; })();