From 132e1e9acd6e62c1b3074fb493656c91e827f38d Mon Sep 17 00:00:00 2001
From: Methapon Metanipat <methapon@frappet.com>
Date: Mon, 26 Aug 2024 11:35:21 +0700
Subject: [PATCH] fix: error

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

diff --git a/Services/server/src/rabbitmq/handler.ts b/Services/server/src/rabbitmq/handler.ts
index 74d8126..e6f3aa6 100644
--- a/Services/server/src/rabbitmq/handler.ts
+++ b/Services/server/src/rabbitmq/handler.ts
@@ -41,9 +41,19 @@ export async function handler(key: string, event: string): Promise<boolean> {
   }
 
   if (!cachedMetadata[key]) {
-    const stat = await minioClient.statObject(bucket, pathname);
-    cachedMetadata[key] = { size: stat.size, type: stat.metaData["content-type"] };
-    if (stat.size > 1024 * 1024 * 100) cachedBuffer[key] = Buffer.from([]);
+    try {
+      const stat = await minioClient.statObject(bucket, pathname);
+      cachedMetadata[key] = { size: stat.size, type: stat.metaData["content-type"] };
+      if (stat.size > 1024 * 1024 * 100) cachedBuffer[key] = Buffer.from([]);
+    } catch (e: any) {
+      if (e.code === "NoSuchKey") {
+        console.info(`[AMQ] Key: ${key} received but cannot be found.`);
+        delete cachedBuffer[key];
+        delete cachedMetadata[key];
+        await ensureDelete(pathname);
+        return true;
+      }
+    }
   }
 
   if (!cachedBuffer[key]) {