fix(http): avoid closing stream multiple times

.changes/http-controller-multiple-close.md

@@ -0,0 +1,7 @@
+---
+"http": "patch"
+"http-js": "patch"
+---
+
+Fix `fetch` occasionally throwing an error due to trying to close the underline stream twice.
+

plugins/http/guest-js/index.ts

@@ -239,19 +239,17 @@ export async function fetch(
           return
         }
 
-        // close when the signal to close (an empty chunk)
-        // is sent from the IPC.
-        if (
-          res instanceof ArrayBuffer ? res.byteLength == 0 : res.length == 0
-        ) {
+        const resUint8 = new Uint8Array(res)
+        const lastByte = resUint8[resUint8.byteLength - 1]
+        const actualRes = resUint8.slice(0, resUint8.byteLength - 1)
+
+        // close when the signal to close (last byte is 1) is sent from the IPC.
+        if (lastByte == 1) {
           controller.close()
           return
         }
 
-        // the content conversion (like .text(), .json(), etc.) in Response
-        // must have Uint8Array as its content, else it will
-        // have untraceable error that's hard to debug.
-        controller.enqueue(new Uint8Array(res))
+        controller.enqueue(actualRes)
       }
 
       // run a non-blocking body stream fetch
@@ -269,12 +267,11 @@ export async function fetch(
     statusText
   })
 
-  // url and headers are read only properties
-  // but seems like we can set them like this
+  // Set `Response` properties that are ignored by the
+  // constructor, like url and some headers
   //
-  // we define theme like this, because using `Response`
-  // constructor, it removes url and some headers
-  // like `set-cookie` headers
+  // Since url and headers are read only properties
+  // this is the only way to set them.
   Object.defineProperty(res, 'url', { value: url })
   Object.defineProperty(res, 'headers', {
     value: new Headers(responseHeaders)

plugins/http/src/commands.rs

@@ -426,11 +426,14 @@ pub async fn fetch_read_body<R: Runtime>(
 
     // send response through IPC channel
     while let Some(chunk) = res.chunk().await? {
-        stream_channel.send(tauri::ipc::InvokeResponseBody::Raw(chunk.to_vec()))?;
+        let mut chunk = chunk.to_vec();
+        // append 0 to indicate we are not done yet
+        chunk.push(0);
+        stream_channel.send(tauri::ipc::InvokeResponseBody::Raw(chunk))?;
     }
 
-    // send empty vector when done
-    stream_channel.send(tauri::ipc::InvokeResponseBody::Raw(Vec::new()))?;
+    // send 1 to indicate we are done
+    stream_channel.send(tauri::ipc::InvokeResponseBody::Raw(vec![1]))?;
 
     Ok(())
 }