1
//! Parsing implementation for networkstatus documents.
2
//!
3
//! In Tor, a networkstatus documents describes a complete view of the
4
//! relays in the network: how many there are, how to contact them,
5
//! and so forth.
6
//!
7
//! A networkstatus document can either be a "votes" -- an authority's
8
//! view of the network, used as input to the voting process -- or a
9
//! "consensus" -- a combined view of the network based on multiple
10
//! authorities' votes, and signed by multiple authorities.
11
//!
12
//! A consensus document can itself come in two different flavors: a
13
//! plain (unflavoured) consensus has references to router descriptors, and
14
//! a "microdesc"-flavored consensus ("md") has references to
15
//! microdescriptors.
16
//!
17
//! To keep an up-to-date view of the network, clients download
18
//! microdescriptor-flavored consensuses periodically, and then
19
//! download whatever microdescriptors the consensus lists that the
20
//! client doesn't already have.
21
//!
22
//! For full information about the network status format, see
23
//! [dir-spec.txt](https://spec.torproject.org/dir-spec).
24
//!
25
//! # Limitations
26
//!
27
//! NOTE: The consensus format has changes time, using a
28
//! "consensus-method" mechanism.  This module is does not yet handle all
29
//! all historical consensus-methods.
30
//!
31
//! NOTE: This module _does_ parse some fields that are not in current
32
//! use, like relay nicknames, and the "published" times on
33
//! microdescriptors. We should probably decide whether we actually
34
//! want to do this.
35
//!
36
//! TODO: This module doesn't implement vote parsing at all yet.
37
//!
38
//! TODO: This module doesn't implement plain consensuses.
39
//!
40
//! TODO: We need an object safe trait that combines the common operations found
41
//! on netstatus documents, so we can store one in a `Box<dyn CommonNs>` or
42
//! something similar; otherwise interfacing applications have a hard time to
43
//! process netstatus documents in a flavor agnostic fashion.
44
//!
45
//! TODO: More testing is needed!
46
//!
47
//! TODO: There should be accessor functions for most of the fields here.
48
//! As with the other tor-netdoc types, I'm deferring those till I know what
49
//! they should be.
50

            
51
mod dir_source;
52
mod rs;
53

            
54
pub mod md;
55
pub mod plain;
56
pub mod vote;
57

            
58
#[cfg(feature = "build_docs")]
59
mod build;
60

            
61
pub use proto_statuses_parse2_encode::ProtoStatusesNetdocParseAccumulator;
62

            
63
use crate::doc::authcert::EncodedAuthCert;
64

            
65
use crate::doc::authcert::{self, AuthCert, AuthCertKeyIds, AuthCertUnverified};
66
use crate::encode::{
67
    EncodeOrd, ItemArgument, ItemEncoder, ItemValueEncodable, NetdocEncodable, NetdocEncoder,
68
};
69
use crate::parse::keyword::Keyword;
70
use crate::parse::parser::{Section, SectionRules, SectionRulesBuilder};
71
use crate::parse::tokenize::{Item, ItemResult, NetDocReader};
72
use crate::parse2::{
73
    self, ArgumentError, ArgumentStream, ErrorProblem, IsStructural, ItemArgumentParseable,
74
    ItemStream, ItemValueParseable, KeywordRef, NetdocParseable, NetdocParseableUnverified,
75
    SignatureHashInputs, SignatureItemParseable, StopAt, UnparsedItem, VerifyFailed,
76
};
77
use crate::types::relay_flags::{self, DocRelayFlags};
78
use crate::types::{self, *};
79
use crate::util::PeekableIterator;
80
use crate::{Error, KeywordEncodable, NetdocErrorKind as EK, NormalItemArgument, Pos};
81
use std::collections::{BTreeSet, HashMap, HashSet};
82
use std::fmt::{self, Display};
83
use std::slice;
84
use std::str::FromStr;
85
use std::sync::Arc;
86
use std::time::{self, SystemTime};
87
use std::{net, result};
88
use tor_basic_utils::iter_join;
89
use tor_error::{Bug, HasKind, bad_api_usage, internal};
90
use tor_protover::Protocols;
91
use void::ResultVoidExt as _;
92

            
93
use derive_deftly::{Deftly, define_derive_deftly};
94
use digest::Digest;
95
use itertools::Itertools;
96
use saturating_time::SaturatingTime as _;
97
use std::sync::LazyLock;
98
use tor_checkable::{ExternallySigned, TimeBound, timed::TimeRangeBound};
99
use tor_llcrypto as ll;
100
use tor_llcrypto::pk::rsa::RsaIdentity;
101

            
102
use serde::{Deserialize, Deserializer};
103

            
104
#[cfg(feature = "build_docs")]
105
pub use build::MdConsensusBuilder;
106
#[cfg(feature = "build_docs")]
107
pub use build::PlainConsensusBuilder;
108
#[cfg(feature = "build_docs")]
109
ns_export_each_flavor! {
110
    ty: RouterStatusBuilder;
111
}
112

            
113
ns_export_each_variety! {
114
    ty: Footer, RouterStatus, Preamble;
115
}
116

            
117
#[deprecated]
118
pub use PlainConsensus as NsConsensus;
119
#[deprecated]
120
pub use PlainRouterStatus as NsRouterStatus;
121
#[deprecated]
122
pub use UncheckedPlainConsensus as UncheckedNsConsensus;
123
#[deprecated]
124
pub use UnvalidatedPlainConsensus as UnvalidatedNsConsensus;
125

            
126
pub use rs::{RouterStatusMdDigestsVote, SoftwareVersion};
127

            
128
pub use dir_source::{ConsensusAuthoritySection, DirSource, SupersededAuthorityKey};
129

            
130
define_constant_string! {
131
    /// `network-status-version` version value
132
    ///
133
    /// This is the fixed string `3`.
134
    ///
135
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:network-status-version>
136
    //
137
    // IMO this is nicer than the formulation with an enum.
138
    // In practice we are not going to support other versions with the same parsing approach;
139
    // probably not even with the same code.
140
    NetworkStatusVersion = "3";
141
}
142

            
143
define_constant_string! {
144
    /// The `status` value in a `vote-status` line in a consensus
145
    ///
146
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:vote-status>
147
    VoteStatusConsensus = "consensus";
148
}
149

            
150
define_constant_string! {
151
    /// The `vote` value in a `vote-status` line in a vote
152
    ///
153
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:vote-status>
154
    VoteStatusVote = "vote";
155
}
156

            
157
/// `publiscation` field in routerstatus entry intro item other than in votes
158
///
159
/// Two arguments which are both ignored.
160
/// This used to be an ISO8601 timestamp in anomalous two-argument format.
161
///
162
/// Nowadays, according to the spec, it can be a dummy value.
163
/// So it can be a unit type.
164
///
165
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:r>,
166
/// except in votes which use [`Iso8601TimeSp`] instead.
167
///
168
/// **Not the same as** the `published` item:
169
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:published>
170
#[derive(Debug, Copy, Clone, Eq, PartialEq, Hash, Ord, PartialOrd, Default)]
171
#[allow(clippy::exhaustive_structs)]
172
pub struct IgnoredPublicationTimeSp;
173

            
174
/// The lifetime of a networkstatus document.
175
///
176
/// In a consensus, this type describes when the consensus may safely
177
/// be used.  In a vote, this type describes the proposed lifetime for a
178
/// consensus.
179
///
180
/// Aggregate of three netdoc preamble fields.
181
#[derive(Clone, Debug, PartialEq, Eq, Deftly)]
182
#[derive_deftly(Constructor, NetdocEncodableFields, NetdocParseableFields)]
183
#[derive_deftly(Lifetime)]
184
#[allow(clippy::exhaustive_structs)]
185
pub struct Lifetime {
186
    /// `valid-after` --- Time at which the document becomes valid
187
    ///
188
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:published>
189
    ///
190
    /// (You might see a consensus a little while before this time,
191
    /// since voting tries to finish up before the.)
192
    #[deftly(constructor)]
193
    #[deftly(netdoc(single_arg))]
194
    pub valid_after: Iso8601TimeSp,
195
    /// `fresh-until` --- Time after which there is expected to be a better version
196
    /// of this consensus
197
    ///
198
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:published>
199
    ///
200
    /// You can use the consensus after this time, but there is (or is
201
    /// supposed to be) a better one by this point.
202
    #[deftly(constructor)]
203
    #[deftly(netdoc(single_arg))]
204
    pub fresh_until: Iso8601TimeSp,
205
    /// `valid-until` --- Time after which this consensus is expired.
206
    ///
207
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:published>
208
    ///
209
    /// You should try to get a better consensus after this time,
210
    /// though it's okay to keep using this one if no more recent one
211
    /// can be found.
212
    #[deftly(constructor)]
213
    #[deftly(netdoc(single_arg))]
214
    pub valid_until: Iso8601TimeSp,
215

            
216
    #[doc(hidden)]
217
    #[deftly(netdoc(skip))]
218
    pub __non_exhaustive: (),
219
}
220

            
221
define_derive_deftly! {
222
    /// Bespoke derive for `Lifetime`, for `new` and accessors
223
    Lifetime:
224

            
225
    ${defcond FIELD not(approx_equal($fname, __non_exhaustive))}
226

            
227
    impl Lifetime {
228
        /// Construct a new Lifetime.
229
14699
        pub fn new(
230
14699
            $( ${when FIELD} $fname: time::SystemTime, )
231
14699
        ) -> crate::Result<Self> {
232
            // Make this now because otherwise literal `valid_after` here in the body
233
            // has the wrong span - the compiler refuses to look at the argument.
234
            // But we can refer to the field names.
235
            let self_ = Lifetime {
236
                $( ${when FIELD} $fname: $fname.into(), )
237
                __non_exhaustive: (),
238
            };
239
            if self_.valid_after < self_.fresh_until && self_.fresh_until < self_.valid_until {
240
                Ok(self_)
241
            } else {
242
                Err(EK::InvalidLifetime.err())
243
            }
244
        }
245
      $(
246
        ${when FIELD}
247

            
248
        ${fattrs doc}
249
148665
        pub fn $fname(&self) -> time::SystemTime {
250
            *self.$fname
251
        }
252
      )
253
        /// Return true if this consensus is officially valid at the provided time.
254
530
        pub fn valid_at(&self, when: time::SystemTime) -> bool {
255
            *self.valid_after <= when && when <= *self.valid_until
256
        }
257

            
258
        /// Return the voting period implied by this lifetime.
259
        ///
260
        /// (The "voting period" is the amount of time in between when a consensus first
261
        /// becomes valid, and when the next consensus is expected to become valid)
262
54908
        pub fn voting_period(&self) -> time::Duration {
263
            let valid_after = self.valid_after();
264
            let fresh_until = self.fresh_until();
265
            fresh_until
266
                .duration_since(valid_after)
267
                .expect("Mis-formed lifetime")
268
        }
269
    }
270
}
271
use derive_deftly_template_Lifetime;
272

            
273
/// A single consensus method
274
///
275
/// These are integers, but we don't do arithmetic on them.
276
///
277
/// As defined here:
278
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:consensus-methods>
279
/// <https://spec.torproject.org/dir-spec/computing-consensus.html#flavor:microdesc>
280
///
281
/// As used in a `consensus-method` item:
282
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:consensus-method>
283
#[derive(Debug, Clone, Default, Eq, PartialEq, Ord, PartialOrd, Hash, Copy)] //
284
#[derive(derive_more::From, derive_more::Into, derive_more::Display, derive_more::FromStr)]
285
#[allow(clippy::exhaustive_structs)] // we're v unlikely to want to change this to u16 or u64
286
pub struct ConsensusMethod(pub u32);
287
impl NormalItemArgument for ConsensusMethod {}
288

            
289
/// A set of consensus methods
290
///
291
/// Implements `ItemValueParseable` as required for `consensus-methods`,
292
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:consensus-methods>
293
///
294
/// There is also [`consensus_methods_comma_separated`] for `m` lines in votes.
295
#[derive(Debug, Clone, Default, Eq, PartialEq, Ord, PartialOrd, Hash, Deftly)]
296
#[derive_deftly(ItemValueEncodable, ItemValueParseable)]
297
#[non_exhaustive]
298
pub struct ConsensusMethods {
299
    /// Consensus methods.
300
    pub methods: BTreeSet<ConsensusMethod>,
301
}
302

            
303
/// Module for use with parse2's `with`, to parse one argument of comma-separated consensus methods
304
///
305
/// As found in an `m` item in a vote:
306
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:m>
307
pub mod consensus_methods_comma_separated {
308
    use super::*;
309
    use parse2::ArgumentError as AE;
310
    use std::result::Result;
311

            
312
    /// Parse
313
58
    pub fn from_args<'s>(args: &mut ArgumentStream<'s>) -> Result<ConsensusMethods, AE> {
314
58
        let mut methods = BTreeSet::new();
315
208
        for ent in args.next().ok_or(AE::Missing)?.split(',') {
316
208
            let ent = ent.parse().map_err(|_| AE::Invalid)?;
317
208
            if !methods.insert(ent) {
318
                return Err(AE::Invalid);
319
208
            }
320
        }
321
58
        Ok(ConsensusMethods { methods })
322
58
    }
323

            
324
    /// Encode
325
30
    pub fn write_arg_onto(self_: &ConsensusMethods, out: &mut ItemEncoder) -> Result<(), Bug> {
326
30
        out.args_raw_string(&iter_join(",", &self_.methods));
327
30
        Ok(())
328
30
    }
329
}
330

            
331
/// A set of named network parameters.
332
///
333
/// These are used to describe current settings for the Tor network,
334
/// current weighting parameters for path selection, and so on.  They're
335
/// encoded with a space-separated K=V format.
336
///
337
/// A `NetParams<i32>` is part of the validated directory manager configuration,
338
/// where it is built (in the builder-pattern sense) from a transparent HashMap.
339
///
340
/// As found in `params` in a network status:
341
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:params>
342
///
343
/// The same syntax is also used, and this type used for parsing, in various other places,
344
/// for example routerstatus entry `w` items (bandwidth weights):
345
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:w>
346
//
347
// TODO DIRAUTH torspec#401 Replace `String` with a suitable newtype
348
// Currently:
349
//  - Our parser allows any keyword that makes it into a netdoc argument,
350
//    but it splits on the *first* `=` so a `NetParams<i32>` cannot parse a keyword with a `=`.
351
//  - We provide constructors that allow any `String`, even ones containing space, `=`,
352
//    newline, etc.
353
//  - Encoding throws `Bug` if the resulting document will be clearly garbage,
354
//    forbidding `=`, whitespace, and controls.  If the supplied keywords are bizarre,
355
//    it may generate surprising documents (eg, containing exciting Unicode).
356
#[derive(Debug, Clone, Default, Eq, PartialEq)]
357
pub struct NetParams<T> {
358
    /// Map from keys to values.
359
    params: HashMap<String, T>,
360
}
361

            
362
impl<T> NetParams<T> {
363
    /// Create a new empty list of NetParams.
364
    #[allow(unused)]
365
29794
    pub fn new() -> Self {
366
29794
        NetParams {
367
29794
            params: HashMap::new(),
368
29794
        }
369
29794
    }
370
    /// Retrieve a given network parameter, if it is present.
371
190544
    pub fn get<A: AsRef<str>>(&self, v: A) -> Option<&T> {
372
190544
        self.params.get(v.as_ref())
373
190544
    }
374
    /// Return an iterator over all key value pairs in an arbitrary order.
375
24398
    pub fn iter(&self) -> impl Iterator<Item = (&String, &T)> {
376
24398
        self.params.iter()
377
24398
    }
378
    /// Set or replace the value of a network parameter.
379
10182
    pub fn set(&mut self, k: String, v: T) {
380
10182
        self.params.insert(k, v);
381
10182
    }
382
}
383

            
384
impl<K: Into<String>, T> FromIterator<(K, T)> for NetParams<T> {
385
6826
    fn from_iter<I: IntoIterator<Item = (K, T)>>(i: I) -> Self {
386
        NetParams {
387
6873
            params: i.into_iter().map(|(k, v)| (k.into(), v)).collect(),
388
        }
389
6826
    }
390
}
391

            
392
impl<T> std::iter::Extend<(String, T)> for NetParams<T> {
393
3778
    fn extend<I: IntoIterator<Item = (String, T)>>(&mut self, iter: I) {
394
3778
        self.params.extend(iter);
395
3778
    }
396
}
397

            
398
impl<'de, T> Deserialize<'de> for NetParams<T>
399
where
400
    T: Deserialize<'de>,
401
{
402
    fn deserialize<D>(deserializer: D) -> std::result::Result<Self, D::Error>
403
    where
404
        D: Deserializer<'de>,
405
    {
406
        let params = HashMap::deserialize(deserializer)?;
407
        Ok(NetParams { params })
408
    }
409
}
410

            
411
/// A list of subprotocol versions that implementors should/must provide.
412
///
413
/// This struct represents a pair of (optional) items:
414
/// `recommended-FOO-protocols` and `required-FOO-protocols`.
415
///
416
/// Each consensus has two of these: one for relays, and one for clients.
417
///
418
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:required-relay-protocols>
419
#[derive(Debug, Clone, Default, PartialEq, serde::Serialize, serde::Deserialize)]
420
pub struct ProtoStatus {
421
    /// Set of protocols that are recommended; if we're missing a protocol
422
    /// in this list we should warn the user.
423
    ///
424
    /// `recommended-client-protocols` or `recommended-relay-protocols`
425
    recommended: Protocols,
426
    /// Set of protocols that are required; if we're missing a protocol
427
    /// in this list we should refuse to start.
428
    ///
429
    /// `required-client-protocols` or `required-relay-protocols`
430
    required: Protocols,
431
}
432

            
433
impl ProtoStatus {
434
    /// Check whether the list of supported protocols
435
    /// is sufficient to satisfy this list of recommendations and requirements.
436
    ///
437
    /// If any required protocol is missing, returns [`ProtocolSupportError::MissingRequired`].
438
    ///
439
    /// Otherwise, if no required protocol is missing, but some recommended protocol is missing,
440
    /// returns [`ProtocolSupportError::MissingRecommended`].
441
    ///
442
    /// Otherwise, if no recommended or required protocol is missing, returns `Ok(())`.
443
165
    pub fn check_protocols(
444
165
        &self,
445
165
        supported_protocols: &Protocols,
446
165
    ) -> Result<(), ProtocolSupportError> {
447
        // Required protocols take precedence, so we check them first.
448
165
        let missing_required = self.required.difference(supported_protocols);
449
165
        if !missing_required.is_empty() {
450
55
            return Err(ProtocolSupportError::MissingRequired(missing_required));
451
110
        }
452
110
        let missing_recommended = self.recommended.difference(supported_protocols);
453
110
        if !missing_recommended.is_empty() {
454
55
            return Err(ProtocolSupportError::MissingRecommended(
455
55
                missing_recommended,
456
55
            ));
457
55
        }
458

            
459
55
        Ok(())
460
165
    }
461
}
462

            
463
/// A subprotocol that is recommended or required in the consensus was not present.
464
#[derive(Clone, Debug, thiserror::Error)]
465
#[cfg_attr(test, derive(PartialEq))]
466
#[non_exhaustive]
467
pub enum ProtocolSupportError {
468
    /// At least one required protocol was not in our list of supported protocols.
469
    #[error("Required protocols are not implemented: {0}")]
470
    MissingRequired(Protocols),
471

            
472
    /// At least one recommended protocol was not in our list of supported protocols.
473
    ///
474
    /// Also implies that no _required_ protocols were missing.
475
    #[error("Recommended protocols are not implemented: {0}")]
476
    MissingRecommended(Protocols),
477
}
478

            
479
impl ProtocolSupportError {
480
    /// Return true if the suggested behavior for this error is a shutdown.
481
    pub fn should_shutdown(&self) -> bool {
482
        matches!(self, Self::MissingRequired(_))
483
    }
484
}
485

            
486
impl HasKind for ProtocolSupportError {
487
    fn kind(&self) -> tor_error::ErrorKind {
488
        tor_error::ErrorKind::SoftwareDeprecated
489
    }
490
}
491

            
492
/// A set of recommended and required protocols when running
493
/// in various scenarios.
494
///
495
/// Represents the collection of four items: `{recommended,required}-{client,relay}-protocols`.
496
///
497
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:required-relay-protocols>
498
#[derive(Clone, Debug, Default, PartialEq, serde::Serialize, serde::Deserialize)]
499
pub struct ProtoStatuses {
500
    /// Lists of recommended and required subprotocol versions for clients
501
    client: ProtoStatus,
502
    /// Lists of recommended and required subprotocol versions for relays
503
    relay: ProtoStatus,
504
}
505

            
506
impl ProtoStatuses {
507
    /// Return the list of recommended and required protocols for running as a client.
508
159
    pub fn client(&self) -> &ProtoStatus {
509
159
        &self.client
510
159
    }
511

            
512
    /// Return the list of recommended and required protocols for running as a relay.
513
    pub fn relay(&self) -> &ProtoStatus {
514
        &self.relay
515
    }
516
}
517

            
518
/// List of recommended Tor versions
519
///
520
/// As seen in `client-versions` and `server-versions` in the preamble.
521
///
522
/// Technically these are supposed to be as according to
523
/// "`version-spec.txt`" but we actually allow anything that doesn't contain commas.
524
///
525
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:client-versions>
526
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:server-versions>
527
///
528
/// An empty set means no information, not no recommended versions.
529
//
530
// TODO should we have a CommaSeparated<T> type for arguments like this?
531
// But maybe we wouldn't be able to use it here anyway because of
532
// the special handling of the missing value.
533
//
534
// This is yet a third version number representation in arti!  Here it's just String.
535
// TODO unify RecommendedTorVersions, RelayPlatform, TorVersion
536
// When this is fixed, remove the workaround in netstatus::test::roundtrip_netstatus
537
#[derive(Clone, Debug, Default, Eq, PartialEq, Ord, PartialOrd)] //
538
#[derive(derive_more::Deref, derive_more::Into)]
539
pub struct RecommendedTorVersions(BTreeSet<String>);
540

            
541
/// Erroneous "recommended Tor versions" information
542
#[derive(Clone, Debug, Eq, PartialEq, thiserror::Error)]
543
#[non_exhaustive]
544
pub enum InvalidRecommendedTorVersions {
545
    /// Identical version appears twice
546
    #[error("version {_0:?} contains whitespace")]
547
    ContainsWhitespace(String),
548

            
549
    /// Identical version appears twice
550
    #[error("version {_0:?} is repeated")]
551
    Repeated(String),
552
}
553

            
554
impl RecommendedTorVersions {
555
    /// Return a `RecommendedTorVersions` that has no information
556
    pub fn new_unknown() -> Self {
557
        Self::default()
558
    }
559

            
560
    /// Does this `RecommendedTorVersions` have any information?
561
    ///
562
    /// Ie, is it not empty.
563
    ///
564
    /// The opposite of [`BTreeSet::is_empty()`] (which available via deref).
565
    pub fn is_known(&self) -> bool {
566
        !self.is_empty()
567
    }
568

            
569
    /// Construct a RecommendedTorVersions from a list of strings
570
    #[allow(clippy::should_implement_trait)] // we can't due to coherence
571
26140
    pub fn from_iter<I, S>(i: I) -> Result<Self, InvalidRecommendedTorVersions>
572
26140
    where
573
26140
        I: IntoIterator<Item = S>,
574
26140
        S: AsRef<str>,
575
    {
576
26140
        let mut set = BTreeSet::new();
577
26224
        for v in i {
578
3010
            let v = v.as_ref();
579
3010
            if v.is_empty() {
580
786
                continue;
581
2224
            }
582
20716
            if v.chars().any(|c| c.is_whitespace()) {
583
                return Err(InvalidRecommendedTorVersions::ContainsWhitespace(
584
                    v.to_owned(),
585
                ));
586
2224
            }
587
2224
            if !set.insert(v.to_owned()) {
588
                return Err(InvalidRecommendedTorVersions::Repeated(v.to_owned()));
589
2224
            }
590
        }
591
26140
        Ok(RecommendedTorVersions(set))
592
26140
    }
593
}
594

            
595
impl FromStr for RecommendedTorVersions {
596
    type Err = InvalidRecommendedTorVersions;
597
1222
    fn from_str(s: &str) -> Result<Self, InvalidRecommendedTorVersions> {
598
1222
        Self::from_iter(s.split(','))
599
1222
    }
600
}
601

            
602
impl Display for RecommendedTorVersions {
603
24
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
604
24
        write!(f, "{}", iter_join(",", &self.0))
605
24
    }
606
}
607

            
608
impl NormalItemArgument for RecommendedTorVersions {}
609

            
610
impl ItemValueEncodable for RecommendedTorVersions {
611
24
    fn write_item_value_onto(&self, mut out: ItemEncoder) -> Result<(), Bug> {
612
24
        out.args_raw_string(self);
613
24
        Ok(())
614
24
    }
615
}
616

            
617
impl ItemValueParseable for RecommendedTorVersions {
618
452
    fn from_unparsed(mut item: UnparsedItem) -> Result<Self, ErrorProblem> {
619
        const FIELD: &str = "versions";
620
452
        item.check_no_object()?;
621
452
        let args = item.args_mut();
622
452
        let arg = args.next().unwrap_or("");
623
452
        arg.parse::<Self>()
624
452
            .map_err(|_| args.handle_error(FIELD, ArgumentError::Invalid))
625
452
    }
626
}
627

            
628
/// A recognized 'flavor' of consensus document.
629
///
630
/// The enum is exhaustive because the addition/removal of a consensus flavor
631
/// should indeed be a breaking change, as it would inevitable require
632
/// interfacing code to think about the handling of it.
633
///
634
/// <https://spec.torproject.org/dir-spec/computing-consensus.html#flavors>
635
#[derive(Copy, Clone, Debug, Eq, PartialEq, Hash, Ord, PartialOrd)]
636
#[allow(clippy::exhaustive_enums)]
637
pub enum ConsensusFlavor {
638
    /// A "microdesc"-flavored consensus.  This is the one that
639
    /// clients and relays use today.
640
    Microdesc,
641
    /// A "networkstatus"-flavored consensus.  It's used for
642
    /// historical and network-health purposes.  Instead of listing
643
    /// microdescriptor digests, it lists digests of full relay
644
    /// descriptors.
645
    Plain,
646
}
647

            
648
impl ConsensusFlavor {
649
    /// Return the name of this consensus flavor.
650
2703
    pub fn name(&self) -> &'static str {
651
2703
        match self {
652
954
            ConsensusFlavor::Plain => "ns", // spec bug, now baked in
653
1749
            ConsensusFlavor::Microdesc => "microdesc",
654
        }
655
2703
    }
656
    /// Try to find the flavor whose name is `name`.
657
    ///
658
    /// For historical reasons, an unnamed flavor indicates an "Plain"
659
    /// document.
660
385
    pub fn from_opt_name(name: Option<&str>) -> crate::Result<Self> {
661
385
        match name {
662
383
            Some("microdesc") => Ok(ConsensusFlavor::Microdesc),
663
2
            Some("ns") | None => Ok(ConsensusFlavor::Plain),
664
            Some(other) => {
665
                Err(EK::BadDocumentType.with_msg(format!("unrecognized flavor {:?}", other)))
666
            }
667
        }
668
385
    }
669
}
670

            
671
define_derive_deftly! {
672
    /// Bespoke derives applied to [`DirectorySignatureHashAlgo`]
673
    ///
674
    /// Generates:
675
    ///
676
    ///  * [`DirectorySignaturesHashesAccu`]
677
    ///  * [`DirectorySignaturesHashesAccu::update_from`]
678
    ///  * [`DirectorySignaturesHashesAccu::hash_slice_for_verification`]
679
    DirectorySignaturesHashesAccu:
680

            
681
    ${define FNAME ${paste ${snake_case $vname}} }
682

            
683
    /// `directory-signature`a hash algorithm argument
684
    #[derive(Clone, Copy, Default, Debug, Eq, PartialEq, Deftly)]
685
    #[derive_deftly(AsMutSelf)]
686
    #[non_exhaustive]
687
    pub struct DirectorySignaturesHashesAccu {
688
      $(
689
        ${vattrs doc}
690
        pub $FNAME: Option<[u8; ${vmeta(hash_len) as expr}]>,
691
      )
692

            
693
      /// `sha1` but without the algorithm name
694
      ///
695
      /// This is needed because the hash includes the whole signature item keyword line,
696
      /// and therefore a signature with the `sha1` explicitly stated,
697
      /// and one without, have different hashes!
698
      ///
699
      /// So we mustn't use the `sha1` field for both implicit and explicit use of SHA-1,
700
      /// or multiple signatures with different syntax would overwrite each others'
701
      /// different hashes.
702
      pub sha1_unnamed: Option<[u8; 20]>,
703
    }
704

            
705
    impl DirectorySignaturesHashesAccu {
706
        /// Calculate the hash for a signature item and update this accumulator
707
1984
        fn update_from(
708
            &mut self,
709
            algo: &DigestAlgoInSignature,
710
            body: &SignatureHashInputs,
711
        ) {
712
            // Update the hash in self.$UPDATE according to algorithm $AGLO
713
            // (uses dynamic bindings of those parameters)
714
            ${define HASH {
715
                // Avoid recalculating if we don't need to
716
232
                self.$UPDATE.get_or_insert_with(|| {
717
                    let mut h = tor_llcrypto::d::$ALGO::new();
718
                    h.update(body.body().body());
719
                    h.update(body.signature_item_kw_spc);
720
                    h.finalize().into()
721
                });
722
            }}
723

            
724
            match &**algo {
725
              $(
726
                Some(KeywordOrString::Known($vtype)) => {
727
                    ${define UPDATE $FNAME}
728
                    ${define ALGO $vname}
729
                    $HASH
730
                }
731
              )
732
                None => {
733
                    ${define UPDATE sha1_unnamed}
734
                    ${define ALGO Sha1}
735
                    $HASH
736
                }
737
                Some(KeywordOrString::Unknown(..)) => {}
738
            }
739
        }
740

            
741
        /// Return the hash value for a specific algorithm, as a slice
742
        ///
743
        /// `None` if the value wasn't computed.
744
        /// That shouldn't happen.
745
319
        fn hash_slice_for_verification(
746
319
            &self,
747
319
            algo: &DigestAlgoInSignature,
748
319
        ) -> Option<&[u8]> {
749
            match &**algo {
750
              $(
751
                Some(KeywordOrString::Known($vtype)) => Some(self.$FNAME.as_ref()?),
752
              )
753
                None => Some(self.sha1_unnamed.as_ref()?),
754
                Some(KeywordOrString::Unknown(..)) => None,
755
            }
756
        }
757
    }
758
}
759

            
760
/// `directory-signature` hash algorithm argument
761
#[derive(Clone, Copy, Debug, Eq, PartialEq, strum::Display, strum::EnumString, Deftly)]
762
#[derive_deftly(DirectorySignaturesHashesAccu)]
763
#[non_exhaustive]
764
#[strum(serialize_all = "snake_case")]
765
pub enum DirectorySignatureHashAlgo {
766
    /// SHA-1
767
    #[deftly(hash_len = "20")]
768
    Sha1,
769
    /// SHA-256
770
    #[deftly(hash_len = "32")]
771
    Sha256,
772
}
773

            
774
/// `algorithm` field in a `directory-signature` item
775
///
776
/// This is extremely bizarre: it's an *optional item at the start of the arguments*!
777
// TODO SPEC #350
778
///
779
/// So we parse it with some kind of nightmarish lookahead.
780
///
781
/// Additionally, to be able to convey the signatures accurately, without breaking them,
782
/// we must remember whether the argument was present.
783
///
784
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:directory-signature>
785
#[derive(Debug, Clone, derive_more::Deref, derive_more::DerefMut)]
786
#[allow(clippy::exhaustive_structs)]
787
pub struct DigestAlgoInSignature(pub Option<KeywordOrString<DirectorySignatureHashAlgo>>);
788

            
789
impl ItemArgumentParseable for DigestAlgoInSignature {
790
1984
    fn from_args<'s>(args: &mut ArgumentStream<'s>) -> Result<Self, ArgumentError> {
791
1984
        let v = if args
792
1984
            .clone()
793
1984
            .next()
794
            // Treat it as a fingerprint if it doesn't have any non-hex characters
795
            // (including lowercase ones).  If we reuse this item for new algorithms
796
            // they should have at least one letter g-z in their name.
797
78108
            .and_then(|s| s.chars().all(|c| c.is_ascii_hexdigit()).then_some(()))
798
1984
            .is_some()
799
        {
800
            // next argument looks enough like a fingerprint that we don't treat as an algo name
801
1950
            None
802
        } else {
803
34
            Some(KeywordOrString::from_args(args)?)
804
        };
805
1984
        Ok(DigestAlgoInSignature(v))
806
1984
    }
807
}
808
impl ItemArgument for DigestAlgoInSignature {
809
56
    fn write_arg_onto(&self, out: &mut ItemEncoder<'_>) -> Result<(), Bug> {
810
56
        if let Some(y) = &self.0 {
811
26
            y.write_arg_onto(out)?;
812
30
        }
813
56
        Ok(())
814
56
    }
815
}
816
impl DigestAlgoInSignature {
817
    /// Return the actual algorithm
818
    ///
819
    /// This handles the defaulting, where an absent argument means `sha1`.
820
    pub fn algorithm(&self) -> &KeywordOrString<DirectorySignatureHashAlgo> {
821
        self.as_ref()
822
            .unwrap_or(&KeywordOrString::Known(DirectorySignatureHashAlgo::Sha1))
823
    }
824
}
825

            
826
impl NormalItemArgument for DirectorySignatureHashAlgo {}
827

            
828
/// The signature of a single directory authority on a networkstatus document.
829
///
830
/// Implements `ItemValueParseable` which parses without hashing anything;
831
/// this is mostly useful for use by the `SignatureItemParseable` implementation.
832
#[derive(Debug, Clone, Deftly)]
833
#[derive_deftly(ItemValueEncodable, ItemValueParseable)]
834
#[non_exhaustive]
835
pub struct Signature {
836
    /// The name of the digest algorithm used to make the signature.
837
    ///
838
    /// Currently sha1 and sh256 are recognized.  Here we only support
839
    /// sha256.
840
    pub digest_algo: DigestAlgoInSignature,
841
    /// Fingerprints of the keys for the authority that made
842
    /// this signature.
843
    #[deftly(netdoc(with = authcert::keyids_directory_signature_args))]
844
    pub key_ids: AuthCertKeyIds,
845
    /// The signature itself.
846
    #[deftly(netdoc(object(label = "SIGNATURE"), with = types::raw_data_object))]
847
    pub signature: Vec<u8>,
848
}
849

            
850
impl SignatureItemParseable for Signature {
851
    type HashAccu = DirectorySignaturesHashesAccu;
852

            
853
1984
    fn from_unparsed_and_body(
854
1984
        item: UnparsedItem,
855
1984
        body: &SignatureHashInputs<'_>,
856
1984
        hash: &mut Self::HashAccu,
857
1984
    ) -> Result<Self, ErrorProblem> {
858
1984
        let signature = Signature::from_unparsed(item)?;
859
1984
        hash.update_from(&signature.digest_algo, body);
860
1984
        Ok(signature)
861
1984
    }
862
}
863

            
864
/// A collection of signatures that can be checked on a networkstatus document
865
///
866
/// This is derived from the signatures section of a netstatus,
867
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#section:signature>,
868
/// but it is not isomorphic to it, and is not directly parseable.
869
#[derive(Debug, Clone)]
870
#[non_exhaustive]
871
pub struct SignatureGroup {
872
    /// The document hashes of the signed part of the document
873
    ///
874
    /// The pre-parse2 parser always sets `hashes.sha1` and `hashes.sha1_unnamed`
875
    /// to the same value, which is wrong. which is
876
    /// [bug #2530](https://gitlab.torproject.org/tpo/core/arti/-/work_items/2530)
877
    pub hashes: DirectorySignaturesHashesAccu,
878
    /// The signatures listed on the document.
879
    pub signatures: Vec<Signature>,
880
}
881

            
882
/// Error which will prevent us from attempting to verify signatures on a consensus
883
///
884
/// This error occurs if we the consensus isn't signed by the right people,
885
/// or we are lacking authcerts.
886
///
887
/// Does not represent actual verification errors.
888
/// Those show up as `VerifyFailed`, typically [`ConsensusVerifyFailed::InvalidSignature`].
889
///
890
/// Can be converted to a `VerifyFailed`,
891
/// giving [`InsufficientTrustedSigners`](VerifyFailed::InsufficientTrustedSigners).
892
#[derive(Clone, Debug, thiserror::Error)]
893
#[non_exhaustive]
894
pub enum ConsensusVerifiabilityError {
895
    /// Insufficient trusted signers
896
    #[error("consensus not signed by enough authorities")]
897
    InsufficientTrustedSigners,
898

            
899
    /// Insufficient trusted signers because we are missing authcerts
900
    #[error("missing auth certs mean we could not verify enough consensuis signatures (need at least {deficit} more, out of {} that are missing)", missing.len())]
901
    MissingAuthCerts {
902
        /// The number of additional useful authcerts that would be sufficient
903
        deficit: usize,
904
        /// All the authcerts that would be useful
905
        missing: HashSet<AuthCertKeyIds>,
906
    },
907
}
908

            
909
/// Error encountered while verifying a consensus
910
///
911
/// Thrown by
912
/// [`plain::NetworkStatusUnverified::verify`]
913
/// and
914
/// [`md::NetworkStatusUnverified::verify`].
915
///
916
/// Not used for problems with the validity period:
917
/// that's handled by `tor-checkable` and shows up as [`tor_checkable::TimeValidityError`].
918
///
919
/// Can be converted to a `VerifyFailed` (which, in effect, summarises the error).
920
#[derive(Clone, Debug, thiserror::Error)]
921
#[non_exhaustive]
922
pub enum ConsensusVerifyFailed {
923
    /// Certificates or signatures insufficient
924
    #[error("certs/sigs insufficient")]
925
    CertificationInsufficient(#[from] ConsensusVerifiabilityError),
926

            
927
    /// One or more signatures failed to verify
928
    #[error("invalid signature")]
929
    //
930
    // Not `#[from]` because we don't want to accidentally convert
931
    // ConsensusVerifiabilityError -> VerifyFailed -> ConsensusVerifyFailed
932
    // since that would give the wrong variant.
933
    InvalidSignature(#[source] VerifyFailed),
934
}
935

            
936
/// Error encountered while verifying a vote
937
///
938
/// Thrown by
939
/// [`vote::NetworkStatusUnverified::verify`].
940
///
941
/// Not used for problems with the validity period:
942
/// that's handled by `tor-checkable` and shows up as [`tor_checkable::TimeValidityError`].
943
///
944
/// Can be converted to a `VerifyFailed` (which, in effect, summarises the error).
945
#[derive(Clone, Debug, thiserror::Error)]
946
#[non_exhaustive]
947
pub enum VoteVerifyFailed {
948
    /// The document signature failed to verify
949
    #[error("invalid signature")]
950
    //
951
    // Not `#[from]` because we don't want to accidentally convert
952
    // VoteVerifyFailed::Something -> VerifyFailed -> VoteVerifyFailed
953
    // since that would give the wrong variant.
954
    InvalidSignature(#[source] VerifyFailed),
955

            
956
    /// Authcert couldn't be parsed
957
    #[error("unparseable authcert")]
958
    AuthCertParseError(#[source] parse2::ParseError),
959

            
960
    /// Authcert isn't valid for this vote's validity period
961
    #[error("authcert not valid for vote period")]
962
    AuthCertWrongValidity(#[source] tor_checkable::TimeValidityError),
963

            
964
    /// Authcert is for a different authority
965
    #[error("wrong authcert")]
966
    AuthCertWrongAuthority,
967
}
968

            
969
/// A shared random value produced by the directory authorities.
970
#[derive(
971
    Debug, Clone, Copy, Eq, PartialEq, derive_more::From, derive_more::Into, derive_more::AsRef,
972
)]
973
// (This doesn't need to use CtByteArray; we don't really need to compare these.)
974
pub struct SharedRandVal([u8; 32]);
975

            
976
/// A shared-random value produced by the directory authorities,
977
/// along with meta-information about that value.
978
#[derive(Debug, Clone, Deftly)]
979
#[non_exhaustive]
980
#[derive_deftly(ItemValueEncodable, ItemValueParseable)]
981
pub struct SharedRandStatus {
982
    /// How many authorities revealed shares that contributed to this value.
983
    pub n_reveals: u8,
984
    /// The current random value.
985
    ///
986
    /// The properties of the secure shared-random system guarantee
987
    /// that this value isn't predictable before it first becomes
988
    /// live, and that a hostile party could not have forced it to
989
    /// have any more than a small number of possible random values.
990
    pub value: SharedRandVal,
991

            
992
    /// The time when this SharedRandVal becomes (or became) the latest.
993
    ///
994
    /// (This is added per proposal 342, assuming that gets accepted.)
995
    pub timestamp: Option<Iso8601TimeNoSp>,
996
}
997

            
998
/// The two shared random values, `shared-rand-*-value`
999
///
/// As found in the consensus preamble
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:shared-rand-current-value>
/// and a vote's authority section
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#authority-item-shared-rand-value>
#[derive(Debug, Clone, Default, Deftly)]
#[derive_deftly(Constructor, NetdocEncodableFields, NetdocParseableFields)]
#[allow(clippy::exhaustive_structs)]
pub struct SharedRandStatuses {
    /// Global shared-random value for the previous shared-random period.
    pub shared_rand_previous_value: Option<SharedRandStatus>,
    /// Global shared-random value for the current shared-random period.
    pub shared_rand_current_value: Option<SharedRandStatus>,
    #[doc(hidden)]
    #[deftly(netdoc(skip))]
    pub __non_exhaustive: (),
}
/// Relay weight information - `w` item in routerstatus
///
/// This is a combination of two representations of (subsets of) the same information,
/// from an optional `w` in the document.
///
///  * [`effective`](RelayWeightsItem::effective):
///
///    Always contains the effective weight, as [`RelayWeight`].
///    This is what is used by clients.
///    It does not record whether a `w` line was actually present.
///
///  * [`params`](RelayWeightsItem::params):
///
///    Can represent the presence and whole contents of the `w` line,
///    including all the known and unknown parameters.
///    This is within [`Unknown`], so it is only present with crate `feature = "retain-unknown"`,
///    and only some constructors/parsers record it.
///
/// # Parsing
///
/// Parsing is done with `NetdocParseableFields` rather than `ItemValueParseable`.
/// The `params` are [`Retained`](Unknown::Retained) if `retain_unknown_values` is
/// selected in [`parse2::ParseOptions`].
//
// We use NetdocParseableFields because the containing document, RouterStatus,
// contains `RelayWeightsItem` rather than `Option<RelayWeightsItem>`.
// The item parsing multiplicity machinery would see plain `RelayWeightsItem` as a required item.
//
// This representation also means so that if retaining unknown information is compiled out
// (ie, in clients) each routerstatus entry stored in memory does not need to record
// whether `w` was present, merely what the implications were.
//
// We can't use ItemValueParseable with #[deftly(netdoc(default))]
// because `RelayWeightsItem::default()` is a RelayWeightsItem that definitively
// contains no pazrameters, ie with `Unknown::Retained`,
// and is therefore only conditionally available.
/// # Encoding
///
/// Encoding requires knowing whether a `w` line is to be included, and its contents,
/// so is implemented only with if `effective` is `Unknown::Retained`.
/// The encoding impl is only compiled in with `"retain-unknown"`,
/// and throws [`Bug`] if applied to a `RelayWeightsItem` whose `params` are `Discarded`.
///
/// # Constructors
///
/// An "empty" `RelayWeightsItem` can be constructed with [`RelayWeightsItem::new_no_info`].
///
/// A `RelayWeightsItem` containing only the effective `RelayWeight`
/// can be constructed using [`RelayWeightsItem::from_effective`].
///
/// With `"retain-unknown"`:
/// a `RelayWeightsItem` can be constructed from a [`NetParams<u32>`] using `TryFrom`;
/// and, implements `Default`, which yields a `RelayWeightsItem`
/// representing the (known) absence of a `w` line.
//
// Fields are private to maintain the invariant.
#[derive(Debug, Clone)]
pub struct RelayWeightsItem {
    /// The effective relay weight
    effective: RelayWeight,
    /// The complete parameter set, if available and `w` was present.
    params: Unknown<Option<NetParams<u32>>>,
}
/// Recognized weight fields on a single relay in a consensus
///
/// The part of a `w` item that we understand as a client.
#[non_exhaustive]
#[derive(Debug, Clone, Copy)]
pub enum RelayWeight {
    /// An unmeasured weight for a relay.
    Unmeasured(u32),
    /// An measured weight for a relay.
    Measured(u32),
}
/// Error processing a `w` line's netparams into an effective relay weight
#[derive(Debug, Clone, thiserror::Error)]
#[non_exhaustive]
pub enum InvalidRelayWeights {
    /// Invalid value for `Unmeasured`
    #[error("invalid value for Unmeasured")]
    InvalidUnmeasured,
}
/// Authority entry in a consensus - deprecated compatibility type alias
#[deprecated = "renamed to ConsensusAuthorityEntry"]
pub type ConsensusVoterInfo = ConsensusAuthorityEntry;
/// Authority entry in a plain consensus - type alias provided for consistency
pub type PlainAuthorityEntry = ConsensusAuthorityEntry;
/// Authority entry in an md consensus - type alias provided for consistency
pub type MdAuthorityEntry = ConsensusAuthorityEntry;
/// An authority entry as found in a consensus
///
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#section:authority-entry>
///
/// See also [`VoteAuthorityEntry`]
//
// We don't use the `each_variety` system for this because:
//  1. That avoids separating the two consensus authority entry types, which are identical
//  2. The only common fields are `dir-source` and `contact`, so there is little duplication
#[derive(Debug, Clone, Deftly)]
#[derive_deftly(Constructor, NetdocEncodable, NetdocParseable)]
#[allow(clippy::exhaustive_structs)]
pub struct ConsensusAuthorityEntry {
    /// Contents of the `dir-source` line about an authority
    #[deftly(constructor)]
    pub dir_source: DirSource,
    /// Human-readable contact information about the authority
    //
    // If more non-intro fields get added that are the same in votes and cosensuses,
    // consider using each_variety.rs or breaking those fields out into
    // `AuthorityEntryCommon` implementing `NetdocParseableFields`, or something.
    #[deftly(constructor)]
    pub contact: ContactInfo,
    /// Digest of the vote that the authority cast to contribute to
    /// this consensus.
    ///
    /// This is not a fixed-length, fixed-algorithm field.
    /// Bizarrely, the algorithm is supposed to be inferred from the length!
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:vote-digest>
    #[deftly(netdoc(single_arg))]
    #[deftly(constructor)]
    pub vote_digest: B16U,
    #[doc(hidden)]
    #[deftly(netdoc(skip))]
    pub __non_exhaustive: (),
}
/// An authority entry as found in a vote
///
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#section:authority-entry>
///
/// See also [`ConsensusAuthorityEntry`]
#[derive(Debug, Clone, Deftly)]
#[derive_deftly(Constructor, NetdocEncodable, NetdocParseable)]
#[allow(clippy::exhaustive_structs)]
pub struct VoteAuthorityEntry {
    /// Contents of the `dir-source` line about an authority
    #[deftly(constructor)]
    pub dir_source: DirSource,
    /// Human-readable contact information about the authority
    #[deftly(constructor)]
    pub contact: ContactInfo,
    /// `legacy-dir-key` - superseded authority identity key
    ///
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:legacy-dir-key>
    #[deftly(netdoc(single_arg))]
    pub legacy_dir_key: Option<Fingerprint>,
    /// `shared-rand-participate` - Indicate shared random participation
    ///
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:shared-rand-participate>
    pub shared_rand_participate: Option<SharedRandParticipate>,
    /// `shared-rand-commit` - Shared random commitment
    ///
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:shared-rand-commit>
    pub shared_rand_commit: Vec<SharedRandCommit>,
    /// Global shared-random values
    #[deftly(netdoc(flatten))]
    pub shared_rand: SharedRandStatuses,
    #[doc(hidden)]
    #[deftly(netdoc(skip))]
    pub __non_exhaustive: (),
}
/// `shared-rand-participate` in a vote authority entry
///
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:shared-rand-participate>
//
// We could have done `shared_rand_participate: Option<()>` in VoteAuthorityEntry,
// but then we might end up with variables of type `&Option<()>` etc.
// whose meaning has been detached from its type.
//
// TODO DIRAUTH rework this according to the API design conclusion from !3977 when there is one
#[derive(Debug, Clone, Deftly)]
#[derive_deftly(Constructor, ItemValueEncodable, ItemValueParseable)]
#[allow(clippy::exhaustive_structs)]
pub struct SharedRandParticipate {
    #[doc(hidden)]
    #[deftly(netdoc(skip))]
    pub __non_exhaustive: (),
}
/// `shared-rand-commit` in a vote authority entry
///
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:shared-rand-commit>
#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Deftly)]
// If new protocols use this item with a different version, we'll call it an API break.
#[allow(clippy::exhaustive_enums)]
pub enum SharedRandCommit {
    /// Version 1, the only one supported
    V1(SharedRandCommitV1),
    /// Other versions.  Cannot be encoded.
    // It's not clear that future versions will use this version mechanism.  torspec#408.
    Unknown {},
}
/// `shared-rand-commit` in a vote authority entry
///
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:shared-rand-commit>
///
/// Version and hash are not explicitly represented.  See torspec#407.
///
/// `ItemValueEncodable` and `ItemValueParseable` impls do not include the fixed arguments;
/// in a netdoc, this type should be used within `SharedRandCommit::V1`.
#[derive(Debug, Clone, PartialEq, Eq, PartialOrd, Ord, Deftly)]
#[derive_deftly(Constructor, ItemValueEncodable, ItemValueParseable)]
#[allow(clippy::exhaustive_structs)]
pub struct SharedRandCommitV1 {
    /// Authority id key, recapitulated.
    // TODO this field shouldn't here at all torspec#407
    #[deftly(constructor)]
    h_kp_auth_id_rsa: Fingerprint,
    /// Commitment
    ///
    /// `TIMESTAMP || SHA3_256(REVEAL)`, as per
    /// <https://spec.torproject.org/srv-spec/specification.html#COMMITREVEAL>
    //
    // TOOD we would like to replace this with a type that separates out the pieces!
    // But that would need a FixedB64 generic over some tor-bytes trait, or something.
    #[deftly(constructor)]
    commit: FixedB64<40>,
    /// Reveal
    ///
    /// `TIMESTAMP || random number`, as per
    /// <https://spec.torproject.org/srv-spec/specification.html#COMMITREVEAL>
    reveal: Option<FixedB64<40>>,
    #[doc(hidden)]
    #[deftly(netdoc(skip))]
    pub __non_exhaustive: (),
}
impl SharedRandCommitV1 {
    /// The fixed arguments that precede the actual value in `shared-rand-commit 1 ...`
    const FIXED_ARGUMENTS: &[&str] = &["1", "sha3-256"];
}
impl ItemValueEncodable for SharedRandCommit {
26
    fn write_item_value_onto(&self, mut out: ItemEncoder) -> Result<(), Bug> {
26
        match self {
26
            SharedRandCommit::V1(values) => {
52
                for fixed in SharedRandCommitV1::FIXED_ARGUMENTS {
52
                    out.args_raw_string(fixed);
52
                }
26
                values.write_item_value_onto(out)
            }
            SharedRandCommit::Unknown {} => Err(internal!("encoding SharedRandCommit::Unknown")),
        }
26
    }
}
impl ItemValueParseable for SharedRandCommit {
42
    fn from_unparsed(mut item: UnparsedItem<'_>) -> Result<Self, ErrorProblem> {
42
        let mut fixed = SharedRandCommitV1::FIXED_ARGUMENTS.iter().copied();
42
        let args = item.args_mut();
42
        let version = args
42
            .next()
42
            .ok_or_else(|| args.handle_error("version", ArgumentError::Missing))?;
42
        if version != fixed.next().expect("nonempty") {
            return Ok(SharedRandCommit::Unknown {});
42
        }
42
        for exp in fixed {
42
            let got = args
42
                .next()
42
                .ok_or_else(|| args.handle_error(exp, ArgumentError::Missing))?;
42
            if got != exp {
                Err(args.handle_error(exp, ArgumentError::Invalid))?;
42
            }
        }
42
        let values = SharedRandCommitV1::from_unparsed(item)?;
42
        Ok(SharedRandCommit::V1(values))
42
    }
}
// For `ConsensusAuthoritySection`, see `dir_source.rs`.
define_derive_deftly! {
    /// Ad-hoc derive, `impl NetdocParseable for VoteAuthoritySection`
    ///
    /// We can't derive from `VoteAuthoritySection` with the normal macros, because
    /// it's not a document, with its own intro item.  It's just a collection of sub-documents.
    /// The netdoc derive macros don't have support for that - and it would be a fairly
    /// confusing thing to support because you'd end up with nested multiplicities and a whole
    /// variety of "intro item keywords" that were keywords for arbitrary sub-documents.
    ///
    /// Instead, we do that ad-hoc here.  It's less confusing because we don't need to
    /// worry about multiplicity, and because we know what only the outer document is
    /// that will contain this.
    VoteAuthoritySection:
    ${defcond F_NORMAL not(fmeta(netdoc(skip)))}
    impl NetdocParseable for VoteAuthoritySection {
8
        fn doctype_for_error() -> &'static str {
            "vote.authority.section"
        }
1250
        fn is_intro_item_keyword(kw: KeywordRef<'_>) -> bool {
            VoteAuthorityEntry::is_intro_item_keyword(kw)
        }
122
        fn is_structural_keyword(kw: KeywordRef<'_>) -> Option<IsStructural> {
          $(
            ${when F_NORMAL}
            if let y @ Some(_) = $ftype::is_structural_keyword(kw) {
                return y;
            }
          )
            None
        }
8
        fn from_items<'s>(
8
            input: &mut ItemStream<'s>,
8
            stop_outer: stop_at!(),
8
        ) -> Result<Self, ErrorProblem> {
            let stop_inner = stop_outer
              $(
                ${when F_NORMAL}
                | StopAt($ftype::is_intro_item_keyword)
              )
            ;
            Ok(VoteAuthoritySection { $(
                ${when F_NORMAL}
                $fname: NetdocParseable::from_items(input, stop_inner)?,
            )
                __non_exhaustive: (),
            })
        }
    }
    impl NetdocEncodable for VoteAuthoritySection {
4
        fn encode_unsigned(&self, out: &mut NetdocEncoder) -> Result<(), Bug> {
          $(
            ${when F_NORMAL}
            self.$fname.encode_unsigned(out)?;
          )
          Ok(())
        }
    }
}
/// An authority section in a vote
///
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#section:authority>
//
// We have split this out to help encapsulate vote/consensus-specific
// information in a forthcoming overall network status document type.
#[derive(Deftly, Clone, Debug)]
#[derive_deftly(VoteAuthoritySection, Constructor)]
#[allow(clippy::exhaustive_structs)]
pub struct VoteAuthoritySection {
    /// Authority entry
    #[deftly(constructor)]
    pub authority: VoteAuthorityEntry,
    /// Authority key certificate
    #[deftly(constructor)]
    pub cert: EmbeddedCert<AuthCert, EncodedAuthCert>,
    #[doc(hidden)]
    #[deftly(netdoc(skip))]
    pub __non_exhaustive: (),
}
/// Fields in the footer of a consensus
///
/// <https://spec.torproject.org/dir-spec/consensus-formats.html#section:footer>
///
/// Not the whole footer, because it lacks the `directory-footer` item.
#[derive(Debug, Clone, Deftly)]
#[derive_deftly(Constructor, NetdocEncodableFields, NetdocParseableFields)]
#[allow(clippy::exhaustive_structs)]
pub struct ConsensusFooterFields {
    /// `bandwidth-weights`
    ///
    /// <https://spec.torproject.org/dir-spec/consensus-formats.html#item:bandwidth-weights>
    #[deftly(netdoc(default))]
    pub bandwidth_weights: NetParams<i32>,
    #[doc(hidden)]
    #[deftly(netdoc(skip))]
    pub __non_exhaustive: (),
}
/// A consensus document that lists relays along with their
/// microdescriptor documents.
pub type MdConsensus = md::Consensus;
/// An MdConsensus that has been parsed and checked for timeliness,
/// but not for signatures.
pub type UnvalidatedMdConsensus = md::UnvalidatedConsensus;
/// An MdConsensus that has been parsed but not checked for signatures
/// and timeliness.
pub type UncheckedMdConsensus = md::UncheckedConsensus;
/// A consensus document that lists relays along with their
/// router descriptor documents.
pub type PlainConsensus = plain::Consensus;
/// An PlainConsensus that has been parsed and checked for timeliness,
/// but not for signatures.
pub type UnvalidatedPlainConsensus = plain::UnvalidatedConsensus;
/// An PlainConsensus that has been parsed but not checked for signatures
/// and timeliness.
pub type UncheckedPlainConsensus = plain::UncheckedConsensus;
decl_keyword! {
    /// Keywords that can be used in votes and consensuses.
    // TODO: This is public because otherwise we can't use it in the
    // ParseRouterStatus crate.  But I'd rather find a way to make it
    // private.
    #[non_exhaustive]
    #[allow(missing_docs)]
    pub NetstatusKwd {
        // Header
        "network-status-version" => NETWORK_STATUS_VERSION,
        "vote-status" => VOTE_STATUS,
        "consensus-methods" => CONSENSUS_METHODS,
        "consensus-method" => CONSENSUS_METHOD,
        "published" => PUBLISHED,
        "valid-after" => VALID_AFTER,
        "fresh-until" => FRESH_UNTIL,
        "valid-until" => VALID_UNTIL,
        "voting-delay" => VOTING_DELAY,
        "client-versions" => CLIENT_VERSIONS,
        "server-versions" => SERVER_VERSIONS,
        "known-flags" => KNOWN_FLAGS,
        "flag-thresholds" => FLAG_THRESHOLDS,
        "recommended-client-protocols" => RECOMMENDED_CLIENT_PROTOCOLS,
        "required-client-protocols" => REQUIRED_CLIENT_PROTOCOLS,
        "recommended-relay-protocols" => RECOMMENDED_RELAY_PROTOCOLS,
        "required-relay-protocols" => REQUIRED_RELAY_PROTOCOLS,
        "params" => PARAMS,
        "bandwidth-file-headers" => BANDWIDTH_FILE_HEADERS,
        "bandwidth-file-digest" => BANDWIDTH_FILE_DIGEST,
        // "package" is now ignored.
        // header in consensus, voter section in vote?
        "shared-rand-previous-value" => SHARED_RAND_PREVIOUS_VALUE,
        "shared-rand-current-value" => SHARED_RAND_CURRENT_VALUE,
        // Voter section (both)
        "dir-source" => DIR_SOURCE,
        "contact" => CONTACT,
        // voter section (vote, but not consensus)
        "legacy-dir-key" => LEGACY_DIR_KEY,
        "shared-rand-participate" => SHARED_RAND_PARTICIPATE,
        "shared-rand-commit" => SHARED_RAND_COMMIT,
        // voter section (consensus, but not vote)
        "vote-digest" => VOTE_DIGEST,
        // voter cert beginning (but only the beginning)
        "dir-key-certificate-version" => DIR_KEY_CERTIFICATE_VERSION,
        // routerstatus
        "r" => RS_R,
        "a" => RS_A,
        "s" => RS_S,
        "v" => RS_V,
        "pr" => RS_PR,
        "w" => RS_W,
        "p" => RS_P,
        "m" => RS_M,
        "id" => RS_ID,
        // footer
        "directory-footer" => DIRECTORY_FOOTER,
        "bandwidth-weights" => BANDWIDTH_WEIGHTS,
        "directory-signature" => DIRECTORY_SIGNATURE,
    }
}
/// Shared parts of rules for all kinds of netstatus headers
55
static NS_HEADER_RULES_COMMON_: LazyLock<SectionRulesBuilder<NetstatusKwd>> = LazyLock::new(|| {
    use NetstatusKwd::*;
55
    let mut rules = SectionRules::builder();
55
    rules.add(NETWORK_STATUS_VERSION.rule().required().args(1..=2));
55
    rules.add(VOTE_STATUS.rule().required().args(1..));
55
    rules.add(VALID_AFTER.rule().required());
55
    rules.add(FRESH_UNTIL.rule().required());
55
    rules.add(VALID_UNTIL.rule().required());
55
    rules.add(VOTING_DELAY.rule().args(2..));
55
    rules.add(CLIENT_VERSIONS.rule());
55
    rules.add(SERVER_VERSIONS.rule());
55
    rules.add(KNOWN_FLAGS.rule().required());
55
    rules.add(RECOMMENDED_CLIENT_PROTOCOLS.rule().args(1..));
55
    rules.add(RECOMMENDED_RELAY_PROTOCOLS.rule().args(1..));
55
    rules.add(REQUIRED_CLIENT_PROTOCOLS.rule().args(1..));
55
    rules.add(REQUIRED_RELAY_PROTOCOLS.rule().args(1..));
55
    rules.add(PARAMS.rule());
55
    rules
55
});
/// Rules for parsing the header of a consensus.
55
static NS_HEADER_RULES_CONSENSUS: LazyLock<SectionRules<NetstatusKwd>> = LazyLock::new(|| {
    use NetstatusKwd::*;
55
    let mut rules = NS_HEADER_RULES_COMMON_.clone();
55
    rules.add(CONSENSUS_METHOD.rule().args(1..=1));
55
    rules.add(SHARED_RAND_PREVIOUS_VALUE.rule().args(2..));
55
    rules.add(SHARED_RAND_CURRENT_VALUE.rule().args(2..));
55
    rules.add(UNRECOGNIZED.rule().may_repeat().obj_optional());
55
    rules.build()
55
});
/*
/// Rules for parsing the header of a vote.
static NS_HEADER_RULES_VOTE: SectionRules<NetstatusKwd> = {
    use NetstatusKwd::*;
    let mut rules = NS_HEADER_RULES_COMMON_.clone();
    rules.add(CONSENSUS_METHODS.rule().args(1..));
    rules.add(FLAG_THRESHOLDS.rule());
    rules.add(BANDWIDTH_FILE_HEADERS.rule());
    rules.add(BANDWIDTH_FILE_DIGEST.rule().args(1..));
    rules.add(UNRECOGNIZED.rule().may_repeat().obj_optional());
    rules
};
/// Rules for parsing a single voter's information in a vote.
static NS_VOTERINFO_RULES_VOTE: SectionRules<NetstatusKwd> = {
    use NetstatusKwd::*;
    let mut rules = SectionRules::new();
    rules.add(DIR_SOURCE.rule().required().args(6..));
    rules.add(CONTACT.rule().required());
    rules.add(LEGACY_DIR_KEY.rule().args(1..));
    rules.add(SHARED_RAND_PARTICIPATE.rule().no_args());
    rules.add(SHARED_RAND_COMMIT.rule().may_repeat().args(4..));
    rules.add(SHARED_RAND_PREVIOUS_VALUE.rule().args(2..));
    rules.add(SHARED_RAND_CURRENT_VALUE.rule().args(2..));
    // then comes an entire cert: When we implement vote parsing,
    // we should use the authcert code for handling that.
    rules.add(UNRECOGNIZED.rule().may_repeat().obj_optional());
    rules
};
 */
/// Rules for parsing a single voter's information in a consensus
55
static NS_VOTERINFO_RULES_CONSENSUS: LazyLock<SectionRules<NetstatusKwd>> = LazyLock::new(|| {
    use NetstatusKwd::*;
55
    let mut rules = SectionRules::builder();
55
    rules.add(DIR_SOURCE.rule().required().args(6..));
55
    rules.add(CONTACT.rule().required());
55
    rules.add(VOTE_DIGEST.rule().required());
55
    rules.add(UNRECOGNIZED.rule().may_repeat().obj_optional());
55
    rules.build()
55
});
/// Shared rules for parsing a single routerstatus
static NS_ROUTERSTATUS_RULES_COMMON_: LazyLock<SectionRulesBuilder<NetstatusKwd>> =
55
    LazyLock::new(|| {
        use NetstatusKwd::*;
55
        let mut rules = SectionRules::builder();
55
        rules.add(RS_A.rule().may_repeat().args(1..));
55
        rules.add(RS_S.rule().required());
55
        rules.add(RS_V.rule());
55
        rules.add(RS_PR.rule().required());
55
        rules.add(RS_W.rule());
55
        rules.add(RS_P.rule().args(2..));
55
        rules.add(UNRECOGNIZED.rule().may_repeat().obj_optional());
55
        rules
55
    });
/// Rules for parsing a single routerstatus in an NS consensus
2
static NS_ROUTERSTATUS_RULES_PLAIN: LazyLock<SectionRules<NetstatusKwd>> = LazyLock::new(|| {
    use NetstatusKwd::*;
2
    let mut rules = NS_ROUTERSTATUS_RULES_COMMON_.clone();
2
    rules.add(RS_R.rule().required().args(8..));
2
    rules.build()
2
});
/*
/// Rules for parsing a single routerstatus in a vote
static NS_ROUTERSTATUS_RULES_VOTE: SectionRules<NetstatusKwd> = {
    use NetstatusKwd::*;
        let mut rules = NS_ROUTERSTATUS_RULES_COMMON_.clone();
        rules.add(RS_R.rule().required().args(8..));
        rules.add(RS_M.rule().may_repeat().args(2..));
        rules.add(RS_ID.rule().may_repeat().args(2..)); // may-repeat?
        rules
    };
*/
/// Rules for parsing a single routerstatus in a microdesc consensus
55
static NS_ROUTERSTATUS_RULES_MDCON: LazyLock<SectionRules<NetstatusKwd>> = LazyLock::new(|| {
    use NetstatusKwd::*;
55
    let mut rules = NS_ROUTERSTATUS_RULES_COMMON_.clone();
55
    rules.add(RS_R.rule().required().args(6..));
55
    rules.add(RS_M.rule().required().args(1..));
55
    rules.build()
55
});
/// Rules for parsing consensus fields from a footer.
55
static NS_FOOTER_RULES: LazyLock<SectionRules<NetstatusKwd>> = LazyLock::new(|| {
    use NetstatusKwd::*;
55
    let mut rules = SectionRules::builder();
55
    rules.add(DIRECTORY_FOOTER.rule().required().no_args());
    // consensus only
55
    rules.add(BANDWIDTH_WEIGHTS.rule());
55
    rules.add(UNRECOGNIZED.rule().may_repeat().obj_optional());
55
    rules.build()
55
});
impl ProtoStatus {
    /// Construct a ProtoStatus from two chosen keywords in a section.
770
    fn from_section(
770
        sec: &Section<'_, NetstatusKwd>,
770
        recommend_token: NetstatusKwd,
770
        required_token: NetstatusKwd,
770
    ) -> crate::Result<ProtoStatus> {
        /// Helper: extract a Protocols entry from an item's arguments.
1540
        fn parse(t: Option<&Item<'_, NetstatusKwd>>) -> crate::Result<Protocols> {
1540
            if let Some(item) = t {
1540
                item.args_as_str()
1540
                    .parse::<Protocols>()
1540
                    .map_err(|e| EK::BadArgument.at_pos(item.pos()).with_source(e))
            } else {
                Ok(Protocols::new())
            }
1540
        }
770
        let recommended = parse(sec.get(recommend_token))?;
770
        let required = parse(sec.get(required_token))?;
770
        Ok(ProtoStatus {
770
            recommended,
770
            required,
770
        })
770
    }
    /// Return the protocols that are listed as "required" in this `ProtoStatus`.
    ///
    /// Implementations may assume that relays on the network implement all the
    /// protocols in the relays' required-protocols list.  Implementations should
    /// refuse to start if they do not implement all the protocols on their own
    /// (client or relay) required-protocols list.
2385
    pub fn required_protocols(&self) -> &Protocols {
2385
        &self.required
2385
    }
    /// Return the protocols that are listed as "recommended" in this `ProtoStatus`.
    ///
    /// Implementations should warn if they do not implement all the protocols
    /// on their own (client or relay) recommended-protocols list.
    pub fn recommended_protocols(&self) -> &Protocols {
        &self.recommended
    }
}
impl<T> std::str::FromStr for NetParams<T>
where
    T: std::str::FromStr,
    T::Err: std::error::Error,
{
    type Err = Error;
17902
    fn from_str(s: &str) -> crate::Result<Self> {
        /// Helper: parse a single K=V pair.
32402
        fn parse_pair<U>(p: &str) -> crate::Result<(String, U)>
32402
        where
32402
            U: std::str::FromStr,
32402
            U::Err: std::error::Error,
        {
32402
            let parts: Vec<_> = p.splitn(2, '=').collect();
32402
            if parts.len() != 2 {
                return Err(EK::BadArgument
                    .at_pos(Pos::at(p))
                    .with_msg("Missing = in key=value list"));
32402
            }
32402
            let num = parts[1].parse::<U>().map_err(|e| {
8
                EK::BadArgument
8
                    .at_pos(Pos::at(parts[1]))
8
                    .with_msg(e.to_string())
8
            })?;
32394
            Ok((parts[0].to_string(), num))
32402
        }
17902
        let params = s
17902
            .split(' ')
45187
            .filter(|p| !p.is_empty())
17902
            .map(parse_pair)
17902
            .try_collect()?;
17894
        Ok(NetParams { params })
17902
    }
}
impl FromStr for SharedRandVal {
    type Err = Error;
440
    fn from_str(s: &str) -> crate::Result<Self> {
440
        let val: B64 = s.parse()?;
440
        let val = SharedRandVal(val.into_array()?);
440
        Ok(val)
440
    }
}
impl Display for SharedRandVal {
12
    fn fmt(&self, f: &mut fmt::Formatter) -> fmt::Result {
12
        Display::fmt(&B64::from(Vec::from(self.0)), f)
12
    }
}
impl NormalItemArgument for SharedRandVal {}
impl SharedRandStatus {
    /// Parse a current or previous shared rand value from a given
    /// SharedRandPreviousValue or SharedRandCurrentValue.
6
    fn from_item(item: &Item<'_, NetstatusKwd>) -> crate::Result<Self> {
6
        match item.kwd() {
4
            NetstatusKwd::SHARED_RAND_PREVIOUS_VALUE | NetstatusKwd::SHARED_RAND_CURRENT_VALUE => {}
            _ => {
2
                return Err(Error::from(internal!(
2
                    "wrong keyword {:?} on shared-random value",
2
                    item.kwd()
2
                ))
2
                .at_pos(item.pos()));
            }
        }
4
        let n_reveals: u8 = item.parse_arg(0)?;
4
        let value: SharedRandVal = item.parse_arg(1)?;
        // Added in proposal 342
4
        let timestamp = item.parse_optional_arg::<Iso8601TimeNoSp>(2)?;
4
        Ok(SharedRandStatus {
4
            n_reveals,
4
            value,
4
            timestamp,
4
        })
6
    }
    /// Return the actual shared random value.
1272
    pub fn value(&self) -> &SharedRandVal {
1272
        &self.value
1272
    }
    /// Return the timestamp (if any) associated with this `SharedRandValue`.
3498
    pub fn timestamp(&self) -> Option<std::time::SystemTime> {
3498
        self.timestamp.map(|t| t.0)
3498
    }
}
impl DirSource {
    /// Parse a "dir-source" item
1157
    fn from_item(item: &Item<'_, NetstatusKwd>) -> crate::Result<Self> {
1157
        if item.kwd() != NetstatusKwd::DIR_SOURCE {
            return Err(
                Error::from(internal!("Bad keyword {:?} on dir-source", item.kwd()))
                    .at_pos(item.pos()),
            );
1157
        }
1157
        let nickname = item
1157
            .required_arg(0)?
1157
            .parse()
1157
            .map_err(|e: InvalidNickname| {
                EK::BadArgument.at_pos(item.pos()).with_msg(e.to_string())
            })?;
1157
        let identity = item.parse_arg(1)?;
1157
        let hostname = item
1157
            .required_arg(2)?
1157
            .parse()
1157
            .map_err(|e: InvalidInternetHost| {
                EK::BadArgument.at_pos(item.pos()).with_msg(e.to_string())
            })?;
1157
        let ip = item.parse_arg(3)?;
1157
        let dir_port = item.parse_arg(4)?;
1157
        let or_port = item.parse_arg(5)?;
1157
        Ok(DirSource {
1157
            nickname,
1157
            identity,
1157
            hostname,
1157
            ip,
1157
            dir_port,
1157
            or_port,
1157
            __non_exhaustive: (),
1157
        })
1157
    }
}
impl ConsensusAuthorityEntry {
    /// Parse a single ConsensusAuthorityEntry from a voter info section.
1157
    fn from_section(sec: &Section<'_, NetstatusKwd>) -> crate::Result<ConsensusAuthorityEntry> {
        use NetstatusKwd::*;
        // this unwrap should be safe because if there is not at least one
        // token in the section, the section is unparsable.
        #[allow(clippy::unwrap_used)]
1157
        let first = sec.first_item().unwrap();
1157
        if first.kwd() != DIR_SOURCE {
            return Err(Error::from(internal!(
                "Wrong keyword {:?} at start of voter info",
                first.kwd()
            ))
            .at_pos(first.pos()));
1157
        }
1157
        let dir_source = DirSource::from_item(sec.required(DIR_SOURCE)?)?;
1157
        let contact = sec.required(CONTACT)?;
        // Ideally we would parse_args_as_str but that requires us to
        // impl From<InvalidContactInfo> for crate::Error which is wrong
        // because many it's a footgun which lets you just write ? here
        // resulting in lack of position information.
        // (This is a general problem with the error handling in crate::parse.)
1157
        let contact = contact
1157
            .args_as_str()
1157
            .parse()
1157
            .map_err(|err: InvalidContactInfo| {
                EK::BadArgument
                    .with_msg(err.to_string())
                    .at_pos(contact.pos())
            })?;
1157
        let vote_digest = sec.required(VOTE_DIGEST)?.parse_arg::<B16U>(0)?;
1157
        Ok(ConsensusAuthorityEntry {
1157
            dir_source,
1157
            contact,
1157
            vote_digest,
1157
            __non_exhaustive: (),
1157
        })
1157
    }
}
impl RelayWeightsItem {
    /// Return a new `RelayWeightsItem` containing no information
    ///
    /// As if parsed from a document with no `w` line, discarding unknown information.
2076
    pub fn new_no_info() -> Self {
2076
        RelayWeightsItem {
2076
            effective: RelayWeight::default(),
2076
            params: Unknown::new_discard(),
2076
        }
2076
    }
    /// Return a new `RelayWeightsItem` containing only the effective weight
    pub fn from_effective(effective: RelayWeight) -> Self {
        RelayWeightsItem {
            effective,
            params: Unknown::new_discard(),
        }
    }
    /// Get the effective relay weight (bandwidth estimate) for path selection.
    ///
    /// Invariant: consistent with from [`params`](RelayWeightsItem::params),
    /// if `parsed` isn't [`Discarded`](Unknown::Discarded).
    //
    // We open-code this rather than deriving it so we can provide better docs.
    pub fn effective(&self) -> RelayWeight {
        self.effective
    }
    /// Get the complete parameter set, if this information is available.
    ///
    /// After parsing, this is the parsed but not interpreted `w` item,
    /// or `None` if the document contained no `w` item.
    //
    // We open-code this rather than deriving it because we want to return
    // `Unknown<&...>` rather than `&Unknown<..>`, which the user would just have to .as_ref().
    pub fn params(&self) -> Unknown<&Option<NetParams<u32>>> {
        self.params.as_ref()
    }
    /// Parse a routerweight from a "w" line.
2088
    fn from_item(item: &Item<'_, NetstatusKwd>) -> crate::Result<RelayWeightsItem> {
2088
        if item.kwd() != NetstatusKwd::RS_W {
6
            return Err(
6
                Error::from(internal!("Wrong keyword {:?} on W line", item.kwd()))
6
                    .at_pos(item.pos()),
6
            );
2082
        }
2082
        let params = item.args_as_str().parse()?;
2080
        let effective = RelayWeight::from_net_params(&params).map_err(|e| e.at_pos(item.pos()))?;
2080
        Ok(RelayWeightsItem {
2080
            effective,
2080
            params: Unknown::new_discard(),
2080
        })
2088
    }
    /// The keyword for parsing and encoding
    const KEYWORD: &str = "w";
}
#[cfg(feature = "retain-unknown")]
impl Default for RelayWeightsItem {
    fn default() -> Self {
        RelayWeightsItem {
            effective: RelayWeight::default(),
            params: Unknown::Retained(None),
        }
    }
}
impl RelayWeight {
    /// Return true if this weight is the result of a successful measurement
26298
    pub fn is_measured(&self) -> bool {
26298
        matches!(self, RelayWeight::Measured(_))
26298
    }
    /// Return true if this weight is nonzero
24867
    pub fn is_nonzero(&self) -> bool {
24867
        !matches!(self, RelayWeight::Unmeasured(0) | RelayWeight::Measured(0))
24867
    }
    /// Parse a routerweight from partially-parsed `w` line in the form of a `NetParams`
    ///
    /// This function is the common part shared between `parse2` and `parse`.
2080
    fn from_net_params(params: &NetParams<u32>) -> crate::Result<RelayWeight> {
2080
        params
2080
            .try_into()
2080
            .map_err(|e: InvalidRelayWeights| EK::BadArgument.with_msg(e.to_string()))
2080
    }
}
impl Default for RelayWeight {
2076
    fn default() -> RelayWeight {
2076
        RelayWeight::Unmeasured(0)
2076
    }
}
impl TryFrom<&NetParams<u32>> for RelayWeight {
    type Error = InvalidRelayWeights;
2632
    fn try_from(params: &NetParams<u32>) -> Result<RelayWeight, InvalidRelayWeights> {
2632
        let bw = params.params.get("Bandwidth");
2632
        let unmeas = params.params.get("Unmeasured");
2632
        let bw = match bw {
2
            None => return Ok(RelayWeight::Unmeasured(0)),
2630
            Some(b) => *b,
        };
2630
        match unmeas {
494
            None | Some(0) => Ok(RelayWeight::Measured(bw)),
2136
            Some(1) => Ok(RelayWeight::Unmeasured(bw)),
            _ => Err(InvalidRelayWeights::InvalidUnmeasured),
        }
2632
    }
}
#[cfg(feature = "retain-unknown")]
impl TryFrom<NetParams<u32>> for RelayWeightsItem {
    type Error = InvalidRelayWeights;
    fn try_from(params: NetParams<u32>) -> Result<RelayWeightsItem, InvalidRelayWeights> {
        Ok(RelayWeightsItem {
            effective: (&params).try_into()?,
            params: Unknown::Retained(Some(params)),
        })
    }
}
/// `parse2` impls for types in this modulea
///
/// Separate module for a separate namespace.
mod parse2_impls {
    use super::*;
    pub(super) use parse2::{
        ArgumentError as AE, ArgumentStream, ErrorProblem as EP, ItemArgumentParseable,
        ItemValueParseable, NetdocParseableFields,
    };
    use std::result::Result;
    // The NormalItemArgument bound ensures that this is applied only to sane types eg integers
    impl<T: FromStr + NormalItemArgument> ItemValueParseable for NetParams<T>
    where
        T::Err: std::error::Error,
    {
1060
        fn from_unparsed(item: parse2::UnparsedItem<'_>) -> Result<Self, EP> {
1060
            item.check_no_object()?;
1060
            item.args_copy()
1060
                .into_remaining()
1060
                .parse()
1060
                .map_err(item.invalid_argument_handler("parameters"))
1060
        }
    }
    impl NetdocParseableFields for RelayWeightsItem {
        type Accumulator = Option<NetParams<u32>>;
552
        fn is_item_keyword(kw: KeywordRef) -> bool {
552
            kw == Self::KEYWORD
552
        }
552
        fn accumulate_item(acc: &mut Self::Accumulator, item: UnparsedItem) -> Result<(), EP> {
552
            if acc.is_some() {
                return Err(EP::ItemRepeated);
552
            }
552
            item.check_no_object()?;
552
            let params = NetParams::from_unparsed(item)?;
552
            *acc = Some(params);
552
            Ok(())
552
        }
552
        fn finish(params: Self::Accumulator, items: &ItemStream) -> Result<Self, EP> {
552
            let effective = params
552
                .as_ref()
552
                .map(TryFrom::try_from)
552
                .transpose()
552
                .map_err(|_| EP::OtherBadDocument("invalid information in `w` item"))?
552
                .unwrap_or_default();
552
            let params = items.parse_options().retain_unknown_values.map(|()| params);
552
            Ok(RelayWeightsItem { effective, params })
552
        }
    }
    impl ItemValueParseable for rs::SoftwareVersion {
552
        fn from_unparsed(mut item: parse2::UnparsedItem<'_>) -> Result<Self, EP> {
552
            item.check_no_object()?;
552
            item.args_mut()
552
                .into_remaining()
552
                .parse()
552
                .map_err(item.invalid_argument_handler("version"))
552
        }
    }
    impl ItemArgumentParseable for IgnoredPublicationTimeSp {
500
        fn from_args(a: &mut ArgumentStream) -> Result<IgnoredPublicationTimeSp, AE> {
1046
            let mut next_arg = || a.next().ok_or(AE::Missing);
500
            let _: &str = next_arg()?;
500
            let _: &str = next_arg()?;
500
            Ok(IgnoredPublicationTimeSp)
500
        }
    }
}
/// `encode` impls for types in this modulea
///
/// Separate module for a separate namespace.
mod encode_impls {
    use super::*;
    use std::result::Result;
    pub(crate) use {
        crate::encode::{ItemEncoder, ItemValueEncodable, NetdocEncodableFields},
        tor_error::Bug,
    };
    impl NetdocEncodableFields for RelayWeightsItem {
72
        fn encode_fields(&self, out: &mut NetdocEncoder) -> Result<(), Bug> {
72
            if let Some(w) = self.params.as_ref().into_retained()? {
72
                w.write_item_value_onto(out.item(Self::KEYWORD))?;
            }
72
            Ok(())
72
        }
    }
    // The NormalItemArgument bound ensures that this is applied only to sane types eg integers
    impl<T: NormalItemArgument + Ord + Display> ItemValueEncodable for NetParams<T> {
124
        fn write_item_value_onto(&self, mut out: ItemEncoder) -> Result<(), Bug> {
628
            for (k, v) in self.iter().collect::<BTreeSet<_>>() {
628
                if k.is_empty()
626
                    || k.chars()
7819
                        .any(|c| c.is_whitespace() || c.is_control() || c == '=')
                {
                    // TODO torspec#401 see TODO in NetParams<T> definition
8
                    return Err(bad_api_usage!(
8
                        "tried to encode NetParms with unreasonable keyword {k:?}"
8
                    ));
620
                }
620
                out.args_raw_string(&format_args!("{k}={v}"));
            }
116
            Ok(())
124
        }
    }
    impl ItemValueEncodable for rs::SoftwareVersion {
72
        fn write_item_value_onto(&self, mut out: ItemEncoder) -> Result<(), Bug> {
72
            out.args_raw_string(self);
72
            Ok(())
72
        }
    }
    impl ItemArgument for IgnoredPublicationTimeSp {
48
        fn write_arg_onto(&self, out: &mut ItemEncoder) -> Result<(), Bug> {
48
            out.args_raw_string(&"2000-01-01 00:00:01");
48
            Ok(())
48
        }
    }
}
impl ConsensusFooterFields {
    /// Parse a directory footer from a footer section.
377
    fn from_section(sec: &Section<'_, NetstatusKwd>) -> crate::Result<ConsensusFooterFields> {
        use NetstatusKwd::*;
377
        sec.required(DIRECTORY_FOOTER)?;
377
        let bandwidth_weights = sec
377
            .maybe(BANDWIDTH_WEIGHTS)
377
            .args_as_str()
377
            .unwrap_or("")
377
            .parse()?;
375
        Ok(ConsensusFooterFields {
375
            bandwidth_weights,
375
            __non_exhaustive: (),
375
        })
377
    }
}
/// `ProtoStatuses` parsing and encoding
///
/// Separate module for separate namespace
mod proto_statuses_parse2_encode {
    use super::encode_impls::*;
    use super::parse2_impls::*;
    use super::*;
    use paste::paste;
    use std::result::Result;
    /// Implements `NetdocParseableFields` for `ProtoStatuses`
    ///
    /// We have this macro so that it's impossible to write things like
    /// ```text
    ///      ProtoStatuses {
    ///          client: ProtoStatus {
    ///              recommended: something something recommended_relay_versions something,
    /// ```
    ///
    /// (The structure of `ProtoStatuses` means the normal parse2 derive won't work for it.
    /// Note the bug above: the recommended *relay* version info is put in the *client* field.
    /// Preventing this bug must involve: avoiding writing twice the field name elements,
    /// such as `relay` and `client`, during this kind of construction/conversion.)
    macro_rules! impl_proto_statuses { { $( $rr:ident $cr:ident; )* } => { paste! {
        #[derive(Deftly)]
        #[derive_deftly(NetdocParseableFields)]
        // Only ProtoStatusesParseNetdocParseAccumulator is exposed.
        #[allow(unreachable_pub)]
        pub struct ProtoStatusesParseHelper {
            $(
                #[deftly(netdoc(default))]
                [<$rr _ $cr _protocols>]: Protocols,
            )*
        }
        /// Partially parsed `ProtoStatuses`
        pub use ProtoStatusesParseHelperNetdocParseAccumulator
            as ProtoStatusesNetdocParseAccumulator;
        impl NetdocParseableFields for ProtoStatuses {
            type Accumulator = ProtoStatusesNetdocParseAccumulator;
2732
            fn is_item_keyword(kw: KeywordRef<'_>) -> bool {
2732
                ProtoStatusesParseHelper::is_item_keyword(kw)
2732
            }
928
            fn accumulate_item(
928
                acc: &mut Self::Accumulator,
928
                item: UnparsedItem<'_>,
928
            ) -> Result<(), EP> {
928
                ProtoStatusesParseHelper::accumulate_item(acc, item)
928
            }
232
            fn finish(acc: Self::Accumulator, items: &ItemStream<'_>) -> Result<Self, EP> {
232
                let parse = ProtoStatusesParseHelper::finish(acc, items)?;
232
                let mut out = ProtoStatuses::default();
                $(
232
                    out.$cr.$rr = parse.[< $rr _ $cr _protocols >];
                )*
232
                Ok(out)
232
            }
        }
        impl NetdocEncodableFields for ProtoStatuses {
12
            fn encode_fields(&self, out: &mut NetdocEncoder) -> Result<(), Bug> {
              $(
12
                self.$cr.$rr.write_item_value_onto(
12
                    out.item(concat!(stringify!($rr), "-", stringify!($cr), "-protocols"))
                )?;
              )*
12
                Ok(())
12
            }
        }
    } } }
    impl_proto_statuses! {
        recommended client;
        recommended relay;
        required client;
        required relay;
    }
}
impl Signature {
    /// Parse a Signature from a directory-signature section
1127
    fn from_item(item: &Item<'_, NetstatusKwd>) -> crate::Result<Signature> {
1127
        if item.kwd() != NetstatusKwd::DIRECTORY_SIGNATURE {
            return Err(Error::from(internal!(
                "Wrong keyword {:?} for directory signature",
                item.kwd()
            ))
            .at_pos(item.pos()));
1127
        }
1127
        let (digest_algo, id_fp, sk_fp) = if item.n_args() > 2 {
            (
1119
                item.required_arg(0)?,
1119
                item.required_arg(1)?,
1119
                item.required_arg(2)?,
            )
        } else {
            // TODO #2530 digest_algo needs to depend on whether SHA1 was stated
8
            ("sha1", item.required_arg(0)?, item.required_arg(1)?)
        };
1127
        let digest_algo = digest_algo.to_string().parse().void_unwrap();
1127
        let digest_algo = DigestAlgoInSignature(Some(digest_algo));
1127
        let id_fingerprint = id_fp.parse::<Fingerprint>()?.into();
1127
        let sk_fingerprint = sk_fp.parse::<Fingerprint>()?.into();
1127
        let key_ids = AuthCertKeyIds {
1127
            id_fingerprint,
1127
            sk_fingerprint,
1127
        };
1127
        let signature = item.obj("SIGNATURE")?;
1127
        Ok(Signature {
1127
            digest_algo,
1127
            key_ids,
1127
            signature,
1127
        })
1127
    }
    /// Return true if this signature has the identity key and signing key
    /// that match a given cert.
1115
    fn matches_cert(&self, cert: &AuthCert) -> bool {
1115
        cert.key_ids() == self.key_ids
1115
    }
    /// If possible, find the right certificate for checking this signature
    /// from among a slice of certificates.
1311
    fn find_cert<'a>(&self, certs: &'a [AuthCert]) -> Option<&'a AuthCert> {
1651
        certs.iter().find(|&c| self.matches_cert(c))
1311
    }
    /// Find the certificate and assemble the pieces ready for verification
    ///
    /// `None` means precisely that we're missing the authcert.
319
    fn signature_to_verify<'r>(
319
        &'r self,
319
        signed_digest: &'r [u8],
319
        certs: &'r [AuthCert],
319
    ) -> Option<ConsensusSignatureToVerify> {
319
        let cert = self.find_cert(certs)?;
238
        let key = cert.signing_key();
238
        Some(ConsensusSignatureToVerify {
238
            key,
238
            signed_digest,
238
            signature: &self.signature,
238
        })
319
    }
}
impl EncodeOrd for Signature {
44
    fn encode_cmp(&self, other: &Self) -> std::cmp::Ordering {
110
        let k: for<'s> fn(&'_ Signature) -> (&'_ _, &'_ _) = |s| (&s.key_ids, &s.signature);
44
        Ord::cmp(&k(self), &k(other))
44
    }
}
/// Signature information in a consensus, to be verified
///
/// Used by callers of [`SignatureGroup::verify_general`],
/// to allow verification to be suppressed if all we wanted to know was
/// whether we have enough signatures and enough authcerts.
#[derive(Debug, Clone, Copy)]
struct ConsensusSignatureToVerify<'r> {
    /// KP_auth_sign_rsa
    key: &'r ll::pk::rsa::PublicKey,
    /// The digest (actual RSA signature payload, before PKCS#11 padding)
    signed_digest: &'r [u8],
    /// The RSA signature value
    signature: &'r [u8],
}
/// Token indicating that signature verification has been done, if required
///
/// Prevents accidentally passing an unintended no-op function as
/// `do_verify` to [`SignatureGroup::verify_general`].
///
/// Write `SignatureVerifiedIfIntended {}` to construct this,
/// only in code which has actually done the verification,
/// or code which is deliberately not verifying at all.
pub(crate) struct SignatureVerifiedIfIntended {}
impl<'r> ConsensusSignatureToVerify<'r> {
    /// Verify this signature
    ///
190
    fn verify(self) -> Result<SignatureVerifiedIfIntended, VerifyFailed> {
190
        self.key.verify(self.signed_digest, self.signature)?;
180
        Ok(SignatureVerifiedIfIntended {})
190
    }
}
/// How `verify_general` should decide who is a trusted authority
///
/// Don't use this for other purposes
#[derive(Debug, Clone, Copy)]
pub(crate) enum VerifyGeneralTrustedAuthorities<'r> {
    /// Trust these authorities.
    TrustThese {
        /// The HKP_auth_id_rsa
        trusted: &'r [RsaIdentity],
    },
    /// Document is a a vote, so OK if signed by any one of the listed authorities
    AnyOneOfThese {
        /// The HKP_auth_id_rsa
        trusted: &'r [RsaIdentity],
    },
    /// For the benefit of `SignatureGroup::validate`, used by the old parser, only
    ///
    /// Every `AuthCert` passed to `verify_general` is a real authority (!)
    /// (But not necessarily a different one!)
    HazardouslyAssumeAllAuthCertsAreReal {
        /// Total number of authorities that we trust
        ///
        /// Used only to calculate the threshold
        n_authorities: usize,
    },
}
/// Return the minimum number of authorities that we need signatures from
///
/// Enough is strictly more than half.
///
/// The returned value is a [`RangeFrom`](std::ops::RangeFrom), ie an inclusive range.
/// Its `start` value is the minimum acceptable number of authorities
/// from whom we have good signatures.
///
/// Should usually be followed by
/// [`.contains`](std::ops::RangeFrom::contains)`(&actual_number)`.
///
/// # Example
///
/// ```
/// use tor_netdoc::{doc::netstatus::consensus_threshold, parse2::VerifyFailed};
/// # fn main() -> Result<(), VerifyFailed> {
///
/// let n_trusted_authorities = 3;
/// let n_good_signatures_from_different_authorities = 2;
///
/// if consensus_threshold(n_trusted_authorities)
///      .contains(&n_good_signatures_from_different_authorities)
/// {
///     Ok(())
/// } else {
///     Err(VerifyFailed::InsufficientTrustedSigners)
/// }
/// # }
/// ```
712
pub fn consensus_threshold(n_authorities: usize) -> std::ops::RangeFrom<usize> {
712
    (n_authorities / 2) + 1 // strict majority
712
        ..
712
}
impl SignatureGroup {
    // TODO: these functions are pretty similar and could probably stand to be
    // refactored a lot.
    /// Helper: Return a pair of the number of possible authorities'
    /// signatures in this object for which we _could_ find certs, and
    /// a list of the signatures we couldn't find certificates for.
330
    fn list_missing(&self, certs: &[AuthCert]) -> (usize, Vec<&Signature>) {
330
        let mut ok: HashSet<RsaIdentity> = HashSet::new();
330
        let mut missing = Vec::new();
992
        for sig in &self.signatures {
992
            let id_fingerprint = &sig.key_ids.id_fingerprint;
992
            if ok.contains(id_fingerprint) {
                continue;
992
            }
992
            if sig.find_cert(certs).is_some() {
183
                ok.insert(*id_fingerprint);
183
                continue;
809
            }
809
            missing.push(sig);
        }
330
        (ok.len(), missing)
330
    }
    /// Given a list of authority identity key fingerprints, return true if
    /// this signature group is _potentially_ well-signed according to those
    /// authorities.
275
    fn could_validate(&self, authorities: &[&RsaIdentity]) -> bool {
275
        let mut signed_by: HashSet<RsaIdentity> = HashSet::new();
829
        for sig in &self.signatures {
829
            let id_fp = &sig.key_ids.id_fingerprint;
829
            if signed_by.contains(id_fp) {
                // Already found this in the list.
                continue;
829
            }
829
            if authorities.contains(&id_fp) {
442
                signed_by.insert(*id_fp);
442
            }
        }
275
        consensus_threshold(authorities.len()).contains(&signed_by.len())
275
    }
    /// Return true if the signature group defines a valid signature.
    ///
    /// A signature is valid if it signed by more than half of the
    /// authorities.  This API requires that `n_authorities` is the number of
    /// authorities we believe in, and that every cert in `certs` belongs
    /// to a real authority.
59
    fn validate(&self, n_authorities: usize, certs: &[AuthCert]) -> Result<(), VerifyFailed> {
        // TODO we ought to take the set of trusted authorities as an argument,
        // rather than use VGTA::HazardouslyAssumeAllAuthCertsAreReal.
59
        self.verify_general(
59
            VerifyGeneralTrustedAuthorities::HazardouslyAssumeAllAuthCertsAreReal { n_authorities },
59
            certs,
122
            |tv| tv.verify(),
        )
59
    }
    /// Check signatures (maybe), but not timeliness
    ///
    /// Examines the signatures and collates them with authcerts.
    /// Performs the necessary consensus signature verifications, via `do_verify`.
    ///
    /// If there are not enough authcerts or not enough signatures,
    /// throws a `ConsensusVerifiabilityError`.
    ///
    /// Differs from [`SignatureGroup::validate`]:
    ///
    ///  * Intended also for use with types from parse2.
    ///
    ///  * Yields information about missing authcerts directly in the return value,
    ///    and can be used without actually doing the verification,
    ///    so there's no need for a separate "which certs are we missing" function.
    ///
    ///  * Threshold is passed as a parameter (wanted for votes).
    ///
    ///  * Ability to check authority identities, by passing `trusted_authorities`.
    ///    (done with `authorities_are_correct` in old parser,
    ///    apparently with no engineered safeguard against consensus user omitting to do so).
    ///
    ///    **If `trusted_authorities` is None, all authorities in `certs` are treated as trusted**.
    ///
    ///  * Returns `Result`, not a boolean
    ///
    ///  * We prefer the term `verify` to `validate`.  All this does is signature verification.
    ///
107
    fn verify_general<E>(
107
        &self,
107
        trusted_authorities: VerifyGeneralTrustedAuthorities,
107
        certs: &[AuthCert],
107
        do_verify: impl Fn(ConsensusSignatureToVerify) -> Result<SignatureVerifiedIfIntended, E>,
107
    ) -> Result<(), E>
107
    where
107
        ConsensusVerifiabilityError: Into<E>,
    {
        use VerifyGeneralTrustedAuthorities as TA;
        // A set of the authorities (by identity) who have have signed
        // this document.  We use a set here in case `certs` has more
        // than one certificate for a single authority.
107
        let mut ok: HashSet<RsaIdentity> = HashSet::new();
107
        let mut missing = HashSet::new();
107
        let mut verify_failed = Ok(());
335
        for sig in &self.signatures {
            // Exhaustive pattern makes it hard to accidentally ignore a field.
            let Signature {
335
                digest_algo,
                key_ids:
                    AuthCertKeyIds {
335
                        id_fingerprint,
                        // h_kp_auth_sign_rsa, which Signature::check_signature
                        // checks against the authcert.
                        sk_fingerprint: _,
                    },
                // Used by Signature::check_signature
                signature: _,
335
            } = sig;
335
            match trusted_authorities {
152
                TA::TrustThese { trusted } | TA::AnyOneOfThese { trusted } => {
156
                    if !trusted.contains(id_fingerprint) {
16
                        continue;
140
                    }
                }
179
                TA::HazardouslyAssumeAllAuthCertsAreReal { .. } => {
179
                    // OK then!
179
                }
            }
319
            if ok.contains(id_fingerprint) {
                // We already checked at least one signature using this
                // authority's identity fingerprint.
                continue;
319
            }
319
            let Some(d) = self.hashes.hash_slice_for_verification(digest_algo) else {
                // We don't support this kind of digest for this kind
                // of document.
                continue;
            };
319
            let Some(tv) = sig.signature_to_verify(d, certs) else {
81
                missing.insert(sig.key_ids);
81
                continue;
            };
238
            match do_verify(tv) {
228
                Ok::<SignatureVerifiedIfIntended, _>(_) => {
228
                    ok.insert(*id_fingerprint);
228
                }
10
                Err(e) => {
10
                    verify_failed = Err(e);
10
                }
            }
        }
107
        let n_authorities = match trusted_authorities {
44
            TA::TrustThese { trusted } => trusted.len(),
59
            TA::HazardouslyAssumeAllAuthCertsAreReal { n_authorities: n } => n,
            TA::AnyOneOfThese { .. } => {
                // strict majority of 1 is 1, so n_authorites being 1 leads to threshold of 1
                // (doing it this way avoids having both thresholds and authority counts
                // in the same code area, which might lead to confusing one with the other.
4
                1
            }
        };
107
        let threshold = consensus_threshold(n_authorities);
107
        if threshold.contains(&ok.len()) {
75
            Ok(())
        } else {
            // Throw the verification error if any of the verifications failed
32
            verify_failed?;
            // Otherwise report that we're missing certs and/or signers
26
            Err(if missing.is_empty() {
16
                ConsensusVerifiabilityError::InsufficientTrustedSigners
            } else {
10
                let deficit = threshold.start - ok.len();
10
                ConsensusVerifiabilityError::MissingAuthCerts { missing, deficit }
            }
26
            .into())
        }
107
    }
}
impl From<ConsensusVerifiabilityError> for VerifyFailed {
2
    fn from(cve: ConsensusVerifiabilityError) -> VerifyFailed {
        use ConsensusVerifiabilityError as CVE;
        use VerifyFailed as VF;
2
        match cve {
            CVE::InsufficientTrustedSigners => VF::InsufficientTrustedSigners,
2
            CVE::MissingAuthCerts { .. } => VF::InsufficientTrustedSigners,
        }
2
    }
}
impl From<ConsensusVerifyFailed> for VerifyFailed {
    fn from(cvf: ConsensusVerifyFailed) -> VerifyFailed {
        use ConsensusVerifyFailed as CVF;
        use VerifyFailed as VF;
        match cvf {
            CVF::CertificationInsufficient { .. } => VF::InsufficientTrustedSigners,
            CVF::InvalidSignature { .. } => VF::VerifyFailed,
        }
    }
}
#[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 super::*;
    use crate::doc::authcert::AuthCertUnverified;
    use crate::encode::{NetdocEncodable, NetdocEncodableFields};
    use crate::parse2::{ParseInput, parse_netdoc, parse_netdoc_multiple};
    use crate::test_support::regsub;
    use anyhow::Context as _;
    use assert_matches::assert_matches;
    use hex_literal::hex;
    use humantime::parse_rfc3339;
    use std::fmt::Debug;
    use std::fs;
    use std::time::Duration;
    use tor_checkable::TimeBound;
    const CERTS: &str = include_str!("../../testdata/authcerts2.txt");
    const CONSENSUS: &str = include_str!("../../testdata/mdconsensus1.txt");
    const PLAIN_CERTS: &str = include_str!("../../testdata2/cached-certs");
    const PLAIN_CONSENSUS: &str = include_str!("../../testdata2/cached-consensus");
    fn read_bad(fname: &str) -> String {
        use std::fs;
        use std::path::PathBuf;
        let mut path = PathBuf::from(env!("CARGO_MANIFEST_DIR"));
        path.push("testdata");
        path.push("bad-mdconsensus");
        path.push(fname);
        fs::read_to_string(path).unwrap()
    }
    #[test]
    fn parse_and_validate_md() -> crate::Result<()> {
        use std::net::SocketAddr;
        use tor_checkable::{SelfSigned, TimeBound};
        let mut certs = Vec::new();
        for cert in AuthCert::parse_multiple(CERTS)? {
            let cert = cert?.check_signature()?.dangerously_assume_timely();
            certs.push(cert);
        }
        let auth_ids: Vec<_> = certs.iter().map(|c| c.id_fingerprint()).collect();
        assert_eq!(certs.len(), 3);
        let (_, _, consensus) = MdConsensus::parse(CONSENSUS)?;
        let consensus = consensus.dangerously_assume_timely().set_n_authorities(3);
        // The set of authorities we know _could_ validate this cert.
        assert!(consensus.authorities_are_correct(&auth_ids));
        // A subset would also work.
        assert!(consensus.authorities_are_correct(&auth_ids[0..1]));
        {
            // If we only believe in an authority that isn't listed,
            // that won't work.
            let bad_auth_id = (*b"xxxxxxxxxxxxxxxxxxxx").into();
            assert!(!consensus.authorities_are_correct(&[&bad_auth_id]));
        }
        let missing = consensus.key_is_correct(&[]).err().unwrap();
        assert_eq!(3, missing.len());
        assert!(consensus.key_is_correct(&certs).is_ok());
        let missing = consensus.key_is_correct(&certs[0..1]).err().unwrap();
        assert_eq!(2, missing.len());
        // here is a trick that had better not work.
        let same_three_times = vec![certs[0].clone(), certs[0].clone(), certs[0].clone()];
        let missing = consensus.key_is_correct(&same_three_times).err().unwrap();
        assert_eq!(2, missing.len());
        assert!(consensus.is_well_signed(&same_three_times).is_err());
        assert!(consensus.key_is_correct(&certs).is_ok());
        let consensus = consensus.check_signature(&certs)?;
        assert_eq!(6, consensus.relays().len());
        let r0 = &consensus.relays()[0];
        assert_eq!(
            r0.md_digest(),
            &hex!("73dabe0a0468f4f7a67810a18d11e36731bb1d2ec3634db459100609f3b3f535")
        );
        assert_eq!(
            r0.rsa_identity().as_bytes(),
            &hex!("0a3057af2910415794d8ea430309d9ac5f5d524b")
        );
        assert!(!r0.weight().is_measured());
        assert!(!r0.weight().is_nonzero());
        let pv = &r0.protovers();
        assert!(pv.supports_subver("HSDir", 2));
        assert!(!pv.supports_subver("HSDir", 3));
        let ip4 = "127.0.0.1:5002".parse::<SocketAddr>().unwrap();
        let ip6 = "[::1]:5002".parse::<SocketAddr>().unwrap();
        assert!(r0.addrs().any(|a| a == ip4));
        assert!(r0.addrs().any(|a| a == ip6));
        Ok(())
    }
    #[test]
    fn parse_and_validate_ns() -> crate::Result<()> {
        use tor_checkable::{SelfSigned, TimeBound};
        let mut certs = Vec::new();
        for cert in AuthCert::parse_multiple(PLAIN_CERTS)? {
            let cert = cert?.check_signature()?.dangerously_assume_timely();
            certs.push(cert);
        }
        let auth_ids: Vec<_> = certs.iter().map(|c| c.id_fingerprint()).collect();
        assert_eq!(certs.len(), 4);
        let (_, _, consensus) = PlainConsensus::parse(PLAIN_CONSENSUS)?;
        let consensus = consensus.dangerously_assume_timely().set_n_authorities(3);
        // The set of authorities we know _could_ validate this cert.
        assert!(consensus.authorities_are_correct(&auth_ids));
        // A subset would also work.
        assert!(consensus.authorities_are_correct(&auth_ids[0..1]));
        assert!(consensus.key_is_correct(&certs).is_ok());
        let _consensus = consensus.check_signature(&certs)?;
        Ok(())
    }
    #[test]
    fn test_bad() {
        use crate::Pos;
        fn check(fname: &str, e: &Error) {
            let content = read_bad(fname);
            let res = MdConsensus::parse(&content);
            assert!(res.is_err());
            assert_eq!(&res.err().unwrap(), e);
        }
        check(
            "bad-flags",
            &EK::BadArgument
                .at_pos(Pos::from_line(27, 1))
                .with_msg("Flags out of order"),
        );
        check(
            "bad-md-digest",
            &EK::BadArgument
                .at_pos(Pos::from_line(40, 3))
                .with_msg("Invalid base64"),
        );
        check(
            "bad-weight",
            &EK::BadArgument
                .at_pos(Pos::from_line(67, 141))
                .with_msg("invalid digit found in string"),
        );
        check(
            "bad-weights",
            &EK::BadArgument
                .at_pos(Pos::from_line(51, 13))
                .with_msg("invalid digit found in string"),
        );
        check(
            "wrong-order",
            &EK::WrongSortOrder.at_pos(Pos::from_line(52, 1)),
        );
        check(
            "wrong-start",
            &EK::UnexpectedToken
                .with_msg("vote-status")
                .at_pos(Pos::from_line(1, 1)),
        );
        check("wrong-version", &EK::BadDocumentVersion.with_msg("10"));
    }
    fn gettok(s: &str) -> crate::Result<Item<'_, NetstatusKwd>> {
        let mut reader = NetDocReader::new(s)?;
        let tok = reader.next().unwrap();
        assert!(reader.next().is_none());
        tok
    }
    #[test]
    fn test_weight() {
        let w = gettok("w Unmeasured=1 Bandwidth=6\n").unwrap();
        let w = RelayWeightsItem::from_item(&w).unwrap();
        assert!(!w.effective.is_measured());
        assert!(w.effective.is_nonzero());
        let w = gettok("w Bandwidth=10\n").unwrap();
        let w = RelayWeightsItem::from_item(&w).unwrap();
        assert!(w.effective.is_measured());
        assert!(w.effective.is_nonzero());
        let w = RelayWeightsItem::new_no_info();
        assert!(!w.effective.is_measured());
        assert!(!w.effective.is_nonzero());
        let w = gettok("w Mustelid=66 Cheato=7 Unmeasured=1\n").unwrap();
        let w = RelayWeightsItem::from_item(&w).unwrap();
        assert!(!w.effective.is_measured());
        assert!(!w.effective.is_nonzero());
        let w = gettok("r foo\n").unwrap();
        let w = RelayWeightsItem::from_item(&w);
        assert!(w.is_err());
        let w = gettok("r Bandwidth=6 Unmeasured=Frog\n").unwrap();
        let w = RelayWeightsItem::from_item(&w);
        assert!(w.is_err());
        let w = gettok("r Bandwidth=6 Unmeasured=3\n").unwrap();
        let w = RelayWeightsItem::from_item(&w);
        assert!(w.is_err());
    }
    #[test]
    fn test_netparam() {
        let p = "Hello=600 Goodbye=5 Fred=7"
            .parse::<NetParams<u32>>()
            .unwrap();
        assert_eq!(p.get("Hello"), Some(&600_u32));
        let p = "Hello=Goodbye=5 Fred=7".parse::<NetParams<u32>>();
        assert!(p.is_err());
        let p = "Hello=Goodbye Fred=7".parse::<NetParams<u32>>();
        assert!(p.is_err());
        for bad_kw in ["What=The", "", "\n", "\0"] {
            let p = [(bad_kw, 42)].into_iter().collect::<NetParams<i32>>();
            let mut d = NetdocEncoder::new();
            let d = (|| {
                let i = d.item("bad-psrams");
                p.write_item_value_onto(i)?;
                d.finish()
            })();
            let _: tor_error::Bug = d.expect_err(bad_kw);
        }
    }
    #[test]
    fn test_sharedrand() {
        let sr =
            gettok("shared-rand-previous-value 9 5LodY4yWxFhTKtxpV9wAgNA9N8flhUCH0NqQv1/05y4\n")
                .unwrap();
        let sr = SharedRandStatus::from_item(&sr).unwrap();
        assert_eq!(sr.n_reveals, 9);
        assert_eq!(
            sr.value.0,
            hex!("e4ba1d638c96c458532adc6957dc0080d03d37c7e5854087d0da90bf5ff4e72e")
        );
        assert!(sr.timestamp.is_none());
        let sr2 = gettok(
            "shared-rand-current-value 9 \
                    5LodY4yWxFhTKtxpV9wAgNA9N8flhUCH0NqQv1/05y4 2022-01-20T12:34:56\n",
        )
        .unwrap();
        let sr2 = SharedRandStatus::from_item(&sr2).unwrap();
        assert_eq!(sr2.n_reveals, sr.n_reveals);
        assert_eq!(sr2.value.0, sr.value.0);
        assert_eq!(
            sr2.timestamp.unwrap().0,
            humantime::parse_rfc3339("2022-01-20T12:34:56Z").unwrap()
        );
        let sr = gettok("foo bar\n").unwrap();
        let sr = SharedRandStatus::from_item(&sr);
        assert!(sr.is_err());
    }
    #[test]
    fn test_protostatus() {
        let my_protocols: Protocols = "Link=7 Cons=1-5 Desc=3-10".parse().unwrap();
        let outcome = ProtoStatus {
            recommended: "Link=7".parse().unwrap(),
            required: "Desc=5".parse().unwrap(),
        }
        .check_protocols(&my_protocols);
        assert!(outcome.is_ok());
        let outcome = ProtoStatus {
            recommended: "Microdesc=4 Link=7".parse().unwrap(),
            required: "Desc=5".parse().unwrap(),
        }
        .check_protocols(&my_protocols);
        assert_eq!(
            outcome,
            Err(ProtocolSupportError::MissingRecommended(
                "Microdesc=4".parse().unwrap()
            ))
        );
        let outcome = ProtoStatus {
            recommended: "Microdesc=4 Link=7".parse().unwrap(),
            required: "Desc=5 Cons=5-12 Wombat=15".parse().unwrap(),
        }
        .check_protocols(&my_protocols);
        assert_eq!(
            outcome,
            Err(ProtocolSupportError::MissingRequired(
                "Cons=6-12 Wombat=15".parse().unwrap()
            ))
        );
    }
    #[test]
    fn serialize_protostatus() {
        let ps = ProtoStatuses {
            client: ProtoStatus {
                recommended: "Link=1-5 LinkAuth=2-5".parse().unwrap(),
                required: "Link=5 LinkAuth=3".parse().unwrap(),
            },
            relay: ProtoStatus {
                recommended: "Wombat=20-30 Knish=20-30".parse().unwrap(),
                required: "Wombat=20-22 Knish=25-27".parse().unwrap(),
            },
        };
        let json = serde_json::to_string(&ps).unwrap();
        let ps2 = serde_json::from_str(json.as_str()).unwrap();
        assert_eq!(ps, ps2);
        let ps3: ProtoStatuses = serde_json::from_str(
            r#"{
            "client":{
                "required":"Link=5 LinkAuth=3",
                "recommended":"Link=1-5 LinkAuth=2-5"
            },
            "relay":{
                "required":"Wombat=20-22 Knish=25-27",
                "recommended":"Wombat=20-30 Knish=20-30"
            }
        }"#,
        )
        .unwrap();
        assert_eq!(ps, ps3);
    }
    // consensuses are done in each_flavor.rs: see verify_error_netstatus
    #[test]
    fn verify_error_netstatus_vote() -> Result<(), anyhow::Error> {
        use VerifyFailed as VF;
        use VoteVerifyFailed as VVF;
        use vote::NetworkStatusUnverified as UV;
        let file = "testdata2/v3-status-votes--1";
        let text = fs::read_to_string(file).with_context(|| file.to_owned())?;
        let input = ParseInput::new(&text, file);
        let doc: UV = parse_netdoc(&input)?;
        let trusted = [doc.peek_alleged_authority()];
        let edit_body = |f: &dyn Fn(&mut _)| {
            let (mut body, sigs) = doc.clone().unwrap_unverified();
            f(&mut body);
            UV::from_parts(body, sigs)
        };
        // sabotage the overall signature
        {
            let mut doc = doc.clone();
            doc.sigs.sigs.directory_signature.signature.fill(0xff);
            assert_matches! {
                doc.verify(&trusted),
                Err(VVF::InvalidSignature(VF::VerifyFailed))
            }
        }
        // wrong authority
        {
            let doc = doc.clone();
            assert_matches! {
                doc.verify(&[[0x55; _].into()]),
                Err(VVF::InvalidSignature(VF::InsufficientTrustedSigners))
            }
        }
        // authcert is for a different authority
        {
            let doc = edit_body(&|body| {
                body.authority.authority.dir_source.identity.0 = [0x55; _].into();
            });
            assert_matches! {
                doc.verify(&trusted),
                Err(VVF::AuthCertWrongAuthority)
            }
        }
        // authcert is from a different time
        let with_mutated_lifetime = |f: &dyn Fn(&mut Lifetime)| {
            let doc = edit_body(&|body| f(&mut body.preamble.lifetime));
            assert_matches! {
                doc.verify(&trusted),
                Err(VVF::AuthCertWrongValidity(_))
            }
        };
        let t_past = parse_rfc3339("1990-01-01T00:02:25Z")?;
        let t_future = parse_rfc3339("2010-01-01T00:02:25Z")?;
        with_mutated_lifetime(&|lifetime| lifetime.valid_after.0 = t_future);
        with_mutated_lifetime(&|lifetime| lifetime.fresh_until.0 = t_past);
        with_mutated_lifetime(&|lifetime| lifetime.valid_until.0 = t_past);
        // syntactically invalid authcert
        {
            let mut text = text.clone();
            regsub(&mut text, "^dir-key-expires ", "dir-key-expires-SABOTAGED ");
            let input = ParseInput::new(&text, file);
            let doc: UV = parse_netdoc(&input)?;
            assert_matches! {
                doc.verify(&trusted),
                Err(VVF::AuthCertParseError(..))
            }
        }
        Ok(())
    }
    #[cfg(feature = "retain-unknown")]
    #[allow(clippy::type_complexity)]
    pub(super) fn prep_netstatus_verify<UV: NetdocParseable>(
        file: &str,
    ) -> anyhow::Result<(UV, String, Vec<AuthCert>, Vec<RsaIdentity>, SystemTime)> {
        let text = fs::read_to_string(file).with_context(|| file.to_owned())?;
        let now = parse_rfc3339("2000-01-01T00:02:25Z")?;
        let mut input = ParseInput::new(&text, file);
        input.retain_unknown_values();
        let doc: UV = parse_netdoc(&input)?;
        let certs = {
            let file = "testdata2/cached-certs";
            let text = fs::read_to_string(file)?;
            let input = ParseInput::new(&text, file);
            let certs: Vec<AuthCertUnverified> = parse_netdoc_multiple(&input)?;
            certs
                .into_iter()
                .map(|cert| cert.verify_selfcert(now))
                .collect::<Result<Vec<AuthCert>, _>>()?
        };
        let authorities = certs.iter().map(|cert| *cert.fingerprint).collect_vec();
        Ok((doc, text, certs, authorities, now))
    }
    /// Check that a network document can be parsed and regenerated, mostly identically
    ///
    /// The regenerated encoded form doesn't need to be 100% identical:
    /// it is compared with a *munged* version of the the original input file,
    /// to cope with differences between C Tor and Arti.
    ///
    /// The mungings are:
    ///
    ///  * Some fields' syntax are adjusted, where C Tor and Arti disagree
    ///    in all kinds of network document.
    ///
    ///  * Document-specific, [`MungeForRoundtrip::adjust_exp`]
    #[cfg(feature = "retain-unknown")]
    fn roundtrip_netstatus<UV, V, VE>(
        // TODO DIRAUTH use include_str!, so, at call sites
        // https://gitlab.torproject.org/tpo/core/arti/-/merge_requests/4121#note_3428675
        file: &str,
        verify: impl FnOnce(UV, &[RsaIdentity], &[AuthCert]) -> Result<TimeRangeBound<V>, VE>,
        adjust_now: Duration,
    ) -> anyhow::Result<()>
    where
        UV: NetdocParseable + NetdocParseableUnverified + MungeForRoundtrip,
        UV::Signatures: Clone + Debug + NetdocEncodableFields,
        VE: Debug + std::error::Error + Send + Sync + 'static,
        V: Debug + NetdocEncodable,
    {
        let (doc, text, certs, authorities, now) = prep_netstatus_verify::<UV>(file)?;
        let now = now + adjust_now;
        let sigs = doc.inspect_unverified().1.sigs.clone();
        let doc = verify(doc, &authorities, &certs)?.if_valid_at(&now)?;
        println!("{doc:?}");
        let mut enc = NetdocEncoder::new();
        doc.encode_unsigned(&mut enc)?;
        sigs.encode_fields(&mut enc)?;
        let enc = enc.finish()?;
        let mut exp: String = text.clone();
        // TODO DIRAUTH torspec!507 C Tor emits padded base64 in shared-rand-* items.
        regsub(
            //
            &mut exp,
            r#"^(shared-rand-.*)$"#,
            |c: &regex::Captures| {
                let mut s = c[1].to_owned();
                regsub(&mut s, r#"="#, "");
                s
            },
        );
        // We don't manage proper numerical sorting of version numbers.
        // Doing so is awkward.  See the (2nd) TODO on RecommendedTorVersions.
        regsub(
            //
            &mut exp,
            r#"^(client|server)-versions (.+)$"#,
            |c: &regex::Captures| -> String {
                format!(
                    "{}-versions {}",
                    &c[1],
                    iter_join(",", c[2].split(',').sorted()),
                )
            },
        );
        let mut regsub = |re, repl| regsub(&mut exp, re, repl);
        // C Tor writes empty versions lines with trailing space
        regsub(
            //
            r#"^((?:client|server)-versions) $"#,
            "$1",
        );
        // C Tor emits `m` in varying places: after `a` in votes,
        // and at the end of each routerstatus in md consensuses.
        // We emit it at the start of each routerstatus, right after `r`.
        regsub(
            r#"(?x)
                   ( ^    r\ .* \n     )  #  ( r  )  $1, part before where we want to put m's
                   ( (?:     .* \n )*? )  #  (.*? )  $2, the rest, before the m's
                   ( (?:  m\ .* \n )+  )  #  ( m+ )  $3, one or more m's
            "#,
            r#"$1$3$2"#,
        );
        UV::adjust_exp(&mut exp);
        assert_eq_or_diff!(&exp, &enc);
        Ok(())
    }
    trait MungeForRoundtrip {
        /// Munge `s` so that it resembles the output of C Tor
        fn adjust_exp(exp: &mut String);
    }
    /// Test that we can re-encode the consensus we parsed, and that we get the same thing back.
    ///
    /// Well, roughly the same thing.
    #[cfg(feature = "retain-unknown")]
    #[test]
    fn roundtrip_netstatus_plain() -> anyhow::Result<()> {
        roundtrip_netstatus::<plain::NetworkStatusUnverified, _, _>(
            "testdata2/cached-consensus",
            plain::NetworkStatusUnverified::verify,
            Duration::ZERO,
        )
    }
    impl MungeForRoundtrip for plain::NetworkStatusUnverified {
        fn adjust_exp(exp: &mut String) {
            let mut regsub = |re, repl| regsub(exp, re, repl);
            // We emit the optional `ns`
            // https://spec.torproject.org/dir-spec/consensus-formats.html#item:network-status-version
            regsub(
                r#"^network-status-version 3$"#,
                "network-status-version 3 ns",
            );
            // C Tor writes nontrivial values for `publication` in rs `r` items,
            // but we use a fixed string.
            // https://spec.torproject.org/dir-spec/consensus-formats.html#item:r
            regsub(
                r#"^(r \S+ \S+ \S+) \d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}"#,
                "$1 2000-01-01 00:00:01",
            );
        }
    }
    #[cfg(feature = "retain-unknown")]
    #[test]
    fn roundtrip_netstatus_md() -> anyhow::Result<()> {
        roundtrip_netstatus::<md::NetworkStatusUnverified, _, _>(
            "testdata2/cached-microdesc-consensus",
            md::NetworkStatusUnverified::verify,
            Duration::ZERO,
        )
    }
    impl MungeForRoundtrip for md::NetworkStatusUnverified {
        fn adjust_exp(exp: &mut String) {
            let mut regsub = |re, repl| regsub(exp, re, repl);
            // C Tor writes nontrivial values for `publication` in rs `r` items,
            // but we use a fixed string.
            // https://spec.torproject.org/dir-spec/consensus-formats.html#item:r
            //
            // Not the same as in plain consensus: one fewer fields!
            regsub(
                r#"^(r \S+ \S+) \d{4}-\d{2}-\d{2} \d{2}:\d{2}:\d{2}"#,
                "$1 2000-01-01 00:00:01",
            );
        }
    }
    #[cfg(feature = "retain-unknown")]
    #[test]
    fn roundtrip_netstatus_vote() -> anyhow::Result<()> {
        roundtrip_netstatus::<vote::NetworkStatusUnverified, _, _>(
            "testdata2/v3-status-votes--1",
            |doc, trusted, _| vote::NetworkStatusUnverified::verify(doc, trusted),
            Duration::from_secs(20),
        )
    }
    impl MungeForRoundtrip for vote::NetworkStatusUnverified {
        fn adjust_exp(exp: &mut String) {
            // C Tor writes items in consensuses a different order to in votes!
            // C Tor writes different stats items with different floating point formats!
            let stats_massage_entry = |e: &str| {
                let mut e = e.to_owned();
                if e.contains('.') {
                    regsub(
                        &mut e,
                        // strip trailing 0's and then trailing `.`
                        r#"(?x)^ ( (?:wfu) = [0-9.]*? )( \.? 0+ ) $"#,
                        "$1",
                    );
                }
                e
            };
            // C Tor writes stats items in votes in an apparently arbitrarily chosen order
            regsub(exp, r#"^stats (.+)$"#, |c: &regex::Captures| -> String {
                format!(
                    "stats {}",
                    iter_join(" ", c[1].split(' ').sorted().map(stats_massage_entry)),
                )
            });
            let mut regsub = |re: &_, repl| regsub(exp, re, repl);
            // C Tor writes *-protocols in an apparently arbitrarily chosen order
            regsub(
                r#"(?x)
                       ^ (recommended-relay-protocols\ .*)  \n
                         (recommended-client-protocols\ .*) \n
                         (required-relay-protocols\ .*)     \n
                         (required-client-protocols\ .*)    \n
                         (known-flags .*)$                  \n
                    "#,
                r#"$5
$2
$1
$4
$3
"#,
            );
            // C Tor emits empty `client-versions` in consensuses, but not in votes.
            // (See also the fixup in `roundtrip_netstatus`, which relates to the *syntax*)
            //
            // Some of our inputs (eg the testdata2 votes) don't contain meaningful
            // info, so to make the C Tor output match our output, add them.
            regsub(
                r#"(?x) ^ (voting-delay\ .*) \n
                          (known-flags\ .*) \n"#,
                "$1
client-versions
server-versions
$2
",
            );
            //#                         (?:  a\ .* \n )?    )   #    a? )           we want to put m's
            for missing_field in [
                "bandwidth-file-headers", // TODO DIRAUTH implement
                "bandwidth-file-digest",  // TODO DIRAUTH implement
                "flag-thresholds",        // TODO DIRAUTH implement
            ] {
                regsub(&format!(r#"^{missing_field} .*\n"#), "");
            }
        }
    }
    fn testdata_live(f: &str) -> String {
        // We implement an overrideable *prefix* rather than suffix, here,
        // so that we can access the files in a totally different directory.
        // (This is helpful with nailing-cargo, amongst other things.)
        let var = "TOR_NETDOC_TESTDATA_LIVE_PREFIX";
        let prefix = std::env::var_os(var)
            .map(|s| s.into_string().expect(var))
            .unwrap_or("testdata-live/".into());
        format!("{prefix}{f}")
    }
    #[allow(clippy::unnecessary_wraps)] // signature needs to match for roundtrip_netstatus
    fn unwrap_unverified_for_test<UV: NetdocParseableUnverified>(
        uv: UV,
        _ids: &[RsaIdentity],
        _certs: &[AuthCert],
    ) -> Result<TimeRangeBound<UV::Body>, std::convert::Infallible> {
        Ok(TimeRangeBound::new(uv.unwrap_unverified().0, ..))
    }
    #[cfg(feature = "retain-unknown")]
    #[test]
    fn roundtrip_live_plain() -> anyhow::Result<()> {
        roundtrip_netstatus::<plain::NetworkStatusUnverified, _, _>(
            &testdata_live("consensus"),
            unwrap_unverified_for_test,
            Duration::ZERO,
        )
    }
    #[cfg(feature = "retain-unknown")]
    #[test]
    fn roundtrip_live_md() -> anyhow::Result<()> {
        roundtrip_netstatus::<md::NetworkStatusUnverified, _, _>(
            &testdata_live("consensus-microdesc"),
            unwrap_unverified_for_test,
            Duration::ZERO,
        )
    }
    #[cfg(feature = "retain-unknown")]
    #[test]
    fn roundtrip_live_vote() -> anyhow::Result<()> {
        roundtrip_netstatus::<vote::NetworkStatusUnverified, _, _>(
            &testdata_live("authority"),
            unwrap_unverified_for_test,
            Duration::ZERO,
        )
    }
}