10mb max size

Author: edidealt

dist/README.md

@@ -0,0 +1 @@
+This folder contains the built output assets for the worker "r2-uploader-example-worker" generated at 2026-03-19T18:04:58.000Z.

dist/index.js.map

@@ -2,7 +2,7 @@
   "name": "r2-uploader-example-worker",
   "scripts": {
     "dev": "wrangler dev src/index.ts --port 4897",
-    "build": "wrangler deploy --dry-run --outfile dist/worker.js src/index.ts",
+    "build": "wrangler deploy --dry-run --outdir dist && mv dist/index.js dist/worker.js",
     "deploy": "wrangler deploy --minify src/index.ts"
   },
   "dependencies": {

dist/worker.js

@@ -13,11 +13,14 @@ import MpuSupport from './routes/mpu/support'
 
 import checkHeader from "./middleware/checkHeader"
 
+const MAX_UPLOAD_SIZE = 10 * 1024 * 1024
+
 interface Env {
   Bindings: {
     R2_BUCKET: R2Bucket
     UPLOAD_LIMITER: Ratelimit
     READ_LIMITER: Ratelimit
+    UPLOAD_SIZES: KVNamespace
   }
 }
 

package.json

@@ -15,6 +15,7 @@ export default async function (c: Context) {
 
   try {
     await multipartUpload.abort();
+    await c.env.UPLOAD_SIZES.delete(uploadId)
   } catch (error: any) {
     return new Response(error.message, {status: 400})
   }

src/index.ts

@@ -32,6 +32,7 @@ export default async function (c: Context) {
 
   try {
     const object = await multipartUpload.complete(body.parts)
+    await c.env.UPLOAD_SIZES.delete(uploadId)
     return new Response(null, {
       headers: {
         etag: object.httpEtag

src/routes/mpu/abort.ts

@@ -8,6 +8,8 @@ export default async function (c: Context) {
   }
 
   const upload = await c.env.R2_BUCKET.createMultipartUpload(key)
+  
+  await c.env.UPLOAD_SIZES.put(upload.uploadId, '0')
 
   return c.json({
     uploadId: upload.uploadId,

src/routes/mpu/complete.ts

@@ -1,5 +1,7 @@
 import {Context} from "hono"
 
+const MAX_UPLOAD_SIZE = 10 * 1024 * 1024
+
 export default async function (c: Context) {
   const key = c.req.param('key')
   const uploadId = c.req.query('uploadId')
@@ -15,6 +17,15 @@ export default async function (c: Context) {
   )
 
   const part = await c.req.blob()
+  
+  const currentSize = parseInt(await c.env.UPLOAD_SIZES.get(uploadId) || '0')
+  const newSize = currentSize + part.size
+
+  if (newSize > MAX_UPLOAD_SIZE) {
+    return c.text(`Upload exceeds 10MB limit (current: ${currentSize}, part: ${part.size})`, 413)
+  }
+
+  await c.env.UPLOAD_SIZES.put(uploadId, newSize.toString())
 
   const uploaded = await multipartUpload.uploadPart(
     parseInt(partNumber),

src/routes/mpu/create.ts

@@ -1,5 +1,7 @@
 import {Context} from "hono"
 
+const MAX_UPLOAD_SIZE = 10 * 1024 * 1024
+
 export default async function (c: Context) {
   const key = c.req.param('key')
   const file = await c.req.blob()
@@ -9,6 +11,10 @@ export default async function (c: Context) {
     return c.text('file name is required', 400)
   }
 
+  if (file.size > MAX_UPLOAD_SIZE) {
+    return c.text('File too large. Maximum size is 10MB', 413)
+  }
+
   await bucket.put(key, file, {
     httpMetadata: {
       contentType: file.type