chore(ui): remove debugging logs for sse connection

backend/src/main.rs

@@ -243,12 +243,14 @@ async fn main() {
     let socket_path = std::path::Path::new(&args.socket);
     if !socket_path.exists() {
         tracing::error!("CRITICAL: rTorrent socket not found at {:?}.", socket_path);
-        tracing::warn!(
+        tracing::error!(
             "HINT: Make sure rTorrent is running and the SCGI socket is enabled in .rtorrent.rc"
         );
-        tracing::warn!(
+        tracing::error!(
             "HINT: You can configure the socket path via --socket ARG or RTORRENT_SOCKET ENV."
         );
+        tracing::error!("FATAL: VibeTorrent cannot start without a running rTorrent instance. Exiting.");
+        std::process::exit(1);
     } else {
         tracing::info!("Socket file exists. Testing connection...");
         let client = xmlrpc::RtorrentClient::new(&args.socket);
@@ -259,7 +261,11 @@ async fn main() {
                 let version = xmlrpc::parse_string_response(&xml).unwrap_or(xml);
                 tracing::info!("Connected to rTorrent successfully. Version: {}", version);
             }
-            Err(e) => tracing::error!("Socket exists but failed to connect to rTorrent: {}", e),
+            Err(e) => {
+                tracing::error!("CRITICAL: Socket exists but failed to connect to rTorrent: {}", e);
+                tracing::error!("FATAL: Ensure rTorrent is fully started and the socket has correct permissions. Exiting.");
+                std::process::exit(1);
+            }
         }
     }
 

frontend/src/store.rs

@@ -88,13 +88,10 @@ pub fn provide_torrent_store() {
         let mut disconnect_notified = false;
 
         loop {
-            log::info!("[SSE] Attempting to connect to /api/events...");
             let es_result = EventSource::new("/api/events");
             match es_result {
                 Ok(mut es) => {
-                    log::info!("[SSE] EventSource instantiated successfully.");
                     if let Ok(mut stream) = es.subscribe("message") {
-                        log::info!("[SSE] Subscribed to 'message' events.");
                         let mut got_first_message = false;
                         while let Some(Ok((_, msg))) = stream.next().await {
                             if !got_first_message {
@@ -108,40 +105,29 @@ pub fn provide_torrent_store() {
                             }
 
                             if let Some(data_str) = msg.data().as_string() {
-                                log::info!("[SSE] Received message: {:?}", data_str.chars().take(50).collect::<String>());
+                                if let Ok(bytes) = BASE64.decode(&data_str) {
-                                match BASE64.decode(&data_str) {
+                                    if let Ok(event) = rmp_serde::from_slice::<AppEvent>(&bytes) {
-                                    Ok(bytes) => {
+                                        match event {
-                                        match rmp_serde::from_slice::<AppEvent>(&bytes) {
+                                            AppEvent::FullList(list, _) => {
-                                            Ok(event) => {
+                                                torrents_for_sse.update(|map| {
-                                                match event {
+                                                    let new_hashes: std::collections::HashSet<String> = list.iter().map(|t| t.hash.clone()).collect();
-                                                    AppEvent::FullList(list, _) => {
+                                                    map.retain(|hash, _| new_hashes.contains(hash));
-                                                        torrents_for_sse.update(|map| {
+                                                    for new_torrent in list { map.insert(new_torrent.hash.clone(), new_torrent); }
-                                                            let new_hashes: std::collections::HashSet<String> = list.iter().map(|t| t.hash.clone()).collect();
+                                                });
-                                                            map.retain(|hash, _| new_hashes.contains(hash));
+                                            }
-                                                            for new_torrent in list { map.insert(new_torrent.hash.clone(), new_torrent); }
+                                            AppEvent::Update(patch) => {
-                                                        });
+                                                if let Some(hash) = patch.hash.clone() {
-                                                    }
+                                                    torrents_for_sse.update(|map| { if let Some(t) = map.get_mut(&hash) { t.apply(patch); } });
-                                                    AppEvent::Update(patch) => {
+                                                }
-                                                        if let Some(hash) = patch.hash.clone() {
+                                            }
-                                                            torrents_for_sse.update(|map| { if let Some(t) = map.get_mut(&hash) { t.apply(patch); } });
+                                            AppEvent::Stats(stats) => { global_stats_for_sse.set(stats); }
-                                                        }
+                                            AppEvent::Notification(n) => {
-                                                    }
+                                                show_toast(n.level.clone(), n.message.clone());
-                                                    AppEvent::Stats(stats) => { global_stats_for_sse.set(stats); }
+                                                if n.message.contains("tamamlandı") || n.level == shared::NotificationLevel::Error {
-                                                    AppEvent::Notification(n) => {
+                                                    show_browser_notification("VibeTorrent", &n.message);
-                                                        show_toast(n.level.clone(), n.message.clone());
-                                                        if n.message.contains("tamamlandı") || n.level == shared::NotificationLevel::Error {
-                                                            show_browser_notification("VibeTorrent", &n.message);
-                                                        }
-                                                    }
                                                 }
-                                            },
-                                            Err(e) => {
-                                                log::error!("[SSE] Failed to deserialize AppEvent: {:?}", e);
                                             }
                                         }
-                                    },
-                                    Err(e) => {
-                                        log::error!("[SSE] Failed to decode base64: {:?}", e);
                                     }
                                 }
                             }