1
//! Types used to parse arguments of entries in a directory document.
2
//!
3
//! There are some types that are pretty common, like "ISOTime",
4
//! "base64-encoded data", and so on.
5
//!
6
//! These types shouldn't be exposed outside of the netdoc crate.
7

            
8
pub use b16impl::*;
9
pub use b64impl::*;
10
pub use contact_info::*;
11
pub use curve25519impl::*;
12
pub use ed25519impl::*;
13
pub use edcert::*;
14
pub use fingerprint::*;
15
pub use hostname::*;
16
pub use rsa::*;
17
pub use timeimpl::*;
18

            
19
pub use nickname::{InvalidNickname, Nickname};
20

            
21
pub use boolean::NumericBoolean;
22

            
23
pub use fingerprint::{Base64Fingerprint, Fingerprint};
24

            
25
pub use identified_digest::{DigestName, IdentifiedDigest};
26

            
27
pub use ignored_impl::{
28
    Ignored, IgnoredItemOrObjectValue, ItemPresent, NoMoreArguments, NotPresent,
29
    NotPresentEachValue,
30
};
31

            
32
use crate::NormalItemArgument;
33
use crate::encode::{
34
    self,
35
    ItemArgument,
36
    ItemEncoder,
37
    ItemObjectEncodable,
38
    ItemValueEncodable,
39
    // `E` for "encode`; different from `parse2::MultiplicitySelector`
40
    MultiplicitySelector as EMultiplicitySelector,
41
    NetdocEncoder,
42
};
43
use crate::parse2::{
44
    self, ArgumentError, ArgumentStream, ItemArgumentParseable, ItemObjectParseable,
45
    ItemValueParseable, SignatureHashInputs, SignatureItemParseable, UnparsedItem,
46
    multiplicity::{
47
        ArgumentSetMethods,
48
        ItemSetMethods,
49
        // `P2` for "parse2`; different from `encode::MultiplicitySelector`
50
        MultiplicitySelector as P2MultiplicitySelector,
51
        ObjectSetMethods,
52
    },
53
    sig_hashes::Sha1WholeKeywordLine,
54
};
55

            
56
use derive_deftly::{Deftly, define_derive_deftly, define_derive_deftly_module};
57
use digest::Digest as _;
58
use educe::Educe;
59
use std::cmp::{self, Ordering, PartialOrd};
60
use std::fmt::{self, Display};
61
use std::iter;
62
use std::marker::PhantomData;
63
use std::ops::{Deref, DerefMut};
64
use std::result::Result as StdResult;
65
use std::str::FromStr;
66
use subtle::{Choice, ConstantTimeEq};
67
use tor_error::{Bug, ErrorReport as _, internal, into_internal};
68
use void::{ResultVoidExt as _, Void};
69

            
70
/// Describes a value that van be decoded from a bunch of bytes.
71
///
72
/// Used for decoding the objects between BEGIN and END tags.
73
pub(crate) trait FromBytes: Sized {
74
    /// Try to parse a value of this type from a byte slice
75
    fn from_bytes(b: &[u8], p: crate::Pos) -> crate::Result<Self>;
76
    /// Try to parse a value of this type from a vector of bytes,
77
    /// and consume that value
78
5400
    fn from_vec(v: Vec<u8>, p: crate::Pos) -> crate::Result<Self> {
79
5400
        Self::from_bytes(&v[..], p)
80
5400
    }
81
}
82

            
83
define_derive_deftly_module! {
84
    /// Implement conversion traits for a transparent newtype around bytes - shared code
85
    ///
86
    /// This is precisely `#[derive_deftly(Transparent)]`, but in the form of a deftly module,
87
    /// so that other derives (eg `BytesTransparent`) can re-use it.
88
    Transparent beta_deftly:
89

            
90
    // Expands to bullet points for "generated code", except omitting
91
    // `AsRef` & `AsMut` because some uses sites have additional impls of those,
92
    // which are best presented together in the docs.
93
  ${define TRANSPARENT_DOCS_IMPLS {
94
    ///  * impls of `Deref`, `DerefMut`
95
    ///  * impls of `From<field>` and "`Into`" (technically, `From<Self> for field`)
96
  }}
97

            
98
    // Expands to the implementations
99
  ${define TRANSPARENT_IMPLS {
100

            
101
  ${for fields {
102
    ${loop_exactly_1 "must be applied to a single-field struct"}
103

            
104
    impl<$tgens> From<$ftype> for $ttype {
105
1003082
        fn from($fpatname: $ftype) -> $ttype {
106
            $vpat
107
        }
108
    }
109

            
110
    // TODO: This implementation is probably a bug, as it forbids to derive
111
    // Transparent on types like `struct Foo<T>(T)`, namely `T` not being
112
    // covered by something else, like `PhantomData<T>` or `Vec<T>`.
113
    impl<$tgens> From<$ttype> for $ftype {
114
16012
        fn from(self_: $ttype) -> $ftype {
115
            self_.$fname
116
        }
117
    }
118

            
119
    impl<$tgens> Deref for $ttype {
120
        type Target = $ftype;
121
328412484
        fn deref(&self) -> &$ftype {
122
            &self.$fname
123
        }
124
    }
125

            
126
    impl<$tgens> DerefMut for $ttype {
127
2
        fn deref_mut(&mut self) -> &mut $ftype {
128
            &mut self.$fname
129
        }
130
    }
131

            
132
    impl<$tgens> AsRef<$ftype> for $ttype {
133
        fn as_ref(&self) -> &$ftype {
134
            &self.$fname
135
        }
136
    }
137

            
138
    impl<$tgens> AsMut<$ftype> for $ttype {
139
        fn as_mut(&mut self) -> &mut $ftype {
140
            &mut self.$fname
141
        }
142
    }
143
  }}
144
  }}
145
}
146

            
147
define_derive_deftly! {
148
    use Transparent;
149

            
150
    /// Implement conversion traits for an arbitrary transparent newtype
151
    ///
152
    /// # Requirements
153
    ///
154
    ///  * Self should be a single-field struct
155
    ///  * Self should have no runtime invariants
156
    ///
157
    /// # Generated code
158
    ///
159
    $TRANSPARENT_DOCS_IMPLS
160
    ///  * impls of `AsMut<field>`, `AsRef<field>`
161
    ///
162
    /// # Guidelines
163
    ///
164
    ///  * the field should be `pub`, with `#[allow(clippy::exhaustive_structs)]`
165
    ///  * derive `Hash`, `Debug` and (usually) `Clone`
166
    ///  * consider deriving `PartialEq` and `Eq`
167
    ///    but for types containing bytes, use [`ConstantTimeEq`],
168
    ///    eg with [`#[derive_deftly(BytesTransparent)]`](derive_deftly_template_BytesTransparent)
169
    ///    (instead of `Transparent`).
170
    ///  * implement `FromStr`, `Display`, `NormalItemArgument`, as required
171
    Transparent for struct, beta_deftly:
172

            
173
    $TRANSPARENT_IMPLS
174
}
175

            
176
define_derive_deftly! {
177
    use Transparent;
178

            
179
    /// Implement `ConstantTimeEq`, `.as_bytes()`, etc., for a transparent newtype around bytes
180
    ///
181
    /// # Requirements
182
    ///
183
    ///  * Self should be a single-field struct
184
    ///  * Self should deref to `&[u8]` (and to `&mut [u8]`).
185
    ///  * (so Self should have no runtime invariants)
186
    ///
187
    /// # Generated code
188
    ///
189
    ///  * impls of `ConstantTimeEq`, `Eq`, `PartialEq`, `Ord`, `PartialOrd`
190
    ///  * `as_bytes()` method
191
    ${TRANSPARENT_DOCS_IMPLS}
192
    ///  * impls of `AsMut<field>`, `AsRef<field>`, `AsRef<[u8]>`, `AsMut<[u8]>`
193
    ///
194
    // We could derive Debug here but then we have to deal with the Fixed's N
195
    // which gets quite fiddly.
196
    //
197
    /// # Guidelines
198
    ///
199
    ///  * derive `Hash` and write `#[allow(clippy::derived_hash_with_manual_eq)]`
200
    ///  * impl `FromStr` and `Display` (if required, which they usually will be)
201
    ///  * derive `derive_more::Debug` eg with `#[debug(r#"B64("{self}")"#)]`
202
    ///  * `impl NormalItemArgument` if appropriate (ie the representation has no spaces)
203
    BytesTransparent for struct, beta_deftly:
204

            
205
    $TRANSPARENT_IMPLS
206

            
207
    impl<$tgens> ConstantTimeEq for $ttype {
208
        fn ct_eq(&self, other: &$ttype) -> Choice {
209
          $(
210
            self.$fname.ct_eq(&other.$fname)
211
          )
212
        }
213
    }
214
    $/// `$tname` is `Eq` via its constant-time implementation.
215
    impl<$tgens> PartialEq for $ttype {
216
        fn eq(&self, other: &$ttype) -> bool {
217
            self.ct_eq(other).into()
218
        }
219
    }
220
    impl<$tgens> Eq for $ttype {}
221
    impl<$tgens> PartialOrd for $ttype {
222
        fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
223
            Some(self.cmp(other))
224
        }
225
    }
226
    impl<$tgens> Ord for $ttype {
227
        fn cmp(&self, other: &Self) -> Ordering {
228
          $(
229
            self.$fname.cmp(&other.$fname)
230
          )
231
        }
232
    }
233

            
234
    impl<$tgens> $ttype {
235
        /// Return the byte array from this object.
236
13510
        pub fn as_bytes(&self) -> &[u8] {
237
          $(
238
13510
            &self.$fname[..]
239
          )
240
13510
        }
241
    }
242

            
243
    impl<$tgens> AsRef<[u8]> for $ttype {
244
        fn as_ref(&self) -> &[u8] {
245
          $(
246
            self.$fname.as_ref()
247
          )
248
        }
249
    }
250

            
251
    impl<$tgens> AsMut<[u8]> for $ttype {
252
        fn as_mut(&mut self) -> &mut [u8] {
253
          $(
254
            self.$fname.as_mut()
255
          )
256
        }
257
    }
258
}
259

            
260
/// Types for decoding base64-encoded values.
261
mod b64impl {
262
    use super::*;
263
    use crate::{Error, NetdocErrorKind as EK, Pos, Result};
264
    use base64ct::{Base64, Base64Unpadded, Encoding};
265
    use std::ops::RangeBounds;
266

            
267
    /// A byte array, encoded in base64 with optional padding.
268
    ///
269
    /// On output (`Display`), output is unpadded.
270
    #[derive(Clone, Hash, Deftly)]
271
    #[derive_deftly(BytesTransparent)]
272
    #[allow(clippy::derived_hash_with_manual_eq)]
273
    #[derive(derive_more::Debug)]
274
    #[debug(r#"B64("{self}")"#)]
275
    #[allow(clippy::exhaustive_structs)]
276
    pub struct B64(pub Vec<u8>);
277

            
278
    impl FromStr for B64 {
279
        type Err = Error;
280
94736
        fn from_str(s: &str) -> Result<Self> {
281
94736
            let v: core::result::Result<Vec<u8>, base64ct::Error> = match s.len() % 4 {
282
14568
                0 => Base64::decode_vec(s),
283
80168
                _ => Base64Unpadded::decode_vec(s),
284
            };
285
112743
            let v = v.map_err(|_| {
286
36014
                EK::BadArgument
287
36014
                    .with_msg("Invalid base64")
288
36014
                    .at_pos(Pos::at(s))
289
54021
            })?;
290
58722
            Ok(B64(v))
291
94736
        }
292
    }
293

            
294
    impl Display for B64 {
295
102
        fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
296
102
            Display::fmt(&Base64Unpadded::encode_string(&self.0), f)
297
102
        }
298
    }
299

            
300
    impl B64 {
301
        /// Return this object if its length is within the provided bounds
302
        /// object, or an error otherwise.
303
2124
        pub(crate) fn check_len<B: RangeBounds<usize>>(self, bounds: B) -> Result<Self> {
304
2124
            if bounds.contains(&self.0.len()) {
305
2122
                Ok(self)
306
            } else {
307
2
                Err(EK::BadObjectVal.with_msg("Invalid length on base64 data"))
308
            }
309
2124
        }
310

            
311
        /// Try to convert this object into an array of N bytes.
312
        ///
313
        /// Return an error if the length is wrong.
314
42388
        pub(crate) fn into_array<const N: usize>(self) -> Result<[u8; N]> {
315
42388
            self.0
316
42388
                .try_into()
317
42388
                .map_err(|_| EK::BadObjectVal.with_msg("Invalid length on base64 data"))
318
42388
        }
319
    }
320

            
321
    impl FromIterator<u8> for B64 {
322
        fn from_iter<T: IntoIterator<Item = u8>>(iter: T) -> Self {
323
            Self(iter.into_iter().collect())
324
        }
325
    }
326

            
327
    impl NormalItemArgument for B64 {}
328

            
329
    /// A byte array encoded in a hexadecimal with a fixed length.
330
    #[derive(Clone, Hash, Deftly)]
331
    #[derive_deftly(BytesTransparent)]
332
    #[allow(clippy::derived_hash_with_manual_eq)]
333
    #[derive(derive_more::Debug)]
334
    #[debug(r#"FixedB64::<{N}>("{self}")"#)]
335
    #[allow(clippy::exhaustive_structs)]
336
    pub struct FixedB64<const N: usize>(pub [u8; N]);
337

            
338
    impl<const N: usize> Display for FixedB64<N> {
339
82
        fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
340
82
            Display::fmt(&B64(self.0.to_vec()), f)
341
82
        }
342
    }
343

            
344
    impl<const N: usize> FromStr for FixedB64<N> {
345
        type Err = Error;
346
6122
        fn from_str(s: &str) -> Result<Self> {
347
6122
            Ok(Self(B64::from_str(s)?.0.try_into().map_err(|_| {
348
2
                EK::BadArgument
349
2
                    .at_pos(Pos::at(s))
350
2
                    .with_msg("invalid length")
351
2
            })?))
352
6122
        }
353
    }
354

            
355
    impl<const N: usize> NormalItemArgument for FixedB64<N> {}
356
}
357

            
358
// ============================================================
359

            
360
/// Types for decoding hex-encoded values.
361
mod b16impl {
362
    use super::*;
363
    use crate::{Error, NetdocErrorKind as EK, Pos, Result};
364

            
365
    /// A byte array encoded in hexadecimal; prints in lowercase
366
    ///
367
    /// Both uppercase and lowercase are tolerated when parsing.
368
    #[derive(Clone, Hash, Deftly)]
369
    #[derive_deftly(BytesTransparent)]
370
    #[allow(clippy::derived_hash_with_manual_eq)]
371
    #[derive(derive_more::Debug)]
372
    #[debug(r#"B16("{self}")"#)]
373
    #[allow(clippy::exhaustive_structs)]
374
    pub struct B16(pub Vec<u8>);
375

            
376
    /// A byte array encoded in hexadecimal; prints in uppercase
377
    ///
378
    /// Both uppercase and lowercase are tolerated when parsing.
379
    #[derive(Clone, Hash, Deftly)]
380
    #[derive_deftly(BytesTransparent)]
381
    #[allow(clippy::derived_hash_with_manual_eq)]
382
    #[derive(derive_more::Debug)]
383
    #[debug(r#"B16U("{self}")"#)]
384
    #[allow(clippy::exhaustive_structs)]
385
    pub struct B16U(pub Vec<u8>);
386

            
387
    /// A fixed-length version of [`B16U`].
388
    #[derive(Clone, Hash, Deftly)]
389
    #[derive_deftly(BytesTransparent)]
390
    #[allow(clippy::derived_hash_with_manual_eq)]
391
    #[derive(derive_more::Debug)]
392
    #[debug(r#"FixedB16U("{self}")"#)]
393
    #[allow(clippy::exhaustive_structs)]
394
    pub struct FixedB16U<const N: usize>(pub [u8; N]);
395

            
396
    impl FromStr for B16 {
397
        type Err = Error;
398
3154
        fn from_str(s: &str) -> Result<Self> {
399
3156
            let bytes = hex::decode(s).map_err(|_| {
400
4
                EK::BadArgument
401
4
                    .at_pos(Pos::at(s))
402
4
                    .with_msg("invalid hexadecimal")
403
6
            })?;
404
3150
            Ok(B16(bytes))
405
3154
        }
406
    }
407

            
408
    impl FromStr for B16U {
409
        type Err = Error;
410
3144
        fn from_str(s: &str) -> Result<Self> {
411
3144
            Ok(B16U(B16::from_str(s)?.0))
412
3144
        }
413
    }
414

            
415
    impl<const N: usize> FromStr for FixedB16U<N> {
416
        type Err = Error;
417
        fn from_str(s: &str) -> Result<Self> {
418
            Ok(Self(B16U::from_str(s)?.0.try_into().map_err(|_| {
419
                EK::BadArgument
420
                    .at_pos(Pos::at(s))
421
                    .with_msg("invalid length")
422
            })?))
423
        }
424
    }
425

            
426
    /// Write `b` to `f` in hex uppercase
427
    // `hex` has `hex::encode_upper` but that allocates a `String`
428
38
    fn write_b16u(b: &[u8], f: &mut fmt::Formatter) -> fmt::Result {
429
668
        for c in b {
430
668
            write!(f, "{c:02X}")?;
431
        }
432
38
        Ok(())
433
38
    }
434

            
435
    impl Display for B16 {
436
6
        fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
437
            // `hex` has `hex::encode` but that allocates a `String`, which this approach doesn't
438
28
            for c in self.as_bytes() {
439
28
                write!(f, "{c:02x}")?;
440
            }
441
6
            Ok(())
442
6
        }
443
    }
444

            
445
    impl Display for B16U {
446
38
        fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
447
38
            write_b16u(self.as_bytes(), f)
448
38
        }
449
    }
450

            
451
    impl<const N: usize> Display for FixedB16U<N> {
452
        fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
453
            write_b16u(self.as_bytes(), f)
454
        }
455
    }
456

            
457
    impl NormalItemArgument for B16 {}
458
    impl NormalItemArgument for B16U {}
459
    impl<const N: usize> NormalItemArgument for FixedB16U<N> {}
460
}
461

            
462
// ============================================================
463

            
464
/// Types for decoding curve25519 keys
465
mod curve25519impl {
466
    use super::*;
467

            
468
    use crate::{Error, NormalItemArgument, Result, types::misc::FixedB64};
469
    use tor_llcrypto::pk::curve25519::PublicKey;
470

            
471
    /// A Curve25519 public key, encoded in base64 with optional padding
472
    #[derive(Debug, Clone, PartialEq, Eq, Deftly)]
473
    #[derive_deftly(Transparent)]
474
    #[allow(clippy::exhaustive_structs)]
475
    pub struct Curve25519Public(pub PublicKey);
476

            
477
    impl FromStr for Curve25519Public {
478
        type Err = Error;
479
2812
        fn from_str(s: &str) -> Result<Self> {
480
2812
            let pk: FixedB64<32> = s.parse()?;
481
2802
            let pk: [u8; 32] = pk.into();
482
2802
            Ok(Curve25519Public(pk.into()))
483
2812
        }
484
    }
485

            
486
    impl Display for Curve25519Public {
487
        fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
488
            FixedB64::from(self.0.to_bytes()).fmt(f)
489
        }
490
    }
491

            
492
    impl NormalItemArgument for Curve25519Public {}
493
}
494

            
495
// ============================================================
496

            
497
/// Types for decoding ed25519 keys
498
mod ed25519impl {
499
    use super::*;
500

            
501
    use crate::{Error, NormalItemArgument, Result, types::misc::FixedB64};
502
    use derive_deftly::Deftly;
503
    use tor_llcrypto::pk::ed25519::{Ed25519Identity, Signature};
504

            
505
    /// An alleged ed25519 public key, encoded in base64 with optional
506
    /// padding.
507
    #[derive(Debug, Clone, PartialEq, Eq, Deftly)]
508
    #[derive_deftly(Transparent)]
509
    #[allow(clippy::exhaustive_structs)]
510
    pub struct Ed25519Public(pub Ed25519Identity);
511

            
512
    impl FromStr for Ed25519Public {
513
        type Err = Error;
514
2822
        fn from_str(s: &str) -> Result<Self> {
515
2822
            let pk: FixedB64<32> = s.parse()?;
516
2816
            Ok(Ed25519Public(Ed25519Identity::new(pk.into())))
517
2822
        }
518
    }
519

            
520
    impl Display for Ed25519Public {
521
        fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
522
            let pk: [u8; 32] = self.0.into();
523
            let pk = FixedB64::from(pk);
524
            pk.fmt(f)
525
        }
526
    }
527

            
528
    impl NormalItemArgument for Ed25519Public {}
529

            
530
    /// Helper that checks for the presence of `ed25519`.
531
    #[derive(Debug, Clone, PartialEq, Eq, derive_more::Display, derive_more::FromStr)]
532
    #[display(rename_all = "lowercase")]
533
    #[from_str(rename_all = "lowercase")]
534
    #[allow(clippy::exhaustive_enums)]
535
    pub enum Ed25519AlgorithmString {
536
        /// Ed25519 encoded as `ed25519`.
537
        Ed25519,
538
    }
539

            
540
    impl NormalItemArgument for Ed25519AlgorithmString {}
541

            
542
    /// Ed25519 public key in the form `<keyword> id <base64>`
543
    ///
544
    ///  * `id` in microdescriptors:
545
    ///    <https://spec.torproject.org/dir-spec/computing-microdescriptors.html>
546
    ///
547
    ///  * `identity-ed25519` in routerdescs:
548
    ///    <https://spec.torproject.org/dir-spec/server-descriptor-format.html#item:identity-ed25519>
549
    ///
550
    ///  * `id` in votes' routerstatus entries:
551
    ///    <https://spec.torproject.org/dir-spec/consensus-formats.html#item:id>
552
    #[derive(Debug, Clone, PartialEq, Eq, Deftly)]
553
    #[derive_deftly(ItemValueEncodable, ItemValueParseable)]
554
    #[non_exhaustive]
555
    pub struct Ed25519IdentityLine {
556
        /// Fixed magic identifier (`ed25519`) for this line.
557
        pub alg: Ed25519AlgorithmString,
558

            
559
        /// The actual Ed25519 identity.
560
        pub pk: Ed25519Public,
561
    }
562

            
563
    impl From<Ed25519Public> for Ed25519IdentityLine {
564
488166
        fn from(pk: Ed25519Public) -> Self {
565
488166
            Self {
566
488166
                alg: Ed25519AlgorithmString::Ed25519,
567
488166
                pk,
568
488166
            }
569
488166
        }
570
    }
571

            
572
    impl From<Ed25519Identity> for Ed25519IdentityLine {
573
488166
        fn from(pk: Ed25519Identity) -> Self {
574
488166
            Ed25519Public(pk).into()
575
488166
        }
576
    }
577

            
578
    impl ItemArgument for Signature {
579
2
        fn write_arg_onto(&self, out: &mut ItemEncoder) -> StdResult<(), Bug> {
580
2
            FixedB64::from(self.to_bytes()).write_arg_onto(out)
581
2
        }
582
    }
583
}
584

            
585
// ============================================================
586

            
587
/// Dummy types like [`Ignored`]
588
mod ignored_impl {
589
    use super::*;
590

            
591
    use crate::parse2::ErrorProblem as EP;
592
    use ArgumentError as AE;
593

            
594
    /// Part of a network document, that isn't actually there.
595
    ///
596
    /// Used as a standin in `ns_type!` calls in various netstatus `each_variety.rs`.
597
    /// The effect is as if the field were omitted from the containing type.
598
    ///
599
    ///  * When used as item(s) (ie, a field type when deriving `NetdocParseable\[Fields\]`):
600
    ///    **ignores any number** of items with that field's keyword during parsing,
601
    ///    and emits none during encoding.
602
    ///
603
    ///    (To *reject* documents containing this item, use `Option<Void>`,
604
    ///    but note that the spec says unknown items should be ignored,
605
    ///    which would normally include items which are merely missing from one variety.)
606
    ///
607
    ///  * When used as an argument (ie, a field type when deriving `ItemValueParseable`,
608
    ///    or with `netdoc(single_arg)`  when deriving `NetdocParseable\[Fields\]`):
609
    ///    consumes **no arguments** during parsing, and emits none during encoding.
610
    ///
611
    ///  * When used as an object field (ie, `netdoc(object)` when deriving `ItemValueParseable`):
612
    ///    **rejects** an object - failing the parse if one is present.
613
    ///    (Functions similarly to `Option<Void>`, but prefer `NotPresent` as it's clearer.)
614
    ///
615
    ///  * When used as a sub-document (ie, `netdoc(flatten)` when deriving a document trait),
616
    ///    it recognises, and encodes as, no fields.
617
    ///
618
    /// There are bespoke impls of the multiplicity traits
619
    /// `ItemSetMethods` and `ObjectSetMethods`:
620
    /// don't wrap this type in `Option` or `Vec`.
621
    //
622
    // TODO we'll need to implement ItemArgument etc., for encoding, too.
623
    #[derive(Debug, Copy, Clone, Eq, PartialEq, Hash, Ord, PartialOrd, Default)]
624
    #[allow(clippy::exhaustive_structs)]
625
    #[derive(Deftly)]
626
    #[derive_deftly(NetdocEncodableFields, NetdocParseableFields)]
627
    pub struct NotPresent;
628

            
629
    /// An individual value that is not present - placeholder type
630
    ///
631
    /// This is the "single" item type for encoding multiplicity
632
    /// (for Items, Arguments or Objects), for [`NotPresent`].
633
    ///
634
    /// It should not be used directly.
635
    ///
636
    /// During parsing, each "not present" item is ignored,
637
    /// but the multiplicity arrangements involve parsing each value
638
    /// and then passing the item value to [`ItemSetMethods::accumulate`]
639
    /// where (for [`NotPresentEachValue`]) it is discarded.
640
    /// Therefore this type must be inhabited; the item parser discards the unparsed item.
641
    ///
642
    /// During parsing of arguments, parsing is driven by
643
    /// [our `ArgumentSetMethods::parse_with`][`P2MultiplicitySelector::<NotPresent>::parse_with)
644
    /// which doesn't need to call any parser.
645
    /// So the [`ItemArgumentParseable`] implementation always throws an error.
646
    ///
647
    /// During parsing of objects, rejection is done by
648
    /// [`NotPresentEachValue::check_label`] (and `from_bytes`).
649
    ///
650
    /// For encoding, there is only one multiplicity system which
651
    /// will never call any encoding function, so the encoding functions all throw `Bug`.
652
    ///
653
    /// This type has a similar role to `IgnoredItemOrObjectValue`,
654
    /// but `NotPresentEachValue` is different in detail,
655
    /// and (unlike `Ignored`) must support arguments, not just items and objects.
656
    #[derive(Debug, Clone, Deftly)]
657
    #[non_exhaustive]
658
    #[derive_deftly(ItemValueParseable, NetdocParseableFields)]
659
    pub struct NotPresentEachValue;
660

            
661
    /// Ignored part of a network document.
662
    ///
663
    /// With `parse2`, can be used as an item, object, or even flattened-fields.
664
    ///
665
    /// When deriving `parse2` traits, and a field is absent in a particular netstatus variety,
666
    /// use `ns_type!` with [`NotPresent`], rather than `Ignored`.
667
    ///
668
    /// During encoding as an Items or Objects, will be entirely omitted,
669
    /// via the multiplicity arrangements.
670
    ///
671
    /// Cannot be encoded as an Argument: if this is not the last
672
    /// Argument, we need something to put into the output document to avoid generating
673
    /// a document with the arguments out of step.  If it *is* the last argument,
674
    /// it could simply be omitted, since additional arguments are in any case ignored.
675
    #[derive(Debug, Copy, Clone, Eq, PartialEq, Hash, Ord, PartialOrd, Default, Deftly)]
676
    #[derive_deftly(ItemValueParseable, NetdocParseableFields)]
677
    #[allow(clippy::exhaustive_structs)]
678
    pub struct Ignored;
679

            
680
    /// An Item or Object that would be ignored during parsing and is omitted during encoding
681
    ///
682
    /// This is the "single" item type for encoding multiplicity for Items or Objects,
683
    /// for [`Ignored`].
684
    ///
685
    /// It should not be used directly.
686
    ///
687
    /// This type is uninhabited.
688
    pub struct IgnoredItemOrObjectValue(Void);
689

            
690
    /// Indicates that no further arguments are allowed in a network document Item line
691
    ///
692
    /// Unlike [`NotPresent`], this fails during parsing if there are any more arguments.
693
    ///
694
    /// Should appear only at the end of the argument list.
695
    #[derive(Debug, Copy, Clone, Eq, PartialEq, Hash, Ord, PartialOrd, Default)]
696
    #[allow(clippy::exhaustive_structs)]
697
    pub struct NoMoreArguments;
698

            
699
    /// An item that only matters in terms of presence of absence.
700
    ///
701
    /// Useful for items such as `tunnelled-dir-server` where the mere presence
702
    /// implies a truthful value.
703
    ///
704
    /// This wrapper implements [`ItemValueParseable`] and [`ItemValueEncodable`]
705
    /// rejecting all arguments and objects and just expecting/emitting the
706
    /// keyword (or not).
707
    ///
708
    /// # Examples
709
    ///
710
    /// The following shows an except from a hypothetical netdoc with a
711
    /// [`ItemPresent`] item.
712
    ///
713
    /// ```
714
    /// use derive_deftly::Deftly;
715
    /// use tor_netdoc::types::*;
716
    /// use tor_netdoc::parse2::*;
717
    /// use tor_netdoc::*;
718
    ///
719
    /// #[derive(Debug, Default)]
720
    /// struct Hello;
721
    ///
722
    /// #[derive(Deftly, Debug)]
723
    /// #[derive_deftly(NetdocParseable)]
724
    /// struct TestDoc {
725
    ///     intro: Ignored,
726
    ///     hello: Option<ItemPresent<Hello>>,
727
    /// }
728
    ///
729
    /// // hello is not present.
730
    /// let doc = parse_netdoc::<TestDoc>(&ParseInput::new("intro\n", "")).unwrap();
731
    /// assert!(doc.hello.is_none());
732
    ///
733
    /// // hello is present.
734
    /// let doc = parse_netdoc::<TestDoc>(&ParseInput::new("intro\nhello\n", "")).unwrap();
735
    /// assert!(doc.hello.is_some());
736
    ///
737
    /// // hello has arguments which are ignored.
738
    /// let doc = parse_netdoc::<TestDoc>(&ParseInput::new("intro\nhello world\n", "")).unwrap();
739
    /// assert!(doc.hello.is_some());
740
    ///
741
    /// // hello is present twice which is not allowed.
742
    /// let doc = parse_netdoc::<TestDoc>(&ParseInput::new("intro\nhello\nhello\n", "")).unwrap_err();
743
    /// ```
744
    //
745
    // We cannot derive Transparent here, because it is not possible to
746
    // implement `From<ItemPresent<T>> for T` due to orphan rule.
747
    //
748
    // Otherwise, a downstream crate could for example implement
749
    // `From<ItemPresent<U>> for U` with `U` being a locally defined type,
750
    // leading to a conflicting implementation.  A solution would be to cover
751
    // `T` behind another generic type such as `PhantomData`, as this can't be
752
    // a type in a downstream crate, but that level of indirection feels wrong.
753
    #[derive(Debug, Copy, Clone, Default, Ord, PartialOrd, Eq, PartialEq, Hash)]
754
    //
755
    #[derive(
756
        derive_more::From,
757
        derive_more::Deref,
758
        derive_more::DerefMut,
759
        derive_more::AsRef,
760
        derive_more::AsMut,
761
    )]
762
    #[allow(clippy::exhaustive_structs)]
763
    pub struct ItemPresent<T: Default>(pub T);
764

            
765
    impl ItemSetMethods for P2MultiplicitySelector<NotPresent> {
766
        type Each = NotPresentEachValue;
767
        type Field = NotPresent;
768
        fn can_accumulate(self, _acc: &Option<NotPresent>) -> Result<(), EP> {
769
            Ok(())
770
        }
771
12
        fn accumulate(self, _: &mut Option<NotPresent>, _: NotPresentEachValue) -> Result<(), EP> {
772
12
            Ok(())
773
12
        }
774
1408
        fn finish(self, _acc: Option<NotPresent>, _: &'static str) -> Result<NotPresent, EP> {
775
1408
            Ok(NotPresent)
776
1408
        }
777
        fn debug_core(self) -> &'static str {
778
            "Ignored"
779
        }
780
    }
781

            
782
    impl ItemValueEncodable for NotPresentEachValue {
783
        fn write_item_value_onto(&self, _out: ItemEncoder) -> Result<(), Bug> {
784
            Err(internal!("NotPresentEachValue as ItemValueEncodable"))
785
        }
786
    }
787

            
788
    impl ArgumentSetMethods for P2MultiplicitySelector<NotPresent> {
789
        type Each = NotPresentEachValue;
790
        type Field = NotPresent;
791

            
792
14
        fn parse_with<P>(self, _: &mut ArgumentStream<'_>, _: P) -> Result<Self::Field, AE>
793
14
        where
794
14
            P: for<'s> Fn(&mut ArgumentStream<'s>) -> Result<Self::Each, AE>,
795
        {
796
14
            Ok(NotPresent)
797
14
        }
798

            
799
        fn debug_core(self) -> &'static str {
800
            "NotPresent"
801
        }
802
    }
803
    impl ItemArgument for NotPresentEachValue {
804
        fn write_arg_onto(&self, _out: &mut ItemEncoder) -> Result<(), Bug> {
805
            Err(internal!("NotPresentEachValue as ItemArgument"))
806
        }
807
    }
808
    impl ItemArgumentParseable for NotPresentEachValue {
809
        fn from_args<'s>(_: &mut ArgumentStream<'s>) -> Result<Self, ArgumentError> {
810
            // Not quite the right error, but we don't have an ArgumentError::Internal
811
            Err(AE::Unexpected)
812
        }
813
    }
814

            
815
    impl ItemObjectEncodable for NotPresentEachValue {
816
        fn label(&self) -> &str {
817
            "INTERNAL ERROR"
818
        }
819
        fn write_object_onto(&self, _b: &mut Vec<u8>) -> Result<(), Bug> {
820
            Err(internal!("NotPresentEachValue as ItemObjectEncodable"))
821
        }
822
    }
823

            
824
    impl ObjectSetMethods for P2MultiplicitySelector<NotPresent> {
825
        type Field = NotPresent;
826
        type Each = NotPresentEachValue;
827
6
        fn resolve_option(self, _found: Option<NotPresentEachValue>) -> Result<NotPresent, EP> {
828
6
            Ok(NotPresent)
829
6
        }
830
        fn debug_core(self) -> &'static str {
831
            "NotPresent"
832
        }
833
    }
834
    impl ItemObjectParseable for NotPresentEachValue {
835
2
        fn check_label(_label: &str) -> Result<(), EP> {
836
2
            Err(EP::ObjectUnexpected)
837
2
        }
838
        fn from_bytes(_input: &[u8]) -> Result<Self, EP> {
839
            Err(EP::ObjectUnexpected)
840
        }
841
    }
842

            
843
    impl<'f> encode::MultiplicityMethods<'f> for EMultiplicitySelector<NotPresent> {
844
        type Field = NotPresent;
845
        type Each = NotPresentEachValue;
846
112
        fn iter_ordered(self, _: &'f Self::Field) -> impl Iterator<Item = &'f Self::Each> {
847
112
            iter::empty()
848
112
        }
849
    }
850

            
851
    impl encode::OptionalityMethods for EMultiplicitySelector<NotPresent> {
852
        type Field = NotPresent;
853
        type Each = NotPresentEachValue;
854
2
        fn as_option<'f>(self, _: &'f Self::Field) -> Option<&'f Self::Each> {
855
2
            None
856
2
        }
857
    }
858

            
859
    impl FromStr for Ignored {
860
        type Err = Void;
861
        fn from_str(_s: &str) -> Result<Ignored, Void> {
862
            Ok(Ignored)
863
        }
864
    }
865

            
866
    impl ItemArgumentParseable for Ignored {
867
        fn from_args(_: &mut ArgumentStream) -> Result<Ignored, ArgumentError> {
868
            Ok(Ignored)
869
        }
870
    }
871

            
872
    impl ItemObjectParseable for Ignored {
873
6
        fn check_label(_label: &str) -> Result<(), EP> {
874
            // allow any label
875
6
            Ok(())
876
6
        }
877
6
        fn from_bytes(_input: &[u8]) -> Result<Self, EP> {
878
6
            Ok(Ignored)
879
6
        }
880
    }
881

            
882
    impl ObjectSetMethods for P2MultiplicitySelector<Ignored> {
883
        type Field = Ignored;
884
        type Each = Ignored;
885
6
        fn resolve_option(self, _found: Option<Ignored>) -> Result<Ignored, EP> {
886
6
            Ok(Ignored)
887
6
        }
888
        fn debug_core(self) -> &'static str {
889
            "Ignored"
890
        }
891
    }
892

            
893
    impl<'f> encode::MultiplicityMethods<'f> for EMultiplicitySelector<Ignored> {
894
        type Field = Ignored;
895
        type Each = IgnoredItemOrObjectValue;
896
        fn iter_ordered(self, _: &'f Self::Field) -> impl Iterator<Item = &'f Self::Each> {
897
            iter::empty()
898
        }
899
    }
900

            
901
    impl encode::OptionalityMethods for EMultiplicitySelector<Ignored> {
902
        type Field = Ignored;
903
        type Each = IgnoredItemOrObjectValue;
904
2
        fn as_option<'f>(self, _: &'f Self::Field) -> Option<&'f Self::Each> {
905
2
            None
906
2
        }
907
    }
908

            
909
    impl ItemValueEncodable for IgnoredItemOrObjectValue {
910
        fn write_item_value_onto(&self, _: ItemEncoder) -> Result<(), Bug> {
911
            void::unreachable(self.0)
912
        }
913
    }
914

            
915
    impl ItemObjectEncodable for IgnoredItemOrObjectValue {
916
        fn label(&self) -> &str {
917
            void::unreachable(self.0)
918
        }
919
        fn write_object_onto(&self, _: &mut Vec<u8>) -> Result<(), Bug> {
920
            void::unreachable(self.0)
921
        }
922
    }
923

            
924
    impl ItemArgumentParseable for NoMoreArguments {
925
2
        fn from_args(args: &mut ArgumentStream) -> Result<NoMoreArguments, ArgumentError> {
926
2
            Ok(args.reject_extra_args()?)
927
2
        }
928
    }
929

            
930
    impl ItemArgument for NoMoreArguments {
931
        fn write_arg_onto(&self, _: &mut ItemEncoder) -> Result<(), Bug> {
932
            Ok(())
933
        }
934
    }
935

            
936
    impl<T: Default> ItemValueParseable for ItemPresent<T> {
937
16
        fn from_unparsed(item: UnparsedItem<'_>) -> StdResult<Self, EP> {
938
16
            item.check_no_object()?;
939
14
            Ok(Self::default())
940
16
        }
941
    }
942

            
943
    impl<T: Default> ItemValueEncodable for ItemPresent<T> {
944
2
        fn write_item_value_onto(&self, out: ItemEncoder) -> StdResult<(), Bug> {
945
2
            out.finish();
946
2
            Ok(())
947
2
        }
948
    }
949
}
950

            
951
// ============================================================
952

            
953
/// Information about unknown values, which may have been retained as a `T`
954
///
955
/// Won't grow additional variants - but, `Retained` is only included conditionally.
956
///
957
/// Also used in the form `Unknown<()>` to indicate whether unknown values *should* be retained.
958
///
959
/// ### Example
960
///
961
/// ```
962
/// # {
963
/// #![cfg(feature = "retain-unknown")]
964
///
965
/// use tor_netdoc::types::Unknown;
966
///
967
/// let mut unk: Unknown<Vec<String>> = Unknown::new_retained_default();
968
/// unk.with_mut_unknown(|u| u.push("something-we-found".into()));
969
/// assert_eq!(unk.into_retained().unwrap(), ["something-we-found"]);
970
/// # }
971
/// ```
972
///
973
/// ### Equality comparison, semantics
974
///
975
/// Two `Unknown` are consider equal if both have the same record of unknown values,
976
/// or if neither records unknown values at all.
977
///
978
/// `Unknown` is not `Eq` or `Ord` because we won't want to relate a `Discarded`
979
/// to a `Retained`.  That would be a logic error.  `partial_cmp` gives `None` for this.
980
#[derive(Debug, PartialEq, Clone, Copy, Hash)]
981
#[allow(clippy::exhaustive_enums)] // this isn't going to change
982
pub enum Unknown<T> {
983
    /// The parsing discarded unknown values and they are no longer available.
984
    Discarded(PhantomData<T>),
985

            
986
    /// The document parsing retained (or should retain) unknown values.
987
    #[cfg(feature = "retain-unknown")]
988
    Retained(T),
989
}
990

            
991
impl<T> Unknown<T> {
992
    /// Create an `Unknown` which specifies that values were discarded (or should be)
993
942110
    pub fn new_discard() -> Self {
994
942110
        Unknown::Discarded(PhantomData)
995
942110
    }
996

            
997
    /// Map the `Retained`, if there is one
998
3068
    pub fn map<U>(self, f: impl FnOnce(T) -> U) -> Unknown<U> {
999
3068
        self.try_map(move |t| Ok::<_, Void>(f(t))).void_unwrap()
3068
    }
    /// Map the `Retained`, fallibly
3068
    pub fn try_map<U, E>(self, f: impl FnOnce(T) -> Result<U, E>) -> Result<Unknown<U>, E> {
3068
        Ok(match self {
3008
            Unknown::Discarded(_) => Unknown::Discarded(PhantomData),
            #[cfg(feature = "retain-unknown")]
60
            Unknown::Retained(t) => Unknown::Retained(f(t)?),
        })
3068
    }
    /// Obtain an `Unknown` containing (maybe) a reference
60
    pub fn as_ref(&self) -> Unknown<&T> {
60
        match self {
            Unknown::Discarded(_) => Unknown::Discarded(PhantomData),
            #[cfg(feature = "retain-unknown")]
60
            Unknown::Retained(t) => Unknown::Retained(t),
        }
60
    }
    /// Return the retained unknown data, giving `None` if none was saved
    ///
    /// This is the function for disregarding the possible previously existence
    /// of now-discarded unknown (unrecognised) information.
    ///
    /// Use [`into_retained`](Self::into_retained) if it would be a bug
    /// if unrecognised information had been previously discarded.
32
    pub fn only_known(self) -> Option<T> {
32
        match self {
            Unknown::Discarded(_) => None,
            #[cfg(feature = "retain-unknown")]
32
            Unknown::Retained(t) => Some(t),
        }
32
    }
    /// Obtain the `Retained` data
    ///
    /// Treats lack of retention as an internal error.
28
    pub fn into_retained(self) -> Result<T, Bug> {
28
        match self {
            Unknown::Discarded(_) => Err(internal!("Unknown::retained but data not collected")),
            #[cfg(feature = "retain-unknown")]
28
            Unknown::Retained(t) => Ok(t),
        }
28
    }
    /// Start recording unknown information, with a default value for `T`
    #[cfg(feature = "retain-unknown")]
    pub fn new_retained_default() -> Self
    where
        T: Default,
    {
        Unknown::Retained(T::default())
    }
    /// Update the `Retained`, if there is one
    ///
    /// Intended for use in parsing, when we encounter an unknown value.
    ///
    /// Not provided in `try_` form.  If you think you need this, instead, unconditionally
    /// parse and verify the unknown value, and then conditionally insert it with this function.
    /// Don't parse it conditionally - that would skip some validation.
6
    pub fn with_mut_unknown(&mut self, f: impl FnOnce(&mut T)) {
6
        match self {
2
            Unknown::Discarded(_) => {}
            #[cfg(feature = "retain-unknown")]
4
            Unknown::Retained(t) => f(t),
        }
6
    }
}
impl<T: PartialOrd> PartialOrd for Unknown<T> {
    fn partial_cmp(&self, other: &Self) -> Option<cmp::Ordering> {
        use Unknown::*;
        match (self, other) {
            (Discarded(_), Discarded(_)) => Some(cmp::Ordering::Equal),
            #[cfg(feature = "retain-unknown")]
            (Discarded(_), Retained(_)) | (Retained(_), Discarded(_)) => None,
            #[cfg(feature = "retain-unknown")]
            (Retained(a), Retained(b)) => a.partial_cmp(b),
        }
    }
}
// ============================================================
/// A finite floating point number
///
/// Suitable for `stats` items in voites' routerstatus entries:
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:stats>
///
/// Invariants:
///
///  * Is finite.  (So not NaN or Inf.)  Might be denormal.
///
/// String representation:
///
///  * Parses any valid C-like notation.
///
///  * Never uses exponential notation to display.
///
///  * Output can be rather large, up to 326 characters!
///    This is a spec bug.  The spec forbids us from using exponential notation.
///    <https://gitlab.torproject.org/tpo/core/torspec/-/work_items/416>
///
/// We may to change this in the future to use exponentials notation for output.
/// See <https://gitlab.torproject.org/tpo/core/torspec/-/work_items/416>
//
// TODO torspec#416 Consider replacing our F64Finite with finite f64 newtype from some crate
//
// What a palaver!
//
// This type is here rather than in rs.rs, in case similar things appears in other documents.
#[derive(Debug, Copy, Clone, PartialEq, PartialOrd)] //
#[derive(derive_more::Deref, derive_more::Into, derive_more::Display)]
pub struct F64Finite(f64);
/// Error converting an [`F64Finite`] from an `f64`: the value wasn't finite
#[derive(Clone, Debug, Eq, PartialEq, thiserror::Error, amplify::Getters)]
#[error("FP value {} ({bits:#x}) is not finite", f64::from_bits(self.bits))]
pub struct F64FiniteError {
    /// The raw bits (as from [`f64::to_bits`])
    //
    // We store it this way rather than as `f64` so that `Eq` etc. make sense.
    bits: u64,
}
impl TryFrom<f64> for F64Finite {
    type Error = F64FiniteError;
86
    fn try_from(v: f64) -> Result<Self, F64FiniteError> {
86
        v.is_finite()
86
            .then_some(F64Finite(v))
88
            .ok_or_else(|| F64FiniteError { bits: v.to_bits() })
86
    }
}
/// Error parsing [`F64Finite`] from a string
#[derive(Clone, Debug, Eq, PartialEq, thiserror::Error)]
#[non_exhaustive]
pub enum F64FiniteParseError {
    /// Syntax error
    #[error("syntax error")]
    Syntax(#[from] std::num::ParseFloatError),
    /// Value is not finite
    #[error("bad value")]
    NotFinite(#[from] F64FiniteError),
}
impl FromStr for F64Finite {
    type Err = F64FiniteParseError;
78
    fn from_str(s: &str) -> StdResult<Self, F64FiniteParseError> {
78
        Ok(s.parse::<f64>()?.try_into()?)
78
    }
}
impl Eq for F64Finite {}
#[allow(clippy::derive_ord_xor_partial_ord)]
impl Ord for F64Finite {
    fn cmp(&self, other: &F64Finite) -> cmp::Ordering {
        self.0
            .partial_cmp(&other.0)
            .expect("finite f64 partial_cmp gave None")
    }
}
impl NormalItemArgument for F64Finite {}
// ============================================================
/// Known keyword (enum) value, or arbitrary string
///
/// `T` should be a `Copy` enum with unit variants.
/// It should have appropriate `FromStr` and `Display`,
/// as well as [`NormalItemArgument`], impls.
///
/// Then `KeywordOrString` will implement the same traits.
///
/// Unlike [`Unknown`], unknown values are always retained as strings.
//
// `RelayFlags` has machinery for parsing flags and retaining unknown values,
// but it uses `Unknown` to maybe discard unknown flags,
// and it is generally quite a lot more complicated.
#[derive(Debug, PartialEq, Clone, Hash)]
#[allow(clippy::exhaustive_enums)] // this isn't going to change
pub enum KeywordOrString<T: Copy> {
    /// Known and recognised `T`
    Known(T),
    /// Unknown value in arbitrary syntax
    Unknown(String),
}
impl<T: Copy + NormalItemArgument> NormalItemArgument for KeywordOrString<T> {}
impl<T: Copy + Display> Display for KeywordOrString<T> {
8
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
8
        match self {
8
            KeywordOrString::Known(t) => Display::fmt(t, f),
            KeywordOrString::Unknown(s) => Display::fmt(s, f),
        }
8
    }
}
impl<T: Copy + FromStr> FromStr for KeywordOrString<T> {
    type Err = Void;
1156
    fn from_str(s: &str) -> Result<Self, Void> {
1156
        Ok(match s.parse() {
1156
            Ok(y) => KeywordOrString::Known(y),
            Err(_) => KeywordOrString::Unknown(s.to_owned()),
        })
1156
    }
}
// ============================================================
/// A sequence of `T` items, with their order retained
///
/// Normally when a `Vec<T>` appears in a network document,
/// we expect the items to be sortable - they must impl [`EncodeOrd`](encode::EncodeOrd).
/// When encoding, the output is always sorted.
///
/// *This* type retains the ordering.
///
/// Implements the [`encode`] and [`parse2`] item multiplicity traits.
#[derive(Debug, Clone, Hash, Deftly, Eq, PartialEq, Educe)]
#[educe(Default)]
#[derive_deftly(Transparent)]
#[allow(clippy::exhaustive_structs)]
pub struct RetainedOrderVec<T>(pub Vec<T>);
// ============================================================
/// Types for decoding times and dates
mod timeimpl {
    use super::*;
    use crate::{Error, NetdocErrorKind as EK, Pos, Result};
    use std::time::SystemTime;
    use time::{
        OffsetDateTime, PrimitiveDateTime, format_description::FormatItem,
        macros::format_description,
    };
    /// A wall-clock time, encoded in Iso8601 format with an intervening
    /// space between the date and time.
    ///
    /// (Example: "2020-10-09 17:38:12")
    #[derive(Debug, Copy, Clone, Ord, PartialOrd, Eq, PartialEq, Hash, Deftly)]
    #[derive_deftly(Transparent)]
    #[allow(clippy::exhaustive_structs)]
    pub struct Iso8601TimeSp(pub SystemTime);
    /// Formatting object for parsing the space-separated Iso8601 format.
    const ISO_8601SP_FMT: &[FormatItem] =
        format_description!("[year]-[month]-[day] [hour]:[minute]:[second]");
    impl FromStr for Iso8601TimeSp {
        type Err = Error;
8426
        fn from_str(s: &str) -> Result<Iso8601TimeSp> {
8430
            let d = PrimitiveDateTime::parse(s, &ISO_8601SP_FMT).map_err(|e| {
8
                EK::BadArgument
8
                    .at_pos(Pos::at(s))
8
                    .with_msg(format!("invalid time: {}", e))
12
            })?;
8418
            Ok(Iso8601TimeSp(d.assume_utc().into()))
8426
        }
    }
    /// Formats a SystemTime according to the given format description
    ///
    /// Also converts any time::error::format to fmt::Error
    /// so that it can be unwrapped in the Display trait impl
30
    fn fmt_with(
30
        t: SystemTime,
30
        format_desc: &[FormatItem],
30
    ) -> core::result::Result<String, fmt::Error> {
30
        OffsetDateTime::from(t)
30
            .format(format_desc)
30
            .map_err(|_| fmt::Error)
30
    }
    impl Display for Iso8601TimeSp {
24
        fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
24
            write!(f, "{}", fmt_with(self.0, ISO_8601SP_FMT)?)
24
        }
    }
    /// A wall-clock time, encoded in ISO8601 format without an intervening
    /// space.
    ///
    /// This represents a specific UTC instant (ie an instant in global civil time).
    /// But it may not be able to represent leap seconds.
    ///
    /// The timezone is not included in the string representation; `+0000` is implicit.
    ///
    /// (Example: "2020-10-09T17:38:12")
    #[derive(Debug, Copy, Clone, Ord, PartialOrd, Eq, PartialEq, Hash, Deftly)]
    #[derive_deftly(Transparent)]
    #[allow(clippy::exhaustive_structs)]
    pub struct Iso8601TimeNoSp(pub SystemTime);
    /// Formatting object for parsing the space-separated Iso8601 format.
    const ISO_8601NOSP_FMT: &[FormatItem] =
        format_description!("[year]-[month]-[day]T[hour]:[minute]:[second]");
    impl FromStr for Iso8601TimeNoSp {
        type Err = Error;
24
        fn from_str(s: &str) -> Result<Iso8601TimeNoSp> {
28
            let d = PrimitiveDateTime::parse(s, &ISO_8601NOSP_FMT).map_err(|e| {
8
                EK::BadArgument
8
                    .at_pos(Pos::at(s))
8
                    .with_msg(format!("invalid time: {}", e))
12
            })?;
16
            Ok(Iso8601TimeNoSp(d.assume_utc().into()))
24
        }
    }
    impl Display for Iso8601TimeNoSp {
6
        fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
6
            write!(f, "{}", fmt_with(self.0, ISO_8601NOSP_FMT)?)
6
        }
    }
    impl crate::NormalItemArgument for Iso8601TimeNoSp {}
}
/// Types for decoding RSA keys
mod rsa {
    use super::*;
    use crate::{NetdocErrorKind as EK, Pos, Result};
    use std::ops::RangeBounds;
    use tor_llcrypto::pk::rsa::PublicKey;
    use tor_llcrypto::{d::Sha1, pk::rsa::KeyPair};
    /// The fixed exponent which we require when parsing any RSA key in a netdoc
    //
    // TODO this value is duplicated a lot in the v1 parser
    pub(crate) const RSA_FIXED_EXPONENT: u32 = 65537;
    /// The fixed exponent which we require when parsing any RSA key in a netdoc
    //
    // TODO this value is duplicated a lot in the v1 parser
    pub(crate) const RSA_MIN_BITS: usize = 1024;
    /// RSA public key, partially processed by `crate::paarse`.
    ///
    /// As parsed from a base64-encoded object.
    /// They key's properties (exponent and size) haven't been checked.
    #[allow(non_camel_case_types)]
    #[derive(Clone, Debug)]
    pub(crate) struct RsaPublicParse1Helper(PublicKey, Pos);
    /// RSA signature using SHA-1 as per "Signing documents" in dir-spec
    ///
    /// <https://spec.torproject.org/dir-spec/netdoc.html#signing>
    ///
    /// Used for
    /// [`AuthCert::dir-key-certification`](crate::doc::authcert::AuthCert::dir-key-certification),
    /// for example.
    ///
    /// # Caveats
    ///
    /// This type MUST NOT be used for anomalous signatures
    /// such as
    /// [`AuthCert::dir_key_crosscert`](crate::doc::authcert::AuthCert::dir_key_crosscert);
    /// in that case because `dir_key_crosscert`'s
    /// set of allowed object labels includes `ID SIGNATURE` whereas this type
    /// is always `SIGNATURE`
    #[derive(Debug, Clone, PartialEq, Eq, Deftly)]
    #[derive_deftly(ItemValueParseable, ItemValueEncodable)]
    #[deftly(netdoc(no_extra_args, signature(hash_accu = Sha1WholeKeywordLine)))]
    #[non_exhaustive]
    pub struct RsaSha1Signature {
        /// The bytes of the signature (base64-decoded).
        #[deftly(netdoc(object(label = "SIGNATURE"), with = crate::types::raw_data_object))]
        pub signature: Vec<u8>,
    }
    impl From<RsaPublicParse1Helper> for PublicKey {
5398
        fn from(k: RsaPublicParse1Helper) -> PublicKey {
5398
            k.0
5398
        }
    }
    impl super::FromBytes for RsaPublicParse1Helper {
5400
        fn from_bytes(b: &[u8], pos: Pos) -> Result<Self> {
5400
            let key = PublicKey::from_der(b)
5401
                .ok_or_else(|| EK::BadObjectVal.with_msg("unable to decode RSA public key"))?;
5398
            Ok(RsaPublicParse1Helper(key, pos))
5400
        }
    }
    impl RsaPublicParse1Helper {
        /// Give an error if the exponent of this key is not 'e'
5400
        pub(crate) fn check_exponent(self, e: u32) -> Result<Self> {
5400
            if self.0.exponent_is(e) {
5398
                Ok(self)
            } else {
2
                Err(EK::BadObjectVal
2
                    .at_pos(self.1)
2
                    .with_msg("invalid RSA exponent"))
            }
5400
        }
        /// Give an error if the length of this key's modulus, in
        /// bits, is not contained in 'bounds'
5404
        pub(crate) fn check_len<B: RangeBounds<usize>>(self, bounds: B) -> Result<Self> {
5404
            if bounds.contains(&self.0.bits()) {
5400
                Ok(self)
            } else {
4
                Err(EK::BadObjectVal
4
                    .at_pos(self.1)
4
                    .with_msg("invalid RSA length"))
            }
5404
        }
        /// Give an error if the length of this key's modulus, in
        /// bits, is not exactly `n`.
5022
        pub(crate) fn check_len_eq(self, n: usize) -> Result<Self> {
5022
            self.check_len(n..=n)
5022
        }
    }
    impl RsaSha1Signature {
        /// Make a signature according to "Signing documents" in the netdoc spec
        ///
        /// <https://spec.torproject.org/dir-spec/netdoc.html#signing>
        ///
        /// `NetdocEncoder` should have had the body of the document
        /// (everything except the signatures) already encoded.
        ///
        /// `item_keyword` is the keyword for the signature item.
        /// This is needed because different documents use different keywords,
        /// and the keyword is covered by the signature (an annoying is a layering violation).
        /// See <https://gitlab.torproject.org/tpo/core/torspec/-/issues/322>.
        ///
        /// # Example
        ///
        /// ```
        /// use derive_deftly::Deftly;
        /// use tor_error::Bug;
        /// use tor_llcrypto::pk::rsa;
        /// use tor_netdoc::derive_deftly_template_NetdocEncodable;
        /// use tor_netdoc::encode::{NetdocEncodable, NetdocEncoder};
        /// use tor_netdoc::types::RsaSha1Signature;
        ///
        /// #[derive(Deftly, Default)]
        /// #[derive_deftly(NetdocEncodable)]
        /// pub struct Document {
        ///     pub document_intro_keyword: (),
        /// }
        /// #[derive(Deftly)]
        /// #[derive_deftly(NetdocEncodable)]
        /// pub struct DocumentSignatures {
        ///     pub document_signature: RsaSha1Signature,
        /// }
        /// impl Document {
        ///     pub fn encode_sign(&self, k: &rsa::KeyPair) -> Result<String, Bug> {
        ///         let mut encoder = NetdocEncoder::new();
        ///         self.encode_unsigned(&mut encoder)?;
        ///         let document_signature =
        ///             RsaSha1Signature::new_sign_netdoc(k, &encoder, "document-signature")?;
        ///         let sigs = DocumentSignatures { document_signature };
        ///         sigs.encode_unsigned(&mut encoder)?;
        ///         let encoded = encoder.finish()?;
        ///         Ok(encoded)
        ///     }
        /// }
        ///
        /// # fn main() -> Result<(), anyhow::Error> {
        /// let k = rsa::KeyPair::generate(&mut tor_basic_utils::test_rng::testing_rng())?;
        /// let doc = Document::default();
        /// let encoded = doc.encode_sign(&k)?;
        /// assert!(encoded.starts_with(concat!(
        ///     "document-intro-keyword\n",
        ///     "document-signature\n",
        ///     "-----BEGIN SIGNATURE-----\n",
        /// )));
        /// # Ok(())
        /// # }
        /// ```
2
        pub fn new_sign_netdoc(
2
            private_key: &KeyPair,
2
            encoder: &NetdocEncoder,
2
            item_keyword: &str,
2
        ) -> StdResult<Self, Bug> {
2
            let mut h = Sha1::new();
2
            h.update(encoder.text_sofar()?);
2
            h.update(item_keyword);
2
            h.update("\n");
2
            let h = h.finalize();
2
            let signature = private_key
2
                .sign(&h)
2
                .map_err(into_internal!("RSA signing failed"))?;
2
            Ok(RsaSha1Signature { signature })
2
        }
    }
}
/// Types for decoding Ed25519 certificates
mod edcert {
    use std::result::Result as StdResult;
    use std::time::{Duration, SystemTime};
    use crate::types::EmbeddedCert;
    use crate::{
        NetdocErrorKind as EK, Pos, Result,
        parse2::{ErrorProblem, VerifyFailed},
        types::EmbeddableCertObject,
    };
    use saturating_time::SaturatingTime;
    use tor_cert::{CertType, CertifiedKey, Ed25519Cert, KeyUnknownCert};
    use tor_checkable::signed::SignatureGated;
    use tor_checkable::timed::TimerangeBound;
    use tor_checkable::{SelfSigned, Timebound};
    use tor_error::{Bug, into_internal};
    use tor_llcrypto::pk::ed25519::{self, Ed25519PublicKey, ValidatableEd25519Signature};
    /// An ed25519 certificate as parsed from a directory object, with
    /// signature not validated.
    #[derive(Debug, Clone)]
    pub(crate) struct UnvalidatedEdCert(KeyUnknownCert, Pos);
    impl super::FromBytes for UnvalidatedEdCert {
9772
        fn from_bytes(b: &[u8], p: Pos) -> Result<Self> {
9773
            let cert = Ed25519Cert::decode(b).map_err(|e| {
2
                EK::BadObjectVal
2
                    .at_pos(p)
2
                    .with_msg("Bad certificate")
2
                    .with_source(e)
3
            })?;
9770
            Ok(Self(cert, p))
9772
        }
9772
        fn from_vec(v: Vec<u8>, p: Pos) -> Result<Self> {
9772
            Self::from_bytes(&v[..], p)
9772
        }
    }
    impl UnvalidatedEdCert {
        /// Give an error if this certificate's type is not `desired_type`.
7490
        pub(crate) fn check_cert_type(self, desired_type: CertType) -> Result<Self> {
7490
            if self.0.peek_cert_type() != desired_type {
2
                return Err(EK::BadObjectVal.at_pos(self.1).with_msg(format!(
2
                    "bad certificate type {} (wanted {})",
2
                    self.0.peek_cert_type(),
2
                    desired_type
2
                )));
7488
            }
7488
            Ok(self)
7490
        }
        /// Give an error if this certificate's subject_key is not `pk`
8
        pub(crate) fn check_subject_key_is(self, pk: &ed25519::Ed25519Identity) -> Result<Self> {
8
            if self.0.peek_subject_key().as_ed25519() != Some(pk) {
2
                return Err(EK::BadObjectVal
2
                    .at_pos(self.1)
2
                    .with_msg("incorrect subject key"));
6
            }
6
            Ok(self)
8
        }
        /// Consume this object and return the inner Ed25519 certificate.
9768
        pub(crate) fn into_unchecked(self) -> KeyUnknownCert {
9768
            self.0
9768
        }
    }
    /// An Ed25519 identity certificate.
    ///
    /// This is a certificate of [`CertType::IDENTITY_V_SIGNING`] where the
    /// relay's long-term ed25519 identity key signs the relay's medium-term
    /// ed25519 signing key, used for signing almost all other certifications
    /// associated with a given relay.
    #[derive(Debug, Clone, PartialEq, Eq)]
    #[allow(clippy::exhaustive_structs)]
    pub struct Ed25519IdentityCert {
        /// The long-term ed25519 identity key of the relay
        pub id_ed25519: ed25519::Ed25519Identity,
        /// The medium-term ed25519 signing key of the relay.
        pub sign_ed25519: ed25519::Ed25519Identity,
    }
    impl EmbeddableCertObject<KeyUnknownCert> for Ed25519IdentityCert {
        const LABEL: &str = "ED25519 CERT";
    }
    impl Ed25519IdentityCert {
        /// Verifies the validity of an [`Ed25519IdentityCert`].
        ///
        /// # Requirements
        ///
        /// 1. MUST have the identity key in the `signed-with-ed25519-key` extension.
        /// 2. MUST have a valid signature by the identity key.
        /// 3. MUST be valid at `now`.
        /// 4. MUST be of [`CertType::IDENTITY_V_SIGNING`].
        /// 5. Certified key MUST BE of [`tor_cert::CertifiedKey::Ed25519`].
        /// 6. Both keys MUST be valid mappings to a [`ed25519::PublicKey`].
12
        pub fn verify(
12
            cert: KeyUnknownCert,
12
            post_tolerance: Duration,
12
            now: SystemTime,
12
        ) -> StdResult<Self, VerifyFailed> {
12
            let cert = cert
                // 1. MUST have the identity key in the `signed-with-ed25519-key` extension.
12
                .should_have_signing_key()
13
                .map_err(|_| VerifyFailed::ParseEmbedded(ErrorProblem::ObjectInvalidData))?
                // 2. MUST have a valid signature by the identity key.
10
                .check_signature()?
                // 3. MUST be valid at `now`.
10
                .check_valid_at(&now.saturating_sub(post_tolerance))?;
            // 4. MUST be of [`CertType::IDENTITY_V_SIGNING`].
8
            if cert.cert_type() != CertType::IDENTITY_V_SIGNING {
2
                return Err(VerifyFailed::ParseEmbedded(ErrorProblem::ObjectInvalidData));
6
            }
            // Bug is alright because .should_have_signing_key() assured us.
6
            let id_ed25519 = *cert.signing_key().ok_or(VerifyFailed::Bug)?;
            // 5. Certified key MUST BE of [`tor_cert::CertifiedKey::Ed25519`].
6
            let sign_ed25519 = *cert
6
                .subject_key()
6
                .as_ed25519()
6
                .ok_or(VerifyFailed::ParseEmbedded(ErrorProblem::ObjectInvalidData))?;
            // 6. Both keys MUST be valid mappings to a [`ed25519::PublicKey`].
            // Unsure if this check is required or implied by (2) but defensive
            // programming does not hurt.
4
            if ed25519::PublicKey::try_from(id_ed25519).is_err()
4
                || ed25519::PublicKey::try_from(sign_ed25519).is_err()
            {
                return Err(VerifyFailed::ParseEmbedded(ErrorProblem::ObjectInvalidData));
4
            }
4
            Ok(Self {
4
                id_ed25519,
4
                sign_ed25519,
4
            })
12
        }
        /// Creates a new signed [`Ed25519IdentityCert`].
2
        pub fn new_signed(
2
            id_ed25519: &ed25519::Keypair,
2
            sign_ed25519: ed25519::Ed25519Identity,
2
            expiry: SystemTime,
2
        ) -> StdResult<EmbeddedCert<Self, KeyUnknownCert>, Bug> {
2
            let cert = Ed25519Cert::builder()
2
                .expiration(expiry)
2
                .signing_key(id_ed25519.public_key().into())
2
                .cert_type(CertType::IDENTITY_V_SIGNING)
2
                .cert_key(sign_ed25519.into())
2
                .encode_and_sign(id_ed25519)
2
                .map_err(into_internal!("failed to encode and sign identity cert"))?;
2
            let cert =
2
                Ed25519Cert::decode(&cert).map_err(into_internal!("decode just encoded cert"))?;
2
            Ok(EmbeddedCert::new(
2
                Self {
2
                    id_ed25519: id_ed25519.public_key().into(),
2
                    sign_ed25519,
2
                },
2
                cert,
2
            ))
2
        }
    }
    /// An Ed25519 family certificate.
    ///
    /// This is a certificate of [`CertType::FAMILY_V_IDENTITY`] where the
    /// family key signs the long-term ed25519 identity key of the given relay.
    ///
    /// It purposely does not store the long-term ed25519 identity key of the
    /// relay because the idea of this type should be equal only to other types
    /// with the same family key.
    #[derive(Debug, Clone, PartialEq, Eq)]
    #[allow(clippy::exhaustive_structs)]
    pub struct Ed25519FamilyCert {
        /// The public key of the family.
        // TODO: We probably want to add a getter for this returning the
        // family name as in:
        // <https://spec.torproject.org/dir-spec/server-descriptor-format.html#item:family-cert>
        pub family_ed25519: ed25519::Ed25519Identity,
    }
    impl EmbeddableCertObject<KeyUnknownCert> for Ed25519FamilyCert {
        const LABEL: &str = "FAMILY CERT";
    }
    impl Ed25519FamilyCert {
        /// Verifies the validity of an [`Ed25519FamilyCert`].
        ///
        /// For such a certificate to be valid, the caller must provide a
        /// known Ed25519 identity key of the relay beforehand.
        ///
        /// # Requirements
        ///
        /// 1. MUST have the `signed-with-ed25519-key` extension containing the family key.
        /// 2. MUST have a valid signature by the family key.
        /// 3. MUST be valid at `now`.
        /// 4. MUST be of of [`CertType::FAMILY_V_IDENTITY`].
        /// 5. Certified key MUST BE of [`tor_cert::CertifiedKey::Ed25519`].
        /// 6. `id_ed25519` MUST be the certified key.
        /// 7. Both keys MUST be valid mappings to a [`ed25519::PublicKey`].
12
        pub fn verify(
12
            id_ed25519: ed25519::Ed25519Identity,
12
            cert: KeyUnknownCert,
12
            post_tolerance: Duration,
12
            now: SystemTime,
12
        ) -> StdResult<Self, VerifyFailed> {
12
            let cert = cert
                // 1. MUST have the `signed-with-ed25519-key` extension containing the family key.
12
                .should_have_signing_key()?
                // 2. MUST have a valid signature by the family key.
10
                .check_signature()?
                // 3. MUST be valid at `now`.
10
                .check_valid_at(&now.saturating_sub(post_tolerance))?;
            // 4. MUST be of of [`CertType::FAMILY_V_IDENTITY`].
8
            if cert.cert_type() != CertType::FAMILY_V_IDENTITY {
2
                return Err(ErrorProblem::ObjectInvalidData.into());
6
            }
            // Bug is alright because .should_have_signing_key() assured us.
6
            let family_ed25519 = *cert.signing_key().ok_or(VerifyFailed::Bug)?;
            // 5. Certified key MUST BE of [`tor_cert::CertifiedKey::Ed25519`].
6
            let certified_key = *cert
6
                .subject_key()
6
                .as_ed25519()
6
                .ok_or(VerifyFailed::ParseEmbedded(ErrorProblem::ObjectInvalidData))?;
            // 6. `id_ed25519` MUST be the certified key.
4
            if certified_key != id_ed25519 {
                return Err(VerifyFailed::VerifyFailed);
4
            }
            // 7. Both keys MUST be valid mappings to a [`ed25519::PublicKey`].
4
            if ed25519::PublicKey::try_from(family_ed25519).is_err()
4
                || ed25519::PublicKey::try_from(id_ed25519).is_err()
            {
                return Err(VerifyFailed::ParseEmbedded(ErrorProblem::ObjectInvalidData));
4
            }
4
            Ok(Self { family_ed25519 })
12
        }
        /// Creates a new signed [`Ed25519FamilyCert`].
2
        pub fn new_signed(
2
            family_ed25519: &ed25519::Keypair,
2
            id_ed25519: ed25519::Ed25519Identity,
2
            expiry: SystemTime,
2
        ) -> StdResult<EmbeddedCert<Self, KeyUnknownCert>, Bug> {
2
            let cert = Ed25519Cert::builder()
2
                .expiration(expiry)
2
                .signing_key(family_ed25519.public_key().into())
2
                .cert_type(CertType::FAMILY_V_IDENTITY)
2
                .cert_key(id_ed25519.into())
2
                .encode_and_sign(family_ed25519)
2
                .map_err(into_internal!("failed to encode and sign family cert"))?;
2
            let cert =
2
                Ed25519Cert::decode(&cert).map_err(into_internal!("decode just encoded cert"))?;
2
            Ok(EmbeddedCert::new(
2
                Self {
2
                    family_ed25519: family_ed25519.public_key().into(),
2
                },
2
                cert,
2
            ))
2
        }
    }
    /// Verified reverse cert by K_ntor on KP_relayid_ed
    ///
    /// This certificate is signed by KS_ntor
    /// (the circuit extension key) and certifies
    /// KP_relayid_ed25519 ed25519 identity key of the relay.
    ///
    /// The type itself is zero-sized because it provides no new useful
    /// information that cannot be found elsewhere within the router descriptor.
    /// It is intended for use within
    /// [`EmbeddedCert`]`<Ed25519NtorCrossCert, KeyUnknownCert>`
    ///
    /// # Note on key conversion
    ///
    /// Keep in mind however that the ntor onion key is only provided as an
    /// X25519 key and *not* an Ed25519 key, meaning that interfacing
    /// applications have to convert it using a function such as
    /// [`tor_llcrypto::pk::keymanip::convert_curve25519_to_ed25519_public()`].
    /// This also requires obtaining the sign bit which is usually given as an
    /// argument in the `ntor-onion-key-crosscert` item.  However, this is
    /// outside of the scope of this struct and the code will assume that
    /// callers have already converted the X25519 public key to an Ed25519
    /// public key as outlined in the specifications.
    ///
    /// # See Also
    ///
    /// * <https://spec.torproject.org/dir-spec/server-descriptor-format.html#item:ntor-onion-key-crosscert>
    /// * <https://spec.torproject.org/dir-spec/converting-to-ed25519.html>
    #[derive(Debug, Clone, Copy, PartialEq, Eq)]
    #[non_exhaustive]
    pub struct Ed25519NtorCrossCert {
        /// Explicit field, to avoid constructing this accidentally without
        /// doing all the verification.
        _promise_we_verified: (),
    }
    impl EmbeddableCertObject<KeyUnknownCert> for Ed25519NtorCrossCert {
        const LABEL: &str = "ED25519 CERT";
    }
    impl Ed25519NtorCrossCert {
        /// Verifies the validity of an [`Ed25519NtorCrossCert`].
        ///
        /// For such a certificate to be valid, the caller must provide a known
        /// Ed25519 identity key and Ed25519 ntor onion key of the relay
        /// beforehand.
        ///
        /// # Requirements
        ///
        /// 1. MUST be of [`CertType::NTOR_CC_IDENTITY`].
        /// 2. Certified key MUST be of [`CertifiedKey::Ed25519`].
        /// 3. Certified key MUST be equal to `id_ed25519`.
        /// 4. MUST have a valid signature.
        /// 5. MUST be valid at `now`.
14
        pub fn verify(
14
            ntor_ed25519: ed25519::Ed25519Identity,
14
            id_ed25519: ed25519::Ed25519Identity,
14
            cert: KeyUnknownCert,
14
            post_tolerance: Duration,
14
            now: SystemTime,
14
        ) -> StdResult<Self, VerifyFailed> {
            Ok(
                // .verify_inner() ensures 1-3.
14
                Self::verify_inner(ntor_ed25519, id_ed25519, cert)?
                    .0
                    // 4. MUST have a valid signature.
10
                    .check_signature()?
10
                    .extend_tolerance(post_tolerance)
                    // 5. MUST be valid at `now`.
10
                    .check_valid_at(&now)?,
            )
14
        }
        /// Creates a new signed [`Ed25519NtorCrossCert`].
2
        pub fn new_signed(
2
            ntor_ed25519: &ed25519::Keypair,
2
            id_ed25519: ed25519::Ed25519Identity,
2
            expiry: SystemTime,
2
        ) -> StdResult<EmbeddedCert<Self, KeyUnknownCert>, Bug> {
2
            let cert = Ed25519Cert::builder()
2
                .expiration(expiry)
2
                .cert_type(CertType::NTOR_CC_IDENTITY)
2
                .cert_key(id_ed25519.into())
2
                .encode_and_sign(ntor_ed25519)
2
                .map_err(into_internal!("failed to encode and sign ntor cert"))?;
2
            let cert =
2
                Ed25519Cert::decode(&cert).map_err(into_internal!("decode just encoded cert"))?;
2
            Ok(EmbeddedCert::new(
2
                Self {
2
                    _promise_we_verified: (),
2
                },
2
                cert,
2
            ))
2
        }
        /// Verifies the validity of a [`KeyUnknownCert`] believed to be a
        /// [`CertType::NTOR_CC_IDENTITY`].
        ///
        /// This function serves as glue between the legacy parser and
        /// [`Self::verify()`].
        ///
        /// # Requirements
        ///
        /// 1. MUST be of [`CertType::NTOR_CC_IDENTITY`].
        /// 2. Certified key MUST be of [`CertifiedKey::Ed25519`].
        /// 3. Certified key MUST be equal to `id_ed25519`.
        ///
        /// # Return Type
        ///
        /// Actual signature and time validation is done by the caller, hence
        /// why it returns a gated type as the first element of the tuple.
        /// The other elements constitute the inner signature plus the
        /// SystemTime denoting the expiry.  This is required for integration
        /// with legacy parser in order to enable pushing it to the verification
        /// batch, as the [`tor_checkable`] primitives do not provide access
        /// to the inner signatures/expiries and also do not support operations
        /// like cloning due to being dyn.
2296
        pub(crate) fn verify_inner(
2296
            ntor_ed25519: ed25519::Ed25519Identity,
2296
            id_ed25519: ed25519::Ed25519Identity,
2296
            cert: KeyUnknownCert,
2296
        ) -> StdResult<
2296
            (
2296
                SignatureGated<TimerangeBound<Self>>,
2296
                ValidatableEd25519Signature,
2296
                SystemTime,
2296
            ),
2296
            VerifyFailed,
2296
        > {
            // 1. MUST be of [`CertType::NTOR_CC_IDENTITY`].
2296
            if cert.peek_cert_type() != CertType::NTOR_CC_IDENTITY {
2
                return Err(ErrorProblem::ObjectInvalidData.into());
2294
            }
            // 2. Certified key MUST be of [`CertifiedKey::Ed25519`].
            // 3. Certified key MUST be equal to `id_ed25519`.
2294
            if cert.peek_subject_key() != &CertifiedKey::Ed25519(id_ed25519) {
2
                return Err(VerifyFailed::VerifyFailed);
2292
            }
            // Fish out the signature from the certificate and verify it later.
            //
            // It may fail if ntor_ed25519 is not a valid mapping to a public
            // key.  This is okay.  The .should_be_signed_with() call is
            // tor_cert boilerplate and only required to obtain an
            // UncheckedCert, as ntor cross-certificates do not contain the
            // signed-with extension.
2292
            let (cert, sig) = cert
2292
                .should_be_signed_with(&ntor_ed25519)?
2292
                .dangerously_split()?;
            // Fish out the expiration date from the certificate.
            //
            // TimerangeBound also requires a lower-bound, for which we will use
            // SystemTime::UNIX_EPOCH, because this is the minimum possible
            // value allowed in the expiration date of Tor certificates.
            // Besides, Tor certificates do not contain a valid-after anyways,
            // meaning we cannot really put something more meaningful here.
            // It differs from the legacy parser in that regard, because that
            // parser uses the `published` field found in router descriptors
            // minus a tolerance.  However, we cannot make use of this field
            // here because we do not have access to the full router descriptor
            // in this function.  This should be okay though.
2292
            let cert = cert.dangerously_assume_timely();
2292
            let expiration = SystemTime::UNIX_EPOCH..cert.expiry();
2292
            Ok((
2292
                SignatureGated::new(
2292
                    TimerangeBound::new(
2292
                        Self {
2292
                            _promise_we_verified: (),
2292
                        },
2292
                        expiration.clone(),
2292
                    ),
2292
                    vec![Box::new(sig.clone())],
2292
                ),
2292
                sig,
2292
                expiration.end,
2292
            ))
2296
        }
        /// Internal function for creating an unverified instance.
        ///
        /// This is only intended for testing and legacy parser compatibility
        /// purposes.
2284
        pub(crate) fn dangerous_new_unverified() -> Self {
2284
            Self {
2284
                _promise_we_verified: (),
2284
            }
2284
        }
    }
}
/// Digest identifiers, and digests in the form `ALGORITHM=BASE64U`
///
/// As found in a vote's `m` line.
// TODO Use FixedB64 here.
mod identified_digest {
    use super::*;
    define_derive_deftly! {
        /// impl `FromStr` and `Display` for an enum with unit variants but also "unknown"
        ///
        /// Expected input: an enum whose variants are either
        ///  * unit variants, perhaps with `#[deftly(string_repr = "string")]`
        ///  * singleton tuple variant, containing `String` (or near equivalent)
        ///
        /// If `#[deftly(string_repro)]` is not specified,
        /// the default is snake case of the variant name.
        //
        // This macro may seem overkill, but open-coding these impls gives opportunities
        // for mismatches between FromStr, Display, and the variant name.
        //
        // TODO consider putting this in tor-basic-utils (maybe with a better name),
        // or possibly asking if derive_more want their FromStr to have this.
        StringReprUnitsOrUnknown for enum, expect items, beta_deftly:
        ${define STRING_REPR {
            ${vmeta(string_repr)
              as str,
              default { ${concat ${snake_case $vname}} }
            }
        }}
        impl FromStr for $ttype {
            type Err = Void;
14
            fn from_str(s: &str) -> Result<Self, Void> {
                $(
                    ${when v_is_unit}
                    if s == $STRING_REPR {
                        return Ok($vtype)
                    }
                )
                $(
                    ${when not(v_is_unit)} // anything else had better be Unknown
                    // not using `return ..;` makes this a syntax error if there are several.
                    Ok($vtype { 0: s.into() })
                )
            }
        }
        impl AsRef<str> for $ttype {
            fn as_ref(&self) -> &str {
                match self {
                    $(
                        ${when v_is_unit}
                        $vtype => $STRING_REPR,
                    )
                    $(
                        ${when not(v_is_unit)}
                        $vpat => f_0,
                    )
                }
            }
        }
        impl Display for $ttype {
            fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
                let s: &str = self.as_ref();
                Display::fmt(s, f)
            }
        }
    }
    /// The name of a digest algorithm.
    ///
    /// Can represent an unrecognised algorithm, so it's parsed and reproduced.
    #[derive(Debug, Clone, Eq, PartialEq, Hash, Deftly)]
    #[derive_deftly(StringReprUnitsOrUnknown)]
    #[non_exhaustive]
    pub enum DigestName {
        /// SHA-256
        Sha256,
        /// Unknown
        Unknown(String),
    }
    /// A single digest made with a nominated digest algorithm, `ALGORITHM=DIGEST`
    #[derive(Debug, Clone, Eq, PartialEq, Ord, PartialOrd, Hash, derive_more::Display)]
    #[display("{alg}={value}")]
    #[non_exhaustive]
    pub struct IdentifiedDigest {
        /// The algorithm name.
        alg: DigestName,
        /// The digest value.
        ///
        /// Invariant: length is correct for `alg`, assuming `alg` is known.
        value: B64,
    }
    impl NormalItemArgument for DigestName {}
    impl NormalItemArgument for IdentifiedDigest {}
    /// Invalid syntax parsing an `IdentifiedDigest`
    #[derive(Debug, Clone, Eq, PartialEq, Ord, PartialOrd, Hash, thiserror::Error)]
    #[error("invalid syntax, expected ALGORITHM=DIGEST: {0}")]
    pub struct IdentifiedDigestParseError(String);
    impl Ord for DigestName {
        fn cmp(&self, other: &Self) -> Ordering {
            self.as_ref().cmp(other.as_ref())
        }
    }
    impl PartialOrd for DigestName {
        fn partial_cmp(&self, other: &Self) -> Option<Ordering> {
            Some(self.cmp(other))
        }
    }
    impl FromStr for IdentifiedDigest {
        type Err = IdentifiedDigestParseError;
14
        fn from_str(s: &str) -> Result<Self, Self::Err> {
14
            (|| {
14
                let (alg, value) = s.split_once('=').ok_or("missing equals sign")?;
14
                let alg = alg.parse().void_unwrap();
14
                let value = value
14
                    .parse::<B64>()
14
                    .map_err(|e| format!("bad value: {}", e.report()))?;
14
                if let Some(exp_len) = (|| {
                    Some({
                        use DigestName::*;
14
                        match alg {
14
                            Sha256 => 32,
                            Unknown(_) => None?,
                        }
                    })
                })() {
14
                    let val_len = value.as_bytes().len();
14
                    if val_len != exp_len {
                        return Err(format!("got {val_len} bytes, expected {exp_len}"));
14
                    }
                }
14
                Ok(IdentifiedDigest { alg, value })
            })()
14
            .map_err(IdentifiedDigestParseError)
14
        }
    }
}
/// Types for decoding RSA fingerprints
mod fingerprint {
    use super::*;
    use crate::parse2::{ArgumentError, ArgumentStream, ItemArgumentParseable};
    use crate::{Error, NetdocErrorKind as EK, Pos, Result};
    use base64ct::{Base64Unpadded, Encoding as _};
    use itertools::Itertools;
    use tor_llcrypto::pk::rsa::RsaIdentity;
    /// A hex-encoded RSA key identity (fingerprint) with spaces in it.
    ///
    /// <https://spec.torproject.org/dir-spec/server-descriptor-format.html?highlight=fingerprint#item:fingerprint>
    ///
    /// Netdoc parsing adapter for [`RsaIdentity`]
    #[derive(Debug, Clone, Copy, Eq, PartialEq, Ord, PartialOrd, Hash, Deftly)]
    #[derive_deftly(Transparent)]
    #[allow(clippy::exhaustive_structs)]
    pub struct SpFingerprint(pub RsaIdentity);
    /// A hex-encoded fingerprint with no spaces.
    ///
    /// Netdoc parsing adapter for [`RsaIdentity`]
    #[derive(Debug, Clone, Copy, Eq, PartialEq, Ord, PartialOrd, Hash, Deftly)]
    #[derive_deftly(Transparent)]
    #[allow(clippy::exhaustive_structs)]
    pub struct Fingerprint(pub RsaIdentity);
    /// A base64-encoded fingerprint (unpadded)
    ///
    /// Netdoc parsing adapter for [`RsaIdentity`]
    #[derive(Debug, Clone, Copy, Eq, PartialEq, Ord, PartialOrd, Hash, Deftly)]
    #[derive_deftly(Transparent)]
    #[allow(clippy::exhaustive_structs)]
    pub struct Base64Fingerprint(pub RsaIdentity);
    /// A "long identity" in the format used for Family members.
    ///
    /// Netdoc parsing adapter for [`RsaIdentity`]
    #[derive(Debug, Clone, Copy, Eq, PartialEq, Ord, PartialOrd, Hash, Deftly)]
    #[derive_deftly(Transparent)]
    #[allow(clippy::exhaustive_structs)]
    pub(crate) struct LongIdent(pub RsaIdentity);
    /// Helper: parse an identity from a hexadecimal string
828786
    fn parse_hex_ident(s: &str) -> Result<RsaIdentity> {
828839
        RsaIdentity::from_hex(s).ok_or_else(|| {
2186
            EK::BadArgument
2186
                .at_pos(Pos::at(s))
2186
                .with_msg("wrong length on fingerprint")
2186
        })
828786
    }
    impl FromStr for SpFingerprint {
        type Err = Error;
2290
        fn from_str(s: &str) -> Result<SpFingerprint> {
2292
            let ident = parse_hex_ident(&s.replace(' ', "")).map_err(|e| e.at_pos(Pos::at(s)))?;
2286
            Ok(SpFingerprint(ident))
2290
        }
    }
    impl ItemArgumentParseable for SpFingerprint {
10
        fn from_args<'s>(
10
            args: &mut ArgumentStream<'s>,
10
        ) -> std::result::Result<Self, ArgumentError> {
            // Take the first 10 arguments because an SpFingerprint consists of
            // 10 x 4 = 40 characters.
10
            let fp = args.take(10).collect::<Vec<_>>();
            // Less than 10 means missing arguments.
10
            if fp.len() < 10 {
2
                return Err(ArgumentError::Missing);
8
            }
            // More than 10 should be impossible due to .take(10).
8
            debug_assert_eq!(fp.len(), 10);
            // All arguments must be 4 characters long.
68
            if fp.iter().any(|arg| arg.len() != 4) {
2
                return Err(ArgumentError::Invalid);
6
            }
            // Convert it to a string without spaces, RsaIdentity::from_hex will
            // verify the rest.
            Ok(Self(
6
                RsaIdentity::from_hex(fp.join("").as_str()).ok_or(ArgumentError::Invalid)?,
            ))
10
        }
    }
    impl encode::ItemArgument for SpFingerprint {
4
        fn write_arg_onto(&self, out: &mut ItemEncoder<'_>) -> StdResult<(), Bug> {
4
            let res = self
4
                .0
4
                .to_bytes()
4
                .chunks(2)
42
                .map(|b| format!("{:02X}{:02X}", b[0], b[1]))
4
                .join(" ");
4
            debug_assert_eq!(res.len(), 4 * 10 + 9);
4
            out.args_raw_string(&res);
4
            Ok(())
4
        }
    }
    impl FromStr for Base64Fingerprint {
        type Err = Error;
2592
        fn from_str(s: &str) -> Result<Base64Fingerprint> {
2592
            let b = s.parse::<super::B64>()?;
2592
            let ident = RsaIdentity::from_bytes(b.as_bytes()).ok_or_else(|| {
                EK::BadArgument
                    .at_pos(Pos::at(s))
                    .with_msg("Wrong identity length")
            })?;
2592
            Ok(Base64Fingerprint(ident))
2592
        }
    }
    impl Display for Base64Fingerprint {
30
        fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
30
            Display::fmt(&Base64Unpadded::encode_string(self.as_bytes()), f)
30
        }
    }
    impl FromStr for Fingerprint {
        type Err = Error;
10522
        fn from_str(s: &str) -> Result<Fingerprint> {
10527
            let ident = parse_hex_ident(s).map_err(|e| e.at_pos(Pos::at(s)))?;
10512
            Ok(Fingerprint(ident))
10522
        }
    }
    impl Display for Fingerprint {
56
        fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
56
            Display::fmt(&hex::encode_upper(self.as_bytes()), f)
56
        }
    }
    impl FromStr for LongIdent {
        type Err = Error;
815974
        fn from_str(mut s: &str) -> Result<LongIdent> {
815974
            s = s.strip_prefix('$').unwrap_or(s);
            // Strip at '=' or '~' if found.
815974
            s = s.split_once(['=', '~']).map(|(a, _)| a).unwrap_or(s);
815974
            let ident = parse_hex_ident(s)?;
813802
            Ok(LongIdent(ident))
815974
        }
    }
    impl Display for LongIdent {
        fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
            write!(f, "${}", self.0.as_hex_upper())
        }
    }
    impl crate::NormalItemArgument for Fingerprint {}
    impl crate::NormalItemArgument for Base64Fingerprint {}
    impl crate::NormalItemArgument for LongIdent {}
}
/// A type for relay nicknames
mod nickname {
    use super::*;
    use tinystr::TinyAsciiStr;
    /// This is a strange limit, but it comes from Tor.
    const MAX_NICKNAME_LEN: usize = 19;
    /// The nickname for a Tor relay.
    ///
    /// These nicknames are legacy mechanism that's occasionally useful in
    /// debugging. They should *never* be used to uniquely identify relays;
    /// nothing prevents two relays from having the same nickname.
    ///
    /// Nicknames are required to be ASCII, alphanumeric, and between 1 and 19
    /// characters inclusive.
    #[derive(Clone, Debug, PartialEq, Eq)]
    pub struct Nickname(tinystr::TinyAsciiStr<MAX_NICKNAME_LEN>);
    /// Invalid nickname
    #[derive(Clone, Debug, thiserror::Error)]
    #[error("invalid nickname")]
    #[non_exhaustive]
    pub struct InvalidNickname {}
    impl Nickname {
        /// Return a view of this nickname as a string slice.
52
        pub(crate) fn as_str(&self) -> &str {
52
            self.0.as_str()
52
        }
    }
    impl Display for Nickname {
46
        fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
46
            self.as_str().fmt(f)
46
        }
    }
    impl FromStr for Nickname {
        type Err = InvalidNickname;
469074
        fn from_str(s: &str) -> Result<Self, InvalidNickname> {
469076
            let tiny = TinyAsciiStr::from_str(s).map_err(|_| InvalidNickname {})?;
469070
            if tiny.is_ascii_alphanumeric() && !tiny.is_empty() {
469066
                Ok(Nickname(tiny))
            } else {
4
                Err(InvalidNickname {})
            }
469074
        }
    }
    impl crate::NormalItemArgument for Nickname {}
}
/// Hostnames etc.
//
// TODO maybe move all this to tor-basic-utils
mod hostname {
    use super::*;
    use std::net::IpAddr;
    /// Internet hostname
    ///
    /// Valid according to Internet RFC1123,
    /// with the additional restriction that there must be at least one letter.
    /// (That means that anything accepted as a `Hostname`
    /// won't be accepted as an address even by very relaxed IPv4 address parsers.
    /// We presume that no TLD will ever exist that is entirely decimal digits.)
    ///
    /// Preserves case.
    ///
    /// Reserved hostname such as `example.come`, `tor.invalid` and `localhost`
    /// are accepted.
    ///
    /// # Comparisons; `PartialEq`, `Eq`
    ///
    /// The `PartialEq` and `Eq` implementations are case sensitive,
    /// even though internet hostnames are not case-sensitive.
    ///
    /// Comparing hostnames for identical apparent meaning is complicated.
    /// If you need to do that, you (may) need to engage with punycode (IDN),
    /// as well as arranging for a case-insensitive comparison.
    ///
    /// And of course, hostnames reference to the DNS.
    /// A single host may have multiple names and it may change its address.
    #[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd)] //
    #[derive(derive_more::Into, derive_more::Deref, derive_more::AsRef, derive_more::Display)]
    pub struct Hostname(String);
    /// Hostname, or IP address (v4 or v6)
    ///
    /// Preserves hostname case.  See [`Hostname`].
    ///
    /// Reserved hostnames and addresses (eg `0.0.0.0` or `tor.invalid`) are accepted.
    ///
    /// IPv6 addresses are represented *without* surrounding `[ ]`.
    ///
    /// Therefore, you cannot make this into a host-and-port by appending `:port`.
    /// To process name-and-port is complex.  `SRV` (or `MX`) records might be involved.
    //
    // This type is called `InternetHost` to emphasise that it is primarily for
    // hosts on the public internet and, unlike arti-client's `Host`,
    // has special handling of `.onion` addresses.
    #[derive(Clone, Debug, Hash, Eq, PartialEq, Ord, PartialOrd)] //
    #[derive(derive_more::Display)]
    #[allow(clippy::exhaustive_enums)]
    // TODO derive .as_hostname(), .as_ip_addr(), From<Hostname>, From<IpAddr>
    pub enum InternetHost {
        /// Hostname
        #[display("{_0}")]
        Name(Hostname),
        /// IP address (v4 or v6)
        #[display("{_0}")]
        IpAddr(IpAddr),
    }
    /// Invalid hostname
    #[derive(Clone, Debug, thiserror::Error)]
    #[error("invalid hostname")]
    #[non_exhaustive]
    pub struct InvalidHostname {}
    /// Invalid Internet hostname/address
    #[derive(Clone, Debug, thiserror::Error)]
    #[error("invalid: not a valid hostname, nor a valid IPv4 or IPv6 address")]
    #[non_exhaustive]
    pub struct InvalidInternetHost {}
    impl Hostname {
        /// Obtain this hostname as a `str`
8
        pub fn as_str(&self) -> &str {
8
            &self.0
8
        }
    }
    impl AsRef<str> for Hostname {
        fn as_ref(&self) -> &str {
            self.as_str()
        }
    }
    impl TryFrom<String> for Hostname {
        type Error = InvalidHostname;
496
        fn try_from(s: String) -> Result<Self, InvalidHostname> {
496
            if hostname_validator::is_valid(&s) &&
                // Reject hostnames that consist only of decimal digits and full stops.
                // Some of those are accepted by some old IPv4 address parsers.
                // If any fool makes a TLD that is only digits, they deserve everything they get.
560
                !s.chars().all(|c| c.is_ascii_digit() || c == '.')
            {
452
                Ok(Hostname(s))
            } else {
44
                Err(InvalidHostname {})
            }
496
        }
    }
    impl FromStr for Hostname {
        type Err = InvalidHostname;
496
        fn from_str(s: &str) -> Result<Self, InvalidHostname> {
496
            s.to_owned().try_into()
496
        }
    }
    impl FromStr for InternetHost {
        type Err = InvalidInternetHost;
3182
        fn from_str(s: &str) -> Result<Self, InvalidInternetHost> {
3182
            if let Ok(y) = s.parse() {
2720
                Ok(InternetHost::IpAddr(y))
462
            } else if let Ok(y) = s.parse() {
444
                Ok(InternetHost::Name(y))
            } else {
                // For simplicity, we  discard the errors from parsing the options
                // rather than trying to reproduce them.  Why something isn't a valid
                // address or hostname ought to be fairly obvious.
18
                Err(InvalidInternetHost {})
            }
3182
        }
    }
    impl NormalItemArgument for Hostname {}
    impl NormalItemArgument for InternetHost {}
}
/// Contact information of the relay operator.
mod contact_info {
    use super::*;
    /// `contact` item: contact information (eg of a relay dirauth operator)
    ///
    /// <https://spec.torproject.org/dir-spec/server-descriptor-format.html#item:contact>
    ///
    /// Also used for authority entries in netstatus documents.
    #[derive(Clone, Debug, PartialEq, Eq, Deftly)] //
    #[derive(derive_more::Into, derive_more::AsRef, derive_more::Deref, derive_more::Display)]
    #[derive_deftly(ItemValueEncodable)]
    #[non_exhaustive]
    pub struct ContactInfo(#[deftly(netdoc(rest))] String);
    /// Contact information (`contact` item value) has invalid syntax
    #[derive(Clone, Debug, thiserror::Error)]
    #[error("contact information (`contact` item value) has invalid syntax")]
    #[non_exhaustive]
    pub struct InvalidContactInfo {}
    impl FromStr for ContactInfo {
        type Err = InvalidContactInfo;
3162
        fn from_str(s: &str) -> Result<Self, InvalidContactInfo> {
            // TODO torspec#396 we should probably impose more restrictions
            // For now we forbid `\n` and initial whitespace, which is enough to ensure
            // that all values will roundtrip unchanged through netdoc encoding and parsing.
3162
            if s.contains('\n') || s.starts_with(char::is_whitespace) {
4
                Err(InvalidContactInfo {})
            } else {
3158
                Ok(ContactInfo(s.to_owned()))
            }
3162
        }
    }
    impl ItemValueParseable for ContactInfo {
1968
        fn from_unparsed(mut item: UnparsedItem<'_>) -> Result<Self, parse2::ErrorProblem> {
1968
            item.check_no_object()?;
1968
            item.args_mut()
1968
                .into_remaining()
1968
                .parse()
1968
                .map_err(|_e| item.args().handle_error("info", ArgumentError::Invalid))
1968
        }
    }
}
/// Types for boolean-like types.
mod boolean {
    use derive_deftly::Deftly;
    use std::{
        fmt::Display,
        ops::{Deref, DerefMut},
        str::FromStr,
    };
    use crate::{Error, NetdocErrorKind as EK, NormalItemArgument, Pos};
    /// A boolean that is represented by a `0` (false) or `1` (true).
    #[derive(Clone, Copy, Debug, Default, PartialEq, Eq, PartialOrd, Ord, Deftly)]
    #[derive_deftly(Transparent)]
    #[allow(clippy::exhaustive_structs)]
    pub struct NumericBoolean(pub bool);
    impl FromStr for NumericBoolean {
        type Err = Error;
46
        fn from_str(s: &str) -> Result<Self, Self::Err> {
46
            match s {
46
                "0" => Ok(Self(false)),
34
                "1" => Ok(Self(true)),
2
                _ => Err(EK::BadArgument
2
                    .at_pos(Pos::at(s))
2
                    .with_msg("Invalid numeric boolean")),
            }
46
        }
    }
    impl Display for NumericBoolean {
4
        fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
4
            write!(f, "{}", u8::from(self.0))
4
        }
    }
    impl NormalItemArgument for NumericBoolean {}
}
/// Types for router descriptors.
pub mod routerdesc {
    use crate::types::EmbeddedCert;
    use super::*;
    use parse2::ErrorProblem as EP;
    use tor_cert::KeyUnknownCert;
    use tor_llcrypto::pk::ed25519;
    /// Version argument found in an `overload-general` item.
    ///
    /// <https://spec.torproject.org/dir-spec/server-descriptor-format.html#item:overload-general>
    #[derive(Debug, Clone, Copy, Hash, Eq, PartialEq, strum::EnumString, strum::Display)]
    #[non_exhaustive]
    pub enum OverloadGeneralVersion {
        /// Version 1, currently the only supported and specified one.
        #[strum(serialize = "1")]
        V1,
    }
    impl NormalItemArgument for OverloadGeneralVersion {}
    /// The overload general type found in router descriptors.
    ///
    /// <https://spec.torproject.org/dir-spec/server-descriptor-format.html#item:overload-general>
    #[derive(Debug, Clone, Copy, PartialEq, Eq, Deftly)]
    #[derive_deftly(ItemValueParseable, ItemValueEncodable)]
    #[non_exhaustive]
    pub struct OverloadGeneral {
        /// The version of the item.
        pub version: OverloadGeneralVersion,
        /// The timestamp since when the relay is overloaded.
        pub since: Iso8601TimeSp,
    }
    /// Introduction line of a router descriptor.
    ///
    /// <https://spec.torproject.org/dir-spec/server-descriptor-format.html#item:router>
    #[derive(Clone, Debug, PartialEq, Eq, Deftly)]
    #[derive_deftly(ItemValueParseable, ItemValueEncodable)]
    #[non_exhaustive]
    pub struct RouterDescIntroItem {
        /// A valid router [`Nickname`].
        pub nickname: Nickname,
        /// An IPv4 address in dotted-squad format.
        pub address: std::net::Ipv4Addr,
        /// The TCP port of the onion router.
        pub orport: u16,
        /// Legacy.
        pub socksport: u16,
        /// Legacy.
        pub dirport: u16,
    }
    /// Digest identifying the extra-info document.
    ///
    /// <https://spec.torproject.org/dir-spec/server-descriptor-format.html#item:extra-info-digest>
    #[derive(Clone, Debug, PartialEq, Eq, Deftly)]
    #[derive_deftly(ItemValueParseable, ItemValueEncodable)]
    #[non_exhaustive]
    pub struct ExtraInfoDigests {
        /// Mandatory SHA-1 of the signed data in base 16.
        pub sha1: FixedB16U<20>,
        /// Optional SHA-256 of the entire extra-info in base 64.
        pub sha2: Option<FixedB64<32>>,
    }
    /// Accumulator for router descriptor hash signatures.
    #[derive(Debug, Clone, Default, Deftly)]
    #[derive_deftly(AsMutSelf)]
    #[allow(clippy::exhaustive_structs)]
    pub struct RouterHashAccu {
        /// Potentially the SHA-1 for the signature.
        pub sha1: Option<[u8; 20]>,
        /// Potentially the SHA-256 for the signature.
        pub sha256: Option<[u8; 32]>,
    }
    /// SHA-256 router descriptor signature including magic and the keyword.
    #[derive(Debug, Clone, PartialEq, Eq, Deftly)]
    #[derive_deftly(ItemValueEncodable)]
    #[allow(clippy::exhaustive_structs)]
    // TODO SPEC is RouterSigEd25519 not a standard-ish kind of signature?
    // TODO DIRAUTH is RouterSigEd25519 not a standard-ish kind of signature?
    pub struct RouterSigEd25519(pub ed25519::Signature);
    impl RouterSigEd25519 {
        /// The magic prefix for hashing this type of signature.
        const HASH_PREFIX_MAGIC: &str = "Tor router descriptor signature v1";
        /// Calculate the hash for signature
        ///
        /// `signature_item_kw_spc` is the keyword *with a trailing space*.
        /// It's `&[&str]` for the convenience of the two call sites.
4
        fn hash(document_sofar: &str, signature_item_kw_spc: &[&str]) -> [u8; 32] {
4
            debug_assert!(
4
                signature_item_kw_spc
4
                    .last()
4
                    .expect("signature_item_kw_spc")
4
                    .ends_with(" ")
            );
4
            let mut h = tor_llcrypto::d::Sha256::new();
4
            h.update(Self::HASH_PREFIX_MAGIC);
4
            h.update(document_sofar);
6
            for b in signature_item_kw_spc {
6
                h.update(b);
6
            }
4
            h.finalize().into()
4
        }
        /// Make a signature during document encoding
        ///
        /// `item_keyword` is the keyword for the signature item.
        ///
        /// # Example
        ///
        /// ```
        /// use derive_deftly::Deftly;
        /// use tor_error::Bug;
        /// use tor_llcrypto::pk::ed25519;
        /// use tor_netdoc::derive_deftly_template_NetdocEncodable;
        /// use tor_netdoc::encode::{NetdocEncodable, NetdocEncoder};
        /// use tor_netdoc::types::routerdesc::RouterSigEd25519;
        ///
        /// #[derive(Deftly, Default)]
        /// #[derive_deftly(NetdocEncodable)]
        /// pub struct Document {
        ///     pub document_intro_keyword: (),
        /// }
        /// #[derive(Deftly)]
        /// #[derive_deftly(NetdocEncodable)]
        /// pub struct DocumentSignatures {
        ///     pub document_signature: RouterSigEd25519,
        /// }
        /// impl Document {
        ///     pub fn encode_sign(&self, k: &ed25519::Keypair) -> Result<String, Bug> {
        ///         let mut encoder = NetdocEncoder::new();
        ///         self.encode_unsigned(&mut encoder)?;
        ///         let document_signature =
        ///             RouterSigEd25519::new_sign_netdoc(k, &encoder, "document-signature")?;
        ///         let sigs = DocumentSignatures { document_signature };
        ///         sigs.encode_unsigned(&mut encoder)?;
        ///         let encoded = encoder.finish()?;
        ///         Ok(encoded)
        ///     }
        /// }
        ///
        /// # fn main() -> Result<(), anyhow::Error> {
        /// let k = ed25519::Keypair::generate(&mut tor_basic_utils::test_rng::testing_rng());
        /// let doc = Document::default();
        /// let encoded = doc.encode_sign(&k)?;
        /// assert!(encoded.starts_with(concat!(
        ///     "document-intro-keyword\n",
        ///     "document-signature ",
        /// )));
        /// # Ok(())
        /// # }
        /// ```
2
        pub fn new_sign_netdoc(
2
            private_key: &ed25519::Keypair,
2
            encoder: &NetdocEncoder,
2
            item_keyword: &str,
2
        ) -> StdResult<Self, Bug> {
2
            let signature = private_key
2
                .sign(&Self::hash(encoder.text_sofar()?, &[item_keyword, " "]))
2
                .to_bytes()
2
                .into();
2
            Ok(RouterSigEd25519(signature))
2
        }
    }
    impl SignatureItemParseable for RouterSigEd25519 {
        type HashAccu = RouterHashAccu;
2
        fn from_unparsed_and_body(
2
            mut item: UnparsedItem<'_>,
2
            hash_inputs: &SignatureHashInputs<'_>,
2
            hash: &mut Self::HashAccu,
2
        ) -> Result<Self, EP> {
            // TODO DIRMIRROR break this out into impl ItemArgumentParseable for Signature
2
            let args = item.args_mut();
2
            let sig = FixedB64::<64>::from_args(args)
2
                .map_err(|e| args.handle_error("router-sig-ed25519", e))?
                .0;
2
            let sig = ed25519::Signature::from(sig);
2
            hash.sha256 = Some(Self::hash(
2
                hash_inputs.document_sofar,
2
                &[hash_inputs.signature_item_kw_spc],
2
            ));
2
            Ok(Self(sig))
2
        }
    }
    /// SHA-1 router descriptor signature over `router-sig-ed25519`.
    // TODO DIRMIRROR Is this not the same as RsaSha1Signature ?
    #[derive(Debug, Clone, PartialEq, Eq)]
    #[allow(clippy::exhaustive_structs)]
    pub struct RouterSignature(pub Vec<u8>);
    impl SignatureItemParseable for RouterSignature {
        type HashAccu = RouterHashAccu;
        fn from_unparsed_and_body(
            mut item: UnparsedItem<'_>,
            hash_inputs: &SignatureHashInputs<'_>,
            hash: &mut Self::HashAccu,
        ) -> Result<Self, EP> {
            // There must be no additonal arguments.
            let args = item.args_mut();
            if args.next().is_some() {
                return Err(EP::UnexpectedArgument {
                    column: args.prev_arg_column(),
                });
            }
            let obj = item.object().ok_or(EP::MissingObject)?.decode_data()?;
            let mut h = tor_llcrypto::d::Sha1::new();
            h.update(hash_inputs.document_sofar);
            h.update(hash_inputs.signature_item_line);
            h.update("\n");
            hash.sha1 = Some(h.finalize().into());
            Ok(Self(obj))
        }
    }
    /// Estimated bandwidth for a router.
    ///
    /// <https://spec.torproject.org/dir-spec/server-descriptor-format.html#item:bandwidth>
    // Does not derive Ord because it only makes sense to order on a single
    // field but not all.
    #[derive(Debug, Clone, Copy, Default, PartialEq, Eq, Hash, Deftly)]
    #[derive_deftly(ItemValueParseable, ItemValueEncodable)]
    #[non_exhaustive]
    pub struct Bandwidth {
        /// The volume that the relay is willing to sustain over long periods.
        pub average: u64,
        /// The volume that the relay is willing to sustain in very short intervals.
        pub burst: u64,
        /// The estimate of the capacity this relay can handle.
        pub observed: u64,
    }
    /// Ntor onion key cross-certificate.
    ///
    /// This struct contains an [`Ed25519NtorCrossCert`] alongside the `bit`
    /// field required for converting the ntor X25519 key to an Ed25519 key.
    ///
    /// # See Also
    ///
    /// * [`Ed25519NtorCrossCert`]
    /// * <https://spec.torproject.org/dir-spec/server-descriptor-format.html#item:ntor-onion-key-crosscert>
    #[derive(Debug, Clone, Deftly)]
    #[derive_deftly(ItemValueParseable, ItemValueEncodable)]
    #[deftly(netdoc(no_extra_args))]
    #[non_exhaustive]
    pub struct NtorOnionKeyCrossCert {
        /// True if X coordinate of the ntor onion key is negative, false if
        /// positive.
        // TODO spec: This name is very unfortunate, how about we change it
        // to `is_negative`.  Also, using a boolean for storing a sign bit feels
        // wrong to me due to the zero edge case, which would not be negative,
        // but also not positive either.
        pub bit: NumericBoolean,
        /// The actual embedded ntor onion key certificate.
        #[deftly(netdoc(object))]
        pub cert: EmbeddedCert<Ed25519NtorCrossCert, KeyUnknownCert>,
    }
}
#[cfg(test)]
mod test {
    // @@ begin test lint list maintained by maint/add_warning @@
    #![allow(clippy::bool_assert_comparison)]
    #![allow(clippy::clone_on_copy)]
    #![allow(clippy::dbg_macro)]
    #![allow(clippy::mixed_attributes_style)]
    #![allow(clippy::print_stderr)]
    #![allow(clippy::print_stdout)]
    #![allow(clippy::single_char_pattern)]
    #![allow(clippy::unwrap_used)]
    #![allow(clippy::unchecked_time_subtraction)]
    #![allow(clippy::useless_vec)]
    #![allow(clippy::needless_pass_by_value)]
    #![allow(clippy::string_slice)] // See arti#2571
    //! <!-- @@ end test lint list maintained by maint/add_warning @@ -->
    use std::{
        fmt::Debug,
        time::{Duration, SystemTime},
    };
    use itertools::Itertools;
    use base64ct::Encoding;
    use tor_basic_utils::test_rng::testing_rng;
    use tor_cert::{CertType, CertifiedKey, Ed25519Cert, KeyUnknownCert};
    use tor_llcrypto::pk::ed25519::{self, Ed25519Identity, Ed25519PublicKey};
    use super::*;
    use crate::{
        Pos, Result,
        encode::NetdocEncodable,
        parse2::{ErrorProblem, ParseInput, VerifyFailed},
        types::{
            EmbeddedCert,
            routerdesc::{NtorOnionKeyCrossCert, RouterDescIntroItem},
        },
    };
    /// Decode s as a multi-line base64 string, ignoring ascii whitespace.
    fn base64_decode_ignore_ws(s: &str) -> std::result::Result<Vec<u8>, base64ct::Error> {
        let mut s = s.to_string();
        s.retain(|c| !c.is_ascii_whitespace());
        base64ct::Base64::decode_vec(s.as_str())
    }
    #[test]
    fn base64() -> Result<()> {
        // Test parsing success:
        // Unpadded:
        assert_eq!("Mi43MTgyOA".parse::<B64>()?.as_bytes(), &b"2.71828"[..]);
        assert!("Mi43MTgyOA".parse::<B64>()?.check_len(7..8).is_ok());
        assert_eq!("Mg".parse::<B64>()?.as_bytes(), &b"2"[..]);
        assert!("Mg".parse::<B64>()?.check_len(1..2).is_ok());
        assert_eq!(
            "8J+NkvCfjZLwn42S8J+NkvCfjZLwn42S"
                .parse::<B64>()?
                .as_bytes(),
            "🍒🍒🍒🍒🍒🍒".as_bytes()
        );
        assert!(
            "8J+NkvCfjZLwn42S8J+NkvCfjZLwn42S"
                .parse::<B64>()?
                .check_len(24..25)
                .is_ok()
        );
        assert!(
            "ppwthHXW8kXD0f9fE7UPYsOAAu4uj5ORwSomCMxKkz8="
                .parse::<B64>()?
                .check_len(32..33)
                .is_ok()
        );
        // Padded:
        assert_eq!("Mi43MTgyOA==".parse::<B64>()?.as_bytes(), &b"2.71828"[..]);
        assert!("Mi43MTgyOA==".parse::<B64>()?.check_len(7..8).is_ok());
        assert_eq!("Mg==".parse::<B64>()?.as_bytes(), &b"2"[..]);
        assert!("Mg==".parse::<B64>()?.check_len(1..2).is_ok());
        // Test parsing failures:
        // Invalid character.
        assert!("Mi43!!!!!!".parse::<B64>().is_err());
        // Invalid last character.
        assert!("Mi".parse::<B64>().is_err());
        assert!(
            "ppwthHXW8kXD0f9fE7UPYsOAAu4uj5ORwSomCMxaaaa"
                .parse::<B64>()
                .is_err()
        );
        // Invalid length.
        assert!("Mi43MTgyOA".parse::<B64>()?.check_len(8..).is_err());
        Ok(())
    }
    #[test]
    fn base64_lengths() -> Result<()> {
        assert_eq!("".parse::<B64>()?.as_bytes(), b"");
        assert!("=".parse::<B64>().is_err());
        assert!("==".parse::<B64>().is_err());
        assert!("B".parse::<B64>().is_err());
        assert!("B=".parse::<B64>().is_err());
        assert!("B==".parse::<B64>().is_err());
        assert!("Bg=".parse::<B64>().is_err());
        assert_eq!("Bg".parse::<B64>()?.as_bytes(), b"\x06");
        assert_eq!("Bg==".parse::<B64>()?.as_bytes(), b"\x06");
        assert_eq!("BCg".parse::<B64>()?.as_bytes(), b"\x04\x28");
        assert_eq!("BCg=".parse::<B64>()?.as_bytes(), b"\x04\x28");
        assert!("BCg==".parse::<B64>().is_err());
        assert_eq!("BCDE".parse::<B64>()?.as_bytes(), b"\x04\x20\xc4");
        assert!("BCDE=".parse::<B64>().is_err());
        assert!("BCDE==".parse::<B64>().is_err());
        Ok(())
    }
    #[test]
    fn base64_rev() {
        use base64ct::{Base64, Base64Unpadded};
        // Check that strings that we accept are precisely ones which
        // can be generated by either Base64 or Base64Unpadded
        for n in 0..=5 {
            for c_vec in std::iter::repeat_n("ACEQg/=".chars(), n).multi_cartesian_product() {
                let s: String = c_vec.into_iter().collect();
                #[allow(clippy::print_stderr)]
                let b = match s.parse::<B64>() {
                    Ok(b) => {
                        eprintln!("{:10} {:?}", &s, b.as_bytes());
                        b
                    }
                    Err(_) => {
                        eprintln!("{:10} Err", &s);
                        continue;
                    }
                };
                let b = b.as_bytes();
                let ep = Base64::encode_string(b);
                let eu = Base64Unpadded::encode_string(b);
                assert!(
                    s == ep || s == eu,
                    "{:?} decoded to {:?} giving neither {:?} nor {:?}",
                    s,
                    b,
                    ep,
                    eu
                );
            }
        }
    }
    #[test]
    fn base16() -> anyhow::Result<()> {
        let chk = |s: &str, b: &[u8]| -> anyhow::Result<()> {
            let parsed = s.parse::<B16>()?;
            assert_eq!(parsed.as_bytes(), b, "{s:?}");
            assert_eq!(parsed.to_string(), s.to_ascii_lowercase());
            let parsed = s.parse::<B16U>()?;
            assert_eq!(parsed.as_bytes(), b, "{s:?}");
            assert_eq!(parsed.to_string(), s.to_ascii_uppercase());
            Ok(())
        };
        chk("332e313432", b"3.142")?;
        chk("332E313432", b"3.142")?;
        chk("332E3134", b"3.14")?;
        assert!("332E313".parse::<B16>().is_err());
        assert!("332G3134".parse::<B16>().is_err());
        Ok(())
    }
    #[test]
    fn curve25519() -> Result<()> {
        use tor_llcrypto::pk::curve25519::PublicKey;
        let k1 = "ppwthHXW8kXD0f9fE7UPYsOAAu4uj5ORwSomCMxKkz8=";
        let k2 = hex::decode("a69c2d8475d6f245c3d1ff5f13b50f62c38002ee2e8f9391c12a2608cc4a933f")
            .unwrap();
        let k2: &[u8; 32] = &k2[..].try_into().unwrap();
        let k1: PublicKey = k1.parse::<Curve25519Public>()?.into();
        assert_eq!(k1, (*k2).into());
        assert!(
            "ppwthHXW8kXD0f9fE7UPYsOAAu4uj5ORwSomCMxKkz"
                .parse::<Curve25519Public>()
                .is_err()
        );
        assert!(
            "ppwthHXW8kXD0f9fE7UPYsOAAu4uj5ORSomCMxKkz"
                .parse::<Curve25519Public>()
                .is_err()
        );
        assert!(
            "ppwthHXW8kXD0f9fE7UPYsOAAu4uj5wSomCMxKkz"
                .parse::<Curve25519Public>()
                .is_err()
        );
        assert!(
            "ppwthHXW8kXD0f9fE7UPYsOAAu4ORwSomCMxKkz"
                .parse::<Curve25519Public>()
                .is_err()
        );
        Ok(())
    }
    #[test]
    fn ed25519() -> Result<()> {
        use tor_llcrypto::pk::ed25519::Ed25519Identity;
        let k1 = "WVIPQ8oArAqLY4XzkcpIOI6U8KsUJHBQhG8SC57qru0";
        let k2 = hex::decode("59520f43ca00ac0a8b6385f391ca48388e94f0ab14247050846f120b9eeaaeed")
            .unwrap();
        let k1: Ed25519Identity = k1.parse::<Ed25519Public>()?.into();
        assert_eq!(k1, Ed25519Identity::from_bytes(&k2).unwrap());
        assert!(
            "WVIPQ8oArAqLY4Xzk0!!!!8KsUJHBQhG8SC57qru"
                .parse::<Ed25519Public>()
                .is_err()
        );
        assert!(
            "WVIPQ8oArAqLY4XzkcpIU8KsUJHBQhG8SC57qru"
                .parse::<Ed25519Public>()
                .is_err()
        );
        assert!(
            "WVIPQ8oArAqLY4XzkcpIU8KsUJHBQhG8SC57qr"
                .parse::<Ed25519Public>()
                .is_err()
        );
        // right length, bad key:
        assert!(
            "ppwthHXW8kXD0f9fE7UPYsOAAu4uj5ORwSomCMxaaaa"
                .parse::<Curve25519Public>()
                .is_err()
        );
        Ok(())
    }
    #[test]
    fn time() -> Result<()> {
        use humantime::parse_rfc3339;
        use std::time::SystemTime;
        let t = "2020-09-29 13:36:33".parse::<Iso8601TimeSp>()?;
        let t: SystemTime = t.into();
        assert_eq!(t, parse_rfc3339("2020-09-29T13:36:33Z").unwrap());
        assert!("2020-FF-29 13:36:33".parse::<Iso8601TimeSp>().is_err());
        assert!("2020-09-29Q13:99:33".parse::<Iso8601TimeSp>().is_err());
        assert!("2020-09-29".parse::<Iso8601TimeSp>().is_err());
        assert!("too bad, waluigi time".parse::<Iso8601TimeSp>().is_err());
        assert_eq!(
            "2020-09-29 13:36:33",
            "2020-09-29 13:36:33".parse::<Iso8601TimeSp>()?.to_string()
        );
        let t = "2020-09-29T13:36:33".parse::<Iso8601TimeNoSp>()?;
        let t: SystemTime = t.into();
        assert_eq!(t, parse_rfc3339("2020-09-29T13:36:33Z").unwrap());
        assert!("2020-09-29 13:36:33".parse::<Iso8601TimeNoSp>().is_err());
        assert!("2020-09-29Q13:99:33".parse::<Iso8601TimeNoSp>().is_err());
        assert!("2020-09-29".parse::<Iso8601TimeNoSp>().is_err());
        assert!("too bad, waluigi time".parse::<Iso8601TimeNoSp>().is_err());
        assert_eq!(
            "2020-09-29T13:36:33",
            "2020-09-29T13:36:33"
                .parse::<Iso8601TimeNoSp>()?
                .to_string()
        );
        Ok(())
    }
    #[test]
    fn rsa_public_key() {
        // Taken from a chutney network.
        let key_b64 = r#"
        MIIBigKCAYEAsDkzTcKS4kAF56R2ijb9qCek53tKC1EwMdpWMk58bB28fY6kHc55
        E7n1hB+LC5neZlx88GKuZ9k8P3g0MlO5ejalcfBdIIm28Nz86JXf/L23YnEpxnG/
        IpxZEcmx/EYN+vwp72W3DGuzyntaoaut6lGJk+O/aRCLLcTm4MNznvN1ackK2H6b
        Xm2ejRwtVRLoPKODJiPGl43snCfXXWsMH3IALFOgm0szPLv2fAJzBI8VWrUN81M/
        lgwJhG6+xbr1CkrXI5fKs/TNr0B0ydC9BIZplmPrnXaeNklnw1cqUJ1oxDSgBrvx
        rpDo7paObjSPV26opa68QKGa7Gu2MZQC3RzViNCbawka/108g6hSUkoM+Om2oivr
        DvtMOs10MjsfibEBVnwEhqnlb/gj3hJkYoGRsCwAyMIaMObHcmAevMJRWAjGCc8T
        GMS9dSmg1IZst+U+V2OCcIHXT6wZ1zPsBM0pYKVLCwtewaq1306k0n+ekriEo7eI
        FS3Dd/Dx/a6jAgMBAAE=
        "#;
        let key_bytes = base64_decode_ignore_ws(key_b64).unwrap();
        let rsa = RsaPublicParse1Helper::from_vec(key_bytes, Pos::None).unwrap();
        let bits = tor_llcrypto::pk::rsa::PublicKey::from(rsa.clone()).bits();
        assert_eq!(bits, 3072);
        // tests on a valid key
        assert!(rsa.clone().check_exponent(65537).is_ok());
        assert!(rsa.clone().check_exponent(1337).is_err());
        assert!(rsa.clone().check_len_eq(3072).is_ok());
        assert!(rsa.clone().check_len(1024..=4096).is_ok());
        assert!(rsa.clone().check_len(1024..=1024).is_err());
        assert!(rsa.check_len(4096..).is_err());
        // A string of bytes that is not an RSA key.
        let failure = RsaPublicParse1Helper::from_vec(vec![1, 2, 3], Pos::None);
        assert!(failure.is_err());
    }
    #[test]
    fn ed_cert() {
        use tor_llcrypto::pk::ed25519::Ed25519Identity;
        // From a chutney network.
        let cert_b64 = r#"
        AQQABwRNAR6m3kq5h8i3wwac+Ti293opoOP8RKGP9MT0WD4Bbz7YAQAgBACGCdys
        G7AwsoYMIKenDN6In6ReiGF8jaYoGqmWKDVBdGGMDIZyNIq+VdhgtAB1EyNFHJU1
        jGM0ir9dackL+PIsHbzJH8s/P/8RfUsKIL6/ZHbn3nKMxLH/8kjtxp5ScAA=
        "#;
        let cert_bytes = base64_decode_ignore_ws(cert_b64).unwrap();
        // From the cert above.
        let right_subject_key: Ed25519Identity = "HqbeSrmHyLfDBpz5OLb3eimg4/xEoY/0xPRYPgFvPtg"
            .parse::<Ed25519Public>()
            .unwrap()
            .into();
        // From `ed25519()` test above.
        let wrong_subject_key: Ed25519Identity = "WVIPQ8oArAqLY4XzkcpIOI6U8KsUJHBQhG8SC57qru0"
            .parse::<Ed25519Public>()
            .unwrap()
            .into();
        // decode and check correct type and key
        let cert = UnvalidatedEdCert::from_vec(cert_bytes, Pos::None)
            .unwrap()
            .check_cert_type(tor_cert::CertType::IDENTITY_V_SIGNING)
            .unwrap()
            .check_subject_key_is(&right_subject_key)
            .unwrap();
        // check wrong type.
        assert!(
            cert.clone()
                .check_cert_type(tor_cert::CertType::RSA_ID_X509)
                .is_err()
        );
        // check wrong key.
        assert!(cert.check_subject_key_is(&wrong_subject_key).is_err());
        // Try an invalid object that isn't a certificate.
        let failure = UnvalidatedEdCert::from_vec(vec![1, 2, 3], Pos::None);
        assert!(failure.is_err());
    }
    #[test]
    fn fingerprint() -> Result<()> {
        use tor_llcrypto::pk::rsa::RsaIdentity;
        let fp1 = "7467 A97D 19CD 2B4F 2BC0 388A A99C 5E67 710F 847E";
        let fp2 = "7467A97D19CD2B4F2BC0388AA99C5E67710F847E";
        let fp3 = "$7467A97D19CD2B4F2BC0388AA99C5E67710F847E";
        let fp4 = "$7467A97D19CD2B4F2BC0388AA99C5E67710F847E=fred";
        let k = hex::decode(fp2).unwrap();
        let k = RsaIdentity::from_bytes(&k[..]).unwrap();
        assert_eq!(RsaIdentity::from(fp1.parse::<SpFingerprint>()?), k);
        assert_eq!(RsaIdentity::from(fp2.parse::<SpFingerprint>()?), k);
        assert!(fp3.parse::<SpFingerprint>().is_err());
        assert!(fp4.parse::<SpFingerprint>().is_err());
        assert!(fp1.parse::<Fingerprint>().is_err());
        assert_eq!(RsaIdentity::from(fp2.parse::<Fingerprint>()?), k);
        assert!(fp3.parse::<Fingerprint>().is_err());
        assert!(fp4.parse::<Fingerprint>().is_err());
        assert_eq!(Fingerprint(k).to_string(), fp2);
        assert!(fp1.parse::<LongIdent>().is_err());
        assert_eq!(RsaIdentity::from(fp2.parse::<LongIdent>()?), k);
        assert_eq!(RsaIdentity::from(fp3.parse::<LongIdent>()?), k);
        assert_eq!(RsaIdentity::from(fp4.parse::<LongIdent>()?), k);
        assert!("xxxx".parse::<Fingerprint>().is_err());
        assert!("ffffffffff".parse::<Fingerprint>().is_err());
        let fp_b64 = "dGepfRnNK08rwDiKqZxeZ3EPhH4";
        assert_eq!(RsaIdentity::from(fp_b64.parse::<Base64Fingerprint>()?), k);
        assert_eq!(Base64Fingerprint(k).to_string(), fp_b64);
        Ok(())
    }
    #[test]
    fn nickname() -> anyhow::Result<()> {
        let n: Nickname = "Foo".parse()?;
        assert_eq!(n.as_str(), "Foo");
        assert_eq!(n.to_string(), "Foo");
        let word = "Untr1gonometr1cally";
        assert_eq!(word.len(), 19);
        let long: Nickname = word.parse()?;
        assert_eq!(long.as_str(), word);
        let too_long = "abcdefghijklmnopqrstuvwxyz";
        let not_ascii = "Eyjafjallajökull";
        let too_short = "";
        let other_invalid = "contains space";
        assert!(not_ascii.len() <= 19);
        assert!(too_long.parse::<Nickname>().is_err());
        assert!(not_ascii.parse::<Nickname>().is_err());
        assert!(too_short.parse::<Nickname>().is_err());
        assert!(other_invalid.parse::<Nickname>().is_err());
        Ok(())
    }
    /// Test for both `Hostname` and `InternetHost`
    #[test]
    fn hostname() {
        use std::net::IpAddr;
        // Test a string that we should treat as a valid hostname.
        let chk_name = |s: &str| {
            let n: Hostname = s.parse().expect(s);
            assert_eq!(n.as_str(), s);
            assert_eq!(n.to_string(), s);
            assert_eq!(s.parse::<InternetHost>().expect(s), InternetHost::Name(n));
        };
        // Test a string that looks like it could be an address or a hostname.
        // We parse those as addresses.
        let chk_either = |s: &str| {
            let h: InternetHost = s.parse().expect(s);
            let a: IpAddr = s.parse().expect(s);
            assert_eq!(h, InternetHost::IpAddr(a), "{s:?}");
            assert_eq!(h.to_string(), a.to_string(), "{s:?}");
        };
        // Test a string that's an address, and isn't a valid hostname.
        let chk_addr = |s: &str| {
            let _: InvalidHostname = s.parse::<Hostname>().expect_err(s);
            chk_either(s);
        };
        // Test a string that we should reject.
        let chk_bad = |s: &str| {
            let _: InvalidHostname = s.parse::<Hostname>().expect_err(s);
            let _: InvalidInternetHost = s.parse::<InternetHost>().expect_err(s);
        };
        chk_name("foo.bar");
        chk_name("localhost");
        chk_name("tor.invalid");
        chk_name("example.com");
        // Unarguably invalid.
        chk_bad("");
        chk_bad("foo bar");
        chk_bad("foo..bar");
        chk_bad("foo.-bar");
        chk_bad(" foo.bar ");
        chk_bad("[::1]");
        // Strings that some IP address parsers accept as addresses,
        // but which are also valid hostnames according to RFC1123.
        //
        // We reject them rather than processing of them as hostnames,
        // exposing downstream software to possible strangeness.
        chk_bad("1");
        chk_bad("127.0.0.023");
        // No-one thinks this is a valid IP address but we reject it as a hostname too,
        // even though it's syntactically legal per RFC1123, because it's quite bad.
        chk_bad("1.2.3.4.5");
        chk_either("0.0.0.0");
        chk_either("127.0.0.1");
        chk_addr("::");
        chk_addr("::1");
        chk_addr("2001:0db8:85a3:0000:0000:8a2e:0370:7334");
        chk_addr("::ffff:192.0.2.3"); // IPv6-mapped IPv4 address
    }
    #[test]
    fn contact_info() -> anyhow::Result<()> {
        use encode::NetdocEncodable;
        use parse2::{ParseInput, parse_netdoc};
        const S: &str = "some relay operator";
        let n: ContactInfo = S.parse()?;
        assert_eq!(n.as_str(), S);
        assert_eq!(n.to_string(), S);
        let bad = |s: &str| {
            let _: InvalidContactInfo = s.parse::<ContactInfo>().unwrap_err();
        };
        bad(" starts with space");
        bad("contains\nnewline");
        #[derive(PartialEq, Debug, Deftly)]
        #[derive_deftly(NetdocParseable, NetdocEncodable)]
        struct TestDoc {
            pub intro: (),
            pub contact: ContactInfo,
        }
        let roundtrip = |s: &str| -> anyhow::Result<()> {
            let doc = TestDoc {
                intro: (),
                contact: s.parse()?,
            };
            let mut enc = NetdocEncoder::new();
            doc.encode_unsigned(&mut enc)?;
            let enc = enc.finish()?;
            let reparsed = parse_netdoc::<TestDoc>(&ParseInput::new(&enc, "<test>"))?;
            assert_eq!(doc, reparsed);
            Ok(())
        };
        roundtrip("normal")?;
        roundtrip("trailing  white space  ")?;
        roundtrip("wtf is this allowed in \x03 netdocs\r")?; // TODO torspec#396
        Ok(())
    }
    /// Round trip test for [`NumericBoolean`] ensuring that `0` is false,
    /// `1` is true, and other things fail.
    #[test]
    fn numeric_boolean() {
        let chk = |s: &str| {
            assert_eq!(NumericBoolean::from_str(s).expect(s).to_string(), s);
        };
        chk("0");
        chk("1");
        // Testing this because it is not a u8.
        assert!(NumericBoolean::from_str("10000").is_err());
    }
    #[test]
    fn f64_finite() {
        let normalise_string = |i: &str, o: &str| {
            let v: F64Finite = i.parse().expect(i);
            assert_eq!(v.to_string(), o, "i={i:?}");
        };
        let roundtrip_string = |s: &str| normalise_string(s, s);
        let roundtrip_value = |i: f64| {
            let v: F64Finite = i.try_into().unwrap();
            let s = v.to_string();
            let o: F64Finite = s.parse().expect(&s);
            assert_eq!(v, o, "{i:?} {s}");
            assert_eq!(v.to_bits(), o.to_bits(), "{i:?} {s}");
        };
        let error_string = |s: &str| {
            let _: F64FiniteParseError = s.parse::<F64Finite>().expect_err(s);
        };
        roundtrip_string("0");
        roundtrip_string("0.5");
        roundtrip_string("1");
        roundtrip_string("42");
        roundtrip_string("9007199254740991"); // f64::MAX_EXACT_INTEGER (as per Rust 1.96.0)
        normalise_string("1e3", "1000");
        roundtrip_value(f64::EPSILON);
        roundtrip_value(f64::EPSILON + 1.0);
        roundtrip_value(f64::MIN);
        roundtrip_value(f64::MIN_POSITIVE);
        roundtrip_value(-f64::MIN_POSITIVE);
        roundtrip_value(f64::MAX);
        error_string(&f64::NAN.to_string());
        error_string(&f64::INFINITY.to_string());
        error_string("");
        error_string("garbage");
        // TODO torspec#416 these ought to be more reasonable, but this is what it does now:
        roundtrip_string(
            "0.000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000022250738585072014",
        ); // MIN_POSITIVE
        roundtrip_string(
            "179769313486231570000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000000",
        ); // MAX
    }
    /// Test that ensures SpFingerprint matches the 10x4 requirement.
    #[test]
    fn sp_fingerprint() {
        use derive_deftly::Deftly;
        use tor_llcrypto::pk::rsa::RsaIdentity;
        use crate::parse2::ErrorProblem;
        #[derive(Deftly)]
        #[derive_deftly(NetdocParseable, NetdocEncodable)]
        struct Wrapper {
            #[deftly(netdoc(single_arg))]
            fingerprint: SpFingerprint,
        }
        /// Small helper to parse an [`SpFingerprint`].
        ///
        /// In the case the parsing went successful, it also performs a
        /// round-trip encoding test.
        fn parse2(s: &str) -> std::result::Result<SpFingerprint, ErrorProblem> {
            use crate::parse2::{self, ParseInput};
            let input = format!("fingerprint {s}\n");
            let res = parse2::parse_netdoc::<Wrapper>(&ParseInput::new(&input, ""))
                .map_err(|x| x.problem)?;
            // Round-trip encoding; we only do .starts_with() because input
            // may contain trailing parameters which will obviously not be
            // encoded; trimming to remove the trailing "\n" afterwards.
            let mut enc = NetdocEncoder::default();
            res.encode_unsigned(&mut enc).unwrap();
            assert!(input.starts_with(enc.finish().unwrap().trim_end()));
            Ok(res.fingerprint)
        }
        // Test a valid one.
        assert_eq!(
            parse2(&vec!["ABAB"; 10].join(" ")).unwrap(),
            SpFingerprint(RsaIdentity::from_bytes(&[0xAB; 20]).unwrap())
        );
        // Test a valid one with tail.
        assert_eq!(
            parse2(&vec!["ABAB"; 11].join(" ")).unwrap(),
            SpFingerprint(RsaIdentity::from_bytes(&[0xAB; 20]).unwrap())
        );
        // Missing argument
        assert!(matches!(
            parse2(&vec!["ABAB"; 9].join(" ")).unwrap_err(),
            ErrorProblem::MissingArgument { .. }
        ));
        // Invalid argument.
        // In this case, we have string with a total length of 40 but with
        // one pair having 6 characters and another one having 2 as a proof
        // of that.
        assert!(matches!(
            parse2("0000 000000 00 0000 0000 0000 0000 0000 0000 0000").unwrap_err(),
            ErrorProblem::InvalidArgument { .. }
        ));
        // And of course invalid hex should fail too.
        assert!(matches!(
            parse2(&vec!["ZZZZ"; 10].join(" ")).unwrap_err(),
            ErrorProblem::InvalidArgument { .. }
        ));
    }
    /// Verifies the parsing of [`ItemPresent`].
    #[test]
    fn item_present_parse2() {
        #[derive(Default)]
        struct Token;
        #[derive(Deftly)]
        #[derive_deftly(NetdocParseable)]
        struct TestDoc {
            #[allow(unused)]
            intro: Ignored,
            foo: Option<ItemPresent<Token>>,
        }
        // The test cases with their respective result; boolean indicating that
        // it was present.
        let tests = [
            // Test valid present.
            ("intro\nfoo\n", Ok(true)),
            // Test valid absent.
            ("intro\n", Ok(false)),
            // Test repeated.
            ("intro\nfoo\nfoo\n", Err(ErrorProblem::ItemRepeated)),
            // Test repeated with unknown.
            ("intro\nbar\nfoo\nfoo\n", Err(ErrorProblem::ItemRepeated)),
            // Test with argument.
            ("intro\nfoo bar\n", Ok(true)),
            // Test with two arguments.
            ("intro\nfoo bar baz\n", Ok(true)),
            // Test with object.
            (
                "intro\nfoo\n-----BEGIN RSA PUBLIC KEY-----\n-----END RSA PUBLIC KEY-----\n",
                Err(ErrorProblem::ObjectUnexpected),
            ),
        ];
        for (input, expect) in tests {
            println!("{input:?}, {expect:?}");
            // Convert the result by calling .is_present() and extracting EP.
            let got = parse2::parse_netdoc::<TestDoc>(&ParseInput::new(input, ""))
                .map(|x| x.foo.is_some())
                .map_err(|e| e.problem);
            assert_eq!(got, expect);
        }
    }
    #[test]
    fn item_present_encode() {
        #[derive(Default)]
        struct Token;
        #[derive(Deftly)]
        #[derive_deftly(NetdocEncodable)]
        struct TestDoc {
            #[allow(unused)]
            intro: (),
            foo: Option<ItemPresent<Token>>,
        }
        let tests = [
            (Some(ItemPresent(Token)), "intro\nfoo\n"),
            (None, "intro\n"),
        ];
        for (present, output) in tests {
            let mut encoder = NetdocEncoder::new();
            TestDoc {
                intro: (),
                foo: present,
            }
            .encode_unsigned(&mut encoder)
            .unwrap();
            assert_eq!(encoder.finish().unwrap(), output);
        }
    }
    #[test]
    fn ntor_onion_key_cross_cert() {
        // Dummy helper for parsing a subset of a router desc.
        #[derive(Debug, Deftly)]
        #[derive_deftly(NetdocParseable)]
        #[allow(unused)]
        struct TestDoc {
            /// Intro item.
            router: RouterDescIntroItem,
            /// Timestamp used for `now` in certificate validation.
            #[deftly(netdoc(single_arg))]
            published: Iso8601TimeSp,
            /// Required to ensure certified key of the crosscert.
            #[deftly(netdoc(single_arg))]
            master_key_ed25519: Ed25519Public,
            /// Required to obtain the key signing the crosscert.
            #[deftly(netdoc(single_arg))]
            ntor_onion_key: Curve25519Public,
            /// The actual crosscert.
            ntor_onion_key_crosscert: NtorOnionKeyCrossCert,
        }
        impl TestDoc {
            // Quick verify helper.
            fn verify(&self, now: SystemTime) {
                Ed25519NtorCrossCert::verify(
                    // Converts X25519 to Ed25519.
                    tor_llcrypto::pk::keymanip::convert_curve25519_to_ed25519_public(
                        &self.ntor_onion_key.0,
                        self.ntor_onion_key_crosscert.bit.0.into(),
                    )
                    .unwrap()
                    .into(),
                    self.master_key_ed25519.0,
                    self.ntor_onion_key_crosscert.cert.raw_unverified().clone(),
                    Duration::ZERO,
                    now,
                )
                .unwrap();
            }
        }
        let descs = include_str!("../../testdata2/cached-descriptors.new");
        let descs = parse2::parse_netdoc_multiple::<TestDoc>(&ParseInput::new(
            descs,
            "cached-descriptors.new",
        ))
        .unwrap();
        // Find the first with negative and first with positive X coordinate.
        let negative_rd = descs
            .iter()
            .find(|rd| rd.ntor_onion_key_crosscert.bit.0)
            .unwrap();
        let positive_rd = descs
            .iter()
            .find(|rd| !rd.ntor_onion_key_crosscert.bit.0)
            .unwrap();
        negative_rd.verify(negative_rd.published.0);
        positive_rd.verify(positive_rd.published.0);
    }
    /// Helper to call methods for edcerts.
    trait Ed25519CertTest: Sized + PartialEq + Eq + Debug {
        /// Creates a new instance.
        ///
        /// Used to create a struct in ad-hoc fashion for Eq comparison.
        fn new(
            signing_key: ed25519::Ed25519Identity,
            certified_key: ed25519::Ed25519Identity,
        ) -> Self;
        /// Returns the expected [`CertType`].
        fn cert_type() -> CertType;
        /// Calls .new_signed().
        ///
        /// This method is used to create an [`EmbeddedCert`] with a given
        /// signing key and a key that shall be certified.
        fn new_signed(
            signing_key: &ed25519::Keypair,
            certified_key: ed25519::Ed25519Identity,
            expiry: SystemTime,
        ) -> StdResult<EmbeddedCert<Self, KeyUnknownCert>, Bug>;
        /// Calls .verify().
        ///
        /// The method verifies a certificate given a pre-known certified key,
        /// the actual certificate, and a timestamp.
        fn verify(
            signing_key: Option<ed25519::Ed25519Identity>,
            certified_key: ed25519::Ed25519Identity,
            cert: KeyUnknownCert,
            post_tolerance: Duration,
            now: SystemTime,
        ) -> StdResult<Self, VerifyFailed>;
    }
    impl Ed25519CertTest for Ed25519IdentityCert {
        fn new(
            signing_key: ed25519::Ed25519Identity,
            certified_key: ed25519::Ed25519Identity,
        ) -> Self {
            Self {
                id_ed25519: signing_key,
                sign_ed25519: certified_key,
            }
        }
        fn cert_type() -> CertType {
            CertType::IDENTITY_V_SIGNING
        }
        fn new_signed(
            signing_key: &ed25519::Keypair,
            certified_key: ed25519::Ed25519Identity,
            expiry: SystemTime,
        ) -> StdResult<EmbeddedCert<Self, KeyUnknownCert>, Bug> {
            Self::new_signed(signing_key, certified_key, expiry)
        }
        fn verify(
            _signing_key: Option<ed25519::Ed25519Identity>,
            _certified_key: ed25519::Ed25519Identity,
            cert: KeyUnknownCert,
            post_tolerance: Duration,
            now: SystemTime,
        ) -> StdResult<Self, VerifyFailed> {
            Self::verify(cert, post_tolerance, now)
        }
    }
    impl Ed25519CertTest for Ed25519FamilyCert {
        fn new(
            signing_key: ed25519::Ed25519Identity,
            _certified_key: ed25519::Ed25519Identity,
        ) -> Self {
            Self {
                family_ed25519: signing_key,
            }
        }
        fn cert_type() -> CertType {
            CertType::FAMILY_V_IDENTITY
        }
        fn new_signed(
            signing_key: &ed25519::Keypair,
            certified_key: ed25519::Ed25519Identity,
            expiry: SystemTime,
        ) -> StdResult<EmbeddedCert<Self, KeyUnknownCert>, Bug> {
            Self::new_signed(signing_key, certified_key, expiry)
        }
        fn verify(
            _signing_key: Option<ed25519::Ed25519Identity>,
            certified_key: ed25519::Ed25519Identity,
            cert: KeyUnknownCert,
            post_tolerance: Duration,
            now: SystemTime,
        ) -> StdResult<Self, VerifyFailed> {
            Self::verify(certified_key, cert, post_tolerance, now)
        }
    }
    impl Ed25519CertTest for Ed25519NtorCrossCert {
        fn new(
            _signing_key: ed25519::Ed25519Identity,
            _certified_key: ed25519::Ed25519Identity,
        ) -> Self {
            Self::dangerous_new_unverified()
        }
        fn cert_type() -> CertType {
            CertType::NTOR_CC_IDENTITY
        }
        fn new_signed(
            signing_key: &ed25519::Keypair,
            certified_key: ed25519::Ed25519Identity,
            expiry: SystemTime,
        ) -> StdResult<EmbeddedCert<Self, KeyUnknownCert>, Bug> {
            Self::new_signed(signing_key, certified_key, expiry)
        }
        fn verify(
            signing_key: Option<ed25519::Ed25519Identity>,
            certified_key: ed25519::Ed25519Identity,
            cert: KeyUnknownCert,
            post_tolerance: Duration,
            now: SystemTime,
        ) -> StdResult<Self, VerifyFailed> {
            Self::verify(
                signing_key.unwrap(),
                certified_key,
                cert,
                post_tolerance,
                now,
            )
        }
    }
    /// Converts from [`Iso8601TimeSp`] to [`SystemTime`]
    fn str_to_st(s: &str) -> SystemTime {
        Iso8601TimeSp::from_str(s).unwrap().0
    }
    /// Tests a valid ad-hoc generated certificate.
    fn ed25519_cert_rng<T: Ed25519CertTest>() {
        let mut rng = testing_rng();
        let signing_key = ed25519::Keypair::generate(&mut rng);
        let certified_key = ed25519::Keypair::generate(&mut rng);
        let now = str_to_st("2000-01-01 06:00:00");
        let expiry = str_to_st("2000-01-01 12:00:00");
        // Test ad-hoc generation.
        let embedded_cert =
            T::new_signed(&signing_key, certified_key.public_key().into(), expiry).unwrap();
        assert_eq!(
            *embedded_cert.get().unwrap(),
            T::new(
                signing_key.public_key().into(),
                certified_key.public_key().into()
            )
        );
        // Verify ad-hoc certificate generation.
        let unverified = embedded_cert.raw_unverified().clone();
        assert_eq!(T::cert_type(), unverified.peek_cert_type());
        match unverified.peek_subject_key() {
            CertifiedKey::Ed25519(x) => assert_eq!(
                *x,
                ed25519::Ed25519Identity::from(certified_key.public_key())
            ),
            _ => panic!(),
        }
        // Finally, see if .verify() agrees.
        T::verify(
            Some(signing_key.public_key().into()),
            certified_key.public_key().into(),
            unverified.clone(),
            Duration::ZERO,
            now,
        )
        .unwrap();
        // See if .verify() also agrees when expired but with toleration.
        T::verify(
            Some(signing_key.public_key().into()),
            certified_key.public_key().into(),
            unverified,
            Duration::from_secs(60 * 60),
            expiry,
        )
        .unwrap();
    }
    /// Tests invalid Ed25519 certificates by violating various constraints.
    fn ed25519_cert_invalid<T: Ed25519CertTest + 'static>(requires_signed_with_ext: bool) {
        let mut rng = testing_rng();
        let now = str_to_st("2000-01-01 06:00:00");
        let expiry = str_to_st("2000-01-01 12:00:00");
        let signing_key = ed25519::Keypair::generate(&mut rng);
        let signing_pk = ed25519::Ed25519Identity::from(signing_key.public_key());
        let certified_key = ed25519::Keypair::generate(&mut rng);
        let certified_pk = ed25519::Ed25519Identity::from(certified_key.public_key());
        let mut tests: Vec<(_, _, CertifiedKey, _, _)> = vec![
            // Testing a violation of the signature is hard because the encoder
            // refuses to emit such a thing.
            // ---
            // Violate timestamp.
            (
                T::cert_type(),
                // We achieve this by setting expiry to now - 1 day.
                now - Duration::from_secs(64 * 64 * 24),
                certified_pk.into(),
                Some(&signing_pk),
                &signing_key,
            ),
            // Violate cert type.
            (
                // Just picking something completely out of place here.
                CertType::LINK_AUTH_X509,
                expiry,
                certified_pk.into(),
                Some(&signing_pk),
                &signing_key,
            ),
            // Violate certified key type.
            (
                T::cert_type(),
                expiry,
                // Just pass a different CertifiedKey variant here.
                CertifiedKey::RsaSha256Digest(certified_pk.into()),
                Some(&signing_pk),
                &signing_key,
            ),
            // ---
            // Missing test for violating both keys MUST be valid mappings to a
            // [`ed25519::PublicKey`].  I was unable to find a single test
            // vector for this, even in curve25591-dalek. :/
        ];
        // Violate absence of `signed-with-ed25519-key`.
        // This is not a violation in Ed25519NtorCrossCert.
        if requires_signed_with_ext {
            tests.push((
                T::cert_type(),
                expiry,
                certified_pk.into(),
                None,
                &signing_key,
            ));
        }
        for (ctype, expiry, certified_key, signing_key, signing_kp) in tests {
            let mut builder = Ed25519Cert::builder()
                .cert_type(ctype)
                .expiration(expiry)
                .cert_key(certified_key.clone())
                .clone();
            if let Some(signing_key) = signing_key {
                builder = builder.signing_key(*signing_key).clone();
            }
            let cert = Ed25519Cert::decode(&builder.encode_and_sign(signing_kp).unwrap()).unwrap();
            // We purposely always create an Ed25519Identity here from the bytes
            // in order to make it possible to test for invalid certified
            // key types.
            T::verify(
                signing_key.copied(),
                Ed25519Identity::from_bytes(certified_key.as_bytes()).unwrap(),
                cert,
                Duration::ZERO,
                now,
            )
            .unwrap_err();
        }
    }
    #[test]
    fn ed25519_cert_rng_test() {
        ed25519_cert_rng::<Ed25519IdentityCert>();
        ed25519_cert_rng::<Ed25519FamilyCert>();
        ed25519_cert_rng::<Ed25519NtorCrossCert>();
    }
    #[test]
    fn ed25519_cert_invalid_test() {
        ed25519_cert_invalid::<Ed25519IdentityCert>(true);
        ed25519_cert_invalid::<Ed25519FamilyCert>(true);
        ed25519_cert_invalid::<Ed25519NtorCrossCert>(false);
    }
}