fix(http, server): handle missing resources with http 404

src/drivers/http.ts

@@ -1,5 +1,5 @@
 import { defineDriver } from "./utils";
-import { $fetch as _fetch } from "ofetch";
+import { type FetchError, $fetch as _fetch } from "ofetch";
 import { joinURL } from "ufo";
 
 export interface HTTPOptions {
@@ -15,6 +15,13 @@
   const rBase = (key: string = "") =>
     joinURL(opts.base!, (key || "/").replace(/:/g, "/"), ":");
 
+  const catchFetchError = (error: FetchError, fallbackVal: any = null) => {
+    if (error?.response?.status === 404) {
+      return fallbackVal;
+    }
+    throw error;
+  };
+
   return {
     name: DRIVER_NAME,
     options: opts,
@@ -24,12 +31,12 @@
         headers: { ...opts.headers, ...topts.headers },
       })
         .then(() => true)
-        .catch(() => false);
+        .catch((err) => catchFetchError(err, false));
     },
     async getItem(key, tops = {}) {
       const value = await _fetch(r(key), {
         headers: { ...opts.headers, ...tops.headers },
-      });
+      }).catch(catchFetchError);
       return value;
     },
     async getItemRaw(key, topts) {
@@ -39,7 +46,7 @@
           ...opts.headers,
           ...topts.headers,
         },
-      });
+      }).catch(catchFetchError);
       return value;
     },
     async getMeta(key, topts) {

src/server.ts

@@ -76,11 +76,23 @@ export function createH3StorageHandler(
 
       const isRaw =
         getRequestHeader(event, "accept") === "application/octet-stream";
+
+      const checkNotFound = (value: any) => {
+        if (value === null) {
+          throw createError({
+            statusMessage: "KV value not found",
+            statusCode: 404,
+          });
+        }
+      };
+
       if (isRaw) {
         const value = await storage.getItemRaw(key);
+        checkNotFound(value);
         return value;
       } else {
         const value = await storage.getItem(key);
+        checkNotFound(value);
         return stringify(value);
       }
     }

test/server.test.ts

@@ -36,6 +36,15 @@ describe("server", () => {
     expect(await fetchStorage("foo/bar", { method: "DELETE" })).toBe("OK");
     expect(await fetchStorage("foo/bar/", {})).toMatchObject([]);
 
+    await expect(
+      fetchStorage("/non", { method: "GET" }).catch((error) => {
+        throw error.data;
+      })
+    ).rejects.toMatchObject({
+      statusCode: 404,
+      statusMessage: "KV value not found",
+    });
+
     await expect(
       fetchStorage("private/foo/bar", { method: "GET" }).catch((error) => {
         throw error.data;