fix: mirage does not support anything

Author: runspired

packages/request/src/fetch.ts

@@ -146,73 +146,77 @@ const Fetch = {
       return null as T;
     }
 
-    const reader = response.body!.getReader();
-    const decoder = new TextDecoder();
     let text = '';
-    let isStreaming = context.hasRequestedStream;
-    let stream: TransformStream | null = isStreaming ? new TransformStream() : null;
-    let writer = stream?.writable.getWriter();
-
-    if (isStreaming) {
-      // Listen for the abort event on the AbortSignal
-      context.request.signal?.addEventListener('abort', () => {
-        if (!isStreaming) {
-          return;
-        }
-        void stream!.writable.abort('Request Aborted');
-        void stream!.readable.cancel('Request Aborted');
-      });
-      context.setStream(stream!.readable);
-    }
-
-    // eslint-disable-next-line no-constant-condition
-    while (true) {
-      // we manually read the stream instead of using `response.json()`
-      // or `response.text()` because if we need to stream the body
-      // we need to be able to pass the stream along efficiently.
-      const { done, value } = await reader.read();
-      if (done) {
-        if (isStreaming) {
-          isStreaming = false;
-          await writer!.ready;
-          await writer!.close();
-        }
-        break;
-      }
-      text += decoder.decode(value, { stream: true });
+    // if we are in a mirage context, we cannot support streaming
+    if (IS_MAYBE_MIRAGE()) {
+      text = await response.text();
+    } else {
+      const reader = response.body!.getReader();
+      const decoder = new TextDecoder();
+      let isStreaming = context.hasRequestedStream;
+      let stream: TransformStream | null = isStreaming ? new TransformStream() : null;
+      let writer = stream?.writable.getWriter();
 
-      // if we are streaming, we want to pass the stream along
       if (isStreaming) {
-        await writer!.ready;
-        await writer!.write(value);
-      } else if (context.hasRequestedStream) {
-        const encode = new TextEncoder();
-        isStreaming = true;
-        stream = new TransformStream();
         // Listen for the abort event on the AbortSignal
-        // eslint-disable-next-line @typescript-eslint/no-loop-func
         context.request.signal?.addEventListener('abort', () => {
           if (!isStreaming) {
             return;
           }
           void stream!.writable.abort('Request Aborted');
           void stream!.readable.cancel('Request Aborted');
         });
-        context.setStream(stream.readable);
-        writer = stream.writable.getWriter();
-        await writer.ready;
-        await writer.write(encode.encode(text));
-        await writer.ready;
-        await writer.write(value);
+        context.setStream(stream!.readable);
       }
-    }
 
-    if (isStreaming) {
-      isStreaming = false;
-      await writer!.ready;
-      await writer!.close();
-    }
+      // eslint-disable-next-line no-constant-condition
+      while (true) {
+        // we manually read the stream instead of using `response.json()`
+        // or `response.text()` because if we need to stream the body
+        // we need to be able to pass the stream along efficiently.
+        const { done, value } = await reader.read();
+        if (done) {
+          if (isStreaming) {
+            isStreaming = false;
+            await writer!.ready;
+            await writer!.close();
+          }
+          break;
+        }
+        text += decoder.decode(value, { stream: true });
 
+        // if we are streaming, we want to pass the stream along
+        if (isStreaming) {
+          await writer!.ready;
+          await writer!.write(value);
+        } else if (context.hasRequestedStream) {
+          const encode = new TextEncoder();
+          isStreaming = true;
+          stream = new TransformStream();
+          // Listen for the abort event on the AbortSignal
+          // eslint-disable-next-line @typescript-eslint/no-loop-func
+          context.request.signal?.addEventListener('abort', () => {
+            if (!isStreaming) {
+              return;
+            }
+            void stream!.writable.abort('Request Aborted');
+            void stream!.readable.cancel('Request Aborted');
+          });
+          context.setStream(stream.readable);
+          writer = stream.writable.getWriter();
+          await writer.ready;
+          await writer.write(encode.encode(text));
+          await writer.ready;
+          await writer.write(value);
+        }
+      }
+
+      if (isStreaming) {
+        isStreaming = false;
+        await writer!.ready;
+        await writer!.close();
+      }
+    }
     // if we are an error, we will want to throw
     if (isError) {
       let errorPayload: object | undefined;