feat(backend): require rTorrent to be running for backend to start

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,10 +88,13 @@ 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 {
@@ -105,29 +108,40 @@ pub fn provide_torrent_store() {
                             }
 
                             if let Some(data_str) = msg.data().as_string() {
-                                if let Ok(bytes) = BASE64.decode(&data_str) {
+                                log::info!("[SSE] Received message: {:?}", data_str.chars().take(50).collect::<String>());
-                                    if let Ok(event) = rmp_serde::from_slice::<AppEvent>(&bytes) {
+                                match BASE64.decode(&data_str) {
-                                        match event {
+                                    Ok(bytes) => {
-                                            AppEvent::FullList(list, _) => {
+                                        match rmp_serde::from_slice::<AppEvent>(&bytes) {
-                                                torrents_for_sse.update(|map| {
+                                            Ok(event) => {
-                                                    let new_hashes: std::collections::HashSet<String> = list.iter().map(|t| t.hash.clone()).collect();
+                                                match event {
-                                                    map.retain(|hash, _| new_hashes.contains(hash));
+                                                    AppEvent::FullList(list, _) => {
-                                                    for new_torrent in list { map.insert(new_torrent.hash.clone(), new_torrent); }
+                                                        torrents_for_sse.update(|map| {
-                                                });
+                                                            let new_hashes: std::collections::HashSet<String> = list.iter().map(|t| t.hash.clone()).collect();
-                                            }
+                                                            map.retain(|hash, _| new_hashes.contains(hash));
-                                            AppEvent::Update(patch) => {
+                                                            for new_torrent in list { map.insert(new_torrent.hash.clone(), new_torrent); }
-                                                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() {
-                                            AppEvent::Stats(stats) => { global_stats_for_sse.set(stats); }
+                                                            torrents_for_sse.update(|map| { if let Some(t) = map.get_mut(&hash) { t.apply(patch); } });
-                                            AppEvent::Notification(n) => {
+                                                        }
-                                                show_toast(n.level.clone(), n.message.clone());
+                                                    }
-                                                if n.message.contains("tamamlandı") || n.level == shared::NotificationLevel::Error {
+                                                    AppEvent::Stats(stats) => { global_stats_for_sse.set(stats); }
-                                                    show_browser_notification("VibeTorrent", &n.message);
+                                                    AppEvent::Notification(n) => {
+                                                        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);
                                     }
                                 }
                             }

frontend/sw.js

@@ -1,4 +1,4 @@
-const CACHE_NAME = "vibetorrent-v2";
+const CACHE_NAME = "vibetorrent-v3";
 const ASSETS_TO_CACHE = [
   "/",
   "/index.html",
@@ -51,6 +51,11 @@ self.addEventListener("activate", (event) => {
 self.addEventListener("fetch", (event) => {
   const url = new URL(event.request.url);
 
+  // Skip unsupported schemes (like chrome-extension://)
+  if (!url.protocol.startsWith("http")) {
+    return;
+  }
+
   // Network-first strategy for API calls
   if (url.pathname.startsWith("/api/")) {
     event.respondWith(
@@ -75,10 +80,12 @@ self.addEventListener("fetch", (event) => {
       fetch(event.request)
         .then((response) => {
           // Cache the latest version of the HTML
-          const responseToCache = response.clone();
+          if (response && response.status === 200) {
-          caches.open(CACHE_NAME).then((cache) => {
+            const responseToCache = response.clone();
-            cache.put(event.request, responseToCache);
+            caches.open(CACHE_NAME).then((cache) => {
-          });
+              cache.put(event.request, responseToCache);
+            });
+          }
           return response;
         })
         .catch(() => {