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
Apply dependencies update
[e-mobility-charging-stations-simulator.git]
/
src
/
charging-station
/
ChargingStationWorkerBroadcastChannel.ts
diff --git
a/src/charging-station/ChargingStationWorkerBroadcastChannel.ts
b/src/charging-station/ChargingStationWorkerBroadcastChannel.ts
index 08126286b15d5cbe6ed378e9c41045232347fb76..e36650bb3cb2ab1c4d2281e8bbd0dc2ac0cb7f63 100644
(file)
--- a/
src/charging-station/ChargingStationWorkerBroadcastChannel.ts
+++ b/
src/charging-station/ChargingStationWorkerBroadcastChannel.ts
@@
-34,21
+34,22
@@
type CommandResponse =
| StatusNotificationResponse
| HeartbeatResponse;
| StatusNotificationResponse
| HeartbeatResponse;
+type CommandHandler = (
+ requestPayload?: BroadcastChannelRequestPayload
+) => Promise<CommandResponse | void> | void;
+
export default class ChargingStationWorkerBroadcastChannel extends WorkerBroadcastChannel {
export default class ChargingStationWorkerBroadcastChannel extends WorkerBroadcastChannel {
- private readonly commandHandlers: Map<
- BroadcastChannelProcedureName,
- (requestPayload?: BroadcastChannelRequestPayload) => Promise<CommandResponse> | void
- >;
+ private readonly commandHandlers: Map<BroadcastChannelProcedureName, CommandHandler>;
private readonly chargingStation: ChargingStation;
constructor(chargingStation: ChargingStation) {
super();
private readonly chargingStation: ChargingStation;
constructor(chargingStation: ChargingStation) {
super();
- this.commandHandlers = new Map([
+ this.commandHandlers = new Map
<BroadcastChannelProcedureName, CommandHandler>
([
[BroadcastChannelProcedureName.START_CHARGING_STATION, () => this.chargingStation.start()],
[
BroadcastChannelProcedureName.STOP_CHARGING_STATION,
[BroadcastChannelProcedureName.START_CHARGING_STATION, () => this.chargingStation.start()],
[
BroadcastChannelProcedureName.STOP_CHARGING_STATION,
- async () =>
await
this.chargingStation.stop(),
+ async () => this.chargingStation.stop(),
],
[
BroadcastChannelProcedureName.OPEN_CONNECTION,
],
[
BroadcastChannelProcedureName.OPEN_CONNECTION,