ezhttp 0.2.2

Simple async http library with client and server
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

use super::{
    HttpServer, 
    super::{
        Stream,
        request::HttpRequest
    }
};

use std::{future::Future, pin::Pin, sync::Arc};
use tokio::net::TcpStream;
use tokio_io_timeout::TimeoutStream;

pub type Handler<T> = Box<dyn Fn(Arc<T>, TimeoutStream<TcpStream>) -> Pin<Box<dyn Future<Output = ()> + Send>> + Send + Sync>;

/// Default connection handler
/// Turns input to request and response to output
pub async fn handler_connection<S: HttpServer + Send + 'static + Sync>(
    server: Arc<S>, 
    mut sock: Stream
) {
    let Ok(addr) = sock.get_ref().peer_addr() else { return; };

    loop {
        let req = match HttpRequest::recv(sock.get_mut(), &addr).await {
            Ok(i) => i,
            Err(e) => {
                server.on_error(e).await;
                return;
            }
        };

        let resp = match server.on_request(&req).await {
            Some(i) => i,
            None => {
                return;
            }
        };

        match resp.send(sock.get_mut()).await {
            Ok(_) => {},
            Err(e) => {
                server.on_error(e).await;
                return;
            },
        }
    }
}

#[macro_export]
macro_rules! pin_handler {
    ($handler: expr) => {
        Box::new(move |a, b| Box::pin($handler(a, b)))
    };
}