geph4-client 4.4.18

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

use anyhow::Context;
use async_net::SocketAddr;
use sosistab::Multiplex;

use super::{getsess::get_session, tunnelctx::TunnelCtx};

pub async fn rerouter_once(
    ctx: TunnelCtx,
    bridge_addr: SocketAddr,
    tunnel_mux: &Multiplex,
    other_id: [u8; 32],
) -> anyhow::Result<()> {
    let new_sess = get_session(ctx.clone(), Some(bridge_addr)).await;
    match new_sess {
        Ok(new_sess) => {
            // if new_sess.remote_addr() == bridge_addr {
            //     log::trace!("skipping hijack because the best connection was identical");
            // } else {
            new_sess
                .hijack(tunnel_mux, other_id)
                .await
                .context("hijack failed")?;
            // }
            Ok(())
        }
        Err(err) => {
            anyhow::bail!("rerouter failed to make new sess: {:?}", err);
        }
    }
}