refactor: move to streams

Author: mtdvlpr

package.json

@@ -22,6 +22,7 @@
     "postinstall": "pnpm prepare:husky && pnpm prepare:nuxt"
   },
   "dependencies": {
+    "@fastify/busboy": "^3.2.0",
     "@iconify-json/lucide": "^1.2.87",
     "@iconify-json/simple-icons": "^1.2.68",
     "@nuxt/test-utils": "3.23.0",
@@ -37,6 +38,7 @@
     "pinia-plugin-persistedstate": "^4.7.1",
     "sql.js": "^1.13.0",
     "tailwindcss": "^4.1.18",
+    "unzipper": "^0.12.3",
     "v-code-diff": "^1.13.1",
     "zod": "^4.3.6"
   },
@@ -48,6 +50,7 @@
     "@types/node": "^22.19.7",
     "@types/pako": "^2.0.4",
     "@types/sql.js": "^1.4.9",
+    "@types/unzipper": "^0.10.11",
     "@vitest/coverage-v8": "^3.2.4",
     "@vitest/eslint-plugin": "^1.6.6",
     "@vue/test-utils": "^2.4.6",

pnpm-lock.yaml

@@ -1,27 +1,12 @@
 export default defineEventHandler(async (event) => {
-  console.log("Getting outlines...");
-  const [file] = await receiveFiles(event, {
-    ensure: {
-      maxSize: "128MB",
-      types: ["application/octet-stream"],
+  const database = await processFileUpload(event, {
+    maxSize: 256 * 1024 * 1024,
+    processor: async (fileStream) => {
+      console.log("Processing file stream...");
+      return await getJWPUBDatabase(fileStream);
     },
-    formKey: "file",
-    multiple: false,
   });
 
-  if (!file) {
-    throw createError({
-      statusCode: 400,
-      statusMessage: "No file received",
-    });
-  }
-
-  console.log("File received");
-
-  const database = await getJWPUBDatabase(
-    getRequestURL(event).origin,
-    await file.arrayBuffer(),
-  );
   const outlines = queryDatabase<{ Title: string }>(
     database,
     "SELECT Title FROM Document",