X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;ds=sidebyside;f=src%2Fcharging-station%2Focpp%2FOCPPServiceUtils.ts;h=33637c65a9e7501ea045cee9fd521863b27c1f0a;hb=aef5c03ddd1489b52df3801284d704342d60a41c;hp=ad78d347b965ddef05d06777388461cce61e6a2c;hpb=2329015067d5715c3eb0b56984a66cdc1fe31452;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/OCPPServiceUtils.ts b/src/charging-station/ocpp/OCPPServiceUtils.ts index ad78d347..33637c65 100644 --- a/src/charging-station/ocpp/OCPPServiceUtils.ts +++ b/src/charging-station/ocpp/OCPPServiceUtils.ts @@ -5,7 +5,7 @@ import type { SampledValueTemplate } from '../../types/MeasurandPerPhaseSampledV import { StandardParametersKey } from '../../types/ocpp/Configuration'; import { ErrorType } from '../../types/ocpp/ErrorType'; import { MeterValueMeasurand, type MeterValuePhase } from '../../types/ocpp/MeterValues'; -import { IncomingRequestCommand, RequestCommand } from '../../types/ocpp/Requests'; +import { IncomingRequestCommand, MessageTrigger, RequestCommand } from '../../types/ocpp/Requests'; import Constants from '../../utils/Constants'; import logger from '../../utils/Logger'; import Utils from '../../utils/Utils'; @@ -37,7 +37,7 @@ export class OCPPServiceUtils { chargingStation: ChargingStation, command: RequestCommand ): boolean { - const isRequestCommand = Object.values(RequestCommand).includes(command); + const isRequestCommand = Object.values(RequestCommand).includes(command); if ( isRequestCommand === true && !chargingStation.stationInfo?.commandsSupport?.outgoingCommands @@ -57,7 +57,8 @@ export class OCPPServiceUtils { chargingStation: ChargingStation, command: IncomingRequestCommand ): boolean { - const isIncomingRequestCommand = Object.values(IncomingRequestCommand).includes(command); + const isIncomingRequestCommand = + Object.values(IncomingRequestCommand).includes(command); if ( isIncomingRequestCommand === true && !chargingStation.stationInfo?.commandsSupport?.incomingCommands @@ -73,6 +74,36 @@ export class OCPPServiceUtils { return false; } + public static isMessageTriggerSupported( + chargingStation: ChargingStation, + messageTrigger: MessageTrigger + ): boolean { + const isMessageTrigger = Object.values(MessageTrigger).includes(messageTrigger); + if (isMessageTrigger === true && !chargingStation.stationInfo?.messageTriggerSupport) { + return true; + } else if (isMessageTrigger === true && chargingStation.stationInfo?.messageTriggerSupport) { + return chargingStation.stationInfo?.messageTriggerSupport[messageTrigger] ?? false; + } + logger.error( + `${chargingStation.logPrefix()} Unknown incoming OCPP message trigger '${messageTrigger}'` + ); + return false; + } + + public static isConnectorIdValid( + chargingStation: ChargingStation, + ocppCommand: IncomingRequestCommand, + connectorId: number + ): boolean { + if (connectorId < 0) { + logger.error( + `${chargingStation.logPrefix()} ${ocppCommand} incoming request received with invalid connector Id ${connectorId}` + ); + return false; + } + return true; + } + protected static getSampledValueTemplate( chargingStation: ChargingStation, connectorId: number, @@ -164,7 +195,8 @@ export class OCPPServiceUtils { ): number { options.limitationEnabled = options?.limitationEnabled ?? true; options.unitMultiplier = options?.unitMultiplier ?? 1; - const numberValue = isNaN(parseInt(value)) ? Infinity : parseInt(value); + const parsedInt = parseInt(value); + const numberValue = isNaN(parsedInt) ? Infinity : parsedInt; return options?.limitationEnabled ? Math.min(numberValue * options.unitMultiplier, limit) : numberValue * options.unitMultiplier;