@@ -8,31 +8,15 @@ describe('reading request body in middleware', () => {
8
8
beforeAll ( async ( ) => {
9
9
next = await createNext ( {
10
10
files : {
11
- 'src/readBody.js' : `
12
- export async function readBody(reader, input = reader.read(), body = "") {
13
- const { value, done } = await input;
14
- const inputText = new TextDecoder().decode(value);
15
- body += inputText;
16
- if (done) {
17
- return body;
18
- }
19
- const next = await reader.read();
20
- return readBody(reader, next, body);
21
- }
22
- ` ,
23
-
24
11
'pages/_middleware.js' : `
25
12
const { NextResponse } = require('next/server');
26
- import { readBody } from '../src/readBody';
27
13
28
14
export default async function middleware(request) {
29
15
if (!request.body) {
30
16
return new Response('No body', { status: 400 });
31
17
}
32
18
33
- const reader = await request.body.getReader();
34
- const body = await readBody(reader);
35
- const json = JSON.parse(body);
19
+ const json = await request.json();
36
20
37
21
if (request.nextUrl.searchParams.has("next")) {
38
22
return NextResponse.next();
@@ -52,16 +36,13 @@ describe('reading request body in middleware', () => {
52
36
53
37
'pages/nested/_middleware.js' : `
54
38
const { NextResponse } = require('next/server');
55
- import { readBody } from '../../src/readBody';
56
39
57
40
export default async function middleware(request) {
58
41
if (!request.body) {
59
42
return new Response('No body', { status: 400 });
60
43
}
61
44
62
- const reader = await request.body.getReader();
63
- const body = await readBody(reader);
64
- const json = JSON.parse(body);
45
+ const json = await request.json();
65
46
66
47
return new Response(JSON.stringify({
67
48
root: false,
0 commit comments