use serde::{Serialize, Deserialize}; use rand::{Rng, distributions::Alphanumeric}; use sha2::{Sha256, Digest}; use data_encoding::BASE64URL; #[derive(PartialEq, Eq, Copy, Clone, Debug, Serialize, Deserialize)] pub enum PKCEMethod { S256, Plain } #[derive(Debug, PartialEq, Eq, Clone, Serialize, Deserialize)] pub struct PKCEVerifier(pub(super) String); impl AsRef for PKCEVerifier { fn as_ref(&self) -> &str { self.0.as_str() } } impl ToString for PKCEVerifier { fn to_string(&self) -> String { self.0.clone() } } impl PKCEVerifier { fn new() -> Self { let bytes = rand::thread_rng() .sample_iter(&Alphanumeric) .take(128) .collect::>(); Self(String::from_utf8(bytes).unwrap()) } } #[derive(Eq, PartialEq, Debug, Clone, Serialize, Deserialize)] pub struct PKCEChallenge { code_challenge: String, method: PKCEMethod } impl PKCEChallenge { pub fn new(code_verifier: PKCEVerifier, method: PKCEMethod) -> Self { Self { code_challenge: match method { PKCEMethod::S256 => { let mut hasher = Sha256::new(); hasher.update(code_verifier.as_ref()); BASE64URL.encode(&hasher.finalize()) }, PKCEMethod::Plain => code_verifier.to_string(), }, method } } #[must_use] pub fn verify(&self, code_verifier: PKCEVerifier) -> bool { Self::new(code_verifier, self.method) == *self } } #[cfg(test)] mod tests { use super::*; #[test] fn test_pkce() { let verifier = PKCEVerifier::new(); let challenge = PKCEChallenge::new(verifier.clone(), PKCEMethod::S256); assert!(challenge.verify(verifier)); } }