runique 2.0.1

A Django-inspired web framework for Rust with ORM, templates, and comprehensive security middleware
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

//! `Message` — Axum extractor to read/write flash messages in session.
use crate::flash::flash_struct::FlashMessage;
use crate::utils::{aliases::Messages, constante::session_key::session::FLASH_KEY};
use axum::extract::FromRequestParts;
use axum::http::{StatusCode, request::Parts};
use tower_sessions::Session;

#[derive(Clone, Debug)]
pub struct Message {
    pub session: Session,
}

impl<S> FromRequestParts<S> for Message
where
    S: Send + Sync,
{
    type Rejection = StatusCode;

    async fn from_request_parts(parts: &mut Parts, _: &S) -> Result<Self, Self::Rejection> {
        let session = parts
            .extensions
            .get::<Session>()
            .cloned()
            .ok_or(StatusCode::INTERNAL_SERVER_ERROR)?;

        Ok(Self { session })
    }
}

impl Message {
    async fn push(&self, msg: FlashMessage) {
        let mut messages = self
            .session
            .get::<Messages>(FLASH_KEY)
            .await
            .ok()
            .flatten()
            .unwrap_or_default();

        messages.push(msg);
        let _ = self.session.insert(FLASH_KEY, messages).await;
    }

    pub async fn success(&self, msg: impl Into<String>) {
        self.push(FlashMessage::success(msg)).await
    }
    pub async fn error(&self, msg: impl Into<String>) {
        self.push(FlashMessage::error(msg)).await
    }
    pub async fn info(&self, msg: impl Into<String>) {
        self.push(FlashMessage::info(msg)).await
    }
    pub async fn warning(&self, msg: impl Into<String>) {
        self.push(FlashMessage::warning(msg)).await
    }
    pub async fn get_all(&self) -> Messages {
        let messages = self
            .session
            .get::<Messages>(FLASH_KEY)
            .await
            .ok()
            .flatten()
            .unwrap_or_default();

        // Deletes after reading for “flash” effect
        let _ = self.session.remove::<Messages>(FLASH_KEY).await;
        messages
    }
}