Retry implementation

web/netlify/functions/delete-post.mts

@@ -4,20 +4,30 @@ import storageClient from "../../db/storageConnect"
 import { consts } from "../../utils/consts"
 
 export default async (req: Request) => {
-    const { next_run } = await req.json()
-
-    const res = await storageClient.listObjectsV2({ Bucket: consts.storageBucket })
-    const posts = await Post.find({ pending: false })
-
-    //find the attachments not found in posts
-    const attachments = res?.Contents?.filter((x) => !posts.some((y) => y.attachments.includes(x.Key)))
-
-    //delete those attachments from bucket
-    await attachments?.map((x) => storageClient.deleteObject({ Bucket: "development-uploads", Key: x.Key }))
-
-    return new Response("OK")
+    let retryCount = 0;
+    let success = false;
+
+    while (!success && retryCount < 3) {
+      try {
+        const res = await storageClient.listObjectsV2({ Bucket: consts.storageBucket });
+        const posts = await Post.find({ pending: false });
+
+        //find the attachments not found in posts
+        const attachments = res?.Contents?.filter((x) => !posts.some((y) => y.attachments.includes(x.Key)));
+
+        //delete those attachments from bucket
+        await attachments?.map((x) => storageClient.deleteObject({ Bucket: "development-uploads", Key: x.Key }));
+
+        success = true;
+        return "OK";
+      } catch (err) {
+        retryCount++;
+      }
+    }
+
+    throw new Error('Failed to delete post after 3 retries');
 }
 
 export const config: Config = {
-    schedule: "@hourly"
+    schedule: "@daily"
 }