X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Focpp%2F1.6%2FOCPP16ResponseService.ts;h=e6c3b43472c8ef0975f3e855deebf51b7c013919;hb=a9671b9e315a2807c2659fdda962203229d35c0a;hp=543e2eda6e84e0a98dc8862c25c36c3d92b2dd93;hpb=66dd344779f5258bbf4c76b386d005c0c2160b11;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ocpp/1.6/OCPP16ResponseService.ts b/src/charging-station/ocpp/1.6/OCPP16ResponseService.ts index 543e2eda..e6c3b434 100644 --- a/src/charging-station/ocpp/1.6/OCPP16ResponseService.ts +++ b/src/charging-station/ocpp/1.6/OCPP16ResponseService.ts @@ -1,32 +1,30 @@ -// Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved. +// Partial Copyright Jerome Benoit. 2021-2024. All Rights Reserved. -import { parentPort } from 'node:worker_threads'; +import type { ValidateFunction } from 'ajv' +import { secondsToMilliseconds } from 'date-fns' -import type { JSONSchemaType } from 'ajv'; - -import { OCPP16ServiceUtils } from './OCPP16ServiceUtils'; import { + addConfigurationKey, type ChargingStation, - ChargingStationConfigurationUtils, - ChargingStationUtils, -} from '../../../charging-station'; -import { OCPPError } from '../../../exception'; + getConfigurationKey, + hasReservationExpired, + resetConnectorStatus +} from '../../../charging-station/index.js' +import { OCPPError } from '../../../exception/index.js' import { - type ChangeAvailabilityResponse, type ChangeConfigurationResponse, - type ClearChargingProfileResponse, ErrorType, type GenericResponse, type GetConfigurationResponse, type GetDiagnosticsResponse, - type JsonObject, type JsonType, OCPP16AuthorizationStatus, type OCPP16AuthorizeRequest, type OCPP16AuthorizeResponse, type OCPP16BootNotificationResponse, - type OCPP16CancelReservationResponse, + type OCPP16ChangeAvailabilityResponse, OCPP16ChargePointStatus, + type OCPP16ClearChargingProfileResponse, type OCPP16DataTransferResponse, type OCPP16DiagnosticsStatusNotificationResponse, type OCPP16FirmwareStatusNotificationResponse, @@ -47,387 +45,515 @@ import { type OCPP16UpdateFirmwareResponse, OCPPVersion, RegistrationStatusEnumType, + ReservationTerminationReason, type ResponseHandler, type SetChargingProfileResponse, - type UnlockConnectorResponse, -} from '../../../types'; -import { Constants, MessageChannelUtils, Utils, logger } from '../../../utils'; -import { OCPPResponseService } from '../OCPPResponseService'; + type UnlockConnectorResponse +} from '../../../types/index.js' +import { Constants, convertToInt, isAsyncFunction, logger } from '../../../utils/index.js' +import { OCPPResponseService } from '../OCPPResponseService.js' +import { OCPP16ServiceUtils } from './OCPP16ServiceUtils.js' -const moduleName = 'OCPP16ResponseService'; +const moduleName = 'OCPP16ResponseService' export class OCPP16ResponseService extends OCPPResponseService { - public jsonIncomingRequestResponseSchemas: Map< - OCPP16IncomingRequestCommand, - JSONSchemaType - >; + public incomingRequestResponsePayloadValidateFunctions: Map< + OCPP16IncomingRequestCommand, + ValidateFunction + > - private responseHandlers: Map; - private jsonSchemas: Map>; + protected payloadValidateFunctions: Map> + private readonly responseHandlers: Map - public constructor() { - // if (new.target?.name === moduleName) { - // throw new TypeError(`Cannot construct ${new.target?.name} instances directly`); + public constructor () { + // if (new.target.name === moduleName) { + // throw new TypeError(`Cannot construct ${new.target.name} instances directly`) // } - super(OCPPVersion.VERSION_16); + super(OCPPVersion.VERSION_16) this.responseHandlers = new Map([ - [OCPP16RequestCommand.BOOT_NOTIFICATION, this.handleResponseBootNotification.bind(this)], - [OCPP16RequestCommand.HEARTBEAT, this.emptyResponseHandler.bind(this)], - [OCPP16RequestCommand.AUTHORIZE, this.handleResponseAuthorize.bind(this)], - [OCPP16RequestCommand.START_TRANSACTION, this.handleResponseStartTransaction.bind(this)], - [OCPP16RequestCommand.STOP_TRANSACTION, this.handleResponseStopTransaction.bind(this)], - [OCPP16RequestCommand.STATUS_NOTIFICATION, this.emptyResponseHandler.bind(this)], - [OCPP16RequestCommand.METER_VALUES, this.emptyResponseHandler.bind(this)], - [OCPP16RequestCommand.DIAGNOSTICS_STATUS_NOTIFICATION, this.emptyResponseHandler.bind(this)], - [OCPP16RequestCommand.DATA_TRANSFER, this.emptyResponseHandler.bind(this)], - [OCPP16RequestCommand.FIRMWARE_STATUS_NOTIFICATION, this.emptyResponseHandler.bind(this)], - ]); - this.jsonSchemas = new Map>([ [ OCPP16RequestCommand.BOOT_NOTIFICATION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/BootNotificationResponse.json', - moduleName, - 'constructor' - ), + this.handleResponseBootNotification.bind(this) as ResponseHandler + ], + [OCPP16RequestCommand.HEARTBEAT, this.emptyResponseHandler], + [OCPP16RequestCommand.AUTHORIZE, this.handleResponseAuthorize.bind(this) as ResponseHandler], + [ + OCPP16RequestCommand.START_TRANSACTION, + this.handleResponseStartTransaction.bind(this) as ResponseHandler + ], + [ + OCPP16RequestCommand.STOP_TRANSACTION, + this.handleResponseStopTransaction.bind(this) as ResponseHandler + ], + [ + OCPP16RequestCommand.STATUS_NOTIFICATION, + this.emptyResponseHandler.bind(this) as ResponseHandler + ], + [OCPP16RequestCommand.METER_VALUES, this.emptyResponseHandler], + [ + OCPP16RequestCommand.DIAGNOSTICS_STATUS_NOTIFICATION, + this.emptyResponseHandler.bind(this) as ResponseHandler + ], + [OCPP16RequestCommand.DATA_TRANSFER, this.emptyResponseHandler], + [OCPP16RequestCommand.FIRMWARE_STATUS_NOTIFICATION, this.emptyResponseHandler] + ]) + this.payloadValidateFunctions = new Map>([ + [ + OCPP16RequestCommand.BOOT_NOTIFICATION, + this.ajv + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/BootNotificationResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16RequestCommand.HEARTBEAT, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/HeartbeatResponse.json', - moduleName, - 'constructor' - ), + this.ajv + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/HeartbeatResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16RequestCommand.AUTHORIZE, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/AuthorizeResponse.json', - moduleName, - 'constructor' - ), + this.ajv + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/AuthorizeResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16RequestCommand.START_TRANSACTION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/StartTransactionResponse.json', - moduleName, - 'constructor' - ), + this.ajv + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/StartTransactionResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16RequestCommand.STOP_TRANSACTION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/StopTransactionResponse.json', - moduleName, - 'constructor' - ), + this.ajv + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/StopTransactionResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16RequestCommand.STATUS_NOTIFICATION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/StatusNotificationResponse.json', - moduleName, - 'constructor' - ), + this.ajv + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/StatusNotificationResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16RequestCommand.METER_VALUES, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/MeterValuesResponse.json', - moduleName, - 'constructor' - ), + this.ajv + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/MeterValuesResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16RequestCommand.DIAGNOSTICS_STATUS_NOTIFICATION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/DiagnosticsStatusNotificationResponse.json', - moduleName, - 'constructor' - ), + this.ajv + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/DiagnosticsStatusNotificationResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16RequestCommand.DATA_TRANSFER, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/DataTransferResponse.json', - moduleName, - 'constructor' - ), + this.ajv + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/DataTransferResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16RequestCommand.FIRMWARE_STATUS_NOTIFICATION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/FirmwareStatusNotificationResponse.json', - moduleName, - 'constructor' - ), - ], - [ - OCPP16RequestCommand.RESERVE_NOW, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/ReserveNowResponse.json', - moduleName, - 'constructor' - ), - ], - [ - OCPP16RequestCommand.CANCEL_RESERVATION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/CancelReservationResponse.json', - moduleName, - 'constructor' - ), - ], - ]); - this.jsonIncomingRequestResponseSchemas = new Map([ + this.ajv + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/FirmwareStatusNotificationResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) + ] + ]) + this.incomingRequestResponsePayloadValidateFunctions = new Map< + OCPP16IncomingRequestCommand, + ValidateFunction + >([ [ OCPP16IncomingRequestCommand.RESET, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/ResetResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/ResetResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.CLEAR_CACHE, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/ClearCacheResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/ClearCacheResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.CHANGE_AVAILABILITY, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/ChangeAvailabilityResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/ChangeAvailabilityResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.UNLOCK_CONNECTOR, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/UnlockConnectorResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/UnlockConnectorResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.GET_CONFIGURATION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/GetConfigurationResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/GetConfigurationResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.CHANGE_CONFIGURATION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/ChangeConfigurationResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/ChangeConfigurationResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.GET_COMPOSITE_SCHEDULE, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/GetCompositeScheduleResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/GetCompositeScheduleResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.SET_CHARGING_PROFILE, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/SetChargingProfileResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/SetChargingProfileResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.CLEAR_CHARGING_PROFILE, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/ClearChargingProfileResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/ClearChargingProfileResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.REMOTE_START_TRANSACTION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/RemoteStartTransactionResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/RemoteStartTransactionResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.REMOTE_STOP_TRANSACTION, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/RemoteStopTransactionResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/RemoteStopTransactionResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.GET_DIAGNOSTICS, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/GetDiagnosticsResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/GetDiagnosticsResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.TRIGGER_MESSAGE, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/TriggerMessageResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/TriggerMessageResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.DATA_TRANSFER, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/DataTransferResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/DataTransferResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], [ OCPP16IncomingRequestCommand.UPDATE_FIRMWARE, - OCPP16ServiceUtils.parseJsonSchemaFile( - 'assets/json-schemas/ocpp/1.6/UpdateFirmwareResponse.json', - moduleName, - 'constructor' - ), + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/UpdateFirmwareResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) ], - ]); - this.validatePayload = this.validatePayload.bind(this) as ( - chargingStation: ChargingStation, - commandName: OCPP16RequestCommand, - payload: JsonType - ) => boolean; + [ + OCPP16IncomingRequestCommand.RESERVE_NOW, + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/ReserveNowResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) + ], + [ + OCPP16IncomingRequestCommand.CANCEL_RESERVATION, + this.ajvIncomingRequest + .compile( + OCPP16ServiceUtils.parseJsonSchemaFile( + 'assets/json-schemas/ocpp/1.6/CancelReservationResponse.json', + moduleName, + 'constructor' + ) + ) + .bind(this) + ] + ]) + this.validatePayload = this.validatePayload.bind(this) } - public async responseHandler( + public async responseHandler( chargingStation: ChargingStation, commandName: OCPP16RequestCommand, - payload: JsonType, - requestPayload: JsonType + payload: ResType, + requestPayload: ReqType ): Promise { - if ( - chargingStation.isRegistered() === true || - commandName === OCPP16RequestCommand.BOOT_NOTIFICATION - ) { + if (chargingStation.isRegistered() || commandName === OCPP16RequestCommand.BOOT_NOTIFICATION) { if ( - this.responseHandlers.has(commandName) === true && - OCPP16ServiceUtils.isRequestCommandSupported(chargingStation, commandName) === true + this.responseHandlers.has(commandName) && + OCPP16ServiceUtils.isRequestCommandSupported(chargingStation, commandName) ) { try { - this.validatePayload(chargingStation, commandName, payload); - await this.responseHandlers.get(commandName)(chargingStation, payload, requestPayload); + this.validatePayload(chargingStation, commandName, payload) + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + const responseHandler = this.responseHandlers.get(commandName)! + if (isAsyncFunction(responseHandler)) { + await responseHandler(chargingStation, payload, requestPayload) + } else { + ( + responseHandler as ( + chargingStation: ChargingStation, + payload: JsonType, + requestPayload?: JsonType + ) => void + )(chargingStation, payload, requestPayload) + } } catch (error) { logger.error( `${chargingStation.logPrefix()} ${moduleName}.responseHandler: Handle response error:`, error - ); - throw error; + ) + throw error } } else { // Throw exception throw new OCPPError( ErrorType.NOT_IMPLEMENTED, - `${commandName} is not implemented to handle response PDU ${JSON.stringify( + `'${commandName}' is not implemented to handle response PDU ${JSON.stringify( payload, - null, + undefined, 2 )}`, commandName, payload - ); + ) } } else { throw new OCPPError( ErrorType.SECURITY_ERROR, `${commandName} cannot be issued to handle response PDU ${JSON.stringify( payload, - null, + undefined, 2 - )} while the charging station is not registered on the central server.`, + )} while the charging station is not registered on the central server`, commandName, payload - ); + ) } } - private validatePayload( + private validatePayload ( chargingStation: ChargingStation, commandName: OCPP16RequestCommand, payload: JsonType ): boolean { - if (this.jsonSchemas.has(commandName) === true) { - return this.validateResponsePayload( - chargingStation, - commandName, - this.jsonSchemas.get(commandName), - payload - ); + if (this.payloadValidateFunctions.has(commandName)) { + return this.validateResponsePayload(chargingStation, commandName, payload) } logger.warn( - `${chargingStation.logPrefix()} ${moduleName}.validatePayload: No JSON schema found for command '${commandName}' PDU validation` - ); - return false; + `${chargingStation.logPrefix()} ${moduleName}.validatePayload: No JSON schema validation function found for command '${commandName}' PDU validation` + ) + return false } - private handleResponseBootNotification( + private handleResponseBootNotification ( chargingStation: ChargingStation, payload: OCPP16BootNotificationResponse ): void { if (payload.status === RegistrationStatusEnumType.ACCEPTED) { - ChargingStationConfigurationUtils.addConfigurationKey( + addConfigurationKey( chargingStation, OCPP16StandardParametersKey.HeartbeatInterval, payload.interval.toString(), {}, { overwrite: true, save: true } - ); - ChargingStationConfigurationUtils.addConfigurationKey( + ) + addConfigurationKey( chargingStation, OCPP16StandardParametersKey.HeartBeatInterval, payload.interval.toString(), { visible: false }, { overwrite: true, save: true } - ); - OCPP16ServiceUtils.startHeartbeatInterval(chargingStation, payload.interval); + ) + OCPP16ServiceUtils.startHeartbeatInterval(chargingStation, payload.interval) } if (Object.values(RegistrationStatusEnumType).includes(payload.status)) { const logMsg = `${chargingStation.logPrefix()} Charging station in '${ payload.status - }' state on the central server`; + }' state on the central server` payload.status === RegistrationStatusEnumType.REJECTED ? logger.warn(logMsg) - : logger.info(logMsg); + : logger.info(logMsg) } else { logger.error( `${chargingStation.logPrefix()} Charging station boot notification response received: %j with undefined registration status`, payload - ); + ) } } - private handleResponseAuthorize( + private handleResponseAuthorize ( chargingStation: ChargingStation, payload: OCPP16AuthorizeResponse, requestPayload: OCPP16AuthorizeRequest ): void { - let authorizeConnectorId: number; + let authorizeConnectorId: number | undefined if (chargingStation.hasEvses) { for (const [evseId, evseStatus] of chargingStation.evses) { if (evseId > 0) { for (const [connectorId, connectorStatus] of evseStatus.connectors) { - if (connectorStatus?.authorizeIdTag === requestPayload.idTag) { - authorizeConnectorId = connectorId; - break; + if (connectorStatus.authorizeIdTag === requestPayload.idTag) { + authorizeConnectorId = connectorId + break } } } @@ -438,259 +564,286 @@ export class OCPP16ResponseService extends OCPPResponseService { connectorId > 0 && chargingStation.getConnectorStatus(connectorId)?.authorizeIdTag === requestPayload.idTag ) { - authorizeConnectorId = connectorId; - break; + authorizeConnectorId = connectorId + break } } } - const authorizeConnectorIdDefined = !Utils.isNullOrUndefined(authorizeConnectorId); - if (payload.idTagInfo.status === OCPP16AuthorizationStatus.ACCEPTED) { - authorizeConnectorIdDefined && - (chargingStation.getConnectorStatus(authorizeConnectorId).idTagAuthorized = true); - logger.debug( - `${chargingStation.logPrefix()} idTag '${requestPayload.idTag}' accepted${ - authorizeConnectorIdDefined ? ` on connector id ${authorizeConnectorId}` : '' - }` - ); - } else { - if (authorizeConnectorIdDefined) { - chargingStation.getConnectorStatus(authorizeConnectorId).idTagAuthorized = false; - delete chargingStation.getConnectorStatus(authorizeConnectorId)?.authorizeIdTag; + if (authorizeConnectorId != null) { + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + const authorizeConnectorStatus = chargingStation.getConnectorStatus(authorizeConnectorId)! + if (payload.idTagInfo.status === OCPP16AuthorizationStatus.ACCEPTED) { + authorizeConnectorStatus.idTagAuthorized = true + logger.debug( + `${chargingStation.logPrefix()} idTag '${ + requestPayload.idTag + }' accepted on connector id ${authorizeConnectorId}` + ) + } else { + authorizeConnectorStatus.idTagAuthorized = false + delete authorizeConnectorStatus.authorizeIdTag + logger.debug( + `${chargingStation.logPrefix()} idTag '${requestPayload.idTag}' rejected with status '${ + payload.idTagInfo.status + }'` + ) } - logger.debug( - `${chargingStation.logPrefix()} idTag '${requestPayload.idTag}' rejected with status '${ - payload.idTagInfo.status - }'${authorizeConnectorIdDefined ? ` on connector id ${authorizeConnectorId}` : ''}` - ); + } else { + logger.error( + `${chargingStation.logPrefix()} idTag '${ + requestPayload.idTag + }' has no authorize request pending` + ) } } - private async handleResponseStartTransaction( + private async handleResponseStartTransaction ( chargingStation: ChargingStation, payload: OCPP16StartTransactionResponse, requestPayload: OCPP16StartTransactionRequest ): Promise { - const transactionConnectorId = requestPayload.connectorId; - if ( - transactionConnectorId === 0 || - chargingStation.hasConnector(transactionConnectorId) === false - ) { + const { connectorId } = requestPayload + if (connectorId === 0 || !chargingStation.hasConnector(connectorId)) { logger.error( - `${chargingStation.logPrefix()} Trying to start a transaction on a non existing connector id ${transactionConnectorId.toString()}` - ); - return; + `${chargingStation.logPrefix()} Trying to start a transaction on a non existing connector id ${connectorId}` + ) + return } + const connectorStatus = chargingStation.getConnectorStatus(connectorId) if ( - chargingStation.getConnectorStatus(transactionConnectorId)?.transactionRemoteStarted === - true && - chargingStation.getAuthorizeRemoteTxRequests() === true && - chargingStation.getLocalAuthListEnabled() === true && + connectorStatus?.transactionRemoteStarted === true && + chargingStation.getAuthorizeRemoteTxRequests() && + chargingStation.getLocalAuthListEnabled() && chargingStation.hasIdTags() && - chargingStation.getConnectorStatus(transactionConnectorId)?.idTagLocalAuthorized === false + connectorStatus.idTagLocalAuthorized === false ) { logger.error( `${chargingStation.logPrefix()} Trying to start a transaction with a not local authorized idTag ${ - chargingStation.getConnectorStatus(transactionConnectorId)?.localAuthorizeIdTag - } on connector id ${transactionConnectorId.toString()}` - ); - await this.resetConnectorOnStartTransactionError(chargingStation, transactionConnectorId); - return; + connectorStatus.localAuthorizeIdTag + } on connector id ${connectorId}` + ) + await this.resetConnectorOnStartTransactionError(chargingStation, connectorId) + return } if ( - chargingStation.getConnectorStatus(transactionConnectorId)?.transactionRemoteStarted === - true && - chargingStation.getAuthorizeRemoteTxRequests() === true && - chargingStation.getMustAuthorizeAtRemoteStart() === true && - chargingStation.getConnectorStatus(transactionConnectorId)?.idTagLocalAuthorized === false && - chargingStation.getConnectorStatus(transactionConnectorId)?.idTagAuthorized === false + connectorStatus?.transactionRemoteStarted === true && + chargingStation.getAuthorizeRemoteTxRequests() && + chargingStation.stationInfo?.remoteAuthorization === true && + connectorStatus.idTagLocalAuthorized === false && + connectorStatus.idTagAuthorized === false ) { logger.error( `${chargingStation.logPrefix()} Trying to start a transaction with a not authorized idTag ${ - chargingStation.getConnectorStatus(transactionConnectorId)?.authorizeIdTag - } on connector id ${transactionConnectorId.toString()}` - ); - await this.resetConnectorOnStartTransactionError(chargingStation, transactionConnectorId); - return; + connectorStatus.authorizeIdTag + } on connector id ${connectorId}` + ) + await this.resetConnectorOnStartTransactionError(chargingStation, connectorId) + return } if ( - chargingStation.getConnectorStatus(transactionConnectorId)?.idTagAuthorized && - chargingStation.getConnectorStatus(transactionConnectorId)?.authorizeIdTag !== - requestPayload.idTag + connectorStatus?.idTagAuthorized === true && + connectorStatus.authorizeIdTag !== requestPayload.idTag ) { logger.error( `${chargingStation.logPrefix()} Trying to start a transaction with an idTag ${ requestPayload.idTag } different from the authorize request one ${ - chargingStation.getConnectorStatus(transactionConnectorId)?.authorizeIdTag - } on connector id ${transactionConnectorId.toString()}` - ); - await this.resetConnectorOnStartTransactionError(chargingStation, transactionConnectorId); - return; + connectorStatus.authorizeIdTag + } on connector id ${connectorId}` + ) + await this.resetConnectorOnStartTransactionError(chargingStation, connectorId) + return } if ( - chargingStation.getConnectorStatus(transactionConnectorId)?.idTagLocalAuthorized && - chargingStation.getConnectorStatus(transactionConnectorId)?.localAuthorizeIdTag !== - requestPayload.idTag + connectorStatus?.idTagLocalAuthorized === true && + connectorStatus.localAuthorizeIdTag !== requestPayload.idTag ) { logger.error( `${chargingStation.logPrefix()} Trying to start a transaction with an idTag ${ requestPayload.idTag } different from the local authorized one ${ - chargingStation.getConnectorStatus(transactionConnectorId)?.localAuthorizeIdTag - } on connector id ${transactionConnectorId.toString()}` - ); - await this.resetConnectorOnStartTransactionError(chargingStation, transactionConnectorId); - return; + connectorStatus.localAuthorizeIdTag + } on connector id ${connectorId}` + ) + await this.resetConnectorOnStartTransactionError(chargingStation, connectorId) + return } - if (chargingStation.getConnectorStatus(transactionConnectorId)?.transactionStarted === true) { + if (connectorStatus?.transactionStarted === true) { logger.error( - `${chargingStation.logPrefix()} Trying to start a transaction on an already used connector id ${transactionConnectorId.toString()}:`, - chargingStation.getConnectorStatus(transactionConnectorId) - ); - return; + `${chargingStation.logPrefix()} Trying to start a transaction on an already used connector id ${connectorId} by idTag ${ + connectorStatus.transactionIdTag + }` + ) + return } if (chargingStation.hasEvses) { for (const [evseId, evseStatus] of chargingStation.evses) { if (evseStatus.connectors.size > 1) { - for (const [connectorId, connectorStatus] of evseStatus.connectors) { - if ( - transactionConnectorId !== connectorId && - connectorStatus?.transactionStarted === true - ) { + for (const [id, status] of evseStatus.connectors) { + if (id !== connectorId && status.transactionStarted === true) { logger.error( - `${chargingStation.logPrefix()} Trying to start a transaction on an already used evse id ${evseId.toString()}:`, - evseStatus - ); - await this.resetConnectorOnStartTransactionError( - chargingStation, - transactionConnectorId - ); - return; + `${chargingStation.logPrefix()} Trying to start a transaction on an already used evse id ${evseId} by connector id ${id} with idTag ${ + status.transactionIdTag + }` + ) + await this.resetConnectorOnStartTransactionError(chargingStation, connectorId) + return } } } } } if ( - chargingStation.getConnectorStatus(transactionConnectorId)?.status !== - OCPP16ChargePointStatus.Available && - chargingStation.getConnectorStatus(transactionConnectorId)?.status !== - OCPP16ChargePointStatus.Preparing + connectorStatus?.status !== OCPP16ChargePointStatus.Available && + connectorStatus?.status !== OCPP16ChargePointStatus.Preparing ) { logger.error( - `${chargingStation.logPrefix()} Trying to start a transaction on connector id ${transactionConnectorId.toString()} with status ${ - chargingStation.getConnectorStatus(transactionConnectorId)?.status - }` - ); - return; + `${chargingStation.logPrefix()} Trying to start a transaction on connector id ${connectorId} with status ${connectorStatus?.status}` + ) + return } - if (!Number.isInteger(payload.transactionId)) { + if (!Number.isSafeInteger(payload.transactionId)) { logger.warn( - `${chargingStation.logPrefix()} Trying to start a transaction on connector id ${transactionConnectorId.toString()} with a non integer transaction id ${ + `${chargingStation.logPrefix()} Trying to start a transaction on connector id ${connectorId} with a non integer transaction id ${ payload.transactionId }, converting to integer` - ); - payload.transactionId = Utils.convertToInt(payload.transactionId); + ) + payload.transactionId = convertToInt(payload.transactionId) } - if (payload.idTagInfo?.status === OCPP16AuthorizationStatus.ACCEPTED) { - chargingStation.getConnectorStatus(transactionConnectorId).transactionStarted = true; - chargingStation.getConnectorStatus(transactionConnectorId).transactionId = - payload.transactionId; - chargingStation.getConnectorStatus(transactionConnectorId).transactionIdTag = - requestPayload.idTag; - chargingStation.getConnectorStatus( - transactionConnectorId - ).transactionEnergyActiveImportRegisterValue = 0; - chargingStation.getConnectorStatus(transactionConnectorId).transactionBeginMeterValue = + if (payload.idTagInfo.status === OCPP16AuthorizationStatus.ACCEPTED) { + connectorStatus.transactionStarted = true + connectorStatus.transactionStart = requestPayload.timestamp + connectorStatus.transactionId = payload.transactionId + connectorStatus.transactionIdTag = requestPayload.idTag + connectorStatus.transactionEnergyActiveImportRegisterValue = 0 + connectorStatus.transactionBeginMeterValue = OCPP16ServiceUtils.buildTransactionBeginMeterValue( chargingStation, - transactionConnectorId, + connectorId, requestPayload.meterStart - ); - chargingStation.getBeginEndMeterValues() && + ) + if (requestPayload.reservationId != null) { + const reservation = chargingStation.getReservationBy( + 'reservationId', + requestPayload.reservationId + ) + if (reservation != null) { + if (reservation.idTag !== requestPayload.idTag) { + logger.warn( + `${chargingStation.logPrefix()} Reserved transaction ${ + payload.transactionId + } started with a different idTag ${requestPayload.idTag} than the reservation one ${ + reservation.idTag + }` + ) + } + if (hasReservationExpired(reservation)) { + logger.warn( + `${chargingStation.logPrefix()} Reserved transaction ${ + payload.transactionId + } started with expired reservation ${ + requestPayload.reservationId + } (expiry date: ${reservation.expiryDate.toISOString()}))` + ) + } + await chargingStation.removeReservation( + reservation, + ReservationTerminationReason.TRANSACTION_STARTED + ) + } else { + logger.warn( + `${chargingStation.logPrefix()} Reserved transaction ${ + payload.transactionId + } started with unknown reservation ${requestPayload.reservationId}` + ) + } + } + chargingStation.stationInfo?.beginEndMeterValues === true && (await chargingStation.ocppRequestService.requestHandler< - OCPP16MeterValuesRequest, - OCPP16MeterValuesResponse + OCPP16MeterValuesRequest, + OCPP16MeterValuesResponse >(chargingStation, OCPP16RequestCommand.METER_VALUES, { - connectorId: transactionConnectorId, + connectorId, transactionId: payload.transactionId, - meterValue: [ - chargingStation.getConnectorStatus(transactionConnectorId).transactionBeginMeterValue, - ], - })); + meterValue: [connectorStatus.transactionBeginMeterValue] + } satisfies OCPP16MeterValuesRequest)) await OCPP16ServiceUtils.sendAndSetConnectorStatus( chargingStation, - transactionConnectorId, + connectorId, OCPP16ChargePointStatus.Charging - ); + ) logger.info( - `${chargingStation.logPrefix()} Transaction with id ${payload.transactionId.toString()} STARTED on ${ - chargingStation.stationInfo.chargingStationId - }#${transactionConnectorId.toString()} for idTag '${requestPayload.idTag}'` - ); - if (chargingStation.stationInfo.powerSharedByConnectors) { - ++chargingStation.powerDivider; + `${chargingStation.logPrefix()} Transaction with id ${ + payload.transactionId + } STARTED on ${chargingStation.stationInfo?.chargingStationId}#${connectorId} for idTag '${ + requestPayload.idTag + }'` + ) + if (chargingStation.stationInfo?.powerSharedByConnectors === true) { + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + ++chargingStation.powerDivider! } - const configuredMeterValueSampleInterval = - ChargingStationConfigurationUtils.getConfigurationKey( - chargingStation, - OCPP16StandardParametersKey.MeterValueSampleInterval - ); + const configuredMeterValueSampleInterval = getConfigurationKey( + chargingStation, + OCPP16StandardParametersKey.MeterValueSampleInterval + ) chargingStation.startMeterValues( - transactionConnectorId, - configuredMeterValueSampleInterval - ? Utils.convertToInt(configuredMeterValueSampleInterval.value) * 1000 + connectorId, + configuredMeterValueSampleInterval != null + ? secondsToMilliseconds(convertToInt(configuredMeterValueSampleInterval.value)) : Constants.DEFAULT_METER_VALUES_INTERVAL - ); + ) } else { logger.warn( - `${chargingStation.logPrefix()} Starting transaction with id ${payload.transactionId.toString()} REJECTED with status '${ - payload.idTagInfo?.status - }', idTag '${requestPayload.idTag}'` - ); - await this.resetConnectorOnStartTransactionError(chargingStation, transactionConnectorId); + `${chargingStation.logPrefix()} Starting transaction with id ${ + payload.transactionId + } REJECTED on ${ + chargingStation.stationInfo?.chargingStationId + }#${connectorId} with status '${payload.idTagInfo.status}', idTag '${ + requestPayload.idTag + }'${ + OCPP16ServiceUtils.hasReservation(chargingStation, connectorId, requestPayload.idTag) + ? `, reservationId '${requestPayload.reservationId}'` + : '' + }` + ) + await this.resetConnectorOnStartTransactionError(chargingStation, connectorId) } } - private async resetConnectorOnStartTransactionError( + private async resetConnectorOnStartTransactionError ( chargingStation: ChargingStation, connectorId: number ): Promise { - ChargingStationUtils.resetConnectorStatus(chargingStation.getConnectorStatus(connectorId)); - chargingStation.stopMeterValues(connectorId); - parentPort?.postMessage(MessageChannelUtils.buildUpdatedMessage(chargingStation)); - if ( - chargingStation.getConnectorStatus(connectorId)?.status !== OCPP16ChargePointStatus.Available - ) { - await OCPP16ServiceUtils.sendAndSetConnectorStatus( - chargingStation, - connectorId, - OCPP16ChargePointStatus.Available - ); - } + chargingStation.stopMeterValues(connectorId) + const connectorStatus = chargingStation.getConnectorStatus(connectorId) + resetConnectorStatus(connectorStatus) + await OCPP16ServiceUtils.restoreConnectorStatus(chargingStation, connectorId, connectorStatus) } - private async handleResponseStopTransaction( + private async handleResponseStopTransaction ( chargingStation: ChargingStation, payload: OCPP16StopTransactionResponse, requestPayload: OCPP16StopTransactionRequest ): Promise { const transactionConnectorId = chargingStation.getConnectorIdByTransactionId( requestPayload.transactionId - ); - if (Utils.isNullOrUndefined(transactionConnectorId)) { + ) + if (transactionConnectorId == null) { logger.error( - `${chargingStation.logPrefix()} Trying to stop a non existing transaction with id ${requestPayload.transactionId.toString()}` - ); - return; + `${chargingStation.logPrefix()} Trying to stop a non existing transaction with id ${ + requestPayload.transactionId + }` + ) + return } - chargingStation.getBeginEndMeterValues() === true && - chargingStation.getOcppStrictCompliance() === false && - chargingStation.getOutOfOrderEndMeterValues() === true && + chargingStation.stationInfo?.beginEndMeterValues === true && + chargingStation.stationInfo.ocppStrictCompliance === false && + chargingStation.stationInfo.outOfOrderEndMeterValues === true && (await chargingStation.ocppRequestService.requestHandler< - OCPP16MeterValuesRequest, - OCPP16MeterValuesResponse + OCPP16MeterValuesRequest, + OCPP16MeterValuesResponse >(chargingStation, OCPP16RequestCommand.METER_VALUES, { connectorId: transactionConnectorId, transactionId: requestPayload.transactionId, @@ -699,45 +852,43 @@ export class OCPP16ResponseService extends OCPPResponseService { chargingStation, transactionConnectorId, requestPayload.meterStop - ), - ], - })); + ) + ] + })) if ( - chargingStation.isChargingStationAvailable() === false || - chargingStation.isConnectorAvailable(transactionConnectorId) === false + !chargingStation.isChargingStationAvailable() || + !chargingStation.isConnectorAvailable(transactionConnectorId) ) { await OCPP16ServiceUtils.sendAndSetConnectorStatus( chargingStation, transactionConnectorId, OCPP16ChargePointStatus.Unavailable - ); + ) } else { await OCPP16ServiceUtils.sendAndSetConnectorStatus( chargingStation, transactionConnectorId, OCPP16ChargePointStatus.Available - ); + ) } - if (chargingStation.stationInfo.powerSharedByConnectors) { - chargingStation.powerDivider--; + if (chargingStation.stationInfo?.powerSharedByConnectors === true) { + // eslint-disable-next-line @typescript-eslint/no-non-null-assertion + chargingStation.powerDivider!-- } - ChargingStationUtils.resetConnectorStatus( - chargingStation.getConnectorStatus(transactionConnectorId) - ); - chargingStation.stopMeterValues(transactionConnectorId); - parentPort?.postMessage(MessageChannelUtils.buildUpdatedMessage(chargingStation)); - const logMsg = `${chargingStation.logPrefix()} Transaction with id ${requestPayload.transactionId.toString()} STOPPED on ${ - chargingStation.stationInfo.chargingStationId - }#${transactionConnectorId?.toString()} with status '${ - payload.idTagInfo?.status ?? 'undefined' - }'`; + resetConnectorStatus(chargingStation.getConnectorStatus(transactionConnectorId)) + chargingStation.stopMeterValues(transactionConnectorId) + const logMsg = `${chargingStation.logPrefix()} Transaction with id ${ + requestPayload.transactionId + } STOPPED on ${ + chargingStation.stationInfo?.chargingStationId + }#${transactionConnectorId} with status '${payload.idTagInfo?.status}'` if ( - Utils.isNullOrUndefined(payload.idTagInfo) || - payload.idTagInfo?.status === OCPP16AuthorizationStatus.ACCEPTED + payload.idTagInfo == null || + payload.idTagInfo.status === OCPP16AuthorizationStatus.ACCEPTED ) { - logger.info(logMsg); + logger.info(logMsg) } else { - logger.warn(logMsg); + logger.warn(logMsg) } } }