mirror of
https://github.com/servo/servo.git
synced 2025-06-06 16:45:39 +00:00
120 lines
4.3 KiB
Rust
120 lines
4.3 KiB
Rust
/* This Source Code Form is subject to the terms of the Mozilla Public
|
|
* License, v. 2.0. If a copy of the MPL was not distributed with this
|
|
* file, You can obtain one at https://mozilla.org/MPL/2.0/. */
|
|
|
|
use crate::hosts::replace_host;
|
|
use hyper::client::connect::{Connect, Destination};
|
|
use hyper::client::HttpConnector as HyperHttpConnector;
|
|
use hyper::rt::Future;
|
|
use hyper::{Body, Client};
|
|
use hyper_openssl::HttpsConnector;
|
|
use openssl::ssl::{SslConnector, SslConnectorBuilder, SslMethod, SslOptions};
|
|
use openssl::x509;
|
|
use tokio::prelude::future::Executor;
|
|
|
|
pub const BUF_SIZE: usize = 32768;
|
|
pub const ALPN_H2_H1: &'static [u8] = b"\x02h2\x08http/1.1";
|
|
pub const ALPN_H1: &'static [u8] = b"\x08http/1.1";
|
|
|
|
// See https://wiki.mozilla.org/Security/Server_Side_TLS for orientation.
|
|
const TLS1_2_CIPHERSUITES: &'static str = concat!(
|
|
"ECDHE-ECDSA-CHACHA20-POLY1305:ECDHE-RSA-CHACHA20-POLY1305:",
|
|
"ECDHE-ECDSA-AES256-GCM-SHA384:ECDHE-ECDSA-AES128-GCM-SHA256:",
|
|
"ECDHE-RSA-AES256-GCM-SHA384:ECDHE-RSA-AES128-GCM-SHA256:",
|
|
"ECDHE-RSA-AES256-SHA:ECDHE-RSA-AES128-SHA"
|
|
);
|
|
const SIGNATURE_ALGORITHMS: &'static str = concat!(
|
|
"ed448:ed25519:",
|
|
"ECDSA+SHA384:ECDSA+SHA256:",
|
|
"RSA-PSS+SHA512:RSA-PSS+SHA384:RSA-PSS+SHA256:",
|
|
"RSA+SHA512:RSA+SHA384:RSA+SHA256"
|
|
);
|
|
|
|
pub struct HttpConnector {
|
|
inner: HyperHttpConnector,
|
|
}
|
|
|
|
impl HttpConnector {
|
|
fn new() -> HttpConnector {
|
|
let mut inner = HyperHttpConnector::new(4);
|
|
inner.enforce_http(false);
|
|
inner.set_happy_eyeballs_timeout(None);
|
|
HttpConnector { inner }
|
|
}
|
|
}
|
|
|
|
impl Connect for HttpConnector {
|
|
type Transport = <HyperHttpConnector as Connect>::Transport;
|
|
type Error = <HyperHttpConnector as Connect>::Error;
|
|
type Future = <HyperHttpConnector as Connect>::Future;
|
|
|
|
fn connect(&self, dest: Destination) -> Self::Future {
|
|
// Perform host replacement when making the actual TCP connection.
|
|
let mut new_dest = dest.clone();
|
|
let addr = replace_host(dest.host());
|
|
new_dest.set_host(&*addr).unwrap();
|
|
self.inner.connect(new_dest)
|
|
}
|
|
}
|
|
|
|
pub type Connector = HttpsConnector<HttpConnector>;
|
|
pub type TlsConfig = SslConnectorBuilder;
|
|
|
|
pub fn create_tls_config(certs: &str, alpn: &[u8]) -> TlsConfig {
|
|
// certs include multiple certificates. We could add all of them at once,
|
|
// but if any of them were already added, openssl would fail to insert all
|
|
// of them.
|
|
let mut certs = certs;
|
|
let mut cfg = SslConnector::builder(SslMethod::tls()).unwrap();
|
|
loop {
|
|
let token = "-----END CERTIFICATE-----";
|
|
if let Some(index) = certs.find(token) {
|
|
let (cert, rest) = certs.split_at(index + token.len());
|
|
certs = rest;
|
|
let cert = x509::X509::from_pem(cert.as_bytes()).unwrap();
|
|
cfg.cert_store_mut()
|
|
.add_cert(cert)
|
|
.or_else(|e| {
|
|
let v: Option<Option<&str>> = e.errors().iter().nth(0).map(|e| e.reason());
|
|
if v == Some(Some("cert already in hash table")) {
|
|
warn!("Cert already in hash table. Ignoring.");
|
|
// Ignore error X509_R_CERT_ALREADY_IN_HASH_TABLE which means the
|
|
// certificate is already in the store.
|
|
Ok(())
|
|
} else {
|
|
Err(e)
|
|
}
|
|
})
|
|
.expect("could not set CA file");
|
|
} else {
|
|
break;
|
|
}
|
|
}
|
|
cfg.set_alpn_protos(alpn)
|
|
.expect("could not set alpn protocols");
|
|
cfg.set_cipher_list(TLS1_2_CIPHERSUITES)
|
|
.expect("could not set TLS 1.2 ciphersuites");
|
|
cfg.set_sigalgs_list(SIGNATURE_ALGORITHMS)
|
|
.expect("could not set signature algorithms");
|
|
cfg.set_options(
|
|
SslOptions::NO_SSLV2 |
|
|
SslOptions::NO_SSLV3 |
|
|
SslOptions::NO_TLSV1 |
|
|
SslOptions::NO_TLSV1_1 |
|
|
SslOptions::NO_COMPRESSION,
|
|
);
|
|
|
|
cfg
|
|
}
|
|
|
|
pub fn create_http_client<E>(tls_config: TlsConfig, executor: E) -> Client<Connector, Body>
|
|
where
|
|
E: Executor<Box<dyn Future<Error = (), Item = ()> + Send + 'static>> + Sync + Send + 'static,
|
|
{
|
|
let connector = HttpsConnector::with_connector(HttpConnector::new(), tls_config).unwrap();
|
|
|
|
Client::builder()
|
|
.http1_title_case_headers(true)
|
|
.executor(executor)
|
|
.build(connector)
|
|
}
|