ntpsec-rs-logtemp 0.3.12

NTP temperature logger — forensic Rust reconstruction of ntplogtemp
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65

// ──── ntplogtemp-rs — NTP temperature logger ────────────────────────────────
//
// Forensic Rust reconstruction of ntplogtemp. Logs temperature data for
// environmental compensation.
//
// ## Oracle
//   - ntpsec ntpclients/ntplogtemp.py (10K)
// =============================================================================

use clap::Parser;
use std::io::Write;

/// Temperature logging daemon
#[derive(Parser, Debug)]
#[command(name = "ntplogtemp-rs", about = "Temperature logging daemon", version)]
struct Cli {
    /// Temperature source path (sysfs)
    #[arg(default_value = "/sys/class/thermal/thermal_zone0/temp")]
    source: String,
    /// Output file
    #[arg(short = 'o', long, default_value = "/var/log/ntpstats/temperature")]
    output: String,
    /// Poll interval in seconds
    #[arg(short = 'i', long, default_value = "60")]
    interval: u64,
}

fn read_temperature(path: &str) -> Result<f64, String> {
    let content = std::fs::read_to_string(path).map_err(|e| format!("cannot read {path}: {e}"))?;
    let millidegrees: f64 = content
        .trim()
        .parse()
        .map_err(|e| format!("bad temp data: {e}"))?;
    Ok(millidegrees / 1000.0)
}

fn main() {
    let cli = Cli::parse();
    println!("ntplogtemp-rs — Temperature logging daemon");
    println!("Source: {}", cli.source);
    println!("Output: {}", cli.output);

    loop {
        match read_temperature(&cli.source) {
            Ok(temp) => {
                let now = std::time::SystemTime::now()
                    .duration_since(std::time::UNIX_EPOCH)
                    .unwrap_or_default();
                let line = format!("{} {:.3}\n", now.as_secs(), temp);
                if let Ok(mut f) = std::fs::OpenOptions::new()
                    .create(true)
                    .append(true)
                    .open(&cli.output)
                {
                    let _ = f.write_all(line.as_bytes());
                }
                println!("{} {:.1}°C", now.as_secs(), temp);
            }
            Err(e) => {
                eprintln!("Error: {e}");
            }
        }
        std::thread::sleep(std::time::Duration::from_secs(cli.interval));
    }
}