X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Fui-server%2FUIWebSocketServer.ts;h=b28b6df76f4d33e85ab2cf82178a86addfc6e94c;hb=42371a2ed3ad187c91417fa759fd260ae86dee7c;hp=09842bf67ffae1432537f26c69daba87a1864e99;hpb=d972af76b6d7d1d2a099d254eacf45245b5316ac;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ui-server/UIWebSocketServer.ts b/src/charging-station/ui-server/UIWebSocketServer.ts index 09842bf6..b28b6df7 100644 --- a/src/charging-station/ui-server/UIWebSocketServer.ts +++ b/src/charging-station/ui-server/UIWebSocketServer.ts @@ -12,7 +12,15 @@ import { type UIServerConfiguration, WebSocketCloseEventStatusCode, } from '../../types'; -import { Constants, Utils, logger } from '../../utils'; +import { + Constants, + getWebSocketCloseEventStatusString, + isNotEmptyString, + isNullOrUndefined, + logPrefix, + logger, + validateUUID, +} from '../../utils'; const moduleName = 'UIWebSocketServer'; @@ -34,8 +42,8 @@ export class UIWebSocketServer extends AbstractUIServer { logger.error( `${this.logPrefix( moduleName, - 'start.server.onconnection' - )} Unsupported UI protocol version: '${ws.protocol}'` + 'start.server.onconnection', + )} Unsupported UI protocol version: '${ws.protocol}'`, ); ws.close(WebSocketCloseEventStatusCode.CLOSE_PROTOCOL_ERROR); } @@ -53,7 +61,7 @@ export class UIWebSocketServer extends AbstractUIServer { .get(version) ?.requestHandler(request) .then((protocolResponse: ProtocolResponse) => { - if (!Utils.isNullOrUndefined(protocolResponse)) { + if (!isNullOrUndefined(protocolResponse)) { this.sendResponse(protocolResponse); } }) @@ -66,10 +74,10 @@ export class UIWebSocketServer extends AbstractUIServer { logger.debug( `${this.logPrefix( moduleName, - 'start.ws.onclose' - )} WebSocket closed: '${Utils.getWebSocketCloseEventStatusString( - code - )}' - '${reason.toString()}'` + 'start.ws.onclose', + )} WebSocket closed: '${getWebSocketCloseEventStatusString( + code, + )}' - '${reason.toString()}'`, ); }); }); @@ -95,9 +103,9 @@ export class UIWebSocketServer extends AbstractUIServer { logger.error( `${this.logPrefix( moduleName, - 'start.httpServer.on.upgrade' + 'start.httpServer.on.upgrade', )} Error at handling connection upgrade:`, - error + error, ); } }); @@ -120,27 +128,25 @@ export class UIWebSocketServer extends AbstractUIServer { logger.error( `${this.logPrefix( moduleName, - 'sendResponse' - )} Error at sending response id '${responseId}', WebSocket is not open: ${ - ws?.readyState - }` + 'sendResponse', + )} Error at sending response id '${responseId}', WebSocket is not open: ${ws?.readyState}`, ); } } else { logger.error( `${this.logPrefix( moduleName, - 'sendResponse' - )} Response for unknown request id: ${responseId}` + 'sendResponse', + )} Response for unknown request id: ${responseId}`, ); } } catch (error) { logger.error( `${this.logPrefix( moduleName, - 'sendResponse' + 'sendResponse', )} Error at sending response id '${responseId}':`, - error + error, ); } finally { this.responseHandlers.delete(responseId); @@ -152,10 +158,10 @@ export class UIWebSocketServer extends AbstractUIServer { ? `UI WebSocket Server ${prefixSuffix}` : 'UI WebSocket Server'; const logMsg = - Utils.isNotEmptyString(modName) && Utils.isNotEmptyString(methodName) + isNotEmptyString(modName) && isNotEmptyString(methodName) ? ` ${logMsgPrefix} | ${modName}.${methodName}:` : ` ${logMsgPrefix} |`; - return Utils.logPrefix(logMsg); + return logPrefix(logMsg); }; private broadcastToClients(message: string): void { @@ -170,19 +176,21 @@ export class UIWebSocketServer extends AbstractUIServer { // logger.debug( // `${this.logPrefix( // moduleName, - // 'validateRawDataRequest' - // )} Raw data received in string format: ${rawData.toString()}` + // 'validateRawDataRequest', + // // eslint-disable-next-line @typescript-eslint/no-base-to-string + // )} Raw data received in string format: ${rawData.toString()}`, // ); + // eslint-disable-next-line @typescript-eslint/no-base-to-string const request = JSON.parse(rawData.toString()) as ProtocolRequest; if (Array.isArray(request) === false) { logger.error( `${this.logPrefix( moduleName, - 'validateRawDataRequest' + 'validateRawDataRequest', )} UI protocol request is not an array:`, - request + request, ); return false; } @@ -190,18 +198,18 @@ export class UIWebSocketServer extends AbstractUIServer { if (request.length !== 3) { logger.error( `${this.logPrefix(moduleName, 'validateRawDataRequest')} UI protocol request is malformed:`, - request + request, ); return false; } - if (Utils.validateUUID(request[0]) === false) { + if (validateUUID(request[0]) === false) { logger.error( `${this.logPrefix( moduleName, - 'validateRawDataRequest' + 'validateRawDataRequest', )} UI protocol request UUID field is invalid:`, - request + request, ); return false; }