svrjs/reverse-proxy-mod
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Activity Actions

Fixed server crashes with invalid HTTP/2 status codes

Browse source
This commit is contained in:
Dorian Niemiec 2023-09-04 13:37:33 +02:00
parent 6b24b28c3c
commit e6a016fa47
2 changed files with 22 additions and 18 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

22
index.js
View file

@ -42,7 +42,7 @@ Mod.prototype.callback = function callback(req, res, serverconsole, responseEnd,
if (!port) port = 80; if (!port) port = 80;
if (!securePort && secureHostname) securePort = 443; if (!securePort && secureHostname) securePort = 443;
if (!hostname) { if (!hostname) {
callServerError(500, "reverse-proxy-mod/1.1.1", new Error("Proxy server is misconfigured. Hostname property is missing.")); callServerError(500, "reverse-proxy-mod/1.1.2", new Error("Proxy server is misconfigured. Hostname property is missing."));
return; return;
} }
try { try {
@ -94,11 +94,11 @@ Mod.prototype.callback = function callback(req, res, serverconsole, responseEnd,
}).on("error", (ex) => { }).on("error", (ex) => {
try { try {
if (ex.code == "ENOTFOUND" || ex.code == "EHOSTUNREACH" || ex.code == "ECONNREFUSED") { if (ex.code == "ENOTFOUND" || ex.code == "EHOSTUNREACH" || ex.code == "ECONNREFUSED") {
callServerError(503, "reverse-proxy-mod/1.1.1", ex); //Server error callServerError(503, "reverse-proxy-mod/1.1.2", ex); //Server error
} else if (ex.code == "ETIMEDOUT") { } else if (ex.code == "ETIMEDOUT") {
callServerError(504, "reverse-proxy-mod/1.1.1", ex); //Server error callServerError(504, "reverse-proxy-mod/1.1.2", ex); //Server error
} else { } else {
callServerError(502, "reverse-proxy-mod/1.1.1", ex); //Server error callServerError(502, "reverse-proxy-mod/1.1.2", ex); //Server error
} }
} catch (ex) {} } catch (ex) {}
serverconsole.errmessage("Client fails to recieve content."); //Log into SVR.JS serverconsole.errmessage("Client fails to recieve content."); //Log into SVR.JS
@ -124,6 +124,7 @@ Mod.prototype.callback = function callback(req, res, serverconsole, responseEnd,
delete sres.headers["Transfer-Encoding"]; delete sres.headers["Transfer-Encoding"];
delete sres.headers["keep-alive"]; delete sres.headers["keep-alive"];
delete sres.headers["Keep-Alive"]; delete sres.headers["Keep-Alive"];
try {
res.writeHead(sres.statusCode, sres.headers); res.writeHead(sres.statusCode, sres.headers);
sres.pipe(res); sres.pipe(res);
res.prependListener("end", function () { res.prependListener("end", function () {
@ -131,15 +132,18 @@ Mod.prototype.callback = function callback(req, res, serverconsole, responseEnd,
sres.end(); sres.end();
} catch (ex) {} } catch (ex) {}
}); });
} catch (ex) {
callServerError(502, "reverse-proxy-mod/1.1.2", ex); //Server error
}
}); });
proxy.on("error", (ex) => { proxy.on("error", function (ex) {
try { try {
if (ex.code == "ENOTFOUND" || ex.code == "EHOSTUNREACH" || ex.code == "ECONNREFUSED") { if (ex.code == "ENOTFOUND" || ex.code == "EHOSTUNREACH" || ex.code == "ECONNREFUSED") {
callServerError(503, "reverse-proxy-mod/1.1.1", ex); //Server error callServerError(503, "reverse-proxy-mod/1.1.2", ex); //Server error
} else if (ex.code == "ETIMEDOUT") { } else if (ex.code == "ETIMEDOUT") {
callServerError(504, "reverse-proxy-mod/1.1.1", ex); //Server error callServerError(504, "reverse-proxy-mod/1.1.2", ex); //Server error
} else { } else {
callServerError(502, "reverse-proxy-mod/1.1.1", ex); //Server error callServerError(502, "reverse-proxy-mod/1.1.2", ex); //Server error
} }
} catch (ex) {} } catch (ex) {}
serverconsole.errmessage("Client fails to recieve content."); //Log into SVR.JS serverconsole.errmessage("Client fails to recieve content."); //Log into SVR.JS
@ -152,7 +156,7 @@ Mod.prototype.callback = function callback(req, res, serverconsole, responseEnd,
}); });
} }
} else if ((href == "/reverse-proxy-config.json" || (os.platform() == "win32" && href.toLowerCase() == "/reverse-proxy-config.json")) && path.normalize(__dirname + "/../../..") == process.cwd()) { } else if ((href == "/reverse-proxy-config.json" || (os.platform() == "win32" && href.toLowerCase() == "/reverse-proxy-config.json")) && path.normalize(__dirname + "/../../..") == process.cwd()) {
callServerError(403, "reverse-proxy-mod/1.1.1"); callServerError(403, "reverse-proxy-mod/1.1.2");
} else { } else {
elseCallback(); elseCallback();
} }

2
mod.info
View file

@ -1,4 +1,4 @@
{ {
"name": "Reverse proxy mod for SVR.JS 3.x", "name": "Reverse proxy mod for SVR.JS 3.x",
"version": "1.1.1" "version": "1.1.2"
} }