multi download

Author: neckaros

.claude/settings.local.json

@@ -9,7 +9,8 @@
       "Bash(cargo test:*)",
       "Bash(dir:*)",
       "Bash(ls:*)",
-      "WebFetch(domain:r365mail.fit)"
+      "WebFetch(domain:r365mail.fit)",
+      "Bash(npx svelte-check:*)"
     ]
   }
 }

src/model/error.rs

@@ -56,6 +56,7 @@ pub enum Error {
     //RsRequest
     UnableToFormatHeaders,
     InvalidRsRequestStatus(RsRequestStatus),
+    NeedFileSelection(RsRequest),
     RequestNeedsModelControllerForResolution(RsRequest),
     RequestNeedsLibraryIdForResolution(RsRequest),
 
@@ -155,6 +156,11 @@ impl Error {
                 ClientError::Custom { message: format!("Invalid id {} for {}", id, action) },
             ),
 
+            Error::NeedFileSelection(_) => (
+                StatusCode::CONFLICT,
+                ClientError::Custom { message: "File selection required".to_string() },
+            ),
+
             Error::ServiceError(_, _) => (
                 StatusCode::INTERNAL_SERVER_ERROR,
                 ClientError::SERVICE_ERROR,

src/model/medias.rs

@@ -1851,14 +1851,19 @@ impl ModelController {
             self.plugin_manager.fill_infos(&mut request).await;
 
             let mut infos: MediaForUpdate = request.clone().into();
-            infos.origin = origin.clone();
+            infos.origin = origin.clone().or_else(|| Some(RsLink {
+                platform: "link".to_owned(),
+                kind: Some(RsLinkType::Post),
+                id: request.url.clone(),
+                ..Default::default()
+            }));
 
             let tx_progress =
                 self.create_progress_sender(library_id.to_owned(), Some(upload_id.clone()));
 
             // Check for origin duplicate
             if let Some(origin) = &mut infos.origin {
-                let origin_filename = filename_from_path(&request.url);
+                let origin_filename = request.selected_file.clone().or_else(|| filename_from_path(&request.url));
                 self.check_origin_duplicate(
                     store,
                     origin,

src/plugins/sources/mod.rs

@@ -308,11 +308,14 @@ impl SourceRead {
 
 
 
+                    },
+                    RsRequestStatus::NeedFileSelection => {
+                        Err(Error::NeedFileSelection(request).into())
                     },
                     _ => Err(Error::InvalidRsRequestStatus(request.status).into())
                 }
 
-                
+
             },
         }
     }
@@ -394,10 +397,13 @@ impl SourceRead {
                         let body = Body::empty();
                         Ok((status, headers, body).into_response())
                     },
+                    RsRequestStatus::NeedFileSelection => {
+                        Err(Error::NeedFileSelection(request).into())
+                    },
                     _ => Err(Error::InvalidRsRequestStatus(request.status).into())
                 }
 
-                
+
             },
         }
     }

src/routes/medias.rs

@@ -615,10 +615,19 @@ async fn handler_download(
 
         Ok(Json(json!({"downloading": true})))
     } else {
-        let body = mc
+        match mc
             .download_library_url(&library_id, download, &user)
-            .await?;
-        Ok(Json(json!(body)))
+            .await
+        {
+            Ok(body) => Ok(Json(json!(body))),
+            Err(crate::Error::Model(crate::model::error::Error::NeedFileSelection(request))) => {
+                Ok(Json(json!({
+                    "needFileSelection": true,
+                    "request": request
+                })))
+            }
+            Err(e) => Err(e),
+        }
     }
 }