Skip to main content

tor_netdoc/
parse2.rs

1//! New netdoc parsing arrangements, with `derive`
2//!
3//! # Parsing principles
4//!
5//! A parseable network document is a type implementing [`NetdocParseable`].
6//! usually via the
7//! [`NetdocParseable` derive=deftly macro`](crate::derive_deftly_template_NetdocParseable).
8//!
9//! A document type is responsible for recognising its own heading item.
10//! Its parser will also be told other of structural items that it should not consume.
11//! The structural lines can then be used to pass control to the appropriate parser.
12//!
13//! A "structural item" is a netdoc item that is defines the structure of the document.
14//! This includes the intro items for whole documents,
15//! the items that introduce document sections
16//! (which we model by treating the section as a sub-document)
17//! and signature items (which introduce the signatures at the end of the document,
18//! and after which no non-signature items may appear).
19//!
20//! # Ordering
21//!
22//! We don't always parse things into a sorted order.
23//! Sorting will be done when assembling documents, before outputting.
24//!
25//! # Types, and signature handling
26//!
27//! Most top-level network documents are signed somehow.
28//! In this case there are three types:
29//!
30//!   * **`FooUnverified`**: a signed `Foo`, with its signatures, not yet verified.
31//!     Implements [`NetdocParseableUnverified`],
32//!     typically by invoking the
33//!     [`NetdocUParseablenverified` derive macro](crate::derive_deftly_template_NetdocParseableUnverified)
34//!     on `Foo`.
35//!
36//!     Type-specific methods are provided for verification,
37//!     to obtain a `Foo`.
38//!
39//!   * **`Foo`**: the body data for the document.
40//!     This doesn't contain any signatures.
41//!     Having one of these to play with means signatures have already been validated.
42//!     Can be parsed as part of the signed document,
43//!     via the `NetdocParseable` implementation on `FooUnverified`,
44//!     and then obtained via `.verify_...` method(s) on `FooUnverified`,
45//!
46//!   * **`FooSignatures`**: the signatures for a `Foo`.
47//!     Implements `NetdocParseableSignatures`, via
48//!     [derive](crate::derive_deftly_template_NetdocParseableSignatures),
49//!     with `#[deftly(netdoc(signatures))]`.
50//!
51//! # Relationship to tor_netdoc::parse
52//!
53//! This is a completely new parsing approach, based on different principles.
54//! The key principle is the recognition of "structural keywords",
55//! recursively within a parsing stack, via the p`NetdocParseable`] trait.
56//!
57//! This allows the parser to be derived.  We have type-driven parsing
58//! of whole Documents, Items, and their Arguments and Objects,
59//! including of their multiplicity.
60//!
61//! The different keyword handling means we can't use most of the existing lexer,
62//! and need new item parsing API:
63//!
64//!  * [`NetdocParseable`] trait.
65//!  * [`KeywordRef`] type.
66//!  * [`ItemStream`], [`UnparsedItem`], [`ArgumentStream`], [`UnparsedObject`].
67//!
68//! The different error handling means we have our own error types.
69//! (The crate's existing parse errors have information that we don't track,
70//! and is also a portmanteau error for parsing, writing, and other functions.)
71//!
72//! Document signing is handled in a more abstract way.
73//!
74//! Some old netdoc constructs are not supported.
75//! For example, the obsolete `opt` prefix on safe-to-ignore Items.
76//! The parser may make different decisions about netdocs with anomalous item ordering.
77
78#[doc(hidden)]
79#[macro_use]
80pub mod internal_prelude;
81
82#[macro_use]
83mod structural;
84
85#[macro_use]
86mod derive;
87
88mod error;
89mod impls;
90pub mod keyword;
91mod lex;
92mod lines;
93pub mod multiplicity;
94mod signatures;
95mod traits;
96
97use internal_prelude::*;
98
99pub use error::{ArgumentError, ErrorProblem, ParseError, UnexpectedArgument, VerifyFailed};
100pub use impls::times::NdaSystemTimeDeprecatedSyntax;
101pub use keyword::KeywordRef;
102pub use lex::{ArgumentStream, ItemStream, NoFurtherArguments, UnparsedItem, UnparsedObject};
103pub use lines::{Lines, Peeked, StrExt};
104pub use signatures::{
105    HasUnverifiedParsedBody, NetdocParseableSignatures, NetdocParseableUnverified,
106    SignatureHashInputs, SignatureHashesAccumulator, SignatureItemParseable, SignaturesData,
107    sig_hashes,
108};
109#[allow(deprecated)]
110#[deprecated]
111pub use signatures::{check_validity_time, check_validity_time_tolerance};
112pub use structural::{StopAt, StopPredicate};
113pub use traits::{
114    IsStructural, ItemArgumentParseable, ItemObjectParseable, ItemValueParseable, NetdocParseable,
115    NetdocParseableFields,
116};
117
118#[doc(hidden)]
119pub use derive::netdoc_parseable_derive_debug;
120
121pub(crate) use internal_prelude::EP;
122
123//---------- input ----------
124
125/// Options for parsing
126///
127/// Specific document and type parsing methods may use these parameters
128/// to control their parsing behaviour at run-time.
129#[derive(educe::Educe, Debug, Clone)]
130#[allow(clippy::manual_non_exhaustive)]
131#[educe(Default)]
132pub struct ParseOptions {
133    /// Retain unknown values?
134    ///
135    /// Some field types, especially for flags fields, have the capability to retain
136    /// unknown flags.  But, whereas known flags can be represented as single bits,
137    /// representing unknown flags involves allocating and copying strings.
138    /// Unless the document is to be reproduced, this is a waste of effort.
139    ///
140    /// Each document field type affected by this option should store the unknowns
141    /// as `Unknown<HashSet<String>>` or similar.
142    ///
143    /// This feature should only be used where performance is important.
144    /// For example, it is useful for types that appear in md consensus routerdescs,
145    /// but less useful for types that appear only in a netstatus preamble.
146    ///
147    /// This is currently used for router flags.
148    #[educe(Default(expression = "Unknown::new_discard()"))]
149    pub retain_unknown_values: Unknown<()>,
150
151    // Like `#[non_exhaustive]`, but doesn't prevent use of struct display syntax with `..`
152    #[doc(hidden)]
153    _private_non_exhaustive: (),
154}
155
156/// Input to a network document top-level parsing operation
157#[derive(Debug, Clone, amplify::Getters)]
158pub struct ParseInput<'s> {
159    /// The actual document text
160    #[getter(as_copy)]
161    input: &'s str,
162
163    /// Filename (for error reporting)
164    #[getter(as_copy)]
165    file: &'s str,
166
167    /// Parsing options
168    #[getter(as_ref, as_mut)]
169    options: ParseOptions,
170}
171
172impl<'s> ParseInput<'s> {
173    /// Prepare to parse an input string
174    pub fn new(input: &'s str, file: &'s str) -> Self {
175        ParseInput {
176            input,
177            file,
178            options: ParseOptions::default(),
179        }
180    }
181
182    /// Enable retention of unknown values during parsing
183    ///
184    /// Convenience method to set
185    /// [`.options_mut().retain_unknown_values`](ParseOptions::retain_unknown_values)
186    /// to [`Unknown::Retained`].
187    #[cfg(feature = "retain-unknown")]
188    pub fn retain_unknown_values(&mut self) {
189        self.options_mut().retain_unknown_values = Unknown::Retained(());
190    }
191}
192
193//---------- parser ----------
194
195/// Common code for `parse_netdoc` and `parse_netdoc_multiple`
196///
197/// Creates the `ItemStream`, calls `parse_completely`, and handles errors.
198fn parse_internal<T, D: NetdocParseable>(
199    input: &ParseInput<'_>,
200    parse_completely: impl FnOnce(&mut ItemStream) -> Result<T, ErrorProblem>,
201) -> Result<T, ParseError> {
202    let mut items = ItemStream::new(input)?;
203    parse_completely(&mut items).map_err(|problem| ParseError {
204        problem,
205        doctype: D::doctype_for_error(),
206        file: input.file.to_owned(),
207        lno: items.lno_for_error(),
208        column: problem.column(),
209    })
210}
211
212/// Parse a network document - **toplevel entrypoint**
213pub fn parse_netdoc<D: NetdocParseable>(input: &ParseInput<'_>) -> Result<D, ParseError> {
214    parse_internal::<_, D>(input, |items| {
215        let doc = D::from_items(items, StopAt(false))?;
216        if let Some(_kw) = items.peek_keyword()? {
217            return Err(EP::MultipleDocuments);
218        }
219        Ok(doc)
220    })
221}
222
223/// Parse multiple concatenated network documents - **toplevel entrypoint**
224pub fn parse_netdoc_multiple<D: NetdocParseable>(
225    input: &ParseInput<'_>,
226) -> Result<Vec<D>, ParseError> {
227    parse_internal::<_, D>(input, |items| {
228        let mut docs = vec![];
229        while items.peek_keyword()?.is_some() {
230            let doc = D::from_items(items, StopAt(false))?;
231            docs.push(doc);
232        }
233        Ok(docs)
234    })
235}
236
237/// Parse multiple network documents, also returning their offsets  - **toplevel entrypoint**
238///
239/// Each returned document is accompanied by the byte offsets of its start and end.
240///
241/// (The netdoc metaformat does not allow anything in between subsequent documents in a file,
242/// so the end of one document is the start of the next.)
243///
244/// This returns byte offsets rather than string slices,
245/// because the caller can always convert the offsets into string slices,
246/// but it is not straightforward to convert string slices borrowed from some input string
247/// into offsets, in a way that is obviously correct without nightly `str::substr_range`.
248///
249/// Interfacing code can assume that slicing the input string with the returned
250/// [`usize`] values will not cause an out-of-bounds error, meaning runtime
251/// checks are not necessary there.
252pub fn parse_netdoc_multiple_with_offsets<D: NetdocParseable>(
253    input: &ParseInput<'_>,
254) -> Result<Vec<(D, usize, usize)>, ParseError> {
255    parse_internal::<_, D>(input, |items| {
256        let mut docs = vec![];
257        while items.peek_keyword()?.is_some() {
258            let start_pos = items.byte_position();
259            let doc = D::from_items(items, StopAt(false))?;
260            let end_pos = items.byte_position();
261
262            // Check start_pos and end_pos are in range.
263            if input.input.get(start_pos..end_pos).is_none() {
264                return Err(ErrorProblem::Internal("out-of-bounds bug?"));
265            }
266
267            docs.push((doc, start_pos, end_pos));
268        }
269        Ok(docs)
270    })
271}