fix

packages/backend/package.json

@@ -20,9 +20,7 @@
     "nitropack": "^2.9.6",
     "octokit": "^3.2.1",
     "query-registry": "^3.0.1",
-    "wrangler": "^3.57.1"
-  },
-  "dependencies": {
+    "wrangler": "^3.57.1",
     "@paralleldrive/cuid2": "^2.2.2"
   }
 }

packages/backend/server/routes/multipart/complete.post.ts

@@ -0,0 +1,21 @@
+import type { R2UploadedPart } from "@cloudflare/workers-types";
+
+export default eventHandler(async (event) => {
+  const {
+    key: key,
+    id: id,
+    "uploaded-parts": uploadedPartsHeader,
+  } = getHeaders(event);
+
+  const binding = useBinding(event);
+
+  const upload = binding.resumeMultipartUpload(key!, id!);
+  const uploadedParts: R2UploadedPart[] = JSON.parse(uploadedPartsHeader!);
+
+  const object = await upload.complete(uploadedParts);
+
+  return {
+    ok: true,
+    key: object.key,
+  };
+});

packages/backend/server/routes/multipart/upload.put.ts

@@ -0,0 +1,19 @@
+export default eventHandler(async (event) => {
+  const {
+    key: key,
+    id: id,
+    "part-number": partNumberHeader,
+  } = getHeaders(event);
+
+  const partNumber = Number(partNumberHeader);
+  const binding = useBinding(event);
+
+  const upload = binding.resumeMultipartUpload(key!, id!);
+  const buffer = (await readRawBody(event, false))!;
+  const part = await upload.uploadPart(partNumber, buffer);
+
+  return {
+    ok: true,
+    part,
+  };
+});

packages/cli/index.ts

@@ -42,6 +42,7 @@ const apiUrl = process.env.API_URL ?? API_URL;
 const publishUrl = new URL("/publish", apiUrl);
 const createMultipart = new URL("/multipart/create", apiUrl);
 const uploadMultipart = new URL("/multipart/upload", apiUrl);
+const completeMultipart = new URL("/multipart/complete", apiUrl);
 
 const main = defineCommand({
   meta: {
@@ -402,7 +403,7 @@ const main = defineCommand({
                   const chunk = file.slice(start, end);
 
                   const uploadMultipartRes = await fetch(uploadMultipart, {
-                    method: "POST",
+                    method: "PUT",
                     headers: {
                       key: uploadKey,
                       id: uploadId,
@@ -420,8 +421,7 @@ const main = defineCommand({
                   const { part } = await uploadMultipartRes.json();
                   uploadedParts.push(part);
                 }
-                console.log('uploaded-parts', uploadedParts)
-                const completeMultipartRes = await fetch(uploadMultipart, {
+                const completeMultipartRes = await fetch(completeMultipart, {
                   method: "POST",
                   headers: {
                     key: uploadKey,
@@ -437,7 +437,7 @@ const main = defineCommand({
                 }
                 const { key: completionKey } =
                   await completeMultipartRes.json();
-                console.log(name, `object:${completionKey}`)
+
                 formData.set(name, `object:${completionKey}`);
               }
             }