chore(storage): up

_nuxthub/server/api/_hub/blob/[...pathname].delete.ts

@@ -0,0 +1,10 @@
+export default eventHandler(async (event) => {
+  // TODO: handle authorization
+  const { pathname } = await getValidatedRouterParams(event, z.object({
+    pathname: z.string().min(1)
+  }).parse)
+
+  await useBlob().delete(pathname)
+
+  return setResponseStatus(event, 204)
+})

_nuxthub/server/api/_hub/blob/[...pathname].get.ts

@@ -0,0 +1,8 @@
+export default eventHandler(async (event) => {
+  // TODO: handle authorization
+  const { pathname } = await getValidatedRouterParams(event, z.object({
+    pathname: z.string().min(1)
+  }).parse)
+
+  return useBlob().serve(event, pathname)
+})

_nuxthub/server/api/_hub/blob/[...pathname].head.ts

@@ -0,0 +1,13 @@
+export default eventHandler(async (event) => {
+  // TODO: handle authorization
+
+  const { pathname } = await getValidatedRouterParams(event, z.object({
+    pathname: z.string().min(1)
+  }).parse)
+
+  const blob = useBlob().head(pathname)
+
+  setHeader(event, 'x-blob', JSON.stringify(blob))
+
+  return setResponseStatus(event, 204)
+})

_nuxthub/server/utils/blob.ts

@@ -94,23 +94,44 @@ export function useBlob () {
       const contentType = optionsContentType || (body as Blob).type || getContentType(pathname)
 
       const { dir, ext, name: filename } = parse(pathname)
-      let key = pathname
       if (addRandomSuffix) {
-        key = joinURL(dir === '.' ? '' : dir, `${filename}-${randomUUID().split('-')[0]}${ext}`)
+        pathname = joinURL(dir === '.' ? '' : dir, `${filename}-${randomUUID().split('-')[0]}${ext}`)
       }
 
-      const object = await bucket.put(key, body as any, { httpMetadata: { contentType }, customMetadata })
+      const object = await bucket.put(pathname, body as any, { httpMetadata: { contentType }, customMetadata })
 
       return mapR2ObjectToBlob(object)
     },
-    async delete (key: string) {
+    async head (pathname: string) {
       if (proxyURL) {
-        const query: Record<string, any> = {}
+        const body = await $fetch<void>(joinURL('/api/_hub/blob', pathname), {
+          baseURL: proxyURL,
+          method: 'HEAD'
+        })
+        console.log('head body', body)
+        return
+      }
+      // Use R2 binding
+      const object = await bucket.head(pathname)
+
+      if (!object) {
+        throw createError({ message: 'Blob not found', statusCode: 404 })
+      }
+
+      return mapR2ObjectToBlob(object)
+    },
+    async delete (pathname: string) {
+      if (proxyURL) {
+        const body = await $fetch<void>(`/api/_hub/blob/${pathname}`, {
+          baseURL: proxyURL,
+          method: 'DELETE',
+        })
 
-        return $fetch<void>(`/api/_hub/blob/${key}`, { baseURL: proxyURL, method: 'DELETE', query })
+        console.log('delete body', body)
+        return
       }
       // Use R2 binding
-      return await bucket.delete(key)
+      return await bucket.delete(pathname)
     }
   }
 }

_nuxthub/server/utils/zod.ts

@@ -0,0 +1 @@
+export { z } from 'zod'