@nohost/router
Advanced tools
Comparing version 0.5.2 to 0.5.3
@@ -82,6 +82,8 @@ const http = require('http'); | ||
const restoreHeaders = (req) => { | ||
const restoreHeaders = (req, isRes) => { | ||
const { headers, rawHeaders } = req; | ||
headers[XFF] = getClientIp(req); | ||
headers[XWCP] = getClientPort(req); | ||
if (!isRes) { | ||
headers[XFF] = getClientIp(req); | ||
headers[XWCP] = getClientPort(req); | ||
} | ||
return formatHeaders(headers, rawHeaders && getRawHeaderNames(rawHeaders)); | ||
@@ -211,3 +213,3 @@ }; | ||
} | ||
res.writeHead(svrRes.statusCode, restoreHeaders(svrRes)); | ||
res.writeHead(svrRes.statusCode, restoreHeaders(svrRes, true)); | ||
svrRes.pipe(res); | ||
@@ -214,0 +216,0 @@ }); |
@@ -59,4 +59,5 @@ const crc32 = require('crc32'); | ||
const servers = workers._servers; | ||
delete headers[ENV_HEAD]; | ||
return proxyToNohost(servers[index++ % servers.totalLen], req, res); | ||
const i = index++ % servers.totalLen; | ||
headers[ENV_HEAD] = `${i}`; | ||
return proxyToNohost(servers[i], req, res); | ||
} | ||
@@ -63,0 +64,0 @@ |
{ | ||
"name": "@nohost/router", | ||
"version": "0.5.2", | ||
"version": "0.5.3", | ||
"description": "Nohost cluster router", | ||
@@ -5,0 +5,0 @@ "main": "lib/", |
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
14928
417