ruwuma/examples/hello_world_await.rs

74 lines
2.1 KiB
Rust

#![feature(conservative_impl_trait)]
#![feature(generators)]
#![feature(proc_macro)]
#![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 futures::prelude::*;
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, Handle};
use url::Url;
fn hello_world(
tokio_handle: &Handle,
homeserver_url: Url,
) -> impl Future<Item = (), Error = ruma_client::Error> + 'static {
let client = Client::https(tokio_handle, 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("#ruma-client-test:matrix.org").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 mut core = Core::new().unwrap();
let handle = core.handle();
let server = Url::parse("https://matrix.org/").unwrap();
core.run(hello_world(&handle, server)).unwrap();
}