flatline

use flatline::session::{Session, Config, DefaultNotifier};
use flatline::session::channel::Message;
use tokio::net::TcpStream;

#[tokio::main]
async fn main() -> Result<(), Box<dyn std::error::Error>> {
    let socket = TcpStream::connect("example.com:22").await?;
    let config = Config::default();
    let notifier = DefaultNotifier::default();

    let session = Session::handshake(socket, config, notifier).await?;

    session.request_authentication().await?;
    let status = session.authenticate_password("user", "password").await?;
    assert!(status.success());

    let mut channel = session.channel_open_default().await?;
    channel.request_exec(true, "echo hello").await?;

    while let Ok(msg) = channel.receive().await {
        match msg {
            Message::Stdout(data) => {
                println!("{}", String::from_utf8_lossy(&data));
            }
            Message::Exit(_) | Message::Close => break,
            _ => {}
        }
    }

    Ok(())
}