use crate::err::packet::BuildWriteError;
use super::*;
use std::{io, marker};
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
pub struct PacketBuilder {}
impl PacketBuilder {
pub fn ethernet2(source: [u8; 6], destination: [u8; 6]) -> PacketBuilderStep<Ethernet2Header> {
PacketBuilderStep {
state: PacketImpl {
link_header: Some(LinkHeader::Ethernet2(Ethernet2Header {
source,
destination,
ether_type: EtherType(0), })),
vlan_header: None,
net_header: None,
transport_header: None,
},
_marker: marker::PhantomData::<Ethernet2Header> {},
}
}
pub fn linux_sll(
packet_type: LinuxSllPacketType,
sender_address_valid_length: u16,
sender_address: [u8; 8],
) -> PacketBuilderStep<LinuxSllHeader> {
PacketBuilderStep {
state: PacketImpl {
link_header: Some(LinkHeader::LinuxSll(LinuxSllHeader {
packet_type,
arp_hrd_type: ArpHardwareId::ETHERNET,
sender_address_valid_length,
sender_address,
protocol_type: LinuxSllProtocolType::EtherType(EtherType(0)), })),
vlan_header: None,
net_header: None,
transport_header: None,
},
_marker: marker::PhantomData::<LinuxSllHeader> {},
}
}
pub fn ipv4(
source: [u8; 4],
destination: [u8; 4],
time_to_live: u8,
) -> PacketBuilderStep<IpHeaders> {
PacketBuilderStep {
state: PacketImpl {
link_header: None,
vlan_header: None,
net_header: None,
transport_header: None,
},
_marker: marker::PhantomData::<Ethernet2Header> {},
}
.ipv4(source, destination, time_to_live)
}
pub fn ipv6(
source: [u8; 16],
destination: [u8; 16],
hop_limit: u8,
) -> PacketBuilderStep<IpHeaders> {
PacketBuilderStep {
state: PacketImpl {
link_header: None,
vlan_header: None,
net_header: None,
transport_header: None,
},
_marker: marker::PhantomData::<Ethernet2Header> {},
}
.ipv6(source, destination, hop_limit)
}
pub fn ip(ip_header: IpHeaders) -> PacketBuilderStep<IpHeaders> {
PacketBuilderStep {
state: PacketImpl {
link_header: None,
vlan_header: None,
net_header: None,
transport_header: None,
},
_marker: marker::PhantomData::<Ethernet2Header> {},
}
.ip(ip_header)
}
}
struct PacketImpl {
link_header: Option<LinkHeader>,
net_header: Option<NetHeaders>,
vlan_header: Option<VlanHeader>,
transport_header: Option<TransportHeader>,
}
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
pub struct PacketBuilderStep<LastStep> {
state: PacketImpl,
_marker: marker::PhantomData<LastStep>,
}
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
impl PacketBuilderStep<Ethernet2Header> {
pub fn ipv4(
mut self,
source: [u8; 4],
destination: [u8; 4],
time_to_live: u8,
) -> PacketBuilderStep<IpHeaders> {
self.state.net_header = Some(NetHeaders::Ipv4(
Ipv4Header {
source,
destination,
time_to_live,
..Default::default()
},
Default::default(),
));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<IpHeaders> {},
}
}
pub fn ip(mut self, ip_header: IpHeaders) -> PacketBuilderStep<IpHeaders> {
self.state.net_header = Some(match ip_header {
IpHeaders::Ipv4(header, exts) => NetHeaders::Ipv4(header, exts),
IpHeaders::Ipv6(header, exts) => NetHeaders::Ipv6(header, exts),
});
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<IpHeaders> {},
}
}
pub fn ipv6(
mut self,
source: [u8; 16],
destination: [u8; 16],
hop_limit: u8,
) -> PacketBuilderStep<IpHeaders> {
self.state.net_header = Some(NetHeaders::Ipv6(
Ipv6Header {
traffic_class: 0,
flow_label: Ipv6FlowLabel::ZERO,
payload_length: 0, next_header: IpNumber(255), hop_limit,
source,
destination,
},
Default::default(),
));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<IpHeaders> {},
}
}
pub fn vlan(mut self, vlan: VlanHeader) -> PacketBuilderStep<VlanHeader> {
self.state.vlan_header = Some(vlan);
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<VlanHeader> {},
}
}
pub fn single_vlan(mut self, vlan_identifier: VlanId) -> PacketBuilderStep<VlanHeader> {
self.state.vlan_header = Some(VlanHeader::Single(SingleVlanHeader {
pcp: VlanPcp::ZERO,
drop_eligible_indicator: false,
vlan_id: vlan_identifier,
ether_type: EtherType(0), }));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<VlanHeader> {},
}
}
pub fn double_vlan(
mut self,
outer_vlan_identifier: VlanId,
inner_vlan_identifier: VlanId,
) -> PacketBuilderStep<VlanHeader> {
self.state.vlan_header = Some(VlanHeader::Double(DoubleVlanHeader {
outer: SingleVlanHeader {
pcp: VlanPcp::ZERO,
drop_eligible_indicator: false,
vlan_id: outer_vlan_identifier,
ether_type: EtherType(0), },
inner: SingleVlanHeader {
pcp: VlanPcp::ZERO,
drop_eligible_indicator: false,
vlan_id: inner_vlan_identifier,
ether_type: EtherType(0), },
}));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<VlanHeader> {},
}
}
pub fn arp(mut self, arp_packet: ArpPacket) -> PacketBuilderStep<ArpPacket> {
self.state.net_header = Some(NetHeaders::Arp(arp_packet));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<ArpPacket> {},
}
}
}
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
impl PacketBuilderStep<LinuxSllHeader> {
pub fn ip(self, ip_header: IpHeaders) -> PacketBuilderStep<IpHeaders> {
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Ethernet2Header> {},
}
.ip(ip_header)
}
pub fn ipv6(
self,
source: [u8; 16],
destination: [u8; 16],
hop_limit: u8,
) -> PacketBuilderStep<IpHeaders> {
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Ethernet2Header> {},
}
.ipv6(source, destination, hop_limit)
}
pub fn ipv4(
self,
source: [u8; 4],
destination: [u8; 4],
time_to_live: u8,
) -> PacketBuilderStep<IpHeaders> {
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Ethernet2Header> {},
}
.ipv4(source, destination, time_to_live)
}
pub fn arp(mut self, arp_packet: ArpPacket) -> PacketBuilderStep<ArpPacket> {
self.state.net_header = Some(NetHeaders::Arp(arp_packet));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<ArpPacket> {},
}
}
}
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
impl PacketBuilderStep<VlanHeader> {
pub fn ip(self, ip_header: IpHeaders) -> PacketBuilderStep<IpHeaders> {
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Ethernet2Header> {},
}
.ip(ip_header)
}
pub fn ipv6(
self,
source: [u8; 16],
destination: [u8; 16],
hop_limit: u8,
) -> PacketBuilderStep<IpHeaders> {
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Ethernet2Header> {},
}
.ipv6(source, destination, hop_limit)
}
pub fn ipv4(
self,
source: [u8; 4],
destination: [u8; 4],
time_to_live: u8,
) -> PacketBuilderStep<IpHeaders> {
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Ethernet2Header> {},
}
.ipv4(source, destination, time_to_live)
}
pub fn arp(mut self, arp_packet: ArpPacket) -> PacketBuilderStep<ArpPacket> {
self.state.net_header = Some(NetHeaders::Arp(arp_packet));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<ArpPacket> {},
}
}
}
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
impl PacketBuilderStep<IpHeaders> {
pub fn icmpv4(mut self, icmp_type: Icmpv4Type) -> PacketBuilderStep<Icmpv4Header> {
self.state.transport_header = Some(TransportHeader::Icmpv4(Icmpv4Header {
icmp_type,
checksum: 0, }));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Icmpv4Header> {},
}
}
pub fn icmpv4_raw(
mut self,
type_u8: u8,
code_u8: u8,
bytes5to8: [u8; 4],
) -> PacketBuilderStep<Icmpv4Header> {
let icmp_type = Icmpv4Type::Unknown {
type_u8,
code_u8,
bytes5to8,
};
self.state.transport_header = Some(TransportHeader::Icmpv4(Icmpv4Header {
icmp_type,
checksum: 0, }));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Icmpv4Header> {},
}
}
pub fn icmpv4_echo_request(mut self, id: u16, seq: u16) -> PacketBuilderStep<Icmpv4Header> {
let echo_header = IcmpEchoHeader { id, seq };
let icmpv4_echo = Icmpv4Header::new(Icmpv4Type::EchoRequest(echo_header));
self.state.transport_header = Some(TransportHeader::Icmpv4(icmpv4_echo));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Icmpv4Header> {},
}
}
pub fn icmpv4_echo_reply(mut self, id: u16, seq: u16) -> PacketBuilderStep<Icmpv4Header> {
let echo_header = IcmpEchoHeader { id, seq };
let icmpv4_echo = Icmpv4Header::new(Icmpv4Type::EchoReply(echo_header));
self.state.transport_header = Some(TransportHeader::Icmpv4(icmpv4_echo));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Icmpv4Header> {},
}
}
pub fn icmpv6(mut self, icmp_type: Icmpv6Type) -> PacketBuilderStep<Icmpv6Header> {
self.state.transport_header = Some(TransportHeader::Icmpv6(Icmpv6Header {
icmp_type,
checksum: 0, }));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Icmpv6Header> {},
}
}
pub fn icmpv6_raw(
mut self,
type_u8: u8,
code_u8: u8,
bytes5to8: [u8; 4],
) -> PacketBuilderStep<Icmpv6Header> {
let icmp_type = Icmpv6Type::Unknown {
type_u8,
code_u8,
bytes5to8,
};
self.state.transport_header = Some(TransportHeader::Icmpv6(Icmpv6Header {
icmp_type,
checksum: 0, }));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Icmpv6Header> {},
}
}
pub fn icmpv6_echo_request(mut self, id: u16, seq: u16) -> PacketBuilderStep<Icmpv6Header> {
let echo_header = IcmpEchoHeader { id, seq };
let icmpv6_echo = Icmpv6Header::new(Icmpv6Type::EchoRequest(echo_header));
self.state.transport_header = Some(TransportHeader::Icmpv6(icmpv6_echo));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Icmpv6Header> {},
}
}
pub fn icmpv6_echo_reply(mut self, id: u16, seq: u16) -> PacketBuilderStep<Icmpv6Header> {
let echo_header = IcmpEchoHeader { seq, id };
let icmpv6_echo = Icmpv6Header::new(Icmpv6Type::EchoReply(echo_header));
self.state.transport_header = Some(TransportHeader::Icmpv6(icmpv6_echo));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<Icmpv6Header> {},
}
}
pub fn udp(mut self, source_port: u16, destination_port: u16) -> PacketBuilderStep<UdpHeader> {
self.state.transport_header = Some(TransportHeader::Udp(UdpHeader {
source_port,
destination_port,
length: 0, checksum: 0, }));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<UdpHeader> {},
}
}
pub fn tcp(
mut self,
source_port: u16,
destination_port: u16,
sequence_number: u32,
window_size: u16,
) -> PacketBuilderStep<TcpHeader> {
self.state.transport_header = Some(TransportHeader::Tcp(TcpHeader::new(
source_port,
destination_port,
sequence_number,
window_size,
)));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<TcpHeader> {},
}
}
pub fn tcp_header(mut self, tcp_header: TcpHeader) -> PacketBuilderStep<TcpHeader> {
self.state.transport_header = Some(TransportHeader::Tcp(tcp_header));
PacketBuilderStep {
state: self.state,
_marker: marker::PhantomData::<TcpHeader> {},
}
}
pub fn write<T: io::Write + Sized>(
mut self,
writer: &mut T,
last_next_header_ip_number: IpNumber,
payload: &[u8],
) -> Result<(), BuildWriteError> {
match &mut (self.state.net_header) {
Some(NetHeaders::Ipv4(ref mut ip, ref mut exts)) => {
ip.protocol = exts.set_next_headers(last_next_header_ip_number);
}
Some(NetHeaders::Ipv6(ref mut ip, ref mut exts)) => {
ip.next_header = exts.set_next_headers(last_next_header_ip_number);
}
_ => {}
}
final_write_with_net(self, writer, payload)
}
pub fn size(&self, payload_size: usize) -> usize {
final_size(self, payload_size)
}
}
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
impl PacketBuilderStep<Icmpv4Header> {
pub fn write<T: io::Write + Sized>(
self,
writer: &mut T,
payload: &[u8],
) -> Result<(), BuildWriteError> {
final_write_with_net(self, writer, payload)
}
pub fn size(&self, payload_size: usize) -> usize {
final_size(self, payload_size)
}
}
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
impl PacketBuilderStep<Icmpv6Header> {
pub fn write<T: io::Write + Sized>(
self,
writer: &mut T,
payload: &[u8],
) -> Result<(), BuildWriteError> {
final_write_with_net(self, writer, payload)
}
pub fn size(&self, payload_size: usize) -> usize {
final_size(self, payload_size)
}
}
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
impl PacketBuilderStep<UdpHeader> {
pub fn write<T: io::Write + Sized>(
self,
writer: &mut T,
payload: &[u8],
) -> Result<(), BuildWriteError> {
final_write_with_net(self, writer, payload)
}
pub fn size(&self, payload_size: usize) -> usize {
final_size(self, payload_size)
}
}
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
impl PacketBuilderStep<TcpHeader> {
pub fn ns(mut self) -> PacketBuilderStep<TcpHeader> {
self.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap()
.ns = true;
self
}
pub fn fin(mut self) -> PacketBuilderStep<TcpHeader> {
self.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap()
.fin = true;
self
}
pub fn syn(mut self) -> PacketBuilderStep<TcpHeader> {
self.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap()
.syn = true;
self
}
pub fn rst(mut self) -> PacketBuilderStep<TcpHeader> {
self.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap()
.rst = true;
self
}
pub fn psh(mut self) -> PacketBuilderStep<TcpHeader> {
self.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap()
.psh = true;
self
}
pub fn ack(mut self, acknowledgment_number: u32) -> PacketBuilderStep<TcpHeader> {
{
let header = self
.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap();
header.ack = true;
header.acknowledgment_number = acknowledgment_number;
}
self
}
pub fn urg(mut self, urgent_pointer: u16) -> PacketBuilderStep<TcpHeader> {
{
let header = self
.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap();
header.urg = true;
header.urgent_pointer = urgent_pointer;
}
self
}
pub fn ece(mut self) -> PacketBuilderStep<TcpHeader> {
self.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap()
.ece = true;
self
}
pub fn cwr(mut self) -> PacketBuilderStep<TcpHeader> {
self.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap()
.cwr = true;
self
}
pub fn options(
mut self,
options: &[TcpOptionElement],
) -> Result<PacketBuilderStep<TcpHeader>, TcpOptionWriteError> {
self.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap()
.set_options(options)?;
Ok(self)
}
pub fn options_raw(
mut self,
options: &[u8],
) -> Result<PacketBuilderStep<TcpHeader>, TcpOptionWriteError> {
self.state
.transport_header
.as_mut()
.unwrap()
.mut_tcp()
.unwrap()
.set_options_raw(options)?;
Ok(self)
}
pub fn write<T: io::Write + Sized>(
self,
writer: &mut T,
payload: &[u8],
) -> Result<(), BuildWriteError> {
final_write_with_net(self, writer, payload)
}
pub fn size(&self, payload_size: usize) -> usize {
final_size(self, payload_size)
}
}
#[cfg_attr(docsrs, doc(cfg(feature = "std")))]
impl PacketBuilderStep<ArpPacket> {
pub fn write<T: io::Write + Sized>(self, writer: &mut T) -> Result<(), BuildWriteError> {
final_write_with_net(self, writer, &[])?;
Ok(())
}
pub fn size(&self) -> usize {
final_size(self, 0)
}
}
fn final_write_with_net<T: io::Write + Sized, B>(
builder: PacketBuilderStep<B>,
writer: &mut T,
payload: &[u8],
) -> Result<(), BuildWriteError> {
use BuildWriteError::*;
use NetHeaders::*;
let link = builder.state.link_header;
let vlan = builder.state.vlan_header;
let net = builder.state.net_header;
let mut transport = builder.state.transport_header;
let net_ether_type = match &net {
Some(Ipv4(_, _)) => ether_type::IPV4,
Some(Ipv6(_, _)) => ether_type::IPV6,
Some(Arp(_)) => ether_type::ARP,
None => unreachable!(),
};
if let Some(link) = link {
match link {
LinkHeader::Ethernet2(mut eth) => {
eth.ether_type = {
use crate::VlanHeader::*;
match &vlan {
Some(Single(_)) => ether_type::VLAN_TAGGED_FRAME,
Some(Double(_)) => ether_type::PROVIDER_BRIDGING,
None => net_ether_type,
}
};
eth.write(writer).map_err(Io)?;
}
LinkHeader::LinuxSll(mut linux_sll) => {
debug_assert_eq!(linux_sll.arp_hrd_type, ArpHardwareId::ETHERNET);
linux_sll.protocol_type.change_value(net_ether_type.into());
linux_sll.write(writer).map_err(Io)?;
}
}
}
use crate::VlanHeader::*;
match vlan {
Some(Single(mut value)) => {
value.ether_type = net_ether_type;
value.write(writer).map_err(Io)?;
}
Some(Double(mut value)) => {
value.outer.ether_type = ether_type::VLAN_TAGGED_FRAME;
value.inner.ether_type = net_ether_type;
value.outer.write(writer).map_err(Io)?;
value.inner.write(writer).map_err(Io)?;
}
None => {}
}
use TransportHeader::*;
match &mut transport {
Some(Udp(ref mut udp)) => {
udp.length = (UdpHeader::LEN + payload.len()) as u16;
}
Some(Tcp(_)) => {}
Some(Icmpv4(_)) => {}
Some(Icmpv6(_)) => {}
None => {}
}
match net {
Some(NetHeaders::Ipv4(mut ip, mut ip_exts)) => {
ip.set_payload_len(
ip_exts.header_len()
+ transport.as_ref().map(|v| v.header_len()).unwrap_or(0)
+ payload.len(),
)
.map_err(PayloadLen)?;
if let Some(transport) = &transport {
ip.protocol = ip_exts.set_next_headers(match &transport {
Icmpv4(_) => ip_number::ICMP,
Icmpv6(_) => ip_number::IPV6_ICMP,
Udp(_) => ip_number::UDP,
Tcp(_) => ip_number::TCP,
});
}
ip.write(writer).map_err(Io)?;
ip_exts.write(writer, ip.protocol).map_err(|err| {
use err::ipv4_exts::HeaderWriteError as I;
match err {
I::Io(err) => Io(err),
I::Content(err) => Ipv4Exts(err),
}
})?;
if let Some(t) = &mut transport {
t.update_checksum_ipv4(&ip, payload).map_err(|err| {
use err::packet::TransportChecksumError as I;
match err {
I::PayloadLen(err) => PayloadLen(err),
I::Icmpv6InIpv4 => Icmpv6InIpv4,
}
})?;
}
}
Some(NetHeaders::Ipv6(mut ip, mut ip_exts)) => {
ip.set_payload_length(
ip_exts.header_len()
+ transport.as_ref().map(|v| v.header_len()).unwrap_or(0)
+ payload.len(),
)
.map_err(PayloadLen)?;
if let Some(transport) = &transport {
ip.next_header = ip_exts.set_next_headers(match &transport {
Icmpv4(_) => ip_number::ICMP,
Icmpv6(_) => ip_number::IPV6_ICMP,
Udp(_) => ip_number::UDP,
Tcp(_) => ip_number::TCP,
});
}
ip.write(writer).map_err(Io)?;
ip_exts.write(writer, ip.next_header).map_err(|err| {
use err::ipv6_exts::HeaderWriteError as I;
match err {
I::Io(err) => Io(err),
I::Content(err) => Ipv6Exts(err),
}
})?;
if let Some(t) = &mut transport {
t.update_checksum_ipv6(&ip, payload).map_err(PayloadLen)?;
}
}
Some(NetHeaders::Arp(arp)) => {
writer.write_all(&arp.to_bytes()).map_err(Io)?;
}
None => {}
}
if let Some(transport) = transport {
transport.write(writer).map_err(Io)?;
}
writer.write_all(payload).map_err(Io)?;
Ok(())
}
fn final_size<B>(builder: &PacketBuilderStep<B>, payload_size: usize) -> usize {
use crate::NetHeaders::*;
use crate::TransportHeader::*;
use crate::VlanHeader::*;
(match builder.state.link_header {
Some(ref header) => header.header_len(),
None => 0,
}) + match builder.state.vlan_header {
Some(Single(_)) => SingleVlanHeader::LEN,
Some(Double(_)) => SingleVlanHeader::LEN * 2,
None => 0,
} + match builder.state.net_header {
Some(Ipv4(ref value, ref ext)) => value.header_len() + ext.header_len(),
Some(Ipv6(_, ref ext)) => Ipv6Header::LEN + ext.header_len(),
Some(Arp(ref packet)) => packet.packet_len(),
None => 0,
} + match builder.state.transport_header {
Some(Icmpv4(ref value)) => value.header_len(),
Some(Icmpv6(ref value)) => value.header_len(),
Some(Udp(_)) => UdpHeader::LEN,
Some(Tcp(ref value)) => value.header_len(),
None => 0,
} + payload_size
}
#[cfg(test)]
mod white_box_tests {
use super::*;
use alloc::vec::Vec;
#[test]
fn size() {
assert_eq!(
0,
PacketBuilderStep::<UdpHeader> {
state: PacketImpl {
link_header: None,
net_header: None,
vlan_header: None,
transport_header: None,
},
_marker: marker::PhantomData::<UdpHeader> {}
}
.size(0)
);
}
#[test]
#[should_panic]
fn final_write_panic_missing_ip() {
let mut writer = Vec::new();
final_write_with_net(
PacketBuilderStep::<UdpHeader> {
state: PacketImpl {
link_header: None,
net_header: None,
vlan_header: None,
transport_header: None,
},
_marker: marker::PhantomData::<UdpHeader> {},
},
&mut writer,
&[],
)
.unwrap();
}
}
#[cfg(test)]
mod test {
use super::*;
use crate::test_gens::*;
use alloc::{vec, vec::Vec};
use proptest::prelude::*;
use std::io::Read;
#[test]
fn eth_arp() {
let expected_header = ArpPacket::new(
ArpHardwareId::ETHERNET,
EtherType::IPV4,
ArpOperation::REQUEST,
&[20, 30, 40, 50, 60, 70],
&[10, 1, 1, 5],
&[00, 01, 02, 03, 04, 05],
&[192, 168, 1, 2],
)
.unwrap();
let mut serialized = Vec::new();
let pkg = PacketBuilder::ethernet2(
[0x00, 0x1b, 0x21, 0x0f, 0x91, 0x9b],
[0xde, 0xad, 0xc0, 0x00, 0xff, 0xee],
)
.arp(expected_header.clone());
let target_size = pkg.size();
pkg.write(&mut serialized).unwrap();
assert_eq!(serialized.len(), target_size);
use std::io::Cursor;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
Ethernet2Header::read(&mut cursor).unwrap(),
Ethernet2Header {
source: [0x00, 0x1b, 0x21, 0x0f, 0x91, 0x9b],
destination: [0xde, 0xad, 0xc0, 0x00, 0xff, 0xee],
ether_type: ether_type::ARP
}
);
assert_eq!(ArpPacket::read(&mut cursor).unwrap(), expected_header);
}
#[test]
fn eth_vlan_arp() {
let expected_arp = ArpPacket::new(
ArpHardwareId::ETHERNET,
EtherType::IPV4,
ArpOperation::REQUEST,
&[20, 30, 40, 50, 60, 70],
&[10, 1, 1, 5],
&[00, 01, 02, 03, 04, 05],
&[192, 168, 1, 2],
)
.unwrap();
let vlan = SingleVlanHeader {
pcp: VlanPcp::ZERO,
drop_eligible_indicator: false,
vlan_id: VlanId::try_new(123).unwrap(),
ether_type: EtherType(0), };
let mut serialized = Vec::new();
let pkg = PacketBuilder::ethernet2(
[0x00, 0x1b, 0x21, 0x0f, 0x91, 0x9b],
[0xde, 0xad, 0xc0, 0x00, 0xff, 0xee],
)
.vlan(VlanHeader::Single(vlan.clone()))
.arp(expected_arp.clone());
let target_size = pkg.size();
pkg.write(&mut serialized).unwrap();
assert_eq!(serialized.len(), target_size);
use std::io::Cursor;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
Ethernet2Header::read(&mut cursor).unwrap(),
Ethernet2Header {
source: [0x00, 0x1b, 0x21, 0x0f, 0x91, 0x9b],
destination: [0xde, 0xad, 0xc0, 0x00, 0xff, 0xee],
ether_type: ether_type::VLAN_TAGGED_FRAME
}
);
let mut expected_vlan = vlan.clone();
expected_vlan.ether_type = EtherType::ARP;
assert_eq!(SingleVlanHeader::read(&mut cursor).unwrap(), expected_vlan);
assert_eq!(ArpPacket::read(&mut cursor).unwrap(), expected_arp);
}
#[test]
fn eth_ipv4_udp() {
let in_payload = [24, 25, 26, 27];
let mut serialized = Vec::new();
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.ipv4([13, 14, 15, 16], [17, 18, 19, 20], 21)
.udp(22, 23)
.write(&mut serialized, &in_payload)
.unwrap();
let expected_ip_size: usize = UdpHeader::LEN + in_payload.len();
assert_eq!(
expected_ip_size + Ethernet2Header::LEN + Ipv4Header::MIN_LEN,
serialized.len()
);
use std::io::Cursor;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
Ethernet2Header::read(&mut cursor).unwrap(),
Ethernet2Header {
source: [1, 2, 3, 4, 5, 6],
destination: [7, 8, 9, 10, 11, 12],
ether_type: ether_type::IPV4
}
);
let ip_actual = Ipv4Header::read(&mut cursor).unwrap();
let mut ip_expected = Ipv4Header::new(
expected_ip_size as u16,
21, ip_number::UDP,
[13, 14, 15, 16],
[17, 18, 19, 20],
)
.unwrap();
ip_expected.header_checksum = ip_expected.calc_header_checksum();
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv4_checksum(22, 23, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn linuxsll_ipv4_udp() {
let in_payload = [24, 25, 26, 27];
let mut serialized = Vec::new();
PacketBuilder::linux_sll(LinuxSllPacketType::OUTGOING, 6, [7, 8, 9, 10, 11, 12, 0, 0])
.ipv4([13, 14, 15, 16], [17, 18, 19, 20], 21)
.udp(22, 23)
.write(&mut serialized, &in_payload)
.unwrap();
let expected_ip_size: usize = UdpHeader::LEN + in_payload.len();
assert_eq!(
expected_ip_size + LinuxSllHeader::LEN + Ipv4Header::MIN_LEN,
serialized.len()
);
use std::io::Cursor;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
LinuxSllHeader::read(&mut cursor).unwrap(),
LinuxSllHeader {
packet_type: LinuxSllPacketType::OUTGOING,
arp_hrd_type: ArpHardwareId::ETHERNET,
sender_address_valid_length: 6,
sender_address: [7, 8, 9, 10, 11, 12, 0, 0],
protocol_type: LinuxSllProtocolType::EtherType(EtherType::IPV4)
}
);
let ip_actual = Ipv4Header::read(&mut cursor).unwrap();
let mut ip_expected = Ipv4Header::new(
expected_ip_size as u16,
21, ip_number::UDP,
[13, 14, 15, 16],
[17, 18, 19, 20],
)
.unwrap();
ip_expected.header_checksum = ip_expected.calc_header_checksum();
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv4_checksum(22, 23, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn linuxsll_arp() {
let expected_arp = ArpPacket::new(
ArpHardwareId::ETHERNET,
EtherType::IPV4,
ArpOperation::REQUEST,
&[20, 30, 40, 50, 60, 70],
&[10, 1, 1, 5],
&[00, 01, 02, 03, 04, 05],
&[192, 168, 1, 2],
)
.unwrap();
let builder =
PacketBuilder::linux_sll(LinuxSllPacketType::OUTGOING, 6, [7, 8, 9, 10, 11, 12, 0, 0])
.arp(expected_arp.clone());
let predicted_size = builder.size();
let mut serialized = Vec::with_capacity(builder.size());
builder.write(&mut serialized).unwrap();
assert_eq!(predicted_size, serialized.len());
use std::io::Cursor;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
LinuxSllHeader::read(&mut cursor).unwrap(),
LinuxSllHeader {
packet_type: LinuxSllPacketType::OUTGOING,
arp_hrd_type: ArpHardwareId::ETHERNET,
sender_address_valid_length: 6,
sender_address: [7, 8, 9, 10, 11, 12, 0, 0],
protocol_type: LinuxSllProtocolType::EtherType(EtherType::ARP)
}
);
assert_eq!(ArpPacket::read(&mut cursor).unwrap(), expected_arp);
}
#[test]
fn ipv4() {
let auth_ext = IpAuthHeader::new(0.into(), 1, 2, &[3, 4, 5, 6]).unwrap();
let in_payload = [22, 23, 24, 25];
let mut serialized = Vec::new();
let builder = PacketBuilder::ip(IpHeaders::Ipv4(
Ipv4Header::new(
in_payload.len() as u16,
21,
0.into(),
[13, 14, 15, 16],
[17, 18, 19, 20],
)
.unwrap(),
Ipv4Extensions {
auth: Some(auth_ext.clone()),
},
));
assert_eq!(
builder.size(in_payload.len()),
Ipv4Header::MIN_LEN + auth_ext.header_len() + in_payload.len()
);
serialized.reserve(builder.size(in_payload.len()));
builder
.write(&mut serialized, 200.into(), &in_payload)
.unwrap();
assert_eq!(
Ipv4Header::MIN_LEN + auth_ext.header_len() + in_payload.len(),
serialized.len()
);
use std::io::{Cursor, Read};
let mut cursor = Cursor::new(&serialized);
let ip_actual = Ipv4Header::read(&mut cursor).unwrap();
let mut ip_expected = Ipv4Header::new(
(auth_ext.header_len() + in_payload.len()) as u16,
21, ip_number::AUTH, [13, 14, 15, 16],
[17, 18, 19, 20],
)
.unwrap();
ip_expected.header_checksum = ip_expected.calc_header_checksum();
assert_eq!(ip_actual, ip_expected);
let auth_actual = IpAuthHeader::read(&mut cursor).unwrap();
assert_eq!(
auth_actual,
IpAuthHeader::new(
200.into(), 1,
2,
&[3, 4, 5, 6]
)
.unwrap()
);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn ipv6() {
let auth_ext = IpAuthHeader::new(0.into(), 1, 2, &[3, 4, 5, 6]).unwrap();
let in_payload = [48, 49, 50, 51];
let mut serialized = Vec::new();
let builder = PacketBuilder::ip(IpHeaders::Ipv6(
Ipv6Header {
traffic_class: 0,
flow_label: Ipv6FlowLabel::ZERO,
payload_length: in_payload.len() as u16,
next_header: 0.into(),
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
},
Ipv6Extensions {
hop_by_hop_options: None,
destination_options: None,
routing: None,
fragment: None,
auth: Some(auth_ext.clone()),
},
));
assert_eq!(
builder.size(in_payload.len()),
Ipv6Header::LEN + auth_ext.header_len() + in_payload.len()
);
builder
.write(&mut serialized, 200.into(), &in_payload)
.unwrap();
assert_eq!(
Ipv6Header::LEN + auth_ext.header_len() + in_payload.len(),
serialized.len()
);
use std::io::{Cursor, Read};
let mut cursor = Cursor::new(&serialized);
let ip_actual = Ipv6Header::read(&mut cursor).unwrap();
let ip_expected = Ipv6Header {
traffic_class: 0,
flow_label: Ipv6FlowLabel::ZERO,
payload_length: (auth_ext.header_len() + in_payload.len()) as u16,
next_header: ip_number::AUTH, hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
};
assert_eq!(ip_actual, ip_expected);
let auth_actual = IpAuthHeader::read(&mut cursor).unwrap();
assert_eq!(
auth_actual,
IpAuthHeader::new(
200.into(), 1,
2,
&[3, 4, 5, 6]
)
.unwrap()
);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn ipv4_udp() {
let in_payload = [24, 25, 26, 27];
let mut serialized = Vec::new();
PacketBuilder::ipv4([13, 14, 15, 16], [17, 18, 19, 20], 21)
.udp(22, 23)
.write(&mut serialized, &in_payload)
.unwrap();
let expected_ip_size: usize = UdpHeader::LEN + in_payload.len();
assert_eq!(expected_ip_size + Ipv4Header::MIN_LEN, serialized.len());
use std::io::{Cursor, Read};
let mut cursor = Cursor::new(&serialized);
let ip_actual = Ipv4Header::read(&mut cursor).unwrap();
let mut ip_expected = Ipv4Header::new(
expected_ip_size as u16,
21, ip_number::UDP,
[13, 14, 15, 16],
[17, 18, 19, 20],
)
.unwrap();
ip_expected.header_checksum = ip_expected.calc_header_checksum();
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv4_checksum(22, 23, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn ipv6_udp() {
let in_payload = [24, 25, 26, 27];
let mut serialized = Vec::new();
PacketBuilder::ipv6(
[
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
[
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
47,
)
.udp(22, 23)
.write(&mut serialized, &in_payload)
.unwrap();
let expected_ip_size: usize = UdpHeader::LEN + in_payload.len();
assert_eq!(expected_ip_size + Ipv6Header::LEN, serialized.len());
use std::io::{Cursor, Read};
let mut cursor = Cursor::new(&serialized);
let ip_actual = Ipv6Header::read(&mut cursor).unwrap();
let ip_expected = Ipv6Header {
traffic_class: 0,
flow_label: Ipv6FlowLabel::ZERO,
payload_length: (UdpHeader::LEN + in_payload.len()) as u16,
next_header: ip_number::UDP,
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
};
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv6_checksum(22, 23, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn ipv4_custom_udp() {
let in_payload = [24, 25, 26, 27];
let mut serialized = Vec::new();
PacketBuilder::ip(IpHeaders::Ipv4(
Ipv4Header::new(
0, 12, ip_number::TCP, [13, 14, 15, 16], [17, 18, 19, 20], )
.unwrap(),
Default::default(),
))
.udp(22, 23)
.write(&mut serialized, &in_payload)
.unwrap();
let expected_ip_size: usize = UdpHeader::LEN + in_payload.len();
assert_eq!(expected_ip_size + Ipv4Header::MIN_LEN, serialized.len());
use std::io::{Cursor, Read};
let mut cursor = Cursor::new(&serialized);
let ip_actual = Ipv4Header::read(&mut cursor).unwrap();
let mut ip_expected = Ipv4Header::new(
expected_ip_size as u16,
12, ip_number::UDP,
[13, 14, 15, 16],
[17, 18, 19, 20],
)
.unwrap();
ip_expected.header_checksum = ip_expected.calc_header_checksum();
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv4_checksum(22, 23, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn eth_ipv6_udp() {
let in_payload = [50, 51, 52, 53];
let mut serialized = Vec::new();
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.ipv6(
[
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
[
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
47,
)
.udp(48, 49)
.write(&mut serialized, &in_payload)
.unwrap();
assert_eq!(
Ethernet2Header::LEN + Ipv6Header::LEN + UdpHeader::LEN + in_payload.len(),
serialized.len()
);
use std::io::Cursor;
use std::io::Read;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
Ethernet2Header::read(&mut cursor).unwrap(),
Ethernet2Header {
source: [1, 2, 3, 4, 5, 6],
destination: [7, 8, 9, 10, 11, 12],
ether_type: ether_type::IPV6
}
);
let ip_actual = Ipv6Header::read(&mut cursor).unwrap();
let ip_expected = Ipv6Header {
traffic_class: 0,
flow_label: Ipv6FlowLabel::ZERO,
payload_length: (UdpHeader::LEN + in_payload.len()) as u16,
next_header: ip_number::UDP,
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
};
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv6_checksum(48, 49, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn linuxsll_ipv6_udp() {
let in_payload = [50, 51, 52, 53];
let mut serialized = Vec::new();
PacketBuilder::linux_sll(LinuxSllPacketType::OUTGOING, 6, [7, 8, 9, 10, 11, 12, 0, 0])
.ipv6(
[
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
[
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
47,
)
.udp(48, 49)
.write(&mut serialized, &in_payload)
.unwrap();
assert_eq!(
LinuxSllHeader::LEN + Ipv6Header::LEN + UdpHeader::LEN + in_payload.len(),
serialized.len()
);
use std::io::Cursor;
use std::io::Read;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
LinuxSllHeader::read(&mut cursor).unwrap(),
LinuxSllHeader {
packet_type: LinuxSllPacketType::OUTGOING,
arp_hrd_type: ArpHardwareId::ETHERNET,
sender_address_valid_length: 6,
sender_address: [7, 8, 9, 10, 11, 12, 0, 0],
protocol_type: LinuxSllProtocolType::EtherType(EtherType::IPV6)
}
);
let ip_actual = Ipv6Header::read(&mut cursor).unwrap();
let ip_expected = Ipv6Header {
traffic_class: 0,
flow_label: Ipv6FlowLabel::ZERO,
payload_length: (UdpHeader::LEN + in_payload.len()) as u16,
next_header: ip_number::UDP,
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
};
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv6_checksum(48, 49, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn eth_single_vlan_ipv4_udp() {
let in_payload = [50, 51, 52, 53];
let mut serialized = Vec::new();
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.single_vlan(0x123.try_into().unwrap())
.ipv4([13, 14, 15, 16], [17, 18, 19, 20], 21)
.udp(48, 49)
.write(&mut serialized, &in_payload)
.unwrap();
let expected_ip_size: usize = UdpHeader::LEN + in_payload.len();
assert_eq!(
expected_ip_size + Ethernet2Header::LEN + Ipv4Header::MIN_LEN + SingleVlanHeader::LEN,
serialized.len()
);
use std::io::Cursor;
use std::io::Read;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
Ethernet2Header::read(&mut cursor).unwrap(),
Ethernet2Header {
source: [1, 2, 3, 4, 5, 6],
destination: [7, 8, 9, 10, 11, 12],
ether_type: ether_type::VLAN_TAGGED_FRAME
}
);
assert_eq!(
SingleVlanHeader::read(&mut cursor).unwrap(),
SingleVlanHeader {
pcp: VlanPcp::ZERO,
drop_eligible_indicator: false,
vlan_id: 0x123.try_into().unwrap(),
ether_type: ether_type::IPV4
}
);
let ip_actual = Ipv4Header::read(&mut cursor).unwrap();
let mut ip_expected = Ipv4Header::new(
expected_ip_size as u16, 21, ip_number::UDP,
[13, 14, 15, 16],
[17, 18, 19, 20],
)
.unwrap();
ip_expected.header_checksum = ip_expected.calc_header_checksum();
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv4_checksum(48, 49, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn eth_double_vlan_ipv6_udp() {
let in_payload = [50, 51, 52, 53];
let mut serialized = Vec::new();
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.double_vlan(0x123.try_into().unwrap(), 0x234.try_into().unwrap())
.ipv6(
[
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
[
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
47,
)
.udp(48, 49)
.write(&mut serialized, &in_payload)
.unwrap();
assert_eq!(
Ethernet2Header::LEN
+ SingleVlanHeader::LEN * 2
+ Ipv6Header::LEN
+ UdpHeader::LEN
+ in_payload.len(),
serialized.len()
);
use std::io::Cursor;
use std::io::Read;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
Ethernet2Header::read(&mut cursor).unwrap(),
Ethernet2Header {
source: [1, 2, 3, 4, 5, 6],
destination: [7, 8, 9, 10, 11, 12],
ether_type: ether_type::PROVIDER_BRIDGING,
}
);
assert_eq!(
SingleVlanHeader::read(&mut cursor).unwrap(),
SingleVlanHeader {
pcp: VlanPcp::ZERO,
drop_eligible_indicator: false,
vlan_id: 0x123.try_into().unwrap(),
ether_type: ether_type::VLAN_TAGGED_FRAME
}
);
assert_eq!(
SingleVlanHeader::read(&mut cursor).unwrap(),
SingleVlanHeader {
pcp: VlanPcp::ZERO,
drop_eligible_indicator: false,
vlan_id: 0x234.try_into().unwrap(),
ether_type: ether_type::IPV6
}
);
let ip_actual = Ipv6Header::read(&mut cursor).unwrap();
let ip_expected = Ipv6Header {
traffic_class: 0,
flow_label: Ipv6FlowLabel::ZERO,
payload_length: (UdpHeader::LEN + in_payload.len()) as u16,
next_header: ip_number::UDP,
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
};
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv6_checksum(48, 49, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn eth_ip_udp() {
let in_payload = [50, 51, 52, 53];
let mut serialized = Vec::new();
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.ip(IpHeaders::Ipv6(
Ipv6Header {
traffic_class: 1,
flow_label: 2.try_into().unwrap(),
payload_length: (UdpHeader::LEN + in_payload.len()) as u16,
next_header: ip_number::UDP,
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
},
Default::default(),
))
.udp(48, 49)
.write(&mut serialized, &in_payload)
.unwrap();
assert_eq!(
Ethernet2Header::LEN + Ipv6Header::LEN + UdpHeader::LEN + in_payload.len(),
serialized.len()
);
use std::io::Cursor;
use std::io::Read;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
Ethernet2Header::read(&mut cursor).unwrap(),
Ethernet2Header {
source: [1, 2, 3, 4, 5, 6],
destination: [7, 8, 9, 10, 11, 12],
ether_type: ether_type::IPV6
}
);
let ip_actual = Ipv6Header::read(&mut cursor).unwrap();
let ip_expected = Ipv6Header {
traffic_class: 1,
flow_label: 2.try_into().unwrap(),
payload_length: (UdpHeader::LEN + in_payload.len()) as u16,
next_header: ip_number::UDP,
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
};
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv6_checksum(48, 49, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn linuxsll_ip_udp() {
let in_payload = [50, 51, 52, 53];
let mut serialized = Vec::new();
PacketBuilder::linux_sll(LinuxSllPacketType::OUTGOING, 6, [7, 8, 9, 10, 11, 12, 0, 0])
.ip(IpHeaders::Ipv6(
Ipv6Header {
traffic_class: 1,
flow_label: 2.try_into().unwrap(),
payload_length: (UdpHeader::LEN + in_payload.len()) as u16,
next_header: ip_number::UDP,
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
},
Default::default(),
))
.udp(48, 49)
.write(&mut serialized, &in_payload)
.unwrap();
assert_eq!(
LinuxSllHeader::LEN + Ipv6Header::LEN + UdpHeader::LEN + in_payload.len(),
serialized.len()
);
use std::io::Cursor;
use std::io::Read;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
LinuxSllHeader::read(&mut cursor).unwrap(),
LinuxSllHeader {
packet_type: LinuxSllPacketType::OUTGOING,
arp_hrd_type: ArpHardwareId::ETHERNET,
sender_address_valid_length: 6,
sender_address: [7, 8, 9, 10, 11, 12, 0, 0],
protocol_type: LinuxSllProtocolType::EtherType(EtherType::IPV6)
}
);
let ip_actual = Ipv6Header::read(&mut cursor).unwrap();
let ip_expected = Ipv6Header {
traffic_class: 1,
flow_label: 2.try_into().unwrap(),
payload_length: (UdpHeader::LEN + in_payload.len()) as u16,
next_header: ip_number::UDP,
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
};
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv6_checksum(48, 49, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
#[test]
fn eth_vlan_ip_udp() {
let in_payload = [50, 51, 52, 53];
let mut serialized = Vec::new();
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.vlan(VlanHeader::Single(SingleVlanHeader {
pcp: 1.try_into().unwrap(),
drop_eligible_indicator: true,
vlan_id: 0x123.try_into().unwrap(),
ether_type: 0.into(), }))
.ip(IpHeaders::Ipv6(
Ipv6Header {
traffic_class: 1,
flow_label: 2.try_into().unwrap(),
payload_length: (UdpHeader::LEN + in_payload.len()) as u16,
next_header: ip_number::UDP,
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
},
Default::default(),
))
.udp(48, 49)
.write(&mut serialized, &in_payload)
.unwrap();
assert_eq!(
Ethernet2Header::LEN
+ SingleVlanHeader::LEN
+ Ipv6Header::LEN
+ UdpHeader::LEN
+ in_payload.len(),
serialized.len()
);
use std::io::Cursor;
use std::io::Read;
let mut cursor = Cursor::new(&serialized);
assert_eq!(
Ethernet2Header::read(&mut cursor).unwrap(),
Ethernet2Header {
source: [1, 2, 3, 4, 5, 6],
destination: [7, 8, 9, 10, 11, 12],
ether_type: ether_type::VLAN_TAGGED_FRAME
}
);
assert_eq!(
SingleVlanHeader::read(&mut cursor).unwrap(),
SingleVlanHeader {
pcp: 1.try_into().unwrap(),
drop_eligible_indicator: true,
vlan_id: 0x123.try_into().unwrap(),
ether_type: ether_type::IPV6
}
);
let ip_actual = Ipv6Header::read(&mut cursor).unwrap();
let ip_expected = Ipv6Header {
traffic_class: 1,
flow_label: 2.try_into().unwrap(),
payload_length: (UdpHeader::LEN + in_payload.len()) as u16,
next_header: ip_number::UDP,
hop_limit: 47,
source: [
11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26,
],
destination: [
31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46,
],
};
assert_eq!(ip_actual, ip_expected);
let udp_actual = UdpHeader::read(&mut cursor).unwrap();
let udp_expected =
UdpHeader::with_ipv6_checksum(48, 49, &ip_expected, &in_payload).unwrap();
assert_eq!(udp_actual, udp_expected);
let mut actual_payload: [u8; 4] = [0; 4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
proptest! {
#[test]
fn tcp_ipv4(ref input in tcp_any()) {
let in_payload = [24,25,26,27];
let mut ip_expected = Ipv4Header::new(
in_payload.len() as u16 + input.header_len_u16(),
21, ip_number::TCP,
[13,14,15,16],
[17,18,19,20]
).unwrap();
ip_expected.header_checksum = ip_expected.calc_header_checksum();
let expected = {
let mut expected = input.clone();
if !expected.ack {
expected.acknowledgment_number = 0;
}
if !expected.urg {
expected.urgent_pointer = 0;
}
expected.checksum = expected.calc_checksum_ipv4(&ip_expected, &in_payload[..]).unwrap();
expected
};
let serialized = {
let mut builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv4([13,14,15,16], [17,18,19,20], 21)
.tcp(input.source_port,
input.destination_port,
input.sequence_number,
input.window_size)
.options_raw(input.options.as_slice()).unwrap();
if input.ns {
builder = builder.ns();
}
if input.fin {
builder = builder.fin();
}
if input.syn {
builder = builder.syn();
}
if input.rst {
builder = builder.rst();
}
if input.psh {
builder = builder.psh();
}
if input.ack {
builder = builder.ack(input.acknowledgment_number);
}
if input.urg {
builder = builder.urg(input.urgent_pointer);
}
if input.ece {
builder = builder.ece();
}
if input.cwr {
builder = builder.cwr();
}
let mut serialized = Vec::new();
builder.write(&mut serialized, &in_payload).unwrap();
serialized
};
use std::io::Cursor;
use std::io::Read;
let mut cursor = Cursor::new(&serialized);
assert_eq!(Ethernet2Header::read(&mut cursor).unwrap(),
Ethernet2Header{
source: [1,2,3,4,5,6],
destination: [7,8,9,10,11,12],
ether_type: ether_type::IPV4
});
let ip_actual = Ipv4Header::read(&mut cursor).unwrap();
assert_eq!(ip_actual,
ip_expected);
assert_eq!(TcpHeader::read(&mut cursor).unwrap(),
expected);
let mut actual_payload: [u8;4] = [0;4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
}
proptest! {
#[test]
fn tcp_ipv6(ref input in tcp_any()) {
let in_payload = [24,25,26,27];
let ip_expected = Ipv6Header{
traffic_class: 0,
flow_label: Ipv6FlowLabel::ZERO,
payload_length: (input.header_len() as usize + in_payload.len()) as u16,
next_header: ip_number::TCP,
hop_limit: 47,
source: [11,12,13,14,15,16,17,18,19,10,21,22,23,24,25,26],
destination: [31,32,33,34,35,36,37,38,39,40,41,42,43,44,45,46]
};
let expected = {
let mut expected = input.clone();
if !expected.ack {
expected.acknowledgment_number = 0;
}
if !expected.urg {
expected.urgent_pointer = 0;
}
expected.checksum = expected.calc_checksum_ipv6(&ip_expected, &in_payload[..]).unwrap();
expected
};
let serialized = {
let mut builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv6([11,12,13,14,15,16,17,18,19,10,21,22,23,24,25,26],
[31,32,33,34,35,36,37,38,39,40,41,42,43,44,45,46],
47,
)
.tcp(input.source_port,
input.destination_port,
input.sequence_number,
input.window_size)
.options_raw(input.options.as_slice()).unwrap();
if input.ns {
builder = builder.ns();
}
if input.fin {
builder = builder.fin();
}
if input.syn {
builder = builder.syn();
}
if input.rst {
builder = builder.rst();
}
if input.psh {
builder = builder.psh();
}
if input.ack {
builder = builder.ack(input.acknowledgment_number);
}
if input.urg {
builder = builder.urg(input.urgent_pointer);
}
if input.ece {
builder = builder.ece();
}
if input.cwr {
builder = builder.cwr();
}
let mut serialized = Vec::new();
builder.write(&mut serialized, &in_payload).unwrap();
serialized
};
use std::io::Cursor;
use std::io::Read;
let mut cursor = Cursor::new(&serialized);
assert_eq!(Ethernet2Header::read(&mut cursor).unwrap(),
Ethernet2Header{
source: [1,2,3,4,5,6],
destination: [7,8,9,10,11,12],
ether_type: ether_type::IPV6
});
let ip_actual = Ipv6Header::read(&mut cursor).unwrap();
assert_eq!(ip_actual,
ip_expected);
assert_eq!(TcpHeader::read(&mut cursor).unwrap(),
expected);
let mut actual_payload: [u8;4] = [0;4];
cursor.read_exact(&mut actual_payload).unwrap();
assert_eq!(actual_payload, in_payload);
}
}
#[test]
fn eth_ipv4_tcp_options() {
let mut serialized = Vec::new();
use crate::TcpOptionElement::*;
let options = vec![MaximumSegmentSize(1234), Noop];
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.ipv4([13, 14, 15, 16], [17, 18, 19, 20], 21)
.tcp(1, 2, 3, 4)
.options(&options)
.unwrap()
.write(&mut serialized, &[])
.unwrap();
let decoded = PacketHeaders::from_ethernet_slice(&serialized[..]).unwrap();
let dec_options: Vec<Result<TcpOptionElement, TcpOptionReadError>> = decoded
.transport
.unwrap()
.tcp()
.unwrap()
.options_iterator()
.collect();
assert_eq!(&[Ok(MaximumSegmentSize(1234)), Ok(Noop)], &dec_options[..]);
}
#[test]
fn eth_ipv4_tcp_header() {
let mut serialized = Vec::new();
let tcp_header = TcpHeader {
source_port: 1234,
destination_port: 2345,
sequence_number: 3456,
acknowledgment_number: 4567,
..Default::default()
};
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.ipv4([13, 14, 15, 16], [17, 18, 19, 20], 21)
.tcp_header(tcp_header.clone())
.write(&mut serialized, &[])
.unwrap();
let decoded = PacketHeaders::from_ethernet_slice(&serialized[..]).unwrap();
let mut expected = tcp_header;
expected.checksum = expected
.calc_checksum_ipv4_raw([13, 14, 15, 16], [17, 18, 19, 20], &[])
.unwrap();
assert_eq!(decoded.transport, Some(TransportHeader::Tcp(expected)));
}
#[test]
fn size() {
assert_eq!(
Ethernet2Header::LEN + Ipv4Header::MIN_LEN + UdpHeader::LEN + 123,
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.ipv4([13, 14, 15, 16], [17, 18, 19, 20], 21)
.udp(22, 23)
.size(123)
);
assert_eq!(
Ethernet2Header::LEN + Ipv6Header::LEN + UdpHeader::LEN + 123,
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.ipv6(
[11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26],
[31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46],
47,
)
.udp(22, 23)
.size(123)
);
assert_eq!(
LinuxSllHeader::LEN + Ipv4Header::MIN_LEN + UdpHeader::LEN + 123,
PacketBuilder::linux_sll(LinuxSllPacketType::OUTGOING, 6, [7, 8, 9, 10, 11, 12, 0, 0])
.ipv4([13, 14, 15, 16], [17, 18, 19, 20], 21)
.udp(22, 23)
.size(123)
);
assert_eq!(
LinuxSllHeader::LEN + Ipv6Header::LEN + UdpHeader::LEN + 123,
PacketBuilder::linux_sll(LinuxSllPacketType::OUTGOING, 6, [7, 8, 9, 10, 11, 12, 0, 0])
.ipv6(
[11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26],
[31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46],
47,
)
.udp(22, 23)
.size(123)
);
assert_eq!(
Ethernet2Header::LEN
+ SingleVlanHeader::LEN
+ Ipv4Header::MIN_LEN
+ UdpHeader::LEN
+ 123,
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.single_vlan(0x123.try_into().unwrap())
.ipv4([13, 14, 15, 16], [17, 18, 19, 20], 21)
.udp(22, 23)
.size(123)
);
assert_eq!(
Ethernet2Header::LEN
+ SingleVlanHeader::LEN * 2
+ Ipv6Header::LEN
+ UdpHeader::LEN
+ 123,
PacketBuilder::ethernet2([1, 2, 3, 4, 5, 6], [7, 8, 9, 10, 11, 12])
.double_vlan(0x123.try_into().unwrap(), 0x234.try_into().unwrap())
.ipv6(
[11, 12, 13, 14, 15, 16, 17, 18, 19, 10, 21, 22, 23, 24, 25, 26],
[31, 32, 33, 34, 35, 36, 37, 38, 39, 40, 41, 42, 43, 44, 45, 46],
47,
)
.udp(22, 23)
.size(123)
);
}
proptest! {
#[test]
fn size_tcp(ref input in tcp_any()) {
assert_eq!(Ethernet2Header::LEN +
Ipv4Header::MIN_LEN +
input.header_len() as usize +
123,
PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv4([13,14,15,16], [17,18,19,20], 21)
.tcp(input.source_port,
input.destination_port,
input.sequence_number,
input.window_size)
.options_raw(input.options.as_slice()).unwrap()
.size(123));
}
}
proptest! {
#[test]
fn ipv4_icmpv4(
ipv4_source in any::<[u8;4]>(),
ipv4_dest in any::<[u8;4]>(),
ipv4_time_to_live in any::<u8>(),
icmpv4_type_u8 in 15u8..u8::MAX,
icmpv4_code_u8 in any::<u8>(),
icmpv4_bytes5to8 in any::<[u8;4]>(),
icmpv4 in icmpv4_type_any(),
echo_id in any::<u16>(),
echo_seq in any::<u16>(),
payload in proptest::collection::vec(any::<u8>(), 0..64),
) {
let test_builder = |builder: PacketBuilderStep<Icmpv4Header>, icmpv4_type: Icmpv4Type| {
use crate::Icmpv4Type::*;
let adapted_payload = match &icmpv4_type {
TimestampRequest(_) |
TimestampReply(_) => &[],
_ => &payload[..],
};
let icmp_expected = Icmpv4Header::with_checksum(icmpv4_type, &adapted_payload);
let ip_expected = {
let mut expected_ipv4 = Ipv4Header::new(
(icmp_expected.header_len() + adapted_payload.len()) as u16,
ipv4_time_to_live,
ip_number::ICMP,
ipv4_source,
ipv4_dest
).unwrap();
expected_ipv4.header_checksum = expected_ipv4.calc_header_checksum();
expected_ipv4
};
assert_eq!(
builder.size(adapted_payload.len()),
Ethernet2Header::LEN +
Ipv4Header::MIN_LEN +
icmp_expected.header_len() +
adapted_payload.len()
);
let mut buffer = Vec::<u8>::with_capacity(builder.size(adapted_payload.len()));
builder.write(&mut buffer, adapted_payload).unwrap();
let actual = PacketHeaders::from_ethernet_slice(&buffer).unwrap();
assert_eq!(
Some(LinkHeader::Ethernet2(Ethernet2Header{
source: [1,2,3,4,5,6],
destination: [7,8,9,10,11,12],
ether_type: ether_type::IPV4
})),
actual.link
);
assert_eq!(
Some(NetHeaders::Ipv4(ip_expected, Default::default())),
actual.net
);
assert_eq!(
Some(TransportHeader::Icmpv4(icmp_expected)),
actual.transport
);
assert_eq!(actual.payload.slice(), adapted_payload);
};
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv4(ipv4_source, ipv4_dest, ipv4_time_to_live)
.icmpv4(icmpv4.clone());
test_builder(
builder,
icmpv4
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv4(ipv4_source, ipv4_dest, ipv4_time_to_live)
.icmpv4_raw(icmpv4_type_u8, icmpv4_code_u8, icmpv4_bytes5to8);
test_builder(
builder,
Icmpv4Type::Unknown{
type_u8: icmpv4_type_u8,
code_u8: icmpv4_code_u8,
bytes5to8: icmpv4_bytes5to8,
}
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv4(ipv4_source, ipv4_dest, ipv4_time_to_live)
.icmpv4_echo_request(echo_id, echo_seq);
test_builder(
builder,
Icmpv4Type::EchoRequest(IcmpEchoHeader{
id: echo_id,
seq: echo_seq,
})
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv4(ipv4_source, ipv4_dest, ipv4_time_to_live)
.icmpv4_echo_reply(echo_id, echo_seq);
test_builder(
builder,
Icmpv4Type::EchoReply(IcmpEchoHeader{
id: echo_id,
seq: echo_seq,
})
);
}
}
}
proptest! {
#[test]
fn ipv4_icmpv6(
ipv4_source in any::<[u8;4]>(),
ipv4_dest in any::<[u8;4]>(),
ipv4_time_to_live in any::<u8>(),
icmpv6_type_u8 in 162u8..u8::MAX,
icmpv6_code_u8 in any::<u8>(),
icmpv6_bytes5to8 in any::<[u8;4]>(),
icmpv6 in icmpv6_type_any(),
echo_id in any::<u16>(),
echo_seq in any::<u16>(),
payload in proptest::collection::vec(any::<u8>(), 0..64),
) {
let test_builder = |builder: PacketBuilderStep<Icmpv6Header>, icmpv6_type: Icmpv6Type| {
assert_eq!(
builder.size(payload.len()),
Ethernet2Header::LEN +
Ipv4Header::MIN_LEN +
icmpv6_type.header_len() +
payload.len()
);
let mut buffer = Vec::<u8>::with_capacity(builder.size(payload.len()));
assert!(builder.write(&mut buffer, &payload).is_err());
};
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv4(ipv4_source, ipv4_dest, ipv4_time_to_live)
.icmpv6(icmpv6.clone());
test_builder(
builder,
icmpv6
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv4(ipv4_source, ipv4_dest, ipv4_time_to_live)
.icmpv6_raw(icmpv6_type_u8, icmpv6_code_u8, icmpv6_bytes5to8);
test_builder(
builder,
Icmpv6Type::Unknown{
type_u8: icmpv6_type_u8,
code_u8: icmpv6_code_u8,
bytes5to8: icmpv6_bytes5to8,
}
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv4(ipv4_source, ipv4_dest, ipv4_time_to_live)
.icmpv6_echo_request(echo_id, echo_seq);
test_builder(
builder,
Icmpv6Type::EchoRequest(IcmpEchoHeader{
id: echo_id,
seq: echo_seq,
})
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv4(ipv4_source, ipv4_dest, ipv4_time_to_live)
.icmpv6_echo_reply(echo_id, echo_seq);
test_builder(
builder,
Icmpv6Type::EchoReply(IcmpEchoHeader{
id: echo_id,
seq: echo_seq,
})
);
}
}
}
proptest! {
#[test]
fn ipv6_icmpv4(
ipv6_source in any::<[u8;16]>(),
ipv6_dest in any::<[u8;16]>(),
ipv6_hop_limit in any::<u8>(),
icmpv4_type_u8 in 15u8..u8::MAX,
icmpv4_code_u8 in any::<u8>(),
icmpv4_bytes5to8 in any::<[u8;4]>(),
icmpv4 in icmpv4_type_any(),
echo_id in any::<u16>(),
echo_seq in any::<u16>(),
payload in proptest::collection::vec(any::<u8>(), 0..64),
) {
let test_builder = |builder: PacketBuilderStep<Icmpv4Header>, icmpv4_type: Icmpv4Type| {
use Icmpv4Type::*;
let adapted_payload = match icmpv4_type {
TimestampRequest(_) | TimestampReply(_) => &[],
_ => &payload[..],
};
let icmp_expected = Icmpv4Header::with_checksum(icmpv4_type, &adapted_payload);
let ip_expected = Ipv6Header{
traffic_class: 0,
flow_label: Ipv6FlowLabel::ZERO,
payload_length: (icmp_expected.header_len() + adapted_payload.len()) as u16,
next_header: ip_number::ICMP,
hop_limit: ipv6_hop_limit,
source: ipv6_source,
destination: ipv6_dest
};
assert_eq!(
builder.size(adapted_payload.len()),
Ethernet2Header::LEN +
Ipv6Header::LEN +
icmp_expected.header_len() +
adapted_payload.len()
);
let mut buffer = Vec::<u8>::with_capacity(builder.size(adapted_payload.len()));
builder.write(&mut buffer, adapted_payload).unwrap();
let actual = PacketHeaders::from_ethernet_slice(&buffer).unwrap();
assert_eq!(
Some(LinkHeader::Ethernet2(Ethernet2Header{
source: [1,2,3,4,5,6],
destination: [7,8,9,10,11,12],
ether_type: ether_type::IPV6
})),
actual.link
);
assert_eq!(
Some(NetHeaders::Ipv6(ip_expected, Default::default())),
actual.net
);
assert_eq!(
Some(TransportHeader::Icmpv4(icmp_expected)),
actual.transport
);
assert_eq!(actual.payload.slice(), adapted_payload);
};
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv6(ipv6_source, ipv6_dest, ipv6_hop_limit)
.icmpv4(icmpv4.clone());
test_builder(
builder,
icmpv4
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv6(ipv6_source, ipv6_dest, ipv6_hop_limit)
.icmpv4_raw(icmpv4_type_u8, icmpv4_code_u8, icmpv4_bytes5to8);
test_builder(
builder,
Icmpv4Type::Unknown{
type_u8: icmpv4_type_u8,
code_u8: icmpv4_code_u8,
bytes5to8: icmpv4_bytes5to8,
}
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv6(ipv6_source, ipv6_dest, ipv6_hop_limit)
.icmpv4_echo_request(echo_id, echo_seq);
test_builder(
builder,
Icmpv4Type::EchoRequest(IcmpEchoHeader{
id: echo_id,
seq: echo_seq,
})
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv6(ipv6_source, ipv6_dest, ipv6_hop_limit)
.icmpv4_echo_reply(echo_id, echo_seq);
test_builder(
builder,
Icmpv4Type::EchoReply(IcmpEchoHeader{
id: echo_id,
seq: echo_seq,
})
);
}
}
}
proptest! {
#[test]
fn ipv6_icmpv6(
ipv6_source in any::<[u8;16]>(),
ipv6_dest in any::<[u8;16]>(),
ipv6_hop_limit in any::<u8>(),
icmpv6_type_u8 in 162u8..u8::MAX,
icmpv6_code_u8 in any::<u8>(),
icmpv6_bytes5to8 in any::<[u8;4]>(),
icmpv6 in icmpv6_type_any(),
echo_id in any::<u16>(),
echo_seq in any::<u16>(),
payload in proptest::collection::vec(any::<u8>(), 0..64),
) {
let test_builder = |builder: PacketBuilderStep<Icmpv6Header>, icmpv6_type: Icmpv6Type| {
let icmp_expected = Icmpv6Header::with_checksum(
icmpv6_type,
ipv6_source,
ipv6_dest,
&payload
).unwrap();
let ip_expected = Ipv6Header{
traffic_class: 0,
flow_label: Ipv6FlowLabel::ZERO,
payload_length: (icmp_expected.header_len() + payload.len()) as u16,
next_header: ip_number::IPV6_ICMP,
hop_limit: ipv6_hop_limit,
source: ipv6_source,
destination: ipv6_dest
};
assert_eq!(
builder.size(payload.len()),
Ethernet2Header::LEN +
Ipv6Header::LEN +
icmp_expected.header_len() +
payload.len()
);
let mut buffer = Vec::<u8>::with_capacity(builder.size(payload.len()));
builder.write(&mut buffer, &payload).unwrap();
let actual = PacketHeaders::from_ethernet_slice(&buffer).unwrap();
assert_eq!(
Some(LinkHeader::Ethernet2(Ethernet2Header{
source: [1,2,3,4,5,6],
destination: [7,8,9,10,11,12],
ether_type: ether_type::IPV6
})),
actual.link
);
assert_eq!(
Some(NetHeaders::Ipv6(ip_expected, Default::default())),
actual.net
);
assert_eq!(
Some(TransportHeader::Icmpv6(icmp_expected)),
actual.transport
);
assert_eq!(actual.payload.slice(), &payload);
};
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv6(ipv6_source, ipv6_dest, ipv6_hop_limit)
.icmpv6(icmpv6.clone());
test_builder(
builder,
icmpv6
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv6(ipv6_source, ipv6_dest, ipv6_hop_limit)
.icmpv6_raw(icmpv6_type_u8, icmpv6_code_u8, icmpv6_bytes5to8);
test_builder(
builder,
Icmpv6Type::Unknown{
type_u8: icmpv6_type_u8,
code_u8: icmpv6_code_u8,
bytes5to8: icmpv6_bytes5to8,
}
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv6(ipv6_source, ipv6_dest, ipv6_hop_limit)
.icmpv6_echo_request(echo_id, echo_seq);
test_builder(
builder,
Icmpv6Type::EchoRequest(IcmpEchoHeader{
id: echo_id,
seq: echo_seq,
})
);
}
{
let builder = PacketBuilder::ethernet2([1,2,3,4,5,6],[7,8,9,10,11,12])
.ipv6(ipv6_source, ipv6_dest, ipv6_hop_limit)
.icmpv6_echo_reply(echo_id, echo_seq);
test_builder(
builder,
Icmpv6Type::EchoReply(IcmpEchoHeader{
id: echo_id,
seq: echo_seq,
})
);
}
}
}
}