nova_middleware 0.0.1

nova - 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

use nova_core::errors::ServerError;
use nova_core::request::HttpRequest;
use nova_core::response::HttpResponse;
use std::collections::HashMap;
use std::fmt::Debug;

use crate::middleware::BoxedMiddleware;

/// Nova Middleware wrapper
#[derive(Clone, Debug, Default)]
pub struct Middlewares {
    inner: HashMap<String, BoxedMiddleware>,
}

impl Middlewares {
    /// Register new Middleware
    pub fn register(&mut self, middle: BoxedMiddleware) {
        self.inner.insert(uuid::Uuid::new_v4().to_string(), middle);
    }

    /// Call Request middleware
    ///
    /// # Errors
    ///
    /// * if calling middleware returns an error, this error is returned
    pub fn call_for_req(&self, request: &mut HttpRequest) -> Result<(), ServerError> {
        let binding = self
            .inner
            .values()
            .map(|boxed| boxed.request(request))
            .collect::<Vec<Result<(), _>>>();
        let error = binding.iter().find(|item| item.is_err());
        error.map_or(Ok(()), Clone::clone)
    }

    /// Call Response middleware
    ///
    /// # Errors
    ///
    /// * if calling middleware returns an error, this error is returned
    pub fn call_for_res(
        &self,
        request: &HttpRequest,
        response: &mut HttpResponse,
    ) -> Result<(), ServerError> {
        let binding = self
            .inner
            .values()
            .map(|boxed| boxed.response(request, response))
            .collect::<Vec<Result<(), _>>>();
        let error = binding.iter().find(|item| item.is_err());
        error.map_or(Ok(()), Clone::clone)
    }
}