Updates for the "full flow"

2026-03-17 21:38:11 -04:00
parent e1b682b048
commit 9e1886b45a
8 changed files with 110 additions and 1 deletions
--- a/src/queries/downloads.rs
+++ b/src/queries/downloads.rs
@@ -68,6 +68,16 @@ pub async fn list(
        .await?)
 }

+pub async fn find_by_wanted_item_id(
+    db: &DatabaseConnection,
+    wanted_item_id: i32,
+) -> DbResult<Option<DownloadQueueItem>> {
+    Ok(DownloadQueue::find()
+        .filter(download_queue::Column::WantedItemId.eq(wanted_item_id))
+        .one(db)
+        .await?)
+}
+
 pub async fn retry_failed(db: &DatabaseConnection, id: i32) -> DbResult<()> {
    let item = DownloadQueue::find_by_id(id)
        .one(db)