rama/http/

tls.rs

//! tls features provided from the http layer.

use crate::error::{ErrorContext as _, OpaqueError};
use crate::http::{
    BodyExtractExt as _, Request, Response, StatusCode, Uri, client::EasyHttpWebClient,
    service::client::HttpClientExt as _,
};
use crate::net::address::{AsDomainRef, Domain, DomainParentMatch, DomainTrie};
use crate::net::tls::{
    DataEncoding,
    client::ClientHello,
    server::{DynamicCertIssuer, ServerAuthData},
};
use crate::rt::Executor;
use crate::telemetry::tracing;
use crate::utils::str::NonEmptyStr;
use crate::{Service, combinators::Either, service::BoxService};

use base64::Engine;
use base64::engine::general_purpose::STANDARD as ENGINE;
use serde::{Deserialize, Serialize};

#[derive(Debug, Clone, Serialize, Deserialize)]
/// Json input used as http (POST) request payload sent by the [`CertIssuerHttpClient`].
pub struct CertOrderInput {
    pub domain: Domain,
}

#[derive(Debug, Clone, Serialize, Deserialize)]
/// Json payload expected in
/// the http (POST) response payload as received by the [`CertIssuerHttpClient`].
pub struct CertOrderOutput {
    pub crt_pem_base64: String,
    pub key_pem_base64: String,
}

#[derive(Debug)]
/// An http client used to fetch certs dynamically ([`DynamicCertIssuer`]).
///
/// There is no server implementation in Rama.
/// It is up to the user of this client to provide their own server.
pub struct CertIssuerHttpClient {
    endpoint: Uri,
    allow_list: Option<DomainTrie<DomainAllowMode>>,
    http_client: BoxService<Request, Response, OpaqueError>,
}

#[derive(Debug, Clone)]
enum DomainAllowMode {
    Exact,
    Parent(Domain),
}

impl CertIssuerHttpClient {
    /// Create a new [`CertIssuerHttpClient`] using the default [`EasyHttpWebClient`].
    pub fn new(exec: Executor, endpoint: Uri) -> Self {
        Self::new_with_client(
            endpoint,
            EasyHttpWebClient::default_with_executor(exec).boxed(),
        )
    }

    #[cfg(feature = "boring")]
    #[cfg_attr(docsrs, doc(cfg(feature = "boring")))]
    pub fn try_from_env(exec: Executor) -> Result<Self, OpaqueError> {
        use crate::{
            Layer as _,
            http::{headers::Authorization, layer::set_header::SetRequestHeaderLayer},
            net::user::Bearer,
            tls::boring::{
                client::TlsConnectorDataBuilder,
                core::x509::{X509, store::X509StoreBuilder},
            },
        };
        use std::sync::Arc;

        let uri_raw = std::env::var("RAMA_TLS_REMOTE").context("RAMA_TLS_REMOTE is undefined")?;

        let mut tls_config = TlsConnectorDataBuilder::new_http_auto();

        if let Ok(remote_ca_raw) = std::env::var("RAMA_TLS_REMOTE_CA") {
            let mut store_builder = X509StoreBuilder::new().context("build x509 store builder")?;
            store_builder
                .add_cert(
                    X509::from_pem(
                        &ENGINE
                            .decode(remote_ca_raw)
                            .context("base64 decode RAMA_TLS_REMOTE_CA")?[..],
                    )
                    .context("load CA cert")?,
                )
                .context("add CA cert to store builder")?;
            let store = store_builder.build();
            tls_config.set_server_verify_cert_store(Arc::new(store));
        }

        let client = EasyHttpWebClient::connector_builder()
            .with_default_transport_connector()
            .without_tls_proxy_support()
            .without_proxy_support()
            .with_tls_support_using_boringssl(Some(Arc::new(tls_config)))
            .with_default_http_connector(exec)
            .build_client();

        let uri: Uri = uri_raw.parse().context("parse RAMA_TLS_REMOTE as URI")?;
        let mut client = if let Ok(auth_raw) = std::env::var("RAMA_TLS_REMOTE_AUTH") {
            Self::new_with_client(
                uri,
                SetRequestHeaderLayer::overriding_typed(Authorization::new(
                    Bearer::try_from(auth_raw)
                        .context("try to create Bearer using RAMA_TLS_REMOTE_AUTH")?,
                ))
                .into_layer(client)
                .boxed(),
            )
        } else {
            Self::new_with_client(uri, client.boxed())
        };

        if let Ok(allow_cn_csv_raw) = std::env::var("RAMA_TLS_REMOTE_CN_CSV") {
            for raw_cn_str in allow_cn_csv_raw.split(',') {
                let cn: Domain = raw_cn_str.parse().context("parse CN as a a valid domain")?;
                client.set_allow_domain(cn);
            }
        }

        Ok(client)
    }

    /// Create a new [`CertIssuerHttpClient`] using a custom http client.
    ///
    /// The custom http client allows you to add whatever layers and client implementation
    /// you wish, to allow for custom headers, behaviour and security measures
    /// such as authorization.
    pub fn new_with_client(
        endpoint: Uri,
        client: BoxService<Request, Response, OpaqueError>,
    ) -> Self {
        Self {
            endpoint,
            allow_list: None,
            http_client: client,
        }
    }

    crate::utils::macros::generate_set_and_with! {
        /// Only allow fetching certs for the given domain.
        ///
        /// By default, if none of the `allow_*` setters are called
        /// the client will fetch for any client.
        pub fn allow_domain(mut self, domain: impl AsDomainRef) -> Self {
            if let Some(parent) = domain.as_wildcard_parent() && let Ok(domain) = parent.try_as_wildcard() {
                self.allow_list.get_or_insert_default().insert_domain(parent, DomainAllowMode::Parent(domain));
            } else {
                self.allow_list.get_or_insert_default().insert_domain(domain, DomainAllowMode::Exact);
            }
            self
        }
    }

    crate::utils::macros::generate_set_and_with! {
        /// Only allow fetching certs for the given domains.
        ///
        /// By default, if none of the `allow_*` setters are called
        /// the client will fetch for any client.
        pub fn allow_domains(mut self, domains: impl IntoIterator<Item: AsDomainRef>) -> Self {
            for domain in domains {
                self.set_allow_domain(domain);
            }
            self
        }
    }

    /// Prefetch all certificates, useful to warm them up at startup time.
    pub fn prefetch_certs_in_background(&self, exec: &Executor) {
        if let Some(allow_list) = &self.allow_list {
            for (domain_key, mode) in allow_list.iter() {
                let domain = match mode {
                    // assumption: only valid domains in trie possible
                    DomainAllowMode::Exact => domain_key,
                    DomainAllowMode::Parent(domain) => domain.clone(),
                };
                let http_client = self.http_client.clone();
                let uri = self.endpoint.clone();
                exec.spawn_task(async move {
                    match fetch_certs(http_client, domain.clone(), uri).await {
                        Ok(_) => tracing::debug!("prefetched certificates for domain: {domain}"),
                        Err(err) => tracing::error!(
                            "failed to prefetch certificates for domain '{domain}': {err}"
                        ),
                    }
                });
            }
        }
    }
}

impl DynamicCertIssuer for CertIssuerHttpClient {
    fn issue_cert(
        &self,
        client_hello: ClientHello,
        _server_name: Option<Domain>,
    ) -> impl Future<Output = Result<ServerAuthData, OpaqueError>> + Send + Sync + '_ {
        let domain = match client_hello.ext_server_name() {
            Some(domain) => {
                if let Some(ref allow_list) = self.allow_list {
                    match allow_list.match_parent(domain) {
                        None => {
                            return Either::A(std::future::ready(Err(OpaqueError::from_display(
                                "sni found: unexpected unknown domain",
                            ))));
                        }
                        Some(DomainParentMatch {
                            value: &DomainAllowMode::Exact,
                            is_exact,
                            ..
                        }) => {
                            if is_exact {
                                domain.clone()
                            } else {
                                return Either::A(std::future::ready(Err(
                                    OpaqueError::from_display("sni found: unexpected child domain"),
                                )));
                            }
                        }
                        Some(DomainParentMatch {
                            value: DomainAllowMode::Parent(wildcard_domain),
                            ..
                        }) => wildcard_domain.clone(),
                    }
                } else {
                    domain.clone()
                }
            }
            None => {
                return Either::A(std::future::ready(Err(OpaqueError::from_display(
                    "no SNI found: failure",
                ))));
            }
        };

        let (tx, rx) = tokio::sync::oneshot::channel();
        let http_client = self.http_client.clone();
        let uri = self.endpoint.clone();

        tokio::spawn(async move {
            if let Err(err) = tx.send(fetch_certs(http_client, domain, uri).await) {
                tracing::debug!("failed to send result back to callee: {err:?}");
            }
        });

        Either::B(async move { rx.await.context("await crt order result")? })
    }

    fn norm_cn(&self, domain: &Domain) -> Option<&Domain> {
        if let Some(ref allow_list) = self.allow_list {
            match allow_list.match_parent(domain) {
                None
                | Some(DomainParentMatch {
                    value: &DomainAllowMode::Exact,
                    ..
                }) => None,
                Some(DomainParentMatch {
                    value: DomainAllowMode::Parent(wildcard_domain),
                    ..
                }) => Some(wildcard_domain),
            }
        } else {
            None
        }
    }
}

async fn fetch_certs(
    client: BoxService<Request, Response, OpaqueError>,
    domain: Domain,
    uri: Uri,
) -> Result<ServerAuthData, OpaqueError> {
    let response = client
        .post(uri)
        .json(&CertOrderInput { domain })
        .send()
        .await
        .context("send order request")?;

    let status = response.status();
    if status != StatusCode::OK {
        return Err(OpaqueError::from_display(format!(
            "unexpected dinocert order response status code: {status}"
        )));
    }

    let CertOrderOutput {
        crt_pem_base64,
        key_pem_base64,
    } = response
        .into_body()
        .try_into_json()
        .await
        .context("fetch json crt order response")?;

    let crt = ENGINE.decode(crt_pem_base64).context("base64 decode crt")?;
    let key = ENGINE.decode(key_pem_base64).context("base64 decode crt")?;

    Ok(ServerAuthData {
        cert_chain: DataEncoding::Pem(
            NonEmptyStr::try_from(
                String::from_utf8(crt).context("concert crt pem to utf8 string")?,
            )
            .context("convert crt utf8 string to non-empty")?,
        ),
        private_key: DataEncoding::Pem(
            NonEmptyStr::try_from(
                String::from_utf8(key).context("concert private key pem to utf8 string")?,
            )
            .context("convert privatek key pem utf8 string to non-empty")?,
        ),
        ocsp: None,
    })
}

#[cfg(test)]
mod tests {
    use super::*;

    #[test]
    fn test_issuer_kind_norm_cn() {
        let issuer =
            CertIssuerHttpClient::new(Executor::default(), Uri::from_static("http://example.com"))
                .with_allow_domains(["*.foo.com", "bar.org", "*.example.io", "example.net"]);
        for (input, expected) in [
            ("example.com", None),
            ("www.foo.com", Some("*.foo.com")),
            ("bar.foo.com", Some("*.foo.com")),
            ("bar.example.io", Some("*.example.io")),
            ("example.net", None),
            ("foo.example.net", None),
            ("foo.bar.org", None),
            ("bar.org", None),
        ] {
            let output = issuer
                .norm_cn(&Domain::from_static(input))
                .map(|d| d.as_str());
            assert_eq!(output, expected, "{input:?} ; {expected:?}")
        }
    }
}