pulse_http 0.2.0

Async HTTP/1.1 framework on Tokio — raw TCP, routing, middleware, no Hyper
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

use std::time::Instant;

use crate::{
    middleware::{Middleware, Next},
    request::Request,
    response::Response,
    router::BoxFuture,
};

pub struct RequestLogger;

impl Middleware for RequestLogger {
    fn handle(&self, request: Request, next: Next) -> BoxFuture<Response> {
        Box::pin(async move {
            let method = request.method.as_str().to_string();
            let path = request.path.clone();
            let request_id = request
                .headers
                .get("x-request-id")
                .cloned()
                .unwrap_or_else(|| "-".into());
            let ip_addr = request.ip_addr;
            let started = Instant::now();

            let response = next.run(request).await; // Response here

            println!(
                "[{request_id}] {} {method} {path} -> {} ({} ms)",
                ip_addr,
                response.status,
                started.elapsed().as_millis()
            );

            response
        })
    }
}