forked from svrjs/svrjs
Remove try/catch block in HTTP/1.x compatibility shim; errors there are non-existent
This commit is contained in:
parent
8ac546ff67
commit
9f8b0f4fe3
1 changed files with 40 additions and 50 deletions
90
svr.js
90
svr.js
|
@ -2918,58 +2918,48 @@ if (!cluster.isPrimary) {
|
|||
|
||||
// Make HTTP/1.x API-based scripts compatible with HTTP/2.0 API
|
||||
if (configJSON.enableHTTP2 == true && req.httpVersion == "2.0") {
|
||||
try {
|
||||
// Set HTTP/1.x methods (to prevent process warnings)
|
||||
res.writeHeadNodeApi = res.writeHead;
|
||||
res.setHeaderNodeApi = res.setHeader;
|
||||
// Set HTTP/1.x methods (to prevent process warnings)
|
||||
res.writeHeadNodeApi = res.writeHead;
|
||||
res.setHeaderNodeApi = res.setHeader;
|
||||
|
||||
res.writeHead = function (a, b, c) {
|
||||
var table = c;
|
||||
if (typeof (b) == "object") table = b;
|
||||
if (table == undefined) table = this.tHeaders;
|
||||
table = JSON.parse(JSON.stringify(table));
|
||||
if (table["content-type"] != undefined && table["Content-Type"] != undefined) {
|
||||
delete table["content-type"];
|
||||
}
|
||||
delete table["transfer-encoding"];
|
||||
delete table["connection"];
|
||||
delete table["keep-alive"];
|
||||
delete table["upgrade"];
|
||||
if (res.stream && res.stream.destroyed) {
|
||||
return false;
|
||||
} else {
|
||||
return res.writeHeadNodeApi(a, table);
|
||||
}
|
||||
};
|
||||
res.setHeader = function (headerName, headerValue) {
|
||||
var al = headerName.toLowerCase();
|
||||
if (al != "transfer-encoding" && al != "connection" && al != "keep-alive" && al != "upgrade") return res.setHeaderNodeApi(headerName, headerValue);
|
||||
return false;
|
||||
};
|
||||
|
||||
// Set HTTP/1.x headers
|
||||
if (!req.headers.host) req.headers.host = req.headers[":authority"];
|
||||
(req.headers[":path"] == undefined ? (function () {})() : req.url = req.headers[":path"]);
|
||||
req.protocol = req.headers[":scheme"];
|
||||
var headers = [":path", ":method"];
|
||||
for (var i = 0; i < headers.length; i++) {
|
||||
if (req.headers[headers[i]] == undefined) {
|
||||
var cheaders = getCustomHeaders();
|
||||
cheaders["Content-Type"] = "text/html; charset=utf-8";
|
||||
res.writeHead(400, "Bad Request", cheaders);
|
||||
res.write("<html><head><title>400 Bad Request</title><meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0\" /></head><body><h1>400 Bad Request</h1><p>The request you sent is invalid. <p><i>" + (exposeServerVersion ? "SVR.JS/" + version + " (" + getOS() + "; " + (process.isBun ? ("Bun/v" + process.versions.bun + "; like Node.JS/" + process.version) : ("Node.JS/" + process.version)) + ")" : "SVR.JS").replace(/&/g, "&").replace(/</g, "<").replace(/>/g, ">") + (req.headers[":authority"] == undefined ? "" : " on " + req.headers[":authority"]) + "</i></p></body></html>");
|
||||
res.end();
|
||||
return;
|
||||
}
|
||||
res.writeHead = function (a, b, c) {
|
||||
var table = c;
|
||||
if (typeof (b) == "object") table = b;
|
||||
if (table == undefined) table = this.tHeaders;
|
||||
table = JSON.parse(JSON.stringify(table));
|
||||
if (table["content-type"] != undefined && table["Content-Type"] != undefined) {
|
||||
delete table["content-type"];
|
||||
}
|
||||
delete table["transfer-encoding"];
|
||||
delete table["connection"];
|
||||
delete table["keep-alive"];
|
||||
delete table["upgrade"];
|
||||
if (res.stream && res.stream.destroyed) {
|
||||
return false;
|
||||
} else {
|
||||
return res.writeHeadNodeApi(a, table);
|
||||
}
|
||||
};
|
||||
res.setHeader = function (headerName, headerValue) {
|
||||
var al = headerName.toLowerCase();
|
||||
if (al != "transfer-encoding" && al != "connection" && al != "keep-alive" && al != "upgrade") return res.setHeaderNodeApi(headerName, headerValue);
|
||||
return false;
|
||||
};
|
||||
|
||||
// Set HTTP/1.x headers
|
||||
if (!req.headers.host) req.headers.host = req.headers[":authority"];
|
||||
(req.headers[":path"] == undefined ? (function () {})() : req.url = req.headers[":path"]);
|
||||
req.protocol = req.headers[":scheme"];
|
||||
var headers = [":path", ":method"];
|
||||
for (var i = 0; i < headers.length; i++) {
|
||||
if (req.headers[headers[i]] == undefined) {
|
||||
var cheaders = getCustomHeaders();
|
||||
cheaders["Content-Type"] = "text/html; charset=utf-8";
|
||||
res.writeHead(400, "Bad Request", cheaders);
|
||||
res.write("<html><head><title>400 Bad Request</title><meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0\" /></head><body><h1>400 Bad Request</h1><p>The request you sent is invalid. <p><i>" + (exposeServerVersion ? "SVR.JS/" + version + " (" + getOS() + "; " + (process.isBun ? ("Bun/v" + process.versions.bun + "; like Node.JS/" + process.version) : ("Node.JS/" + process.version)) + ")" : "SVR.JS").replace(/&/g, "&").replace(/</g, "<").replace(/>/g, ">") + (req.headers[":authority"] == undefined ? "" : " on " + req.headers[":authority"]) + "</i></p></body></html>");
|
||||
res.end();
|
||||
return;
|
||||
}
|
||||
} catch (err) {
|
||||
var cheaders = getCustomHeaders();
|
||||
cheaders["Content-Type"] = "text/html; charset=utf-8";
|
||||
cheaders[":status"] = "500";
|
||||
res.stream.respond(cheaders);
|
||||
res.stream.write("<html><head><title>500 Internal Server Error</title><meta name=\"viewport\" content=\"width=device-width, initial-scale=1.0\" /></head><body><h1>500 Internal Server Error</h1><p>The server had an unexpected error. Below, error stack is shown: </p><code>" + (stackHidden ? "[error stack hidden]" : generateErrorStack(err)).replace(/\r\n/g, "<br/>").replace(/\n/g, "<br/>").replace(/\r/g, "<br/>").replace(/ {2}/g, " ") + "</code><p>Please contact with developer/administrator of the website.</p><p><i>" + (exposeServerVersion ? "SVR.JS/" + version + " (" + getOS() + "; " + (process.isBun ? ("Bun/v" + process.versions.bun + "; like Node.JS/" + process.version) : ("Node.JS/" + process.version)) + ")" : "SVR.JS").replace(/&/g, "&").replace(/</g, "<").replace(/>/g, ">") + (req.headers[":authority"] == undefined ? "" : " on " + req.headers[":authority"]) + "</i></p></body></html>");
|
||||
res.stream.end();
|
||||
return;
|
||||
}
|
||||
}
|
||||
|
||||
|
|
Reference in a new issue