express-http-proxy - npm Package Compare versions

Comparing version 2.0.0 to 2.1.0

app/steps/buildProxyReq.js

@@ -13,2 +13,3 @@ 'use strict';
   var parseBody = (!options.parseReqBody) ? Promise.resolve(null) : requestOptions.bodyContent(req, res, options);
+
   var createReqOptions = requestOptions.create(req, res, options, host);
@@ -19,2 +20,3 @@
     .then(function (responseArray) {
+      req.body = responseArray[0];
       Container.proxy.bodyContent = responseArray[0];
@@ -24,2 +26,6 @@ Container.proxy.reqBuilder = responseArray[1];
       return Container;
+    })
+    .catch(function (err) {
+      debug('error occurred while building proxy request:', err);
+      return Promise.reject(err);
     });
@@ -26,0 +32,0 @@ }

app/steps/maybeSkipToNextHandler.js

@@ -14,4 +14,3 @@ 'use strict';
       if (shouldSkipToNext) {
-        container.user.res.expressHttpProxy = container.proxy;
-        return Promise.reject(container.user.next());
+        return Promise.reject();
       } else {
@@ -18,0 +17,0 @@ return Promise.resolve(container);

app/steps/sendProxyRequest.js

@@ -39,18 +39,13 @@ 'use strict';
 
-    // this guy should go elsewhere, down the chain
-
     if (options.parseReqBody) {
-    // We are parsing the body ourselves so we need to write the body content
-    // and then manually end the request.
+      // We are parsing the body ourselves so we need to write the body content
+      // and then manually end the request.
 
-      //if (bodyContent instanceof Object) {
-      //throw new Error
-      //debugger;
-      //bodyContent = JSON.stringify(bodyContent);
-      //}
-
       if (bodyContent.length) {
         var body = bodyContent;
         var contentType = proxyReq.getHeader('Content-Type');
-        if (contentType === 'x-www-form-urlencoded' || contentType === 'application/x-www-form-urlencoded') {
+        // contentTypes may contain semi-colon
+        // example: "application/x-www-form-urlencoded; charset=UTF-8"
+
+        if (contentType && contentType.match('x-www-form-urlencoded')) {
           try {
@@ -67,2 +62,5 @@ var params = JSON.parse(body);
       proxyReq.end();
+    } else if (bodyContent) {
+      proxyReq.write(bodyContent);
+      proxyReq.end();
     } else {
@@ -69,0 +67,0 @@ // Pipe will call end when it has completely read from the request.

index.js

@@ -47,5 +47,2 @@ 'use strict';
       .catch(function (err) {
-        // I sometimes reject without an error to shortcircuit the remaining
-        // steps and return control to the host application.
-
         if (err) {
@@ -57,3 +54,7 @@ var resolver = (container.options.proxyErrorHandler) ?
         } else {
-          next();
+          // I sometimes reject without an error to shortcircuit the remaining
+          // steps -- e.g. in maybeSkipToNextHandler -- and return control to
+          // the host application for continuing on without raising an error.
+
+          return next();
         }
@@ -60,0 +61,0 @@ });

lib/as.js

@@ -13,5 +13,5 @@ 'use strict';
   } else if (typeof body === 'object') {
-    ret = new Buffer(JSON.stringify(body), options.reqBodyEncoding);
+    ret = Buffer.from(JSON.stringify(body), options.reqBodyEncoding);
   } else if (typeof body === 'string') {
-    ret = new Buffer(body, options.reqBodyEncoding);
+    ret = Buffer.from(body, options.reqBodyEncoding);
   }
@@ -18,0 +18,0 @@ return ret;

lib/requestOptions.js

@@ -93,4 +93,9 @@ 'use strict';
       return Promise.resolve(req.body);
+    } else if (!req.readable) {
+      return Promise.reject(
+        'Tried to parse body after request body has already been read.' +
+        ' Try setting parseReqBody to false and manually specify the body you want to send in decorateProxyReqBody.'
+      );
     } else {
-      // Returns a promise if no callback specified and global Promise exists.
+      // Returns a promise
 
@@ -97,0 +102,0 @@ return getRawBody(req, {

package.json

 {
   "name": "express-http-proxy",
-  "version": "2.0.0",
+  "version": "2.1.0",
   "description": "http proxy middleware for express",
@@ -11,3 +11,3 @@ "engines": {
     "test": "npm -s run mocha && npm run -s lint",
-    "test:debug": "mocha debug -R spec test --recursive --exit",
+    "test:debug": "mocha inspect --debug-brk -R spec test --recursive --exit",
     "mocha": "mocha -R spec test --recursive --exit",
@@ -14,0 +14,0 @@ "lint": "eslint index.js app/**/*js lib/*js"

README.md

@@ -76,2 +76,7 @@ # express-http-proxy [![NPM version](https://badge.fury.io/js/express-http-proxy.svg)](http://badge.fury.io/js/express-http-proxy) [![Build Status](https://travis-ci.org/villadora/express-http-proxy.svg?branch=master)](https://travis-ci.org/villadora/express-http-proxy)
 ```
+
+Notie: Host is only the host name. Any params after in url will be ignored. For ``http://google.com/myPath`, ``myPath`` will be ignored because the host name is ``google.com``. 
+See ``proxyReqPathResolver`` for more detailed path information.
+
+
 ### Middleware mixing
@@ -81,6 +86,5 @@
 
-```
+```js
+app.use('/proxy', proxy('http://foo.bar.com'))
 
-app.use('/proxy', 'http://foo.bar.com')
-
 // Declare use of body-parser AFTER the use of proxy
@@ -91,2 +95,15 @@ app.use(bodyParser.foo(bar))
 
+If this cannot be avoided and you MUST proxy after `body-parser` has been registered, set `parseReqBody` to `false` and explicitly specify the body you wish to send in `proxyReqBodyDecorator`.
+
+```js
+app.use(bodyParser.foo(bar))
+
+app.use('/proxy', proxy('http://foo.bar.com', {
+  parseReqBody: false,
+  proxyReqBodyDecorator: function () {
+
+  },
+}))
+```
+
 ### Options
@@ -581,2 +598,6 @@
 | --- | --- |
+| 2.1.0 | * Fixes => content-types can have semi-colons, and we need to parse around this.<br />
+* Improves => using proxyReqBodyDecorator with parseReqBody=false. <br />
+* Repairs => Can't use proxy() twice in Express middleware stack. <br />
+* Fixes => Instead of new Buffer using Buffer.from as per https://nodejs.org/api/buffer.html\#buffer_new_buffer_string_encoding. <br />
 | 2.0.0 | Update all dependencies; set stage for next iteration. `express-http-proxy` interface has not changed, but the underlying libraries are not guaranteed to be backward compatible. Versions beyond this point are expected to be run in node verions >= 16. |
@@ -583,0 +604,0 @@ | ----- | ----------------------------------------------------------------------- |

test/getBody.js

@@ -158,2 +158,94 @@ 'use strict';
 
+  it('should use proxyReqBodyDecorator with parseReqBody=false', function (done) {
+    var scope = nock('http://127.0.0.1:12345')
+      .get('/', {})
+      .matchHeader('Content-Type', 'application/json')
+      .reply(200, {
+        name: 'proxyReqBodyDecorator + parseReqBody=false works'
+      });
+
+    var payload = {};
+
+    localServer.use('/proxy', proxy('http://127.0.0.1:12345', {
+      parseReqBody: false,
+      proxyReqBodyDecorator: () => JSON.stringify(payload),
+    }));
+
+    request(localServer)
+      .get('/proxy')
+      .send(payload)
+      .set('Content-Type', 'application/json')
+      .expect(function (res) {
+        assert(res.body.name === 'proxyReqBodyDecorator + parseReqBody=false works');
+        scope.done();
+      })
+      .end(done);
+  });
+
+  describe('when body-parser.json() is using strict=false', function () {
+    beforeEach(function () {
+      localServer = createLocalApplicationServer();
+      localServer.use(bodyParser.json({ strict: false }));
+    });
+
+    var testCases = [
+      { value: false },
+      { value: null },
+      { value: '' },
+    ];
+
+    testCases.forEach(function (test) {
+      var valueString = JSON.stringify(test.value);
+
+      it('errors when body is ' + valueString, function (done) {
+        localServer.use('/proxy', proxy('http://127.0.0.1:12345'));
+        localServer.use(function (err, req, res, next) { res.send(err); next(); });
+
+        request(localServer)
+          .get('/proxy')
+          .send(valueString)
+          .set('Content-Type', 'application/json')
+          .expect(function (res) {
+            assert(
+              res.text === (
+                'Tried to parse body after request body has already been read.' +
+                ' Try setting parseReqBody to false and manually specify the body' +
+                ' you want to send in decorateProxyReqBody.'
+              )
+            );
+          })
+          .end(done);
+      });
+
+      it(
+        'succeeds when parseReqBody=false and proxyReqBodyDecorator explicitly returns ' + valueString,
+        function (done) {
+          var scope = nock('http://127.0.0.1:12345')
+            .get('/', valueString)
+            .matchHeader('Content-Type', 'application/json')
+            .reply(200, valueString, {
+              'Content-Type': 'application/json',
+            });
+
+          localServer.use('/proxy', proxy('http://127.0.0.1:12345', {
+            parseReqBody: false,
+            proxyReqBodyDecorator: function () {
+              return valueString;
+            },
+          }));
+
+          request(localServer)
+            .get('/proxy')
+            .send(valueString)
+            .set('Content-Type', 'application/json')
+            .expect(function (res) {
+              assert(res.body === test.value);
+              scope.done();
+            })
+            .end(done);
+        }
+      );
+    });
+  });
+
 });

test/maybeSkipToNextHandler.js

@@ -20,3 +20,3 @@ 'use strict';
     slowTarget = express();
-    slowTarget.use(function (req, res) { res.sendStatus(404); });
+    slowTarget.use(function (req, res) { res.sendStatus(407); });
     serverReference = slowTarget.listen(12345);
@@ -30,4 +30,4 @@ });
   var OUTCOMES = [
-    { shouldSkip: true, expectedStatus: 200 },
-    { shouldSkip: false, expectedStatus: 404 }
+    { shouldSkip: false, expectedStatus: 407 },
+    { shouldSkip: true, expectedStatus: 203 },
   ];
@@ -46,6 +46,3 @@
         app.use(function (req, res) {
-          assert(res.expressHttpProxy instanceof Object);
-          assert(res.expressHttpProxy.res instanceof http.IncomingMessage);
-          assert(res.expressHttpProxy.req instanceof Object);
-          res.sendStatus(200);
+          res.sendStatus(203);
         });
@@ -52,0 +49,0 @@

test/postBody.js

@@ -131,2 +131,94 @@ 'use strict';
 
+  it('should use proxyReqBodyDecorator with parseReqBody=false', function (done) {
+    var scope = nock('http://127.0.0.1:12345')
+      .post('/', {})
+      .matchHeader('Content-Type', 'application/json')
+      .reply(200, {
+        name: 'proxyReqBodyDecorator + parseReqBody=false works'
+      });
+
+    var payload = {};
+
+    localServer.use('/proxy', proxy('http://127.0.0.1:12345', {
+      parseReqBody: false,
+      proxyReqBodyDecorator: () => JSON.stringify(payload),
+    }));
+
+    request(localServer)
+      .post('/proxy')
+      .send(payload)
+      .set('Content-Type', 'application/json')
+      .expect(function (res) {
+        assert(res.body.name === 'proxyReqBodyDecorator + parseReqBody=false works');
+        scope.done();
+      })
+      .end(done);
+  });
+
+  describe('when body-parser.json() is using strict=false', function () {
+    beforeEach(function () {
+      localServer = createLocalApplicationServer();
+      localServer.use(bodyParser.json({ strict: false }));
+    });
+
+    var testCases = [
+      { value: false },
+      { value: null },
+      { value: '' },
+    ];
+
+    testCases.forEach(function (test) {
+      var valueString = JSON.stringify(test.value);
+
+      it('errors when body is ' + valueString, function (done) {
+        localServer.use('/proxy', proxy('http://127.0.0.1:12345'));
+        localServer.use(function (err, req, res, next) { res.send(err); next(); });
+
+        request(localServer)
+          .post('/proxy')
+          .send(valueString)
+          .set('Content-Type', 'application/json')
+          .expect(function (res) {
+            assert(
+              res.text === (
+                'Tried to parse body after request body has already been read.' +
+                ' Try setting parseReqBody to false and manually specify the body' +
+                ' you want to send in decorateProxyReqBody.'
+              )
+            );
+          })
+          .end(done);
+      });
+
+      it(
+        'succeeds when parseReqBody=false and proxyReqBodyDecorator explicitly returns ' + valueString,
+        function (done) {
+          var scope = nock('http://127.0.0.1:12345')
+            .post('/', valueString)
+            .matchHeader('Content-Type', 'application/json')
+            .reply(200, valueString, {
+              'Content-Type': 'application/json',
+            });
+
+          localServer.use('/proxy', proxy('http://127.0.0.1:12345', {
+            parseReqBody: false,
+            proxyReqBodyDecorator: function () {
+              return valueString;
+            },
+          }));
+
+          request(localServer)
+            .post('/proxy')
+            .send(valueString)
+            .set('Content-Type', 'application/json')
+            .expect(function (res) {
+              assert(res.body === test.value);
+              scope.done();
+            })
+            .end(done);
+        }
+      );
+    });
+  });
+
 });

test/proxyReqOptDecorator.js

@@ -68,2 +68,3 @@ 'use strict';
             reqOpt.headers['user-agent'] = 'test user agent';
+            reqOpt.headers['content-type'] = 'multipart/form-data';
             assert(req instanceof http.IncomingMessage);
@@ -79,2 +80,3 @@ return reqOpt;
             assert.equal(res.body.headers['user-agent'], 'test user agent');
+            assert.equal(res.body.headers['content-type'], 'multipart/form-data');
             done();
@@ -81,0 +83,0 @@ });

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Improved metrics

Total package byte prevSize

136925

increased by18%

Number of package files

62

increased by5.08%

Lines of code

3000

increased by8.74%

Number of lines in readme file

634

increased by3.43%

Worsened metrics

Number of medium supply chain risk alerts

8

increased by14.29%

No dependency changes