X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FChargingStationWorkerBroadcastChannel.ts;h=6fd226fa326632d42ef251ae4e59707207c9590f;hb=f27eb751a2eb332306ecb9c5c4f0578d3bf66ee4;hp=9de2cfb2784dc75965403734ccb97b327d940bed;hpb=4eca248cf2d300b51dc45412766a821184a00dcb;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ChargingStationWorkerBroadcastChannel.ts b/src/charging-station/ChargingStationWorkerBroadcastChannel.ts index 9de2cfb2..6fd226fa 100644 --- a/src/charging-station/ChargingStationWorkerBroadcastChannel.ts +++ b/src/charging-station/ChargingStationWorkerBroadcastChannel.ts @@ -15,7 +15,7 @@ import { BroadcastChannelResponsePayload, MessageEvent, } from '../types/WorkerBroadcastChannel'; -import { ResponseStatus } from '../ui/web/src/type/UIProtocol'; +import { ResponseStatus } from '../ui/web/src/types/UIProtocol'; import logger from '../utils/Logger'; import type ChargingStation from './ChargingStation'; import WorkerBroadcastChannel from './WorkerBroadcastChannel'; @@ -38,9 +38,7 @@ export default class ChargingStationWorkerBroadcastChannel extends WorkerBroadca if (this.isResponse(messageEvent.data)) { return; } - if (Array.isArray(messageEvent.data) === false) { - throw new BaseError('Worker broadcast channel protocol request is not an array'); - } + this.validateMessageEvent(messageEvent); const [uuid, command, requestPayload] = messageEvent.data as BroadcastChannelRequest; @@ -67,9 +65,15 @@ export default class ChargingStationWorkerBroadcastChannel extends WorkerBroadca try { commandResponse = await this.commandHandler(command, requestPayload); if (commandResponse === undefined) { - responsePayload = { status: ResponseStatus.SUCCESS }; + responsePayload = { + hashId: this.chargingStation.hashId, + status: ResponseStatus.SUCCESS, + }; } else { - responsePayload = { status: this.commandResponseToResponseStatus(commandResponse) }; + responsePayload = { + hashId: this.chargingStation.hashId, + status: this.commandResponseToResponseStatus(commandResponse), + }; } } catch (error) { logger.error( @@ -77,6 +81,7 @@ export default class ChargingStationWorkerBroadcastChannel extends WorkerBroadca error ); responsePayload = { + hashId: this.chargingStation.hashId, status: ResponseStatus.FAILURE, command, requestPayload,