-
Notifications
You must be signed in to change notification settings - Fork 5
/
print_messages.rs
72 lines (63 loc) · 2.07 KB
/
print_messages.rs
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
use etherparse::*;
use rpcap::read::PcapReader;
use someip_parse::*;
use std::fs::File;
use std::io::BufReader;
fn main() -> Result<(), Error> {
let pcap_path = std::env::args()
.nth(1)
.expect("Expected PCAP file as argument");
let (_, mut reader) = PcapReader::new(BufReader::new(File::open(pcap_path)?))?;
while let Some(packet) = reader.next()? {
// parse ethernet to udp layer
let eth_slice = if let Ok(e) = SlicedPacket::from_ethernet(packet.data) {
e
} else {
// skip broken ethernet packets
continue;
};
// check that the packet is an UDP packet
use TransportSlice::*;
let _ = if let Some(Udp(u)) = eth_slice.transport {
u
} else {
// skip non udp packets
continue;
};
// trying parsing some ip messages located in a udp payload
for someip_message in SomeipMsgsIterator::new(eth_slice.payload) {
match someip_message {
Ok(value) => {
if value.is_someip_sd() {
println!("someip service discovery packet");
} else {
println!(
"0x{:x} (service id: 0x{:x}, method/event id: 0x{:x})",
value.message_id(),
value.service_id(),
value.event_or_method_id()
);
}
println!(" with payload {:?}", value.payload())
}
Err(_) => {} //error reading a someip packet (based on size, protocol version value or message type value)
}
}
}
Ok(())
}
#[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)
}
}