Fix request consumption in server.js

Previously stream errors during `req` consumption would lead to a hanged
connection and resource/memory leak.
This also removes redundant double-promise from receiveBody.

PR-URL: #174

Author: lundibundi

lib/server.js

@@ -12,14 +12,14 @@ const LONG_RESPONSE = 30000;
 
 const clients = new Map();
 
-const receiveBody = async req => new Promise(resolve => {
+const receiveBody = async req => {
   const buffers = [];
-  req.on('data', chunk => {
+  for await (const chunk of req) {
     buffers.push(chunk);
-  }).on('end', () => {
-    resolve(Buffer.concat(buffers).toString());
-  });
-});
+  }
+  return Buffer.concat(buffers).toString();
+};
+
 
 const closeClients = () => {
   for (const [connection, client] of clients.entries()) {
@@ -56,6 +56,8 @@ const listener = (req, res) => {
     }
     receiveBody(req).then(data => {
       client.message(data);
+    }, err => {
+      client.error(500, err);
     });
   } else {
     if (url === '/' && !req.connection.encrypted) {