Support batch R2Bucket#delete()ing keys

Ref: https://community.cloudflare.com/t/2022-9-16-workers-runtime-release-notes/420496

Author: mrbbot

packages/tre/src/plugins/r2/gateway.ts

@@ -110,9 +110,14 @@ export class R2Gateway {
     return new R2Object(metadata);
   }
 
-  async delete(key: string) {
-    validate.key(key);
-    await this.storage.delete(key);
+  async delete(keys: string | string[]) {
+    if (Array.isArray(keys)) {
+      for (const key of keys) validate.key(key);
+      await this.storage.deleteMany(keys);
+    } else {
+      validate.key(keys);
+      await this.storage.delete(keys);
+    }
   }
 
   async list(listOptions: R2ListOptions = {}): Promise<R2Objects> {

packages/tre/src/plugins/r2/router.ts

@@ -1,4 +1,3 @@
-import assert from "assert";
 import { TextDecoder } from "util";
 import { Request, Response } from "../../http";
 import {
@@ -86,9 +85,9 @@ export class R2Router extends Router<R2Gateway> {
     const gateway = this.gatewayFactory.get(params.bucket, persist);
 
     if (metadata.method === "delete") {
-      assert("object" in metadata);
-      // TODO: support multiple delete
-      await gateway.delete(metadata.object);
+      await gateway.delete(
+        "object" in metadata ? metadata.object : metadata.objects
+      );
       return new Response();
     } else if (metadata.method === "put") {
       const result = await gateway.put(metadata.object, value, metadata);

packages/tre/src/plugins/r2/schemas.ts

@@ -175,7 +175,7 @@ export const R2DeleteRequestSchema = z.intersection(
   z.object({ method: z.literal("delete") }),
   z.union([
     z.object({ object: z.string() }),
-    z.object({ objects: z.string().array() }), // TODO: support
+    z.object({ objects: z.string().array() }),
   ])
 );