authentik_client/apis/
mod.rs

1use std::error;
2use std::fmt;
3
4#[derive(Debug, Clone)]
5pub struct ResponseContent<T> {
6    pub status: reqwest::StatusCode,
7    pub content: String,
8    pub entity: Option<T>,
9}
10
11#[derive(Debug)]
12pub enum Error<T> {
13    Reqwest(reqwest::Error),
14    ReqwestMiddleware(reqwest_middleware::Error),
15    Serde(serde_json::Error),
16    Io(std::io::Error),
17    ResponseError(ResponseContent<T>),
18}
19
20impl<T> fmt::Display for Error<T> {
21    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
22        let (module, e) = match self {
23            Error::Reqwest(e) => ("reqwest", e.to_string()),
24            Error::ReqwestMiddleware(e) => ("reqwest-middleware", e.to_string()),
25            Error::Serde(e) => ("serde", e.to_string()),
26            Error::Io(e) => ("IO", e.to_string()),
27            Error::ResponseError(e) => ("response", format!("status code {}", e.status)),
28        };
29        write!(f, "error in {}: {}", module, e)
30    }
31}
32
33impl<T: fmt::Debug> error::Error for Error<T> {
34    fn source(&self) -> Option<&(dyn error::Error + 'static)> {
35        Some(match self {
36            Error::Reqwest(e) => e,
37            Error::ReqwestMiddleware(e) => e,
38            Error::Serde(e) => e,
39            Error::Io(e) => e,
40            Error::ResponseError(_) => return None,
41        })
42    }
43}
44
45impl<T> From<reqwest::Error> for Error<T> {
46    fn from(e: reqwest::Error) -> Self {
47        Error::Reqwest(e)
48    }
49}
50
51impl<T> From<reqwest_middleware::Error> for Error<T> {
52    fn from(e: reqwest_middleware::Error) -> Self {
53        Error::ReqwestMiddleware(e)
54    }
55}
56
57impl<T> From<serde_json::Error> for Error<T> {
58    fn from(e: serde_json::Error) -> Self {
59        Error::Serde(e)
60    }
61}
62
63impl<T> From<std::io::Error> for Error<T> {
64    fn from(e: std::io::Error) -> Self {
65        Error::Io(e)
66    }
67}
68
69pub fn urlencode<T: AsRef<str>>(s: T) -> String {
70    ::url::form_urlencoded::byte_serialize(s.as_ref().as_bytes()).collect()
71}
72
73pub fn parse_deep_object(prefix: &str, value: &serde_json::Value) -> Vec<(String, String)> {
74    if let serde_json::Value::Object(object) = value {
75        let mut params = vec![];
76
77        for (key, value) in object {
78            match value {
79                serde_json::Value::Object(_) => {
80                    params.append(&mut parse_deep_object(&format!("{}[{}]", prefix, key), value))
81                }
82                serde_json::Value::Array(array) => {
83                    for (i, value) in array.iter().enumerate() {
84                        params.append(&mut parse_deep_object(&format!("{}[{}][{}]", prefix, key, i), value));
85                    }
86                }
87                serde_json::Value::String(s) => params.push((format!("{}[{}]", prefix, key), s.clone())),
88                _ => params.push((format!("{}[{}]", prefix, key), value.to_string())),
89            }
90        }
91
92        return params;
93    }
94
95    unimplemented!("Only objects are supported with style=deepObject")
96}
97
98/// Internal use only
99/// A content type supported by this client.
100#[allow(dead_code)]
101enum ContentType {
102    Json,
103    Text,
104    Unsupported(String),
105}
106
107impl From<&str> for ContentType {
108    fn from(content_type: &str) -> Self {
109        if content_type.starts_with("application") && content_type.contains("json") {
110            return Self::Json;
111        } else if content_type.starts_with("text/plain") {
112            return Self::Text;
113        } else {
114            return Self::Unsupported(content_type.to_string());
115        }
116    }
117}
118
119pub mod admin_api;
120pub mod authenticators_api;
121pub mod core_api;
122pub mod crypto_api;
123pub mod enterprise_api;
124pub mod events_api;
125pub mod flows_api;
126pub mod managed_api;
127pub mod oauth2_api;
128pub mod outposts_api;
129pub mod policies_api;
130pub mod propertymappings_api;
131pub mod providers_api;
132pub mod rac_api;
133pub mod rbac_api;
134pub mod root_api;
135pub mod schema_api;
136pub mod sources_api;
137pub mod ssf_api;
138pub mod stages_api;
139pub mod tasks_api;
140pub mod tenants_api;
141
142pub mod configuration;
authentik_client/apis/mod.rs

authentik_client/apis/
mod.rs
