Clone requests/responses

Author: lxsmnsyc

packages/start/src/server/server-functions-handler.ts

@@ -52,18 +52,19 @@ export async function handleServerFunction(h3Event: H3Event) {
       }
     }
   }
-  if (h3Event.method === "POST") {
+  if (request.method === "POST") {
     const contentType = request.headers.get("content-type");
+    const clone = request.clone();
 
     if (
       contentType?.startsWith("multipart/form-data") ||
       contentType?.startsWith("application/x-www-form-urlencoded")
     ) {
-      parsed.push(await event.request.formData());
+      parsed.push(await clone.formData());
     } else if (contentType?.startsWith('application/json')) {
-      parsed = await event.request.json() as any[];
+      parsed = await clone.json() as any[];
     } else if (request.headers.has('x-serialized')) {
-      parsed = (await deserializeJSONStream(event.request.clone())) as any[];
+      parsed = (await deserializeJSONStream(clone)) as any[];
     }
   }
   try {

packages/start/src/server/server-runtime.ts

@@ -67,25 +67,26 @@ async function fetchServerFunction(
       /* @ts-ignore-next-line */
       response.customBody = () => {
         if (import.meta.env.SEROVAL_MODE === "js") {
-          return deserializeJSStream(instance, response);
+          return deserializeJSStream(instance, response.clone());
         }
-        return deserializeJSONStream(response);
+        return deserializeJSONStream(response.clone());
       };
     }
     return response;
   }
 
   const contentType = response.headers.get("Content-Type");
+  const clone = response.clone();
   let result;
   if (contentType?.startsWith("text/plain")) {
-    result = await response.text();
+    result = await clone.text();
   } else if (contentType?.startsWith("application/json")) {
-    result = await response.json();
+    result = await clone.json();
   } else if (response.headers.get('x-serialized')) {
     if (import.meta.env.SEROVAL_MODE === "js") {
-      result = await deserializeJSStream(instance, response);
+      result = await deserializeJSStream(instance, clone);
     } else {
-      result = await deserializeJSONStream(response);
+      result = await deserializeJSONStream(clone);
     }
   }
   if (response.headers.has("X-Error")) {