http_tracker.rs

use std::net::SocketAddr;
use std::sync::Arc;

use log::{info, warn};
use tokio::task::JoinHandle;

use crate::config::HttpTracker;
use crate::http::server::Http;
use crate::tracker;

/// # Panics
///
/// It would panic if the `config::HttpTracker` struct would contain an inappropriate values.
#[must_use]
pub fn start_job(config: &HttpTracker, tracker: Arc<tracker::Tracker>) -> JoinHandle<()> {
    let bind_addr = config.bind_address.parse::<SocketAddr>().unwrap();
    let ssl_enabled = config.ssl_enabled;
    let ssl_cert_path = config.ssl_cert_path.clone();
    let ssl_key_path = config.ssl_key_path.clone();

    tokio::spawn(async move {
        let http_tracker = Http::new(tracker);

        if !ssl_enabled {
            info!("Starting HTTP server on: http://{}", bind_addr);
            http_tracker.start(bind_addr).await;
        } else if ssl_enabled && ssl_cert_path.is_some() && ssl_key_path.is_some() {
            info!("Starting HTTPS server on: https://{} (TLS)", bind_addr);
            http_tracker
                .start_tls(bind_addr, ssl_cert_path.unwrap(), ssl_key_path.unwrap())
                .await;
        } else {
            warn!("Could not start HTTP tracker on: {}, missing SSL Cert or Key!", bind_addr);
        }
    })
}