From ba1d9e794abd27dfbd17954676830edbc41d8be8 Mon Sep 17 00:00:00 2001
From: Methapon2001 <61303214+Methapon2001@users.noreply.github.com>
Date: Fri, 1 Dec 2023 11:37:31 +0700
Subject: [PATCH] fix: remove queued if file not exist

---
 Services/server/src/rabbitmq/handler.ts | 15 ++++++++++++---
 1 file changed, 12 insertions(+), 3 deletions(-)

diff --git a/Services/server/src/rabbitmq/handler.ts b/Services/server/src/rabbitmq/handler.ts
index f02d48b..382da34 100644
--- a/Services/server/src/rabbitmq/handler.ts
+++ b/Services/server/src/rabbitmq/handler.ts
@@ -21,9 +21,18 @@ export async function handler(key: string, event: string): Promise<boolean> {
   }
 
   if (!cachedBuffer[key]) {
-    const stream = await minioClient.getObject(bucket, pathname);
-    const buffer = Buffer.concat(await stream.toArray());
-    cachedBuffer[key] = buffer;
+    try {
+      const stream = await minioClient.getObject(bucket, pathname);
+      const buffer = Buffer.concat(await stream.toArray());
+      cachedBuffer[key] = buffer;
+    } catch (e: any) {
+      if (e.code === "NoSuchKey") {
+        delete cachedBuffer[key];
+        delete cachedMetadata[key];
+        await ensureDelete(pathname);
+        return true;
+      }
+    }
   }
 
   if (!cachedMetadata[key]) {