static_web_server/
custom_headers.rs1use hyper::{Body, Request, Response};
10use std::{ffi::OsStr, path::PathBuf};
11
12use crate::{Error, handler::RequestHandlerOpts, settings::Headers};
13
14pub(crate) fn post_process<T>(
16 opts: &RequestHandlerOpts,
17 req: &Request<T>,
18 mut resp: Response<Body>,
19 file_path: Option<&PathBuf>,
20) -> Result<Response<Body>, Error> {
21 if let Some(advanced) = &opts.advanced_opts {
22 append_headers(
23 req.uri().path(),
24 advanced.headers.as_deref(),
25 &mut resp,
26 file_path,
27 opts.redirect_trailing_slash,
28 )
29 }
30 Ok(resp)
31}
32
33fn append_headers(
35 uri_path: &str,
36 headers_opts: Option<&[Headers]>,
37 resp: &mut Response<Body>,
38 file_path: Option<&PathBuf>,
39 redirect_trailing_slash: bool,
40) {
41 if let Some(headers_vec) = headers_opts {
42 let uri_path_auto_index = file_path
43 .filter(|_| uri_path.ends_with('/') || !redirect_trailing_slash)
44 .and_then(|p| p.file_name())
45 .and_then(OsStr::to_str)
46 .map(|name| match uri_path {
47 "/" => ["/", name].concat(),
48 _ => [uri_path, "/", name].concat(),
49 });
50
51 let uri_path = match uri_path_auto_index {
52 Some(ref s) => s.as_str(),
53 _ => uri_path,
54 };
55
56 for headers_entry in headers_vec {
57 if headers_entry.source.is_match(uri_path) {
59 for (name, value) in &headers_entry.headers {
61 resp.headers_mut().insert(name, value.to_owned());
62 }
63 }
64 }
65 }
66}