pusher 0.4.5

The Rust library for interacting with the Pusher HTTP API.
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
39
40
41
42
43
44
45
46
47
48
49
50

extern crate hyper;
extern crate pusher;
extern crate serde;
extern crate serde_json;
extern crate tokio;
extern crate url;

use hyper::body::to_bytes;
use hyper::server::Server;
use hyper::service::{make_service_fn, service_fn};
use hyper::{Body, Error, Request, Response};
use pusher::PusherBuilder;
use std::collections::HashMap;
use std::net::SocketAddr;
use url::form_urlencoded::parse;

#[tokio::main(flavor = "current_thread")]
async fn main() {
    let addr = SocketAddr::from(([127, 0, 0, 1], 3000));

    let make_svc = make_service_fn(|_conn| async { Ok::<_, Error>(service_fn(authenticate)) });

    let server = Server::bind(&addr).serve(make_svc);

    if let Err(e) = server.await {
        eprintln!("server error: {}", e);
    }
}

async fn authenticate(req: Request<Body>) -> Result<Response<Body>, Error> {
    let pusher = PusherBuilder::from_url("http://key:secret@api.host.com/apps/id").finalize();
    let body = to_bytes(req).await.unwrap();
    let params = parse(body.as_ref())
        .into_owned()
        .collect::<HashMap<String, String>>();
    let channel_name = params.get("channel_name").unwrap();
    let socket_id = params.get("socket_id").unwrap();

    let mut member_data = HashMap::new();
    member_data.insert("twitter", "jamiepatel");
    let member = pusher::Member {
        user_id: "4",
        user_info: Some(member_data),
    };
    let auth_signature = pusher
        .authenticate_presence_channel(channel_name, socket_id, &member)
        .unwrap();

    Ok(Response::new(auth_signature.into()))
}