DorianNiemiecSVRJS/svrjs
Archived
1
0
Fork 0
forked from svrjs/svrjs
Code Pull requests Activity

Clean up res.writeHead wraooer code

Browse source
This commit is contained in:
Dorian Niemiec 2023-12-12 22:37:23 +01:00
parent 5902dd52fc
commit 5950d326fe
1 changed files with 12 additions and 12 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

24
svr.js
View file

@ -2871,8 +2871,8 @@ if (!cluster.isPrimary) {
var headWritten = false; var headWritten = false;
var lastStatusCode = null; var lastStatusCode = null;
res.writeHeadNative = res.writeHead; res.writeHeadNative = res.writeHead;
res.writeHead = function (a, b, c) { res.writeHead = function (code, codeDescription, headers) {
if (!(headWritten && process.isBun && a === lastStatusCode && b === undefined && c === undefined)) { if (!(headWritten && process.isBun && code === lastStatusCode && codeDescription === undefined && codeDescription === undefined)) {
if (headWritten) { if (headWritten) {
process.emitWarning("res.writeHead called multiple times.", { process.emitWarning("res.writeHead called multiple times.", {
code: "WARN_SVRJS_MULTIPLE_WRITEHEAD" code: "WARN_SVRJS_MULTIPLE_WRITEHEAD"
@ -2881,20 +2881,20 @@ if (!cluster.isPrimary) {
} else { } else {
headWritten = true; headWritten = true;
} }
if(a >= 400 && a <= 499) err4xxcounter++; if (code >= 400 && code <= 499) err4xxcounter++;
if(a >= 500 && a <= 599) err5xxcounter++; if (code >= 500 && code <= 599) err5xxcounter++;
if (parseInt(a) >= 400 && parseInt(a) <= 599) { if (code >= 400 && code <= 599) {
serverconsole.errmessage("Server responded with " + a.toString() + " code."); serverconsole.errmessage("Server responded with " + code.toString() + " code.");
} else { } else {
serverconsole.resmessage("Server responded with " + a.toString() + " code."); serverconsole.resmessage("Server responded with " + code.toString() + " code.");
} }
if (typeof b != "string" && http.STATUS_CODES[a]) { if (typeof codeDescription != "string" && http.STATUS_CODES[code]) {
if (!c) c = b; if (!headers) headers = codeDescription;
b = http.STATUS_CODES[a]; codeDescription = http.STATUS_CODES[code];
} }
lastStatusCode = a; lastStatusCode = code;
} }
res.writeHeadNative(a, b, c); res.writeHeadNative(code, codeDescription, headers);
}; };
var finished = false; var finished = false;