Line data    Source code

       1              : pub mod routes;
       2              : use std::sync::Arc;
       3              : 
       4              : pub use routes::make_router;
       5              : pub use safekeeper_api::models;
       6              : use tokio_util::sync::CancellationToken;
       7              : 
       8              : use crate::{GlobalTimelines, SafeKeeperConf};
       9              : 
      10            0 : pub async fn task_main_http(
      11            0 :     conf: Arc<SafeKeeperConf>,
      12            0 :     http_listener: std::net::TcpListener,
      13            0 :     global_timelines: Arc<GlobalTimelines>,
      14            0 : ) -> anyhow::Result<()> {
      15            0 :     let router = make_router(conf, global_timelines)
      16            0 :         .build()
      17            0 :         .map_err(|err| anyhow::anyhow!(err))?;
      18              : 
      19            0 :     let service = Arc::new(
      20            0 :         http_utils::RequestServiceBuilder::new(router).map_err(|err| anyhow::anyhow!(err))?,
      21              :     );
      22            0 :     let server = http_utils::server::Server::new(service, http_listener, None)?;
      23            0 :     server.serve(CancellationToken::new()).await?;
      24            0 :     Ok(()) // unreachable
      25            0 : }
      26              : 
      27            0 : pub async fn task_main_https(
      28            0 :     conf: Arc<SafeKeeperConf>,
      29            0 :     https_listener: std::net::TcpListener,
      30            0 :     global_timelines: Arc<GlobalTimelines>,
      31            0 : ) -> anyhow::Result<()> {
      32            0 :     let certs = http_utils::tls_certs::load_cert_chain(&conf.ssl_cert_file)?;
      33            0 :     let key = http_utils::tls_certs::load_private_key(&conf.ssl_key_file)?;
      34              : 
      35            0 :     let server_config = rustls::ServerConfig::builder()
      36            0 :         .with_no_client_auth()
      37            0 :         .with_single_cert(certs, key)?;
      38              : 
      39            0 :     let tls_acceptor = tokio_rustls::TlsAcceptor::from(Arc::new(server_config));
      40              : 
      41            0 :     let router = make_router(conf, global_timelines)
      42            0 :         .build()
      43            0 :         .map_err(|err| anyhow::anyhow!(err))?;
      44              : 
      45            0 :     let service = Arc::new(
      46            0 :         http_utils::RequestServiceBuilder::new(router).map_err(|err| anyhow::anyhow!(err))?,
      47              :     );
      48            0 :     let server = http_utils::server::Server::new(service, https_listener, Some(tls_acceptor))?;
      49            0 :     server.serve(CancellationToken::new()).await?;
      50            0 :     Ok(()) // unreachable
      51            0 : }