use crate::{dns::WireFormat, Name};
use std::{
borrow::Cow,
net::{Ipv4Addr, Ipv6Addr},
};
use super::RR;
#[derive(Debug, PartialEq, Eq, Hash, Clone)]
pub struct IPSECKEY<'a> {
pub precedence: u8,
pub algorithm: u8,
pub gateway: Gateway<'a>,
pub public_key: Cow<'a, [u8]>,
}
#[derive(Debug, PartialEq, Eq, Hash, Clone)]
pub enum Gateway<'a> {
None,
IPv4(Ipv4Addr),
IPv6(Ipv6Addr),
Domain(Name<'a>),
}
impl Gateway<'_> {
pub fn into_owned<'b>(self) -> Gateway<'b> {
match self {
Gateway::None => Gateway::None,
Gateway::IPv4(x) => Gateway::IPv4(x),
Gateway::IPv6(x) => Gateway::IPv6(x),
Gateway::Domain(x) => Gateway::Domain(x.into_owned()),
}
}
}
impl RR for IPSECKEY<'_> {
const TYPE_CODE: u16 = 45;
}
impl<'a> WireFormat<'a> for IPSECKEY<'a> {
const MINIMUM_LEN: usize = 5;
fn parse_after_check(data: &'a [u8], position: &mut usize) -> crate::Result<Self>
where
Self: Sized,
{
let precedence = data[*position];
*position += 1;
let gateway_type = data[*position];
*position += 1;
let algorithm = data[*position];
*position += 1;
let gateway = match gateway_type {
0 => Gateway::None,
1 => {
if data.len() < *position + 4 {
return Err(crate::SimpleDnsError::InsufficientData);
}
let x = Gateway::IPv4(Ipv4Addr::new(
data[*position],
data[*position + 1],
data[*position + 2],
data[*position + 3],
));
*position += 4;
x
}
2 => {
let mut octets = [0u8; 16];
if data.len() < *position + 16 {
return Err(crate::SimpleDnsError::InsufficientData);
}
octets.copy_from_slice(&data[*position..*position + 16]);
*position += 16;
Gateway::IPv6(Ipv6Addr::from(octets))
}
3 => {
let gateway = Name::parse(data, position)?;
Gateway::Domain(gateway)
}
_ => return Err(crate::SimpleDnsError::AttemptedInvalidOperation),
};
let public_key = &data[*position..];
*position += public_key.len();
Ok(Self {
precedence,
algorithm,
gateway,
public_key: Cow::Borrowed(public_key),
})
}
fn write_to<T: std::io::Write>(&self, out: &mut T) -> crate::Result<()> {
match &self.gateway {
Gateway::None => {
out.write_all(&[self.precedence, 0, self.algorithm])?;
}
Gateway::IPv4(ipv4_addr) => {
out.write_all(&[self.precedence, 1, self.algorithm])?;
out.write_all(&ipv4_addr.octets())?
}
Gateway::IPv6(ipv6_addr) => {
out.write_all(&[self.precedence, 2, self.algorithm])?;
out.write_all(&ipv6_addr.octets())?
}
Gateway::Domain(name) => {
out.write_all(&[self.precedence, 3, self.algorithm])?;
name.write_to(out)?
}
};
out.write_all(&self.public_key)?;
Ok(())
}
fn len(&self) -> usize {
(match &self.gateway {
Gateway::None => 0,
Gateway::IPv4(_) => 4,
Gateway::IPv6(_) => 16,
Gateway::Domain(name) => name.len(),
}) + self.public_key.len()
+ Self::MINIMUM_LEN
}
}
impl IPSECKEY<'_> {
pub fn into_owned<'b>(self) -> IPSECKEY<'b> {
IPSECKEY {
precedence: self.precedence,
algorithm: self.algorithm,
gateway: self.gateway.into_owned(),
public_key: self.public_key.into_owned().into(),
}
}
}
#[cfg(test)]
mod tests {
use crate::{rdata::RData, ResourceRecord};
use super::*;
#[test]
fn parse_and_write_ipseckey() {
let ipseckey = IPSECKEY {
precedence: 10,
algorithm: 2,
gateway: Gateway::IPv4(Ipv4Addr::new(192,0,2,38)),
public_key: Cow::Borrowed(b"\x01\x03\x51\x53\x79\x86\xed\x35\x53\x3b\x60\x64\x47\x8e\xee\xb2\x7b\x5b\xd7\x4d\xae\x14\x9b\x6e\x81\xba\x3a\x05\x21\xaf\x82\xab\x78\x01"),
};
let mut data = Vec::new();
ipseckey.write_to(&mut data).unwrap();
let ipseckey = IPSECKEY::parse(&data, &mut 0).unwrap();
assert_eq!(ipseckey.precedence, 10);
assert_eq!(ipseckey.algorithm, 2);
assert_eq!(
ipseckey.gateway,
Gateway::IPv4(Ipv4Addr::new(192, 0, 2, 38))
);
assert_eq!(*ipseckey.public_key, *b"\x01\x03\x51\x53\x79\x86\xed\x35\x53\x3b\x60\x64\x47\x8e\xee\xb2\x7b\x5b\xd7\x4d\xae\x14\x9b\x6e\x81\xba\x3a\x05\x21\xaf\x82\xab\x78\x01");
}
#[test]
fn parse_sample() -> Result<(), Box<dyn std::error::Error>> {
let sample_file = std::fs::read("samples/zonefile/IPSECKEY.sample")?;
let sample_rdata = match ResourceRecord::parse(&sample_file, &mut 0)?.rdata {
RData::IPSECKEY(rdata) => rdata,
_ => unreachable!(),
};
assert_eq!(sample_rdata.precedence, 10);
assert_eq!(sample_rdata.algorithm, 2);
assert_eq!(
sample_rdata.gateway,
Gateway::IPv4(Ipv4Addr::new(192, 0, 2, 38))
);
assert_eq!(*sample_rdata.public_key, *b"\x01\x03\x51\x53\x79\x86\xed\x35\x53\x3b\x60\x64\x47\x8e\xee\xb2\x7b\x5b\xd7\x4d\xae\x14\x9b\x6e\x81\xba\x3a\x05\x21\xaf\x82\xab\x78\x01");
Ok(())
}
}