bytehaul 0.1.8

use std::collections::HashMap;
use std::path::{Path, PathBuf};
use std::time::Duration;

use crate::error::DownloadError;

/// Log verbosity level for download tasks.
///
/// The default is `Off`, which means no log events are emitted by the library.
/// When set to a non-`Off` value, log events up to and including that level
/// will be produced via the `tracing` crate. A subscriber must be installed
/// by the application (or the Python binding) to actually see the output.
#[derive(Debug, Clone, Copy, PartialEq, Eq, PartialOrd, Ord, Hash, Default)]
pub enum LogLevel {
    /// No logging.
    #[default]
    Off = 0,
    /// Errors only.
    Error = 1,
    /// Errors and warnings.
    Warn = 2,
    /// Errors, warnings, and informational messages.
    Info = 3,
    /// All of the above plus debug details.
    Debug = 4,
    /// Most verbose level including trace-level details.
    Trace = 5,
}



impl std::fmt::Display for LogLevel {
    fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result {
        let s = match self {
            LogLevel::Off => "off",
            LogLevel::Error => "error",
            LogLevel::Warn => "warn",
            LogLevel::Info => "info",
            LogLevel::Debug => "debug",
            LogLevel::Trace => "trace",
        };
        f.write_str(s)
    }
}

impl std::str::FromStr for LogLevel {
    type Err = String;

    fn from_str(s: &str) -> Result<Self, Self::Err> {
        match s.to_ascii_lowercase().as_str() {
            "off" => Ok(LogLevel::Off),
            "error" => Ok(LogLevel::Error),
            "warn" | "warning" => Ok(LogLevel::Warn),
            "info" => Ok(LogLevel::Info),
            "debug" => Ok(LogLevel::Debug),
            "trace" => Ok(LogLevel::Trace),
            _ => Err(format!(
                "invalid log level: '{s}'; expected one of: off, error, warn, info, debug, trace"
            )),
        }
    }
}

impl LogLevel {
    /// Check whether a `tracing::Level` should be emitted given this log level.
    pub(crate) fn enabled(self, level: tracing::Level) -> bool {
        match level {
            tracing::Level::ERROR => self >= LogLevel::Error,
            tracing::Level::WARN => self >= LogLevel::Warn,
            tracing::Level::INFO => self >= LogLevel::Info,
            tracing::Level::DEBUG => self >= LogLevel::Debug,
            tracing::Level::TRACE => self >= LogLevel::Trace,
        }
    }

    /// Convert to the corresponding `tracing::level_filters::LevelFilter`.
    pub fn to_tracing_level_filter(self) -> tracing::level_filters::LevelFilter {
        match self {
            LogLevel::Off => tracing::level_filters::LevelFilter::OFF,
            LogLevel::Error => tracing::level_filters::LevelFilter::ERROR,
            LogLevel::Warn => tracing::level_filters::LevelFilter::WARN,
            LogLevel::Info => tracing::level_filters::LevelFilter::INFO,
            LogLevel::Debug => tracing::level_filters::LevelFilter::DEBUG,
            LogLevel::Trace => tracing::level_filters::LevelFilter::TRACE,
        }
    }
}

/// File allocation strategy.
#[derive(Debug, Clone, Copy, PartialEq, Eq, Default)]
pub enum FileAllocation {
    /// No pre-allocation; file grows as data is written.
    None,
    /// Pre-allocate the full file size by writing zeros before downloading.
    #[default]
    Prealloc,
}

/// Checksum algorithm for post-download verification.
#[derive(Debug, Clone)]
pub enum Checksum {
    /// SHA-256 digest (hex-encoded).
    Sha256(String),
    /// SHA-1 digest (hex-encoded).
    Sha1(String),
    /// MD5 digest (hex-encoded).
    Md5(String),
    /// SHA-512 digest (hex-encoded).
    Sha512(String),
}

/// Specification for a download task.
#[derive(Debug, Clone)]
pub struct DownloadSpec {
    pub(crate) url: String,
    pub(crate) output_path: Option<PathBuf>,
    pub(crate) output_dir: Option<PathBuf>,
    pub(crate) headers: HashMap<String, String>,
    pub(crate) max_connections: u32,
    pub(crate) connect_timeout: Duration,
    pub(crate) connect_timeout_overridden: bool,
    pub(crate) all_proxy: Option<String>,
    pub(crate) http_proxy: Option<String>,
    pub(crate) https_proxy: Option<String>,
    pub(crate) read_timeout: Duration,
    pub(crate) memory_budget: usize,
    pub(crate) file_allocation: FileAllocation,
    pub(crate) channel_buffer: usize,
    pub(crate) resume: bool,
    pub(crate) piece_size: u64,
    pub(crate) min_split_size: u64,
    /// Maximum retry attempts per segment (0 = no retries).
    pub(crate) max_retries: u32,
    /// Base delay for exponential backoff between retries.
    pub(crate) retry_base_delay: Duration,
    /// Maximum delay cap for exponential backoff.
    pub(crate) retry_max_delay: Duration,
    /// Optional total elapsed retry budget across retries for a single request.
    pub(crate) max_retry_elapsed: Option<Duration>,
    /// Maximum download speed in bytes/sec. 0 = unlimited.
    pub(crate) max_download_speed: u64,
    /// Optional checksum for post-download verification.
    pub(crate) checksum: Option<Checksum>,
    /// Interval for periodic control-file saves (default 5 s).
    pub(crate) control_save_interval: Duration,
    /// Persist a durable autosave every N autosave ticks with unsaved progress.
    pub(crate) autosave_sync_every: u32,
}

impl DownloadSpec {
    /// Create a new download specification for the given URL.
    ///
    /// All other fields are populated with sensible defaults:
    /// 4 connections, 1 MiB pieces, 64 MiB memory budget, resume enabled, etc.
    pub fn new(url: impl Into<String>) -> Self {
        Self {
            url: url.into(),
            output_path: None,
            output_dir: None,
            headers: HashMap::new(),
            max_connections: 4,
            connect_timeout: Duration::from_secs(30),
            connect_timeout_overridden: false,
            all_proxy: None,
            http_proxy: None,
            https_proxy: None,
            read_timeout: Duration::from_secs(60),
            memory_budget: 64 * 1024 * 1024, // 64 MiB
            file_allocation: FileAllocation::default(),
            channel_buffer: 64,
            resume: true,
            piece_size: 1024 * 1024,          // 1 MiB
            min_split_size: 10 * 1024 * 1024, // 10 MiB
            max_retries: 5,
            retry_base_delay: Duration::from_secs(1),
            retry_max_delay: Duration::from_secs(30),
            max_retry_elapsed: None,
            max_download_speed: 0,
            checksum: None,
            control_save_interval: Duration::from_secs(5),
            autosave_sync_every: 2,
        }
    }

    /// Returns the download URL.
    pub fn get_url(&self) -> &str {
        &self.url
    }

    /// Returns the explicit output file path, if set.
    pub fn get_output_path(&self) -> Option<&Path> {
        self.output_path.as_deref()
    }

    /// Returns the output directory (filename will be derived from the URL or
    /// `Content-Disposition` header).
    pub fn get_output_dir(&self) -> Option<&Path> {
        self.output_dir.as_deref()
    }

    /// Returns the custom HTTP headers that will be sent with every request.
    pub fn get_headers(&self) -> &HashMap<String, String> {
        &self.headers
    }

    /// Returns the maximum number of parallel connections.
    pub fn get_max_connections(&self) -> u32 {
        self.max_connections
    }

    /// Returns the TCP connect timeout.
    pub fn get_connect_timeout(&self) -> Duration {
        self.connect_timeout
    }

    /// Returns the proxy applied to all HTTP/HTTPS requests, if set.
    pub fn get_all_proxy(&self) -> Option<&str> {
        self.all_proxy.as_deref()
    }

    /// Returns the proxy applied only to plain HTTP requests, if set.
    pub fn get_http_proxy(&self) -> Option<&str> {
        self.http_proxy.as_deref()
    }

    /// Returns the proxy applied only to HTTPS requests, if set.
    pub fn get_https_proxy(&self) -> Option<&str> {
        self.https_proxy.as_deref()
    }

    /// Returns the per-request read timeout.
    pub fn get_read_timeout(&self) -> Duration {
        self.read_timeout
    }

    pub(crate) fn has_connect_timeout_override(&self) -> bool {
        self.connect_timeout_overridden
    }

    pub(crate) fn has_proxy_override(&self) -> bool {
        self.all_proxy.is_some() || self.http_proxy.is_some() || self.https_proxy.is_some()
    }

    /// Returns the memory budget (in bytes) for the write-back cache.
    pub fn get_memory_budget(&self) -> usize {
        self.memory_budget
    }

    /// Returns the file allocation strategy.
    pub fn get_file_allocation(&self) -> FileAllocation {
        self.file_allocation
    }

    /// Returns the internal channel buffer size.
    pub fn get_channel_buffer(&self) -> usize {
        self.channel_buffer
    }

    /// Returns whether resume is enabled.
    pub fn get_resume(&self) -> bool {
        self.resume
    }

    /// Returns the piece size in bytes used for multi-connection splitting.
    pub fn get_piece_size(&self) -> u64 {
        self.piece_size
    }

    /// Returns the minimum file size required before the download is split
    /// across multiple connections.
    pub fn get_min_split_size(&self) -> u64 {
        self.min_split_size
    }

    /// Returns the maximum number of retry attempts per segment.
    pub fn get_max_retries(&self) -> u32 {
        self.max_retries
    }

    /// Returns the base delay for exponential backoff between retries.
    pub fn get_retry_base_delay(&self) -> Duration {
        self.retry_base_delay
    }

    /// Returns the maximum delay cap for exponential backoff.
    pub fn get_retry_max_delay(&self) -> Duration {
        self.retry_max_delay
    }

    /// Returns the optional total elapsed retry budget.
    pub fn get_max_retry_elapsed(&self) -> Option<Duration> {
        self.max_retry_elapsed
    }

    /// Returns the maximum download speed in bytes/sec (0 = unlimited).
    pub fn get_max_download_speed(&self) -> u64 {
        self.max_download_speed
    }

    /// Returns the checksum used for post-download verification, if set.
    pub fn get_checksum(&self) -> Option<&Checksum> {
        self.checksum.as_ref()
    }

    /// Returns the interval for periodic control-file saves.
    pub fn get_control_save_interval(&self) -> Duration {
        self.control_save_interval
    }

    /// Returns how many autosave ticks are coalesced into one durable save.
    pub fn get_autosave_sync_every(&self) -> u32 {
        self.autosave_sync_every
    }

    /// Set the explicit output file path.
    pub fn output_path(mut self, output_path: impl Into<PathBuf>) -> Self {
        self.output_path = Some(output_path.into());
        self
    }

    /// Set the output directory. The filename will be derived automatically
    /// from the URL or `Content-Disposition` response header.
    pub fn output_dir(mut self, output_dir: impl Into<PathBuf>) -> Self {
        self.output_dir = Some(output_dir.into());
        self
    }

    /// Set custom HTTP headers to include in every request.
    pub fn headers(mut self, headers: HashMap<String, String>) -> Self {
        self.headers = headers;
        self
    }

    /// Set the maximum number of parallel connections (default: 4).
    pub fn max_connections(mut self, max_connections: u32) -> Self {
        self.max_connections = max_connections;
        self
    }

    /// Set the TCP connect timeout (default: 30 s).
    pub fn connect_timeout(mut self, connect_timeout: Duration) -> Self {
        self.connect_timeout = connect_timeout;
        self.connect_timeout_overridden = true;
        self
    }

    /// Set a proxy applied to all HTTP/HTTPS requests for this download only.
    pub fn all_proxy(mut self, proxy: impl Into<String>) -> Self {
        self.all_proxy = Some(proxy.into());
        self
    }

    /// Set a proxy applied only to plain HTTP requests for this download.
    pub fn http_proxy(mut self, proxy: impl Into<String>) -> Self {
        self.http_proxy = Some(proxy.into());
        self
    }

    /// Set a proxy applied only to HTTPS requests for this download.
    pub fn https_proxy(mut self, proxy: impl Into<String>) -> Self {
        self.https_proxy = Some(proxy.into());
        self
    }

    /// Set the per-request read timeout (default: 60 s).
    pub fn read_timeout(mut self, read_timeout: Duration) -> Self {
        self.read_timeout = read_timeout;
        self
    }

    /// Set the memory budget in bytes for the write-back cache (default: 64 MiB).
    pub fn memory_budget(mut self, memory_budget: usize) -> Self {
        self.memory_budget = memory_budget;
        self
    }

    /// Set the file allocation strategy (default: [`FileAllocation::Prealloc`]).
    pub fn file_allocation(mut self, file_allocation: FileAllocation) -> Self {
        self.file_allocation = file_allocation;
        self
    }

    /// Set the internal channel buffer size (default: 64).
    pub fn channel_buffer(mut self, channel_buffer: usize) -> Self {
        self.channel_buffer = channel_buffer;
        self
    }

    /// Enable or disable resume support (default: `true`).
    pub fn resume(mut self, resume: bool) -> Self {
        self.resume = resume;
        self
    }

    /// Set the piece size in bytes for multi-connection splitting (default: 1 MiB).
    pub fn piece_size(mut self, piece_size: u64) -> Self {
        self.piece_size = piece_size;
        self
    }

    /// Set the minimum file size before splitting across connections (default: 10 MiB).
    pub fn min_split_size(mut self, min_split_size: u64) -> Self {
        self.min_split_size = min_split_size;
        self
    }

    /// Set the maximum retry attempts per segment (default: 5).
    pub fn max_retries(mut self, max_retries: u32) -> Self {
        self.max_retries = max_retries;
        self
    }

    /// Set the base delay for exponential backoff (default: 1 s).
    pub fn retry_base_delay(mut self, retry_base_delay: Duration) -> Self {
        self.retry_base_delay = retry_base_delay;
        self
    }

    /// Set the maximum delay cap for exponential backoff (default: 30 s).
    pub fn retry_max_delay(mut self, retry_max_delay: Duration) -> Self {
        self.retry_max_delay = retry_max_delay;
        self
    }

    /// Set the total elapsed retry budget for a single request.
    pub fn max_retry_elapsed(mut self, max_retry_elapsed: Duration) -> Self {
        self.max_retry_elapsed = Some(max_retry_elapsed);
        self
    }

    /// Configure the full retry policy in one call.
    pub fn retry_policy(
        mut self,
        max_retries: u32,
        retry_base_delay: Duration,
        retry_max_delay: Duration,
    ) -> Self {
        self.max_retries = max_retries;
        self.retry_base_delay = retry_base_delay;
        self.retry_max_delay = retry_max_delay;
        self
    }

    /// Set the maximum download speed in bytes/sec (default: 0 = unlimited).
    pub fn max_download_speed(mut self, max_download_speed: u64) -> Self {
        self.max_download_speed = max_download_speed;
        self
    }

    /// Set the checksum for post-download integrity verification.
    pub fn checksum(mut self, checksum: Checksum) -> Self {
        self.checksum = Some(checksum);
        self
    }

    /// Set the interval for periodic control-file saves (default: 5 s).
    pub fn control_save_interval(mut self, interval: Duration) -> Self {
        self.control_save_interval = interval;
        self
    }

    /// Save a durable autosave every N autosave ticks that have unsaved progress.
    pub fn autosave_sync_every(mut self, autosave_sync_every: u32) -> Self {
        self.autosave_sync_every = autosave_sync_every;
        self
    }

    /// Validate the configuration and return an error if any value is out of range.
    pub fn validate(&self) -> Result<(), DownloadError> {
        if self.url.trim().is_empty() {
            return Err(DownloadError::InvalidConfig("url cannot be empty".into()));
        }
        for (label, value) in [
            ("all_proxy", self.all_proxy.as_deref()),
            ("http_proxy", self.http_proxy.as_deref()),
            ("https_proxy", self.https_proxy.as_deref()),
        ] {
            if let Some(value) = value {
                if value.trim().is_empty() {
                    return Err(DownloadError::InvalidConfig(format!(
                        "{label} cannot be empty"
                    )));
                }
            }
        }
        if self.max_connections == 0 {
            return Err(DownloadError::InvalidConfig(
                "max_connections must be >= 1".into(),
            ));
        }
        if self.memory_budget == 0 {
            return Err(DownloadError::InvalidConfig(
                "memory_budget must be >= 1".into(),
            ));
        }
        if self.channel_buffer == 0 {
            return Err(DownloadError::InvalidConfig(
                "channel_buffer must be >= 1".into(),
            ));
        }
        if self.piece_size == 0 {
            return Err(DownloadError::InvalidConfig("piece_size must be >= 1".into()));
        }
        if self.min_split_size == 0 {
            return Err(DownloadError::InvalidConfig(
                "min_split_size must be >= 1".into(),
            ));
        }
        if self.autosave_sync_every == 0 {
            return Err(DownloadError::InvalidConfig(
                "autosave_sync_every must be >= 1".into(),
            ));
        }
        if self.retry_base_delay > self.retry_max_delay {
            return Err(DownloadError::InvalidConfig(
                "retry_base_delay cannot exceed retry_max_delay".into(),
            ));
        }
        if let Some(ref checksum) = self.checksum {
            let value = match checksum {
                Checksum::Sha256(v) | Checksum::Sha1(v) | Checksum::Md5(v) | Checksum::Sha512(v) => v,
            };
            if value.trim().is_empty() {
                return Err(DownloadError::InvalidConfig(
                    "checksum value cannot be empty".into(),
                ));
            }
        }
        Ok(())
    }
}

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

    #[test]
    fn test_download_spec_defaults() {
        let spec = DownloadSpec::new("https://example.com/file");
        assert_eq!(spec.url, "https://example.com/file");
        assert_eq!(spec.output_path, None);
        assert_eq!(spec.output_dir, None);
        assert_eq!(spec.max_connections, 4);
        assert_eq!(spec.connect_timeout, Duration::from_secs(30));
        assert!(!spec.connect_timeout_overridden);
        assert_eq!(spec.all_proxy, None);
        assert_eq!(spec.http_proxy, None);
        assert_eq!(spec.https_proxy, None);
        assert_eq!(spec.read_timeout, Duration::from_secs(60));
        assert_eq!(spec.memory_budget, 64 * 1024 * 1024);
        assert_eq!(spec.file_allocation, FileAllocation::Prealloc);
        assert_eq!(spec.channel_buffer, 64);
        assert!(spec.resume);
        assert_eq!(spec.piece_size, 1024 * 1024);
        assert_eq!(spec.min_split_size, 10 * 1024 * 1024);
        assert_eq!(spec.max_retries, 5);
        assert_eq!(spec.max_retry_elapsed, None);
        assert_eq!(spec.max_download_speed, 0);
        assert!(spec.checksum.is_none());
        assert!(spec.headers.is_empty());
        assert_eq!(spec.autosave_sync_every, 2);
    }

    #[test]
    fn test_download_spec_output_builders() {
        let spec = DownloadSpec::new("https://example.com/file")
            .output_dir("/tmp")
            .output_path("nested/file.bin");
        assert_eq!(spec.output_dir, Some(PathBuf::from("/tmp")));
        assert_eq!(spec.output_path, Some(PathBuf::from("nested/file.bin")));
    }

    #[test]
    fn test_download_spec_configuration_builders() {
        let mut headers = HashMap::new();
        headers.insert("Authorization".into(), "Bearer token".into());

        let spec = DownloadSpec::new("https://example.com/file")
            .headers(headers.clone())
            .max_connections(8)
            .connect_timeout(Duration::from_secs(10))
            .all_proxy("http://127.0.0.1:8080")
            .http_proxy("http://127.0.0.1:8081")
            .https_proxy("http://127.0.0.1:8443")
            .read_timeout(Duration::from_secs(20))
            .memory_budget(1024)
            .file_allocation(FileAllocation::None)
            .channel_buffer(8)
            .resume(false)
            .piece_size(2048)
            .min_split_size(4096)
            .retry_policy(7, Duration::from_millis(10), Duration::from_millis(50))
            .max_retry_elapsed(Duration::from_secs(3))
            .max_download_speed(12345)
            .checksum(Checksum::Sha256("abc123".into()))
            .autosave_sync_every(4);

        assert_eq!(spec.headers, headers);
        assert_eq!(spec.max_connections, 8);
        assert_eq!(spec.connect_timeout, Duration::from_secs(10));
        assert!(spec.connect_timeout_overridden);
        assert_eq!(spec.all_proxy.as_deref(), Some("http://127.0.0.1:8080"));
        assert_eq!(spec.http_proxy.as_deref(), Some("http://127.0.0.1:8081"));
        assert_eq!(spec.https_proxy.as_deref(), Some("http://127.0.0.1:8443"));
        assert_eq!(spec.read_timeout, Duration::from_secs(20));
        assert_eq!(spec.memory_budget, 1024);
        assert_eq!(spec.file_allocation, FileAllocation::None);
        assert_eq!(spec.channel_buffer, 8);
        assert!(!spec.resume);
        assert_eq!(spec.piece_size, 2048);
        assert_eq!(spec.min_split_size, 4096);
        assert_eq!(spec.max_retries, 7);
        assert_eq!(spec.retry_base_delay, Duration::from_millis(10));
        assert_eq!(spec.retry_max_delay, Duration::from_millis(50));
        assert_eq!(spec.max_retry_elapsed, Some(Duration::from_secs(3)));
        assert_eq!(spec.max_download_speed, 12345);
        assert!(matches!(spec.checksum, Some(Checksum::Sha256(ref value)) if value == "abc123"));
        assert_eq!(spec.autosave_sync_every, 4);
    }

    #[test]
    fn test_download_spec_validate_rejects_invalid_values() {
        let err = DownloadSpec::new("https://example.com/file")
            .max_connections(0)
            .validate()
            .unwrap_err();
        assert!(err.to_string().contains("max_connections"));

        let err = DownloadSpec::new("https://example.com/file")
            .retry_policy(1, Duration::from_secs(5), Duration::from_secs(1))
            .validate()
            .unwrap_err();
        assert!(err.to_string().contains("retry_base_delay"));

        let err = DownloadSpec::new("https://example.com/file")
            .checksum(Checksum::Sha256("   ".into()))
            .validate()
            .unwrap_err();
        assert!(err.to_string().contains("checksum"));

        let err = DownloadSpec::new("https://example.com/file")
            .all_proxy("   ")
            .validate()
            .unwrap_err();
        assert!(err.to_string().contains("all_proxy"));

        let err = DownloadSpec::new("https://example.com/file")
            .autosave_sync_every(0)
            .validate()
            .unwrap_err();
        assert!(err.to_string().contains("autosave_sync_every"));
    }

    #[test]
    fn test_download_spec_validate_accepts_defaults() {
        DownloadSpec::new("https://example.com/file")
            .validate()
            .unwrap();
    }

    #[test]
    fn test_file_allocation_default() {
        assert_eq!(FileAllocation::default(), FileAllocation::Prealloc);
    }

    #[test]
    fn test_checksum_debug() {
        let c = Checksum::Sha256("abc123".into());
        let debug = format!("{c:?}");
        assert!(debug.contains("abc123"));
    }

    #[test]
    fn test_log_level_default() {
        assert_eq!(LogLevel::default(), LogLevel::Off);
    }

    #[test]
    fn test_log_level_ordering() {
        assert!(LogLevel::Off < LogLevel::Error);
        assert!(LogLevel::Error < LogLevel::Warn);
        assert!(LogLevel::Warn < LogLevel::Info);
        assert!(LogLevel::Info < LogLevel::Debug);
        assert!(LogLevel::Debug < LogLevel::Trace);
    }

    #[test]
    fn test_log_level_display() {
        assert_eq!(LogLevel::Off.to_string(), "off");
        assert_eq!(LogLevel::Error.to_string(), "error");
        assert_eq!(LogLevel::Warn.to_string(), "warn");
        assert_eq!(LogLevel::Info.to_string(), "info");
        assert_eq!(LogLevel::Debug.to_string(), "debug");
        assert_eq!(LogLevel::Trace.to_string(), "trace");
    }

    #[test]
    fn test_log_level_from_str() {
        assert_eq!("off".parse::<LogLevel>().unwrap(), LogLevel::Off);
        assert_eq!("error".parse::<LogLevel>().unwrap(), LogLevel::Error);
        assert_eq!("warn".parse::<LogLevel>().unwrap(), LogLevel::Warn);
        assert_eq!("warning".parse::<LogLevel>().unwrap(), LogLevel::Warn);
        assert_eq!("info".parse::<LogLevel>().unwrap(), LogLevel::Info);
        assert_eq!("debug".parse::<LogLevel>().unwrap(), LogLevel::Debug);
        assert_eq!("trace".parse::<LogLevel>().unwrap(), LogLevel::Trace);
        assert_eq!("INFO".parse::<LogLevel>().unwrap(), LogLevel::Info);
        assert_eq!("Debug".parse::<LogLevel>().unwrap(), LogLevel::Debug);
        assert!("invalid".parse::<LogLevel>().is_err());
    }

    #[test]
    fn test_log_level_enabled() {
        let level = LogLevel::Info;
        assert!(level.enabled(tracing::Level::ERROR));
        assert!(level.enabled(tracing::Level::WARN));
        assert!(level.enabled(tracing::Level::INFO));
        assert!(!level.enabled(tracing::Level::DEBUG));
        assert!(!level.enabled(tracing::Level::TRACE));

        assert!(!LogLevel::Off.enabled(tracing::Level::ERROR));
        assert!(LogLevel::Trace.enabled(tracing::Level::TRACE));
    }

    #[test]
    fn test_log_level_tracing_filter() {
        assert_eq!(
            LogLevel::Off.to_tracing_level_filter(),
            tracing::level_filters::LevelFilter::OFF
        );
        assert_eq!(
            LogLevel::Error.to_tracing_level_filter(),
            tracing::level_filters::LevelFilter::ERROR
        );
        assert_eq!(
            LogLevel::Warn.to_tracing_level_filter(),
            tracing::level_filters::LevelFilter::WARN
        );
        assert_eq!(
            LogLevel::Info.to_tracing_level_filter(),
            tracing::level_filters::LevelFilter::INFO
        );
        assert_eq!(
            LogLevel::Debug.to_tracing_level_filter(),
            tracing::level_filters::LevelFilter::DEBUG
        );
        assert_eq!(
            LogLevel::Trace.to_tracing_level_filter(),
            tracing::level_filters::LevelFilter::TRACE
        );
    }

    #[test]
    fn test_download_spec_getter_methods() {
        let mut headers = HashMap::new();
        headers.insert("X-Custom".into(), "value".into());

        let spec = DownloadSpec::new("https://example.com/file")
            .output_path("/tmp/out.bin")
            .output_dir("/tmp")
            .headers(headers)
            .max_connections(8)
            .connect_timeout(Duration::from_secs(10))
            .all_proxy("http://127.0.0.1:8080")
            .http_proxy("http://127.0.0.1:8081")
            .https_proxy("http://127.0.0.1:8443")
            .read_timeout(Duration::from_secs(20))
            .memory_budget(2048)
            .file_allocation(FileAllocation::None)
            .channel_buffer(16)
            .resume(false)
            .piece_size(4096)
            .min_split_size(8192)
            .max_retries(3)
            .retry_base_delay(Duration::from_millis(100))
            .retry_max_delay(Duration::from_secs(5))
            .max_retry_elapsed(Duration::from_secs(60))
            .max_download_speed(999)
            .checksum(Checksum::Sha256("abc".into()))
            .control_save_interval(Duration::from_secs(10))
            .autosave_sync_every(6);

        assert_eq!(spec.get_url(), "https://example.com/file");
        assert_eq!(spec.get_output_path().unwrap(), Path::new("/tmp/out.bin"));
        assert_eq!(spec.get_output_dir().unwrap(), Path::new("/tmp"));
        assert_eq!(spec.get_headers().len(), 1);
        assert_eq!(spec.get_max_connections(), 8);
        assert_eq!(spec.get_connect_timeout(), Duration::from_secs(10));
        assert_eq!(spec.get_all_proxy(), Some("http://127.0.0.1:8080"));
        assert_eq!(spec.get_http_proxy(), Some("http://127.0.0.1:8081"));
        assert_eq!(spec.get_https_proxy(), Some("http://127.0.0.1:8443"));
        assert_eq!(spec.get_read_timeout(), Duration::from_secs(20));
        assert_eq!(spec.get_memory_budget(), 2048);
        assert_eq!(spec.get_file_allocation(), FileAllocation::None);
        assert_eq!(spec.get_channel_buffer(), 16);
        assert!(!spec.get_resume());
        assert_eq!(spec.get_piece_size(), 4096);
        assert_eq!(spec.get_min_split_size(), 8192);
        assert_eq!(spec.get_max_retries(), 3);
        assert_eq!(spec.get_retry_base_delay(), Duration::from_millis(100));
        assert_eq!(spec.get_retry_max_delay(), Duration::from_secs(5));
        assert_eq!(spec.get_max_retry_elapsed(), Some(Duration::from_secs(60)));
        assert_eq!(spec.get_max_download_speed(), 999);
        assert!(spec.get_checksum().is_some());
        assert_eq!(spec.get_control_save_interval(), Duration::from_secs(10));
        assert_eq!(spec.get_autosave_sync_every(), 6);
    }

    #[test]
    fn test_download_spec_getter_defaults_none() {
        let spec = DownloadSpec::new("https://example.com");
        assert!(spec.get_output_path().is_none());
        assert!(spec.get_output_dir().is_none());
        assert!(spec.get_all_proxy().is_none());
        assert!(spec.get_http_proxy().is_none());
        assert!(spec.get_https_proxy().is_none());
        assert!(spec.get_max_retry_elapsed().is_none());
        assert!(spec.get_checksum().is_none());
    }

    #[test]
    fn test_validate_empty_url() {
        let err = DownloadSpec::new("   ").validate().unwrap_err();
        assert!(err.to_string().contains("url"));
    }

    #[test]
    fn test_validate_zero_memory_budget() {
        let err = DownloadSpec::new("https://x.com")
            .memory_budget(0)
            .validate()
            .unwrap_err();
        assert!(err.to_string().contains("memory_budget"));
    }

    #[test]
    fn test_validate_zero_channel_buffer() {
        let err = DownloadSpec::new("https://x.com")
            .channel_buffer(0)
            .validate()
            .unwrap_err();
        assert!(err.to_string().contains("channel_buffer"));
    }

    #[test]
    fn test_validate_zero_piece_size() {
        let err = DownloadSpec::new("https://x.com")
            .piece_size(0)
            .validate()
            .unwrap_err();
        assert!(err.to_string().contains("piece_size"));
    }

    #[test]
    fn test_validate_zero_min_split_size() {
        let err = DownloadSpec::new("https://x.com")
            .min_split_size(0)
            .validate()
            .unwrap_err();
        assert!(err.to_string().contains("min_split_size"));
    }

    #[test]
    fn test_checksum_variants_debug() {
        let sha1 = Checksum::Sha1("aaa".into());
        let md5 = Checksum::Md5("bbb".into());
        let sha512 = Checksum::Sha512("ccc".into());
        assert!(format!("{sha1:?}").contains("Sha1"));
        assert!(format!("{md5:?}").contains("Md5"));
        assert!(format!("{sha512:?}").contains("Sha512"));
    }
}