tachyon-web 0.0.1

A fast, Axum-compatible async web framework with native TLS, HTTP/3, Tor (.onion), and I2P (.i2p) support
Documentation 
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
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210
211
212
213
214
215
216
217
218
219
220
221
222
223
224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
253
254
255
256
257
258
259
260
261
262
263
264
265
266
267
268
269
270
271
272
273
274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
291
292
293
294
295
296
297
298
299
300
301
302
303

//! Opt-in response hardening for `.onion`/`.i2p` routes — see [`anonymity_guard`].
//!
//! Requires the `tor` or `i2p` feature (either is enough; this module has no dependency on
//! either transport's own code, it just targets the failure mode they share).

use crate::http::response::Body;
use crate::routing::middleware::Next;
use hyper::header::{self, ACCESS_CONTROL_ALLOW_ORIGIN, CONTENT_LOCATION, HeaderMap, LOCATION};
#[cfg(feature = "cookies")]
use hyper::header::{HeaderValue, SET_COOKIE};
use hyper::{Request, Response, StatusCode};

/// Middleware that hardens every response against the classic ways a `.onion`/`.i2p` deployment
/// accidentally deanonymizes itself.
///
/// Install with `.hoop(anonymity_guard)` on a [`Router`](crate::routing::Router) mounted on an
/// anonymity-network transport (see [`Server::serve_onion`](crate::server::Server::serve_onion)/
/// [`Server::serve_i2p_config`](crate::server::Server::serve_i2p_config)).
///
/// On every response, unconditionally:
/// - Strips `Date`, `Server`, and `X-Powered-By` — clock-skew and stack fingerprinting vectors
///   that a client reachable only over Tor/I2P has no legitimate need to see.
/// - Rewrites every `Set-Cookie` header to `SameSite=Strict`, dropping (not forwarding
///   unhardened) any that fail to parse — a cookie usable cross-site is a correlation vector
///   between this service and anywhere else the same browser profile is logged in.
///
/// Additionally, when the request's own `Host` header ends in `.onion` or `.i2p` (i.e. this
/// really is being reached over the anonymity network, not just mounted defensively on a
/// clearnet route too): every `Location`, `Content-Location`, and `Access-Control-Allow-Origin`
/// header is checked for an **absolute** URL whose host is neither the request's own `.onion`/
/// `.i2p` host nor itself anonymity-suffixed. This is the #1 real-world onion-site
/// deanonymization bug — a redirect, canonical-URL, or CORS header that echoes back the
/// operator's clearnet domain (shared config/templates between a clearnet site and its mirror
/// are the usual cause). Rather than silently rewrite or drop just that header (which would
/// mask the underlying bug), the entire response is replaced with a generic `500` — the leak is
/// logged server-side (`tracing::error!`) with the offending header and value for the operator
/// to fix, but never reaches the client.
///
/// This is defense-in-depth, not a substitute for reviewing what your handlers actually set —
/// see the `server::tor`/`server::i2p` module docs for the fuller anonymity threat model.
pub async fn anonymity_guard<S>(req: Request<Body>, next: Next<S>) -> Response<Body>
where
    S: Send + Sync + 'static,
{
    let request_host = req
        .headers()
        .get(header::HOST)
        .and_then(|h| h.to_str().ok())
        .map(|h| host_without_port(h).to_ascii_lowercase());

    let mut resp = next.run(req).await;

    strip_fingerprinting_headers(resp.headers_mut());
    harden_set_cookie_headers(resp.headers_mut());

    if let Some(host) = request_host.as_deref()
        && looks_like_anonymity_host(host)
        && let Err((leaked_header, leaked_value)) = check_no_clearnet_leak(resp.headers(), host)
    {
        tracing::error!(
            header = leaked_header,
            value = %leaked_value,
            request_host = host,
            "anonymity_guard: response header pointed at what looks like a clearnet origin on \
             a `.onion`/`.i2p` request — replacing the response with 500 instead of letting it \
             reach the client; fix the handler/middleware that set this header"
        );
        return Response::builder()
            .status(StatusCode::INTERNAL_SERVER_ERROR)
            .header(header::CONTENT_TYPE, "text/plain; charset=utf-8")
            .body(Body::full(bytes::Bytes::from_static(
                b"Internal Server Error",
            )))
            .unwrap_or_else(|_| Response::new(Body::empty()));
    }

    resp
}

/// Strips the `:port` suffix from a `Host` header value, if present.
fn host_without_port(host: &str) -> &str {
    host.split(':').next().unwrap_or(host)
}

// Not a file-extension check (clippy's `case_sensitive_file_extension_comparisons` doesn't
// apply) — `host` is a hostname suffix, and every caller already normalizes it with
// `to_ascii_lowercase` before calling this.
#[allow(clippy::case_sensitive_file_extension_comparisons)]
fn looks_like_anonymity_host(host: &str) -> bool {
    host.ends_with(".onion") || host.ends_with(".i2p")
}

fn strip_fingerprinting_headers(headers: &mut HeaderMap) {
    let _ = headers.remove(header::DATE);
    let _ = headers.remove(header::SERVER);
    let _ = headers.remove("x-powered-by");
}

/// Rewrites every `Set-Cookie` header to carry `SameSite=Strict`. A header that fails to parse
/// as a cookie is dropped entirely rather than forwarded unhardened.
///
/// A no-op without the `cookies` feature — the `cookie` crate this needs to parse and
/// re-serialize `Set-Cookie` values is only pulled in when that feature is on. Enable
/// `cookies` alongside `tor`/`i2p` to get this specific hardening.
#[cfg(feature = "cookies")]
fn harden_set_cookie_headers(headers: &mut HeaderMap) {
    let original: Vec<HeaderValue> = headers.get_all(SET_COOKIE).iter().cloned().collect();
    if original.is_empty() {
        return;
    }
    headers.remove(SET_COOKIE);
    for value in original {
        let hardened = value.to_str().ok().and_then(|s| {
            let mut cookie = cookie::Cookie::parse(s.to_string()).ok()?;
            cookie.set_same_site(cookie::SameSite::Strict);
            HeaderValue::from_str(&cookie.to_string()).ok()
        });
        match hardened {
            Some(hv) => {
                headers.append(SET_COOKIE, hv);
            }
            None => {
                tracing::warn!(
                    "anonymity_guard: dropped a Set-Cookie header that couldn't be parsed and \
                     hardened to SameSite=Strict"
                );
            }
        }
    }
}

#[cfg(not(feature = "cookies"))]
const fn harden_set_cookie_headers(_headers: &mut HeaderMap) {}

/// Returns `Err((header name, offending value))` for the first `Location`/`Content-Location`/
/// `Access-Control-Allow-Origin` header whose value is an absolute URL pointing at a host that
/// is neither `request_host` nor itself `.onion`/`.i2p`-suffixed.
fn check_no_clearnet_leak(
    headers: &HeaderMap,
    request_host: &str,
) -> Result<(), (&'static str, String)> {
    for (name, header_name) in [
        ("location", &LOCATION),
        ("content-location", &CONTENT_LOCATION),
        ("access-control-allow-origin", &ACCESS_CONTROL_ALLOW_ORIGIN),
    ] {
        for value in headers.get_all(header_name) {
            let Ok(s) = value.to_str() else { continue };
            let Some(host) = absolute_url_host(s) else {
                continue;
            };
            let host = host.to_ascii_lowercase();
            if host != request_host && !looks_like_anonymity_host(&host) {
                return Err((name, s.to_string()));
            }
        }
    }
    Ok(())
}

/// Extracts the host from an absolute `scheme://host[:port][/...]` URL. Returns `None` for
/// anything that isn't an absolute URL (a relative path like `/foo`, or `*`/`null` as seen in
/// `Access-Control-Allow-Origin`) — those can't point at a different origin, so there's nothing
/// to check.
fn absolute_url_host(value: &str) -> Option<&str> {
    let after_scheme = value.split_once("://")?.1;
    let host_and_rest = after_scheme
        .split(['/', '?', '#'])
        .next()
        .unwrap_or(after_scheme);
    let host_and_port = host_and_rest.rsplit('@').next().unwrap_or(host_and_rest);
    let host = host_and_port.split(':').next().unwrap_or(host_and_port);
    (!host.is_empty()).then_some(host)
}

#[cfg(test)]
mod tests {
    #![allow(clippy::unwrap_used)]
    use super::*;
    use crate::routing::{Router, get};

    fn build_app<H, T>(handler: H) -> Router
    where
        H: crate::routing::handler::Handler<T, ()> + Clone + Send + Sync + 'static,
        T: Send + Sync + 'static,
    {
        Router::new().route("/", get(handler)).hoop(anonymity_guard)
    }

    fn req_with_host(host: &str) -> Request<Body> {
        Request::builder()
            .uri("/")
            .header(header::HOST, host)
            .body(Body::empty())
            .unwrap()
    }

    #[tokio::test]
    async fn strips_date_and_server_headers() {
        async fn handler() -> Response<Body> {
            Response::builder()
                .header(header::DATE, "Mon, 01 Jan 2024 00:00:00 GMT")
                .header(header::SERVER, "tachyon-web")
                .body(Body::empty())
                .unwrap()
        }
        let app = build_app(handler);
        let resp = app.handle_request(req_with_host("abc.onion")).await;
        assert!(resp.headers().get(header::DATE).is_none());
        assert!(resp.headers().get(header::SERVER).is_none());
    }

    #[tokio::test]
    async fn forces_samesite_strict_on_cookies() {
        async fn handler() -> Response<Body> {
            Response::builder()
                .header(header::SET_COOKIE, "session=abc; Path=/")
                .body(Body::empty())
                .unwrap()
        }
        let app = build_app(handler);
        let resp = app.handle_request(req_with_host("abc.onion")).await;
        let cookie = resp
            .headers()
            .get(header::SET_COOKIE)
            .unwrap()
            .to_str()
            .unwrap();
        assert!(cookie.contains("SameSite=Strict"), "cookie: {cookie}");
    }

    #[tokio::test]
    async fn blocks_response_leaking_a_clearnet_redirect() {
        async fn handler() -> Response<Body> {
            Response::builder()
                .status(StatusCode::FOUND)
                .header(header::LOCATION, "https://my-real-site.example/dashboard")
                .body(Body::empty())
                .unwrap()
        }
        let app = build_app(handler);
        let resp = app.handle_request(req_with_host("abc.onion")).await;
        assert_eq!(resp.status(), StatusCode::INTERNAL_SERVER_ERROR);
        assert!(resp.headers().get(header::LOCATION).is_none());
    }

    #[tokio::test]
    async fn allows_relative_redirects() {
        async fn handler() -> Response<Body> {
            Response::builder()
                .status(StatusCode::FOUND)
                .header(header::LOCATION, "/dashboard")
                .body(Body::empty())
                .unwrap()
        }
        let app = build_app(handler);
        let resp = app.handle_request(req_with_host("abc.onion")).await;
        assert_eq!(resp.status(), StatusCode::FOUND);
    }

    #[tokio::test]
    async fn allows_redirects_to_the_same_onion_host() {
        async fn handler() -> Response<Body> {
            Response::builder()
                .status(StatusCode::FOUND)
                .header(header::LOCATION, "http://abc.onion/dashboard")
                .body(Body::empty())
                .unwrap()
        }
        let app = build_app(handler);
        let resp = app.handle_request(req_with_host("abc.onion")).await;
        assert_eq!(resp.status(), StatusCode::FOUND);
    }

    #[tokio::test]
    async fn does_not_check_leaks_on_a_non_anonymity_host() {
        async fn handler() -> Response<Body> {
            Response::builder()
                .status(StatusCode::FOUND)
                .header(header::LOCATION, "https://example.com/dashboard")
                .body(Body::empty())
                .unwrap()
        }
        let app = build_app(handler);
        let resp = app.handle_request(req_with_host("clearnet.example")).await;
        assert_eq!(resp.status(), StatusCode::FOUND);
    }

    #[test]
    fn absolute_url_host_examples() {
        assert_eq!(
            absolute_url_host("https://example.com/foo"),
            Some("example.com")
        );
        assert_eq!(
            absolute_url_host("http://abc.onion:8080/foo"),
            Some("abc.onion")
        );
        assert_eq!(absolute_url_host("/relative/path"), None);
        assert_eq!(absolute_url_host("*"), None);
        assert_eq!(absolute_url_host("null"), None);
    }
}