archive-gh-me/node-http-proxy
1
0
Fork 0
mirror of https://github.com/http-party/node-http-proxy.git synced 2025-12-08 20:59:18 +00:00
Code Issues Projects Releases Wiki Activity

[examples] Restream body before proxying, support for Content-Type of application/x-www-form-urlencoded (#1264)

Browse Source
This commit is contained in:
任侠 2018-06-07 00:39:50 +08:00 committed by Jarrett Cruger
parent 42e8e1e099
commit a3fe02d651
1 changed files with 17 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
examples/middleware/bodyDecoder-middleware.js
View File

@ -29,6 +29,7 @@ var http = require('http'),
request = require('request'), request = require('request'),
colors = require('colors'), colors = require('colors'),
util = require('util'), util = require('util'),
queryString = require('querystring'),
bodyParser = require('body-parser'), bodyParser = require('body-parser'),
httpProxy = require('../../lib/http-proxy'), httpProxy = require('../../lib/http-proxy'),
proxy = httpProxy.createProxyServer({}); proxy = httpProxy.createProxyServer({});
@ -36,12 +37,23 @@ var http = require('http'),
//restream parsed body before proxying //restream parsed body before proxying
proxy.on('proxyReq', function(proxyReq, req, res, options) { proxy.on('proxyReq', function(proxyReq, req, res, options) {
if(req.body) { if (!req.body || !Object.keys(req.body).length) {
let bodyData = JSON.stringify(req.body); return;
// incase if content-type is application/x-www-form-urlencoded -> we need to change to application/json }
proxyReq.setHeader('Content-Type','application/json');
var contentType = proxyReq.getHeader('Content-Type');
var bodyData;
if (contentType === 'application/json') {
bodyData = JSON.stringify(req.body);
}
if (contentType === 'application/x-www-form-urlencoded') {
bodyData = queryString.stringify(req.body);
}
if (bodyData) {
proxyReq.setHeader('Content-Length', Buffer.byteLength(bodyData)); proxyReq.setHeader('Content-Length', Buffer.byteLength(bodyData));
// stream the content
proxyReq.write(bodyData); proxyReq.write(bodyData);
} }
}); });
@ -94,5 +106,3 @@ http.createServer(app1).listen(9013, function(){
console.log('return for urlencoded request:' ,err, data) console.log('return for urlencoded request:' ,err, data)
}) })
}); });