touche 0.0.15

Synchronous HTTP library
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
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108

use std::{
    collections::HashMap,
    sync::{
        atomic::{AtomicUsize, Ordering},
        mpsc::{self, Sender},
        Arc, Mutex,
    },
    thread,
};

use indoc::formatdoc;
use touche::{body::HttpBody, Body, Method, Request, Response, Server, StatusCode};

#[derive(Debug)]
enum Event {
    User(usize),
    Message(usize, String),
}

type Users = Arc<Mutex<HashMap<usize, Sender<Event>>>>;

fn main() -> std::io::Result<()> {
    static NEXT_USER_ID: AtomicUsize = AtomicUsize::new(1);

    let users: Users = Arc::new(Mutex::new(HashMap::new()));

    Server::bind("0.0.0.0:4444").serve(move |req: Request<Body>| {
        let users = users.clone();

        match req.uri().path() {
            "/messages" if req.method() == Method::POST => {
                let user_id = req
                    .headers()
                    .get("x-user-id")
                    .and_then(|h| h.to_str().ok())
                    .and_then(|user_id| user_id.parse::<usize>().ok());

                match user_id {
                    Some(user_id) => {
                        let text = req.into_body().into_bytes().unwrap_or_default();
                        let text = std::str::from_utf8(&text).unwrap_or_default();

                        users.lock().unwrap().retain(|id, tx| {
                            if user_id != *id {
                                tx.send(Event::Message(user_id, text.to_string())).is_ok()
                            } else {
                                true
                            }
                        });

                        Response::builder()
                            .status(StatusCode::CREATED)
                            .body(Body::empty())
                    }

                    None => Response::builder()
                        .status(StatusCode::UNAUTHORIZED)
                        .body("Missing x-user-id header".into()),
                }
            }

            "/messages" => {
                let user_id = NEXT_USER_ID.fetch_add(1, Ordering::Relaxed);

                let (tx, rx) = mpsc::channel();
                tx.send(Event::User(user_id)).unwrap();
                users.lock().unwrap().insert(user_id, tx);

                let (sender, body) = Body::channel();
                thread::spawn(move || {
                    for event in rx {
                        let message = match event {
                            Event::User(id) => formatdoc! {r#"
                                event: user
                                data: {{"id": "{id}"}}

                            "#},
                            Event::Message(user_id, text) => formatdoc! {r#"
                                event: message
                                data: {{"userId": {user_id}, "message": "{text}"}}

                            "#},
                        };

                        if let Err(_err) = sender.send(message) {
                            break;
                        }
                    }
                });

                Response::builder()
                    .status(StatusCode::OK)
                    .header("content-type", "text/event-stream")
                    .header("connection", "close")
                    .body(body)
            }

            "/" => Response::builder()
                .status(StatusCode::OK)
                .header("content-type", "text/html")
                .body(include_str!("sse-chat.html").into()),

            _ => Response::builder()
                .status(StatusCode::NOT_FOUND)
                .body(Body::empty()),
        }
    })
}