X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Fui-server%2FUIWebSocketServer.ts;h=be2961c522584172560a9736b15f6703f10599da;hb=852a4c5f07886502e278d44fda06efdfa8c711d8;hp=66980f610f08e86a4f111ded7db26a9bab7ec41e;hpb=02a6943a30a9a6c93e5dcbdb79aa8d9746ae368e;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 66980f61..be2961c5 100644 --- a/src/charging-station/ui-server/UIWebSocketServer.ts +++ b/src/charging-station/ui-server/UIWebSocketServer.ts @@ -28,18 +28,12 @@ export default class UIWebSocketServer extends AbstractUIServer { this.uiServices.set(version, UIServiceFactory.getUIServiceImplementation(version, this)); } // FIXME: check connection validity - socket.on('message', (messageData) => { + socket.on('message', (rawData) => { this.uiServices .get(version) - .requestHandler(messageData) - .catch((error) => { - logger.error( - `${this.logPrefix( - moduleName, - 'start.socket.onmessage' - )} Error while handling message:`, - error - ); + .requestHandler(rawData) + .catch(() => { + /* Error caught by AbstractUIService */ }); }); socket.on('error', (error) => { @@ -52,7 +46,7 @@ export default class UIWebSocketServer extends AbstractUIServer { } public stop(): void { - this.server.close(); + this.chargingStations.clear(); } public sendRequest(request: string): void { @@ -60,6 +54,7 @@ export default class UIWebSocketServer extends AbstractUIServer { } public sendResponse(response: string): void { + // TODO: send response only to the client that sent the request this.broadcastToClients(response); }