hyperapi 0.2.2

An easy to use API Gateway
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

use std::collections::HashMap;
use hyper::http::request::Parts;
use tokio::sync::oneshot;
use crate::config::{ConfigUpdate, FilterSetting, AuthSetting};
use thiserror::Error;


#[derive(Error, Debug, Clone)]
pub enum GatewayAuthError { 
    #[error("Unknown Service")]
    UnknownService,

    #[error("Unknown Client")]
    UnknownClient,

    #[error("Invalid SLA")]
    InvalidSLA,

    #[error("Invalid auth token")]
    InvalidToken,

    #[error("Auth token not found")]
    TokenNotFound,

    #[error("Unknown auth error")]
    Unknown,
}


#[derive(Debug, Clone)]
pub struct AuthResponse {
    pub client_id: String,
    pub service_id: String,
    pub sla: String,
    pub service_filters: Vec<FilterSetting>,
    pub client_filters: Vec<FilterSetting>,
}


pub struct AuthRequest {
    pub head: Parts,
    pub result: oneshot::Sender<Result<(Parts, AuthResponse), GatewayAuthError>>,
}

impl AuthRequest {
    pub fn into_parts(self) -> (Parts, oneshot::Sender<Result<(Parts, AuthResponse), GatewayAuthError>>) {
        (self.head, self.result)
    }
}


pub struct ServiceAuthInfo {
    pub service_id: String,
    pub auth: AuthSetting,
    pub filters: Vec<FilterSetting>,
    pub slas: HashMap<String, Vec<FilterSetting>>
}


#[derive(Debug, Clone)]
pub struct AuthResult {
    pub client_id: String,
    pub sla: String,
}


pub trait AuthProvider {

    fn update_config(&mut self, update: ConfigUpdate);

    fn identify_client(&self, client: Parts, service_id: &str) -> Result<(Parts, AuthResult), GatewayAuthError>;
}