feat: Now you can use with body-parser

Author: muratcorlu

README.md

@@ -28,8 +28,9 @@ you'll have this:
 
 ```js
 const { use } = require('lambda-expressless');
+const bodyParser = require('body-parser');
 
-exports.handler = use((req, res) => {
+exports.handler = use(bodyParser.json(), (req, res) => {
   res.status(201).json({
     success: false,
     data: req.body.id
@@ -59,6 +60,11 @@ const getUser = (req, res) => {
 
 exports.handler = use(checkUser, getUser);
 ```
+
+You can use many popular Express Middlewares. Some examples are:
+
+- [body-parser](https://github.com/expressjs/body-parser)
+
 ## Installation
 
 ```npm i lambda-expressless```
@@ -73,8 +79,15 @@ Properties:
 
 | Property    | Notes |
 |-------------|-------|
-| [body](https://expressjs.com/en/4x/api.html#req.body) | - |
+| [body](https://expressjs.com/en/4x/api.html#req.body) | You need to use [body-parser](https://github.com/expressjs/body-parser) |
+| [hostname](https://expressjs.com/en/4x/api.html#req.hostname) | - |
+| [host](https://expressjs.com/en/4x/api.html#req.host) | - |
+| [xhr](https://expressjs.com/en/4x/api.html#req.xhr) | - |
+| [ip](https://expressjs.com/en/4x/api.html#req.ip) | - |
+| [ips](https://expressjs.com/en/4x/api.html#req.ips) | - |
 | [path](https://expressjs.com/en/4x/api.html#req.path) | - |
+| [protocol](https://expressjs.com/en/4x/api.html#req.protocol) | - |
+| [secure](https://expressjs.com/en/4x/api.html#req.secure) | - |
 | [method](https://expressjs.com/en/4x/api.html#req.method) | - |
 | [query](https://expressjs.com/en/4x/api.html#req.query) | Doesn't include repeated query parameters. |
 | [params](https://expressjs.com/en/4x/api.html#req.params) | - |

package-lock.json

@@ -20,6 +20,7 @@
   },
   "homepage": "https://github.com/muratcorlu/lambda-expressless#readme",
   "devDependencies": {
+    "body-parser": "^1.19.0",
     "jest": "^24.9.0",
     "semantic-release": "^15.13.21"
   }

package.json

@@ -1,4 +1,5 @@
 const { use } = require('./lambda-wrapper');
+const bodyParser = require('body-parser');
 
 describe('Lambda Wrapper', () => {
   const proxyRequest = {
@@ -54,7 +55,7 @@ describe('Lambda Wrapper', () => {
 
   it('should handle json body on a post request', () => {
 
-    const lambdaHandler = use((req, res) => {
+    const lambdaHandler = use(bodyParser.json(), (req, res) => {
       res.json(req.body);
     });
 
@@ -63,7 +64,8 @@ describe('Lambda Wrapper', () => {
     const proxyRequest = {
       body: requestObject,
       headers: {
-        'Content-Type': 'application/json'
+        'Content-Type': 'application/json',
+        'Content-Length': requestObject.length
       },
       multiValueHeaders: {},
       httpMethod: 'POST',

src/lambda-wrapper.spec.js

@@ -1,21 +1,32 @@
+const ReadableStream = require('stream').Readable;
+
 /**
  *
  */
-class Request {
+class Request extends ReadableStream {
   constructor(event) {
-    this.method = event.httpMethod;
-    this.query = event.queryStringParameters;
-    this.path = event.path;
-    this.params = event.pathParameters;
+    super();
     this.headers = Object.keys(event.headers).reduce((headers, key) => {
       headers[key.toLowerCase()] = event.headers[key];
       return headers;
     }, {});
+    this.hostname = this.headers.host
+    this.method = event.httpMethod;
+    this.query = event.queryStringParameters;
+    this.path = event.path;
+    this.params = event.pathParameters;
+
+    this.protocol = this.get('X-Forwarded-Proto')
+    this.secure = this.protocol === 'https';
+    this.ips = (this.get('X-Forwarded-For') || '').split(', ');
+    this.ip = this.ips[0];
+    this.host = this.get('X-Forwarded-Host') || this.hostname;
+    this.xhr = (this.get('X-Requested-With') || '').toLowerCase() === 'xmlhttprequest';
+
+    this.event = event;
 
-    this.body = event.body;
-    if (this.is('json')) {
-      this.body = JSON.parse(event.body);
-    }
+    this.push(event.body);
+    this.push(null);
   }
 
   get(key) {

src/request.js

@@ -5,7 +5,8 @@ describe('Request object', () => {
   const event = {
     body: JSON.stringify(requestObject),
     headers: {
-      'Content-Type': 'application/json'
+      'Content-Type': 'application/json',
+      'Content-Length': JSON.stringify(requestObject).length
     },
     multiValueHeaders: {},
     httpMethod: 'POST',
@@ -19,12 +20,6 @@ describe('Request object', () => {
     resource: ''
   };
 
-  it('read body', () => {
-    const request = new Request(event);
-
-    expect(request.body).toEqual(requestObject);
-  });
-
   it('should read header', () => {
     const request = new Request(event);