X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Fui-server%2Fui-services%2FUIService001.ts;h=de7ba25736e60c6ebbc036d44259550cd7eb74b2;hb=d56ea27cd1c2e1df9317602551c443a720e1c7cb;hp=57c34c2239a6ee573d7462d5e57c96b1157f2cfc;hpb=10db00b2276f4cc7a88dd18e8f6f80593d6458b3;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ui-server/ui-services/UIService001.ts b/src/charging-station/ui-server/ui-services/UIService001.ts index 57c34c22..de7ba257 100644 --- a/src/charging-station/ui-server/ui-services/UIService001.ts +++ b/src/charging-station/ui-server/ui-services/UIService001.ts @@ -1,119 +1,21 @@ import { ProcedureName, - ProtocolRequestHandler, + type ProtocolRequestHandler, ProtocolVersion, - RequestPayload, } from '../../../types/UIProtocol'; -import { BroadcastChannelProcedureName } from '../../../types/WorkerBroadcastChannel'; import type { AbstractUIServer } from '../AbstractUIServer'; import AbstractUIService from './AbstractUIService'; export default class UIService001 extends AbstractUIService { constructor(uiServer: AbstractUIServer) { super(uiServer, ProtocolVersion['0.0.1']); - this.requestHandlers.set( - ProcedureName.START_CHARGING_STATION, - this.handleStartChargingStation.bind(this) as ProtocolRequestHandler - ); - this.requestHandlers.set( - ProcedureName.STOP_CHARGING_STATION, - this.handleStopChargingStation.bind(this) as ProtocolRequestHandler - ); - this.requestHandlers.set( - ProcedureName.OPEN_CONNECTION, - this.handleOpenConnection.bind(this) as ProtocolRequestHandler - ); - this.requestHandlers.set( - ProcedureName.CLOSE_CONNECTION, - this.handleCloseConnection.bind(this) as ProtocolRequestHandler - ); - this.requestHandlers.set( - ProcedureName.START_TRANSACTION, - this.handleStartTransaction.bind(this) as ProtocolRequestHandler - ); - this.requestHandlers.set( - ProcedureName.STOP_TRANSACTION, - this.handleStopTransaction.bind(this) as ProtocolRequestHandler - ); - this.requestHandlers.set( - ProcedureName.START_AUTOMATIC_TRANSACTION_GENERATOR, - this.handleStartAutomaticTransactionGenerator.bind(this) as ProtocolRequestHandler - ); - this.requestHandlers.set( - ProcedureName.STOP_AUTOMATIC_TRANSACTION_GENERATOR, - this.handleStopAutomaticTransactionGenerator.bind(this) as ProtocolRequestHandler - ); - this.requestHandlers.set( - ProcedureName.STATUS_NOTIFICATION, - this.handleStatusNotification.bind(this) as ProtocolRequestHandler - ); - this.requestHandlers.set( - ProcedureName.HEARTBEAT, - this.handleHeartbeat.bind(this) as ProtocolRequestHandler - ); - } - - private handleStartChargingStation(uuid: string, payload: RequestPayload): void { - this.sendBroadcastChannelRequest( - uuid, - BroadcastChannelProcedureName.START_CHARGING_STATION, - payload - ); - } - - private handleStopChargingStation(uuid: string, payload: RequestPayload): void { - this.sendBroadcastChannelRequest( - uuid, - BroadcastChannelProcedureName.STOP_CHARGING_STATION, - payload - ); - } - - private handleOpenConnection(uuid: string, payload: RequestPayload): void { - this.sendBroadcastChannelRequest(uuid, BroadcastChannelProcedureName.OPEN_CONNECTION, payload); - } - - private handleCloseConnection(uuid: string, payload: RequestPayload): void { - this.sendBroadcastChannelRequest(uuid, BroadcastChannelProcedureName.CLOSE_CONNECTION, payload); - } - - private handleStartTransaction(uuid: string, payload: RequestPayload): void { - this.sendBroadcastChannelRequest( - uuid, - BroadcastChannelProcedureName.START_TRANSACTION, - payload - ); - } - - private handleStopTransaction(uuid: string, payload: RequestPayload): void { - this.sendBroadcastChannelRequest(uuid, BroadcastChannelProcedureName.STOP_TRANSACTION, payload); - } - - private handleStartAutomaticTransactionGenerator(uuid: string, payload: RequestPayload): void { - this.sendBroadcastChannelRequest( - uuid, - BroadcastChannelProcedureName.START_AUTOMATIC_TRANSACTION_GENERATOR, - payload - ); - } - - private handleStopAutomaticTransactionGenerator(uuid: string, payload: RequestPayload): void { - this.sendBroadcastChannelRequest( - uuid, - BroadcastChannelProcedureName.STOP_AUTOMATIC_TRANSACTION_GENERATOR, - payload - ); - } - - private handleStatusNotification(uuid: string, payload: RequestPayload): void { - this.sendBroadcastChannelRequest( - uuid, - BroadcastChannelProcedureName.STATUS_NOTIFICATION, - payload - ); - } - - private handleHeartbeat(uuid: string, payload: RequestPayload): void { - this.sendBroadcastChannelRequest(uuid, BroadcastChannelProcedureName.HEARTBEAT, payload); + for (const procedureName of Object.keys( + AbstractUIService.ProcedureNameToBroadCastChannelProcedureNameMap + ) as ProcedureName[]) { + this.requestHandlers.set( + procedureName, + this.handleProtocolRequest.bind(this) as ProtocolRequestHandler + ); + } } }