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,6 +108,7 @@ 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>());
                                 match BASE64.decode(&data_str) {
                                     Ok(bytes) => {
                                         match rmp_serde::from_slice::<AppEvent>(&bytes) {