Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 267654fda4 | |||
| dc1105eefe | |||
| c9d12793ef |
6
Cargo.lock
generated
6
Cargo.lock
generated
@@ -279,7 +279,7 @@ checksum = "a1d728cc89cf3aee9ff92b05e62b19ee65a02b5702cff7d5a377e32c6ae29d8d"
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "cm-dashboard"
|
name = "cm-dashboard"
|
||||||
version = "0.1.153"
|
version = "0.1.156"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"anyhow",
|
"anyhow",
|
||||||
"chrono",
|
"chrono",
|
||||||
@@ -301,7 +301,7 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "cm-dashboard-agent"
|
name = "cm-dashboard-agent"
|
||||||
version = "0.1.153"
|
version = "0.1.156"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"anyhow",
|
"anyhow",
|
||||||
"async-trait",
|
"async-trait",
|
||||||
@@ -324,7 +324,7 @@ dependencies = [
|
|||||||
|
|
||||||
[[package]]
|
[[package]]
|
||||||
name = "cm-dashboard-shared"
|
name = "cm-dashboard-shared"
|
||||||
version = "0.1.153"
|
version = "0.1.156"
|
||||||
dependencies = [
|
dependencies = [
|
||||||
"chrono",
|
"chrono",
|
||||||
"serde",
|
"serde",
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "cm-dashboard-agent"
|
name = "cm-dashboard-agent"
|
||||||
version = "0.1.153"
|
version = "0.1.156"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
|
|||||||
@@ -437,12 +437,14 @@ impl DiskCollector {
|
|||||||
// Return unknown data rather than failing completely
|
// Return unknown data rather than failing completely
|
||||||
return Ok(SmartData {
|
return Ok(SmartData {
|
||||||
health: "UNKNOWN".to_string(),
|
health: "UNKNOWN".to_string(),
|
||||||
|
serial_number: None,
|
||||||
temperature_celsius: None,
|
temperature_celsius: None,
|
||||||
wear_percent: None,
|
wear_percent: None,
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
let mut health = "UNKNOWN".to_string();
|
let mut health = "UNKNOWN".to_string();
|
||||||
|
let mut serial_number = None;
|
||||||
let mut temperature = None;
|
let mut temperature = None;
|
||||||
let mut wear_percent = None;
|
let mut wear_percent = None;
|
||||||
|
|
||||||
@@ -455,6 +457,19 @@ impl DiskCollector {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
// Serial number parsing (both SATA and NVMe)
|
||||||
|
if line.contains("Serial Number:") {
|
||||||
|
if let Some(serial_part) = line.split("Serial Number:").nth(1) {
|
||||||
|
let serial_str = serial_part.trim();
|
||||||
|
if !serial_str.is_empty() {
|
||||||
|
// Take first whitespace-separated token
|
||||||
|
if let Some(serial) = serial_str.split_whitespace().next() {
|
||||||
|
serial_number = Some(serial.to_string());
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
// Temperature parsing for different drive types
|
// Temperature parsing for different drive types
|
||||||
if line.contains("Temperature_Celsius") || line.contains("Airflow_Temperature_Cel") {
|
if line.contains("Temperature_Celsius") || line.contains("Airflow_Temperature_Cel") {
|
||||||
// Traditional SATA drives: attribute table format
|
// Traditional SATA drives: attribute table format
|
||||||
@@ -497,6 +512,7 @@ impl DiskCollector {
|
|||||||
|
|
||||||
Ok(SmartData {
|
Ok(SmartData {
|
||||||
health,
|
health,
|
||||||
|
serial_number,
|
||||||
temperature_celsius: temperature,
|
temperature_celsius: temperature,
|
||||||
wear_percent,
|
wear_percent,
|
||||||
})
|
})
|
||||||
@@ -522,6 +538,7 @@ impl DiskCollector {
|
|||||||
|
|
||||||
agent_data.system.storage.drives.push(DriveData {
|
agent_data.system.storage.drives.push(DriveData {
|
||||||
name: drive.name.clone(),
|
name: drive.name.clone(),
|
||||||
|
serial_number: smart.and_then(|s| s.serial_number.clone()),
|
||||||
health: smart.map(|s| s.health.clone()).unwrap_or_else(|| drive.health.clone()),
|
health: smart.map(|s| s.health.clone()).unwrap_or_else(|| drive.health.clone()),
|
||||||
temperature_celsius: smart.and_then(|s| s.temperature_celsius),
|
temperature_celsius: smart.and_then(|s| s.temperature_celsius),
|
||||||
wear_percent: smart.and_then(|s| s.wear_percent),
|
wear_percent: smart.and_then(|s| s.wear_percent),
|
||||||
@@ -587,6 +604,7 @@ impl DiskCollector {
|
|||||||
|
|
||||||
cm_dashboard_shared::PoolDriveData {
|
cm_dashboard_shared::PoolDriveData {
|
||||||
name: d.name.clone(),
|
name: d.name.clone(),
|
||||||
|
serial_number: smart.and_then(|s| s.serial_number.clone()),
|
||||||
temperature_celsius: temperature,
|
temperature_celsius: temperature,
|
||||||
health,
|
health,
|
||||||
wear_percent: smart.and_then(|s| s.wear_percent),
|
wear_percent: smart.and_then(|s| s.wear_percent),
|
||||||
@@ -611,6 +629,7 @@ impl DiskCollector {
|
|||||||
|
|
||||||
cm_dashboard_shared::PoolDriveData {
|
cm_dashboard_shared::PoolDriveData {
|
||||||
name: d.name.clone(),
|
name: d.name.clone(),
|
||||||
|
serial_number: smart.and_then(|s| s.serial_number.clone()),
|
||||||
temperature_celsius: temperature,
|
temperature_celsius: temperature,
|
||||||
health,
|
health,
|
||||||
wear_percent: smart.and_then(|s| s.wear_percent),
|
wear_percent: smart.and_then(|s| s.wear_percent),
|
||||||
@@ -808,6 +827,7 @@ impl Collector for DiskCollector {
|
|||||||
#[derive(Debug, Clone)]
|
#[derive(Debug, Clone)]
|
||||||
struct SmartData {
|
struct SmartData {
|
||||||
health: String,
|
health: String,
|
||||||
|
serial_number: Option<String>,
|
||||||
temperature_celsius: Option<f32>,
|
temperature_celsius: Option<f32>,
|
||||||
wear_percent: Option<f32>,
|
wear_percent: Option<f32>,
|
||||||
}
|
}
|
||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "cm-dashboard"
|
name = "cm-dashboard"
|
||||||
version = "0.1.153"
|
version = "0.1.156"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
|
|||||||
@@ -239,8 +239,11 @@ impl SystemWidget {
|
|||||||
};
|
};
|
||||||
|
|
||||||
// Add drive info
|
// Add drive info
|
||||||
|
let display_name = drive.serial_number.as_ref()
|
||||||
|
.map(|s| truncate_serial(s))
|
||||||
|
.unwrap_or(drive.name.clone());
|
||||||
let storage_drive = StorageDrive {
|
let storage_drive = StorageDrive {
|
||||||
name: drive.name.clone(),
|
name: display_name,
|
||||||
temperature: drive.temperature_celsius,
|
temperature: drive.temperature_celsius,
|
||||||
wear_percent: drive.wear_percent,
|
wear_percent: drive.wear_percent,
|
||||||
status: Status::Ok,
|
status: Status::Ok,
|
||||||
@@ -311,8 +314,11 @@ impl SystemWidget {
|
|||||||
Status::Unknown
|
Status::Unknown
|
||||||
};
|
};
|
||||||
|
|
||||||
|
let display_name = drive.serial_number.as_ref()
|
||||||
|
.map(|s| truncate_serial(s))
|
||||||
|
.unwrap_or(drive.name.clone());
|
||||||
let storage_drive = StorageDrive {
|
let storage_drive = StorageDrive {
|
||||||
name: drive.name.clone(),
|
name: display_name,
|
||||||
temperature: drive.temperature_celsius,
|
temperature: drive.temperature_celsius,
|
||||||
wear_percent: drive.wear_percent,
|
wear_percent: drive.wear_percent,
|
||||||
status: drive_status,
|
status: drive_status,
|
||||||
@@ -333,8 +339,11 @@ impl SystemWidget {
|
|||||||
Status::Unknown
|
Status::Unknown
|
||||||
};
|
};
|
||||||
|
|
||||||
|
let display_name = drive.serial_number.as_ref()
|
||||||
|
.map(|s| truncate_serial(s))
|
||||||
|
.unwrap_or(drive.name.clone());
|
||||||
let storage_drive = StorageDrive {
|
let storage_drive = StorageDrive {
|
||||||
name: drive.name.clone(),
|
name: display_name,
|
||||||
temperature: drive.temperature_celsius,
|
temperature: drive.temperature_celsius,
|
||||||
wear_percent: drive.wear_percent,
|
wear_percent: drive.wear_percent,
|
||||||
status: drive_status,
|
status: drive_status,
|
||||||
@@ -382,8 +391,8 @@ impl SystemWidget {
|
|||||||
pool.name.clone()
|
pool.name.clone()
|
||||||
}
|
}
|
||||||
} else {
|
} else {
|
||||||
// For mergerfs pools, show pool name with format like "mergerfs (2+1):"
|
// For mergerfs pools, show pool type with mount point
|
||||||
format!("{}:", pool.pool_type)
|
format!("mergerfs {}:", pool.mount_point)
|
||||||
};
|
};
|
||||||
|
|
||||||
let pool_spans = StatusIcons::create_status_spans(pool.status.clone(), &pool_label);
|
let pool_spans = StatusIcons::create_status_spans(pool.status.clone(), &pool_label);
|
||||||
@@ -422,7 +431,7 @@ impl SystemWidget {
|
|||||||
// └─ Mount: /srv/media
|
// └─ Mount: /srv/media
|
||||||
|
|
||||||
// Pool total usage
|
// Pool total usage
|
||||||
let total_text = format!("Total: {:.0}% {:.1}GB/{:.1}GB",
|
let total_text = format!("{:.0}% {:.1}GB/{:.1}GB",
|
||||||
pool.usage_percent.unwrap_or(0.0),
|
pool.usage_percent.unwrap_or(0.0),
|
||||||
pool.used_gb.unwrap_or(0.0),
|
pool.used_gb.unwrap_or(0.0),
|
||||||
pool.total_gb.unwrap_or(0.0)
|
pool.total_gb.unwrap_or(0.0)
|
||||||
@@ -433,20 +442,30 @@ impl SystemWidget {
|
|||||||
total_spans.extend(StatusIcons::create_status_spans(Status::Ok, &total_text));
|
total_spans.extend(StatusIcons::create_status_spans(Status::Ok, &total_text));
|
||||||
lines.push(Line::from(total_spans));
|
lines.push(Line::from(total_spans));
|
||||||
|
|
||||||
// Data Disks section
|
// Data drives - at same level as parity
|
||||||
if !pool.data_drives.is_empty() {
|
|
||||||
lines.push(Line::from(vec![
|
|
||||||
Span::styled(" ├─ ", Typography::tree()),
|
|
||||||
Span::styled("Data Disks:", Typography::secondary())
|
|
||||||
]));
|
|
||||||
for (i, drive) in pool.data_drives.iter().enumerate() {
|
for (i, drive) in pool.data_drives.iter().enumerate() {
|
||||||
let is_last = i == pool.data_drives.len() - 1;
|
let mut drive_details = Vec::new();
|
||||||
let tree_symbol = if is_last { " │ └─ " } else { " │ ├─ " };
|
if let Some(temp) = drive.temperature {
|
||||||
render_mergerfs_drive(drive, tree_symbol, &mut lines);
|
drive_details.push(format!("T: {}°C", temp as i32));
|
||||||
}
|
}
|
||||||
|
if let Some(wear) = drive.wear_percent {
|
||||||
|
drive_details.push(format!("W: {}%", wear as i32));
|
||||||
}
|
}
|
||||||
|
|
||||||
// Parity section
|
let drive_text = if !drive_details.is_empty() {
|
||||||
|
format!("Data_{}: {} {}", i + 1, drive.name, drive_details.join(" "))
|
||||||
|
} else {
|
||||||
|
format!("Data_{}: {}", i + 1, drive.name)
|
||||||
|
};
|
||||||
|
|
||||||
|
let mut data_spans = vec![
|
||||||
|
Span::styled(" ├─ ", Typography::tree()),
|
||||||
|
];
|
||||||
|
data_spans.extend(StatusIcons::create_status_spans(drive.status.clone(), &drive_text));
|
||||||
|
lines.push(Line::from(data_spans));
|
||||||
|
}
|
||||||
|
|
||||||
|
// Parity drives - last item
|
||||||
if !pool.parity_drives.is_empty() {
|
if !pool.parity_drives.is_empty() {
|
||||||
for drive in &pool.parity_drives {
|
for drive in &pool.parity_drives {
|
||||||
let mut drive_details = Vec::new();
|
let mut drive_details = Vec::new();
|
||||||
@@ -458,25 +477,18 @@ impl SystemWidget {
|
|||||||
}
|
}
|
||||||
|
|
||||||
let drive_text = if !drive_details.is_empty() {
|
let drive_text = if !drive_details.is_empty() {
|
||||||
format!("{} {}", drive.name, drive_details.join(" "))
|
format!("Parity: {} {}", drive.name, drive_details.join(" "))
|
||||||
} else {
|
} else {
|
||||||
drive.name.clone()
|
format!("Parity: {}", drive.name)
|
||||||
};
|
};
|
||||||
|
|
||||||
let mut parity_spans = vec![
|
let mut parity_spans = vec![
|
||||||
Span::styled(" ├─ ", Typography::tree()),
|
Span::styled(" └─ ", Typography::tree()),
|
||||||
Span::styled("Parity: ", Typography::secondary()),
|
|
||||||
];
|
];
|
||||||
parity_spans.extend(StatusIcons::create_status_spans(drive.status.clone(), &drive_text));
|
parity_spans.extend(StatusIcons::create_status_spans(drive.status.clone(), &drive_text));
|
||||||
lines.push(Line::from(parity_spans));
|
lines.push(Line::from(parity_spans));
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
// Mount point
|
|
||||||
lines.push(Line::from(vec![
|
|
||||||
Span::styled(" └─ Mount: ", Typography::tree()),
|
|
||||||
Span::styled(&pool.mount_point, Typography::secondary())
|
|
||||||
]));
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -484,6 +496,16 @@ impl SystemWidget {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
/// Truncate serial number to last 8 characters
|
||||||
|
fn truncate_serial(serial: &str) -> String {
|
||||||
|
let len = serial.len();
|
||||||
|
if len > 8 {
|
||||||
|
serial[len - 8..].to_string()
|
||||||
|
} else {
|
||||||
|
serial.to_string()
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
/// Helper function to render a drive in a MergerFS pool
|
/// Helper function to render a drive in a MergerFS pool
|
||||||
fn render_mergerfs_drive<'a>(drive: &StorageDrive, tree_symbol: &'a str, lines: &mut Vec<Line<'a>>) {
|
fn render_mergerfs_drive<'a>(drive: &StorageDrive, tree_symbol: &'a str, lines: &mut Vec<Line<'a>>) {
|
||||||
let mut drive_details = Vec::new();
|
let mut drive_details = Vec::new();
|
||||||
@@ -540,6 +562,7 @@ impl SystemWidget {
|
|||||||
|
|
||||||
// First line: serial number with temperature and wear
|
// First line: serial number with temperature and wear
|
||||||
if let Some(serial) = &self.backup_disk_serial {
|
if let Some(serial) = &self.backup_disk_serial {
|
||||||
|
let truncated_serial = truncate_serial(serial);
|
||||||
let mut details = Vec::new();
|
let mut details = Vec::new();
|
||||||
if let Some(temp) = self.backup_disk_temperature {
|
if let Some(temp) = self.backup_disk_temperature {
|
||||||
details.push(format!("T: {}°C", temp as i32));
|
details.push(format!("T: {}°C", temp as i32));
|
||||||
@@ -549,9 +572,9 @@ impl SystemWidget {
|
|||||||
}
|
}
|
||||||
|
|
||||||
let disk_text = if !details.is_empty() {
|
let disk_text = if !details.is_empty() {
|
||||||
format!("{} {}", serial, details.join(" "))
|
format!("{} {}", truncated_serial, details.join(" "))
|
||||||
} else {
|
} else {
|
||||||
serial.clone()
|
truncated_serial
|
||||||
};
|
};
|
||||||
|
|
||||||
let backup_status = match self.backup_status.as_str() {
|
let backup_status = match self.backup_status.as_str() {
|
||||||
|
|||||||
@@ -1,6 +1,6 @@
|
|||||||
[package]
|
[package]
|
||||||
name = "cm-dashboard-shared"
|
name = "cm-dashboard-shared"
|
||||||
version = "0.1.153"
|
version = "0.1.156"
|
||||||
edition = "2021"
|
edition = "2021"
|
||||||
|
|
||||||
[dependencies]
|
[dependencies]
|
||||||
|
|||||||
@@ -66,6 +66,7 @@ pub struct StorageData {
|
|||||||
#[derive(Debug, Clone, Serialize, Deserialize)]
|
#[derive(Debug, Clone, Serialize, Deserialize)]
|
||||||
pub struct DriveData {
|
pub struct DriveData {
|
||||||
pub name: String,
|
pub name: String,
|
||||||
|
pub serial_number: Option<String>,
|
||||||
pub health: String,
|
pub health: String,
|
||||||
pub temperature_celsius: Option<f32>,
|
pub temperature_celsius: Option<f32>,
|
||||||
pub wear_percent: Option<f32>,
|
pub wear_percent: Option<f32>,
|
||||||
@@ -104,6 +105,7 @@ pub struct PoolData {
|
|||||||
#[derive(Debug, Clone, Serialize, Deserialize)]
|
#[derive(Debug, Clone, Serialize, Deserialize)]
|
||||||
pub struct PoolDriveData {
|
pub struct PoolDriveData {
|
||||||
pub name: String,
|
pub name: String,
|
||||||
|
pub serial_number: Option<String>,
|
||||||
pub temperature_celsius: Option<f32>,
|
pub temperature_celsius: Option<f32>,
|
||||||
pub wear_percent: Option<f32>,
|
pub wear_percent: Option<f32>,
|
||||||
pub health: String,
|
pub health: String,
|
||||||
|
|||||||
Reference in New Issue
Block a user