#![cfg(feature = "rustls")] //! Commonly used code in most examples. use proto::EndpointConfig; use quinn::{ClientConfig, Endpoint, ServerConfig}; use std::{error::Error, sync::Arc}; use scionnet::SocketAddr; pub fn make_scion_server_endpoint2(bind_addr: SocketAddr) -> Result<(Endpoint, Vec), Box> { let (server_config, server_cert) = configure_server()?; let endpoint = Endpoint::new_scion(EndpointConfig::default(), Some(server_config), Some( bind_addr), None)?; Ok((endpoint, server_cert)) } pub fn make_scion_client_endpoint2( bind_addr: SocketAddr, server_certs: &[&[u8]], ) -> Result> { let client_cfg = configure_client(server_certs)?; let mut endpoint = Endpoint::new_scion( EndpointConfig::default(), None, Some(bind_addr), None)?; endpoint.set_default_client_config(client_cfg); Ok(endpoint) } pub fn make_scion_server_endpoint(bind_addr: SocketAddr) -> Result<(Endpoint, Vec), Box> { let (server_config, server_cert) = configure_server()?; let endpoint = Endpoint::default_scion_server(server_config, bind_addr)?; Ok((endpoint, server_cert)) } pub fn make_scion_client_endpoint( bind_addr: SocketAddr, server_certs: &[&[u8]], ) -> Result> { let client_cfg = configure_client(server_certs)?; let mut endpoint = Endpoint::default_scion_client(/*bind_addr*/)?; endpoint.set_default_client_config(client_cfg); Ok(endpoint) } /// Constructs a QUIC endpoint configured for use a client only. /// /// ## Args /// /// - server_certs: list of trusted certificates. #[allow(unused)] pub fn make_client_endpoint( bind_addr: SocketAddr, server_certs: &[&[u8]], ) -> Result> { let client_cfg = configure_client(server_certs)?; let mut endpoint = Endpoint::client(bind_addr)?; endpoint.set_default_client_config(client_cfg); Ok(endpoint) } /// Constructs a QUIC endpoint configured to listen for incoming connections on a certain address /// and port. /// /// ## Returns /// /// - a stream of incoming QUIC connections /// - server certificate serialized into DER format #[allow(unused)] pub fn make_server_endpoint(bind_addr: SocketAddr) -> Result<(Endpoint, Vec), Box> { let (server_config, server_cert) = configure_server()?; let endpoint = Endpoint::server(server_config, bind_addr)?; Ok((endpoint, server_cert)) } /// Builds default quinn client config and trusts given certificates. /// /// ## Args /// /// - server_certs: a list of trusted certificates in DER format. fn configure_client(server_certs: &[&[u8]]) -> Result> { let mut certs = rustls::RootCertStore::empty(); for cert in server_certs { certs.add(&rustls::Certificate(cert.to_vec()))?; } let client_config = ClientConfig::with_root_certificates(certs); Ok(client_config) } /// Returns default server configuration along with its certificate. fn configure_server() -> Result<(ServerConfig, Vec), Box> { let cert = rcgen::generate_simple_self_signed(vec!["localhost".into()]).unwrap(); let cert_der = cert.serialize_der().unwrap(); let priv_key = cert.serialize_private_key_der(); let priv_key = rustls::PrivateKey(priv_key); let cert_chain = vec![rustls::Certificate(cert_der.clone())]; let mut server_config = ServerConfig::with_single_cert(cert_chain, priv_key)?; let transport_config = Arc::get_mut(&mut server_config.transport).unwrap(); transport_config.max_concurrent_uni_streams(0_u8.into()); Ok((server_config, cert_der)) } #[allow(unused)] pub const ALPN_QUIC_HTTP: &[&[u8]] = &[b"hq-29"];