1use anyhow::Result;
7use base64::{Engine, engine::general_purpose::URL_SAFE_NO_PAD};
8use ring::rand::{SecureRandom, SystemRandom};
9use sha2::{Digest, Sha256};
10use std::fmt;
11
12const CODE_VERIFIER_LENGTH: usize = 64;
14
15const CODE_VERIFIER_CHARSET: &[u8] = b"ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789-._~";
17
18#[derive(Clone)]
24pub struct PkceChallenge {
25 pub(crate) code_verifier: String,
27 pub(crate) code_challenge: String,
29 pub(crate) code_challenge_method: String,
31}
32
33impl fmt::Debug for PkceChallenge {
34 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
35 f.debug_struct("PkceChallenge")
36 .field("code_verifier", &"<redacted>")
37 .field("code_challenge", &self.code_challenge)
38 .field("code_challenge_method", &self.code_challenge_method)
39 .finish()
40 }
41}
42
43impl PkceChallenge {
44 fn from_verifier(code_verifier: String) -> Result<Self> {
46 let code_challenge = compute_s256_challenge(&code_verifier)?;
47 Ok(Self {
48 code_verifier,
49 code_challenge,
50 code_challenge_method: "S256".to_string(),
51 })
52 }
53}
54
55pub fn generate_pkce_challenge() -> Result<PkceChallenge> {
69 let code_verifier = generate_code_verifier()?;
70 PkceChallenge::from_verifier(code_verifier)
71}
72
73fn generate_code_verifier() -> Result<String> {
78 let rng = SystemRandom::new();
79 let charset_len = CODE_VERIFIER_CHARSET.len() as u8;
80 let max_valid = (256u16 - 256u16 % charset_len as u16) as u8;
81 let mut verifier = String::with_capacity(CODE_VERIFIER_LENGTH);
82 let mut buf = [0u8; 1];
83
84 while verifier.len() < CODE_VERIFIER_LENGTH {
85 rng.fill(&mut buf)
86 .map_err(|_| anyhow::anyhow!("failed to read from OS random source"))?;
87 if buf[0] < max_valid {
89 let idx = (buf[0] % charset_len) as usize;
90 verifier.push(CODE_VERIFIER_CHARSET[idx] as char);
91 }
92 }
93
94 Ok(verifier)
95}
96
97fn compute_s256_challenge(code_verifier: &str) -> Result<String> {
101 let mut hasher = Sha256::new();
102 hasher.update(code_verifier.as_bytes());
103 let hash = hasher.finalize();
104
105 Ok(URL_SAFE_NO_PAD.encode(hash))
106}
107
108#[cfg(test)]
109mod tests {
110 use super::*;
111
112 #[test]
113 fn test_generate_pkce_challenge() {
114 let challenge = generate_pkce_challenge().unwrap();
115
116 assert_eq!(challenge.code_verifier.len(), CODE_VERIFIER_LENGTH);
118
119 for c in challenge.code_verifier.chars() {
121 assert!(CODE_VERIFIER_CHARSET.contains(&(c as u8)), "Invalid character in verifier: {c}");
122 }
123
124 assert_eq!(challenge.code_challenge_method, "S256");
126
127 assert_eq!(challenge.code_challenge.len(), 43);
129 }
130
131 #[test]
132 fn test_deterministic_challenge() {
133 let verifier = "test_verifier_string_for_deterministic_test";
135 let challenge1 = PkceChallenge::from_verifier(verifier.to_string()).unwrap();
136 let challenge2 = PkceChallenge::from_verifier(verifier.to_string()).unwrap();
137
138 assert_eq!(challenge1.code_challenge, challenge2.code_challenge);
139 }
140
141 #[test]
142 fn test_unique_verifiers() {
143 let c1 = generate_pkce_challenge().unwrap();
145 let c2 = generate_pkce_challenge().unwrap();
146
147 assert_ne!(c1.code_verifier, c2.code_verifier);
148 }
149}