use std::{convert::TryFrom, env, process::exit};

use ruma::{
    api::client::{alias::get_alias, membership::join_room_by_id, message::send_message_event},
    events::room::message::RoomMessageEventContent,
    RoomAliasId,
};
use ruma_api::MatrixVersion;
use ruma_identifiers::TransactionId;

type MatrixClient = ruma_client::Client<ruma_client::http_client::HyperNativeTls>;

async fn hello_world(
    homeserver_url: String,
    username: &str,
    password: &str,
    room_alias: &RoomAliasId,
) -> anyhow::Result<()> {
    let client = MatrixClient::new(homeserver_url, None);
    client.log_in(username, password, None, Some("ruma-example-client")).await?;

    let room_id = client
        .send_request(get_alias::v3::Request::new(room_alias), &[MatrixVersion::V1_0])
        .await?
        .room_id;
    client
        .send_request(join_room_by_id::v3::Request::new(&room_id), &[MatrixVersion::V1_0])
        .await?;
    client
        .send_request(
            send_message_event::v3::Request::new(
                &room_id,
                &TransactionId::new(),
                &RoomMessageEventContent::text_plain("Hello World!"),
            )?,
            &[MatrixVersion::V1_0],
        )
        .await?;

    Ok(())
}

#[tokio::main(flavor = "current_thread")]
async fn main() -> anyhow::Result<()> {
    let (homeserver_url, username, password, room) =
        match (env::args().nth(1), env::args().nth(2), env::args().nth(3), env::args().nth(4)) {
            (Some(a), Some(b), Some(c), Some(d)) => (a, b, c, d),
            _ => {
                eprintln!(
                    "Usage: {} <homeserver_url> <username> <password> <room>",
                    env::args().next().unwrap()
                );
                exit(1)
            }
        };

    hello_world(homeserver_url, &username, &password, <&RoomAliasId>::try_from(room.as_str())?)
        .await
}