#![feature(generators)]
#![feature(proc_macro_non_items)]
#![feature(try_from)]

extern crate futures_await as futures;
extern crate ruma_client;
extern crate ruma_events;
extern crate ruma_identifiers;
extern crate tokio_core;
extern crate url;

use std::convert::TryFrom;
use std::env;
use std::process::exit;

use futures::prelude::{*, await};
use ruma_client::Client;
use ruma_client::api::r0;
use ruma_events::EventType;
use ruma_events::room::message::{MessageEventContent, MessageType, TextMessageEventContent};
use ruma_identifiers::RoomAliasId;
use tokio_core::reactor::Core;
use url::Url;

fn hello_world(
    homeserver_url: Url,
    room: String,
) -> impl Future<Item = (), Error = ruma_client::Error> + 'static {
    let client = Client::https(homeserver_url, None).unwrap();

    async_block! {
        await!(client.register_guest())?;

        let response = await!(r0::alias::get_alias::call(
            client.clone(),
            r0::alias::get_alias::Request {
                room_alias: RoomAliasId::try_from(&room[..]).unwrap(),
            }
        ))?;

        let room_id = response.room_id;

        await!(r0::membership::join_room_by_id::call(
            client.clone(),
            r0::membership::join_room_by_id::Request {
                room_id: room_id.clone(),
                third_party_signed: None,
            }
        ))?;

        await!(r0::send::send_message_event::call(
            client.clone(),
            r0::send::send_message_event::Request {
                room_id: room_id,
                event_type: EventType::RoomMessage,
                txn_id: "1".to_owned(),
                data: MessageEventContent::Text(TextMessageEventContent {
                    body: "Hello World!".to_owned(),
                    msgtype: MessageType::Text,
                }),
            }
        ))?;

        Ok(())
    }
}

fn main() {
    let (homeserver_url, room) = match (env::args().nth(1), env::args().nth(2)) {
        (Some(a), Some(b)) => (a, b),
        _ => {
            eprintln!("Usage: {} <homeserver_url> <room>", env::args().next().unwrap());
            exit(1)
        }
    };

    Core::new().unwrap()
        .run(hello_world(homeserver_url.parse().unwrap(), room))
        .unwrap();
}