🐛 hotfix(download): Create user specified directory if inexistent

Author: wylited

src/lib.rs

@@ -37,7 +37,7 @@ impl Client {
         let peers = Arc::new(Mutex::new(HashMap::new()));
         let http_client = reqwest::Client::new();
         let sessions = Arc::new(Mutex::new(HashMap::new()));
-        let download_dir = "/home/wyli/Downloads".to_string();
+        let download_dir = "/home/localsend".to_string();
 
         Ok(Self {
             device,

src/server/http.rs

@@ -35,6 +35,7 @@ impl Client {
             .layer(RequestBodyLimitLayer::new(1024 * 1024 * 1024))
             .layer(Extension(self.device.clone()))
             .layer(Extension(self.sessions.clone()))
+            .layer(Extension(self.download_dir.clone()))
             .with_state(peers)
 
     }

src/transfer/upload.rs

@@ -192,13 +192,13 @@ pub async fn register_prepare_upload(
 pub async fn register_upload(
     Query(params): Query<UploadParams>,
     Extension(sessions): Extension<Arc<Mutex<HashMap<String, Session>>>>,
+    Extension(download_dir): Extension<String>,
     body: Bytes,
 ) -> impl IntoResponse {
     // Extract query parameters
     let session_id = &params.session_id;
     let file_id = &params.file_id;
     let token = &params.token;
-    let download_dir = PathBuf::from("/home/wyli/Downloads");
 
     // Get session and validate
     let mut sessions_lock = sessions.lock().await;
@@ -237,7 +237,7 @@ pub async fn register_upload(
     }
 
     // Create file path
-    let file_path = download_dir.join(&file_metadata.file_name);
+    let file_path = format!("{}/{}", download_dir, file_metadata.file_name);
 
     // Write file
     if let Err(e) = tokio::fs::write(&file_path, body).await {