Function readNodeHttpRequestBody

src/utils/node-http.ts:16–32

(
  req: IncomingMessage,
  maxBodyBytes: number,
  tooLargeMessage: string,
)

}

export async function readNodeHttpRequestBody(
  req: IncomingMessage,
  maxBodyBytes: number,
  tooLargeMessage: string,
): Promise<Buffer> {
  const chunks: Buffer[] = [];
  let bodyBytes = 0;
  for await (const chunk of req) {
    const buffer = Buffer.isBuffer(chunk) ? chunk : Buffer.from(chunk);
    bodyBytes += buffer.length;
    if (bodyBytes > maxBodyBytes) {
      throw new AppError('INVALID_ARGS', tooLargeMessage);
    }
    chunks.push(buffer);
  }
  return Buffer.concat(chunks);
}