470486104/Server
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Further cleanup of sendResponse()

Browse Source
This commit is contained in:
Dev 2024-10-08 22:35:45 +01:00
parent f76ffc8f93
commit 50c2c55837
1 changed files with 33 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

45
project/src/servers/http/SptHttpListener.ts
View File

@ -92,21 +92,42 @@ export class SptHttpListener implements IHttpListener {
): void {
const bodyInfo = this.getBodyInfo(body);
// Check if this is a debug request, send only raw response without transformation
if (req.headers.responsecompressed === "0") {
if (this.isDebugRequest(req)) {
// Send only raw response without transformation
this.sendJson(resp, output, sessionID);
} else {
// Not debug, minority of requests need a serializer to do the job (IMAGE/BUNDLE/NOTIFY)
const serialiser = this.serializers.find((x) => x.canHandle(output));
if (serialiser) {
serialiser.serialize(sessionID, req, resp, bodyInfo);
} else {
// No serializer can handle the request (majority of requests dont), zlib the output and send response back
this.sendZlibJson(resp, output, sessionID);
}
this.logRequest(req, output);
return;
}
// Log request if enabled
// Not debug, minority of requests need a serializer to do the job (IMAGE/BUNDLE/NOTIFY)
const serialiser = this.serializers.find((x) => x.canHandle(output));
if (serialiser) {
serialiser.serialize(sessionID, req, resp, bodyInfo);
} else {
// No serializer can handle the request (majority of requests dont), zlib the output and send response back
this.sendZlibJson(resp, output, sessionID);
}
this.logRequest(req, output);
}
/**
* Is request flagged as debug enabled
* @param req Incoming request
* @returns True if request is flagged as debug
*/
protected isDebugRequest(req: IncomingMessage): boolean {
return req.headers.responsecompressed === "0";
}
/**
* Log request if enabled
* @param req Incoming message request
* @param output Output string
*/
protected logRequest(req: IncomingMessage, output: string): void {
//
if (globalThis.G_LOG_REQUESTS) {
const log = new Response(req.method, output);
this.requestsLogger.info(`RESPONSE=${this.jsonUtil.serialize(log)}`);