1#[cfg(feature = "logging")]
2use crate::log::trace;
3use alloc::sync::Arc;
4use alloc::vec::Vec;
5
6use pki_types::{CertificateDer, CertificateRevocationListDer, ServerName, UnixTime};
7use webpki::{CertRevocationList, RevocationCheckDepth, UnknownStatusPolicy};
8
9use crate::crypto::{CryptoProvider, WebPkiSupportedAlgorithms};
10use crate::verify::{
11 DigitallySignedStruct, HandshakeSignatureValid, ServerCertVerified, ServerCertVerifier,
12};
13use crate::webpki::verify::{
14 verify_server_cert_signed_by_trust_anchor_impl, verify_tls12_signature, verify_tls13_signature,
15 ParsedCertificate,
16};
17use crate::webpki::{parse_crls, verify_server_name, VerifierBuilderError};
18use crate::{Error, RootCertStore, SignatureScheme};
19
20#[cfg(doc)]
21use crate::{crypto, ConfigBuilder, ServerConfig};
22
23#[derive(Debug, Clone)]
27pub struct ServerCertVerifierBuilder {
28 roots: Arc<RootCertStore>,
29 crls: Vec<CertificateRevocationListDer<'static>>,
30 revocation_check_depth: RevocationCheckDepth,
31 unknown_revocation_policy: UnknownStatusPolicy,
32 supported_algs: WebPkiSupportedAlgorithms,
33}
34
35impl ServerCertVerifierBuilder {
36 pub(crate) fn new(
37 roots: Arc<RootCertStore>,
38 supported_algs: WebPkiSupportedAlgorithms,
39 ) -> Self {
40 Self {
41 roots,
42 crls: Vec::new(),
43 revocation_check_depth: RevocationCheckDepth::Chain,
44 unknown_revocation_policy: UnknownStatusPolicy::Deny,
45 supported_algs,
46 }
47 }
48
49 pub fn with_crls(
53 mut self,
54 crls: impl IntoIterator<Item = CertificateRevocationListDer<'static>>,
55 ) -> Self {
56 self.crls.extend(crls);
57 self
58 }
59
60 pub fn only_check_end_entity_revocation(mut self) -> Self {
70 self.revocation_check_depth = RevocationCheckDepth::EndEntity;
71 self
72 }
73
74 pub fn allow_unknown_revocation_status(mut self) -> Self {
83 self.unknown_revocation_policy = UnknownStatusPolicy::Allow;
84 self
85 }
86
87 pub fn build(self) -> Result<Arc<WebPkiServerVerifier>, VerifierBuilderError> {
102 if self.roots.is_empty() {
103 return Err(VerifierBuilderError::NoRootAnchors);
104 }
105
106 Ok(WebPkiServerVerifier::new(
107 self.roots,
108 parse_crls(self.crls)?,
109 self.revocation_check_depth,
110 self.unknown_revocation_policy,
111 self.supported_algs,
112 )
113 .into())
114 }
115}
116
117#[allow(unreachable_pub)]
119#[derive(Debug)]
120pub struct WebPkiServerVerifier {
121 roots: Arc<RootCertStore>,
122 crls: Vec<CertRevocationList<'static>>,
123 revocation_check_depth: RevocationCheckDepth,
124 unknown_revocation_policy: UnknownStatusPolicy,
125 supported: WebPkiSupportedAlgorithms,
126}
127
128#[allow(unreachable_pub)]
129impl WebPkiServerVerifier {
130 #[cfg(feature = "ring")]
140 pub fn builder(roots: Arc<RootCertStore>) -> ServerCertVerifierBuilder {
141 Self::builder_with_provider(roots, crate::crypto::ring::default_provider().into())
142 }
143
144 pub fn builder_with_provider(
153 roots: Arc<RootCertStore>,
154 provider: Arc<CryptoProvider>,
155 ) -> ServerCertVerifierBuilder {
156 ServerCertVerifierBuilder::new(roots, provider.signature_verification_algorithms)
157 }
158
159 pub(crate) fn new_without_revocation(
162 roots: impl Into<Arc<RootCertStore>>,
163 supported_algs: WebPkiSupportedAlgorithms,
164 ) -> Self {
165 Self::new(
166 roots,
167 Vec::default(),
168 RevocationCheckDepth::Chain,
169 UnknownStatusPolicy::Allow,
170 supported_algs,
171 )
172 }
173
174 pub(crate) fn new(
186 roots: impl Into<Arc<RootCertStore>>,
187 crls: Vec<CertRevocationList<'static>>,
188 revocation_check_depth: RevocationCheckDepth,
189 unknown_revocation_policy: UnknownStatusPolicy,
190 supported: WebPkiSupportedAlgorithms,
191 ) -> Self {
192 Self {
193 roots: roots.into(),
194 crls,
195 revocation_check_depth,
196 unknown_revocation_policy,
197 supported,
198 }
199 }
200}
201
202impl ServerCertVerifier for WebPkiServerVerifier {
203 fn verify_server_cert(
214 &self,
215 end_entity: &CertificateDer<'_>,
216 intermediates: &[CertificateDer<'_>],
217 server_name: &ServerName<'_>,
218 ocsp_response: &[u8],
219 now: UnixTime,
220 ) -> Result<ServerCertVerified, Error> {
221 let cert = ParsedCertificate::try_from(end_entity)?;
222
223 let crl_refs = self.crls.iter().collect::<Vec<_>>();
224
225 let revocation = if self.crls.is_empty() {
226 None
227 } else {
228 Some(
231 webpki::RevocationOptionsBuilder::new(crl_refs.as_slice())
232 .unwrap()
235 .with_depth(self.revocation_check_depth)
236 .with_status_policy(self.unknown_revocation_policy)
237 .build(),
238 )
239 };
240
241 verify_server_cert_signed_by_trust_anchor_impl(
244 &cert,
245 &self.roots,
246 intermediates,
247 revocation,
248 now,
249 self.supported.all,
250 )?;
251
252 if !ocsp_response.is_empty() {
253 trace!("Unvalidated OCSP response: {:?}", ocsp_response.to_vec());
254 }
255
256 verify_server_name(&cert, server_name)?;
257 Ok(ServerCertVerified::assertion())
258 }
259
260 fn verify_tls12_signature(
261 &self,
262 message: &[u8],
263 cert: &CertificateDer<'_>,
264 dss: &DigitallySignedStruct,
265 ) -> Result<HandshakeSignatureValid, Error> {
266 verify_tls12_signature(message, cert, dss, &self.supported)
267 }
268
269 fn verify_tls13_signature(
270 &self,
271 message: &[u8],
272 cert: &CertificateDer<'_>,
273 dss: &DigitallySignedStruct,
274 ) -> Result<HandshakeSignatureValid, Error> {
275 verify_tls13_signature(message, cert, dss, &self.supported)
276 }
277
278 fn supported_verify_schemes(&self) -> Vec<SignatureScheme> {
279 self.supported.supported_schemes()
280 }
281}
282
283#[cfg(all(test, any(feature = "ring", feature = "aws_lc_rs")))]
284mod tests {
285 use std::prelude::v1::*;
286 use std::sync::Arc;
287 use std::{println, vec};
288
289 use pki_types::{CertificateDer, CertificateRevocationListDer};
290
291 use super::{VerifierBuilderError, WebPkiServerVerifier};
292 use crate::{test_provider, RootCertStore};
293
294 fn load_crls(crls_der: &[&[u8]]) -> Vec<CertificateRevocationListDer<'static>> {
295 crls_der
296 .iter()
297 .map(|pem_bytes| {
298 rustls_pemfile::crls(&mut &pem_bytes[..])
299 .next()
300 .unwrap()
301 .unwrap()
302 })
303 .collect()
304 }
305
306 fn test_crls() -> Vec<CertificateRevocationListDer<'static>> {
307 load_crls(&[
308 include_bytes!("../../../test-ca/ecdsa-p256/client.revoked.crl.pem").as_slice(),
309 include_bytes!("../../../test-ca/rsa/client.revoked.crl.pem").as_slice(),
310 ])
311 }
312
313 fn load_roots(roots_der: &[&[u8]]) -> Arc<RootCertStore> {
314 let mut roots = RootCertStore::empty();
315 roots_der.iter().for_each(|der| {
316 roots
317 .add(CertificateDer::from(der.to_vec()))
318 .unwrap()
319 });
320 roots.into()
321 }
322
323 fn test_roots() -> Arc<RootCertStore> {
324 load_roots(&[
325 include_bytes!("../../../test-ca/ecdsa-p256/ca.der").as_slice(),
326 include_bytes!("../../../test-ca/rsa/ca.der").as_slice(),
327 ])
328 }
329
330 #[test]
331 fn test_with_invalid_crls() {
332 let result = WebPkiServerVerifier::builder_with_provider(
334 test_roots(),
335 test_provider::default_provider().into(),
336 )
337 .with_crls(vec![CertificateRevocationListDer::from(vec![0xFF])])
338 .build();
339 assert!(matches!(result, Err(VerifierBuilderError::InvalidCrl(_))));
340 }
341
342 #[test]
343 fn test_with_crls_multiple_calls() {
344 let initial_crls = test_crls();
346 let extra_crls =
347 load_crls(&[
348 include_bytes!("../../../test-ca/eddsa/client.revoked.crl.pem").as_slice(),
349 ]);
350
351 let builder = WebPkiServerVerifier::builder_with_provider(
352 test_roots(),
353 test_provider::default_provider().into(),
354 )
355 .with_crls(initial_crls.clone())
356 .with_crls(extra_crls.clone());
357
358 assert_eq!(builder.crls.len(), initial_crls.len() + extra_crls.len());
360 println!("{:?}", builder);
362 builder.build().unwrap();
363 }
364
365 #[test]
366 fn test_builder_no_roots() {
367 let result = WebPkiServerVerifier::builder_with_provider(
369 RootCertStore::empty().into(),
370 test_provider::default_provider().into(),
371 )
372 .build();
373 assert!(matches!(result, Err(VerifierBuilderError::NoRootAnchors)));
374 }
375
376 #[test]
377 fn test_server_verifier_ee_only() {
378 let builder = WebPkiServerVerifier::builder_with_provider(
380 test_roots(),
381 test_provider::default_provider().into(),
382 )
383 .only_check_end_entity_revocation();
384 println!("{:?}", builder);
386 builder.build().unwrap();
387 }
388
389 #[test]
390 fn test_server_verifier_allow_unknown() {
391 let builder = WebPkiServerVerifier::builder_with_provider(
394 test_roots(),
395 test_provider::default_provider().into(),
396 )
397 .allow_unknown_revocation_status();
398 println!("{:?}", builder);
400 builder.build().unwrap();
401 }
402
403 #[test]
404 fn test_server_verifier_allow_unknown_ee_only() {
405 let builder = WebPkiServerVerifier::builder_with_provider(
408 test_roots(),
409 test_provider::default_provider().into(),
410 )
411 .allow_unknown_revocation_status()
412 .only_check_end_entity_revocation();
413 println!("{:?}", builder);
415 builder.build().unwrap();
416 }
417}