dlt_parse 0.10.1

A library for parsing the "Diagnostic Log and Trace" network protocol (currently without payload interpretation).
Documentation 
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
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116

use std::{
    fs::File,
    io::{BufReader, BufWriter},
    path::PathBuf,
    time::UNIX_EPOCH,
};

use dlt_parse::{
    storage::{DltStorageWriter, StorageHeader},
    SliceIterator,
};
use etherparse::{SlicedPacket, TransportSlice::Udp};
use rpcap::read::PcapReader;
use structopt::StructOpt;

/// Expected command line arguments
#[derive(StructOpt, Debug)]
#[structopt(name = "pcap2dlt")]
struct CommandLineArguments {
    /// Udp port on which dlt packets are send.
    #[structopt(short("u"), long("udp-dest-port"))]
    udp_dest_port: u16,

    /// Path to pcap file.
    #[structopt(short("o"), long("output-file"), parse(from_os_str))]
    output_file: PathBuf,

    /// Path to pcap file.
    #[structopt(parse(from_os_str))]
    pcap_file: PathBuf,
}

#[derive(Debug)]
pub enum Error {
    IoError(std::io::Error),
    PcapError(rpcap::PcapError),
}

impl From<std::io::Error> for Error {
    fn from(err: std::io::Error) -> Error {
        Error::IoError(err)
    }
}

impl From<rpcap::PcapError> for Error {
    fn from(err: rpcap::PcapError) -> Error {
        Error::PcapError(err)
    }
}

fn main() -> Result<(), Error> {
    let args = CommandLineArguments::from_args();

    let dlt_file = File::create(args.output_file)?;
    let mut dlt_writer = DltStorageWriter::new(BufWriter::new(dlt_file));

    let pcap_file = File::open(args.pcap_file)?;
    let (_, mut reader) = PcapReader::new(BufReader::new(pcap_file))?;

    while let Some(packet) = reader.next()? {
        // decode from ethernet to udp layer
        let sliced = match SlicedPacket::from_ethernet(packet.data) {
            Ok(value) => value,
            Err(err) => {
                eprintln!("Error parsing packet: {}", err);
                continue;
            }
        };

        // verify the packet is an udp packet with the correct destination port
        if let Some(Udp(udp)) = sliced.transport {
            if udp.destination_port() != args.udp_dest_port {
                // skip packet if the port is not matching
                continue;
            }
        } else {
            // skip packet if not relevant
            continue;
        }

        // iterate over the dlt messages in the packet
        for dlt_packet in SliceIterator::new(sliced.payload) {
            let dlt_packet = match dlt_packet {
                Ok(value) => value,
                Err(err) => {
                    eprintln!("Error parsing dlt: {}", err);
                    break;
                }
            };

            // determine ecu id
            let ecu_id = if let Some(ecu_id) = dlt_packet.header().ecu_id {
                ecu_id
            } else {
                // you might want to determine the ecu id via the ip here
                // if you have that option
                [0, 0, 0, 0]
            };

            // determine utc time (unwrap is ok, as all pcap timestamps start at UNIX_EPOCH)
            let d = packet.time.duration_since(UNIX_EPOCH).unwrap();

            // write the packet
            dlt_writer.write_slice(
                StorageHeader {
                    timestamp_seconds: d.as_secs() as u32,
                    timestamp_microseconds: d.subsec_micros(),
                    ecu_id,
                },
                dlt_packet,
            )?;
        }
    }

    Ok(())
}