From 79c6b603b4afc7757de16cb9cb3dd741e94871b4 Mon Sep 17 00:00:00 2001
From: tdurieux <durieuxthomas@hotmail.com>
Date: Thu, 11 Apr 2024 17:22:08 +0100
Subject: [PATCH] fix: handle error in queue admin

---
 src/server/routes/admin.ts | 10 +++++++++-
 1 file changed, 9 insertions(+), 1 deletion(-)

diff --git a/src/server/routes/admin.ts b/src/server/routes/admin.ts
index 033b982..7b9d218 100644
--- a/src/server/routes/admin.ts
+++ b/src/server/routes/admin.ts
@@ -35,6 +35,8 @@ router.post("/queue/:name/:repo_id", async (req, res) => {
   let queue: Queue<Repository, void>;
   if (req.params.name == "download") {
     queue = downloadQueue;
+  } else if (req.params.name == "cache") {
+    queue = cacheQueue;
   } else if (req.params.name == "remove") {
     queue = removeQueue;
   } else {
@@ -62,6 +64,8 @@ router.delete("/queue/:name/:repo_id", async (req, res) => {
   let queue: Queue;
   if (req.params.name == "download") {
     queue = downloadQueue;
+  } else if (req.params.name == "cache") {
+    queue = cacheQueue;
   } else if (req.params.name == "remove") {
     queue = removeQueue;
   } else {
@@ -71,7 +75,11 @@ router.delete("/queue/:name/:repo_id", async (req, res) => {
   if (!job) {
     return res.status(404).json({ error: "job_not_found" });
   }
-  await job.remove();
+  try {
+    await job.remove();
+  } catch (error) {
+    handleError(error, res, req);
+  }
   res.send("ok");
 });