dns_parser/rdata/
srv.rs

1use {Name, Error};
2use byteorder::{BigEndian, ByteOrder};
3
4#[derive(Debug, Clone, Copy)]
5pub struct Record<'a> {
6    pub priority: u16,
7    pub weight: u16,
8    pub port: u16,
9    pub target: Name<'a>,
10}
11
12impl<'a> super::Record<'a> for Record<'a> {
13
14    const TYPE: isize = 33;
15
16    fn parse(rdata: &'a [u8], original: &'a [u8]) -> super::RDataResult<'a> {
17        if rdata.len() < 7 {
18            return Err(Error::WrongRdataLength);
19        }
20        let record = Record {
21            priority: BigEndian::read_u16(&rdata[..2]),
22            weight: BigEndian::read_u16(&rdata[2..4]),
23            port: BigEndian::read_u16(&rdata[4..6]),
24            target: Name::scan(&rdata[6..], original)?,
25        };
26        Ok(super::RData::SRV(record))
27    }
28}
29
30#[cfg(test)]
31mod test {
32
33    use {Packet, Header};
34    use Opcode::*;
35    use ResponseCode::NoError;
36    use QueryType as QT;
37    use QueryClass as QC;
38    use Class as C;
39    use RData;
40    use super::*;
41
42    #[test]
43    fn parse_response() {
44        let response = b"[\xd9\x81\x80\x00\x01\x00\x05\x00\x00\x00\x00\
45            \x0c_xmpp-server\x04_tcp\x05gmail\x03com\x00\x00!\x00\x01\
46            \xc0\x0c\x00!\x00\x01\x00\x00\x03\x84\x00 \x00\x05\x00\x00\
47            \x14\x95\x0bxmpp-server\x01l\x06google\x03com\x00\xc0\x0c\x00!\
48            \x00\x01\x00\x00\x03\x84\x00%\x00\x14\x00\x00\x14\x95\
49            \x04alt3\x0bxmpp-server\x01l\x06google\x03com\x00\
50            \xc0\x0c\x00!\x00\x01\x00\x00\x03\x84\x00%\x00\x14\x00\x00\
51            \x14\x95\x04alt1\x0bxmpp-server\x01l\x06google\x03com\x00\
52            \xc0\x0c\x00!\x00\x01\x00\x00\x03\x84\x00%\x00\x14\x00\x00\
53            \x14\x95\x04alt2\x0bxmpp-server\x01l\x06google\x03com\x00\
54            \xc0\x0c\x00!\x00\x01\x00\x00\x03\x84\x00%\x00\x14\x00\x00\
55            \x14\x95\x04alt4\x0bxmpp-server\x01l\x06google\x03com\x00";
56        let packet = Packet::parse(response).unwrap();
57        assert_eq!(packet.header, Header {
58            id: 23513,
59            query: false,
60            opcode: StandardQuery,
61            authoritative: false,
62            truncated: false,
63            recursion_desired: true,
64            recursion_available: true,
65            authenticated_data: false,
66            checking_disabled: false,
67            response_code: NoError,
68            questions: 1,
69            answers: 5,
70            nameservers: 0,
71            additional: 0,
72        });
73        assert_eq!(packet.questions.len(), 1);
74        assert_eq!(packet.questions[0].qtype, QT::SRV);
75        assert_eq!(packet.questions[0].qclass, QC::IN);
76        assert_eq!(&packet.questions[0].qname.to_string()[..],
77            "_xmpp-server._tcp.gmail.com");
78        assert_eq!(packet.answers.len(), 5);
79        let items = vec![
80            (5, 0, 5269, "xmpp-server.l.google.com"),
81            (20, 0, 5269, "alt3.xmpp-server.l.google.com"),
82            (20, 0, 5269, "alt1.xmpp-server.l.google.com"),
83            (20, 0, 5269, "alt2.xmpp-server.l.google.com"),
84            (20, 0, 5269, "alt4.xmpp-server.l.google.com"),
85        ];
86        for i in 0..5 {
87            assert_eq!(&packet.answers[i].name.to_string()[..],
88                "_xmpp-server._tcp.gmail.com");
89            assert_eq!(packet.answers[i].cls, C::IN);
90            assert_eq!(packet.answers[i].ttl, 900);
91            match *&packet.answers[i].data {
92                RData::SRV(Record { priority, weight, port, target }) => {
93                    assert_eq!(priority, items[i].0);
94                    assert_eq!(weight, items[i].1);
95                    assert_eq!(port, items[i].2);
96                    assert_eq!(target.to_string(), (items[i].3).to_string());
97                }
98                ref x => panic!("Wrong rdata {:?}", x),
99            }
100        }
101    }
102}
dns_parser/rdata/srv.rs

dns_parser/rdata/
srv.rs
