Add jsonParse and receiveBody

PR-URL: #92

Author: tshemsedinov

CHANGELOG.md

@@ -3,6 +3,8 @@
 ## [Unreleased][unreleased]
 
 - Add `Pool` method `isFree(item: object): boolean`
+- Add function `jsonParse(buffer: Buffer): object | null`
+- Add function `receiveBody(req: IncomingMessage): Promise<string | null>`
 
 ## [3.5.15][] - 2021-09-23
 

README.md

@@ -43,6 +43,8 @@
 - `parseHost(host?: string): string`
 - `parseCookies(cookie: string): object`
 - `fetch(url: string): Promise<string>`
+- `jsonParse(buffer: Buffer): object | null`
+- `receiveBody(req: IncomingMessage): Promise<Buffer | null>`
 
 ## Crypto utilities
 

lib/network.js

@@ -23,4 +23,12 @@ const fetch = async (url) => {
   });
 };
 
-module.exports = { fetch };
+const receiveBody = async (req) => {
+  const buffers = [];
+  for await (const chunk of req) {
+    buffers.push(chunk);
+  }
+  return Buffer.concat(buffers);
+};
+
+module.exports = { fetch, receiveBody };

lib/utilities.js

@@ -291,6 +291,15 @@ const parseCookies = (cookie) => {
   return values;
 };
 
+const jsonParse = (buffer) => {
+  if (buffer.length === 0) return null;
+  try {
+    return JSON.parse(buffer);
+  } catch {
+    return null;
+  }
+};
+
 module.exports = {
   random,
   sample,
@@ -316,4 +325,5 @@ module.exports = {
   makePrivate,
   protect,
   parseCookies,
+  jsonParse,
 };

metautil.d.ts

@@ -1,4 +1,5 @@
 import { EventEmitter } from 'events';
+import { IncomingMessage } from 'http';
 
 export function cryptoRandom(): number;
 export function generateKey(length: number, possible: string): string;
@@ -104,3 +105,5 @@ export class Pool {
 }
 
 export function fetch(url: string): Promise<string>;
+export function jsonParse(buffer: Buffer): object | null;
+export function receiveBody(req: IncomingMessage): Promise<Buffer | null>;

test/network.js

@@ -22,3 +22,22 @@ metatests.test('Fetch', async (test) => {
   test.strictSame(rate, 1);
   test.end();
 });
+
+metatests.test('receiveBody', async (test) => {
+  const value = Buffer.from('{ "a": 5 }');
+  let done = false;
+  const body = {
+    [Symbol.asyncIterator]() {
+      return {
+        async next() {
+          const res = { value, done };
+          done = true;
+          return res;
+        },
+      };
+    },
+  };
+  const data = await metautil.receiveBody(body);
+  test.strictSame(data.toString(), '{ "a": 5 }');
+  test.end();
+});

test/utilities.js

@@ -289,6 +289,12 @@ metatests.case(
       ['domain.com:8080', 'domain.com'],
       ['localhost:8080', 'localhost'],
     ],
+    'metautil.jsonParse': [
+      ['{}', {}],
+      ['{ "a": 5 }', { a: 5 }],
+      ['{', null],
+      ['', null],
+    ],
   }
 );