http-server 0.8.9

Simple and configurable command-line HTTP 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
55
56
57
58
59
60
61
62
63
64
65
66
67
68

mod file_server;
mod proxy;

use anyhow::Result;
use async_trait::async_trait;
use http::{Request, Response};
use hyper::Body;
use std::convert::TryFrom;
use std::sync::Arc;
use tokio::sync::Mutex;

use crate::addon::file_server::FileServer;
use crate::addon::proxy::Proxy;
use crate::Config;

use super::middleware::Middleware;

use self::file_server::FileServerHandler;
use self::proxy::ProxyHandler;

/// A trait to implement on addons in order to handle incomming requests and
/// generate responses.
#[async_trait]
pub trait RequestHandler {
    async fn handle(&self, req: Arc<Mutex<Request<Body>>>) -> Arc<Mutex<http::Response<Body>>>;
}

#[derive(Clone)]
pub struct HttpHandler {
    request_handler: Arc<dyn RequestHandler + Send + Sync>,
    middleware: Arc<Middleware>,
}

impl HttpHandler {
    pub async fn handle_request(self, request: Request<Body>) -> Result<Response<Body>> {
        let handler = Arc::clone(&self.request_handler);
        let middleware = Arc::clone(&self.middleware);
        let response = middleware.handle(request, handler).await;

        Ok(response)
    }
}

impl From<Arc<Config>> for HttpHandler {
    fn from(config: Arc<Config>) -> Self {
        if let Some(proxy_config) = config.proxy.clone() {
            let proxy = Proxy::new(&proxy_config.url);
            let request_handler = Arc::new(ProxyHandler::new(proxy));
            let middleware = Middleware::try_from(config).unwrap();
            let middleware = Arc::new(middleware);

            return HttpHandler {
                request_handler,
                middleware,
            };
        }

        let file_server = FileServer::new(config.clone());
        let request_handler = Arc::new(FileServerHandler::new(file_server));
        let middleware = Middleware::try_from(config).unwrap();
        let middleware = Arc::new(middleware);

        HttpHandler {
            request_handler,
            middleware,
        }
    }
}