cebolla 0.3.0

A convenience layer over Arti for building and connecting to Tor hidden services
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

use crate::*;

use poem::{
    http::uri::Scheme,
    web::{LocalAddr, RemoteAddr},
};

/// Re-export of `poem::Server`
pub use poem::Server as HttpServer;

impl poem::listener::Acceptor for HiddenService {
    type Io = DataStream;

    fn local_addr(&self) -> Vec<poem::web::LocalAddr> {
        let mut dest = vec![];
        if let Some(addr) = self.service.onion_address() {
            dest.push(poem::web::LocalAddr(poem::Addr::Custom(
                "onion",
                addr.display_unredacted().to_string().into(),
            )));
        }
        dest
    }

    async fn accept(&mut self) -> std::io::Result<(Self::Io, LocalAddr, RemoteAddr, Scheme)> {
        loop {
            if let Some((_addr, conn)) = self.handle().await? {
                return Ok((
                    conn,
                    self.local_addr().first().cloned().unwrap_or_default(),
                    poem::web::RemoteAddr::default(), // TODO: hook up _addr
                    poem::http::uri::Scheme::HTTP,
                ));
            }
        }
    }
}

impl poem::listener::Listener for HiddenService {
    type Acceptor = Self;

    async fn into_acceptor(self) -> std::io::Result<Self::Acceptor> {
        Ok(self)
    }
}