maw 0.26.3

A simple and efficient web framework for Rust.
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
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122

use std::{
    marker::PhantomData,
    time::{Duration, UNIX_EPOCH},
};

use http::StatusCode;
use httpdate::{fmt_http_date, parse_http_date};
use rust_embed::RustEmbed;

use crate::{ctx::Ctx, handler::Handler};

pub struct StaticFiles<E> {
    _marker: PhantomData<E>,
    pub(crate) index: &'static str,
    cache_control: Option<String>,
    fallback_to: Option<&'static str>,
}

impl<E: RustEmbed> StaticFiles<E> {
    pub fn new(_: E) -> Self {
        Self {
            _marker: PhantomData,
            index: "index.html",
            cache_control: None,
            fallback_to: None,
        }
    }

    pub fn index(mut self, file: &'static str) -> Self {
        self.index = file;
        self
    }

    pub fn max_age(mut self, seconds: u32) -> Self {
        self.cache_control = if seconds > 0 {
            Some(format!("max-age={seconds}"))
        } else {
            None
        };
        self
    }

    /// Serve a specific embedded file when no matching path is found,
    /// going through the same last-modified/cache-control logic as normal files.
    ///
    /// ```rust
    /// // SPA: let the client-side router handle all unknown paths
    /// StaticFiles::new(Assets).fallback_to("index.html")
    /// ```
    pub fn fallback_to(mut self, file: &'static str) -> Self {
        self.fallback_to = Some(file);
        self
    }
}

impl<E> Clone for StaticFiles<E> {
    fn clone(&self) -> Self {
        Self {
            _marker: PhantomData,
            index: self.index,
            cache_control: self.cache_control.clone(),
            fallback_to: self.fallback_to,
        }
    }
}

impl<E: RustEmbed + Sync> Handler<&mut Ctx> for StaticFiles<E> {
    type Output = ();

    async fn call(&self, c: &mut Ctx) -> Self::Output {
        let path = c.req.param_str("_");

        let (file, mime_path) = if path.is_empty() || path.ends_with('/') {
            let full = [path, self.index].concat();
            (E::get(&full), full)
        } else {
            match E::get(path) {
                Some(f) => (Some(f), path.to_string()),
                None => {
                    let full = [path, "/", self.index].concat();
                    (E::get(&full), full)
                }
            }
        };

        let (file, mime_path) = match file {
            Some(f) => (f, mime_path),
            None => match self.fallback_to.and_then(|p| E::get(p).map(|f| (f, p))) {
                Some((f, p)) => (f, p.to_string()),
                None => {
                    c.res.send_status(StatusCode::NOT_FOUND);
                    return;
                }
            },
        };

        if let Some(last_modified) = file.metadata.last_modified() {
            let modified = UNIX_EPOCH + Duration::from_secs(last_modified);
            c.res.header(("Last-Modified", fmt_http_date(modified)));

            if let Some(ims) = c.req.headers().get("If-Modified-Since") {
                if let Ok(ims_str) = ims.to_str() {
                    if let Ok(ims_time) = parse_http_date(ims_str) {
                        if modified <= ims_time {
                            c.res.send_status(StatusCode::NOT_MODIFIED);
                            return;
                        }
                    }
                }
            }
        }

        let mime = mime_guess::from_path(&mime_path).first_or_octet_stream();
        c.res.header(("Content-Type", mime.as_ref()));

        if let Some(cc) = &self.cache_control {
            c.res.header(("Cache-Control", cc.as_str()));
        }

        c.res.send(file.data.into_owned());
    }
}