use leptos::prelude::*; use leptos::html; use leptos_use::storage::use_local_storage; use ::codee::string::FromToStringCodec; use shared::GlobalLimitRequest; use crate::api; fn format_bytes(bytes: i64) -> String { const UNITS: [&str; 6] = ["B", "KB", "MB", "GB", "TB", "PB"]; if bytes < 1024 { return format!("{} B", bytes); } let i = (bytes as f64).log2().div_euclid(10.0) as usize; format!( "{:.1} {}", (bytes as f64) / 1024_f64.powi(i as i32), UNITS[i] ) } fn format_speed(bytes_per_sec: i64) -> String { if bytes_per_sec == 0 { return "0 B/s".to_string(); } format!("{}/s", format_bytes(bytes_per_sec)) } #[component] pub fn StatusBar() -> impl IntoView { let store = use_context::().expect("store not provided"); let stats = store.global_stats; let (current_theme, set_current_theme, _) = use_local_storage::("vibetorrent_theme"); // Initialize with default if empty let current_theme_val = current_theme.get(); if current_theme_val.is_empty() { set_current_theme.set("dark".to_string()); } // Automatically sync theme to document attribute Effect::new(move |_| { let theme = current_theme.get().to_lowercase(); if let Some(doc) = document().document_element() { let _ = doc.set_attribute("data-theme", &theme); } }); // Preset limits in bytes/s let limits: Vec<(i64, &str)> = vec!( (0, "Unlimited"), (100 * 1024, "100 KB/s"), (500 * 1024, "500 KB/s"), (1024 * 1024, "1 MB/s"), (2 * 1024 * 1024, "2 MB/s"), (5 * 1024 * 1024, "5 MB/s"), (10 * 1024 * 1024, "10 MB/s"), (20 * 1024 * 1024, "20 MB/s"), ); let set_limit = move |limit_type: &str, val: i64| { let limit_type = limit_type.to_string(); log::info!("Setting {} limit to {}", limit_type, val); let req = if limit_type == "down" { GlobalLimitRequest { max_download_rate: Some(val), max_upload_rate: None, } } else { GlobalLimitRequest { max_download_rate: None, max_upload_rate: Some(val), } }; leptos::task::spawn_local(async move { if let Err(e) = api::settings::set_global_limits(&req).await { log::error!("Failed to set limit: {:?}", e); } else { log::info!("Limit set successfully"); } }); }; let down_details_ref = NodeRef::::new(); let up_details_ref = NodeRef::::new(); let theme_details_ref = NodeRef::::new(); let close_details = move |node_ref: NodeRef| { if let Some(el) = node_ref.get_untracked() { el.set_open(false); } }; view! {
// --- DOWNLOAD SPEED DROPDOWN ---
{move || format_speed(stats.get().down_rate)} 0 } fallback=|| ()> {move || format!("(Limit: {})", format_speed(stats.get().down_limit.unwrap_or(0)))}
    { limits.clone().into_iter().map(|(val, label)| { let is_active = move || { let current = stats.get().down_limit.unwrap_or(0); (current - val).abs() < 1024 }; view! {
    • } }).collect::>() }
// --- UPLOAD SPEED DROPDOWN ---
{move || format_speed(stats.get().up_rate)} 0 } fallback=|| ()> {move || format!("(Limit: {})", format_speed(stats.get().up_limit.unwrap_or(0)))}
    { limits.clone().into_iter().map(|(val, label)| { let is_active = move || { let current = stats.get().up_limit.unwrap_or(0); (current - val).abs() < 1024 }; view! {
    • } }).collect::>() }
    { let themes = vec![ "light", "dark", "dim", "nord", "cupcake", "dracula", "cyberpunk", "emerald", "sunset", "abyss" ]; themes.into_iter().map(|theme| { let theme_name = theme.to_string(); let theme_name_for_class = theme_name.clone(); let theme_name_for_onclick = theme_name.clone(); view! {
    • } }).collect::>() }
} }