debug(smart v0.1.16): log JSON brut complet en cas d'échec parse

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

agent/Cargo.lock

@@ -248,7 +248,7 @@ dependencies = [
 
 [[package]]
 name = "nanometrics-agent"
-version = "0.1.10"
+version = "0.1.16"
 dependencies = [
  "libc",
  "rumqttc",

agent/Cargo.toml

@@ -1,6 +1,6 @@
 [package]
 name = "nanometrics-agent"
-version = "0.1.11"
+version = "0.1.16"
 edition = "2021"
 
 [lib]

agent/src/metrics/smart.rs

@@ -9,10 +9,16 @@ struct SmartJson {
 }
 
 #[derive(Deserialize)]
-struct SmartStatus { passed: bool }
+struct SmartStatus {
+    #[serde(default)]
+    passed: bool,
+}
 
 #[derive(Deserialize)]
-struct SmartTemp { current: i64 }
+struct SmartTemp {
+    #[serde(default)]
+    current: Option<i64>,
+}
 
 #[derive(Deserialize)]
 struct SmartAttrs { table: Vec<SmartAttr> }
@@ -44,7 +50,7 @@ pub fn is_available() -> bool {
 pub fn parse_json(json: &str) -> Result<crate::payload::SmartMetrics, serde_json::Error> {
     let s: SmartJson = serde_json::from_str(json)?;
 
-    let temperature = s.temperature.as_ref().map(|t| t.current)
+    let temperature = s.temperature.as_ref().and_then(|t| t.current)
         .or_else(|| s.nvme_smart_health_information_log.as_ref()?.temperature);
 
     let mut reallocated = None;
@@ -82,41 +88,60 @@ pub fn parse_json(json: &str) -> Result<crate::payload::SmartMetrics, serde_json
 
 pub fn collect() -> Option<Vec<crate::payload::SmartMetrics>> {
     if !is_available() {
+        eprintln!("[smart] smartctl introuvable dans PATH");
         return None;
     }
-    let mut devs: Vec<String> = std::fs::read_dir("/sys/block")
-        .into_iter()
-        .flatten()
-        .flatten()
-        .map(|e| e.file_name().into_string().unwrap_or_default())
-        .filter_map(|n| {
-            if n.starts_with("sd") {
-                // /dev/sda, /dev/sdb — block device, groupe disk OK
-                Some(format!("/dev/{}", n))
-            } else if n.starts_with("nvme") && n.contains('n') {
-                // /dev/nvme0n1 — block device (brw-rw---- root disk), groupe disk OK
-                // NE PAS utiliser /dev/nvme0 (contrôleur crw------- root root, root only)
-                Some(format!("/dev/{}", n))
-            } else {
-                None
-            }
-        })
-        .collect::<std::collections::HashSet<_>>()
-        .into_iter()
-        .collect();
+    let mut set = std::collections::HashSet::new();
+
+    // SATA/SAS : /sys/block/sd* → /dev/sda, /dev/sdb…
+    for e in std::fs::read_dir("/sys/block").into_iter().flatten().flatten() {
+        let n = e.file_name().into_string().unwrap_or_default();
+        if n.starts_with("sd") {
+            set.insert(format!("/dev/{}", n));
+        }
+    }
+
+    // NVMe : /sys/class/nvme/nvme* → /dev/nvme0, /dev/nvme1…
+    // On utilise le contrôleur (char device), pas le namespace (block device),
+    // car smartctl ne peut exécuter les commandes admin SMART que via le contrôleur.
+    // La règle udev 99-nanometrics-smart.rules lui donne l'accès groupe disk.
+    for e in std::fs::read_dir("/sys/class/nvme").into_iter().flatten().flatten() {
+        let n = e.file_name().into_string().unwrap_or_default();
+        if n.starts_with("nvme") {
+            set.insert(format!("/dev/{}", n));
+        }
+    }
+
+    let mut devs: Vec<String> = set.into_iter().collect();
     devs.sort();
+    eprintln!("[smart] disques détectés: {:?}", devs);
 
     let mut results = Vec::new();
     for dev in &devs {
-        let Ok(output) = std::process::Command::new("smartctl")
+        let output = match std::process::Command::new("smartctl")
             .args(["-a", "-j", dev])
-            .output() else { continue };
+            .output()
+        {
+            Ok(o) => o,
+            Err(e) => { eprintln!("[smart] erreur exec smartctl {}: {}", dev, e); continue }
+        };
+        eprintln!("[smart] smartctl {} → exit={}, stdout={} octets, stderr={} octets",
+            dev, output.status, output.stdout.len(), output.stderr.len());
         let json = String::from_utf8_lossy(&output.stdout);
-        if let Ok(metrics) = parse_json(&json) {
-            results.push(crate::payload::SmartMetrics {
-                device: dev.trim_start_matches("/dev/").to_string(),
-                ..metrics
-            });
+        match parse_json(&json) {
+            Ok(metrics) => {
+                eprintln!("[smart] {} parsé OK (passed={})", dev, metrics.passed);
+                results.push(crate::payload::SmartMetrics {
+                    device: dev.trim_start_matches("/dev/").to_string(),
+                    ..metrics
+                });
+            }
+            Err(e) => {
+                eprintln!("[smart] {} parse JSON échoué: {}", dev, e);
+                eprintln!("[smart] --- JSON BRUT BEGIN ({} octets) ---", json.len());
+                eprintln!("{}", &*json);
+                eprintln!("[smart] --- JSON BRUT END ---");
+            }
         }
     }
     if results.is_empty() { None } else { Some(results) }

deploy/99-nanometrics-smart.rules

@@ -0,0 +1,4 @@
+# Nanometrics: accès groupe disk aux contrôleurs NVMe pour SMART
+# Sans cette règle, /dev/nvme0 est crw------- root root (root only),
+# ce qui empêche smartctl d'exécuter les commandes admin et omet smart_status du JSON.
+KERNEL=="nvme[0-9]*", SUBSYSTEM=="nvme", GROUP="disk", MODE="0660"

deploy/install.sh

@@ -45,6 +45,17 @@ else
 fi
 echo ""
 
+# ── 2. Règle udev NVMe (accès SMART pour le groupe disk) ──────────────────────
+UDEV_RULE="/etc/udev/rules.d/99-nanometrics-smart.rules"
+cat > "$UDEV_RULE" << 'UDEVRULE'
+# Nanometrics: accès groupe disk aux contrôleurs NVMe pour SMART
+KERNEL=="nvme[0-9]*", SUBSYSTEM=="nvme", GROUP="disk", MODE="0660"
+UDEVRULE
+udevadm control --reload-rules
+udevadm trigger --subsystem-match=nvme 2>/dev/null || true
+ok "Règle udev NVMe installée ($UDEV_RULE)"
+echo ""
+
 # ── 3. Détection de l'architecture ────────────────────────────────────────────
 ARCH="$(uname -m)"
 case "$ARCH" in

server/transport/udp.go

@@ -2,7 +2,6 @@ package transport
 
 import (
 	"encoding/json"
-	"fmt"
 	"log"
 	"net"
 
@@ -34,19 +33,21 @@ func StartUDP(addr string, handler func(*models.AgentMetrics)) error {
 func processUDP(data []byte, src string, handler func(*models.AgentMetrics)) {
 	var m models.AgentMetrics
 	if err := json.Unmarshal(data, &m); err != nil {
-		preview := ""
-		if len(data) > 0 {
-			end := len(data)
-			if end > 32 {
-				end = 32
-			}
-			preview = fmt.Sprintf(" | src=%s | premiers octets: %x | texte: %q", src, data[:end], data[:end])
+		end := 32
+		if len(data) < end {
+			end = len(data)
 		}
-		log.Printf("[udp] JSON invalide: %v%s", err, preview)
+		log.Printf("[udp] JSON invalide: %v | src=%s | octets: %x", err, src, data[:end])
 		return
 	}
 	if m.Hostname == "" {
 		return
 	}
+	// DEBUG SMART — logguer le payload ASUS complet
+	if m.Smart != nil {
+		log.Printf("[udp] SMART reçu de %s: %d disque(s)", m.Hostname, len(m.Smart))
+	} else {
+		log.Printf("[udp] payload de %s (v%s): smart=nil hdd=%v", m.Hostname, m.Version, m.HDDTotal)
+	}
 	handler(&m)
 }