c3b134db9e812050e7ead6d51db068d10425a129
[dnssec-prover] / src / validation.rs
1 //! Utilities to deserialize and validate RFC 9102 proofs
2
3 use alloc::borrow::ToOwned;
4 use alloc::vec::Vec;
5 use alloc::vec;
6 use core::cmp;
7
8 use ring::signature;
9
10 use crate::rr::*;
11 use crate::ser::write_name;
12
13 /// Gets the trusted root anchors
14 ///
15 /// These are available at <https://data.iana.org/root-anchors/root-anchors.xml>
16 pub fn root_hints() -> Vec<DS> {
17         #[allow(unused_mut)]
18         let mut res = vec![DS {
19                 name: ".".try_into().unwrap(), key_tag: 19036, alg: 8, digest_type: 2,
20                 digest: hex_lit::hex!("49AAC11D7B6F6446702E54A1607371607A1A41855200FD2CE1CDDE32F24E8FB5").to_vec(),
21         }, DS {
22                 name: ".".try_into().unwrap(), key_tag: 20326, alg: 8, digest_type: 2,
23                 digest: hex_lit::hex!("E06D44B80B8F1D39A95C0B0D7C65D08458E880409BBC683457104237C7F8EC8D").to_vec(),
24         }];
25         // In tests, add the trust anchor from RFC 9102
26         #[cfg(test)]
27         res.push(DS {
28                 name: ".".try_into().unwrap(), key_tag: 47005, alg: 13, digest_type: 2,
29                 digest: hex_lit::hex!("2eb6e9f2480126691594d649a5a613de3052e37861634641bb568746f2ffc4d4").to_vec(),
30         });
31         res
32 }
33
34 #[derive(Debug, PartialEq)]
35 /// An error when validating DNSSEC signatures or other data
36 pub enum ValidationError {
37         /// An algorithm used in signing was not supported.
38         ///
39         /// In general DNS usage the resulting data should be used anyway, as we were able to verify
40         /// that a zone wished to use the unsupported algorithm.
41         ///
42         /// However, in cases where signing is mandatory, this can be treated as an error.
43         UnsupportedAlgorithm,
44         /// The provided data was invalid or signatures did not validate.
45         Invalid,
46 }
47
48 pub(crate) fn bytes_to_rsa_pk<'a>(pubkey: &'a [u8])
49 -> Result<signature::RsaPublicKeyComponents<&'a [u8]>, ()> {
50         if pubkey.len() <= 3 { return Err(()); }
51
52         let mut pos = 0;
53         let exponent_length;
54         if pubkey[0] == 0 {
55                 exponent_length = ((pubkey[1] as usize) << 8) | (pubkey[2] as usize);
56                 pos += 3;
57         } else {
58                 exponent_length = pubkey[0] as usize;
59                 pos += 1;
60         }
61
62         if pubkey.len() <= pos + exponent_length { return Err(()); }
63         Ok(signature::RsaPublicKeyComponents {
64                 n: &pubkey[pos + exponent_length..],
65                 e: &pubkey[pos..pos + exponent_length]
66         })
67 }
68
69 fn verify_rrsig<'a, RR: Record, Keys>(sig: &RRSig, dnskeys: Keys, mut records: Vec<&RR>)
70 -> Result<(), ValidationError>
71 where Keys: IntoIterator<Item = &'a DnsKey> {
72         for record in records.iter() {
73                 if sig.ty != record.ty() { return Err(ValidationError::Invalid); }
74         }
75         for dnskey in dnskeys.into_iter() {
76                 if dnskey.key_tag() == sig.key_tag {
77                         // Protocol must be 3, otherwise its not DNSSEC
78                         if dnskey.protocol != 3 { continue; }
79                         // The ZONE flag must be set if we're going to validate RRs with this key.
80                         if dnskey.flags & 0b1_0000_0000 == 0 { continue; }
81                         if dnskey.alg != sig.alg { continue; }
82
83                         let mut signed_data = Vec::with_capacity(2048);
84                         signed_data.extend_from_slice(&sig.ty.to_be_bytes());
85                         signed_data.extend_from_slice(&sig.alg.to_be_bytes());
86                         signed_data.extend_from_slice(&sig.labels.to_be_bytes());
87                         signed_data.extend_from_slice(&sig.orig_ttl.to_be_bytes());
88                         signed_data.extend_from_slice(&sig.expiration.to_be_bytes());
89                         signed_data.extend_from_slice(&sig.inception.to_be_bytes());
90                         signed_data.extend_from_slice(&sig.key_tag.to_be_bytes());
91                         write_name(&mut signed_data, &sig.key_name);
92
93                         records.sort_unstable();
94
95                         for record in records.iter() {
96                                 let periods = record.name().as_str().chars().filter(|c| *c == '.').count();
97                                 let labels = sig.labels.into();
98                                 if periods != 1 && periods != labels {
99                                         if periods < labels { return Err(ValidationError::Invalid); }
100                                         let signed_name = record.name().as_str().splitn(periods - labels + 1, ".").last();
101                                         debug_assert!(signed_name.is_some());
102                                         if let Some(name) = signed_name {
103                                                 signed_data.extend_from_slice(b"\x01*");
104                                                 write_name(&mut signed_data, name);
105                                         } else { return Err(ValidationError::Invalid); }
106                                 } else {
107                                         write_name(&mut signed_data, record.name());
108                                 }
109                                 signed_data.extend_from_slice(&record.ty().to_be_bytes());
110                                 signed_data.extend_from_slice(&1u16.to_be_bytes()); // The INternet class
111                                 signed_data.extend_from_slice(&sig.orig_ttl.to_be_bytes());
112                                 record.write_u16_len_prefixed_data(&mut signed_data);
113                         }
114
115                         let sig_validation = match sig.alg {
116                                 8|10 => {
117                                         let alg = if sig.alg == 8 {
118                                                 &signature::RSA_PKCS1_1024_8192_SHA256_FOR_LEGACY_USE_ONLY
119                                         } else {
120                                                 &signature::RSA_PKCS1_1024_8192_SHA512_FOR_LEGACY_USE_ONLY
121                                         };
122                                         bytes_to_rsa_pk(&dnskey.pubkey).map_err(|_| ValidationError::Invalid)?
123                                                 .verify(alg, &signed_data, &sig.signature)
124                                                 .map_err(|_| ValidationError::Invalid)
125                                 },
126                                 13|14 => {
127                                         let alg = if sig.alg == 13 {
128                                                 &signature::ECDSA_P256_SHA256_FIXED
129                                         } else {
130                                                 &signature::ECDSA_P384_SHA384_FIXED
131                                         };
132
133                                         // Add 0x4 identifier to the ECDSA pubkey as expected by ring.
134                                         let mut key = Vec::with_capacity(dnskey.pubkey.len() + 1);
135                                         key.push(0x4);
136                                         key.extend_from_slice(&dnskey.pubkey);
137
138                                         signature::UnparsedPublicKey::new(alg, &key)
139                                                 .verify(&signed_data, &sig.signature)
140                                                 .map_err(|_| ValidationError::Invalid)
141                                 },
142                                 15 => {
143                                         signature::UnparsedPublicKey::new(&signature::ED25519, &dnskey.pubkey)
144                                                 .verify(&signed_data, &sig.signature)
145                                                 .map_err(|_| ValidationError::Invalid)
146                                 },
147                                 _ => return Err(ValidationError::UnsupportedAlgorithm),
148                         };
149                         #[cfg(fuzzing)] {
150                                 // When fuzzing, treat any signature starting with a 1 as valid, but only after
151                                 // parsing and checking signatures to give that code a chance to panic.
152                                 if sig.signature.get(0) == Some(&1) {
153                                         return Ok(());
154                                 }
155                         }
156                         sig_validation?;
157
158                         return Ok(());
159                 }
160         }
161         Err(ValidationError::Invalid)
162 }
163
164 fn verify_dnskey_rrsig<'a, T, I>(sig: &RRSig, dses: T, records: Vec<&DnsKey>)
165 -> Result<(), ValidationError>
166 where T: IntoIterator<IntoIter = I>, I: Iterator<Item = &'a DS> + Clone {
167         let mut validated_dnskeys = Vec::with_capacity(records.len());
168         let dses = dses.into_iter();
169
170         let mut had_known_digest_type = false;
171         let mut had_ds = false;
172         for ds in dses.clone() {
173                 had_ds = true;
174                 if ds.digest_type == 1 || ds.digest_type == 2 || ds.digest_type == 4 {
175                         had_known_digest_type = true;
176                         break;
177                 }
178         }
179         if !had_ds { return Err(ValidationError::Invalid); }
180         if !had_known_digest_type { return Err(ValidationError::UnsupportedAlgorithm); }
181
182         for dnskey in records.iter() {
183                 // Only use SHA1 DS records if we don't have any SHA256/SHA384 DS RRs.
184                 let trust_sha1 = dses.clone().all(|ds| ds.digest_type != 2 && ds.digest_type != 4);
185                 for ds in dses.clone() {
186                         if ds.alg != dnskey.alg { continue; }
187                         if dnskey.key_tag() == ds.key_tag {
188                                 let alg = match ds.digest_type {
189                                         1 if trust_sha1 => &ring::digest::SHA1_FOR_LEGACY_USE_ONLY,
190                                         2 => &ring::digest::SHA256,
191                                         4 => &ring::digest::SHA384,
192                                         _ => continue,
193                                 };
194                                 let mut ctx = ring::digest::Context::new(alg);
195                                 write_name(&mut ctx, &dnskey.name);
196                                 ctx.update(&dnskey.flags.to_be_bytes());
197                                 ctx.update(&dnskey.protocol.to_be_bytes());
198                                 ctx.update(&dnskey.alg.to_be_bytes());
199                                 ctx.update(&dnskey.pubkey);
200                                 let hash = ctx.finish();
201                                 if hash.as_ref() == &ds.digest {
202                                         validated_dnskeys.push(*dnskey);
203                                         break;
204                                 }
205                         }
206                 }
207         }
208         verify_rrsig(sig, validated_dnskeys.iter().map(|k| *k), records)
209 }
210
211 /// Given a set of [`RR`]s, [`verify_rr_stream`] checks what it can and returns the set of
212 /// non-[`RRSig`]/[`DnsKey`]/[`DS`] records which it was able to verify using this struct.
213 ///
214 /// It also contains signing and expiry times, which must be validated before considering the
215 /// contained records verified.
216 #[derive(Debug, Clone)]
217 pub struct VerifiedRRStream<'a> {
218         /// The set of verified [`RR`]s.
219         ///
220         /// These are not valid unless the current UNIX time is between [`Self::valid_from`] and
221         /// [`Self::expires`].
222         pub verified_rrs: Vec<&'a RR>,
223         /// The latest [`RRSig::inception`] of all the [`RRSig`]s validated to verify
224         /// [`Self::verified_rrs`].
225         ///
226         /// Any records in [`Self::verified_rrs`] should not be considered valid unless this is before
227         /// the current UNIX time.
228         ///
229         /// While the field here is a u64, the algorithm used to identify rollovers will fail in 2133.
230         pub valid_from: u64,
231         /// The earliest [`RRSig::expiration`] of all the [`RRSig`]s validated to verify
232         /// [`Self::verified_rrs`].
233         ///
234         /// Any records in [`Self::verified_rrs`] should not be considered valid unless this is after
235         /// the current UNIX time.
236         ///
237         /// While the field here is a u64, the algorithm used to identify rollovers will fail in 2133.
238         pub expires: u64,
239         /// The minimum [`RRSig::orig_ttl`] of all the [`RRSig`]s validated to verify
240         /// [`Self::verified_rrs`].
241         ///
242         /// Any caching of [`Self::verified_rrs`] must not last longer than this value, in seconds.
243         pub max_cache_ttl: u32,
244 }
245
246 fn resolve_time(time: u32) -> u64 {
247         // RFC 2065 was published in January 1997, so we arbitrarily use that as a cutoff and assume
248         // any timestamps before then are actually past 2106 instead.
249         // We ignore leap years for simplicity.
250         if time < 60*60*24*365*27 {
251                 (time as u64) + (u32::MAX as u64)
252         } else {
253                 time.into()
254         }
255 }
256
257 /// Verifies the given set of resource records.
258 ///
259 /// Given a set of arbitrary records, this attempts to validate DNSSEC data from the [`root_hints`]
260 /// through to any supported non-DNSSEC record types.
261 ///
262 /// All records which could be validated are returned, though if an error is found validating any
263 /// contained record, only `Err` will be returned.
264 ///
265 /// You MUST check that the current UNIX time is between [`VerifiedRRStream::valid_from`] and
266 /// [`VerifiedRRStream::expires`].
267 pub fn verify_rr_stream<'a>(inp: &'a [RR]) -> Result<VerifiedRRStream<'a>, ValidationError> {
268         let mut zone = ".";
269         let mut res = Vec::new();
270         let mut pending_ds_sets = Vec::with_capacity(1);
271         let mut latest_inception = 0;
272         let mut earliest_expiry = u64::MAX;
273         let mut min_ttl = u32::MAX;
274         'next_zone: while zone == "." || !pending_ds_sets.is_empty() {
275                 let mut found_unsupported_alg = false;
276                 let next_ds_set;
277                 if let Some((next_zone, ds_set)) = pending_ds_sets.pop() {
278                         next_ds_set = Some(ds_set);
279                         zone = next_zone;
280                 } else {
281                         debug_assert_eq!(zone, ".");
282                         next_ds_set = None;
283                 }
284
285                 for rrsig in inp.iter()
286                         .filter_map(|rr| if let RR::RRSig(sig) = rr { Some(sig) } else { None })
287                         .filter(|rrsig| rrsig.name.as_str() == zone && rrsig.ty == DnsKey::TYPE)
288                 {
289                         let dnskeys = inp.iter()
290                                 .filter_map(|rr| if let RR::DnsKey(dnskey) = rr { Some(dnskey) } else { None })
291                                 .filter(move |dnskey| dnskey.name.as_str() == zone);
292                         let dnskeys_verified = if zone == "." {
293                                 verify_dnskey_rrsig(rrsig, &root_hints(), dnskeys.clone().collect())
294                         } else {
295                                 debug_assert!(next_ds_set.is_some());
296                                 if next_ds_set.is_none() { break 'next_zone; }
297                                 verify_dnskey_rrsig(rrsig, next_ds_set.clone().unwrap(), dnskeys.clone().collect())
298                         };
299                         if dnskeys_verified.is_ok() {
300                                 latest_inception = cmp::max(latest_inception, resolve_time(rrsig.inception));
301                                 earliest_expiry = cmp::min(earliest_expiry, resolve_time(rrsig.expiration));
302                                 min_ttl = cmp::min(min_ttl, rrsig.orig_ttl);
303                                 for rrsig in inp.iter()
304                                         .filter_map(|rr| if let RR::RRSig(sig) = rr { Some(sig) } else { None })
305                                         .filter(move |rrsig| rrsig.key_name.as_str() == zone && rrsig.ty != DnsKey::TYPE)
306                                 {
307                                         if !rrsig.name.ends_with(zone) { return Err(ValidationError::Invalid); }
308                                         let signed_records = inp.iter()
309                                                 .filter(|rr| rr.name() == &rrsig.name && rr.ty() == rrsig.ty);
310                                         verify_rrsig(rrsig, dnskeys.clone(), signed_records.clone().collect())?;
311                                         latest_inception = cmp::max(latest_inception, resolve_time(rrsig.inception));
312                                         earliest_expiry = cmp::min(earliest_expiry, resolve_time(rrsig.expiration));
313                                         min_ttl = cmp::min(min_ttl, rrsig.orig_ttl);
314                                         match rrsig.ty {
315                                                 // RRSigs shouldn't cover child `DnsKey`s or other `RRSig`s
316                                                 RRSig::TYPE|DnsKey::TYPE => return Err(ValidationError::Invalid),
317                                                 DS::TYPE => {
318                                                         if !pending_ds_sets.iter().any(|(pending_zone, _)| pending_zone == &rrsig.name.as_str()) {
319                                                                 pending_ds_sets.push((
320                                                                         &rrsig.name,
321                                                                         signed_records.filter_map(|rr|
322                                                                                 if let RR::DS(ds) = rr { Some(ds) }
323                                                                                 else { debug_assert!(false, "We already filtered by type"); None })
324                                                                 ));
325                                                         }
326                                                 },
327                                                 _ => {
328                                                         for record in signed_records {
329                                                                 if !res.contains(&record) { res.push(record); }
330                                                         }
331                                                 },
332                                         }
333                                 }
334                                 continue 'next_zone;
335                         } else if dnskeys_verified == Err(ValidationError::UnsupportedAlgorithm) {
336                                 // There may be redundant signatures by different keys, where one we don't supprt
337                                 // and another we do. Ignore ones we don't support, but if there are no more,
338                                 // return UnsupportedAlgorithm
339                                 found_unsupported_alg = true;
340                         } else {
341                                 // We don't explicitly handle invalid signatures here, instead we move on to the
342                                 // next RRSig (if there is one) and return `Invalid` if no `RRSig`s match.
343                         }
344                 }
345                 // No RRSigs were able to verify our DnsKey set
346                 if found_unsupported_alg {
347                         return Err(ValidationError::UnsupportedAlgorithm);
348                 } else {
349                         return Err(ValidationError::Invalid);
350                 }
351         }
352         if res.is_empty() { Err(ValidationError::Invalid) }
353         else if latest_inception >= earliest_expiry { Err(ValidationError::Invalid) }
354         else {
355                 Ok(VerifiedRRStream {
356                         verified_rrs: res, valid_from: latest_inception, expires: earliest_expiry,
357                         max_cache_ttl: min_ttl,
358                 })
359         }
360 }
361
362 impl<'a> VerifiedRRStream<'a> {
363         /// Given a name, resolve any [`CName`] records and return any verified records which were
364         /// pointed to by the original name.
365         ///
366         /// Note that because of [`CName`]s, the [`RR::name`] in the returned records may or may not be
367         /// equal to `name`.
368         ///
369         /// You MUST still check that the current UNIX time is between
370         /// [`VerifiedRRStream::valid_from`] and [`VerifiedRRStream::expires`] before
371         /// using any records returned here.
372         pub fn resolve_name<'b>(&self, name_param: &'b Name) -> Vec<&'a RR> where 'a: 'b {
373                 let mut dname_name;
374                 let mut name = name_param;
375                 loop {
376                         let mut cname_search = self.verified_rrs.iter()
377                                 .filter(|rr| rr.name() == name)
378                                 .filter_map(|rr| if let RR::CName(cn) = rr { Some(cn) } else { None });
379                         if let Some(cname) = cname_search.next() {
380                                 name = &cname.canonical_name;
381                                 continue;
382                         }
383
384                         let mut dname_search = self.verified_rrs.iter()
385                                 .filter(|rr| name.ends_with(&**rr.name()))
386                                 .filter_map(|rr| if let RR::DName(dn) = rr { Some(dn) } else { None });
387                         if let Some(dname) = dname_search.next() {
388                                 let prefix = name.strip_suffix(&*dname.name).expect("We just filtered for this");
389                                 let resolved_name = prefix.to_owned() + &dname.delegation_name;
390                                 dname_name = if let Ok(name) = resolved_name.try_into() {
391                                         name
392                                 } else {
393                                         // This should only happen if the combined name ended up being too long
394                                         return Vec::new();
395                                 };
396                                 name = &dname_name;
397                                 continue;
398                         }
399
400                         return self.verified_rrs.iter().filter(|rr| rr.name() == name).map(|rr| *rr).collect();
401                 }
402         }
403 }
404
405 #[cfg(test)]
406 mod tests {
407         #![allow(deprecated)]
408
409         use super::*;
410
411         use alloc::borrow::ToOwned;
412
413         use crate::ser::{parse_rr_stream, write_rr};
414
415         use hex_conservative::FromHex;
416         use rand::seq::SliceRandom;
417
418         fn root_dnskey() -> (Vec<DnsKey>, Vec<RR>) {
419                 let dnskeys = vec![DnsKey {
420                         name: ".".try_into().unwrap(), flags: 256, protocol: 3, alg: 8,
421                         pubkey: base64::decode("AwEAAentCcIEndLh2QSK+pHFq/PkKCwioxt75d7qNOUuTPMo0Fcte/NbwDPbocvbZ/eNb5RV/xQdapaJASQ/oDLsqzD0H1+JkHNuuKc2JLtpMxg4glSE4CnRXT2CnFTW5IwOREL+zeqZHy68OXy5ngW5KALbevRYRg/q2qFezRtCSQ0knmyPwgFsghVYLKwi116oxwEU5yZ6W7npWMxt5Z+Qs8diPNWrS5aXLgJtrWUGIIuFfuZwXYziGRP/z3o1EfMo9zZU19KLopkoLXX7Ls/diCXdSEdJXTtFA8w0/OKQviuJebfKscoElCTswukVZ1VX5gbaFEo2xWhHJ9Uo63wYaTk=").unwrap(),
422                 }, DnsKey {
423                         name: ".".try_into().unwrap(), flags: 257, protocol: 3, alg: 8,
424                         pubkey: base64::decode("AwEAAaz/tAm8yTn4Mfeh5eyI96WSVexTBAvkMgJzkKTOiW1vkIbzxeF3+/4RgWOq7HrxRixHlFlExOLAJr5emLvN7SWXgnLh4+B5xQlNVz8Og8kvArMtNROxVQuCaSnIDdD5LKyWbRd2n9WGe2R8PzgCmr3EgVLrjyBxWezF0jLHwVN8efS3rCj/EWgvIWgb9tarpVUDK/b58Da+sqqls3eNbuv7pr+eoZG+SrDK6nWeL3c6H5Apxz7LjVc1uTIdsIXxuOLYA4/ilBmSVIzuDWfdRUfhHdY6+cn8HFRm+2hM8AnXGXws9555KrUB5qihylGa8subX2Nn6UwNR1AkUTV74bU=").unwrap(),
425                 }];
426                 let dnskey_rrsig = RRSig {
427                         name: ".".try_into().unwrap(), ty: DnsKey::TYPE, alg: 8, labels: 0, orig_ttl: 172800,
428                         expiration: 1708473600, inception: 1706659200, key_tag: 20326, key_name: ".".try_into().unwrap(),
429                         signature: base64::decode("ZO8LbjtwAiVkkBzOnGbiI/3ilGUPmmJpagsLSBVbIZRG6o/8a+hUZpIPTvk5ERZ1rAW4x0YxKAU8qtaHQpKIp3qYA6u97DYytVD7RdtXKHmGYAvR6QbD5eVTkCw1Sz705rJxbwt6+YM5OBweSUAy5Glo6JSQPDQwRDwj/bV2fLRhJbvfsBgxqaXJA0SaE/ceyvK8gB2NIaguTJNrztr2TENrHxi86OKOuHYDHthOW0TFoPfr19qj/P2eEC6dYniTVovUwHT7e+Hqrb05dJF4mI4ZjaIb5mFf8i5RehT1aRlnb3CLiwJ01bEjrRBo3xUn5I3PkCnglHhx3EvkO73OzA==").unwrap(),
430                 };
431                 let root_hints = root_hints();
432                 verify_dnskey_rrsig(&dnskey_rrsig, &root_hints, dnskeys.iter().collect()).unwrap();
433                 let rrs = vec![dnskeys[0].clone().into(), dnskeys[1].clone().into(), dnskey_rrsig.into()];
434                 (dnskeys, rrs)
435         }
436
437         fn com_dnskey() -> (Vec<DnsKey>, Vec<RR>) {
438                 let root_dnskeys = root_dnskey().0;
439                 let mut com_ds = vec![DS {
440                         name: "com.".try_into().unwrap(), key_tag: 19718, alg: 13, digest_type: 2,
441                         digest: Vec::from_hex("8ACBB0CD28F41250A80A491389424D341522D946B0DA0C0291F2D3D771D7805A").unwrap(),
442                 }];
443                 let ds_rrsig = RRSig {
444                         name: "com.".try_into().unwrap(), ty: DS::TYPE, alg: 8, labels: 1, orig_ttl: 86400,
445                         expiration: 1708189200, inception: 1707062400, key_tag: 30903, key_name: ".".try_into().unwrap(),
446                         signature: base64::decode("vwMOBBwqRBdlmGZB+0FKfyMSignEtpYW9sD4TzPW2E+wdbF7O7epR5cmKmvcv0RUJdM0dGC/QmhCfgf/yqw1Xp7TpmPaYzaruW70hjGXZJO2nY3G6stUVe4S7lM2CzHL7nbbpaB5B+iSu6Ua9dZ+nyKrxfB7855HBLCLrHrkMGxWQiEPTallXXS8tEM1Y2XrsuzAQu2vZ2D2ClhFspFbPwwOdw+G6+NsZ8PnIfTkCj6DuKcgbdxjmGaYmw/6hVt9OU3kGCOBaJaEy4LrD8Kwzfu4S7axMwTKP4y4c5Y/E4k/mVAW0cuUtv549HaDfD2V0CvW1bDl6PqRkOiVsqM/lA==").unwrap(),
447                 };
448                 verify_rrsig(&ds_rrsig, &root_dnskeys, com_ds.iter().collect()).unwrap();
449                 let dnskeys = vec![DnsKey {
450                         name: "com.".try_into().unwrap(), flags: 256, protocol: 3, alg: 13,
451                         pubkey: base64::decode("5i9qjJgyH+9MBz7VO269/srLQB/xRRllyUoVq8oLBZshPe4CGzDSFGnXAM3L/QPzB9ULpJuuy7jcxmBZ5Ebo7A==").unwrap(),
452                 }, DnsKey {
453                         name: "com.".try_into().unwrap(), flags: 257, protocol: 3, alg: 13,
454                         pubkey: base64::decode("tx8EZRAd2+K/DJRV0S+hbBzaRPS/G6JVNBitHzqpsGlz8huE61Ms9ANe6NSDLKJtiTBqfTJWDAywEp1FCsEINQ==").unwrap(),
455                 }];
456                 let dnskey_rrsig = RRSig {
457                         name: "com.".try_into().unwrap(), ty: DnsKey::TYPE, alg: 13, labels: 1, orig_ttl: 86400,
458                         expiration: 1707750155, inception: 1706453855, key_tag: 19718, key_name: "com.".try_into().unwrap(),
459                         signature: base64::decode("ZFGChM7QfJt0QSqVWerWnG5pMjpL1pXyJAmuHe8dHI/olmaNCxm+mqNHv9i3AploFY6JoNtiHmeBiC6zuFj/ZQ==").unwrap(),
460                 };
461                 verify_dnskey_rrsig(&dnskey_rrsig, &com_ds, dnskeys.iter().collect()).unwrap();
462                 let rrs = vec![com_ds.pop().unwrap().into(), ds_rrsig.into(),
463                         dnskeys[0].clone().into(), dnskeys[1].clone().into(), dnskey_rrsig.into()];
464                 (dnskeys, rrs)
465         }
466
467         fn mattcorallo_dnskey() -> (Vec<DnsKey>, Vec<RR>) {
468                 let com_dnskeys = com_dnskey().0;
469                 let mut mattcorallo_ds = vec![DS {
470                         name: "mattcorallo.com.".try_into().unwrap(), key_tag: 25630, alg: 13, digest_type: 2,
471                         digest: Vec::from_hex("DC608CA62BE89B3B9DB1593F9A59930D24FBA79D486E19C88A7792711EC00735").unwrap(),
472                 }];
473                 let ds_rrsig = RRSig {
474                         name: "mattcorallo.com.".try_into().unwrap(), ty: DS::TYPE, alg: 13, labels: 2, orig_ttl: 86400,
475                         expiration: 1707631252, inception: 1707022252, key_tag: 4534, key_name: "com.".try_into().unwrap(),
476                         signature: base64::decode("M7Fk+CjfLz6hRsY5iSuw5bwc2OqlS3XtKH8FDs7lcbhEiR63n+DzOF0I8L+3k06SXFnE89uuofQECzWmAyef6Q==").unwrap(),
477                 };
478                 verify_rrsig(&ds_rrsig, &com_dnskeys, mattcorallo_ds.iter().collect()).unwrap();
479                 let dnskeys = vec![DnsKey {
480                         name: "mattcorallo.com.".try_into().unwrap(), flags: 257, protocol: 3, alg: 13,
481                         pubkey: base64::decode("8BP51Etiu4V6cHvGCYqwNqCip4pvHChjEgkgG4zpdDvO9YRcTGuV/p71hAUut2/qEdxqXfUOT/082BJ/Z089DA==").unwrap(),
482                 }, DnsKey {
483                         name: "mattcorallo.com.".try_into().unwrap(), flags: 256, protocol: 3, alg: 13,
484                         pubkey: base64::decode("AhUlQ8qk7413R0m4zKfTDHb/FQRlKag+ncGXxNxT+qTzSZTb9E5IGjo9VCEp6+IMqqpkd4GrXpN9AzDvlcU9Ig==").unwrap(),
485                 }];
486                 let dnskey_rrsig = RRSig {
487                         name: "mattcorallo.com.".try_into().unwrap(), ty: DnsKey::TYPE, alg: 13, labels: 2, orig_ttl: 604800,
488                         expiration: 1708278650, inception: 1707063650, key_tag: 25630, key_name: "mattcorallo.com.".try_into().unwrap(),
489                         signature: base64::decode("nyVDwG+la8d5dyWgB7m+H3BQwCvTWLQ/kAqNruMzdLmn9B3VC9u/rvM/ortEu0WPbA1FZWJbRKpF1Ohkj3ltNw==").unwrap(),
490                 };
491                 verify_dnskey_rrsig(&dnskey_rrsig, &mattcorallo_ds, dnskeys.iter().collect()).unwrap();
492                 let rrs = vec![mattcorallo_ds.pop().unwrap().into(), ds_rrsig.into(),
493                         dnskeys[0].clone().into(), dnskeys[1].clone().into(), dnskey_rrsig.into()];
494                 (dnskeys, rrs)
495         }
496
497         fn mattcorallo_txt_record() -> (Txt, RRSig) {
498                 let txt_resp = Txt {
499                         name: "matt.user._bitcoin-payment.mattcorallo.com.".try_into().unwrap(),
500                         data: "bitcoin:?b12=lno1qsgqmqvgm96frzdg8m0gc6nzeqffvzsqzrxqy32afmr3jn9ggkwg3egfwch2hy0l6jut6vfd8vpsc3h89l6u3dm4q2d6nuamav3w27xvdmv3lpgklhg7l5teypqz9l53hj7zvuaenh34xqsz2sa967yzqkylfu9xtcd5ymcmfp32h083e805y7jfd236w9afhavqqvl8uyma7x77yun4ehe9pnhu2gekjguexmxpqjcr2j822xr7q34p078gzslf9wpwz5y57alxu99s0z2ql0kfqvwhzycqq45ehh58xnfpuek80hw6spvwrvttjrrq9pphh0dpydh06qqspp5uq4gpyt6n9mwexde44qv7lstzzq60nr40ff38u27un6y53aypmx0p4qruk2tf9mjwqlhxak4znvna5y".to_owned().into_bytes(),
501                 };
502                 let txt_rrsig = RRSig {
503                         name: "matt.user._bitcoin-payment.mattcorallo.com.".try_into().unwrap(),
504                         ty: Txt::TYPE, alg: 13, labels: 5, orig_ttl: 3600, expiration: 1708123318,
505                         inception: 1706908318, key_tag: 47959, key_name: "mattcorallo.com.".try_into().unwrap(),
506                         signature: base64::decode("mgU6iwyMWO0w9nj2Gmt1+RmaIJIU3KO7DWVZiCD1bmU9e9zNefXCtnWOC2HtwjUsn/QYkWluvuSfYpBrt1IjpQ==").unwrap(),
507                 };
508                 (txt_resp, txt_rrsig)
509         }
510
511         fn matcorallo_dnskey() -> (Vec<DnsKey>, Vec<RR>) {
512                 let com_dnskeys = com_dnskey().0;
513                 let mut matcorallo_ds = vec![DS {
514                         name: "matcorallo.com.".try_into().unwrap(), key_tag: 24930, alg: 13, digest_type: 2,
515                         digest: Vec::from_hex("693E990CBB1CE1095E387092D3C04BCE907C008891F32A88D41D3ECB129E5E23").unwrap(),
516                 }];
517                 let ds_rrsig = RRSig {
518                         name: "matcorallo.com.".try_into().unwrap(), ty: DS::TYPE, alg: 13, labels: 2, orig_ttl: 86400,
519                         expiration: 1707628636, inception: 1707019636, key_tag: 4534, key_name: "com.".try_into().unwrap(),
520                         signature: base64::decode("l9b+DhtnJSIzR6y4Bwx+0L9kep77UNCBoTg74RTSL6oMrQd8w4OobHxzwDyXqnLfyxVP18V+AnQp4DdJ2nUW1g==").unwrap(),
521                 };
522                 verify_rrsig(&ds_rrsig, &com_dnskeys, matcorallo_ds.iter().collect()).unwrap();
523                 let dnskeys = vec![DnsKey {
524                         name: "matcorallo.com.".try_into().unwrap(), flags: 257, protocol: 3, alg: 13,
525                         pubkey: base64::decode("pfO3ow3SrKhLS7AMEi3b5W9P28nCOB9vryxfSXhqMcXFP1x9V4xAt0/JLr0zNodsqRD/8d9Yhu4Wf3hnSlaavw==").unwrap(),
526                 }, DnsKey {
527                         name: "matcorallo.com.".try_into().unwrap(), flags: 256, protocol: 3, alg: 13,
528                         pubkey: base64::decode("OO6LQTV1mnRsFgn6YQoyeo/SDqS3eajfVv8WGQVnuSYO/bTS9St1tJiox2fgU6wRWDU3chhjz1Pj0unKUAQKig==").unwrap(),
529                 }];
530                 let dnskey_rrsig = RRSig {
531                         name: "matcorallo.com.".try_into().unwrap(), ty: DnsKey::TYPE, alg: 13, labels: 2, orig_ttl: 604800,
532                         expiration: 1708309135, inception: 1707094135, key_tag: 24930, key_name: "matcorallo.com.".try_into().unwrap(),
533                         signature: base64::decode("2MKg3bTn9zf4ThwCoKRFadqD6l1D6SuLksRieKxFC0QQnzUOCRgZSK2/IlT0DMEoM0+mGrJZo7UG79UILMGUyg==").unwrap(),
534                 };
535                 verify_dnskey_rrsig(&dnskey_rrsig, &matcorallo_ds, dnskeys.iter().collect()).unwrap();
536                 let rrs = vec![matcorallo_ds.pop().unwrap().into(), ds_rrsig.into(),
537                         dnskeys[0].clone().into(), dnskeys[1].clone().into(), dnskey_rrsig.into()];
538                 (dnskeys, rrs)
539         }
540
541         fn matcorallo_txt_record() -> (Txt, RRSig) {
542                 let txt_resp = Txt {
543                         name: "txt_test.matcorallo.com.".try_into().unwrap(),
544                         data: "dnssec_prover_test".to_owned().into_bytes(),
545                 };
546                 let txt_rrsig = RRSig {
547                         name: "txt_test.matcorallo.com.".try_into().unwrap(),
548                         ty: Txt::TYPE, alg: 13, labels: 3, orig_ttl: 30, expiration: 1708319203,
549                         inception: 1707104203, key_tag: 34530, key_name: "matcorallo.com.".try_into().unwrap(),
550                         signature: base64::decode("4vaE5Jex2VvIT39JpuMNT7Ds7O0OfzTik5f8WcRRxO0IJnGAO16syAsNUkNkNqsMYknnjHDF0lI4agszgzdpsw==").unwrap(),
551                 };
552                 (txt_resp, txt_rrsig)
553         }
554
555         fn matcorallo_cname_record() -> (CName, RRSig) {
556                 let cname_resp = CName {
557                         name: "cname_test.matcorallo.com.".try_into().unwrap(),
558                         canonical_name: "txt_test.matcorallo.com.".try_into().unwrap(),
559                 };
560                 let cname_rrsig = RRSig {
561                         name: "cname_test.matcorallo.com.".try_into().unwrap(),
562                         ty: CName::TYPE, alg: 13, labels: 3, orig_ttl: 30, expiration: 1708319203,
563                         inception: 1707104203, key_tag: 34530, key_name: "matcorallo.com.".try_into().unwrap(),
564                         signature: base64::decode("5HIrmEotbVb95umE6SX3NrPboKsthdcY8b7DdaYQZzm0Nj5m2VgcfOmEPJYS8o1xE4GvGGF4sdfSy3Uw7TibBg==").unwrap(),
565                 };
566                 (cname_resp, cname_rrsig)
567         }
568
569         fn matcorallo_wildcard_record() -> (Txt, RRSig) {
570                 let txt_resp = Txt {
571                         name: "test.wildcard_test.matcorallo.com.".try_into().unwrap(),
572                         data: "wildcard_test".to_owned().into_bytes(),
573                 };
574                 let txt_rrsig = RRSig {
575                         name: "test.wildcard_test.matcorallo.com.".try_into().unwrap(),
576                         ty: Txt::TYPE, alg: 13, labels: 3, orig_ttl: 30, expiration: 1708321778,
577                         inception: 1707106778, key_tag: 34530, key_name: "matcorallo.com.".try_into().unwrap(),
578                         signature: base64::decode("vdnXunPY4CnbW/BL8VOOR9o33+dqyKA/4h+u5VM7NjB30Shp8L8gL5UwE0k7TKRNgHC8j3TqEPEmNMIHz87Z4Q==").unwrap(),
579                 };
580                 (txt_resp, txt_rrsig)
581         }
582
583         fn matcorallo_cname_wildcard_record() -> (CName, RRSig, Txt, RRSig) {
584                 let cname_resp = CName {
585                         name: "test.cname_wildcard_test.matcorallo.com.".try_into().unwrap(),
586                         canonical_name: "cname.wildcard_test.matcorallo.com.".try_into().unwrap(),
587                 };
588                 let txt_resp = Txt {
589                         name: "cname.wildcard_test.matcorallo.com.".try_into().unwrap(),
590                         data: "wildcard_test".to_owned().into_bytes(),
591                 };
592                 let cname_rrsig = RRSig {
593                         name: "test.cname_wildcard_test.matcorallo.com.".try_into().unwrap(),
594                         ty: CName::TYPE, alg: 13, labels: 3, orig_ttl: 30, expiration: 1708322050,
595                         inception: 1707107050, key_tag: 34530, key_name: "matcorallo.com.".try_into().unwrap(),
596                         signature: base64::decode("JfJuSemF5dtQYxEw6eKL4IRP8BaDt6FtbtdpZ6HjODTDflhKQRhBEbwT7kwceKPAq18q5sWHFV1bMTqE/F3WLw==").unwrap(),
597                 };
598                 let txt_rrsig = RRSig {
599                         name: "cname.wildcard_test.matcorallo.com.".try_into().unwrap(),
600                         ty: Txt::TYPE, alg: 13, labels: 3, orig_ttl: 30, expiration: 1708321778,
601                         inception: 1707106778, key_tag: 34530, key_name: "matcorallo.com.".try_into().unwrap(),
602                         signature: base64::decode("vdnXunPY4CnbW/BL8VOOR9o33+dqyKA/4h+u5VM7NjB30Shp8L8gL5UwE0k7TKRNgHC8j3TqEPEmNMIHz87Z4Q==").unwrap(),
603                 };
604                 (cname_resp, cname_rrsig, txt_resp, txt_rrsig)
605         }
606
607         fn matcorallo_txt_sort_edge_cases_records() -> (Vec<Txt>, RRSig) {
608                 let txts = vec![Txt {
609                         name: "txt_sort_order.matcorallo.com.".try_into().unwrap(),
610                         data: "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaab".to_owned().into_bytes(),
611                 }, Txt {
612                         name: "txt_sort_order.matcorallo.com.".try_into().unwrap(),
613                         data: "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa".to_owned().into_bytes(),
614                 }, Txt {
615                         name: "txt_sort_order.matcorallo.com.".try_into().unwrap(),
616                         data: "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaabaa".to_owned().into_bytes(),
617                 }, Txt {
618                         name: "txt_sort_order.matcorallo.com.".try_into().unwrap(),
619                         data: "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaba".to_owned().into_bytes(),
620                 }, Txt {
621                         name: "txt_sort_order.matcorallo.com.".try_into().unwrap(),
622                         data: "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa".to_owned().into_bytes(),
623                 }, Txt {
624                         name: "txt_sort_order.matcorallo.com.".try_into().unwrap(),
625                         data: "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaab".to_owned().into_bytes(),
626                 }, Txt {
627                         name: "txt_sort_order.matcorallo.com.".try_into().unwrap(),
628                         data: "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaa".to_owned().into_bytes(),
629                 }, Txt {
630                         name: "txt_sort_order.matcorallo.com.".try_into().unwrap(),
631                         data: "aaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaaba".to_owned().into_bytes(),
632                 }];
633                 let rrsig = RRSig {
634                         name: "txt_sort_order.matcorallo.com.".try_into().unwrap(),
635                         ty: Txt::TYPE, alg: 13, labels: 3, orig_ttl: 30, expiration: 1708449632,
636                         inception: 1707234632, key_tag: 34530, key_name: "matcorallo.com.".try_into().unwrap(),
637                         signature: base64::decode("elAhELwzkGpUMvzeiYZpg1+yRFPjmOeEd1ir1vYx2Dku9kzsXmAlejOYDPWdaJ6ekvHdMejCN/MtyI+iFAYqsw==").unwrap(),
638                 };
639                 (txts, rrsig)
640         }
641
642         #[test]
643         fn check_txt_record_a() {
644                 let dnskeys = mattcorallo_dnskey().0;
645                 let (txt, txt_rrsig) = mattcorallo_txt_record();
646                 let txt_resp = [txt];
647                 verify_rrsig(&txt_rrsig, &dnskeys, txt_resp.iter().collect()).unwrap();
648         }
649
650         #[test]
651         fn check_single_txt_proof() {
652                 let mut rr_stream = Vec::new();
653                 for rr in root_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
654                 for rr in com_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
655                 for rr in mattcorallo_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
656                 let (txt, txt_rrsig) = mattcorallo_txt_record();
657                 for rr in [RR::Txt(txt), RR::RRSig(txt_rrsig)] { write_rr(&rr, 1, &mut rr_stream); }
658
659                 let mut rrs = parse_rr_stream(&rr_stream).unwrap();
660                 rrs.shuffle(&mut rand::rngs::OsRng);
661                 let verified_rrs = verify_rr_stream(&rrs).unwrap();
662                 assert_eq!(verified_rrs.verified_rrs.len(), 1);
663                 if let RR::Txt(txt) = &verified_rrs.verified_rrs[0] {
664                         assert_eq!(txt.name.as_str(), "matt.user._bitcoin-payment.mattcorallo.com.");
665                         assert_eq!(txt.data, b"bitcoin:?b12=lno1qsgqmqvgm96frzdg8m0gc6nzeqffvzsqzrxqy32afmr3jn9ggkwg3egfwch2hy0l6jut6vfd8vpsc3h89l6u3dm4q2d6nuamav3w27xvdmv3lpgklhg7l5teypqz9l53hj7zvuaenh34xqsz2sa967yzqkylfu9xtcd5ymcmfp32h083e805y7jfd236w9afhavqqvl8uyma7x77yun4ehe9pnhu2gekjguexmxpqjcr2j822xr7q34p078gzslf9wpwz5y57alxu99s0z2ql0kfqvwhzycqq45ehh58xnfpuek80hw6spvwrvttjrrq9pphh0dpydh06qqspp5uq4gpyt6n9mwexde44qv7lstzzq60nr40ff38u27un6y53aypmx0p4qruk2tf9mjwqlhxak4znvna5y");
666                 } else { panic!(); }
667                 assert_eq!(verified_rrs.valid_from, 1707063650); // The TXT record RRSig was created last
668                 assert_eq!(verified_rrs.expires, 1707631252); // The mattcorallo.com DS RRSig expires first
669                 assert_eq!(verified_rrs.max_cache_ttl, 3600); // The TXT record had the shortest TTL
670         }
671
672         #[test]
673         fn check_txt_record_b() {
674                 let dnskeys = matcorallo_dnskey().0;
675                 let (txt, txt_rrsig) = matcorallo_txt_record();
676                 let txt_resp = [txt];
677                 verify_rrsig(&txt_rrsig, &dnskeys, txt_resp.iter().collect()).unwrap();
678         }
679
680         #[test]
681         fn check_cname_record() {
682                 let dnskeys = matcorallo_dnskey().0;
683                 let (cname, cname_rrsig) = matcorallo_cname_record();
684                 let cname_resp = [cname];
685                 verify_rrsig(&cname_rrsig, &dnskeys, cname_resp.iter().collect()).unwrap();
686         }
687
688         #[test]
689         fn check_multi_zone_proof() {
690                 let mut rr_stream = Vec::new();
691                 for rr in root_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
692                 for rr in com_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
693                 for rr in mattcorallo_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
694                 let (txt, txt_rrsig) = mattcorallo_txt_record();
695                 for rr in [RR::Txt(txt), RR::RRSig(txt_rrsig)] { write_rr(&rr, 1, &mut rr_stream); }
696                 for rr in matcorallo_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
697                 let (txt, txt_rrsig) = matcorallo_txt_record();
698                 for rr in [RR::Txt(txt), RR::RRSig(txt_rrsig)] { write_rr(&rr, 1, &mut rr_stream); }
699                 let (cname, cname_rrsig) = matcorallo_cname_record();
700                 for rr in [RR::CName(cname), RR::RRSig(cname_rrsig)] { write_rr(&rr, 1, &mut rr_stream); }
701
702                 let mut rrs = parse_rr_stream(&rr_stream).unwrap();
703                 rrs.shuffle(&mut rand::rngs::OsRng);
704                 let mut verified_rrs = verify_rr_stream(&rrs).unwrap();
705                 verified_rrs.verified_rrs.sort();
706                 assert_eq!(verified_rrs.verified_rrs.len(), 3);
707                 if let RR::Txt(txt) = &verified_rrs.verified_rrs[0] {
708                         assert_eq!(txt.name.as_str(), "matt.user._bitcoin-payment.mattcorallo.com.");
709                         assert_eq!(txt.data, b"bitcoin:?b12=lno1qsgqmqvgm96frzdg8m0gc6nzeqffvzsqzrxqy32afmr3jn9ggkwg3egfwch2hy0l6jut6vfd8vpsc3h89l6u3dm4q2d6nuamav3w27xvdmv3lpgklhg7l5teypqz9l53hj7zvuaenh34xqsz2sa967yzqkylfu9xtcd5ymcmfp32h083e805y7jfd236w9afhavqqvl8uyma7x77yun4ehe9pnhu2gekjguexmxpqjcr2j822xr7q34p078gzslf9wpwz5y57alxu99s0z2ql0kfqvwhzycqq45ehh58xnfpuek80hw6spvwrvttjrrq9pphh0dpydh06qqspp5uq4gpyt6n9mwexde44qv7lstzzq60nr40ff38u27un6y53aypmx0p4qruk2tf9mjwqlhxak4znvna5y");
710                 } else { panic!(); }
711                 if let RR::Txt(txt) = &verified_rrs.verified_rrs[1] {
712                         assert_eq!(txt.name.as_str(), "txt_test.matcorallo.com.");
713                         assert_eq!(txt.data, b"dnssec_prover_test");
714                 } else { panic!(); }
715                 if let RR::CName(cname) = &verified_rrs.verified_rrs[2] {
716                         assert_eq!(cname.name.as_str(), "cname_test.matcorallo.com.");
717                         assert_eq!(cname.canonical_name.as_str(), "txt_test.matcorallo.com.");
718                 } else { panic!(); }
719
720                 let filtered_rrs =
721                         verified_rrs.resolve_name(&"cname_test.matcorallo.com.".try_into().unwrap());
722                 assert_eq!(filtered_rrs.len(), 1);
723                 if let RR::Txt(txt) = &filtered_rrs[0] {
724                         assert_eq!(txt.name.as_str(), "txt_test.matcorallo.com.");
725                         assert_eq!(txt.data, b"dnssec_prover_test");
726                 } else { panic!(); }
727         }
728
729         #[test]
730         fn check_wildcard_record() {
731                 let dnskeys = matcorallo_dnskey().0;
732                 let (txt, txt_rrsig) = matcorallo_wildcard_record();
733                 let txt_resp = [txt];
734                 verify_rrsig(&txt_rrsig, &dnskeys, txt_resp.iter().collect()).unwrap();
735         }
736
737         #[test]
738         fn check_wildcard_proof() {
739                 let mut rr_stream = Vec::new();
740                 for rr in root_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
741                 for rr in com_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
742                 for rr in matcorallo_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
743                 let (cname, cname_rrsig, txt, txt_rrsig) = matcorallo_cname_wildcard_record();
744                 for rr in [RR::CName(cname), RR::RRSig(cname_rrsig)] { write_rr(&rr, 1, &mut rr_stream); }
745                 for rr in [RR::Txt(txt), RR::RRSig(txt_rrsig)] { write_rr(&rr, 1, &mut rr_stream); }
746
747                 let mut rrs = parse_rr_stream(&rr_stream).unwrap();
748                 rrs.shuffle(&mut rand::rngs::OsRng);
749                 let mut verified_rrs = verify_rr_stream(&rrs).unwrap();
750                 verified_rrs.verified_rrs.sort();
751                 assert_eq!(verified_rrs.verified_rrs.len(), 2);
752                 if let RR::Txt(txt) = &verified_rrs.verified_rrs[0] {
753                         assert_eq!(txt.name.as_str(), "cname.wildcard_test.matcorallo.com.");
754                         assert_eq!(txt.data, b"wildcard_test");
755                 } else { panic!(); }
756                 if let RR::CName(cname) = &verified_rrs.verified_rrs[1] {
757                         assert_eq!(cname.name.as_str(), "test.cname_wildcard_test.matcorallo.com.");
758                         assert_eq!(cname.canonical_name.as_str(), "cname.wildcard_test.matcorallo.com.");
759                 } else { panic!(); }
760
761                 let filtered_rrs =
762                         verified_rrs.resolve_name(&"test.cname_wildcard_test.matcorallo.com.".try_into().unwrap());
763                 assert_eq!(filtered_rrs.len(), 1);
764                 if let RR::Txt(txt) = &filtered_rrs[0] {
765                         assert_eq!(txt.name.as_str(), "cname.wildcard_test.matcorallo.com.");
766                         assert_eq!(txt.data, b"wildcard_test");
767                 } else { panic!(); }
768         }
769
770         #[test]
771         fn check_txt_sort_order() {
772                 let mut rr_stream = Vec::new();
773                 for rr in root_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
774                 for rr in com_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
775                 for rr in matcorallo_dnskey().1 { write_rr(&rr, 1, &mut rr_stream); }
776                 let (mut txts, rrsig) = matcorallo_txt_sort_edge_cases_records();
777                 write_rr(&rrsig, 1, &mut rr_stream);
778                 for txt in txts.iter() { write_rr(txt, 1, &mut rr_stream); }
779
780                 let mut rrs = parse_rr_stream(&rr_stream).unwrap();
781                 rrs.shuffle(&mut rand::rngs::OsRng);
782                 let verified_rrs = verify_rr_stream(&rrs).unwrap();
783                 let mut verified_txts = verified_rrs.verified_rrs
784                         .iter().map(|rr| if let RR::Txt(txt) = rr { txt.clone() } else { panic!(); })
785                         .collect::<Vec<_>>();
786                 verified_txts.sort();
787                 txts.sort();
788                 assert_eq!(verified_txts, txts);
789         }
790
791         #[test]
792         fn rfc9102_parse_test() {
793                 // Note that this is the `AuthenticationChain` field only, and ignores the
794                 // `ExtSupportLifetime` field (stripping the top two 0 bytes from the front).
795 let rfc9102_test_vector = Vec::from_hex("045f343433045f74637003777777076578616d706c6503636f6d000034000100000e1000230301018bd1da95272f7fa4ffb24137fc0ed03aae67e5c4d8b3c50734e1050a7920b922045f343433045f74637003777777076578616d706c6503636f6d00002e000100000e10005f00340d0500000e105fc6d9005bfdda80074e076578616d706c6503636f6d00ce1d3adeb7dc7cee656d61cfb472c5977c8c9caeae9b765155c518fb107b6a1fe0355fbaaf753c192832fa621fa73a8b85ed79d374117387598fcc812e1ef3fb076578616d706c6503636f6d000030000100000e1000440101030d2670355e0c894d9cfea6c5af6eb7d458b57a50ba88272512d8241d8541fd54adf96ec956789a51ceb971094b3bb3f4ec49f64c686595be5b2e89e8799c7717cc076578616d706c6503636f6d00002e000100000e10005f00300d0200000e105fc6d9005bfdda80074e076578616d706c6503636f6d004628383075b8e34b743a209b27ae148d110d4e1a246138a91083249cb4a12a2d9bc4c2d7ab5eb3afb9f5d1037e4d5da8339c162a9298e9be180741a8ca74accc076578616d706c6503636f6d00002b00010002a3000024074e0d02e9b533a049798e900b5c29c90cd25a986e8a44f319ac3cd302bafc08f5b81e16076578616d706c6503636f6d00002e00010002a3000057002b0d020002a3005fc6d9005bfdda80861703636f6d00a203e704a6facbeb13fc9384fdd6de6b50de5659271f38ce81498684e6363172d47e2319fdb4a22a58a231edc2f1ff4fb2811a1807be72cb5241aa26fdaee03903636f6d00003000010002a30000440100030dec8204e43a25f2348c52a1d3bce3a265aa5d11b43dc2a471162ff341c49db9f50a2e1a41caf2e9cd20104ea0968f7511219f0bdc56b68012cc3995336751900b03636f6d00003000010002a30000440101030d45b91c3bef7a5d99a7a7c8d822e33896bc80a777a04234a605a4a8880ec7efa4e6d112c73cd3d4c65564fa74347c873723cc5f643370f166b43dedff836400ff03636f6d00003000010002a30000440101030db3373b6e22e8e49e0e1e591a9f5bd9ac5e1a0f86187fe34703f180a9d36c958f71c4af48ce0ebc5c792a724e11b43895937ee53404268129476eb1aed323939003636f6d00002e00010002a300005700300d010002a3005fc6d9005bfdda8049f303636f6d0018a948eb23d44f80abc99238fcb43c5a18debe57004f7343593f6deb6ed71e04654a433f7aa1972130d9bd921c73dcf63fcf665f2f05a0aaebafb059dc12c96503636f6d00002e00010002a300005700300d010002a3005fc6d9005bfdda80708903636f6d006170e6959bd9ed6e575837b6f580bd99dbd24a44682b0a359626a246b1812f5f9096b75e157e77848f068ae0085e1a609fc19298c33b736863fbccd4d81f5eb203636f6d00002b000100015180002449f30d0220f7a9db42d0e2042fbbb9f9ea015941202f9eabb94487e658c188e7bcb5211503636f6d00002b000100015180002470890d02ad66b3276f796223aa45eda773e92c6d98e70643bbde681db342a9e5cf2bb38003636f6d00002e0001000151800053002b0d01000151805fc6d9005bfdda807cae00122e276d45d9e9816f7922ad6ea2e73e82d26fce0a4b718625f314531ac92f8ae82418df9b898f989d32e80bc4deaba7c4a7c8f172adb57ced7fb5e77a784b0700003000010001518000440100030dccacfe0c25a4340fefba17a254f706aac1f8d14f38299025acc448ca8ce3f561f37fc3ec169fe847c8fcbe68e358ff7c71bb5ee1df0dbe518bc736d4ce8dfe1400003000010001518000440100030df303196789731ddc8a6787eff24cacfeddd032582f11a75bb1bcaa5ab321c1d7525c2658191aec01b3e98ab7915b16d571dd55b4eae51417110cc4cdd11d171100003000010001518000440101030dcaf5fe54d4d48f16621afb6bd3ad2155bacf57d1faad5bac42d17d948c421736d9389c4c4011666ea95cf17725bd0fa00ce5e714e4ec82cfdfacc9b1c863ad4600002e000100015180005300300d00000151805fc6d9005bfdda80b79d00de7a6740eeecba4bda1e5c2dd4899b2c965893f3786ce747f41e50d9de8c0a72df82560dfb48d714de3283ae99a49c0fcb50d3aaadb1a3fc62ee3a8a0988b6be").unwrap();
796
797                 let mut rrs = parse_rr_stream(&rfc9102_test_vector).unwrap();
798                 rrs.shuffle(&mut rand::rngs::OsRng);
799                 let verified_rrs = verify_rr_stream(&rrs).unwrap();
800                 assert_eq!(verified_rrs.verified_rrs.len(), 1);
801                 if let RR::TLSA(tlsa) = &verified_rrs.verified_rrs[0] {
802                         assert_eq!(tlsa.cert_usage, 3);
803                         assert_eq!(tlsa.selector, 1);
804                         assert_eq!(tlsa.data_ty, 1);
805                         assert_eq!(tlsa.data, Vec::from_hex("8bd1da95272f7fa4ffb24137fc0ed03aae67e5c4d8b3c50734e1050a7920b922").unwrap());
806                 } else { panic!(); }
807         }
808 }