feat: add uploadthing driver

package.json

@@ -92,6 +92,7 @@
     "types-cloudflare-worker": "^1.2.0",
     "typescript": "^5.3.3",
     "unbuild": "^2.0.0",
+    "uploadthing": "^6.3.0",
     "vite": "^5.0.11",
     "vitest": "^1.2.1",
     "vue": "^3.4.14"
@@ -108,7 +109,8 @@
     "@planetscale/database": "^1.13.0",
     "@upstash/redis": "^1.28.1",
     "@vercel/kv": "^0.2.4",
-    "idb-keyval": "^6.2.1"
+    "idb-keyval": "^6.2.1",
+    "uploadthing": "^6.0.0"
   },
   "peerDependenciesMeta": {
     "@azure/app-configuration": {
@@ -146,6 +148,9 @@
     },
     "idb-keyval": {
       "optional": true
+    },
+    "uploadthing": {
+      "optional": true
     }
   },
   "packageManager": "[email protected]"

src/drivers/uploadthing.ts

@@ -0,0 +1,90 @@
+import { defineDriver } from "./utils";
+import { ofetch, $Fetch } from "ofetch";
+import { UTApi } from "uploadthing/server";
+
+export interface UploadThingOptions {
+  apiKey: string;
+}
+
+export default defineDriver<UploadThingOptions>((opts) => {
+  let client: UTApi;
+  let utFetch: $Fetch;
+
+  const getClient = () => {
+    return (client ??= new UTApi({
+      apiKey: opts.apiKey,
+      fetch: ofetch.native,
+    }));
+  };
+
+  const getUTFetch = () => {
+    return (utFetch ??= ofetch.create({
+      baseURL: "https://uploadthing.com/api",
+      headers: {
+        "x-uploadthing-api-key": opts.apiKey,
+      },
+    }));
+  };
+
+  return {
+    hasItem(key) {
+      // This is the best endpoint we got currently...
+      return getUTFetch()("/getFileUrl", {
+        body: { fileKeys: [key] },
+      }).then((res) => res.ok);
+    },
+    getItem(key) {
+      return ofetch(`https://utfs.io/f/${key}`);
+    },
+    getItemRaw(key) {
+      return ofetch
+        .native(`https://utfs.io/f/${key}`)
+        .then((res) => res.arrayBuffer());
+    },
+    getItems(items) {
+      return Promise.all(
+        items.map((item) =>
+          ofetch(`https://utfs.io/f/${item.key}`).then((res) => ({
+            key: item.key,
+            value: res,
+          }))
+        )
+      );
+    },
+    getKeys() {
+      return getClient()
+        .listFiles({})
+        .then((res) => res.map((file) => file.key));
+    },
+    setItem(key, value, opts) {
+      return getClient()
+        .uploadFiles(new Blob([value]), {
+          metadata: opts.metadata,
+        })
+        .then(() => {});
+    },
+    setItems(items, opts) {
+      return getClient()
+        .uploadFiles(
+          items.map((item) => new Blob([item.value])),
+          {
+            metadata: opts?.metadata,
+          }
+        )
+        .then(() => {});
+    },
+    removeItem(key, opts) {
+      return getClient()
+        .deleteFiles([key])
+        .then(() => {});
+    },
+    async clear() {
+      const client = getClient();
+      const keys = await client.listFiles({}).then((r) => r.map((f) => f.key));
+      return client.deleteFiles(keys).then(() => {});
+    },
+    // getMeta(key, opts) {
+    //   // TODO: We don't currently have an endpoint to fetch metadata, but it does exist
+    // },
+  };
+});