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
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
use crate::auth::{AuthenticationScheme, Authorization};
use crate::headers::{HeaderName, HeaderValue, Headers, AUTHORIZATION};
use crate::Status;
use crate::{bail_status as bail, ensure_status as ensure};
#[derive(Debug)]
pub struct BasicAuth {
username: String,
password: String,
}
impl BasicAuth {
pub fn new<U, P>(username: U, password: P) -> Self
where
U: AsRef<str>,
P: AsRef<str>,
{
let username = username.as_ref().to_owned();
let password = password.as_ref().to_owned();
Self { username, password }
}
pub fn from_headers(headers: impl AsRef<Headers>) -> crate::Result<Option<Self>> {
let auth = match Authorization::from_headers(headers)? {
Some(auth) => auth,
None => return Ok(None),
};
let scheme = auth.scheme();
ensure!(
matches!(scheme, AuthenticationScheme::Basic),
400,
"Expected basic auth scheme found `{}`",
scheme
);
Self::from_credentials(auth.credentials()).map(Some)
}
pub fn from_credentials(credentials: impl AsRef<[u8]>) -> crate::Result<Self> {
let bytes = base64::decode(credentials).status(400)?;
let credentials = String::from_utf8(bytes).status(400)?;
let mut iter = credentials.splitn(2, ':');
let username = iter.next();
let password = iter.next();
let (username, password) = match (username, password) {
(Some(username), Some(password)) => (username.to_string(), password.to_string()),
(Some(_), None) => bail!(400, "Expected basic auth to contain a password"),
(None, _) => bail!(400, "Expected basic auth to contain a username"),
};
Ok(Self { username, password })
}
pub fn apply(&self, mut headers: impl AsMut<Headers>) {
headers.as_mut().insert(self.name(), self.value());
}
pub fn name(&self) -> HeaderName {
AUTHORIZATION
}
pub fn value(&self) -> HeaderValue {
let scheme = AuthenticationScheme::Basic;
let credentials = base64::encode(format!("{}:{}", self.username, self.password));
let auth = Authorization::new(scheme, credentials);
auth.value()
}
pub fn username(&self) -> &str {
self.username.as_str()
}
pub fn password(&self) -> &str {
self.password.as_str()
}
}
#[cfg(test)]
mod test {
use super::*;
use crate::headers::Headers;
#[test]
fn smoke() -> crate::Result<()> {
let username = "nori";
let password = "secret_fish!!";
let authz = BasicAuth::new(username, password);
let mut headers = Headers::new();
authz.apply(&mut headers);
let authz = BasicAuth::from_headers(headers)?.unwrap();
assert_eq!(authz.username(), username);
assert_eq!(authz.password(), password);
Ok(())
}
#[test]
fn bad_request_on_parse_error() {
let mut headers = Headers::new();
headers.insert(AUTHORIZATION, "<nori ate the tag. yum.>");
let err = BasicAuth::from_headers(headers).unwrap_err();
assert_eq!(err.status(), 400);
}
}