Handle already read response body

Author: Nesquiko

packages/plugins/package.json

@@ -1,7 +1,7 @@
 {
   "name": "seroval-plugins",
   "type": "module",
-  "version": "1.3.2",
+  "version": "1.3.3",
   "files": [
     "dist",
     "web"

packages/plugins/tests/web/__snapshots__/response.test.ts.snap

@@ -27,3 +27,5 @@ exports[`Response > toCrossJSONStream > supports Response 3`] = `"{"t":34,"i":3,
 exports[`Response > toJSONAsync > supports Response 1`] = `"{"t":{"t":25,"i":0,"s":{"body":{"t":19,"i":1,"s":[72,101,108,108,111,32,87,111,114,108,100,33]},"options":{"t":10,"i":2,"p":{"k":["headers","status","statusText"],"v":[{"t":25,"i":3,"s":{"t":9,"i":4,"l":1,"a":[{"t":9,"i":5,"l":2,"a":[{"t":1,"s":"content-type"},{"t":1,"s":"text/plain;charset=UTF-8"}],"o":0}],"o":0},"c":"seroval-plugins/web/Headers"},{"t":0,"s":200},{"t":1,"s":""}],"s":3},"o":0}},"c":"seroval-plugins/web/Response"},"f":31,"m":[]}"`;
 
 exports[`Response > toJSONAsync > supports Response 2`] = `"{"t":25,"i":0,"s":{"body":{"t":19,"i":1,"s":[72,101,108,108,111,32,87,111,114,108,100,33]},"options":{"t":10,"i":2,"p":{"k":["headers","status","statusText"],"v":[{"t":25,"i":3,"s":{"t":9,"i":4,"l":1,"a":[{"t":9,"i":5,"l":2,"a":[{"t":1,"s":"content-type"},{"t":1,"s":"text/plain;charset=UTF-8"}],"o":0}],"o":0},"c":"seroval-plugins/web/Headers"},{"t":0,"s":200},{"t":1,"s":""}],"s":3},"o":0}},"c":"seroval-plugins/web/Response"}"`;
+
+exports[`Response > toJSONAsync > supports already read Response 1`] = `"{"t":{"t":25,"i":0,"s":{"body":{"t":2,"s":0},"options":{"t":10,"i":1,"p":{"k":["headers","status","statusText"],"v":[{"t":25,"i":2,"s":{"t":9,"i":3,"l":1,"a":[{"t":9,"i":4,"l":2,"a":[{"t":1,"s":"content-type"},{"t":1,"s":"text/plain;charset=UTF-8"}],"o":0}],"o":0},"c":"seroval-plugins/web/Headers"},{"t":0,"s":200},{"t":1,"s":""}],"s":3},"o":0}},"c":"seroval-plugins/web/Response"},"f":31,"m":[]}"`;

packages/plugins/tests/web/response.test.ts

@@ -40,7 +40,22 @@ describe('Response', () => {
       expect(back).toBeInstanceOf(Response);
       expect(await back.text()).toBe(await example.text());
     });
+
+    it('supports already read Response', async () => {
+      const example = new Response(EXAMPLE_BODY);
+      await example.text();
+      const result = await toJSONAsync(example, {
+        plugins: [ResponsePlugin],
+      });
+      expect(JSON.stringify(result)).toMatchSnapshot();
+      const back = fromJSON<typeof example>(result, {
+        plugins: [ResponsePlugin],
+      });
+      expect(back).toBeInstanceOf(Response);
+      expect(back.body).toBe(null);
+    });
   });
+
   describe('crossSerializeAsync', () => {
     it('supports Response', async () => {
       const example = new Response(EXAMPLE_BODY);

packages/plugins/web/response.ts

@@ -29,7 +29,9 @@ const ResponsePlugin = /* @__PURE__ */ createPlugin<Response, ResponseNode>({
     async async(value, ctx) {
       return {
         body: await ctx.parse(
-          value.body ? await value.clone().arrayBuffer() : null,
+          value.body && !value.bodyUsed
+            ? await value.clone().arrayBuffer()
+            : null,
         ),
         options: await ctx.parse(createResponseOptions(value)),
       };

packages/seroval/package.json

@@ -1,7 +1,7 @@
 {
   "name": "seroval",
   "type": "module",
-  "version": "1.3.2",
+  "version": "1.3.3",
   "files": [
     "dist",
     "src"