use std::any::Any;
use std::collections::HashMap;
use std::fmt;
use std::fmt::Formatter;
use crate::messages::inter::rr_classes::RRClasses;
use crate::messages::inter::rr_types::RRTypes;
use crate::rr_data::inter::rr_data::{RRData, RRDataError};
use crate::utils::fqdn_utils::{pack_fqdn, pack_fqdn_compressed, unpack_fqdn};
use crate::zone::inter::zone_rr_data::ZoneRRData;
use crate::zone::zone_reader::{ErrorKind, ZoneReaderError};
#[derive(Clone, Debug)]
pub struct PtrRRData {
class: RRClasses,
cache_flush: bool,
ttl: u32,
fqdn: Option<String>
}
impl Default for PtrRRData {
fn default() -> Self {
Self {
class: RRClasses::default(),
cache_flush: false,
ttl: 0,
fqdn: None
}
}
}
impl RRData for PtrRRData {
fn from_bytes(buf: &[u8], off: usize) -> Result<Self, RRDataError> {
let class = u16::from_be_bytes([buf[off], buf[off+1]]);
let cache_flush = (class & 0x8000) != 0;
let class = RRClasses::try_from(class & 0x7FFF).unwrap();
let ttl = u32::from_be_bytes([buf[off+2], buf[off+3], buf[off+4], buf[off+5]]);
let (fqdn, _) = unpack_fqdn(buf, off+8);
Ok(Self {
class,
cache_flush,
ttl,
fqdn: Some(fqdn)
})
}
fn to_bytes_compressed(&self, compression_data: &mut HashMap<String, usize>, off: usize) -> Result<Vec<u8>, RRDataError> {
let mut buf = vec![0u8; 8];
let mut class = self.class.get_code();
if self.cache_flush {
class = class | 0x8000;
}
buf.splice(0..2, class.to_be_bytes());
buf.splice(2..6, self.ttl.to_be_bytes());
buf.extend_from_slice(&pack_fqdn_compressed(self.fqdn.as_ref().unwrap().as_str(), compression_data, off+8));
buf.splice(6..8, ((buf.len()-8) as u16).to_be_bytes());
Ok(buf)
}
fn to_bytes(&self) -> Result<Vec<u8>, RRDataError> {
let mut buf = vec![0u8; 8];
let mut class = self.class.get_code();
if self.cache_flush {
class = class | 0x8000;
}
buf.splice(0..2, class.to_be_bytes());
buf.splice(2..6, self.ttl.to_be_bytes());
buf.extend_from_slice(&pack_fqdn(self.fqdn.as_ref().unwrap().as_str()));
buf.splice(6..8, ((buf.len()-8) as u16).to_be_bytes());
Ok(buf)
}
fn get_type(&self) -> RRTypes {
RRTypes::Ptr
}
fn upcast(self) -> Box<dyn RRData> {
Box::new(self)
}
fn as_any(&self) -> &dyn Any {
self
}
fn as_any_mut(&mut self) -> &mut dyn Any {
self
}
fn clone_box(&self) -> Box<dyn RRData> {
Box::new(self.clone())
}
}
impl PtrRRData {
pub fn new(ttl: u32, class: RRClasses) -> Self {
Self {
class,
ttl,
..Self::default()
}
}
pub fn set_class(&mut self, class: RRClasses) {
self.class = class;
}
pub fn get_class(&self) -> RRClasses {
self.class
}
pub fn set_ttl(&mut self, ttl: u32) {
self.ttl = ttl;
}
pub fn get_ttl(&self) -> u32 {
self.ttl
}
pub fn set_fqdn(&mut self, fqdn: &str) {
self.fqdn = Some(fqdn.to_string());
}
pub fn get_fqdn(&self) -> Option<&String> {
self.fqdn.as_ref()
}
}
impl ZoneRRData for PtrRRData {
fn set_data(&mut self, index: usize, value: &str) -> Result<(), ZoneReaderError> {
Ok(match index {
0 => self.fqdn = Some(value.strip_suffix('.')
.ok_or_else(|| ZoneReaderError::new(ErrorKind::FormErr, &format!("fqdn param is not fully qualified (missing trailing dot) for record type {}", self.get_type())))?.to_string()),
_ => return Err(ZoneReaderError::new(ErrorKind::ExtraRRData, &format!("extra record data found for record type {}", self.get_type())))
})
}
fn upcast(self) -> Box<dyn ZoneRRData> {
Box::new(self)
}
}
impl fmt::Display for PtrRRData {
fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result {
write!(f, "{:<8}{:<8}{:<8}{}", self.ttl,
self.class.to_string(),
self.get_type().to_string(),
format!("{}.", self.fqdn.as_ref().unwrap()))
}
}