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 { } 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]) {