Updating peer certificate logic to work with modern rustls

.gitignore

@@ -4,3 +4,5 @@
 Cargo.lock
 .idea/
 warp.iml
+
+*.swp

Cargo.toml

@@ -41,6 +41,7 @@ percent-encoding = "2.1"
 pin-project = "1.0"
 tokio-rustls = { version = "0.25", optional = true }
 rustls-pemfile = { version = "2.0", optional = true }
+rustls-pki-types = { version = "1.9.0", optional = true }
 
 [dev-dependencies]
 pretty_env_logger = "0.5"
@@ -56,7 +57,7 @@ listenfd = "1.0"
 default = ["multipart", "websocket"]
 multipart = ["multer"]
 websocket = ["tokio-tungstenite"]
-tls = ["tokio-rustls", "rustls-pemfile"]
+tls = ["tokio-rustls", "rustls-pemfile", "rustls-pki-types"]
 
 # Enable compression-related filters
 compression = ["compression-brotli", "compression-gzip"]

src/filters/mtls.rs

@@ -2,13 +2,16 @@
 
 use std::convert::Infallible;
 
-use tokio_rustls::rustls::Certificate;
+use rustls_pki_types::CertificateDer;
 
 use crate::{
     filter::{filter_fn_one, Filter},
     route::Route,
 };
 
+/// Certificates is a iterable container of Certificates.
+pub type Certificates = Vec<CertificateDer<'static>>;
+
 /// Creates a `Filter` to get the peer certificates for the TLS connection.
 ///
 /// If the underlying transport doesn't have peer certificates, this will yield
@@ -27,35 +30,23 @@ use crate::{
 /// ```
 pub fn peer_certificates(
 ) -> impl Filter<Extract = (Option<Certificates>,), Error = Infallible> + Copy {
-    filter_fn_one(|route| futures_util::future::ok(Certificates::from_route(route)))
+    filter_fn_one(|route| futures_util::future::ok(from_route(route)))
 }
 
-/// Certificates is a iterable container of Certificates.
-#[derive(Debug)]
-pub struct Certificates(Vec<Certificate>);
-
-impl Certificates {
-    fn from_route(route: &Route) -> Option<Certificates> {
-        route
-            .peer_certificates()
-            .read()
-            .unwrap()
-            .as_ref()
-            .map(|certs| Self(certs.to_vec()))
-    }
+/// Testing
+pub fn peer_certs_into_owned(certs: &Vec<CertificateDer<'_>>) -> Vec<CertificateDer<'static>> {
+    certs
+        .to_vec()
+        .iter()
+        .map(|cert| cert.clone().into_owned())
+        .collect()
 }
 
-impl AsRef<[Certificate]> for Certificates {
-    fn as_ref(&self) -> &[Certificate] {
-        self.0.as_ref()
-    }
-}
-
-impl<'a> IntoIterator for &'a Certificates {
-    type Item = &'a Certificate;
-    type IntoIter = std::slice::Iter<'a, Certificate>;
-
-    fn into_iter(self) -> Self::IntoIter {
-        self.0.iter()
-    }
+fn from_route(route: &Route) -> Option<Certificates> {
+    route
+        .peer_certificates()
+        .read()
+        .unwrap()
+        .as_ref()
+        .map(peer_certs_into_owned)
 }

src/test.rs

@@ -113,11 +113,14 @@ use crate::filters::ws::Message;
 use crate::reject::IsReject;
 use crate::reply::Reply;
 use crate::route::{self, Route};
-use crate::Request;
 use crate::transport::PeerInfo;
+use crate::Request;
 #[cfg(feature = "websocket")]
 use crate::{Sink, Stream};
 
+#[cfg(feature = "tls")]
+use crate::filters::mtls::Certificates;
+
 use self::inner::OneOrTuple;
 
 /// Starts a new test `RequestBuilder`.
@@ -256,10 +259,10 @@ impl RequestBuilder {
     /// # Example
     /// ```
     /// let req = warp::test::request()
-    ///     .peer_certificates([tokio_rustls::rustls::Certificate(b"FAKE CERT".to_vec())]);
+    ///     .peer_certificates([rustls_pki_types::CertificateDer::from_slice(b"FAKE CERT")]);
     /// ```
     #[cfg(feature = "tls")]
-    pub fn peer_certificates(self, certs: impl Into<Vec<tokio_rustls::rustls::Certificate>>) -> Self {
+    pub fn peer_certificates(self, certs: impl Into<Certificates>) -> Self {
         *self.peer_info.peer_certificates.write().unwrap() = Some(certs.into());
         self
     }

src/tls.rs

@@ -15,6 +15,7 @@ use hyper::server::conn::{AddrIncoming, AddrStream};
 use tokio_rustls::rustls::server::WebPkiClientVerifier;
 use tokio_rustls::rustls::{Error as TlsError, RootCertStore, ServerConfig};
 
+use crate::filters::mtls::peer_certs_into_owned;
 use crate::transport::{PeerCertificates, Transport};
 
 /// Represents errors that can occur building the TlsConfig
@@ -327,8 +328,9 @@ impl AsyncRead for TlsStream {
             State::Handshaking(ref mut accept) => match ready!(Pin::new(accept).poll(cx)) {
                 Ok(mut stream) => {
                     let (_, conn) = stream.get_ref();
-                    *pin.peer_certs.write().unwrap() =
-                        conn.peer_certificates().map(|certs| certs.to_vec());
+                    *pin.peer_certs.write().unwrap() = conn
+                        .peer_certificates()
+                        .map(|certs| peer_certs_into_owned(&certs.to_vec()));
 
                     let result = Pin::new(&mut stream).poll_read(cx, buf);
                     pin.state = State::Streaming(stream);

src/transport.rs

@@ -7,7 +7,10 @@ use hyper::server::conn::AddrStream;
 use tokio::io::{AsyncRead, AsyncWrite, ReadBuf};
 
 #[cfg(feature = "tls")]
-pub(crate) type PeerCertificates = std::sync::Arc<std::sync::RwLock<Option<Vec<tokio_rustls::rustls::Certificate>>>>;
+use crate::filters::mtls::Certificates;
+
+#[cfg(feature = "tls")]
+pub(crate) type PeerCertificates = std::sync::Arc<std::sync::RwLock<Option<Certificates>>>;
 #[cfg(not(feature = "tls"))]
 pub(crate) type PeerCertificates = ();