m-bus-parser-cli 0.1.3

A cli to use the library for parsing M-Bus frames
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
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94

use clap::{Parser, Subcommand};
use m_bus_parser::serialize_mbus_data;
use std::fs;
use std::path::PathBuf;
use std::str;

#[derive(Parser)]
#[command(version, about)]
struct Cli {
    #[command(subcommand)]
    command: Command,
}

#[derive(Subcommand)]
enum Command {
    /// Parse an M-Bus data file
    Parse {
        /// The file to parse
        #[arg(short = 'f', long)]
        file: Option<PathBuf>,

        /// The raw M-Bus data as a string
        #[arg(short = 'd', long)]
        data: Option<String>,

        #[arg(short = 't', long)]
        format: Option<String>,

        /// Decryption key (32 hex characters for AES-128)
        #[arg(short = 'k', long)]
        key: Option<String>,
    },
}

fn main() {
    let cli = Cli::parse();

    match cli.command {
        Command::Parse {
            file,
            data,
            format,
            key,
        } => {
            let key_bytes = parse_key(key.as_deref());
            let fmt = format.as_deref().unwrap_or("table");

            if let Some(file_path) = file {
                let file_content = fs::read_to_string(file_path).expect("Failed to read the file");
                print!(
                    "{}",
                    serialize_mbus_data(&file_content, fmt, key_bytes.as_ref())
                );
            } else if let Some(data_string) = data {
                print!(
                    "{}",
                    serialize_mbus_data(&data_string, fmt, key_bytes.as_ref())
                );
            } else {
                eprintln!("Either --file or --data must be provided");
            }
        }
    }
}

fn parse_key(key_hex: Option<&str>) -> Option<[u8; 16]> {
    key_hex.and_then(|hex_str| {
        hex::decode(hex_str).ok().and_then(|bytes| {
            if bytes.len() == 16 {
                let mut arr = [0u8; 16];
                arr.copy_from_slice(&bytes);
                Some(arr)
            } else {
                eprintln!(
                    "Warning: Key must be 16 bytes (32 hex chars), got {} bytes. Ignoring key.",
                    bytes.len()
                );
                None
            }
        })
    })
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_parse_data_from_string() {
        let data_string = "0x68, 0x3C, 0x3C, 0x68, 0x08, 0x08, 0x72, 0x78, 0x03, 0x49, 0x11, 0x77, 0x04, 0x0E, 0x16, 0x0A, 0x00, 0x00, 0x00, 0x0C, 0x78, 0x78, 0x03, 0x49, 0x11, 0x04, 0x13, 0x31, 0xD4, 0x00, 0x00, 0x42, 0x6C, 0x00, 0x00, 0x44, 0x13, 0x00, 0x00, 0x00, 0x00, 0x04, 0x6D, 0x0B, 0x0B, 0xCD, 0x13, 0x02, 0x27, 0x00, 0x00, 0x09, 0xFD, 0x0E, 0x02, 0x09, 0xFD, 0x0F, 0x06, 0x0F, 0x00, 0x01, 0x75, 0x13, 0xD3, 0x16";
        let output = serialize_mbus_data(data_string, "table", None);
        assert!(output.contains("Hex"));
    }
}