configure tls automatically when possible (#445)

hyperium · Apr 23, 2021 · b04c1c6 · b04c1c6
1 parent d414206
commit b04c1c6
Showing 1 changed file with 26 additions and 3 deletions.
diff --git a/tonic/src/transport/service/connector.rs b/tonic/src/transport/service/connector.rs
@@ -36,6 +36,26 @@ impl<C> Connector<C> {
     fn new(inner: C, tls: Option<TlsConnector>) -> Self {
         Self { inner, tls }
     }
+
+    #[cfg(feature = "tls-roots")]
+    fn tls_or_default(&self, scheme: Option<&str>, host: Option<&str>) -> Option<TlsConnector> {
+        use tokio_rustls::webpki::DNSNameRef;
+
+        if self.tls.is_some() {
+            return self.tls.clone();
+        }
+
+        match (scheme, host) {
+            (Some("https"), Some(host)) => {
+                if DNSNameRef::try_from_ascii(host.as_bytes()).is_ok() {
+                    TlsConnector::new_with_rustls_cert(None, None, host.to_owned()).ok()
+                } else {
+                    None
+                }
+            }
+            _ => None,
+        }
+    }
 }
 
 impl<C> Service<Uri> for Connector<C>
@@ -54,11 +74,14 @@ where
     }
 
     fn call(&mut self, uri: Uri) -> Self::Future {
-        let connect = self.inner.make_connection(uri);
-
-        #[cfg(feature = "tls")]
+        #[cfg(all(feature = "tls", not(feature = "tls-roots")))]
         let tls = self.tls.clone();
 
+        #[cfg(feature = "tls-roots")]
+        let tls = self.tls_or_default(uri.scheme_str(), uri.host());
+
+        let connect = self.inner.make_connection(uri);
+
         Box::pin(async move {
             let io = connect.await?;