From dfda25f14503bea9259bc244fa255e85234176ef Mon Sep 17 00:00:00 2001
From: Pooya Parsa <pooya@pi0.io>
Date: Thu, 28 Sep 2023 23:20:56 +0200
Subject: [PATCH] fix(server): read body as string

---
 src/server.ts | 25 +++++++++++++------------
 1 file changed, 13 insertions(+), 12 deletions(-)

diff --git a/src/server.ts b/src/server.ts
index 1f0211a1..e92d6d1f 100644
--- a/src/server.ts
+++ b/src/server.ts
@@ -41,21 +41,20 @@ export function createH3StorageHandler(
   opts: StorageServerOptions = {}
 ): EventHandler {
   return eventHandler(async (event) => {
-    const method = getMethod(event);
     const _path = opts.resolvePath?.(event) ?? event.path;
     const isBaseKey = _path.endsWith(":") || _path.endsWith("/");
     const key = isBaseKey ? normalizeBaseKey(_path) : normalizeKey(_path);
 
     // Authorize Request
-    if (!(method in MethodToTypeMap)) {
+    if (!(event.method in MethodToTypeMap)) {
       throw createError({
         statusCode: 405,
-        statusMessage: `Method Not Allowed: ${method}`,
+        statusMessage: `Method Not Allowed: ${event.method}`,
       });
     }
     try {
       await opts.authorize?.({
-        type: MethodToTypeMap[method as keyof typeof MethodToTypeMap],
+        type: MethodToTypeMap[event.method as keyof typeof MethodToTypeMap],
         event,
         key,
       });
@@ -71,7 +70,7 @@ export function createH3StorageHandler(
     }
 
     // GET => getItem
-    if (method === "GET") {
+    if (event.method === "GET") {
       if (isBaseKey) {
         const keys = await storage.getKeys(key);
         return keys.map((key) => key.replace(/:/g, "/"));
@@ -89,7 +88,7 @@ export function createH3StorageHandler(
     }
 
     // HEAD => hasItem + meta (mtime)
-    if (method === "HEAD") {
+    if (event.method === "HEAD") {
       const _hasItem = await storage.hasItem(key);
       event.node.res.statusCode = _hasItem ? 200 : 404;
       if (_hasItem) {
@@ -106,28 +105,30 @@ export function createH3StorageHandler(
     }
 
     // PUT => setItem
-    if (method === "PUT") {
+    if (event.method === "PUT") {
       const isRaw =
         getRequestHeader(event, "content-type") === "application/octet-stream";
       if (isRaw) {
         const value = await readRawBody(event);
         await storage.setItemRaw(key, value);
       } else {
-        const value = await readBody(event);
-        await storage.setItem(key, value);
+        const value = await readRawBody(event, "utf8");
+        if (value !== undefined) {
+          await storage.setItem(key, value);
+        }
       }
       return "OK";
     }
 
     // DELETE => removeItem
-    if (method === "DELETE") {
+    if (event.method === "DELETE") {
       await (isBaseKey ? storage.clear(key) : storage.removeItem(key));
       return "OK";
     }
 
     throw createError({
       statusCode: 405,
-      statusMessage: `Method Not Allowed: ${method}`,
+      statusMessage: `Method Not Allowed: ${event.method}`,
     });
   });
 }
@@ -136,7 +137,7 @@ export function createStorageServer(
   storage: Storage,
   options: StorageServerOptions = {}
 ): { handle: RequestListener } {
-  const app = createApp();
+  const app = createApp({ debug: true });
   const handler = createH3StorageHandler(storage, options);
   app.use(handler);
   return {