swindon 0.7.8

An HTTP edge (frontend) server with smart websockets support 
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

use std::io;
use std::sync::{Arc};

use tk_http::Status;
use http_file_headers::{Input as HeadersInput};

use config::static_files::{SingleFile};
use default_error_page::{serve_error_page};
use incoming::{Input, Request, Transport};
use handlers::files::pools::get_pool;
use handlers::files::common::{reply_file, NotFile};


pub fn serve_file<S: Transport>(settings: &Arc<SingleFile>, mut inp: Input)
    -> Request<S>
{
    if !inp.headers.path().is_some() {
        // Star or authority
        return serve_error_page(Status::Forbidden, inp);
    };
    inp.debug.set_fs_path(&settings.path);
    let pool = get_pool(&inp.runtime, &settings.pool);
    let settings = settings.clone();
    let settings2 = settings.clone();

    let hinp = HeadersInput::from_headers(&settings.headers_config,
        inp.headers.method(), inp.headers.headers());
    let fut = pool.spawn_fn(move || {
        hinp.probe_file(&settings2.path)
        .map(|x| (x, ()))
        .map_err(|e| {
            if e.kind() == io::ErrorKind::PermissionDenied {
                (NotFile::Status(Status::Forbidden), ())
            } else {
                error!("Error reading file {:?}: {}", settings2.path, e);
                (NotFile::Status(Status::InternalServerError), ())
            }
        })
    });

    reply_file(inp, pool, fut, move |e, ()| {
        if let Some(ref val) = settings.content_type {
            e.add_header("Content-Type", val);
        }
        e.add_extra_headers(&settings.extra_headers);
    })
}