azriel91/ssh_jumper

Async SSH tunnel through a jump host.

🌐💨 SSH Jumper

Async SSH tunnel through a jump host.

use std::borrow::Cow;
use ssh_jumper::{
    model::{HostAddress, HostSocketParams, JumpHostAuthParams, SshTunnelParams},
    SshJumper
};

// Similar to running:
// ssh -i ~/.ssh/id_rsa -L 1234:target_host:8080 [email protected]
let (local_socket_addr, ssh_forwarder_end_rx) = {
    let jump_host = HostAddress::HostName(Cow::Borrowed("bastion.com"));
    let jump_host_auth_params = JumpHostAuthParams::new(
        Cow::Borrowed("my_user"),
        Cow::Borrowed(Path::new("~/.ssh/id_rsa")),
    );
    let target_socket = HostSocketParams {
        address: HostAddress::HostName(Cow::Borrowed("target_host")),
        port: 8080,
    };
    let ssh_params =
        SshTunnelParams::new(jump_host, jump_host_auth_params, target_socket)
            // Optional: OS will allocate a port if this is left out
            .with_local_port(1234);

    SshJumper::open_tunnel(&ssh_params).await?
};

// Now you can send traffic to `local_socket_addr`, and it will go to `target_host`.

License

Licensed under either of

• Apache License, Version 2.0, (LICENSE-APACHE or https://www.apache.org/licenses/LICENSE-2.0)
• MIT license (LICENSE-MIT or https://opensource.org/licenses/MIT)

at your option.

Contribution

Unless you explicitly state otherwise, any contribution intentionally submitted for inclusion in the work by you, as defined in the Apache-2.0 license, shall be dual licensed as above, without any additional terms or conditions.

ssh_jumper's Issues

Channel open failure (administratively prohibited)

thread 'main' panicked at 'called Result::unwrap() on an Err value: SshTunnelOpenFail(Custom { kind: Other, error: "Channel open failure (administratively prohibited)" })', src\main.rs

     let params = JumpHostAuthParams::password(
            Cow::from("root"),
            Cow::from("Wangfu123"),
        );

     let  add=  match lookup_host("localhost:80").await {
           Ok(mut addrs) => {
               if let Some(addr) = addrs.next() {
                   // Extract the IpAddr from the resolved address
                   let ip_addr = addr.ip();
                   println!("Resolved IP address: {:?}", ip_addr);
                    Some(ip_addr)
               } else {
                   eprintln!("No addresses found for localhost");
                   None

               }
           }
           Err(e) => {
               eprintln!("Failed to resolve address: {:?}", e);
               None
           },
       };

       let  add2=  match lookup_host("sshhost:80").await {
           Ok(mut addrs) => {
               if let Some(addr) = addrs.next() {
                   // Extract the IpAddr from the resolved address
                   let ip_addr = addr.ip();
                   println!("Resolved IP address: {:?}", ip_addr);
                   Some(ip_addr)
               } else {
                   eprintln!("No addresses found for localhost");
                   None
               }
           }
           Err(e) => {

               eprintln!("Failed to resolve address: {:?}", e);
               None
           },
       };
       let target_socket = HostSocketParams {
           address:  HostAddress::IpAddr(add.unwrap()),
           port: 8090,
       };
        let ssh_params = SshTunnelParams::new(HostAddress::IpAddr(add2.unwrap()), params, target_socket)
            // Optional: OS will allocate a port if this is left out
            .with_local_port(8099);
        let (_, r) = SshJumper::open_tunnel(&ssh_params).await.unwrap();

        r.await.expect("");