rego 0.1.1

some building blocks for creating simple web server
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

use super::Error;
use crate::domain::jwt::{JwtEncoder, WebToken};
use futures::future;
use std::str::FromStr;
use warp::{filters::header::header, Filter, Rejection};

pub fn auth(
    jwt_encoder: JwtEncoder,
) -> impl Filter<Extract = (WebToken,), Error = Rejection> + Clone {
    (header::<BearerToken>("Authorization")
        .or(header::<BearerToken>("authorization"))
        .unify())
    .and_then(
        move |BearerToken(token)| match jwt_encoder.decode(token.as_str()) {
            Ok(token) => future::ok(token),
            Err(_) => future::err(Into::<Rejection>::into(Error::unauthorized())),
        },
    )
    .or_else(|_| future::err(Into::<Rejection>::into(Error::unauthorized())))
}

pub struct BearerToken(String);

impl FromStr for BearerToken {
    type Err = anyhow::Error;

    fn from_str(s: &str) -> anyhow::Result<Self> {
        if s.len() < 7 {
            return Err(anyhow::anyhow!("Not a BearerToken"));
        }
        let (bearer, token) = s.split_at(7);
        if bearer != "Bearer " {
            return Err(anyhow::anyhow!("Not a BearerToken"));
        }
        Ok(BearerToken(token.to_string()))
    }
}