dns_parser/rdata/
soa.rs

1use {Name, Error};
2use byteorder::{BigEndian, ByteOrder};
3
4/// The SOA (Start of Authority) record
5#[derive(Debug, Clone, Copy)]
6pub struct Record<'a> {
7    pub primary_ns: Name<'a>,
8    pub mailbox: Name<'a>,
9    pub serial: u32,
10    pub refresh: u32,
11    pub retry: u32,
12    pub expire: u32,
13    pub minimum_ttl: u32,
14}
15
16impl<'a> super::Record<'a> for Record<'a> {
17
18    const TYPE: isize = 6;
19
20    fn parse(rdata: &'a [u8], original: &'a [u8]) -> super::RDataResult<'a> {
21        let mut pos = 0;
22        let primary_name_server = try!(Name::scan(rdata, original));
23        pos += primary_name_server.byte_len();
24        let mailbox = try!(Name::scan(&rdata[pos..], original));
25        pos += mailbox.byte_len();
26        if rdata[pos..].len() < 20 {
27            return Err(Error::WrongRdataLength);
28        }
29        let record = Record {
30            primary_ns: primary_name_server,
31            mailbox: mailbox,
32            serial: BigEndian::read_u32(&rdata[pos..(pos+4)]),
33            refresh: BigEndian::read_u32(&rdata[(pos+4)..(pos+8)]),
34            retry: BigEndian::read_u32(&rdata[(pos+8)..(pos+12)]),
35            expire: BigEndian::read_u32(&rdata[(pos+12)..(pos+16)]),
36            minimum_ttl: BigEndian::read_u32(&rdata[(pos+16)..(pos+20)]),
37        };
38        Ok(super::RData::SOA(record))
39    }
40}
41
42#[cfg(test)]
43mod test {
44
45    use {Packet, Header};
46    use Opcode::*;
47    use ResponseCode::NameError;
48    use QueryType as QT;
49    use QueryClass as QC;
50    use Class as C;
51    use RData;
52
53     #[test]
54     fn parse_response() {
55         let response = b"\x9f\xc5\x85\x83\x00\x01\x00\x00\x00\x01\x00\x00\
56                          \x0edlkfjkdjdslfkj\x07youtube\x03com\x00\x00\x01\x00\x01\
57                          \xc0\x1b\x00\x06\x00\x01\x00\x00\x2a\x30\x00\x1e\xc0\x1b\
58                          \x05admin\xc0\x1b\x77\xed\x2a\x73\x00\x00\x51\x80\x00\x00\
59                          \x0e\x10\x00\x00\x3a\x80\x00\x00\x2a\x30";
60          let packet = Packet::parse(response).unwrap();
61          assert_eq!(packet.header, Header {
62              id: 40901,
63              query: false,
64              opcode: StandardQuery,
65              authoritative: true,
66              truncated: false,
67              recursion_desired: true,
68              recursion_available: true,
69              authenticated_data: false,
70              checking_disabled: false,
71              response_code: NameError,
72              questions: 1,
73              answers: 0,
74              nameservers: 1,
75              additional: 0,
76          });
77          assert_eq!(packet.questions.len(), 1);
78          assert_eq!(packet.questions[0].qtype, QT::A);
79          assert_eq!(packet.questions[0].qclass, QC::IN);
80          assert_eq!(&packet.questions[0].qname.to_string()[..], "dlkfjkdjdslfkj.youtube.com");
81          assert_eq!(packet.answers.len(), 0);
82
83          assert_eq!(packet.nameservers.len(), 1);
84          assert_eq!(&packet.nameservers[0].name.to_string()[..], "youtube.com");
85          assert_eq!(packet.nameservers[0].cls, C::IN);
86          assert_eq!(packet.nameservers[0].multicast_unique, false);
87          assert_eq!(packet.nameservers[0].ttl, 10800);
88          match packet.nameservers[0].data {
89              RData::SOA(ref soa_rec) => {
90                assert_eq!(&soa_rec.primary_ns.to_string()[..], "youtube.com");
91                assert_eq!(&soa_rec.mailbox.to_string()[..], "admin.youtube.com");
92                assert_eq!(soa_rec.serial, 2012031603);
93                assert_eq!(soa_rec.refresh, 20864);
94                assert_eq!(soa_rec.retry, 3600);
95                assert_eq!(soa_rec.expire, 14976);
96                assert_eq!(soa_rec.minimum_ttl, 10800);
97              }
98              ref x => panic!("Wrong rdata {:?}", x),
99          }
100      }
101}
dns_parser/rdata/soa.rs

dns_parser/rdata/
soa.rs
