fix: use .0 for reading and .1 for writing signals

frontend/src/app.rs

@@ -25,9 +25,7 @@ pub fn App() -> impl IntoView {
             match setup_res {
                 Ok(status) => {
                     if !status.completed {
-                        log::info!("Setup not completed, redirecting to /setup");
+                        log::info!("Setup not completed");
-                        let navigate = use_navigate();
-                        navigate("/setup", Default::default());
                         is_loading.1.set(false);
                         return;
                     }
@@ -48,27 +46,12 @@ pub fn App() -> impl IntoView {
                     }
 
                     is_authenticated.1.set(true);
-
-                    let pathname = window().location().pathname().unwrap_or_default();
-                    if pathname == "/login" || pathname == "/setup" {
-                        log::info!("Already authenticated, redirecting to home");
-                        let navigate = use_navigate();
-                        navigate("/", Default::default());
-                    }
                 }
                 Ok(false) => {
                     log::info!("Not authenticated");
-
-                    let pathname = window().location().pathname().unwrap_or_default();
-                    if pathname != "/login" && pathname != "/setup" {
-                        let navigate = use_navigate();
-                        navigate("/login", Default::default());
-                    }
                 }
                 Err(e) => {
                     log::error!("Auth check failed: {:?}", e);
-                    let navigate = use_navigate();
-                    navigate("/login", Default::default());
                 }
             }
 
@@ -92,10 +75,39 @@ pub fn App() -> impl IntoView {
         <div class="relative w-full h-screen" style="height: 100dvh;">
             <Router>
                 <Routes fallback=|| view! { <div class="p-4">"404 Not Found"</div> }>
-                    <Route path=leptos_router::path!("/login") view=move || view! { <Login /> } />
+                    <Route path=leptos_router::path!("/login") view=move || {
-                    <Route path=leptos_router::path!("/setup") view=move || view! { <Setup /> } />
+                        let authenticated = is_authenticated.0.get();
+                        
+                        Effect::new(move |_| {
+                            if authenticated {
+                                log::info!("Already authenticated, redirecting to home");
+                                let navigate = use_navigate();
+                                navigate("/", Default::default());
+                            }
+                        });
+                        
+                        view! { <Login /> }
+                    } />
+                    <Route path=leptos_router::path!("/setup") view=move || {
+                        Effect::new(move |_| {
+                            if is_authenticated.0.get() {
+                                let navigate = use_navigate();
+                                navigate("/", Default::default());
+                            }
+                        });
+                        
+                        view! { <Setup /> }
+                    } />
 
                     <Route path=leptos_router::path!("/") view=move || {
+                        Effect::new(move |_| {
+                            if !is_loading.0.get() && !is_authenticated.0.get() {
+                                log::info!("Not authenticated, redirecting to login");
+                                let navigate = use_navigate();
+                                navigate("/login", Default::default());
+                            }
+                        });
+                        
                         view! {
                             <Show when=move || !is_loading.0.get() fallback=|| view! {
                                 <div class="flex items-center justify-center h-screen bg-base-100">
@@ -112,6 +124,13 @@ pub fn App() -> impl IntoView {
                     }/>
 
                     <Route path=leptos_router::path!("/settings") view=move || {
+                        Effect::new(move |_| {
+                            if !is_authenticated.0.get() {
+                                let navigate = use_navigate();
+                                navigate("/login", Default::default());
+                            }
+                        });
+                        
                         view! {
                             <Show when=move || !is_loading.0.get() fallback=|| ()>
                                 <Show when=move || is_authenticated.0.get() fallback=|| ()>

frontend/src/components/torrent/table.rs

@@ -51,10 +51,14 @@ pub fn TorrentTable() -> impl IntoView {
     let sort_dir = signal(SortDirection::Descending);
 
     let filtered_hashes = move || {
-        store.torrents.with(|map| {
+        let torrents_map = store.torrents.get();
-            let mut torrents: Vec<&shared::Torrent> = map.values().filter(|t| {
+        log::debug!("TorrentTable: store.torrents has {} entries", torrents_map.len());
+        
         let filter = store.filter.get();
-                let search = store.search_query.get().to_lowercase();
+        let search = store.search_query.get();
+        let search_lower = search.to_lowercase();
+        
+        let mut torrents: Vec<&shared::Torrent> = torrents_map.values().filter(|t| {
             let matches_filter = match filter {
                 crate::store::FilterStatus::All => true,
                 crate::store::FilterStatus::Downloading => t.status == shared::TorrentStatus::Downloading,
@@ -64,10 +68,12 @@ pub fn TorrentTable() -> impl IntoView {
                 crate::store::FilterStatus::Inactive => t.status == shared::TorrentStatus::Paused || t.status == shared::TorrentStatus::Error,
                 _ => true,
             };
-                let matches_search = if search.is_empty() { true } else { t.name.to_lowercase().contains(&search) };
+            let matches_search = if search_lower.is_empty() { true } else { t.name.to_lowercase().contains(&search_lower) };
             matches_filter && matches_search
         }).collect();
 
+        log::debug!("TorrentTable: {} torrents after filtering", torrents.len());
+
         torrents.sort_by(|a, b| {
             let col = sort_col.0.get();
             let dir = sort_dir.0.get();
@@ -88,7 +94,6 @@ pub fn TorrentTable() -> impl IntoView {
             if dir == SortDirection::Descending { cmp.reverse() } else { cmp }
         });
         torrents.into_iter().map(|t| t.hash.clone()).collect::<Vec<String>>()
-        })
     };
 
     let handle_sort = move |col: SortColumn| {

frontend/src/store.rs

@@ -114,7 +114,9 @@ pub fn provide_torrent_store() {
 
     Effect::new(move |_| {
         let user_val = user.get();
+        log::debug!("SSE Effect: user = {:?}", user_val);
         if user_val.is_none() {
+            log::debug!("SSE Effect: user is None, skipping connection");
             return;
         }
 
@@ -131,12 +133,16 @@ pub fn provide_torrent_store() {
             let mut disconnect_notified = false;
 
             loop {
+                log::debug!("SSE: Creating EventSource...");
                 let es_result = EventSource::new("/api/events");
                 match es_result {
                     Ok(mut es) => {
+                        log::debug!("SSE: EventSource created, subscribing to message channel...");
                         if let Ok(mut stream) = es.subscribe("message") {
+                            log::debug!("SSE: Subscribed to message channel");
                             let mut got_first_message = false;
                             while let Some(Ok((_, msg))) = stream.next().await {
+                                log::debug!("SSE: Received message: {:?}", msg.data());
                                 if !got_first_message {
                                     got_first_message = true;
                                     backoff_ms = 1000;
@@ -148,9 +154,11 @@ pub fn provide_torrent_store() {
                                 }
 
                                 if let Some(data_str) = msg.data().as_string() {
+                                    log::debug!("SSE: Parsing JSON: {}", data_str);
                                     if let Ok(event) = serde_json::from_str::<AppEvent>(&data_str) {
                                         match event {
                                             AppEvent::FullList { torrents: list, .. } => {
+                                                log::info!("SSE: Received FullList with {} torrents", list.len());
                                                 torrents.update(|map| {
                                                     let new_hashes: std::collections::HashSet<String> = list.iter().map(|t| t.hash.clone()).collect();
                                                     map.retain(|hash, _| new_hashes.contains(hash));
@@ -158,6 +166,7 @@ pub fn provide_torrent_store() {
                                                         map.insert(new_torrent.hash.clone(), new_torrent);
                                                     }
                                                 });
+                                                log::debug!("SSE: torrents map now has {} entries", torrents.with(|m| m.len()));
                                             }
                                             AppEvent::Update(update) => {
                                                 torrents.update(|map| {