tor_hsservice/
internal_prelude.rs

1//! Imports used internally within this crate
2//!
3//! This file contains most of the imports we wish to use, throughout this crate.
4//!
5//! Every module does `use crate::internal_prelude::*;`
6//!
7//! Exceptions:
8//!
9//!  * Names that are private to a module and its submodules (eg, `publish`)
10//!    are imported to the sub-modules via `use super::*`.
11//!    (Thus, the sub-module inherits the prelude from its parent.)
12//!
13//!  * Broad names from specific contexts, that are unsuitable for wide imports.
14//!    For example, individual cell and message names from `tor-cell`,
15//!    and the types from `tor_proto::client::stream` other than the high-level `DataStream`.
16
17//---------- std ----------
18
19pub(crate) use {
20    std::any::Any,
21    std::borrow::Cow,
22    std::cmp::Ordering,
23    std::cmp::max,
24    std::collections::{BinaryHeap, HashMap, HashSet, VecDeque},
25    std::error::Error as StdError,
26    std::ffi::OsStr,
27    std::fmt::{self, Debug, Display},
28    std::fs,
29    std::fs::{File, OpenOptions},
30    std::future::Future,
31    std::hash::Hash,
32    std::io,
33    std::io::{BufReader, BufWriter, Read, Seek, SeekFrom, Write},
34    std::iter,
35    std::marker::PhantomData,
36    std::panic::AssertUnwindSafe,
37    std::path::{Path, PathBuf},
38    std::str::FromStr,
39    std::sync::{Arc, Mutex, MutexGuard},
40};
41
42//---------- upstreams ----------
43
44pub(crate) use {
45    async_trait::async_trait,
46    derive_builder::Builder,
47    derive_deftly::{Deftly, define_derive_deftly},
48    derive_more::{Constructor, Deref, DerefMut, Into},
49    educe::Educe,
50    futures::channel::mpsc,
51    futures::future::{self, Either},
52    futures::select_biased,
53    futures::stream::BoxStream,
54    futures::task::SpawnError,
55    futures::{AsyncRead, AsyncWrite, Stream},
56    futures::{FutureExt as _, SinkExt as _, StreamExt as _, TryStreamExt as _},
57    itertools::{Itertools as _, chain},
58    postage::{broadcast, watch},
59    rand::Rng,
60    rand_core::{CryptoRng, RngCore},
61    serde::{Deserialize, Deserializer, Serialize, Serializer},
62    thiserror::Error,
63    tor_rtcompat::SpawnExt as _,
64    tracing::{debug, error, info, trace, warn},
65    void::{ResultVoidErrExt as _, Void},
66};
67
68//---------- tor-* crates ----------
69
70pub(crate) use {
71    oneshot_fused_workaround as oneshot,
72    retry_error::RetryError,
73    safelog::{DisplayRedacted as _, Redactable as _},
74    tor_async_utils::mpsc_channel_no_memquota,
75    tor_async_utils::{DropNotifyWatchSender, PostageWatchSenderExt as _},
76    tor_basic_utils::{PathExt as _, RngExt as _, impl_debug_hex, retry::RetryDelay},
77    tor_cell::relaycell::{RelayMsg as _, msg::AnyRelayMsg},
78    tor_circmgr::hspool::HsCircPool,
79    tor_config::{ConfigBuildError, Reconfigure, ReconfigureError},
80    tor_dirclient::request::HsDescUploadRequest,
81    tor_dirclient::{Error as DirClientError, RequestFailedError, send_request},
82    tor_error::define_asref_dyn_std_error,
83    tor_error::{Bug, ErrorKind, ErrorReport as _, HasKind},
84    tor_error::{bad_api_usage, internal, into_bad_api_usage, into_internal},
85    tor_error::{debug_report, error_report, info_report, warn_report},
86    tor_hscrypto::RevisionCounter,
87    tor_hscrypto::ope::AesOpeKey,
88    tor_hscrypto::pk::{
89        HsBlindId, HsBlindIdKey, HsBlindIdKeypair, HsClientDescEncKey, HsDescSigningKeypair,
90        HsIdKey, HsIdKeypair, HsIntroPtSessionIdKey, HsIntroPtSessionIdKeypair, HsSvcNtorKeypair,
91    },
92    tor_hscrypto::time::TimePeriod,
93    tor_keymgr::{
94        KeyMgr, KeySpecifier, KeySpecifierComponentViaDisplayFromStr, KeySpecifierPattern as _,
95        KeystoreSelector, derive_deftly_template_KeySpecifier,
96        {ArtiPathRange, KeySpecifierComponent},
97    },
98    tor_linkspec::{CircTarget, HasRelayIds as _, OwnedCircTarget, RelayIds},
99    tor_llcrypto::pk::{curve25519, ed25519},
100    tor_log_ratelim::log_ratelim,
101    tor_netdir::{HsDirParams, NetDirProvider, Relay, Timeliness},
102    tor_netdoc::NetdocBuilder,
103    tor_netdoc::doc::hsdesc::{HsDescBuilder, create_desc_sign_key_cert},
104    tor_persist::slug::Slug,
105    tor_persist::state_dir::{
106        ContainsInstanceStateGuard as _, InstanceRawSubdir, LockFileGuard, StateDirectory,
107    },
108    tor_proto::MetaCellDisposition,
109    tor_proto::client::stream::DataStream,
110    tor_rtcompat::SleepProvider,
111    tor_rtcompat::{Runtime, SleepProviderExt as _},
112    web_time_compat::{Duration, Instant, SystemTime},
113};
114
115//---------- names from this crate ----------
116
117pub(crate) use {
118    crate::OnionServiceConfig,
119    crate::StartupError,
120    crate::StreamRequest,
121    crate::err::IptStoreError,
122    crate::err::StateExpiryError,
123    crate::ipt_lid::{InvalidIptLocalId, IptLocalId},
124    crate::ipt_mgr::IptManager,
125    crate::ipt_set::IptSet,
126    crate::ipt_set::IptsManagerView,
127    crate::ipt_set::IptsPublisherUploadView,
128    crate::ipt_set::IptsPublisherView,
129    crate::ipt_set::{self, PublishIptSet},
130    crate::keys::expire_publisher_keys,
131    crate::keys::{IptKeyRole, IptKeySpecifier, IptKeySpecifierPattern},
132    crate::publish::Publisher,
133    crate::replay::IptReplayLog,
134    crate::replay::ReplayError,
135    crate::status::PublisherStatusSender,
136    crate::status::State,
137    crate::status::{IptMgrStatusSender, State as IptMgrState},
138    crate::status::{OnionServiceStatus, OnionServiceStatusStream, StatusSender},
139    crate::time_store,
140    crate::timeout_track::{TrackingInstantOffsetNow, TrackingNow, Update as _},
141    crate::{
142        BlindIdKeypairSpecifier, DescSigningKeypairSpecifier, HsIdKeypairSpecifier,
143        HsIdPublicKeySpecifier,
144    },
145    crate::{
146        ClientError,
147        keys::BlindIdKeypairSpecifierPattern,
148        rend_handshake::{self, RendCircConnector},
149    },
150    crate::{DescUploadError, IptError},
151    crate::{FatalError, RendRequest},
152    crate::{HsNickname, LinkSpecs, NtorPublicKey, req::RendRequestContext},
153    crate::{ShutdownStatus, ipt_establish},
154    ipt_establish::{IptEstablisher, IptParameters, IptStatus, IptStatusStatus, IptWantsToRetire},
155};
tor_hsservice/internal_prelude.rs

tor_hsservice/
internal_prelude.rs
