meows 0.2.0

A simple pattern for async service messaging over WebSockets
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

/**
 * The stateful server carries server and connection state to websocket handlers
 */

#[macro_use]
extern crate meows;
extern crate pretty_env_logger;
#[macro_use]
extern crate serde_derive;

use meows::*;
use smol;

#[derive(Debug, Deserialize, Serialize)]
struct Ping {
    msg: String,
}

struct ServerState {
    secret: String,
}

async fn handle_ping(mut req: Request<ServerState, ()>) -> Option<Message> {
    info!("My state secret is: {}", req.state.secret);
    if let Some(ping) = req.from_value::<Ping>() {
        info!("Ping received with message: {}", ping.msg);
    }
    Some(Message::text("pong"))
}

fn main() -> Result<(), std::io::Error> {
    pretty_env_logger::init();

    let state = ServerState {
        secret: String::from("hunter2"),
    };

    println!("Starting simple ping/pong websocket server with meows");
    let mut server = meows::Server::with_state(state);
    server.on("ping", handle_ping);

    smol::run(async move { server.serve("127.0.0.1:8105".to_string()).await })
}