From f84997128c2738852c7a19936459ac039280e31d Mon Sep 17 00:00:00 2001
From: ohwenyi <wenyi2858@gmail.com>
Date: Tue, 31 Mar 2026 23:58:12 +1100
Subject: [PATCH 1/2] Connect sensor dashboard to live MQTT payload

---
 .../HMI/ui/public/admin/sensor-health.html    | 204 +++++-----
 .../ui/public/admin/sensor_health/script.js   | 253 +++++++------
 src/Components/HMI/ui/routes/map.routes.js    | 354 ++++++++++++------
 3 files changed, 487 insertions(+), 324 deletions(-)

diff --git a/src/Components/HMI/ui/public/admin/sensor-health.html b/src/Components/HMI/ui/public/admin/sensor-health.html
index a98f161eb..8fdc55cd4 100644
--- a/src/Components/HMI/ui/public/admin/sensor-health.html
+++ b/src/Components/HMI/ui/public/admin/sensor-health.html
@@ -22,138 +22,122 @@
       <div class="container-fluid">
         <div class="sensor-page">
 
-
+  
   <!-- Mobile backdrop -->
   <div class="mobile-backdrop" id="mobile-backdrop"></div>
 
   <!-- MAIN -->
   <main class="main">
     <header class="page-header">
-      <div></div>
-      <div class="page-header-actions">
+      <div>
+        <h1 style="margin-bottom: 4px;">Sensor Health</h1>
+          <p class="card-subtitle" style="margin-bottom: 0;">
+            Monitor live device health, system performance, GPS location, and recent audio activity from the IoT stream.
+          </p>
       </div>
+      <div class="page-header-actions"></div>
     </header>
 
     <!-- Content root (views load here) -->
-    <div id="view-root">
+     <div id="view-root">
       <div class="dashboard-shell">
 
-      <!-- HERO HEADER -->
-      <section class="hero-header">
-        <h1>Project echo</h1>
-        <p class="subtitle">wildlife sound monitoring & sensor management</p>
-
-        <div class="hero-actions">
-          <button class="btn-primary">View Projects</button>
-          <button class="btn-secondary">Learn More</button>
-        </div>
-      </section>
-
-
-
-      <!-- KPI CARDS -->
-      <section class="kpi-grid">
-        <div class="kpi-card">
-          <p>ACTIVE PROJECTS</p>
-          <h3>7</h3>
-        </div>
-
-        <div class="kpi-card">
-          <p>REGISTERED ECOLOGISTS</p>
-          <h3>69</h3>
-        </div>
-
-        <div class="kpi-card">
-          <p>SENSORS DEPLOYED</p>
-          <h3>420</h3>
-        </div>
-      </section>
-
-
-
-      <!-- PROJECT HIGHLIGHTS -->
-      <section class="card">
-        <h3>Active Projects</h3>
-        <p class="card-subtitle">Overview of ongoing conservation deployments</p>
-
-        <div class="form-grid">
-
-          <div class="card">
-            <h3>Rainforest A</h3>
-            <p class="note">
-              Amazon Basin — Zone A1<br>
-              32 active sensors
-            </p>
-            <span class="pill pill-success">ACTIVE</span>
+        <!-- Summary cards -->
+         <section class="kpi-grid">
+          <div class="kpi-card">
+            <p>SENSOR MONITORING</p>
+            <h3>Live</h3>
           </div>
-
-          <div class="card">
-            <h3>Savannah Trial</h3>
-            <p class="note">
-              Serengeti — West Ridge<br>
-              18 active sensors
-            </p>
-            <span class="pill pill-success">ACTIVE</span>
+          
+          <div class="kpi-card">
+            <p>DATA SOURCE</p>
+             <h3>MQTT</h3>
           </div>
-
-          <div class="card">
-            <h3>Wetlands 2025</h3>
-            <p class="note">
-              New Plymouth — Zone Delta<br>
-              12 sensors in queue
-            </p>
-            <span class="pill pill-warning">PLANNING</span>
+          
+          <div class="kpi-card">
+            <p>AUTO REFRESH</p>
+            <h3>15s</h3>
           </div>
+        </section>
 
-        </div>
-      </section>
-
-
-
-      <!-- FOOTER COLUMNS -->
-      <section class="footer-columns">
-
-        <div>
-          <h4>Wildlife Sound Monitor</h4>
-          <ul>
-            <li>Automated biodiversity tracking</li>
-            <li>24/7 acoustic scanning</li>
-            <li>Data-driven conservation</li>
-          </ul>
-        </div>
 
-        <div>
-          <h4>Quick Links</h4>
-          <ul>
-            <li>Home</li>
-            <li>Projects</li>
-            <li>Deployment Guide</li>
-            <li>Documentation</li>
-          </ul>
-        </div>
-
-        <div>
-          <h4>Resources</h4>
-          <ul>
-            <li>API Reference</li>
-            <li>Support</li>
-            <li>Terms</li>
-            <li>Privacy Policy</li>
-          </ul>
-        </div>
-
-      </section>
-
-    </div><!-- END dashboard-shell -->
-    </div> <!-- END dashboard-shell -->
-        </div>
-      <div id="footer"></div>
+        <!-- Sensor overview table -->
+         <section class="card">
+          <h3>Sensor Overview</h3>
+            <p class="card-subtitle">
+              This table displays the latest live sensor information received from the MQTT broker.
+            </p>
+          
+          <div class="form-grid" style="margin-bottom: 16px;">
+            <div>
+              <label for="sensor-status-filter">Filter by Status</label>
+              <select id="sensor-status-filter">
+                <option>All</option>
+                <option>Online</option>
+                <option>Offline</option>
+                <option>Warning</option>
+              </select>
+            </div>
+          
+            </div>
+              <div class="table-responsive">
+                <table class="table">
+                  <thead>
+                    <tr>
+                      <th>Sensor ID</th>
+                      <th>Status</th>
+                      <th>CPU</th>
+                      <th>RAM</th>
+                      <th>Disk</th>
+                      <th>Uptime</th>
+                      <th>GPS</th>
+                      <th>Last Audio</th>
+                    </tr>
+                  </thead>
+                  <tbody id="sensor-overview-tbody">
+                    <tr>
+                      <td colspan="8">Loading sensor data...</td>
+                    </tr>
+                  </tbody>
+                </table>
+              </div>
+            </section>
+            
+            <section class="card">
+              <h3>Live Data Notes</h3>
+              <p class="card-subtitle">
+                The current dashboard is connected to real-time MQTT-fed sensor data supplied by the IoT team.
+              </p>
+              
+              <div class="form-grid">
+                <div class="card">
+                  <h3>Current Available Fields</h3>
+                  <p class="note">
+                    The live payload currently includes CPU usage, RAM usage, disk usage, uptime, GPS coordinates, and the most recent saved audio file.
+                  </p>
+                </div>
+                
+                <div class="card">
+                  <h3>Future Extensions</h3>
+                  <p class="note">
+                    Additional sensor fields such as ambient light, temperature, battery, connectivity, or other health indicators can be added later as the IoT pipeline expands.
+                  </p>
+                </div>
+              </div>
+            </section>
+            </div>
+          </div>
+        </main>
+      </div>
     </div>
+
+    <div id="footer"></div>
   </div>
+</div>
 
   <script>
     $(document).ready(function() {
-      $("#sidebar").load("/admin/component/sidebar-component.html", function() { $.getScript('/admin/js/sidebarmenu.js'); });
+      $("#sidebar").load("/admin/component/sidebar-component.html", function() {$.getScript('/admin/js/sidebarmenu.js');});
       $("#header").load("/admin/component/header-component.html");
       $("#footer").load("/admin/component/footer-component.html");
     });
diff --git a/src/Components/HMI/ui/public/admin/sensor_health/script.js b/src/Components/HMI/ui/public/admin/sensor_health/script.js
index 3bd65c53d..1688a2437 100644
--- a/src/Components/HMI/ui/public/admin/sensor_health/script.js
+++ b/src/Components/HMI/ui/public/admin/sensor_health/script.js
@@ -1,5 +1,5 @@
-/* Project Echo — moved sensor health script.js (copied)
-   Handles sidebar toggle, theme, fake actions and UI helpers
+/* Project Echo — Sensor Health script.js
+   Handles sidebar toggle, theme, actions and live sensor UI helpers
 */
 
 const menuToggle = document.getElementById("menu-toggle");
@@ -42,7 +42,7 @@ if (themeToggle) {
 function showMessage(elementId, message, type = "success") {
   const el = document.getElementById(elementId);
   if (!el) return;
-  const colors = { success: "var(--primary)", warning: "var(--warning)", danger: "var(--danger)" };
+  const colors = {success: "var(--primary)", warning: "var(--warning)", danger: "var(--danger)"};
   el.style.color = colors[type] || colors.success;
   el.style.marginTop = "10px";
   el.style.fontWeight = "600";
@@ -53,63 +53,89 @@ function showMessage(elementId, message, type = "success") {
 
 async function apiFetch(path, options = {}) {
   const response = await fetch(path, {
-    headers: { 'Content-Type': 'application/json', ...(options.headers || {}) },
+    headers: { "Content-Type": "application/json", ...(options.headers || {}) },
     ...options,
   });
 
   if (!response.ok) {
-    const text = await response.text().catch(() => '');
+    const text = await response.text().catch(() => "");
     throw new Error(text || `Request failed: ${response.status}`);
   }
 
-  const contentType = response.headers.get('content-type') || '';
-  if (contentType.includes('application/json')) {
+  const contentType = response.headers.get("content-type") || "";
+  if (contentType.includes("application/json")) {
     return response.json();
   }
   return response.text();
 }
 
-function formatMinutesAgo(mins) {
-  if (mins === null || typeof mins === 'undefined') return '—';
-  const m = Number(mins);
-  if (!Number.isFinite(m)) return '—';
-  if (m < 60) return `${m}m ago`;
-  const h = Math.floor(m / 60);
-  const r = m % 60;
-  return r ? `${h}h ${r}m ago` : `${h}h ago`;
+function pillHtml(status) {
+  const s = String(status || "").trim();
+  let cls = "pill-warning";
+  if (s === "Online" || s === "Success") cls = "pill-success";
+  else if (s === "Offline" || s === "Failed") cls = "pill-danger";
+  else if (
+    s === "Warning" ||
+    s === "Queued" ||
+    s === "High CPU" ||
+    s === "High RAM" ||
+    s === "High Disk"
+  ) {
+    cls = "pill-warning";
+  }
+  return `<span class="pill ${cls}">${s || "Unknown"}</span>`;
 }
 
-function pillHtml(status) {
-  const s = String(status || '').trim();
-  let cls = 'pill-warning';
-  if (s === 'Online') cls = 'pill-success';
-  if (s === 'Offline') cls = 'pill-danger';
-  return `<span class="pill ${cls}">${s || 'Unknown'}</span>`;
+function formatPercent(value) {
+  const num = Number(value);
+  if (!Number.isFinite(num)) return "—";
+  return `${num}%`;
+}
+
+function formatGps(gps) {
+  if (!gps || typeof gps !== "object") return "—";
+  const lat = gps.lat;
+  const lon = gps.lon;
+  if (lat === null || lat === undefined || lon === null || lon === undefined) {
+    return "—";
+  }
+  return `${lat}, ${lon}`;
+}
+
+function formatUptime(seconds) {
+  const total = Number(seconds);
+  if (!Number.isFinite(total) || total < 0) return "—";
+  const days = Math.floor(total / 86400);
+  const hours = Math.floor((total % 86400) / 3600);
+  const mins = Math.floor((total % 3600) / 60);
+  if (days > 0) return `${days}d ${hours}h ${mins}m`;
+  if (hours > 0) return `${hours}h ${mins}m`;
+  return `${mins}m`;
 }
 
 async function rebootSensors() {
   const sensorsRaw = document.getElementById("reboot-sensor")?.value.trim();
   const reason = document.getElementById("reboot-reason")?.value.trim();
+
   if (!sensorsRaw) {
     showMessage("reboot-message", "Please enter at least one sensor ID.", "warning");
     return;
   }
 
   const sensors = sensorsRaw
-    .split(',')
-    .map(s => s.trim())
+    .split(",")
+    .map((s) => s.trim())
     .filter(Boolean);
 
   try {
-    const results = [];
     for (const sensorId of sensors) {
-      const res = await apiFetch(`/sensors/${encodeURIComponent(sensorId)}/reboot`, {
-        method: 'POST',
+      await apiFetch(`/sensors/${encodeURIComponent(sensorId)}/reboot`, {
+        method: "POST",
         body: JSON.stringify({ reason: reason || null }),
       });
-      results.push(res);
     }
-    showMessage("reboot-message", `Reboot queued for ${sensors.join(', ')}.`, "success");
+
+    showMessage("reboot-message", `Reboot queued for ${sensors.join(", ")}.`, "success");
     await loadRecentRebootHistory();
   } catch (e) {
     showMessage("reboot-message", `Failed to queue reboot: ${e.message}`, "danger");
@@ -117,19 +143,19 @@ async function rebootSensors() {
 }
 
 function intervalLabelToSeconds(label) {
-  const text = String(label || '').toLowerCase();
-  if (text.includes('30')) return 30;
-  if (text.includes('10')) return 600;
-  if (text.includes('5')) return 300;
+  const text = String(label || "").toLowerCase();
+  if (text.includes("30")) return 30;
+  if (text.includes("10")) return 600;
+  if (text.includes("5")) return 300;
   return 60;
 }
 
 function secondsToIntervalLabel(seconds) {
   const s = Number(seconds);
-  if (s === 30) return '30 seconds';
-  if (s === 300) return '5 minutes';
-  if (s === 600) return '10 minutes';
-  return '1 minute';
+  if (s === 30) return "30 seconds";
+  if (s === 300) return "5 minutes";
+  if (s === 600) return "10 minutes";
+  return "1 minute";
 }
 
 async function saveSettings() {
@@ -140,16 +166,16 @@ async function saveSettings() {
   try {
     const payload = {
       recordIntervalSeconds: intervalLabelToSeconds(intervalLabel),
-      sensitivity: sensitivity || 'Medium',
+      sensitivity: sensitivity || "Medium",
       batteryThresholdPct: Number.isFinite(battery) ? battery : 25,
     };
 
     await apiFetch(`/sensors/__default__/settings`, {
-      method: 'PUT',
+      method: "PUT",
       body: JSON.stringify({ settings: payload }),
     });
 
-    showMessage("settings-message", `Settings saved.`, "success");
+    showMessage("settings-message", "Settings saved.", "success");
   } catch (e) {
     showMessage("settings-message", `Failed to save settings: ${e.message}`, "danger");
   }
@@ -159,30 +185,52 @@ function fakeCreateProject() {
   const name = document.getElementById("project-name")?.value.trim();
   const loc = document.getElementById("project-location")?.value.trim();
   const sensors = document.getElementById("project-sensors")?.value.trim();
-  if (!name || !loc) { showMessage("project-message", "Project name and location are required.", "warning"); return; }
-  showMessage("project-message", `Project "${name}" created successfully. Assigned sensors: ${sensors || "None"}.`);
+
+  if (!name || !loc) {
+    showMessage("project-message", "Project name and location are required.", "warning");
+    return;
+  }
+
+  showMessage(
+    "project-message",
+    `Project "${name}" created successfully. Assigned sensors: ${sensors || "None"}.`
+  );
 }
 
-document.querySelectorAll(".card").forEach((card) => { card.style.opacity = 0; setTimeout(() => { card.style.opacity = 1; card.style.transition = "opacity .45s ease"; }, 120); });
-const shell = document.querySelector(".dashboard-shell"); if (shell) { shell.style.opacity = 0; setTimeout(() => { shell.style.opacity = 1; shell.style.transition = "opacity .5s ease"; }, 80); }
+document.querySelectorAll(".card").forEach((card) => {
+  card.style.opacity = 0;
+  setTimeout(() => {
+    card.style.opacity = 1;
+    card.style.transition = "opacity .45s ease";
+  }, 120);
+});
+
+const shell = document.querySelector(".dashboard-shell");
+if (shell) {
+  shell.style.opacity = 0;
+  setTimeout(() => {
+    shell.style.opacity = 1;
+    shell.style.transition = "opacity .5s ease";
+  }, 80);
+}
 
-// Ensure sidebar nav always contains expected links (guard against unexpected DOM changes)
+// Ensure sidebar nav always contains expected links
 function ensureSensorSidebar() {
-  const sidebar = document.querySelector('.sidebar .nav-section');
+  const sidebar = document.querySelector(".sidebar .nav-section");
   if (!sidebar) return;
   const required = [
-    {href: '/admin/dashboard.html', icon: '▦', text: 'Dashboard'},
-    {href: '/admin/sensor-health.html', icon: '📡', text: 'Sensor Health'},
-    {href: '/admin/sensor_health/alerts.html', icon: '🔔', text: 'Alerts'},
-    {href: '/admin/sensor_health/reboot.html', icon: '⟲', text: 'Reboot'},
-    {href: '/admin/sensor_health/settings.html', icon: '⚙', text: 'Settings'},
-    {href: '/admin/sensor_health/add-project.html', icon: '➕', text: 'Add a Project'}
+    { href: "/admin/dashboard.html", icon: "▦", text: "Dashboard" },
+    { href: "/admin/sensor-health.html", icon: "📡", text: "Sensor Health" },
+    { href: "/admin/sensor_health/alerts.html", icon: "🔔", text: "Alerts" },
+    { href: "/admin/sensor_health/reboot.html", icon: "⟲", text: "Reboot" },
+    { href: "/admin/sensor_health/settings.html", icon: "⚙", text: "Settings" },
+    { href: "/admin/sensor_health/add-project.html", icon: "➕", text: "Add a Project" }
   ];
 
-  required.forEach(item => {
+  required.forEach((item) => {
     if (!sidebar.querySelector(`a[href="${item.href}"]`)) {
-      const a = document.createElement('a');
-      a.className = 'nav-link';
+      const a = document.createElement("a");
+      a.className = "nav-link";
       a.href = item.href;
       a.innerHTML = `<span class="nav-icon">${item.icon}</span><span class="nav-text">${item.text}</span>`;
       sidebar.appendChild(a);
@@ -190,9 +238,9 @@ function ensureSensorSidebar() {
   });
 }
 
-document.addEventListener('DOMContentLoaded', function() {
+document.addEventListener("DOMContentLoaded", function () {
   ensureSensorSidebar();
-  const navSection = document.querySelector('.sidebar .nav-section');
+  const navSection = document.querySelector(".sidebar .nav-section");
   if (navSection) {
     const observer = new MutationObserver(() => ensureSensorSidebar());
     observer.observe(navSection, { childList: true });
@@ -201,38 +249,38 @@ document.addEventListener('DOMContentLoaded', function() {
 
 // ---- Page-specific data wiring ----
 async function loadSensorHealthPage() {
-  const tbody = document.getElementById('sensor-overview-tbody');
+  const tbody = document.getElementById("sensor-overview-tbody");
   if (!tbody) return;
 
-  const statusFilter = document.getElementById('sensor-status-filter');
-  const projectFilter = document.getElementById('sensor-project-filter');
-
+  const statusFilter = document.getElementById("sensor-status-filter");
   let lastItems = [];
 
   function render() {
-    const statusVal = statusFilter?.value || 'All';
-    const projectVal = projectFilter?.value || 'All Projects';
+    const statusVal = statusFilter?.value || "All";
 
-    const filtered = lastItems.filter(item => {
-      if (statusVal !== 'All' && item.status !== statusVal) return false;
-      if (projectVal !== 'All Projects' && (item.project || '—') !== projectVal) return false;
+    const filtered = lastItems.filter((item) => {
+      if (statusVal !== "All" && item.status !== statusVal) return false;
       return true;
     });
 
-    tbody.innerHTML = '';
+    tbody.innerHTML = "";
+
     if (!filtered.length) {
-      tbody.innerHTML = '<tr><td colspan="5">No sensors match the current filter.</td></tr>';
+      tbody.innerHTML = '<tr><td colspan="8">No live sensor data available.</td></tr>';
       return;
     }
 
     for (const item of filtered) {
-      const tr = document.createElement('tr');
+      const tr = document.createElement("tr");
       tr.innerHTML = `
-        <td>${item.sensorId}</td>
-        <td>${item.project || '—'}</td>
+        <td>${item.sensorId || "—"}</td>
         <td>${pillHtml(item.status)}</td>
-        <td>${typeof item.batteryPct === 'number' ? `${item.batteryPct}%` : '—'}</td>
-        <td>${formatMinutesAgo(item.lastSeenMinutesAgo)}</td>
+        <td>${formatPercent(item.cpu)}</td>
+        <td>${formatPercent(item.ram)}</td>
+        <td>${formatPercent(item.disk)}</td>
+        <td>${formatUptime(item.uptime)}</td>
+        <td>${formatGps(item.gps)}</td>
+        <td>${item.lastAudio || "—"}</td>
       `;
       tbody.appendChild(tr);
     }
@@ -240,51 +288,39 @@ async function loadSensorHealthPage() {
 
   async function refresh() {
     try {
-      const data = await apiFetch('/sensors/updates');
+      const data = await apiFetch("/sensors/updates");
       lastItems = Array.isArray(data.items) ? data.items : [];
-
-      // Populate project filter options dynamically
-      if (projectFilter) {
-        const projects = Array.from(new Set(lastItems.map(i => i.project).filter(Boolean))).sort();
-        const current = projectFilter.value;
-        projectFilter.innerHTML = '<option>All Projects</option>' + projects.map(p => `<option>${p}</option>`).join('');
-        if ([...projectFilter.options].some(o => o.value === current)) {
-          projectFilter.value = current;
-        }
-      }
-
       render();
     } catch (e) {
-      tbody.innerHTML = `<tr><td colspan="5">Failed to load sensors: ${e.message}</td></tr>`;
+      tbody.innerHTML = `<tr><td colspan="8">Failed to load sensors: ${e.message}</td></tr>`;
     }
   }
 
-  statusFilter?.addEventListener('change', render);
-  projectFilter?.addEventListener('change', render);
+  statusFilter?.addEventListener("change", render);
 
   await refresh();
   setInterval(refresh, 15000);
 }
 
 async function loadAlertsPage() {
-  const tbody = document.getElementById('alerts-tbody');
+  const tbody = document.getElementById("alerts-tbody");
   if (!tbody) return;
   try {
-    const data = await apiFetch('/sensors/alerts');
+    const data = await apiFetch("/sensors/alerts");
     const items = Array.isArray(data.items) ? data.items : [];
-    tbody.innerHTML = '';
+    tbody.innerHTML = "";
     if (!items.length) {
       tbody.innerHTML = '<tr><td colspan="4">No active alerts.</td></tr>';
       return;
     }
     for (const alert of items) {
-      const tr = document.createElement('tr');
+      const tr = document.createElement("tr");
       const sevPill = pillHtml(alert.issue);
       tr.innerHTML = `
-        <td>${alert.sensorId}</td>
+        <td>${alert.sensorId || "—"}</td>
         <td>${sevPill}</td>
-        <td>${alert.details || ''}</td>
-        <td>${formatMinutesAgo(alert.lastAudioMinutesAgo)}</td>
+        <td>${alert.details || ""}</td>
+        <td>${alert.lastAudioMinutesAgo !== undefined ? alert.lastAudioMinutesAgo : "—"}</td>
       `;
       tbody.appendChild(tr);
     }
@@ -294,21 +330,21 @@ async function loadAlertsPage() {
 }
 
 async function loadRecentRebootHistory() {
-  const tbody = document.getElementById('reboot-history-tbody');
+  const tbody = document.getElementById("reboot-history-tbody");
   if (!tbody) return;
   try {
-    const data = await apiFetch('/sensors/reboots/recent?limit=50');
+    const data = await apiFetch("/sensors/reboots/recent?limit=50");
     const items = Array.isArray(data.items) ? data.items : [];
-    tbody.innerHTML = '';
+    tbody.innerHTML = "";
     if (!items.length) {
       tbody.innerHTML = '<tr><td colspan="3">No reboot history yet.</td></tr>';
       return;
     }
     for (const r of items) {
-      const t = r.requestedAt ? new Date(r.requestedAt).toLocaleString() : '—';
-      const status = String(r.status || 'Queued');
-      const cls = status.toLowerCase().includes('fail') ? 'pill-danger' : (status.toLowerCase().includes('success') ? 'pill-success' : 'pill-warning');
-      const tr = document.createElement('tr');
+      const t = r.requestedAt ? new Date(r.requestedAt).toLocaleString() : "—";
+      const status = String(r.status || "Queued");
+      const cls = status.toLowerCase().includes("fail") ? "pill-danger" : status.toLowerCase().includes("success") ? "pill-success" : "pill-warning";
+      const tr = document.createElement("tr");
       tr.innerHTML = `
         <td>${r.sensorId}</td>
         <td><span class="pill ${cls}">${status}</span></td>
@@ -322,22 +358,21 @@ async function loadRecentRebootHistory() {
 }
 
 async function loadSettingsPage() {
-  const interval = document.getElementById('record-interval');
-  const sensitivity = document.getElementById('sensitivity');
-  const battery = document.getElementById('battery-threshold');
+  const interval = document.getElementById("record-interval");
+  const sensitivity = document.getElementById("sensitivity");
+  const battery = document.getElementById("battery-threshold");
   if (!interval || !sensitivity || !battery) return;
 
   try {
-    const data = await apiFetch('/sensors/__default__/settings');
+    const data = await apiFetch("/sensors/__default__/settings");
     const settings = data.settings || {};
     const intervalLabel = secondsToIntervalLabel(settings.recordIntervalSeconds);
 
-    // Set values if present
     interval.value = intervalLabel;
-    sensitivity.value = settings.sensitivity || 'Medium';
+    sensitivity.value = settings.sensitivity || "Medium";
     battery.value = Number(settings.batteryThresholdPct || 25);
   } catch (e) {
-    showMessage('settings-message', `Failed to load settings: ${e.message}`, 'danger');
+    showMessage("settings-message", `Failed to load settings: ${e.message}`, "danger");
   }
 }
 
@@ -345,7 +380,7 @@ async function loadSettingsPage() {
 window.fakeReboot = rebootSensors;
 window.fakeSaveSettings = saveSettings;
 
-document.addEventListener('DOMContentLoaded', () => {
+document.addEventListener("DOMContentLoaded", () => {
   loadSensorHealthPage();
   loadAlertsPage();
   loadRecentRebootHistory();
diff --git a/src/Components/HMI/ui/routes/map.routes.js b/src/Components/HMI/ui/routes/map.routes.js
index 89b58134b..bd349c153 100644
--- a/src/Components/HMI/ui/routes/map.routes.js
+++ b/src/Components/HMI/ui/routes/map.routes.js
@@ -1,111 +1,255 @@
 const { verifySignUp, client } = require("../middleware");
-const axios = require('axios');
-require('dotenv').config();
-const API_BASE_URL = `http://${process.env.API_HOST || 'localhost'}:9000`;
-
+const axios = require("axios");
+const mqtt = require('mqtt');
+const fs = require("fs");
+require("dotenv").config();
+ 
+const API_BASE_URL = `http://${process.env.API_HOST || "localhost"}:9000`;
 const MESSAGE_API_URL = `${API_BASE_URL}/hmi`;
+ 
+const MQTT_BROKER = "mqtt://broker.hivemq.com";
+const MQTT_TOPIC = "iot/data/test";
+ 
 let token;
-// client.get('JWT', (err, storedToken) => {
-//   if (err) {
-//     console.error('Error retrieving token from Redis:', err);
-//     return null
-//   } else {
-//     console.log('Stored Token:', storedToken);
-//     return storedToken
-//   }
-// }).then(response => token = response)
-
-module.exports = function(app) {
-  
-
-  app.use(function(req, res, next) {
-    // req.headers['Authorization'] = `Bearer ${token}`;
-    res.header(
-      "Access-Control-Allow-Headers",
-      "Origin, Content-Type, Accept"
-    );
-    // console.log("Token inside map requests: ", token);
-    next();
-  });
-
-  app.get(`/movement_time/:start/:end`, async (req, res, next) => {
-    const start = req.params.start
-    const end = req.params.end
-    const response = await axios.get(`${MESSAGE_API_URL}/movement_time?start=${start}&end=${end}`);
-    if (Object.keys(response.data).length === 0) {
-      res.send([])
-    } else {
-      res.send(response.data);
-    }
-  })
-
-  app.get(`/events_time/:start/:end`, async (req, res, next) => {
-    const start = req.params.start
-    const end = req.params.end
-    const response = await axios.get(`${MESSAGE_API_URL}/events_time?start=${start}&end=${end}`);
-    res.send(response.data);
-    next()
-  })
-
-  app.get(`/microphones`, async (req, res, next) => {
-    const response = await axios.get(`${MESSAGE_API_URL}/microphones`);
-    res.send(response.data);
-    next()
-  })
-
-  app.get(`/audio/:id`, async (req, res, next) => {
-    const id = req.params.id;
-    //console.log(`${MESSAGE_API_URL}/audio?id=${id}`);
-    const response = await axios.get(`${MESSAGE_API_URL}/audio?id=${id}`);
-    res.send(response.data);
-    next()
-  })
-
-  app.post(`/post_recording`, async (req, res, next) => {
-    let data = req.body
+let latestSensorData = null;
+ 
+const mqttClient = mqtt.connect(MQTT_BROKER);
+ 
+mqttClient.on("connect", () => {
+    console.log("MQTT Connected");
+    mqttClient.subscribe(MQTT_TOPIC);
+});
+ 
+mqttClient.on("message", (topic, message) => {
     try {
-      const response = await axios.post(`${MESSAGE_API_URL}/post_recording`, data);
-      console.log('Record response:', response.data);
-      res.send(response.data);
-      next()
-    } catch (error) {
-      console.error('Error:', error);
+        const data = JSON.parse(message.toString());
+ 
+        if (data.audio_file) {
+            const buffer = Buffer.from(data.audio_file, "base64");
+            const fileName = `audio_${Date.now()}.wav`;
+            fs.writeFileSync(`./audioLocal/${fileName}`, buffer);
+            data.savedAudio = fileName;
+        }
+ 
+        latestSensorData = data;
+    } catch (err) {
+        console.error("MQTT parse error:", err);
     }
-    //axios.post(`${MESSAGE_API_URL}/post_recording?data=${recordingData}`);
-  })
-
-  app.post(`/sim_control/:control`, async (req, res, next) => {
-    const control = req.params.control
-    const response = await axios.post(`${MESSAGE_API_URL}/sim_control?control=${control}`);
-    res.send(response.data);
-    next()
-  })
-
-  
-  app.get(`/latest_movement`, async (req, res, next) => {
-    const response = await axios.get(`${MESSAGE_API_URL}/latest_movement`);
-    res.send(response.data);
-    next()
-  })
-  
+});
+ 
+module.exports = function (app) {
+ 
+    app.use(function (req, res, next) {
+        res.header("Access-Control-Allow-Headers", "Origin, Content-Type, Accept");
+        next();
+    });
+ 
     app.get(`/movement_time/:start/:end`, async (req, res, next) => {
-    const start = req.params.start;
-    const end = req.params.end;
-    const response = await axios.get(
-      `${MESSAGE_API_URL}/movement_time?start=${start}&end=${end}`
-    );
-    res.send(response.data || []);
-  });
-
-  app.get(`/movement_time_daily/:start/:end`, async (req, res, next) => {
-    const start = req.params.start;
-    const end = req.params.end;
-
-    const response = await axios.get(
-      `${MESSAGE_API_URL}/movement_time_daily?start=${start}&end=${end}`
-    );
-
-    res.send(response.data || []);
-  });
-
-}
\ No newline at end of file
+        try {
+            const start = req.params.start;
+            const end = req.params.end;
+            const response = await axios.get(
+                `${MESSAGE_API_URL}/movement_time?start=${start}&end=${end}`
+            );
+ 
+            if (Object.keys(response.data).length === 0) {
+                res.send([]);
+            } else {
+                res.send(response.data);
+            }
+        } catch (error) {
+            console.error("Error fetching movement_time:", error.message);
+            res.status(500).send({ error: "Failed to fetch movement data." });
+        }
+    });
+ 
+    app.get(`/events_time/:start/:end`, async (req, res, next) => {
+        try {
+            const start = req.params.start;
+            const end = req.params.end;
+            const response = await axios.get(
+                `${MESSAGE_API_URL}/events_time?start=${start}&end=${end}`
+            );
+            res.send(response.data);
+            next();
+        } catch (error) {
+            console.error("Error fetching events_time:", error.message);
+            res.status(500).send({ error: "Failed to fetch event data." });
+        }
+    });
+ 
+    app.get(`/microphones`, async (req, res, next) => {
+        try {
+            const response = await axios.get(`${MESSAGE_API_URL}/microphones`);
+            res.send(response.data);
+            next();
+        } catch (error) {
+            console.error("Error fetching microphones:", error.message);
+            res.status(500).send({ error: "Failed to fetch microphones." });
+        }
+    });
+ 
+    app.get(`/audio/:id`, async (req, res, next) => {
+        try {
+            const id = req.params.id;
+            const response = await axios.get(`${MESSAGE_API_URL}/audio?id=${id}`);
+            res.send(response.data);
+            next();
+        } catch (error) {
+            console.error("Error fetching audio:", error.message);
+            res.status(500).send({ error: "Failed to fetch audio." });
+        }
+    });
+ 
+    app.post(`/post_recording`, async (req, res, next) => {
+        const data = req.body;
+        try {
+            const response = await axios.post(`${MESSAGE_API_URL}/post_recording`, data);
+            console.log("Record response:", response.data);
+            res.send(response.data);
+            next();
+        } catch (error) {
+            console.error("Error posting recording:", error.message);
+            res.status(500).send({ error: "Failed to post recording." });
+        }
+    });
+ 
+    app.post(`/sim_control/:control`, async (req, res, next) => {
+        try {
+            const control = req.params.control;
+            const response = await axios.post(
+                `${MESSAGE_API_URL}/sim_control?control=${control}`
+            );
+            res.send(response.data);
+            next();
+        } catch (error) {
+            console.error("Error posting sim control:", error.message);
+            res.status(500).send({ error: "Failed to control simulation." });
+        }
+    });
+ 
+    app.get(`/latest_movement`, async (req, res, next) => {
+        try {
+            const response = await axios.get(`${MESSAGE_API_URL}/latest_movement`);
+            res.send(response.data);
+            next();
+        } catch (error) {
+            console.error("Error fetching latest movement:", error.message);
+            res.status(500).send({ error: "Failed to fetch latest movement." });
+        }
+    });
+ 
+    app.get(`/movement_time_daily/:start/:end`, async (req, res, next) => {
+        try {
+            const start = req.params.start;
+            const end = req.params.end;
+            const response = await axios.get(
+                `${MESSAGE_API_URL}/movement_time_daily?start=${start}&end=${end}`
+            );
+            res.send(response.data || []);
+        } catch (error) {
+            console.error("Error fetching movement_time_daily:", error.message);
+            res.status(500).send({ error: "Failed to fetch daily movement data." });
+        }
+    });
+    // Task 9: Sensor Health mock routes for HMI dashboard
+    // Wait for real information from IoT
+ 
+    app.get("/sensors/updates", async (req, res) => {
+        if (!latestSensorData) {
+            return res.json({ items: [] });
+        }
+ 
+        res.json({
+            items: [
+                {
+                    sensorId: "LIVE-001",
+                    status: "Online",
+                    cpu: latestSensorData.health_data?.cpu,
+                    ram: latestSensorData.health_data?.ram,
+                    disk: latestSensorData.health_data?.disk,
+                    uptime: latestSensorData.health_data?.uptime,
+                    gps: latestSensorData.gps_data,
+                    lastAudio: latestSensorData.savedAudio || null,
+                },
+            ],
+        });
+    });
+ 
+    app.get("/sensors/alerts", async (req, res) => {
+        if (!latestSensorData) {
+            return res.json({ items: [] });
+        }
+ 
+        const items = [];
+ 
+        if (latestSensorData.health_data?.cpu > 90) {
+            items.push({
+                sensorId: "LIVE-001",
+                issue: "High CPU",
+                details: `CPU usage ${latestSensorData.health_data.cpu}%`,
+            });
+        }
+ 
+        if (latestSensorData.health_data?.ram > 90) {
+            items.push({
+                sensorId: "LIVE-001",
+                issue: "High RAM",
+                details: `RAM usage ${latestSensorData.health_data.ram}%`,
+            });
+        }
+ 
+        res.json({ items });
+    });
+ 
+    let rebootHistory = [];
+ 
+    app.get("/sensors/reboots/recent", async (req, res) => {
+        const limit = Number(req.query.limit) || 50;
+        res.json({
+            items: rebootHistory.slice(0, limit),
+        });
+    });
+ 
+    app.post("/sensors/:sensorId/reboot", async (req, res) => {
+        const sensorId = req.params.sensorId;
+ 
+        const entry = {
+            sensorId,
+            status: "Queued",
+            requestedAt: new Date().toISOString(),
+        };
+ 
+        rebootHistory.unshift(entry);
+ 
+        res.json({
+            success: true,
+            message: `Reboot queued for ${sensorId}`,
+            item: entry,
+        });
+    });
+ 
+    let sensorSettings = {
+        recordIntervalSeconds: 60,
+        sensitivity: "Medium",
+        batteryThresholdPct: 25,
+    };
+ 
+    app.get("/sensors/__default__/settings", async (req, res) => {
+        res.json({ settings: sensorSettings });
+    });
+ 
+    app.put("/sensors/__default__/settings", async (req, res) => {
+        const incoming = req.body?.settings || {};
+ 
+        sensorSettings = {
+            ...sensorSettings,
+            ...incoming,
+        };
+ 
+        res.json({
+            success: true,
+            settings: sensorSettings,
+        });
+    });
+};
\ No newline at end of file

From f2f14e4ab0afb185f07bdefcbafdf362bc9f78db Mon Sep 17 00:00:00 2001
From: ohwenyi <wenyi2858@gmail.com>
Date: Sun, 26 Apr 2026 13:53:50 +1000
Subject: [PATCH 2/2] Fix HMI sensor dashboard route and add test seed support

---
 src/Components/HMI/ui/package-lock.json    | 796 ++++++++++++++++++++-
 src/Components/HMI/ui/package.json         |   1 +
 src/Components/HMI/ui/routes/map.routes.js | 544 ++++++++------
 3 files changed, 1082 insertions(+), 259 deletions(-)

diff --git a/src/Components/HMI/ui/package-lock.json b/src/Components/HMI/ui/package-lock.json
index 92ce3fa5b..1007acd67 100644
--- a/src/Components/HMI/ui/package-lock.json
+++ b/src/Components/HMI/ui/package-lock.json
@@ -23,6 +23,7 @@
         "jquery": "^3.6.4",
         "jsonwebtoken": "^9.0.1",
         "mongoose": "^6.10.0",
+        "mqtt": "^5.15.1",
         "nodemailer": "^6.9.1",
         "nodemon": "^2.0.22",
         "ol": "^7.3.0",
@@ -646,6 +647,15 @@
         "tslib": "^2.3.1"
       }
     },
+    "node_modules/@babel/runtime": {
+      "version": "7.29.2",
+      "resolved": "https://registry.npmjs.org/@babel/runtime/-/runtime-7.29.2.tgz",
+      "integrity": "sha512-JiDShH45zKHWyGe4ZNVRrCjBz8Nh9TMmZG1kh4QTK8hCBTWBi8Da+i7s1fJw7/lYpM4ccepSNfqzZ/QvABBi5g==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=6.9.0"
+      }
+    },
     "node_modules/@mapbox/jsonlint-lines-primitives": {
       "version": "2.0.2",
       "resolved": "https://registry.npmjs.org/@mapbox/jsonlint-lines-primitives/-/jsonlint-lines-primitives-2.0.2.tgz",
@@ -1280,6 +1290,15 @@
       "resolved": "https://registry.npmjs.org/@types/node/-/node-20.5.2.tgz",
       "integrity": "sha512-5j/lXt7unfPOUlrKC34HIaedONleyLtwkKggiD/0uuMfT8gg2EOpg0dz4lCD15Ga7muC+1WzJZAjIB9simWd6Q=="
     },
+    "node_modules/@types/readable-stream": {
+      "version": "4.0.23",
+      "resolved": "https://registry.npmjs.org/@types/readable-stream/-/readable-stream-4.0.23.tgz",
+      "integrity": "sha512-wwXrtQvbMHxCbBgjHaMGEmImFTQxxpfMOR/ZoQnXxB1woqkUbdLGFDgauo00Py9IudiaqSeiBiulSV9i6XIPig==",
+      "license": "MIT",
+      "dependencies": {
+        "@types/node": "*"
+      }
+    },
     "node_modules/@types/webidl-conversions": {
       "version": "7.0.0",
       "resolved": "https://registry.npmjs.org/@types/webidl-conversions/-/webidl-conversions-7.0.0.tgz",
@@ -1294,6 +1313,15 @@
         "@types/webidl-conversions": "*"
       }
     },
+    "node_modules/@types/ws": {
+      "version": "8.18.1",
+      "resolved": "https://registry.npmjs.org/@types/ws/-/ws-8.18.1.tgz",
+      "integrity": "sha512-ThVF6DCVhA8kUGy+aazFQ4kXQ7E1Ty7A3ypFOe0IcJV8O/M511G99AW24irKrW56Wt44yG9+ij8FaqoBGkuBXg==",
+      "license": "MIT",
+      "dependencies": {
+        "@types/node": "*"
+      }
+    },
     "node_modules/@yr/monotone-cubic-spline": {
       "version": "1.0.3",
       "resolved": "https://registry.npmjs.org/@yr/monotone-cubic-spline/-/monotone-cubic-spline-1.0.3.tgz",
@@ -1304,6 +1332,18 @@
       "resolved": "https://registry.npmjs.org/abbrev/-/abbrev-1.1.1.tgz",
       "integrity": "sha512-nne9/IiQ/hzIhY6pdDnbBtz7DjPTKrY00P/zvPSm5pOFkl6xuGrGnXn/VtTNNfNtAfZ9/1RtehkszU9qcTii0Q=="
     },
+    "node_modules/abort-controller": {
+      "version": "3.0.0",
+      "resolved": "https://registry.npmjs.org/abort-controller/-/abort-controller-3.0.0.tgz",
+      "integrity": "sha512-h8lQ8tacZYnR3vNQTgibj+tODHI5/+l06Au2Pcriv/Gmet0eaj4TwWH41sO9wnHDiQsEj19q0drzdWdeAHtweg==",
+      "license": "MIT",
+      "dependencies": {
+        "event-target-shim": "^5.0.0"
+      },
+      "engines": {
+        "node": ">=6.5"
+      }
+    },
     "node_modules/accepts": {
       "version": "1.3.8",
       "resolved": "https://registry.npmjs.org/accepts/-/accepts-1.3.8.tgz",
@@ -1404,6 +1444,42 @@
         "node": ">=8"
       }
     },
+    "node_modules/bl": {
+      "version": "6.1.6",
+      "resolved": "https://registry.npmjs.org/bl/-/bl-6.1.6.tgz",
+      "integrity": "sha512-jLsPgN/YSvPUg9UX0Kd73CXpm2Psg9FxMeCSXnk3WBO3CMT10JMwijubhGfHCnFu6TPn1ei3b975dxv7K2pWVg==",
+      "license": "MIT",
+      "dependencies": {
+        "@types/readable-stream": "^4.0.0",
+        "buffer": "^6.0.3",
+        "inherits": "^2.0.4",
+        "readable-stream": "^4.2.0"
+      }
+    },
+    "node_modules/bl/node_modules/buffer": {
+      "version": "6.0.3",
+      "resolved": "https://registry.npmjs.org/buffer/-/buffer-6.0.3.tgz",
+      "integrity": "sha512-FTiCpNxtwiZZHEZbcbTIcZjERVICn9yq/pDFkTl95/AxzD1naBctN7YO68riM/gLSDY7sdrMby8hofADYuuqOA==",
+      "funding": [
+        {
+          "type": "github",
+          "url": "https://github.com/sponsors/feross"
+        },
+        {
+          "type": "patreon",
+          "url": "https://www.patreon.com/feross"
+        },
+        {
+          "type": "consulting",
+          "url": "https://feross.org/support"
+        }
+      ],
+      "license": "MIT",
+      "dependencies": {
+        "base64-js": "^1.3.1",
+        "ieee754": "^1.2.1"
+      }
+    },
     "node_modules/body-parser": {
       "version": "1.20.1",
       "resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.1.tgz",
@@ -1466,6 +1542,18 @@
         "node": ">=8"
       }
     },
+    "node_modules/broker-factory": {
+      "version": "3.1.14",
+      "resolved": "https://registry.npmjs.org/broker-factory/-/broker-factory-3.1.14.tgz",
+      "integrity": "sha512-L45k5HMbPIrMid0nTOZ/UPXG/c0aRuQKVrSDFIb1zOkvfiyHgYmIjc3cSiN1KwQIvRDOtKE0tfb3I9EZ3CmpQQ==",
+      "license": "MIT",
+      "dependencies": {
+        "@babel/runtime": "^7.29.2",
+        "fast-unique-numbers": "^9.0.27",
+        "tslib": "^2.8.1",
+        "worker-factory": "^7.0.49"
+      }
+    },
     "node_modules/bson": {
       "version": "4.7.2",
       "resolved": "https://registry.npmjs.org/bson/-/bson-4.7.2.tgz",
@@ -1505,6 +1593,12 @@
       "resolved": "https://registry.npmjs.org/buffer-equal-constant-time/-/buffer-equal-constant-time-1.0.1.tgz",
       "integrity": "sha512-zRpUiDwd/xk6ADqPMATG8vc9VPrkck7T07OIx0gnjmJAnHnTVXNQG3vfvWNuiZIkwu9KrKdA1iJKfsfTVxE6NA=="
     },
+    "node_modules/buffer-from": {
+      "version": "1.1.2",
+      "resolved": "https://registry.npmjs.org/buffer-from/-/buffer-from-1.1.2.tgz",
+      "integrity": "sha512-E+XQCRwSbaaiChtv6k6Dwgc+bx+Bs6vuKJHHl5kox/BaKbhiXzqQOwK4cO22yElGp2OCmjwVhT3HmxgyPGnJfQ==",
+      "license": "MIT"
+    },
     "node_modules/bytes": {
       "version": "3.1.2",
       "resolved": "https://registry.npmjs.org/bytes/-/bytes-3.1.2.tgz",
@@ -1575,11 +1669,46 @@
         "node": ">= 0.8"
       }
     },
+    "node_modules/commist": {
+      "version": "3.2.0",
+      "resolved": "https://registry.npmjs.org/commist/-/commist-3.2.0.tgz",
+      "integrity": "sha512-4PIMoPniho+LqXmpS5d3NuGYncG6XWlkBSVGiWycL22dd42OYdUGil2CWuzklaJoNxyxUSpO4MKIBU94viWNAw==",
+      "license": "MIT"
+    },
     "node_modules/concat-map": {
       "version": "0.0.1",
       "resolved": "https://registry.npmjs.org/concat-map/-/concat-map-0.0.1.tgz",
       "integrity": "sha512-/Srv4dswyQNBfohGpz9o6Yb3Gz3SrUDqBH5rTuhGR7ahtlbYKnVxw2bCFMRljaA7EXHaXZ8wsHdodFvbkhKmqg=="
     },
+    "node_modules/concat-stream": {
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/concat-stream/-/concat-stream-2.0.0.tgz",
+      "integrity": "sha512-MWufYdFw53ccGjCA+Ol7XJYpAlW6/prSMzuPOTRnJGcGzuhLn4Scrz7qf6o8bROZ514ltazcIFJZevcfbo0x7A==",
+      "engines": [
+        "node >= 6.0"
+      ],
+      "license": "MIT",
+      "dependencies": {
+        "buffer-from": "^1.0.0",
+        "inherits": "^2.0.3",
+        "readable-stream": "^3.0.2",
+        "typedarray": "^0.0.6"
+      }
+    },
+    "node_modules/concat-stream/node_modules/readable-stream": {
+      "version": "3.6.2",
+      "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-3.6.2.tgz",
+      "integrity": "sha512-9u/sniCrY3D5WdsERHzHE4G2YCXqoG5FTHUiCC4SIbr6XcLZBY05ya9EKjYek9O5xOAwjGq+1JdGBAS7Q9ScoA==",
+      "license": "MIT",
+      "dependencies": {
+        "inherits": "^2.0.3",
+        "string_decoder": "^1.1.1",
+        "util-deprecate": "^1.0.1"
+      },
+      "engines": {
+        "node": ">= 6"
+      }
+    },
     "node_modules/content-disposition": {
       "version": "0.5.4",
       "resolved": "https://registry.npmjs.org/content-disposition/-/content-disposition-0.5.4.tgz",
@@ -1772,6 +1901,24 @@
         "node": ">= 0.6"
       }
     },
+    "node_modules/event-target-shim": {
+      "version": "5.0.1",
+      "resolved": "https://registry.npmjs.org/event-target-shim/-/event-target-shim-5.0.1.tgz",
+      "integrity": "sha512-i/2XbnSz/uxRCU6+NdVJgKWDTM427+MqYbkQzD321DuCQJUqOuJKIA0IM2+W2xtYHdKOmZ4dR6fExsd4SXL+WQ==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=6"
+      }
+    },
+    "node_modules/events": {
+      "version": "3.3.0",
+      "resolved": "https://registry.npmjs.org/events/-/events-3.3.0.tgz",
+      "integrity": "sha512-mQw+2fkQbALzQ7V0MY0IqdnXNOeTtP4r0lN9z7AAawCXgqea7bDii20AYrIBrFd/Hx0M2Ocz6S111CaFkUcb0Q==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=0.8.x"
+      }
+    },
     "node_modules/express": {
       "version": "4.18.2",
       "resolved": "https://registry.npmjs.org/express/-/express-4.18.2.tgz",
@@ -1834,6 +1981,19 @@
       "resolved": "https://registry.npmjs.org/ms/-/ms-2.0.0.tgz",
       "integrity": "sha512-Tpp60P6IUJDTuOq/5Z8cdskzJujfwqfOTkrwIwj7IRISpnkJnT6SyJ4PCPnGMoFjC9ddhal5KVIYtAt97ix05A=="
     },
+    "node_modules/fast-unique-numbers": {
+      "version": "9.0.27",
+      "resolved": "https://registry.npmjs.org/fast-unique-numbers/-/fast-unique-numbers-9.0.27.tgz",
+      "integrity": "sha512-nDA9ADeINN8SA2u2wCtU+siWFTTDqQR37XvgPIDDmboWQeExz7X0mImxuaN+kJddliIqy2FpVRmnvRZ+j8i1/A==",
+      "license": "MIT",
+      "dependencies": {
+        "@babel/runtime": "^7.29.2",
+        "tslib": "^2.8.1"
+      },
+      "engines": {
+        "node": ">=18.2.0"
+      }
+    },
     "node_modules/fast-xml-parser": {
       "version": "4.2.5",
       "resolved": "https://registry.npmjs.org/fast-xml-parser/-/fast-xml-parser-4.2.5.tgz",
@@ -2050,6 +2210,12 @@
         "node": ">=16.0.0"
       }
     },
+    "node_modules/help-me": {
+      "version": "5.0.0",
+      "resolved": "https://registry.npmjs.org/help-me/-/help-me-5.0.0.tgz",
+      "integrity": "sha512-7xgomUX6ADmcYzFik0HzAxh/73YlKR9bmFzf51CZwR+b6YtzU2m0u49hQCqV6SvlqIqsaxovfwdvbnsw3b/zpg==",
+      "license": "MIT"
+    },
     "node_modules/http-errors": {
       "version": "2.0.0",
       "resolved": "https://registry.npmjs.org/http-errors/-/http-errors-2.0.0.tgz",
@@ -2105,10 +2271,14 @@
       "resolved": "https://registry.npmjs.org/inherits/-/inherits-2.0.4.tgz",
       "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ=="
     },
-    "node_modules/ip": {
-      "version": "2.0.0",
-      "resolved": "https://registry.npmjs.org/ip/-/ip-2.0.0.tgz",
-      "integrity": "sha512-WKa+XuLG1A1R0UWhl2+1XQSi+fZWMsYKffMZTTYsiZaUD8k2yDAj5atimTUD2TZkyCkNEeYE5NhFZmupOGtjYQ=="
+    "node_modules/ip-address": {
+      "version": "10.1.0",
+      "resolved": "https://registry.npmjs.org/ip-address/-/ip-address-10.1.0.tgz",
+      "integrity": "sha512-XXADHxXmvT9+CRxhXg56LJovE+bmWnEWB78LB83VZTprKTmaC5QfruXocxzTZ2Kl0DNwKuBdlIhjL8LeY8Sf8Q==",
+      "license": "MIT",
+      "engines": {
+        "node": ">= 12"
+      }
     },
     "node_modules/ipaddr.js": {
       "version": "1.9.1",
@@ -2161,6 +2331,16 @@
       "resolved": "https://registry.npmjs.org/jquery/-/jquery-3.6.4.tgz",
       "integrity": "sha512-v28EW9DWDFpzcD9O5iyJXg3R3+q+mET5JhnjJzQUZMHOv67bpSIHq81GEYpPNZHG+XXHsfSme3nxp/hndKEcsQ=="
     },
+    "node_modules/js-sdsl": {
+      "version": "4.3.0",
+      "resolved": "https://registry.npmjs.org/js-sdsl/-/js-sdsl-4.3.0.tgz",
+      "integrity": "sha512-mifzlm2+5nZ+lEcLJMoBK0/IH/bDg8XnJfd/Wq6IP+xoCjLZsTOnV2QpxlVbX9bMnkl5PdEjNtBJ9Cj1NjifhQ==",
+      "license": "MIT",
+      "funding": {
+        "type": "opencollective",
+        "url": "https://opencollective.com/js-sdsl"
+      }
+    },
     "node_modules/json-stringify-pretty-compact": {
       "version": "2.0.0",
       "resolved": "https://registry.npmjs.org/json-stringify-pretty-compact/-/json-stringify-pretty-compact-2.0.0.tgz",
@@ -2401,6 +2581,89 @@
         "node": ">=4.0.0"
       }
     },
+    "node_modules/mqtt": {
+      "version": "5.15.1",
+      "resolved": "https://registry.npmjs.org/mqtt/-/mqtt-5.15.1.tgz",
+      "integrity": "sha512-V1WnkGuJh3ec9QXzy5Iylw8OOBK+Xu1WhxcQ9mMpLThG+/JZIMV1PgLNRgIiqXhZnvnVLsuyxHl5A/3bHHbcAA==",
+      "license": "MIT",
+      "dependencies": {
+        "@types/readable-stream": "^4.0.21",
+        "@types/ws": "^8.18.1",
+        "commist": "^3.2.0",
+        "concat-stream": "^2.0.0",
+        "debug": "^4.4.1",
+        "help-me": "^5.0.0",
+        "lru-cache": "^10.4.3",
+        "minimist": "^1.2.8",
+        "mqtt-packet": "^9.0.2",
+        "number-allocator": "^1.0.14",
+        "readable-stream": "^4.7.0",
+        "rfdc": "^1.4.1",
+        "socks": "^2.8.6",
+        "split2": "^4.2.0",
+        "worker-timers": "^8.0.23",
+        "ws": "^8.18.3"
+      },
+      "bin": {
+        "mqtt": "build/bin/mqtt.js",
+        "mqtt_pub": "build/bin/pub.js",
+        "mqtt_sub": "build/bin/sub.js"
+      },
+      "engines": {
+        "node": ">=16.0.0"
+      }
+    },
+    "node_modules/mqtt-packet": {
+      "version": "9.0.2",
+      "resolved": "https://registry.npmjs.org/mqtt-packet/-/mqtt-packet-9.0.2.tgz",
+      "integrity": "sha512-MvIY0B8/qjq7bKxdN1eD+nrljoeaai+qjLJgfRn3TiMuz0pamsIWY2bFODPZMSNmabsLANXsLl4EMoWvlaTZWA==",
+      "license": "MIT",
+      "dependencies": {
+        "bl": "^6.0.8",
+        "debug": "^4.3.4",
+        "process-nextick-args": "^2.0.1"
+      }
+    },
+    "node_modules/mqtt-packet/node_modules/debug": {
+      "version": "4.4.3",
+      "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.3.tgz",
+      "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
+      "license": "MIT",
+      "dependencies": {
+        "ms": "^2.1.3"
+      },
+      "engines": {
+        "node": ">=6.0"
+      },
+      "peerDependenciesMeta": {
+        "supports-color": {
+          "optional": true
+        }
+      }
+    },
+    "node_modules/mqtt/node_modules/debug": {
+      "version": "4.4.3",
+      "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.3.tgz",
+      "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
+      "license": "MIT",
+      "dependencies": {
+        "ms": "^2.1.3"
+      },
+      "engines": {
+        "node": ">=6.0"
+      },
+      "peerDependenciesMeta": {
+        "supports-color": {
+          "optional": true
+        }
+      }
+    },
+    "node_modules/mqtt/node_modules/lru-cache": {
+      "version": "10.4.3",
+      "resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-10.4.3.tgz",
+      "integrity": "sha512-JNAzZcXrCt42VGLuYz0zfAzDfAvJWW6AfYlDBQyDV5DClI2m5sAmK+OIO7s59XfsRsWHp02jAJrRadPRGTt6SQ==",
+      "license": "ISC"
+    },
     "node_modules/mquery": {
       "version": "4.0.3",
       "resolved": "https://registry.npmjs.org/mquery/-/mquery-4.0.3.tgz",
@@ -2503,6 +2766,33 @@
         "node": ">=0.10.0"
       }
     },
+    "node_modules/number-allocator": {
+      "version": "1.0.14",
+      "resolved": "https://registry.npmjs.org/number-allocator/-/number-allocator-1.0.14.tgz",
+      "integrity": "sha512-OrL44UTVAvkKdOdRQZIJpLkAdjXGTRda052sN4sO77bKEzYYqWKMBjQvrJFzqygI99gL6Z4u2xctPW1tB8ErvA==",
+      "license": "MIT",
+      "dependencies": {
+        "debug": "^4.3.1",
+        "js-sdsl": "4.3.0"
+      }
+    },
+    "node_modules/number-allocator/node_modules/debug": {
+      "version": "4.4.3",
+      "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.3.tgz",
+      "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
+      "license": "MIT",
+      "dependencies": {
+        "ms": "^2.1.3"
+      },
+      "engines": {
+        "node": ">=6.0"
+      },
+      "peerDependenciesMeta": {
+        "supports-color": {
+          "optional": true
+        }
+      }
+    },
     "node_modules/object-assign": {
       "version": "4.1.1",
       "resolved": "https://registry.npmjs.org/object-assign/-/object-assign-4.1.1.tgz",
@@ -2626,6 +2916,12 @@
         "node": ">= 0.6.0"
       }
     },
+    "node_modules/process-nextick-args": {
+      "version": "2.0.1",
+      "resolved": "https://registry.npmjs.org/process-nextick-args/-/process-nextick-args-2.0.1.tgz",
+      "integrity": "sha512-3ouUOpQhtgrbOa17J7+uxOTpITYWaGP7/AhoR3+A+/1e9skrzelGi/dXzEYyvbxubEF6Wn2ypscTKiKJFFn1ag==",
+      "license": "MIT"
+    },
     "node_modules/protocol-buffers-schema": {
       "version": "3.6.0",
       "resolved": "https://registry.npmjs.org/protocol-buffers-schema/-/protocol-buffers-schema-3.6.0.tgz",
@@ -2721,6 +3017,46 @@
         "quickselect": "^2.0.0"
       }
     },
+    "node_modules/readable-stream": {
+      "version": "4.7.0",
+      "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-4.7.0.tgz",
+      "integrity": "sha512-oIGGmcpTLwPga8Bn6/Z75SVaH1z5dUut2ibSyAMVhmUggWpmDn2dapB0n7f8nwaSiRtepAsfJyfXIO5DCVAODg==",
+      "license": "MIT",
+      "dependencies": {
+        "abort-controller": "^3.0.0",
+        "buffer": "^6.0.3",
+        "events": "^3.3.0",
+        "process": "^0.11.10",
+        "string_decoder": "^1.3.0"
+      },
+      "engines": {
+        "node": "^12.22.0 || ^14.17.0 || >=16.0.0"
+      }
+    },
+    "node_modules/readable-stream/node_modules/buffer": {
+      "version": "6.0.3",
+      "resolved": "https://registry.npmjs.org/buffer/-/buffer-6.0.3.tgz",
+      "integrity": "sha512-FTiCpNxtwiZZHEZbcbTIcZjERVICn9yq/pDFkTl95/AxzD1naBctN7YO68riM/gLSDY7sdrMby8hofADYuuqOA==",
+      "funding": [
+        {
+          "type": "github",
+          "url": "https://github.com/sponsors/feross"
+        },
+        {
+          "type": "patreon",
+          "url": "https://www.patreon.com/feross"
+        },
+        {
+          "type": "consulting",
+          "url": "https://feross.org/support"
+        }
+      ],
+      "license": "MIT",
+      "dependencies": {
+        "base64-js": "^1.3.1",
+        "ieee754": "^1.2.1"
+      }
+    },
     "node_modules/readdirp": {
       "version": "3.6.0",
       "resolved": "https://registry.npmjs.org/readdirp/-/readdirp-3.6.0.tgz",
@@ -2765,6 +3101,12 @@
         "protocol-buffers-schema": "^3.3.1"
       }
     },
+    "node_modules/rfdc": {
+      "version": "1.4.1",
+      "resolved": "https://registry.npmjs.org/rfdc/-/rfdc-1.4.1.tgz",
+      "integrity": "sha512-q1b3N5QkRUWUl7iyylaaj3kOpIT0N2i9MqIEQXP73GVsN9cw3fdx8X63cEmWhJGi2PPCF23Ijp7ktmd39rawIA==",
+      "license": "MIT"
+    },
     "node_modules/rw": {
       "version": "1.3.3",
       "resolved": "https://registry.npmjs.org/rw/-/rw-1.3.3.tgz",
@@ -3006,15 +3348,16 @@
       }
     },
     "node_modules/socks": {
-      "version": "2.7.1",
-      "resolved": "https://registry.npmjs.org/socks/-/socks-2.7.1.tgz",
-      "integrity": "sha512-7maUZy1N7uo6+WVEX6psASxtNlKaNVMlGQKkG/63nEDdLOWNbiUMoLK7X4uYoLhQstau72mLgfEWcXcwsaHbYQ==",
+      "version": "2.8.7",
+      "resolved": "https://registry.npmjs.org/socks/-/socks-2.8.7.tgz",
+      "integrity": "sha512-HLpt+uLy/pxB+bum/9DzAgiKS8CX1EvbWxI4zlmgGCExImLdiad2iCwXT5Z4c9c3Eq8rP2318mPW2c+QbtjK8A==",
+      "license": "MIT",
       "dependencies": {
-        "ip": "^2.0.0",
+        "ip-address": "^10.0.1",
         "smart-buffer": "^4.2.0"
       },
       "engines": {
-        "node": ">= 10.13.0",
+        "node": ">= 10.0.0",
         "npm": ">= 3.0.0"
       }
     },
@@ -3055,6 +3398,15 @@
         "memory-pager": "^1.0.2"
       }
     },
+    "node_modules/split2": {
+      "version": "4.2.0",
+      "resolved": "https://registry.npmjs.org/split2/-/split2-4.2.0.tgz",
+      "integrity": "sha512-UcjcJOWknrNkF6PLX83qcHM6KHgVKNkV62Y8a5uYDVv9ydGQVwAHMKqHdJje1VTWpljG0WYpCDhrCdAOYH4TWg==",
+      "license": "ISC",
+      "engines": {
+        "node": ">= 10.x"
+      }
+    },
     "node_modules/statuses": {
       "version": "2.0.1",
       "resolved": "https://registry.npmjs.org/statuses/-/statuses-2.0.1.tgz",
@@ -3063,6 +3415,15 @@
         "node": ">= 0.8"
       }
     },
+    "node_modules/string_decoder": {
+      "version": "1.3.0",
+      "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.3.0.tgz",
+      "integrity": "sha512-hkRX8U1WjJFd8LsDJ2yQ/wWWxaopEsABU1XfkM8A+j0+85JAGppt16cr1Whg6KIbb4okU6Mql6BOj+uup/wKeA==",
+      "license": "MIT",
+      "dependencies": {
+        "safe-buffer": "~5.2.0"
+      }
+    },
     "node_modules/stripe": {
       "version": "13.4.0",
       "resolved": "https://registry.npmjs.org/stripe/-/stripe-13.4.0.tgz",
@@ -3217,10 +3578,10 @@
       }
     },
     "node_modules/tslib": {
-      "version": "2.6.2",
-      "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.6.2.tgz",
-      "integrity": "sha512-AEYxH93jGFPn/a2iVAwW87VuUIkR1FVUKB77NwMF7nBTDkDrrT/Hpt/IrCJ0QXhW27jTBDcf5ZY7w6RiqTMw2Q==",
-      "optional": true
+      "version": "2.8.1",
+      "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.8.1.tgz",
+      "integrity": "sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w==",
+      "license": "0BSD"
     },
     "node_modules/tsscmp": {
       "version": "1.0.6",
@@ -3243,6 +3604,12 @@
         "node": ">= 0.6"
       }
     },
+    "node_modules/typedarray": {
+      "version": "0.0.6",
+      "resolved": "https://registry.npmjs.org/typedarray/-/typedarray-0.0.6.tgz",
+      "integrity": "sha512-/aCDEGatGvZ2BIk+HmLf4ifCJFwvKFNb9/JeZPMulfgFracn9QFcAf5GO8B/mweUjSoblS5In0cWhqpfs/5PQA==",
+      "license": "MIT"
+    },
     "node_modules/undefsafe": {
       "version": "2.0.5",
       "resolved": "https://registry.npmjs.org/undefsafe/-/undefsafe-2.0.5.tgz",
@@ -3264,6 +3631,12 @@
         "inherits": "2.0.3"
       }
     },
+    "node_modules/util-deprecate": {
+      "version": "1.0.2",
+      "resolved": "https://registry.npmjs.org/util-deprecate/-/util-deprecate-1.0.2.tgz",
+      "integrity": "sha512-EPD5q1uXyFxJpCrLnCc1nHnq3gOa6DZBocAIiI2TaSCA7VCJ1UJDMagCzIkXNsUYfD1daK//LTEQ8xiIbrHtcw==",
+      "license": "MIT"
+    },
     "node_modules/util/node_modules/inherits": {
       "version": "2.0.3",
       "resolved": "https://registry.npmjs.org/inherits/-/inherits-2.0.3.tgz",
@@ -3319,6 +3692,74 @@
         "node": ">=12"
       }
     },
+    "node_modules/worker-factory": {
+      "version": "7.0.49",
+      "resolved": "https://registry.npmjs.org/worker-factory/-/worker-factory-7.0.49.tgz",
+      "integrity": "sha512-lW7tpgy6aUv2dFsQhv1yv+XFzdkCf/leoKRTGMPVK5/die6RrUjqgJHJf556qO+ZfytNG6wPXc17E8zzsOLUDw==",
+      "license": "MIT",
+      "dependencies": {
+        "@babel/runtime": "^7.29.2",
+        "fast-unique-numbers": "^9.0.27",
+        "tslib": "^2.8.1"
+      }
+    },
+    "node_modules/worker-timers": {
+      "version": "8.0.31",
+      "resolved": "https://registry.npmjs.org/worker-timers/-/worker-timers-8.0.31.tgz",
+      "integrity": "sha512-ngkq5S6JuZyztom8tDgBzorLo9byhBMko/sXfgiUD945AuzKGg1GCgDMCC3NaYkicLpGKXutONM36wEX8UbBCA==",
+      "license": "MIT",
+      "dependencies": {
+        "@babel/runtime": "^7.29.2",
+        "tslib": "^2.8.1",
+        "worker-timers-broker": "^8.0.16",
+        "worker-timers-worker": "^9.0.14"
+      }
+    },
+    "node_modules/worker-timers-broker": {
+      "version": "8.0.16",
+      "resolved": "https://registry.npmjs.org/worker-timers-broker/-/worker-timers-broker-8.0.16.tgz",
+      "integrity": "sha512-JyP3AvUGyPGbBGW7XiUewm2+0pN/aYo1QpVf5kdXAfkDZcN3p7NbWrG6XnyDEpDIvfHk/+LCnOW/NsuiU9riYA==",
+      "license": "MIT",
+      "dependencies": {
+        "@babel/runtime": "^7.29.2",
+        "broker-factory": "^3.1.14",
+        "fast-unique-numbers": "^9.0.27",
+        "tslib": "^2.8.1",
+        "worker-timers-worker": "^9.0.14"
+      }
+    },
+    "node_modules/worker-timers-worker": {
+      "version": "9.0.14",
+      "resolved": "https://registry.npmjs.org/worker-timers-worker/-/worker-timers-worker-9.0.14.tgz",
+      "integrity": "sha512-/qF06C60sXmSLfUl7WglvrDIbspmPOM8UrG63Dnn4bi2x4/DfqHS/+dxF5B+MdHnYO5tVuZYLHdAodrKdabTIg==",
+      "license": "MIT",
+      "dependencies": {
+        "@babel/runtime": "^7.29.2",
+        "tslib": "^2.8.1",
+        "worker-factory": "^7.0.49"
+      }
+    },
+    "node_modules/ws": {
+      "version": "8.20.0",
+      "resolved": "https://registry.npmjs.org/ws/-/ws-8.20.0.tgz",
+      "integrity": "sha512-sAt8BhgNbzCtgGbt2OxmpuryO63ZoDk/sqaB/znQm94T4fCEsy/yV+7CdC1kJhOU9lboAEU7R3kquuycDoibVA==",
+      "license": "MIT",
+      "engines": {
+        "node": ">=10.0.0"
+      },
+      "peerDependencies": {
+        "bufferutil": "^4.0.1",
+        "utf-8-validate": ">=5.0.2"
+      },
+      "peerDependenciesMeta": {
+        "bufferutil": {
+          "optional": true
+        },
+        "utf-8-validate": {
+          "optional": true
+        }
+      }
+    },
     "node_modules/xml-utils": {
       "version": "1.7.0",
       "resolved": "https://registry.npmjs.org/xml-utils/-/xml-utils-1.7.0.tgz",
@@ -3881,6 +4322,11 @@
         "tslib": "^2.3.1"
       }
     },
+    "@babel/runtime": {
+      "version": "7.29.2",
+      "resolved": "https://registry.npmjs.org/@babel/runtime/-/runtime-7.29.2.tgz",
+      "integrity": "sha512-JiDShH45zKHWyGe4ZNVRrCjBz8Nh9TMmZG1kh4QTK8hCBTWBi8Da+i7s1fJw7/lYpM4ccepSNfqzZ/QvABBi5g=="
+    },
     "@mapbox/jsonlint-lines-primitives": {
       "version": "2.0.2",
       "resolved": "https://registry.npmjs.org/@mapbox/jsonlint-lines-primitives/-/jsonlint-lines-primitives-2.0.2.tgz",
@@ -4394,6 +4840,14 @@
       "resolved": "https://registry.npmjs.org/@types/node/-/node-20.5.2.tgz",
       "integrity": "sha512-5j/lXt7unfPOUlrKC34HIaedONleyLtwkKggiD/0uuMfT8gg2EOpg0dz4lCD15Ga7muC+1WzJZAjIB9simWd6Q=="
     },
+    "@types/readable-stream": {
+      "version": "4.0.23",
+      "resolved": "https://registry.npmjs.org/@types/readable-stream/-/readable-stream-4.0.23.tgz",
+      "integrity": "sha512-wwXrtQvbMHxCbBgjHaMGEmImFTQxxpfMOR/ZoQnXxB1woqkUbdLGFDgauo00Py9IudiaqSeiBiulSV9i6XIPig==",
+      "requires": {
+        "@types/node": "*"
+      }
+    },
     "@types/webidl-conversions": {
       "version": "7.0.0",
       "resolved": "https://registry.npmjs.org/@types/webidl-conversions/-/webidl-conversions-7.0.0.tgz",
@@ -4408,6 +4862,14 @@
         "@types/webidl-conversions": "*"
       }
     },
+    "@types/ws": {
+      "version": "8.18.1",
+      "resolved": "https://registry.npmjs.org/@types/ws/-/ws-8.18.1.tgz",
+      "integrity": "sha512-ThVF6DCVhA8kUGy+aazFQ4kXQ7E1Ty7A3ypFOe0IcJV8O/M511G99AW24irKrW56Wt44yG9+ij8FaqoBGkuBXg==",
+      "requires": {
+        "@types/node": "*"
+      }
+    },
     "@yr/monotone-cubic-spline": {
       "version": "1.0.3",
       "resolved": "https://registry.npmjs.org/@yr/monotone-cubic-spline/-/monotone-cubic-spline-1.0.3.tgz",
@@ -4418,6 +4880,14 @@
       "resolved": "https://registry.npmjs.org/abbrev/-/abbrev-1.1.1.tgz",
       "integrity": "sha512-nne9/IiQ/hzIhY6pdDnbBtz7DjPTKrY00P/zvPSm5pOFkl6xuGrGnXn/VtTNNfNtAfZ9/1RtehkszU9qcTii0Q=="
     },
+    "abort-controller": {
+      "version": "3.0.0",
+      "resolved": "https://registry.npmjs.org/abort-controller/-/abort-controller-3.0.0.tgz",
+      "integrity": "sha512-h8lQ8tacZYnR3vNQTgibj+tODHI5/+l06Au2Pcriv/Gmet0eaj4TwWH41sO9wnHDiQsEj19q0drzdWdeAHtweg==",
+      "requires": {
+        "event-target-shim": "^5.0.0"
+      }
+    },
     "accepts": {
       "version": "1.3.8",
       "resolved": "https://registry.npmjs.org/accepts/-/accepts-1.3.8.tgz",
@@ -4495,6 +4965,28 @@
       "resolved": "https://registry.npmjs.org/binary-extensions/-/binary-extensions-2.2.0.tgz",
       "integrity": "sha512-jDctJ/IVQbZoJykoeHbhXpOlNBqGNcwXJKJog42E5HDPUwQTSdjCHdihjj0DlnheQ7blbT6dHOafNAiS8ooQKA=="
     },
+    "bl": {
+      "version": "6.1.6",
+      "resolved": "https://registry.npmjs.org/bl/-/bl-6.1.6.tgz",
+      "integrity": "sha512-jLsPgN/YSvPUg9UX0Kd73CXpm2Psg9FxMeCSXnk3WBO3CMT10JMwijubhGfHCnFu6TPn1ei3b975dxv7K2pWVg==",
+      "requires": {
+        "@types/readable-stream": "^4.0.0",
+        "buffer": "^6.0.3",
+        "inherits": "^2.0.4",
+        "readable-stream": "^4.2.0"
+      },
+      "dependencies": {
+        "buffer": {
+          "version": "6.0.3",
+          "resolved": "https://registry.npmjs.org/buffer/-/buffer-6.0.3.tgz",
+          "integrity": "sha512-FTiCpNxtwiZZHEZbcbTIcZjERVICn9yq/pDFkTl95/AxzD1naBctN7YO68riM/gLSDY7sdrMby8hofADYuuqOA==",
+          "requires": {
+            "base64-js": "^1.3.1",
+            "ieee754": "^1.2.1"
+          }
+        }
+      }
+    },
     "body-parser": {
       "version": "1.20.1",
       "resolved": "https://registry.npmjs.org/body-parser/-/body-parser-1.20.1.tgz",
@@ -4552,6 +5044,17 @@
         "fill-range": "^7.0.1"
       }
     },
+    "broker-factory": {
+      "version": "3.1.14",
+      "resolved": "https://registry.npmjs.org/broker-factory/-/broker-factory-3.1.14.tgz",
+      "integrity": "sha512-L45k5HMbPIrMid0nTOZ/UPXG/c0aRuQKVrSDFIb1zOkvfiyHgYmIjc3cSiN1KwQIvRDOtKE0tfb3I9EZ3CmpQQ==",
+      "requires": {
+        "@babel/runtime": "^7.29.2",
+        "fast-unique-numbers": "^9.0.27",
+        "tslib": "^2.8.1",
+        "worker-factory": "^7.0.49"
+      }
+    },
     "bson": {
       "version": "4.7.2",
       "resolved": "https://registry.npmjs.org/bson/-/bson-4.7.2.tgz",
@@ -4574,6 +5077,11 @@
       "resolved": "https://registry.npmjs.org/buffer-equal-constant-time/-/buffer-equal-constant-time-1.0.1.tgz",
       "integrity": "sha512-zRpUiDwd/xk6ADqPMATG8vc9VPrkck7T07OIx0gnjmJAnHnTVXNQG3vfvWNuiZIkwu9KrKdA1iJKfsfTVxE6NA=="
     },
+    "buffer-from": {
+      "version": "1.1.2",
+      "resolved": "https://registry.npmjs.org/buffer-from/-/buffer-from-1.1.2.tgz",
+      "integrity": "sha512-E+XQCRwSbaaiChtv6k6Dwgc+bx+Bs6vuKJHHl5kox/BaKbhiXzqQOwK4cO22yElGp2OCmjwVhT3HmxgyPGnJfQ=="
+    },
     "bytes": {
       "version": "3.1.2",
       "resolved": "https://registry.npmjs.org/bytes/-/bytes-3.1.2.tgz",
@@ -4621,11 +5129,39 @@
         "delayed-stream": "~1.0.0"
       }
     },
+    "commist": {
+      "version": "3.2.0",
+      "resolved": "https://registry.npmjs.org/commist/-/commist-3.2.0.tgz",
+      "integrity": "sha512-4PIMoPniho+LqXmpS5d3NuGYncG6XWlkBSVGiWycL22dd42OYdUGil2CWuzklaJoNxyxUSpO4MKIBU94viWNAw=="
+    },
     "concat-map": {
       "version": "0.0.1",
       "resolved": "https://registry.npmjs.org/concat-map/-/concat-map-0.0.1.tgz",
       "integrity": "sha512-/Srv4dswyQNBfohGpz9o6Yb3Gz3SrUDqBH5rTuhGR7ahtlbYKnVxw2bCFMRljaA7EXHaXZ8wsHdodFvbkhKmqg=="
     },
+    "concat-stream": {
+      "version": "2.0.0",
+      "resolved": "https://registry.npmjs.org/concat-stream/-/concat-stream-2.0.0.tgz",
+      "integrity": "sha512-MWufYdFw53ccGjCA+Ol7XJYpAlW6/prSMzuPOTRnJGcGzuhLn4Scrz7qf6o8bROZ514ltazcIFJZevcfbo0x7A==",
+      "requires": {
+        "buffer-from": "^1.0.0",
+        "inherits": "^2.0.3",
+        "readable-stream": "^3.0.2",
+        "typedarray": "^0.0.6"
+      },
+      "dependencies": {
+        "readable-stream": {
+          "version": "3.6.2",
+          "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-3.6.2.tgz",
+          "integrity": "sha512-9u/sniCrY3D5WdsERHzHE4G2YCXqoG5FTHUiCC4SIbr6XcLZBY05ya9EKjYek9O5xOAwjGq+1JdGBAS7Q9ScoA==",
+          "requires": {
+            "inherits": "^2.0.3",
+            "string_decoder": "^1.1.1",
+            "util-deprecate": "^1.0.1"
+          }
+        }
+      }
+    },
     "content-disposition": {
       "version": "0.5.4",
       "resolved": "https://registry.npmjs.org/content-disposition/-/content-disposition-0.5.4.tgz",
@@ -4775,6 +5311,16 @@
       "resolved": "https://registry.npmjs.org/etag/-/etag-1.8.1.tgz",
       "integrity": "sha512-aIL5Fx7mawVa300al2BnEE4iNvo1qETxLrPI/o05L7z6go7fCw1J6EQmbK4FmJ2AS7kgVF/KEZWufBfdClMcPg=="
     },
+    "event-target-shim": {
+      "version": "5.0.1",
+      "resolved": "https://registry.npmjs.org/event-target-shim/-/event-target-shim-5.0.1.tgz",
+      "integrity": "sha512-i/2XbnSz/uxRCU6+NdVJgKWDTM427+MqYbkQzD321DuCQJUqOuJKIA0IM2+W2xtYHdKOmZ4dR6fExsd4SXL+WQ=="
+    },
+    "events": {
+      "version": "3.3.0",
+      "resolved": "https://registry.npmjs.org/events/-/events-3.3.0.tgz",
+      "integrity": "sha512-mQw+2fkQbALzQ7V0MY0IqdnXNOeTtP4r0lN9z7AAawCXgqea7bDii20AYrIBrFd/Hx0M2Ocz6S111CaFkUcb0Q=="
+    },
     "express": {
       "version": "4.18.2",
       "resolved": "https://registry.npmjs.org/express/-/express-4.18.2.tgz",
@@ -4833,6 +5379,15 @@
       "resolved": "https://registry.npmjs.org/express-mongo-sanitize/-/express-mongo-sanitize-2.2.0.tgz",
       "integrity": "sha512-PZBs5nwhD6ek9ZuP+W2xmpvcrHwXZxD5GdieX2dsjPbAbH4azOkrHbycBud2QRU+YQF1CT+pki/lZGedHgo/dQ=="
     },
+    "fast-unique-numbers": {
+      "version": "9.0.27",
+      "resolved": "https://registry.npmjs.org/fast-unique-numbers/-/fast-unique-numbers-9.0.27.tgz",
+      "integrity": "sha512-nDA9ADeINN8SA2u2wCtU+siWFTTDqQR37XvgPIDDmboWQeExz7X0mImxuaN+kJddliIqy2FpVRmnvRZ+j8i1/A==",
+      "requires": {
+        "@babel/runtime": "^7.29.2",
+        "tslib": "^2.8.1"
+      }
+    },
     "fast-xml-parser": {
       "version": "4.2.5",
       "resolved": "https://registry.npmjs.org/fast-xml-parser/-/fast-xml-parser-4.2.5.tgz",
@@ -4975,6 +5530,11 @@
       "resolved": "https://registry.npmjs.org/helmet/-/helmet-7.0.0.tgz",
       "integrity": "sha512-MsIgYmdBh460ZZ8cJC81q4XJknjG567wzEmv46WOBblDb6TUd3z8/GhgmsM9pn8g2B80tAJ4m5/d3Bi1KrSUBQ=="
     },
+    "help-me": {
+      "version": "5.0.0",
+      "resolved": "https://registry.npmjs.org/help-me/-/help-me-5.0.0.tgz",
+      "integrity": "sha512-7xgomUX6ADmcYzFik0HzAxh/73YlKR9bmFzf51CZwR+b6YtzU2m0u49hQCqV6SvlqIqsaxovfwdvbnsw3b/zpg=="
+    },
     "http-errors": {
       "version": "2.0.0",
       "resolved": "https://registry.npmjs.org/http-errors/-/http-errors-2.0.0.tgz",
@@ -5010,10 +5570,10 @@
       "resolved": "https://registry.npmjs.org/inherits/-/inherits-2.0.4.tgz",
       "integrity": "sha512-k/vGaX4/Yla3WzyMCvTQOXYeIHvqOKtnqBduzTHpzpQZzAskKMhZ2K+EnBiSM9zGSoIFeMpXKxa4dYeZIQqewQ=="
     },
-    "ip": {
-      "version": "2.0.0",
-      "resolved": "https://registry.npmjs.org/ip/-/ip-2.0.0.tgz",
-      "integrity": "sha512-WKa+XuLG1A1R0UWhl2+1XQSi+fZWMsYKffMZTTYsiZaUD8k2yDAj5atimTUD2TZkyCkNEeYE5NhFZmupOGtjYQ=="
+    "ip-address": {
+      "version": "10.1.0",
+      "resolved": "https://registry.npmjs.org/ip-address/-/ip-address-10.1.0.tgz",
+      "integrity": "sha512-XXADHxXmvT9+CRxhXg56LJovE+bmWnEWB78LB83VZTprKTmaC5QfruXocxzTZ2Kl0DNwKuBdlIhjL8LeY8Sf8Q=="
     },
     "ipaddr.js": {
       "version": "1.9.1",
@@ -5051,6 +5611,11 @@
       "resolved": "https://registry.npmjs.org/jquery/-/jquery-3.6.4.tgz",
       "integrity": "sha512-v28EW9DWDFpzcD9O5iyJXg3R3+q+mET5JhnjJzQUZMHOv67bpSIHq81GEYpPNZHG+XXHsfSme3nxp/hndKEcsQ=="
     },
+    "js-sdsl": {
+      "version": "4.3.0",
+      "resolved": "https://registry.npmjs.org/js-sdsl/-/js-sdsl-4.3.0.tgz",
+      "integrity": "sha512-mifzlm2+5nZ+lEcLJMoBK0/IH/bDg8XnJfd/Wq6IP+xoCjLZsTOnV2QpxlVbX9bMnkl5PdEjNtBJ9Cj1NjifhQ=="
+    },
     "json-stringify-pretty-compact": {
       "version": "2.0.0",
       "resolved": "https://registry.npmjs.org/json-stringify-pretty-compact/-/json-stringify-pretty-compact-2.0.0.tgz",
@@ -5234,6 +5799,64 @@
       "resolved": "https://registry.npmjs.org/mpath/-/mpath-0.9.0.tgz",
       "integrity": "sha512-ikJRQTk8hw5DEoFVxHG1Gn9T/xcjtdnOKIU1JTmGjZZlg9LST2mBLmcX3/ICIbgJydT2GOc15RnNy5mHmzfSew=="
     },
+    "mqtt": {
+      "version": "5.15.1",
+      "resolved": "https://registry.npmjs.org/mqtt/-/mqtt-5.15.1.tgz",
+      "integrity": "sha512-V1WnkGuJh3ec9QXzy5Iylw8OOBK+Xu1WhxcQ9mMpLThG+/JZIMV1PgLNRgIiqXhZnvnVLsuyxHl5A/3bHHbcAA==",
+      "requires": {
+        "@types/readable-stream": "^4.0.21",
+        "@types/ws": "^8.18.1",
+        "commist": "^3.2.0",
+        "concat-stream": "^2.0.0",
+        "debug": "^4.4.1",
+        "help-me": "^5.0.0",
+        "lru-cache": "^10.4.3",
+        "minimist": "^1.2.8",
+        "mqtt-packet": "^9.0.2",
+        "number-allocator": "^1.0.14",
+        "readable-stream": "^4.7.0",
+        "rfdc": "^1.4.1",
+        "socks": "^2.8.6",
+        "split2": "^4.2.0",
+        "worker-timers": "^8.0.23",
+        "ws": "^8.18.3"
+      },
+      "dependencies": {
+        "debug": {
+          "version": "4.4.3",
+          "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.3.tgz",
+          "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
+          "requires": {
+            "ms": "^2.1.3"
+          }
+        },
+        "lru-cache": {
+          "version": "10.4.3",
+          "resolved": "https://registry.npmjs.org/lru-cache/-/lru-cache-10.4.3.tgz",
+          "integrity": "sha512-JNAzZcXrCt42VGLuYz0zfAzDfAvJWW6AfYlDBQyDV5DClI2m5sAmK+OIO7s59XfsRsWHp02jAJrRadPRGTt6SQ=="
+        }
+      }
+    },
+    "mqtt-packet": {
+      "version": "9.0.2",
+      "resolved": "https://registry.npmjs.org/mqtt-packet/-/mqtt-packet-9.0.2.tgz",
+      "integrity": "sha512-MvIY0B8/qjq7bKxdN1eD+nrljoeaai+qjLJgfRn3TiMuz0pamsIWY2bFODPZMSNmabsLANXsLl4EMoWvlaTZWA==",
+      "requires": {
+        "bl": "^6.0.8",
+        "debug": "^4.3.4",
+        "process-nextick-args": "^2.0.1"
+      },
+      "dependencies": {
+        "debug": {
+          "version": "4.4.3",
+          "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.3.tgz",
+          "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
+          "requires": {
+            "ms": "^2.1.3"
+          }
+        }
+      }
+    },
     "mquery": {
       "version": "4.0.3",
       "resolved": "https://registry.npmjs.org/mquery/-/mquery-4.0.3.tgz",
@@ -5302,6 +5925,25 @@
       "resolved": "https://registry.npmjs.org/normalize-path/-/normalize-path-3.0.0.tgz",
       "integrity": "sha512-6eZs5Ls3WtCisHWp9S2GUy8dqkpGi4BVSz3GaqiE6ezub0512ESztXUwUB6C6IKbQkY2Pnb/mD4WYojCRwcwLA=="
     },
+    "number-allocator": {
+      "version": "1.0.14",
+      "resolved": "https://registry.npmjs.org/number-allocator/-/number-allocator-1.0.14.tgz",
+      "integrity": "sha512-OrL44UTVAvkKdOdRQZIJpLkAdjXGTRda052sN4sO77bKEzYYqWKMBjQvrJFzqygI99gL6Z4u2xctPW1tB8ErvA==",
+      "requires": {
+        "debug": "^4.3.1",
+        "js-sdsl": "4.3.0"
+      },
+      "dependencies": {
+        "debug": {
+          "version": "4.4.3",
+          "resolved": "https://registry.npmjs.org/debug/-/debug-4.4.3.tgz",
+          "integrity": "sha512-RGwwWnwQvkVfavKVt22FGLw+xYSdzARwm0ru6DhTVA3umU5hZc28V3kO4stgYryrTlLpuvgI9GiijltAjNbcqA==",
+          "requires": {
+            "ms": "^2.1.3"
+          }
+        }
+      }
+    },
     "object-assign": {
       "version": "4.1.1",
       "resolved": "https://registry.npmjs.org/object-assign/-/object-assign-4.1.1.tgz",
@@ -5394,6 +6036,11 @@
       "resolved": "https://registry.npmjs.org/process/-/process-0.11.10.tgz",
       "integrity": "sha512-cdGef/drWFoydD1JsMzuFf8100nZl+GT+yacc2bEced5f9Rjk4z+WtFUTBu9PhOi9j/jfmBPu0mMEY4wIdAF8A=="
     },
+    "process-nextick-args": {
+      "version": "2.0.1",
+      "resolved": "https://registry.npmjs.org/process-nextick-args/-/process-nextick-args-2.0.1.tgz",
+      "integrity": "sha512-3ouUOpQhtgrbOa17J7+uxOTpITYWaGP7/AhoR3+A+/1e9skrzelGi/dXzEYyvbxubEF6Wn2ypscTKiKJFFn1ag=="
+    },
     "protocol-buffers-schema": {
       "version": "3.6.0",
       "resolved": "https://registry.npmjs.org/protocol-buffers-schema/-/protocol-buffers-schema-3.6.0.tgz",
@@ -5465,6 +6112,29 @@
         "quickselect": "^2.0.0"
       }
     },
+    "readable-stream": {
+      "version": "4.7.0",
+      "resolved": "https://registry.npmjs.org/readable-stream/-/readable-stream-4.7.0.tgz",
+      "integrity": "sha512-oIGGmcpTLwPga8Bn6/Z75SVaH1z5dUut2ibSyAMVhmUggWpmDn2dapB0n7f8nwaSiRtepAsfJyfXIO5DCVAODg==",
+      "requires": {
+        "abort-controller": "^3.0.0",
+        "buffer": "^6.0.3",
+        "events": "^3.3.0",
+        "process": "^0.11.10",
+        "string_decoder": "^1.3.0"
+      },
+      "dependencies": {
+        "buffer": {
+          "version": "6.0.3",
+          "resolved": "https://registry.npmjs.org/buffer/-/buffer-6.0.3.tgz",
+          "integrity": "sha512-FTiCpNxtwiZZHEZbcbTIcZjERVICn9yq/pDFkTl95/AxzD1naBctN7YO68riM/gLSDY7sdrMby8hofADYuuqOA==",
+          "requires": {
+            "base64-js": "^1.3.1",
+            "ieee754": "^1.2.1"
+          }
+        }
+      }
+    },
     "readdirp": {
       "version": "3.6.0",
       "resolved": "https://registry.npmjs.org/readdirp/-/readdirp-3.6.0.tgz",
@@ -5499,6 +6169,11 @@
         "protocol-buffers-schema": "^3.3.1"
       }
     },
+    "rfdc": {
+      "version": "1.4.1",
+      "resolved": "https://registry.npmjs.org/rfdc/-/rfdc-1.4.1.tgz",
+      "integrity": "sha512-q1b3N5QkRUWUl7iyylaaj3kOpIT0N2i9MqIEQXP73GVsN9cw3fdx8X63cEmWhJGi2PPCF23Ijp7ktmd39rawIA=="
+    },
     "rw": {
       "version": "1.3.3",
       "resolved": "https://registry.npmjs.org/rw/-/rw-1.3.3.tgz",
@@ -5697,11 +6372,11 @@
       "integrity": "sha512-94hK0Hh8rPqQl2xXc3HsaBoOXKV20MToPkcXvwbISWLEs+64sBq5kFgn2kJDHb1Pry9yrP0dxrCI9RRci7RXKg=="
     },
     "socks": {
-      "version": "2.7.1",
-      "resolved": "https://registry.npmjs.org/socks/-/socks-2.7.1.tgz",
-      "integrity": "sha512-7maUZy1N7uo6+WVEX6psASxtNlKaNVMlGQKkG/63nEDdLOWNbiUMoLK7X4uYoLhQstau72mLgfEWcXcwsaHbYQ==",
+      "version": "2.8.7",
+      "resolved": "https://registry.npmjs.org/socks/-/socks-2.8.7.tgz",
+      "integrity": "sha512-HLpt+uLy/pxB+bum/9DzAgiKS8CX1EvbWxI4zlmgGCExImLdiad2iCwXT5Z4c9c3Eq8rP2318mPW2c+QbtjK8A==",
       "requires": {
-        "ip": "^2.0.0",
+        "ip-address": "^10.0.1",
         "smart-buffer": "^4.2.0"
       }
     },
@@ -5733,11 +6408,24 @@
         "memory-pager": "^1.0.2"
       }
     },
+    "split2": {
+      "version": "4.2.0",
+      "resolved": "https://registry.npmjs.org/split2/-/split2-4.2.0.tgz",
+      "integrity": "sha512-UcjcJOWknrNkF6PLX83qcHM6KHgVKNkV62Y8a5uYDVv9ydGQVwAHMKqHdJje1VTWpljG0WYpCDhrCdAOYH4TWg=="
+    },
     "statuses": {
       "version": "2.0.1",
       "resolved": "https://registry.npmjs.org/statuses/-/statuses-2.0.1.tgz",
       "integrity": "sha512-RwNA9Z/7PrK06rYLIzFMlaF+l73iwpzsqRIFgbMLbTcLD6cOao82TaWefPXQvB2fOC4AjuYSEndS7N/mTCbkdQ=="
     },
+    "string_decoder": {
+      "version": "1.3.0",
+      "resolved": "https://registry.npmjs.org/string_decoder/-/string_decoder-1.3.0.tgz",
+      "integrity": "sha512-hkRX8U1WjJFd8LsDJ2yQ/wWWxaopEsABU1XfkM8A+j0+85JAGppt16cr1Whg6KIbb4okU6Mql6BOj+uup/wKeA==",
+      "requires": {
+        "safe-buffer": "~5.2.0"
+      }
+    },
     "stripe": {
       "version": "13.4.0",
       "resolved": "https://registry.npmjs.org/stripe/-/stripe-13.4.0.tgz",
@@ -5855,10 +6543,9 @@
       }
     },
     "tslib": {
-      "version": "2.6.2",
-      "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.6.2.tgz",
-      "integrity": "sha512-AEYxH93jGFPn/a2iVAwW87VuUIkR1FVUKB77NwMF7nBTDkDrrT/Hpt/IrCJ0QXhW27jTBDcf5ZY7w6RiqTMw2Q==",
-      "optional": true
+      "version": "2.8.1",
+      "resolved": "https://registry.npmjs.org/tslib/-/tslib-2.8.1.tgz",
+      "integrity": "sha512-oJFu94HQb+KVduSUQL7wnpmqnfmLsOA/nAh6b6EH0wCEoK0/mPeXU6c3wKDV83MkOuHPRHtSXKKU99IBazS/2w=="
     },
     "tsscmp": {
       "version": "1.0.6",
@@ -5874,6 +6561,11 @@
         "mime-types": "~2.1.24"
       }
     },
+    "typedarray": {
+      "version": "0.0.6",
+      "resolved": "https://registry.npmjs.org/typedarray/-/typedarray-0.0.6.tgz",
+      "integrity": "sha512-/aCDEGatGvZ2BIk+HmLf4ifCJFwvKFNb9/JeZPMulfgFracn9QFcAf5GO8B/mweUjSoblS5In0cWhqpfs/5PQA=="
+    },
     "undefsafe": {
       "version": "2.0.5",
       "resolved": "https://registry.npmjs.org/undefsafe/-/undefsafe-2.0.5.tgz",
@@ -5899,6 +6591,11 @@
         }
       }
     },
+    "util-deprecate": {
+      "version": "1.0.2",
+      "resolved": "https://registry.npmjs.org/util-deprecate/-/util-deprecate-1.0.2.tgz",
+      "integrity": "sha512-EPD5q1uXyFxJpCrLnCc1nHnq3gOa6DZBocAIiI2TaSCA7VCJ1UJDMagCzIkXNsUYfD1daK//LTEQ8xiIbrHtcw=="
+    },
     "utils-merge": {
       "version": "1.0.1",
       "resolved": "https://registry.npmjs.org/utils-merge/-/utils-merge-1.0.1.tgz",
@@ -5934,6 +6631,55 @@
         "webidl-conversions": "^7.0.0"
       }
     },
+    "worker-factory": {
+      "version": "7.0.49",
+      "resolved": "https://registry.npmjs.org/worker-factory/-/worker-factory-7.0.49.tgz",
+      "integrity": "sha512-lW7tpgy6aUv2dFsQhv1yv+XFzdkCf/leoKRTGMPVK5/die6RrUjqgJHJf556qO+ZfytNG6wPXc17E8zzsOLUDw==",
+      "requires": {
+        "@babel/runtime": "^7.29.2",
+        "fast-unique-numbers": "^9.0.27",
+        "tslib": "^2.8.1"
+      }
+    },
+    "worker-timers": {
+      "version": "8.0.31",
+      "resolved": "https://registry.npmjs.org/worker-timers/-/worker-timers-8.0.31.tgz",
+      "integrity": "sha512-ngkq5S6JuZyztom8tDgBzorLo9byhBMko/sXfgiUD945AuzKGg1GCgDMCC3NaYkicLpGKXutONM36wEX8UbBCA==",
+      "requires": {
+        "@babel/runtime": "^7.29.2",
+        "tslib": "^2.8.1",
+        "worker-timers-broker": "^8.0.16",
+        "worker-timers-worker": "^9.0.14"
+      }
+    },
+    "worker-timers-broker": {
+      "version": "8.0.16",
+      "resolved": "https://registry.npmjs.org/worker-timers-broker/-/worker-timers-broker-8.0.16.tgz",
+      "integrity": "sha512-JyP3AvUGyPGbBGW7XiUewm2+0pN/aYo1QpVf5kdXAfkDZcN3p7NbWrG6XnyDEpDIvfHk/+LCnOW/NsuiU9riYA==",
+      "requires": {
+        "@babel/runtime": "^7.29.2",
+        "broker-factory": "^3.1.14",
+        "fast-unique-numbers": "^9.0.27",
+        "tslib": "^2.8.1",
+        "worker-timers-worker": "^9.0.14"
+      }
+    },
+    "worker-timers-worker": {
+      "version": "9.0.14",
+      "resolved": "https://registry.npmjs.org/worker-timers-worker/-/worker-timers-worker-9.0.14.tgz",
+      "integrity": "sha512-/qF06C60sXmSLfUl7WglvrDIbspmPOM8UrG63Dnn4bi2x4/DfqHS/+dxF5B+MdHnYO5tVuZYLHdAodrKdabTIg==",
+      "requires": {
+        "@babel/runtime": "^7.29.2",
+        "tslib": "^2.8.1",
+        "worker-factory": "^7.0.49"
+      }
+    },
+    "ws": {
+      "version": "8.20.0",
+      "resolved": "https://registry.npmjs.org/ws/-/ws-8.20.0.tgz",
+      "integrity": "sha512-sAt8BhgNbzCtgGbt2OxmpuryO63ZoDk/sqaB/znQm94T4fCEsy/yV+7CdC1kJhOU9lboAEU7R3kquuycDoibVA==",
+      "requires": {}
+    },
     "xml-utils": {
       "version": "1.7.0",
       "resolved": "https://registry.npmjs.org/xml-utils/-/xml-utils-1.7.0.tgz",
diff --git a/src/Components/HMI/ui/package.json b/src/Components/HMI/ui/package.json
index c4acef7fe..a1d7fe50e 100644
--- a/src/Components/HMI/ui/package.json
+++ b/src/Components/HMI/ui/package.json
@@ -24,6 +24,7 @@
     "jquery": "^3.6.4",
     "jsonwebtoken": "^9.0.1",
     "mongoose": "^6.10.0",
+    "mqtt": "^5.15.1",
     "nodemailer": "^6.9.1",
     "nodemon": "^2.0.22",
     "ol": "^7.3.0",
diff --git a/src/Components/HMI/ui/routes/map.routes.js b/src/Components/HMI/ui/routes/map.routes.js
index bd349c153..5df10e5b0 100644
--- a/src/Components/HMI/ui/routes/map.routes.js
+++ b/src/Components/HMI/ui/routes/map.routes.js
@@ -1,255 +1,331 @@
 const { verifySignUp, client } = require("../middleware");
 const axios = require("axios");
-const mqtt = require('mqtt');
+const mqtt = require("mqtt");
 const fs = require("fs");
+const path = require("path");
 require("dotenv").config();
- 
+
 const API_BASE_URL = `http://${process.env.API_HOST || "localhost"}:9000`;
 const MESSAGE_API_URL = `${API_BASE_URL}/hmi`;
- 
+
 const MQTT_BROKER = "mqtt://broker.hivemq.com";
 const MQTT_TOPIC = "iot/data/test";
- 
+
 let token;
 let latestSensorData = null;
- 
+
+// Ensure audio output directory exists inside the HMI app
+const audioDir = path.join(__dirname, "..", "audioLocal");
+fs.mkdirSync(audioDir, { recursive: true });
+
 const mqttClient = mqtt.connect(MQTT_BROKER);
- 
+
 mqttClient.on("connect", () => {
-    console.log("MQTT Connected");
-    mqttClient.subscribe(MQTT_TOPIC);
+  console.log("MQTT Connected");
+  mqttClient.subscribe(MQTT_TOPIC, (err) => {
+    if (err) {
+      console.error("MQTT subscribe error:", err);
+    } else {
+      console.log(`Subscribed to MQTT topic: ${MQTT_TOPIC}`);
+    }
+  });
+});
+
+mqttClient.on("error", (err) => {
+  console.error("MQTT connection error:", err);
 });
- 
+
 mqttClient.on("message", (topic, message) => {
-    try {
-        const data = JSON.parse(message.toString());
- 
-        if (data.audio_file) {
-            const buffer = Buffer.from(data.audio_file, "base64");
-            const fileName = `audio_${Date.now()}.wav`;
-            fs.writeFileSync(`./audioLocal/${fileName}`, buffer);
-            data.savedAudio = fileName;
-        }
- 
-        latestSensorData = data;
-    } catch (err) {
-        console.error("MQTT parse error:", err);
+  try {
+    const data = JSON.parse(message.toString());
+
+    if (data.audio_file) {
+      const buffer = Buffer.from(data.audio_file, "base64");
+      const fileName = `audio_${Date.now()}.wav`;
+      const filePath = path.join(audioDir, fileName);
+
+      fs.writeFileSync(filePath, buffer);
+      data.savedAudio = fileName;
     }
+
+    latestSensorData = data;
+    console.log("Latest sensor payload updated from MQTT");
+  } catch (err) {
+    console.error("MQTT parse error:", err);
+  }
 });
- 
+
 module.exports = function (app) {
- 
-    app.use(function (req, res, next) {
-        res.header("Access-Control-Allow-Headers", "Origin, Content-Type, Accept");
-        next();
-    });
- 
-    app.get(`/movement_time/:start/:end`, async (req, res, next) => {
-        try {
-            const start = req.params.start;
-            const end = req.params.end;
-            const response = await axios.get(
-                `${MESSAGE_API_URL}/movement_time?start=${start}&end=${end}`
-            );
- 
-            if (Object.keys(response.data).length === 0) {
-                res.send([]);
-            } else {
-                res.send(response.data);
-            }
-        } catch (error) {
-            console.error("Error fetching movement_time:", error.message);
-            res.status(500).send({ error: "Failed to fetch movement data." });
-        }
-    });
- 
-    app.get(`/events_time/:start/:end`, async (req, res, next) => {
-        try {
-            const start = req.params.start;
-            const end = req.params.end;
-            const response = await axios.get(
-                `${MESSAGE_API_URL}/events_time?start=${start}&end=${end}`
-            );
-            res.send(response.data);
-            next();
-        } catch (error) {
-            console.error("Error fetching events_time:", error.message);
-            res.status(500).send({ error: "Failed to fetch event data." });
-        }
-    });
- 
-    app.get(`/microphones`, async (req, res, next) => {
-        try {
-            const response = await axios.get(`${MESSAGE_API_URL}/microphones`);
-            res.send(response.data);
-            next();
-        } catch (error) {
-            console.error("Error fetching microphones:", error.message);
-            res.status(500).send({ error: "Failed to fetch microphones." });
-        }
-    });
- 
-    app.get(`/audio/:id`, async (req, res, next) => {
-        try {
-            const id = req.params.id;
-            const response = await axios.get(`${MESSAGE_API_URL}/audio?id=${id}`);
-            res.send(response.data);
-            next();
-        } catch (error) {
-            console.error("Error fetching audio:", error.message);
-            res.status(500).send({ error: "Failed to fetch audio." });
-        }
-    });
- 
-    app.post(`/post_recording`, async (req, res, next) => {
-        const data = req.body;
-        try {
-            const response = await axios.post(`${MESSAGE_API_URL}/post_recording`, data);
-            console.log("Record response:", response.data);
-            res.send(response.data);
-            next();
-        } catch (error) {
-            console.error("Error posting recording:", error.message);
-            res.status(500).send({ error: "Failed to post recording." });
-        }
-    });
- 
-    app.post(`/sim_control/:control`, async (req, res, next) => {
-        try {
-            const control = req.params.control;
-            const response = await axios.post(
-                `${MESSAGE_API_URL}/sim_control?control=${control}`
-            );
-            res.send(response.data);
-            next();
-        } catch (error) {
-            console.error("Error posting sim control:", error.message);
-            res.status(500).send({ error: "Failed to control simulation." });
-        }
-    });
- 
-    app.get(`/latest_movement`, async (req, res, next) => {
-        try {
-            const response = await axios.get(`${MESSAGE_API_URL}/latest_movement`);
-            res.send(response.data);
-            next();
-        } catch (error) {
-            console.error("Error fetching latest movement:", error.message);
-            res.status(500).send({ error: "Failed to fetch latest movement." });
-        }
-    });
- 
-    app.get(`/movement_time_daily/:start/:end`, async (req, res, next) => {
-        try {
-            const start = req.params.start;
-            const end = req.params.end;
-            const response = await axios.get(
-                `${MESSAGE_API_URL}/movement_time_daily?start=${start}&end=${end}`
-            );
-            res.send(response.data || []);
-        } catch (error) {
-            console.error("Error fetching movement_time_daily:", error.message);
-            res.status(500).send({ error: "Failed to fetch daily movement data." });
-        }
-    });
-    // Task 9: Sensor Health mock routes for HMI dashboard
-    // Wait for real information from IoT
- 
-    app.get("/sensors/updates", async (req, res) => {
-        if (!latestSensorData) {
-            return res.json({ items: [] });
-        }
- 
-        res.json({
-            items: [
-                {
-                    sensorId: "LIVE-001",
-                    status: "Online",
-                    cpu: latestSensorData.health_data?.cpu,
-                    ram: latestSensorData.health_data?.ram,
-                    disk: latestSensorData.health_data?.disk,
-                    uptime: latestSensorData.health_data?.uptime,
-                    gps: latestSensorData.gps_data,
-                    lastAudio: latestSensorData.savedAudio || null,
-                },
-            ],
-        });
-    });
- 
-    app.get("/sensors/alerts", async (req, res) => {
-        if (!latestSensorData) {
-            return res.json({ items: [] });
-        }
- 
-        const items = [];
- 
-        if (latestSensorData.health_data?.cpu > 90) {
-            items.push({
-                sensorId: "LIVE-001",
-                issue: "High CPU",
-                details: `CPU usage ${latestSensorData.health_data.cpu}%`,
-            });
-        }
- 
-        if (latestSensorData.health_data?.ram > 90) {
-            items.push({
-                sensorId: "LIVE-001",
-                issue: "High RAM",
-                details: `RAM usage ${latestSensorData.health_data.ram}%`,
-            });
-        }
- 
-        res.json({ items });
-    });
- 
-    let rebootHistory = [];
- 
-    app.get("/sensors/reboots/recent", async (req, res) => {
-        const limit = Number(req.query.limit) || 50;
-        res.json({
-            items: rebootHistory.slice(0, limit),
+  app.use(function (req, res, next) {
+    res.header("Access-Control-Allow-Headers", "Origin, Content-Type, Accept");
+    next();
+  });
+
+  app.get(`/movement_time/:start/:end`, async (req, res, next) => {
+    try {
+      const start = req.params.start;
+      const end = req.params.end;
+      const response = await axios.get(
+        `${MESSAGE_API_URL}/movement_time?start=${start}&end=${end}`
+      );
+
+      if (Object.keys(response.data).length === 0) {
+        res.send([]);
+      } else {
+        res.send(response.data);
+      }
+    } catch (error) {
+      console.error("Error fetching movement_time:", error.message);
+      res.status(500).send({ error: "Failed to fetch movement data." });
+    }
+  });
+
+  app.get(`/events_time/:start/:end`, async (req, res, next) => {
+    try {
+      const start = req.params.start;
+      const end = req.params.end;
+      const response = await axios.get(
+        `${MESSAGE_API_URL}/events_time?start=${start}&end=${end}`
+      );
+      res.send(response.data);
+      next();
+    } catch (error) {
+      console.error("Error fetching events_time:", error.message);
+      res.status(500).send({ error: "Failed to fetch event data." });
+    }
+  });
+
+  app.get(`/microphones`, async (req, res, next) => {
+    try {
+      const response = await axios.get(`${MESSAGE_API_URL}/microphones`);
+      res.send(response.data);
+      next();
+    } catch (error) {
+      console.error("Error fetching microphones:", error.message);
+      res.status(500).send({ error: "Failed to fetch microphones." });
+    }
+  });
+
+  app.get(`/audio/:id`, async (req, res, next) => {
+    try {
+      const id = req.params.id;
+      const response = await axios.get(`${MESSAGE_API_URL}/audio?id=${id}`);
+      res.send(response.data);
+      next();
+    } catch (error) {
+      console.error("Error fetching audio:", error.message);
+      res.status(500).send({ error: "Failed to fetch audio." });
+    }
+  });
+
+  app.post(`/post_recording`, async (req, res, next) => {
+    const data = req.body;
+    try {
+      const response = await axios.post(`${MESSAGE_API_URL}/post_recording`, data);
+      console.log("Record response:", response.data);
+      res.send(response.data);
+      next();
+    } catch (error) {
+      console.error("Error posting recording:", error.message);
+      res.status(500).send({ error: "Failed to post recording." });
+    }
+  });
+
+  app.post(`/sim_control/:control`, async (req, res, next) => {
+    try {
+      const control = req.params.control;
+      const response = await axios.post(
+        `${MESSAGE_API_URL}/sim_control?control=${control}`
+      );
+      res.send(response.data);
+      next();
+    } catch (error) {
+      console.error("Error posting sim control:", error.message);
+      res.status(500).send({ error: "Failed to control simulation." });
+    }
+  });
+
+  app.get(`/latest_movement`, async (req, res, next) => {
+    try {
+      const response = await axios.get(`${MESSAGE_API_URL}/latest_movement`);
+      res.send(response.data);
+      next();
+    } catch (error) {
+      console.error("Error fetching latest movement:", error.message);
+      res.status(500).send({ error: "Failed to fetch latest movement." });
+    }
+  });
+
+  app.get(`/movement_time_daily/:start/:end`, async (req, res, next) => {
+    try {
+      const start = req.params.start;
+      const end = req.params.end;
+      const response = await axios.get(
+        `${MESSAGE_API_URL}/movement_time_daily?start=${start}&end=${end}`
+      );
+      res.send(response.data || []);
+    } catch (error) {
+      console.error("Error fetching movement_time_daily:", error.message);
+      res.status(500).send({ error: "Failed to fetch daily movement data." });
+    }
+  });
+
+  app.get("/sensors/test-seed", (req, res) => {
+  latestSensorData = {
+    health_data: {
+      cpu: 37,
+      ram: 48,
+      disk: 62,
+      uptime: 15432
+    },
+    gps_data: {
+      lat: -38.1499,
+      lon: 144.3617
+    },
+    savedAudio: "test_audio.wav"
+  };
+
+  res.json({
+    success: true,
+    message: "Test sensor payload seeded successfully.",
+    latestSensorData
+  });
+});
+
+  // Sensor Health live routes
+  app.get("/sensors/updates", async (req, res) => {
+    try {
+      if (!latestSensorData) {
+        return res.json({ items: [] });
+      }
+
+      res.json({
+        items: [
+          {
+            sensorId: "LIVE-001",
+            status: "Online",
+            cpu: latestSensorData.health_data?.cpu,
+            ram: latestSensorData.health_data?.ram,
+            disk: latestSensorData.health_data?.disk,
+            uptime: latestSensorData.health_data?.uptime,
+            gps: latestSensorData.gps_data,
+            lastAudio: latestSensorData.savedAudio || null,
+          },
+        ],
+      });
+    } catch (error) {
+      console.error("Error in /sensors/updates:", error.message);
+      res.status(500).json({ error: "Failed to load sensor updates." });
+    }
+  });
+
+  app.get("/sensors/alerts", async (req, res) => {
+    try {
+      if (!latestSensorData) {
+        return res.json({ items: [] });
+      }
+
+      const items = [];
+
+      if (latestSensorData.health_data?.cpu > 90) {
+        items.push({
+          sensorId: "LIVE-001",
+          issue: "High CPU",
+          details: `CPU usage ${latestSensorData.health_data.cpu}%`,
         });
-    });
- 
-    app.post("/sensors/:sensorId/reboot", async (req, res) => {
-        const sensorId = req.params.sensorId;
- 
-        const entry = {
-            sensorId,
-            status: "Queued",
-            requestedAt: new Date().toISOString(),
-        };
- 
-        rebootHistory.unshift(entry);
- 
-        res.json({
-            success: true,
-            message: `Reboot queued for ${sensorId}`,
-            item: entry,
+      }
+
+      if (latestSensorData.health_data?.ram > 90) {
+        items.push({
+          sensorId: "LIVE-001",
+          issue: "High RAM",
+          details: `RAM usage ${latestSensorData.health_data.ram}%`,
         });
-    });
- 
-    let sensorSettings = {
-        recordIntervalSeconds: 60,
-        sensitivity: "Medium",
-        batteryThresholdPct: 25,
-    };
- 
-    app.get("/sensors/__default__/settings", async (req, res) => {
-        res.json({ settings: sensorSettings });
-    });
- 
-    app.put("/sensors/__default__/settings", async (req, res) => {
-        const incoming = req.body?.settings || {};
- 
-        sensorSettings = {
-            ...sensorSettings,
-            ...incoming,
-        };
- 
-        res.json({
-            success: true,
-            settings: sensorSettings,
+      }
+
+      if (latestSensorData.health_data?.disk > 90) {
+        items.push({
+          sensorId: "LIVE-001",
+          issue: "High Disk",
+          details: `Disk usage ${latestSensorData.health_data.disk}%`,
         });
-    });
+      }
+
+      res.json({ items });
+    } catch (error) {
+      console.error("Error in /sensors/alerts:", error.message);
+      res.status(500).json({ error: "Failed to load sensor alerts." });
+    }
+  });
+
+  let rebootHistory = [];
+
+  app.get("/sensors/reboots/recent", async (req, res) => {
+    try {
+      const limit = Number(req.query.limit) || 50;
+      res.json({
+        items: rebootHistory.slice(0, limit),
+      });
+    } catch (error) {
+      console.error("Error in /sensors/reboots/recent:", error.message);
+      res.status(500).json({ error: "Failed to load reboot history." });
+    }
+  });
+
+  app.post("/sensors/:sensorId/reboot", async (req, res) => {
+    try {
+      const sensorId = req.params.sensorId;
+
+      const entry = {
+        sensorId,
+        status: "Queued",
+        requestedAt: new Date().toISOString(),
+      };
+
+      rebootHistory.unshift(entry);
+
+      res.json({
+        success: true,
+        message: `Reboot queued for ${sensorId}`,
+        item: entry,
+      });
+    } catch (error) {
+      console.error("Error in reboot route:", error.message);
+      res.status(500).json({ error: "Failed to queue reboot." });
+    }
+  });
+
+  let sensorSettings = {
+    recordIntervalSeconds: 60,
+    sensitivity: "Medium",
+    batteryThresholdPct: 25,
+  };
+
+  app.get("/sensors/__default__/settings", async (req, res) => {
+    try {
+      res.json({ settings: sensorSettings });
+    } catch (error) {
+      console.error("Error in settings GET route:", error.message);
+      res.status(500).json({ error: "Failed to load settings." });
+    }
+  });
+
+  app.put("/sensors/__default__/settings", async (req, res) => {
+    try {
+      const incoming = req.body?.settings || {};
+
+      sensorSettings = {
+        ...sensorSettings,
+        ...incoming,
+      };
+
+      res.json({
+        success: true,
+        settings: sensorSettings,
+      });
+    } catch (error) {
+      console.error("Error in settings PUT route:", error.message);
+      res.status(500).json({ error: "Failed to save settings." });
+    }
+  });
 };
\ No newline at end of file