fix(backend): Support TCP SCGI sockets and remove verbose unstandardized tracker fields

backend/src/bin/test_trackers.rs

@@ -0,0 +1,83 @@
+use shared::xmlrpc::{RtorrentClient, RpcParam, parse_multicall_response};
+
+#[tokio::main]
+async fn main() {
+    let mut client = None;
+    for path in ["127.0.0.1:8000", "0.0.0.0:8000", "localhost:8000"] {
+        let test_client = RtorrentClient::new(path);
+        match test_client.call("system.client_version", &[]).await {
+            Ok(res) => {
+                println!("SUCCESS: Connected to rTorrent at {} (Version: {})", path, res);
+                client = Some(test_client);
+                break;
+            }
+            Err(_) => {
+                // println!("Failed to connect to {}", path);
+            }
+        }
+    }
+
+    let client = match client {
+        Some(c) => c,
+        None => {
+            println!("Could not connect to rTorrent on port 8000.");
+            return;
+        }
+    };
+
+    let mut hash = String::new();
+    match client.call("d.multicall2", &[RpcParam::from(""), RpcParam::from("main"), RpcParam::from("d.hash=")]).await {
+        Ok(xml) => {
+            if let Ok(rows) = parse_multicall_response(&xml) {
+                if let Some(row) = rows.first() {
+                    if let Some(h) = row.first() {
+                        hash = h.clone();
+                        println!("Using torrent hash: {}", hash);
+                    }
+                }
+            }
+        },
+        Err(e) => {
+            println!("Error getting torrents: {:?}", e);
+            return;
+        },
+    }
+
+    if hash.is_empty() {
+        println!("No torrents found to test trackers.");
+        return;
+    }
+
+    // Now test Tracker fields one by one to see which one is failing
+    let fields = vec![
+        "t.url=",
+        "t.is_enabled=",
+        "t.group=",
+        "t.scrape_complete=",
+        "t.scrape_incomplete=",
+        "t.scrape_downloaded=",
+        "t.activity_date_last=",
+        "t.normal_interval=",
+        "t.message=",
+    ];
+
+    for field in &fields {
+        let params = vec![
+            RpcParam::from(hash.as_str()),
+            RpcParam::from(""),
+            RpcParam::from(*field),
+        ];
+
+        print!("Testing field {:<22} : ", field);
+        match client.call("t.multicall", &params).await {
+            Ok(xml) => {
+                if xml.contains("faultCode") {
+                    println!("FAILED");
+                } else {
+                    println!("SUCCESS");
+                }
+            },
+            Err(e) => println!("ERROR: {:?}", e),
+        }
+    }
+}

frontend/src/components/torrent/details.rs

@@ -165,10 +165,19 @@ pub fn TorrentDetailsSheet() -> impl IntoView {
                             </TabsContent>
 
                             <TabsContent value="trackers" class="h-full">
-                                <div class="flex flex-col items-center justify-center h-48 opacity-60">
-                                    <icons::Settings2 class="size-12 mb-3 text-muted-foreground" />
-                                    <p class="text-sm font-medium">"İzleyici listesi yakında eklenecek"</p>
-                                </div>
+                                {move || match selected_torrent.get() {
+                                    Some(t) => leptos::either::Either::Left(view! {
+                                        <div class="h-full overflow-y-auto pr-2 pb-8">
+                                            <crate::components::torrent::trackers::TorrentTrackersTab hash=t.hash />
+                                        </div>
+                                    }),
+                                    None => leptos::either::Either::Right(view! {
+                                        <div class="flex flex-col items-center justify-center h-48 opacity-60">
+                                            <icons::Settings2 class="size-12 mb-3 text-muted-foreground" />
+                                            <p class="text-sm font-medium">"İzleyici yükleniyor..."</p>
+                                        </div>
+                                    }),
+                                }}
                             </TabsContent>
 
                             <TabsContent value="peers" class="h-full">

frontend/src/components/torrent/mod.rs

@@ -2,3 +2,4 @@ pub mod table;
 pub mod add_torrent;
 pub mod details;
 pub mod files;
+pub mod trackers;

frontend/src/components/torrent/trackers.rs

@@ -0,0 +1,121 @@
+use leptos::prelude::*;
+use crate::components::ui::table::*;
+use crate::components::ui::shimmer::*;
+use shared::TorrentTracker;
+
+#[component]
+pub fn TorrentTrackersTab(hash: String) -> impl IntoView {
+    let hash_clone = hash.clone();
+    
+    let trackers_resource = Resource::new(
+        move || hash_clone.clone(),
+        |h| async move { shared::server_fns::torrent::get_trackers(h).await.unwrap_or_default() }
+    );
+
+    view! {
+        <Suspense fallback=move || view! { <TrackersFallback /> }>
+            {move || {
+                let trackers = trackers_resource.get().unwrap_or_default();
+
+                if trackers.is_empty() {
+                    return view! {
+                        <div class="flex flex-col items-center justify-center h-48 opacity-60">
+                            <icons::Settings2 class="size-12 mb-3 text-muted-foreground" />
+                            <p class="text-sm font-medium">"Bu torrent için izleyici bulunamadı."</p>
+                        </div>
+                    }.into_any();
+                }
+
+                view! {
+                    <div class="h-full overflow-auto">
+                        <TableWrapper class="bg-card/50 whitespace-nowrap">
+                            <Table>
+                                <TableHeader class="sticky top-0 bg-muted/80 backdrop-blur-sm z-10">
+                                    <TableRow class="hover:bg-transparent text-xs">
+                                        <TableHead>"İsim"</TableHead>
+                                        <TableHead class="text-center">"Tür"</TableHead>
+                                        <TableHead class="text-center">"Etkin"</TableHead>
+                                        <TableHead class="text-center">"Grup"</TableHead>
+                                        <TableHead class="text-center">"Ortaklar"</TableHead>
+                                        <TableHead class="text-center">"Eşler"</TableHead>
+                                        <TableHead class="text-center">"İndirilen"</TableHead>
+                                        <TableHead class="text-center">"Son Güncelleme"</TableHead>
+                                        <TableHead class="text-center">"Sıklık"</TableHead>
+                                        <TableHead class="text-center">"Özel"</TableHead>
+                                    </TableRow>
+                                </TableHeader>
+                                <TableBody>
+                                    <For 
+                                        each=move || trackers.clone()
+                                        key=|t| t.url.clone()
+                                        children=move |t| {
+                                            let t_type = if t.url.starts_with("http") { "http" } 
+                                                         else if t.url.starts_with("udp") { "udp" } 
+                                                         else if t.url.starts_with("dht") { "dht" } 
+                                                         else { "diğer" };
+                                            let is_enabled = if t.is_enabled { "evet" } else { "hayır" };
+                                            
+                                            // Format timestamp difference for last update
+                                            let now = chrono::Utc::now().timestamp();
+                                            let diff = now - t.last_updated;
+                                            let last_update_str = if t.last_updated == 0 { 
+                                                "Güncellenmedi".to_string() 
+                                            } else if diff >= 0 {
+                                                format_duration_short(diff)
+                                            } else {
+                                                "N/A".to_string()
+                                            };
+                                            
+                                            let url_clone = t.url.clone();
+                                            view! {
+                                                <TableRow class="hover:bg-muted/50 transition-colors group text-xs text-muted-foreground">
+                                                    <TableCell class="font-medium text-foreground max-w-[200px] md:max-w-md truncate" attr:title=url_clone>
+                                                        {t.url.clone()}
+                                                    </TableCell>
+                                                    <TableCell class="text-center">{t_type}</TableCell>
+                                                    <TableCell class="text-center">{is_enabled}</TableCell>
+                                                    <TableCell class="text-center">{t.group}</TableCell>
+                                                    <TableCell class="text-center">{t.seeders}</TableCell>
+                                                    <TableCell class="text-center">{t.peers}</TableCell>
+                                                    <TableCell class="text-center">{t.downloaded}</TableCell>
+                                                    <TableCell class="text-center">{last_update_str}</TableCell>
+                                                    <TableCell class="text-center">{format_duration_short(t.interval)}</TableCell>
+                                                    <TableCell class="text-center">"bilinmiyor"</TableCell> // Özel flag isn't cleanly via XMLRPC per tracker usually
+                                                </TableRow>
+                                            }
+                                        }
+                                    />
+                                </TableBody>
+                            </Table>
+                        </TableWrapper>
+                    </div>
+                }.into_any()
+            }}
+        </Suspense>
+    }
+}
+
+#[component]
+fn TrackersFallback() -> impl IntoView {
+    view! {
+        <Shimmer loading=Signal::derive(|| true) class="space-y-2">
+            <div class="h-10 w-full bg-muted/20 rounded-md"></div>
+            <div class="h-10 w-full bg-muted/20 rounded-md"></div>
+            <div class="h-10 w-full bg-muted/20 rounded-md"></div>
+            <div class="h-10 w-full bg-muted/20 rounded-md"></div>
+        </Shimmer>
+    }
+}
+
+fn format_duration_short(seconds: i64) -> String {
+    if seconds <= 0 { return "0sn".to_string(); }
+    let days = seconds / 86400;
+    let hours = (seconds % 86400) / 3600;
+    let minutes = (seconds % 3600) / 60;
+    let secs = seconds % 60;
+    
+    if days > 0 { format!("{}g {}s", days, hours) }
+    else if hours > 0 { format!("{}s {}dk", hours, minutes) }
+    else if minutes > 0 { format!("{}dk {}sn", minutes, secs) }
+    else { format!("{}sn", secs) }
+}

shared/src/lib.rs

@@ -126,6 +126,13 @@ pub struct TorrentTracker {
     pub url: String,
     pub status: String,
     pub message: String,
+    pub is_enabled: bool,
+    pub group: i64,
+    pub seeders: i64,
+    pub peers: i64,
+    pub downloaded: i64,
+    pub last_updated: i64,
+    pub interval: i64,
 }
 
 #[derive(Debug, Serialize, Deserialize, Clone, ToSchema)]

shared/src/scgi.rs

@@ -83,12 +83,19 @@ impl ScgiRequest {
 
 pub async fn send_request(socket_path: &str, request: ScgiRequest) -> Result<Bytes, ScgiError> {
     let perform_request = async {
-        let mut stream = UnixStream::connect(socket_path).await?;
         let data = request.encode();
-        stream.write_all(&data).await?;
-
         let mut response = Vec::new();
-        stream.read_to_end(&mut response).await?;
+
+        if socket_path.contains(':') {
+            let mut stream = tokio::net::TcpStream::connect(socket_path).await?;
+            stream.write_all(&data).await?;
+            stream.read_to_end(&mut response).await?;
+        } else {
+            let mut stream = tokio::net::UnixStream::connect(socket_path).await?;
+            stream.write_all(&data).await?;
+            stream.read_to_end(&mut response).await?;
+        }
+        
         Ok::<Vec<u8>, std::io::Error>(response)
     };
 

shared/src/server_fns/torrent.rs

@@ -193,8 +193,12 @@ pub async fn get_trackers(hash: String) -> Result<Vec<TorrentTracker>, ServerFnE
         RpcParam::from(hash.as_str()),
         RpcParam::from(""),
         RpcParam::from("t.url="),
-        RpcParam::from("t.activity_date_last="),
-        RpcParam::from("t.message="),
+        RpcParam::from("t.is_enabled="),
+        RpcParam::from("t.group="),
+        RpcParam::from("t.scrape_complete="),
+        RpcParam::from("t.scrape_incomplete="),
+        RpcParam::from("t.scrape_downloaded="),
+        RpcParam::from("t.normal_interval="),
     ];
 
     let xml = client
@@ -205,14 +209,23 @@ pub async fn get_trackers(hash: String) -> Result<Vec<TorrentTracker>, ServerFnE
     let rows = parse_multicall_response(&xml)
         .map_err(|e| ServerFnError::new(format!("Parse error: {}", e)))?;
 
-    Ok(rows
+    let result: Vec<TorrentTracker> = rows
         .into_iter()
         .map(|row| TorrentTracker {
             url: row.get(0).cloned().unwrap_or_default(),
-            status: "Unknown".to_string(),
-            message: row.get(2).cloned().unwrap_or_default(),
+            is_enabled: row.get(1).and_then(|s| s.parse::<i64>().ok()).unwrap_or(0) != 0,
+            group: row.get(2).and_then(|s| s.parse().ok()).unwrap_or(0),
+            seeders: row.get(3).and_then(|s| s.parse().ok()).unwrap_or(0),
+            peers: row.get(4).and_then(|s| s.parse().ok()).unwrap_or(0),
+            downloaded: row.get(5).and_then(|s| s.parse().ok()).unwrap_or(0),
+            interval: row.get(6).and_then(|s| s.parse().ok()).unwrap_or(0),
+            last_updated: 0,
+            status: "Unknown".to_string(), // Can derive from activity later, or keep unknown
+            message: "".to_string(),
         })
-        .collect())
+        .collect();
+    
+    Ok(result)
 }
 
 #[server(SetFilePriority, "/api/server_fns")]

test_rpc.rs

@@ -0,0 +1,26 @@
+use shared::xmlrpc::{RtorrentClient, RpcParam, parse_multicall_response};
+
+#[tokio::main]
+async fn main() {
+    let client = RtorrentClient::new("/tmp/rtorrent.sock");
+    
+    // Hardcode a known hash from the UI, e.g. "C3315ABFAD70C54505813D1303C1457900C5B795" (from first image)
+    let hash = "C3315ABFAD70C54505813D1303C1457900C5B795";
+    
+    let params = vec![
+        RpcParam::from(hash),
+        RpcParam::from(""),
+        RpcParam::from("t.url="),
+    ];
+
+    match client.call("t.multicall", &params).await {
+        Ok(xml) => {
+            println!("Response XML:\n{}", xml);
+            match parse_multicall_response(&xml) {
+                Ok(rows) => println!("Rows ({})", rows.len()),
+                Err(e) => println!("Parse error: {:?}", e),
+            }
+        },
+        Err(e) => println!("Error: {:?}", e),
+    }
+}