chore(blob): batch delete

Author: smarroufin

src/server/api/_hub/blob/delete.post.ts

@@ -0,0 +1,13 @@
+import { eventHandler, readValidatedBody, sendNoContent } from 'h3'
+import { z } from 'zod'
+import { hubBlob } from '../../../utils/blob'
+
+export default eventHandler(async (event) => {
+  const { pathnames } = await readValidatedBody(event, z.object({
+    pathnames: z.array(z.string().min(1)).min(1)
+  }).parse)
+
+  await hubBlob().delete(pathnames)
+
+  return sendNoContent(event)
+})

src/server/utils/blob.ts

@@ -126,8 +126,12 @@ export function hubBlob() {
 
       return mapR2ObjectToBlob(object)
     },
-    async delete(pathname: string) {
-      return await bucket.delete(decodeURI(pathname))
+    async delete(pathnames: string | string[]) {
+      if (Array.isArray(pathnames)) {
+        return await bucket.delete(pathnames.map((p) => decodeURI(p)))
+      } else {
+        return await bucket.delete(decodeURI(pathnames))
+      }
     }
   }
 }
@@ -170,10 +174,19 @@ export function proxyHubBlob(projectUrl: string, secretKey?: string) {
       })
       return JSON.parse(headers.get('x-blob') || '{}') as BlobObject
     },
-    async delete(pathname: string) {
-      await blobAPI<void>(decodeURI(pathname), {
-        method: 'DELETE',
-      })
+    async delete(pathnames: string | string[]) {
+      if (Array.isArray(pathnames)) {
+        await blobAPI<void>('/delete', {
+          method: 'POST',
+          body: {
+            pathnames: pathnames.map((p) => decodeURI(p))
+          }
+        })
+      } else {
+        await blobAPI<void>(decodeURI(pathnames), {
+          method: 'DELETE',
+        })
+      }
       return
     }
   }