1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
|
#![cfg_attr(docsrs, feature(doc_auto_cfg, doc_cfg))]
#![doc = include_str!("../README.md")]
// TODO hs: Add complete suite of warnings here.
#![allow(dead_code, unused_variables)] // TODO hs remove.
mod keys;
mod state;
use async_trait::async_trait;
use std::sync::Arc;
use tor_hscrypto::pk::{ClientSecretKeys, HsId};
use tor_proto::circuit::ClientCirc;
use tor_circmgr::{CircMgr, OnionConnectError, OnionServiceConnector};
use tor_netdir::NetDirProvider;
use tor_rtcompat::Runtime;
/// An object that negotiates connections with onion services
pub struct HsClientConnector<R: Runtime> {
/// A [`CircMgr`] that we use to build circuits to HsDirs, introduction
/// points, and rendezvous points.
//
// TODO hs: currently this is a circular set of Arc, since the CircMgr will
// have to hold an Arc<OnionServiceConnector>. We should make one Weak.
//
// TODO hs: Maybe we can make a trait that only gives a minimal "build a
// circuit" API from CircMgr, so that we can have this be a dyn reference
// too?
circmgr: Arc<CircMgr<R>>,
/// A [`NetDirProvider`] that we use to pick rendezvous points.
//
// TODO hs: Should this be weak too?
netdir_provider: Arc<dyn NetDirProvider>,
/// Information we are remembering about different onion services.
//
// TODO hs: if we implement cache isolation or state isolation, we might
// need multiple instances of this.
state: state::StateMap,
/// A collection of private keys to be used with various onion services.
//
// TODO hs: we might even want multiple instances of this, depending on how
// we decide to do isolation.
keys: keys::Keys,
}
impl<R: Runtime> HsClientConnector<R> {
// TODO hs: Need a way to manage the set of keys.
// TODO hs: need a constructor here.
// TODO hs: need a function to clear our StateMap, or to create a new
// isolated StateMap.
//
// TODO hs: Also, we need to expose that function from `TorClient`, possibly
// in the existing isolation API, possibly in something new.
}
#[async_trait]
impl<R: Runtime> OnionServiceConnector for HsClientConnector<R> {
async fn create_connection(
&self,
service_id: HsId,
using_keys: Option<ClientSecretKeys>,
) -> Result<ClientCirc, OnionConnectError> {
todo!() // TODO hs
// This function must do the following, retrying as appropriate.
// - Look up the onion descriptor in the state.
// - Download the onion descriptor if one isn't there.
// - In parallel:
// - Pick a rendezvous point from the netdirprovider and launch a
// rendezvous circuit to it. Then send ESTABLISH_INTRO.
// - Pick a number of introduction points (1 or more) and try to
// launch circuits to them.
// - On a circuit to an introduction point, send an INTRODUCE1 cell.
// - Wait for a RENDEZVOUS2 cell on the rendezvous circuit
// - Add a virtual hop to the rendezvous circuit.
// - Return the rendezvous circuit.
}
}
|
