Can you make an example of tokio？ about ssh-rs

[HsuJv]

@fullee
run_local mode is not designed to be running in the multiple-thread/coroutine context.
Please use run_backend to get the compatibility of async/await keywords
Examples can be found in exec_backend

Brs.

[HsuJv]

The following codes can be compiled with axum server but I didn't try 'em out as a real WebSocket server.

async fn ws_handler(ws: WebSocketUpgrade) -> impl IntoResponse {
    ws.protocols(["binary"]).on_upgrade(handle_client)
}

pub async fn handle_client(mut client: WebSocket) {
    let mut ssh = ssh_rs::ssh::create_session()
        .username("ubuntu")
        .password("password")
        .connect("127.0.0.1:22")
        .unwrap()
        .run_backend();

    loop {
        if let Some(msg) = client.recv().await {
            if let Ok(msg) = msg {
                match msg {
                    Message::Text(t) => {
                        println!("client sent str: {:?}", t);
                        // let exec = ssh_cloned.lock().unwrap().open_exec().unwrap();
                        let exec = ssh.open_exec().unwrap();
                        exec.send_command(&t).unwrap();
                        let vec = exec.get_result().unwrap();
                        if client
                            .send(Message::Text(String::from_utf8(vec).unwrap()))
                            .await
                            .is_err()
                        {
                            println!("client disconnected");
                        };
                    }
                    Message::Binary(_) => {
                        println!("client sent binary data");
                    }
                    Message::Ping(_) => {
                        println!("socket ping");
                    }
                    Message::Pong(_) => {
                        println!("socket pong");
                    }
                    Message::Close(_) => {
                        println!("client disconnected");
                        return;
                    }
                }
            } else {
                println!("client disconnected");
                return;
            }
        } else {
            println!("client disconnected");
            return;
        }
    }
}

[fullee]

ok,i love you