repositories
/
e-mobility-charging-stations-simulator.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
UI Server: dedupe some code in helpers
[e-mobility-charging-stations-simulator.git]
/
src
/
charging-station
/
ui-server
/
UIWebSocketServer.ts
diff --git
a/src/charging-station/ui-server/UIWebSocketServer.ts
b/src/charging-station/ui-server/UIWebSocketServer.ts
index 66980f610f08e86a4f111ded7db26a9bab7ec41e..be2961c522584172560a9736b15f6703f10599da 100644
(file)
--- 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
this.uiServices.set(version, UIServiceFactory.getUIServiceImplementation(version, this));
}
// FIXME: check connection validity
- socket.on('message', (
message
Data) => {
+ socket.on('message', (
raw
Data) => {
this.uiServices
.get(version)
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) => {
});
});
socket.on('error', (error) => {
@@
-52,7
+46,7
@@
export default class UIWebSocketServer extends AbstractUIServer {
}
public stop(): void {
}
public stop(): void {
- this.
server.close
();
+ this.
chargingStations.clear
();
}
public sendRequest(request: string): void {
}
public sendRequest(request: string): void {
@@
-60,6
+54,7
@@
export default class UIWebSocketServer extends AbstractUIServer {
}
public sendResponse(response: string): void {
}
public sendResponse(response: string): void {
+ // TODO: send response only to the client that sent the request
this.broadcastToClients(response);
}
this.broadcastToClients(response);
}