X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2Focpp%2F1.6%2FOCPP16ResponseService.ts;h=330f6672542c67151d54f4666da19e0f20753ec0;hb=44eb6026079c8dc2c77b10a96a42d0c0b2da7c8f;hp=3af8a1fc5b8d3dcdb6f3f5bbdfa01b7664848667;hpb=7645760b75ac201b8ec0b8378b986cabacce7807;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 3af8a1fc..330f6672 100644 --- a/src/charging-station/ocpp/1.6/OCPP16ResponseService.ts +++ b/src/charging-station/ocpp/1.6/OCPP16ResponseService.ts @@ -1,62 +1,244 @@ -// Partial Copyright Jerome Benoit. 2021. All Rights Reserved. +// Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved. +import fs from 'fs'; +import path from 'path'; +import { fileURLToPath } from 'url'; + +import type { JSONSchemaType } from 'ajv'; + +import { OCPP16ServiceUtils } from './OCPP16ServiceUtils'; import OCPPError from '../../../exception/OCPPError'; -import { JsonType } from '../../../types/JsonType'; +import type { JsonObject, JsonType } from '../../../types/JsonType'; import { OCPP16ChargePointErrorCode } from '../../../types/ocpp/1.6/ChargePointErrorCode'; import { OCPP16ChargePointStatus } from '../../../types/ocpp/1.6/ChargePointStatus'; import { OCPP16StandardParametersKey } from '../../../types/ocpp/1.6/Configuration'; -import { +import type { OCPP16MeterValuesRequest, OCPP16MeterValuesResponse, } from '../../../types/ocpp/1.6/MeterValues'; import { - OCPP16BootNotificationRequest, + type OCPP16BootNotificationRequest, + OCPP16IncomingRequestCommand, OCPP16RequestCommand, - OCPP16StatusNotificationRequest, + type OCPP16StatusNotificationRequest, } from '../../../types/ocpp/1.6/Requests'; -import { +import type { + ChangeAvailabilityResponse, + ChangeConfigurationResponse, + ClearChargingProfileResponse, + GetConfigurationResponse, + GetDiagnosticsResponse, OCPP16BootNotificationResponse, - OCPP16RegistrationStatus, + OCPP16DataTransferResponse, + OCPP16DiagnosticsStatusNotificationResponse, + OCPP16FirmwareStatusNotificationResponse, + OCPP16HeartbeatResponse, OCPP16StatusNotificationResponse, + OCPP16TriggerMessageResponse, + OCPP16UpdateFirmwareResponse, + SetChargingProfileResponse, + UnlockConnectorResponse, } from '../../../types/ocpp/1.6/Responses'; import { OCPP16AuthorizationStatus, - OCPP16AuthorizeRequest, - OCPP16AuthorizeResponse, - OCPP16StartTransactionRequest, - OCPP16StartTransactionResponse, - OCPP16StopTransactionRequest, - OCPP16StopTransactionResponse, + type OCPP16AuthorizeRequest, + type OCPP16AuthorizeResponse, + type OCPP16StartTransactionRequest, + type OCPP16StartTransactionResponse, + type OCPP16StopTransactionRequest, + type OCPP16StopTransactionResponse, } from '../../../types/ocpp/1.6/Transaction'; import { ErrorType } from '../../../types/ocpp/ErrorType'; -import { ResponseHandler } from '../../../types/ocpp/Responses'; +import { OCPPVersion } from '../../../types/ocpp/OCPPVersion'; +import { + type GenericResponse, + RegistrationStatusEnumType, + type ResponseHandler, +} from '../../../types/ocpp/Responses'; +import Constants from '../../../utils/Constants'; import logger from '../../../utils/Logger'; import Utils from '../../../utils/Utils'; import type ChargingStation from '../../ChargingStation'; import { ChargingStationConfigurationUtils } from '../../ChargingStationConfigurationUtils'; -import { ChargingStationUtils } from '../../ChargingStationUtils'; import OCPPResponseService from '../OCPPResponseService'; -import { OCPP16ServiceUtils } from './OCPP16ServiceUtils'; const moduleName = 'OCPP16ResponseService'; export default class OCPP16ResponseService extends OCPPResponseService { + public jsonIncomingRequestResponseSchemas: Map< + OCPP16IncomingRequestCommand, + JSONSchemaType + >; + private responseHandlers: Map; + private jsonSchemas: Map>; public constructor() { if (new.target?.name === moduleName) { throw new TypeError(`Cannot construct ${new.target?.name} instances directly`); } - super(); + super(OCPPVersion.VERSION_16); this.responseHandlers = new Map([ [OCPP16RequestCommand.BOOT_NOTIFICATION, this.handleResponseBootNotification.bind(this)], - [OCPP16RequestCommand.HEARTBEAT, this.handleResponseHeartbeat.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.handleResponseStatusNotification.bind(this)], - [OCPP16RequestCommand.METER_VALUES, this.handleResponseMeterValues.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, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/BootNotificationResponse.json' + ), + ], + [ + OCPP16RequestCommand.HEARTBEAT, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/HeartbeatResponse.json' + ), + ], + [ + OCPP16RequestCommand.AUTHORIZE, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/AuthorizeResponse.json' + ), + ], + [ + OCPP16RequestCommand.START_TRANSACTION, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/StartTransactionResponse.json' + ), + ], + [ + OCPP16RequestCommand.STOP_TRANSACTION, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/StopTransactionResponse.json' + ), + ], + [ + OCPP16RequestCommand.STATUS_NOTIFICATION, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/StatusNotificationResponse.json' + ), + ], + [ + OCPP16RequestCommand.METER_VALUES, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/MeterValuesResponse.json' + ), + ], + [ + OCPP16RequestCommand.DIAGNOSTICS_STATUS_NOTIFICATION, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/DiagnosticsStatusNotificationResponse.json' + ), + ], + [ + OCPP16RequestCommand.DATA_TRANSFER, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/DataTransferResponse.json' + ), + ], + [ + OCPP16RequestCommand.FIRMWARE_STATUS_NOTIFICATION, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/FirmwareStatusNotificationResponse.json' + ), + ], ]); + this.jsonIncomingRequestResponseSchemas = new Map([ + [ + OCPP16IncomingRequestCommand.RESET, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/ResetResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.CLEAR_CACHE, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/ClearCacheResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.CHANGE_AVAILABILITY, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/ChangeAvailabilityResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.UNLOCK_CONNECTOR, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/UnlockConnectorResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.GET_CONFIGURATION, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/GetConfigurationResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.CHANGE_CONFIGURATION, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/ChangeConfigurationResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.SET_CHARGING_PROFILE, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/SetChargingProfileResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.CLEAR_CHARGING_PROFILE, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/ClearChargingProfileResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.REMOTE_START_TRANSACTION, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/RemoteStartTransactionResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.REMOTE_STOP_TRANSACTION, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/RemoteStopTransactionResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.GET_DIAGNOSTICS, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/GetDiagnosticsResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.TRIGGER_MESSAGE, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/TriggerMessageResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.DATA_TRANSFER, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/DataTransferResponse.json' + ), + ], + [ + OCPP16IncomingRequestCommand.UPDATE_FIRMWARE, + this.parseJsonSchemaFile( + '../../../assets/json-schemas/ocpp/1.6/UpdateFirmwareResponse.json' + ), + ], + ]); + this.validatePayload.bind(this); } public async responseHandler( @@ -65,22 +247,29 @@ export default class OCPP16ResponseService extends OCPPResponseService { payload: JsonType, requestPayload: JsonType ): Promise { - if (chargingStation.isRegistered() || commandName === OCPP16RequestCommand.BOOT_NOTIFICATION) { + if ( + chargingStation.isRegistered() === true || + commandName === OCPP16RequestCommand.BOOT_NOTIFICATION + ) { if ( - this.responseHandlers.has(commandName) && - ChargingStationUtils.isCommandSupported(commandName, chargingStation) + this.responseHandlers.has(commandName) === true && + OCPP16ServiceUtils.isRequestCommandSupported(chargingStation, commandName) === true ) { try { + this.validatePayload(chargingStation, commandName, payload); await this.responseHandlers.get(commandName)(chargingStation, payload, requestPayload); } catch (error) { - logger.error(chargingStation.logPrefix() + ' Handle request response error: %j', error); + logger.error( + `${chargingStation.logPrefix()} ${moduleName}.responseHandler: Handle response error:`, + error + ); throw error; } } else { // Throw exception throw new OCPPError( ErrorType.NOT_IMPLEMENTED, - `${commandName} is not implemented to handle request response payload ${JSON.stringify( + `${commandName} is not implemented to handle response PDU ${JSON.stringify( payload, null, 2 @@ -92,22 +281,41 @@ export default class OCPP16ResponseService extends OCPPResponseService { } else { throw new OCPPError( ErrorType.SECURITY_ERROR, - `${commandName} cannot be issued to handle request response payload ${JSON.stringify( + `${commandName} cannot be issued to handle response PDU ${JSON.stringify( payload, null, 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( + chargingStation: ChargingStation, + commandName: OCPP16RequestCommand, + payload: JsonType + ): boolean { + if (this.jsonSchemas.has(commandName) === true) { + return this.validateResponsePayload( + chargingStation, + commandName, + this.jsonSchemas.get(commandName), + payload + ); + } + logger.warn( + `${chargingStation.logPrefix()} ${moduleName}.validatePayload: No JSON schema found for command '${commandName}' PDU validation` + ); + return false; + } + private handleResponseBootNotification( chargingStation: ChargingStation, payload: OCPP16BootNotificationResponse ): void { - if (payload.status === OCPP16RegistrationStatus.ACCEPTED) { + if (payload.status === RegistrationStatusEnumType.ACCEPTED) { ChargingStationConfigurationUtils.addConfigurationKey( chargingStation, OCPP16StandardParametersKey.HeartbeatInterval, @@ -126,25 +334,21 @@ export default class OCPP16ResponseService extends OCPPResponseService { ? chargingStation.restartHeartbeat() : chargingStation.startHeartbeat(); } - if (Object.values(OCPP16RegistrationStatus).includes(payload.status)) { + if (Object.values(RegistrationStatusEnumType).includes(payload.status)) { const logMsg = `${chargingStation.logPrefix()} Charging station in '${ payload.status }' state on the central server`; - payload.status === OCPP16RegistrationStatus.REJECTED + payload.status === RegistrationStatusEnumType.REJECTED ? logger.warn(logMsg) : logger.info(logMsg); } else { logger.error( - chargingStation.logPrefix() + - ' Charging station boot notification response received: %j with undefined registration status', + `${chargingStation.logPrefix()} Charging station boot notification response received: %j with undefined registration status`, payload ); } } - // eslint-disable-next-line @typescript-eslint/no-empty-function - private handleResponseHeartbeat(): void {} - private handleResponseAuthorize( chargingStation: ChargingStation, payload: OCPP16AuthorizeResponse, @@ -160,20 +364,24 @@ export default class OCPP16ResponseService extends OCPPResponseService { break; } } + const authorizeConnectorIdDefined = authorizeConnectorId !== undefined; if (payload.idTagInfo.status === OCPP16AuthorizationStatus.ACCEPTED) { - chargingStation.getConnectorStatus(authorizeConnectorId).idTagAuthorized = true; + authorizeConnectorIdDefined && + (chargingStation.getConnectorStatus(authorizeConnectorId).idTagAuthorized = true); logger.debug( - `${chargingStation.logPrefix()} IdTag ${ - requestPayload.idTag - } authorized on connector ${authorizeConnectorId}` + `${chargingStation.logPrefix()} IdTag '${requestPayload.idTag}' accepted${ + authorizeConnectorIdDefined ? ` on connector ${authorizeConnectorId}` : '' + }` ); } else { - chargingStation.getConnectorStatus(authorizeConnectorId).idTagAuthorized = false; - delete chargingStation.getConnectorStatus(authorizeConnectorId).authorizeIdTag; + if (authorizeConnectorIdDefined) { + chargingStation.getConnectorStatus(authorizeConnectorId).idTagAuthorized = false; + delete chargingStation.getConnectorStatus(authorizeConnectorId).authorizeIdTag; + } logger.debug( - `${chargingStation.logPrefix()} IdTag ${requestPayload.idTag} refused with status '${ + `${chargingStation.logPrefix()} IdTag '${requestPayload.idTag}' rejected with status '${ payload.idTagInfo.status - }' on connector ${authorizeConnectorId}` + }'${authorizeConnectorIdDefined ? ` on connector ${authorizeConnectorId}` : ''}` ); } } @@ -194,42 +402,36 @@ export default class OCPP16ResponseService extends OCPPResponseService { } if (!transactionConnectorId) { logger.error( - chargingStation.logPrefix() + - ' Trying to start a transaction on a non existing connector Id ' + - connectorId.toString() + `${chargingStation.logPrefix()} Trying to start a transaction on a non existing connector Id ${connectorId.toString()}` ); return; } if ( - chargingStation.getConnectorStatus(connectorId).transactionRemoteStarted && - chargingStation.getAuthorizeRemoteTxRequests() && - chargingStation.getLocalAuthListEnabled() && + chargingStation.getConnectorStatus(connectorId).transactionRemoteStarted === true && + chargingStation.getAuthorizeRemoteTxRequests() === true && + chargingStation.getLocalAuthListEnabled() === true && chargingStation.hasAuthorizedTags() && - !chargingStation.getConnectorStatus(connectorId).idTagLocalAuthorized + chargingStation.getConnectorStatus(connectorId).idTagLocalAuthorized === false ) { logger.error( - chargingStation.logPrefix() + - ' Trying to start a transaction with a not local authorized idTag ' + - chargingStation.getConnectorStatus(connectorId).localAuthorizeIdTag + - ' on connector Id ' + - connectorId.toString() + `${chargingStation.logPrefix()} Trying to start a transaction with a not local authorized idTag ${ + chargingStation.getConnectorStatus(connectorId).localAuthorizeIdTag + } on connector Id ${connectorId.toString()}` ); await this.resetConnectorOnStartTransactionError(chargingStation, connectorId); return; } if ( - chargingStation.getConnectorStatus(connectorId).transactionRemoteStarted && - chargingStation.getAuthorizeRemoteTxRequests() && - chargingStation.getMayAuthorizeAtRemoteStart() && - !chargingStation.getConnectorStatus(connectorId).idTagLocalAuthorized && - !chargingStation.getConnectorStatus(connectorId).idTagAuthorized + chargingStation.getConnectorStatus(connectorId).transactionRemoteStarted === true && + chargingStation.getAuthorizeRemoteTxRequests() === true && + chargingStation.getMustAuthorizeAtRemoteStart() === true && + chargingStation.getConnectorStatus(connectorId).idTagLocalAuthorized === false && + chargingStation.getConnectorStatus(connectorId).idTagAuthorized === false ) { logger.error( - chargingStation.logPrefix() + - ' Trying to start a transaction with a not authorized idTag ' + - chargingStation.getConnectorStatus(connectorId).authorizeIdTag + - ' on connector Id ' + - connectorId.toString() + `${chargingStation.logPrefix()} Trying to start a transaction with a not authorized idTag ${ + chargingStation.getConnectorStatus(connectorId).authorizeIdTag + } on connector Id ${connectorId.toString()}` ); await this.resetConnectorOnStartTransactionError(chargingStation, connectorId); return; @@ -239,13 +441,11 @@ export default class OCPP16ResponseService extends OCPPResponseService { chargingStation.getConnectorStatus(connectorId).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(connectorId).authorizeIdTag + - ' on connector Id ' + - connectorId.toString() + `${chargingStation.logPrefix()} Trying to start a transaction with an idTag ${ + requestPayload.idTag + } different from the authorize request one ${ + chargingStation.getConnectorStatus(connectorId).authorizeIdTag + } on connector Id ${connectorId.toString()}` ); await this.resetConnectorOnStartTransactionError(chargingStation, connectorId); return; @@ -255,23 +455,18 @@ export default class OCPP16ResponseService extends OCPPResponseService { chargingStation.getConnectorStatus(connectorId).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(connectorId).localAuthorizeIdTag + - ' on connector Id ' + - connectorId.toString() + `${chargingStation.logPrefix()} Trying to start a transaction with an idTag ${ + requestPayload.idTag + } different from the local authorized one ${ + chargingStation.getConnectorStatus(connectorId).localAuthorizeIdTag + } on connector Id ${connectorId.toString()}` ); await this.resetConnectorOnStartTransactionError(chargingStation, connectorId); return; } - if (chargingStation.getConnectorStatus(connectorId)?.transactionStarted) { + if (chargingStation.getConnectorStatus(connectorId)?.transactionStarted === true) { logger.debug( - chargingStation.logPrefix() + - ' Trying to start a transaction on an already used connector ' + - connectorId.toString() + - ': %j', + `${chargingStation.logPrefix()} Trying to start a transaction on an already used connector ${connectorId.toString()}: %j`, chargingStation.getConnectorStatus(connectorId) ); return; @@ -288,14 +483,14 @@ export default class OCPP16ResponseService extends OCPPResponseService { ); return; } - if (!Number.isInteger(payload.transactionId)) { - logger.warn( - `${chargingStation.logPrefix()} Trying to start a transaction on connector ${connectorId.toString()} with a non integer transaction Id ${ - payload.transactionId - }, converting to integer` - ); - payload.transactionId = Utils.convertToInt(payload.transactionId); - } + // if (!Number.isInteger(payload.transactionId)) { + // logger.warn( + // `${chargingStation.logPrefix()} Trying to start a transaction on connector ${connectorId.toString()} with a non integer transaction Id ${ + // payload.transactionId + // }, converting to integer` + // ); + // payload.transactionId = Utils.convertToInt(payload.transactionId); + // } if (payload.idTagInfo?.status === OCPP16AuthorizationStatus.ACCEPTED) { chargingStation.getConnectorStatus(connectorId).transactionStarted = true; @@ -329,15 +524,9 @@ export default class OCPP16ResponseService extends OCPPResponseService { }); chargingStation.getConnectorStatus(connectorId).status = OCPP16ChargePointStatus.CHARGING; logger.info( - chargingStation.logPrefix() + - ' Transaction ' + - payload.transactionId.toString() + - ' STARTED on ' + - chargingStation.stationInfo.chargingStationId + - '#' + - connectorId.toString() + - ' for idTag ' + - requestPayload.idTag + `${chargingStation.logPrefix()} Transaction ${payload.transactionId.toString()} STARTED on ${ + chargingStation.stationInfo.chargingStationId + }#${connectorId.toString()} for idTag '${requestPayload.idTag}'` ); if (chargingStation.stationInfo.powerSharedByConnectors) { chargingStation.powerDivider++; @@ -351,17 +540,13 @@ export default class OCPP16ResponseService extends OCPPResponseService { connectorId, configuredMeterValueSampleInterval ? Utils.convertToInt(configuredMeterValueSampleInterval.value) * 1000 - : 60000 + : Constants.DEFAULT_METER_VALUES_INTERVAL ); } else { logger.warn( - chargingStation.logPrefix() + - ' Starting transaction id ' + - payload.transactionId.toString() + - " REJECTED with status '" + - payload?.idTagInfo?.status + - "', idTag " + - requestPayload.idTag + `${chargingStation.logPrefix()} Starting transaction id ${payload.transactionId.toString()} REJECTED with status '${ + payload.idTagInfo?.status + }', idTag '${requestPayload.idTag}'` ); await this.resetConnectorOnStartTransactionError(chargingStation, connectorId); } @@ -397,84 +582,78 @@ export default class OCPP16ResponseService extends OCPPResponseService { ); if (!transactionConnectorId) { logger.error( - chargingStation.logPrefix() + - ' Trying to stop a non existing transaction ' + - requestPayload.transactionId.toString() + `${chargingStation.logPrefix()} Trying to stop a non existing transaction ${requestPayload.transactionId.toString()}` ); return; } - if (payload.idTagInfo?.status === OCPP16AuthorizationStatus.ACCEPTED) { - chargingStation.getBeginEndMeterValues() && - !chargingStation.getOcppStrictCompliance() && - chargingStation.getOutOfOrderEndMeterValues() && - (await chargingStation.ocppRequestService.requestHandler< - OCPP16MeterValuesRequest, - OCPP16MeterValuesResponse - >(chargingStation, OCPP16RequestCommand.METER_VALUES, { - connectorId: transactionConnectorId, - transactionId: requestPayload.transactionId, - meterValue: [ - OCPP16ServiceUtils.buildTransactionEndMeterValue( - chargingStation, - transactionConnectorId, - requestPayload.meterStop - ), - ], - })); - if ( - !chargingStation.isChargingStationAvailable() || - !chargingStation.isConnectorAvailable(transactionConnectorId) - ) { - await chargingStation.ocppRequestService.requestHandler< - OCPP16StatusNotificationRequest, - OCPP16StatusNotificationResponse - >(chargingStation, OCPP16RequestCommand.STATUS_NOTIFICATION, { - connectorId: transactionConnectorId, - status: OCPP16ChargePointStatus.UNAVAILABLE, - errorCode: OCPP16ChargePointErrorCode.NO_ERROR, - }); - chargingStation.getConnectorStatus(transactionConnectorId).status = - OCPP16ChargePointStatus.UNAVAILABLE; - } else { - await chargingStation.ocppRequestService.requestHandler< - OCPP16BootNotificationRequest, - OCPP16BootNotificationResponse - >(chargingStation, OCPP16RequestCommand.STATUS_NOTIFICATION, { - connectorId: transactionConnectorId, - status: OCPP16ChargePointStatus.AVAILABLE, - errorCode: OCPP16ChargePointErrorCode.NO_ERROR, - }); - chargingStation.getConnectorStatus(transactionConnectorId).status = - OCPP16ChargePointStatus.AVAILABLE; - } - if (chargingStation.stationInfo.powerSharedByConnectors) { - chargingStation.powerDivider--; - } - logger.info( - chargingStation.logPrefix() + - ' Transaction ' + - requestPayload.transactionId.toString() + - ' STOPPED on ' + - chargingStation.stationInfo.chargingStationId + - '#' + - transactionConnectorId.toString() - ); - chargingStation.resetConnectorStatus(transactionConnectorId); + chargingStation.getBeginEndMeterValues() === true && + chargingStation.getOcppStrictCompliance() === false && + chargingStation.getOutOfOrderEndMeterValues() === true && + (await chargingStation.ocppRequestService.requestHandler< + OCPP16MeterValuesRequest, + OCPP16MeterValuesResponse + >(chargingStation, OCPP16RequestCommand.METER_VALUES, { + connectorId: transactionConnectorId, + transactionId: requestPayload.transactionId, + meterValue: [ + OCPP16ServiceUtils.buildTransactionEndMeterValue( + chargingStation, + transactionConnectorId, + requestPayload.meterStop + ), + ], + })); + if ( + chargingStation.isChargingStationAvailable() === false || + chargingStation.isConnectorAvailable(transactionConnectorId) === false + ) { + await chargingStation.ocppRequestService.requestHandler< + OCPP16StatusNotificationRequest, + OCPP16StatusNotificationResponse + >(chargingStation, OCPP16RequestCommand.STATUS_NOTIFICATION, { + connectorId: transactionConnectorId, + status: OCPP16ChargePointStatus.UNAVAILABLE, + errorCode: OCPP16ChargePointErrorCode.NO_ERROR, + }); + chargingStation.getConnectorStatus(transactionConnectorId).status = + OCPP16ChargePointStatus.UNAVAILABLE; } else { - logger.warn( - chargingStation.logPrefix() + - ' Stopping transaction id ' + - requestPayload.transactionId.toString() + - " REJECTED with status '" + - payload.idTagInfo?.status + - "'" - ); + await chargingStation.ocppRequestService.requestHandler< + OCPP16BootNotificationRequest, + OCPP16BootNotificationResponse + >(chargingStation, OCPP16RequestCommand.STATUS_NOTIFICATION, { + connectorId: transactionConnectorId, + status: OCPP16ChargePointStatus.AVAILABLE, + errorCode: OCPP16ChargePointErrorCode.NO_ERROR, + }); + chargingStation.getConnectorStatus(transactionConnectorId).status = + OCPP16ChargePointStatus.AVAILABLE; + } + if (chargingStation.stationInfo.powerSharedByConnectors) { + chargingStation.powerDivider--; + } + chargingStation.resetConnectorStatus(transactionConnectorId); + const logMsg = `${chargingStation.logPrefix()} Transaction ${requestPayload.transactionId.toString()} STOPPED on ${ + chargingStation.stationInfo.chargingStationId + }#${transactionConnectorId.toString()} with status '${ + payload.idTagInfo?.status ?? 'undefined' + }'`; + if ( + Utils.isNullOrUndefined(payload.idTagInfo) || + payload.idTagInfo?.status === OCPP16AuthorizationStatus.ACCEPTED + ) { + logger.info(logMsg); + } else { + logger.warn(logMsg); } } - // eslint-disable-next-line @typescript-eslint/no-empty-function - private handleResponseStatusNotification(): void {} - - // eslint-disable-next-line @typescript-eslint/no-empty-function - private handleResponseMeterValues(): void {} + private parseJsonSchemaFile(relativePath: string): JSONSchemaType { + return JSON.parse( + fs.readFileSync( + path.resolve(path.dirname(fileURLToPath(import.meta.url)), relativePath), + 'utf8' + ) + ) as JSONSchemaType; + } }