rix 0.3.0

Experimental Matrix client using futures
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38

extern crate rix;
extern crate tokio_core;
extern crate futures;
extern crate hyper;

use futures::{Future, Stream};
use std::str::FromStr;

fn main() {
    let host = std::env::var("MATRIX_HOST").expect("Missing MATRIX_HOST");
    let token = std::env::var("MATRIX_TOKEN").expect("Missing MATRIX_TOKEN");

    let mut core = tokio_core::reactor::Core::new().unwrap();
    let handle = core.handle();

    let task = rix::client::media::upload(&host, &token, &handle, hyper::mime::Mime::from_str("text/plain").unwrap(), "upload.rs", &include_bytes!("./upload.rs")[..])
        .and_then(|url| {
            rix::client::sync_stream(&host, &token, &handle)
                .skip(1)
                .for_each(move |frame| {
                    for evt in frame.events() {
                        if evt.event_type == "m.room.message" {
                            let body = evt.content["body"].as_str();
                            if let Some(body) = body {
                                if body == "!upload.rs" {
                                    if let Some(ref room) = evt.room {
                                        handle.spawn(rix::client::send_file(&host, &token, &handle, &room, &url, "upload.rs").map_err(|e| eprintln!("{:?}", e)));
                                    }
                                }
                            }
                        }
                    }
                    Ok(())
                })
        });

    core.run(task).unwrap();
}