geph4-client 4.99.0

Geph client
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

use std::net::SocketAddr;

use futures_util::AsyncReadExt;

use super::ConnectContext;

/// Forwards ports using a particular description.
pub async fn port_forwarder(ctx: ConnectContext, desc: String) -> anyhow::Result<()> {
    let exploded = desc.split(":::").collect::<Vec<_>>();
    let listen_addr: SocketAddr = exploded[0].parse().expect("invalid port forwarding syntax");
    let listener = smol::net::TcpListener::bind(listen_addr)
        .await
        .expect("could not listen for port forwarding");
    loop {
        let (conn, _) = listener.accept().await?;

        let remote_addr = exploded[1].to_owned();
        let ctx = ctx.clone();
        smolscale::spawn(async move {
            let remote = ctx.tunnel.connect_stream(&remote_addr).await.ok()?;
            let (read_remote, write_remote) = remote.split();
            smol::future::race(
                smol::io::copy(read_remote, conn.clone()),
                smol::io::copy(conn, write_remote),
            )
            .await
            .ok()
        })
        .detach();
    }
}