chore(blob): put workaround (no stream)

Author: smarroufin

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

@@ -1,17 +1,17 @@
-// async function streamToArrayBuffer(stream: ReadableStream, streamSize: number) {
-//   const result = new Uint8Array(streamSize)
-//   let bytesRead = 0
-//   const reader = stream.getReader()
-//   while (true) {
-//     const { done, value } = await reader.read()
-//     if (done) {
-//       break
-//     }
-//     result.set(value, bytesRead)
-//     bytesRead += value.length
-//   }
-//   return result
-// }
+async function streamToArrayBuffer(stream: ReadableStream, streamSize: number) {
+  const result = new Uint8Array(streamSize)
+  let bytesRead = 0
+  const reader = stream.getReader()
+  while (true) {
+    const { done, value } = await reader.read()
+    if (done) {
+      break
+    }
+    result.set(value, bytesRead)
+    bytesRead += value.length
+  }
+  return result
+}
 
 export default eventHandler(async (event) => {
   const { pathname } = await getValidatedRouterParams(event, z.object({
@@ -29,9 +29,9 @@ export default eventHandler(async (event) => {
   }
 
   // FIXME: find a way to re-stream the readable stream
-  const body = getRequestWebStream(event)!
-  // const stream = getRequestWebStream(event)!
-  // const body = await streamToArrayBuffer(stream, contentLength)
+  // const body = getRequestWebStream(event)!
+  const stream = getRequestWebStream(event)!
+  const body = await streamToArrayBuffer(stream, contentLength)
 
   return useBlob().put(pathname, body, query)
 })

_nuxthub/server/utils/blob.ts

@@ -110,8 +110,6 @@ export function useBlob () {
       const httpMetadata: Record<string, string> = { contentType }
       if (contentLength) {
         httpMetadata.contentLength = contentLength
-        // httpMetadata['content-length'] = contentLength
-        // httpMetadata['Content-Length'] = contentLength
       }
 
       console.log('Pushing object on remote server...')