static_web_server/
custom_headers.rs1use hyper::{Body, Request, Response};
10use std::{ffi::OsStr, path::PathBuf};
11
12use crate::{handler::RequestHandlerOpts, settings::Headers, Error};
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 )
28 }
29 Ok(resp)
30}
31
32pub fn append_headers(
34 uri_path: &str,
35 headers_opts: Option<&[Headers]>,
36 resp: &mut Response<Body>,
37 file_path: Option<&PathBuf>,
38) {
39 if let Some(headers_vec) = headers_opts {
40 let uri_path_auto_index = file_path
41 .filter(|_| uri_path.ends_with('/'))
42 .and_then(|p| p.file_name())
43 .and_then(OsStr::to_str)
44 .map(|name| match uri_path {
45 "/" => ["/", name].concat(),
46 _ => [uri_path, "/", name].concat(),
47 });
48
49 let uri_path = match uri_path_auto_index {
50 Some(ref s) => s.as_str(),
51 _ => uri_path,
52 };
53
54 for headers_entry in headers_vec {
55 if headers_entry.source.is_match(uri_path) {
57 for (name, value) in &headers_entry.headers {
59 resp.headers_mut().insert(name, value.to_owned());
60 }
61 }
62 }
63 }
64}