From aee569906a777533dc194eae1b08ced00c9d3ddc Mon Sep 17 00:00:00 2001
From: KeksNino <KeksNino@proton.me>
Date: Mon, 17 Nov 2025 13:01:01 +0100
Subject: [PATCH] added back aria2 output

---
 Cargo.lock  |  1 +
 Cargo.toml  |  1 +
 src/main.rs | 30 ++++++++++++++++--------------
 3 files changed, 18 insertions(+), 14 deletions(-)

diff --git a/Cargo.lock b/Cargo.lock
index 005c87d..4c196db 100644
--- a/Cargo.lock
+++ b/Cargo.lock
@@ -1323,6 +1323,7 @@ dependencies = [
  "select",
  "serde",
  "serde_json",
+ "time",
  "tokio",
 ]
 
diff --git a/Cargo.toml b/Cargo.toml
index 3367a7d..f1ea683 100644
--- a/Cargo.toml
+++ b/Cargo.toml
@@ -11,4 +11,5 @@ reqwest = { version = "0.12", features = ["json"] }
 select = "0.6.1"
 serde = "1.0.228"
 serde_json = "1.0.145"
+time = "0.3.44"
 tokio = { version = "1", features = ["full"] }
diff --git a/src/main.rs b/src/main.rs
index 2855e7c..aaeb52e 100644
--- a/src/main.rs
+++ b/src/main.rs
@@ -8,6 +8,7 @@ use serde_json::{json, Value};
 use std::io;
 use std::process::Command;
 use std::sync::Arc;
+use std::thread;
 use tokio::{spawn, sync::Semaphore};
 
 #[derive(Debug, Deserialize)]
@@ -32,15 +33,6 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
     let server_url = "https://api.michijackson.xyz/search/".to_owned();
     let mut input = String::new();
 
-    let _command = Command::new("/usr/bin/aria2c")
-        .arg("--enable-rpc")
-        .arg("--disable-ipv6")
-        .arg("--rpc-listen-all")
-        .arg("--rpc-listen-port=6800")
-        .stdout(std::process::Stdio::null())
-        .stderr(std::process::Stdio::null())
-        .spawn();
-
     eprint!("Search: ");
     io::stdin()
         .read_line(&mut input)
@@ -80,6 +72,16 @@ async fn main() -> Result<(), Box<dyn std::error::Error>> {
         }
     }
 
+    let _command = Command::new("/usr/bin/aria2c")
+        .arg("--enable-rpc")
+        .arg("--disable-ipv6")
+        .arg("--rpc-listen-all")
+        .arg("--rpc-listen-port=6800")
+        //.arg("--rpc-secret=0")
+        .spawn();
+
+    thread::sleep(std::time::Duration::from_millis(500));
+
     aria2_ws(magnet.unwrap()).await;
 
     Ok(())
@@ -90,11 +92,11 @@ async fn aria2_ws(items: &str) {
         .await
         .unwrap();
     let options = TaskOptions {
-        split: Some(2),
-        extra_options: json!({"max-download-limit": "200K"})
-            .as_object()
-            .unwrap()
-            .clone(),
+        //split: Some(2),
+        //extra_options: json!({"max-download-limit": "200K"})
+        //    .as_object()
+        //    .unwrap()
+        //    .clone(),
         ..Default::default()
     };