1 // Partial Copyright Jerome Benoit. 2021-2023. All Rights Reserved.
3 import type { JSONSchemaType
} from
'ajv';
5 import { type ChargingStation
, ChargingStationConfigurationUtils
} from
'../../../charging-station';
6 import { OCPPError
} from
'../../../exception';
8 type ChangeAvailabilityResponse
,
9 type ChangeConfigurationResponse
,
10 type ClearChargingProfileResponse
,
13 type GetConfigurationResponse
,
14 type GetDiagnosticsResponse
,
17 OCPP16AuthorizationStatus
,
18 type OCPP16AuthorizeRequest
,
19 type OCPP16AuthorizeResponse
,
20 type OCPP16BootNotificationRequest
,
21 type OCPP16BootNotificationResponse
,
22 OCPP16ChargePointErrorCode
,
23 OCPP16ChargePointStatus
,
24 type OCPP16DataTransferResponse
,
25 type OCPP16DiagnosticsStatusNotificationResponse
,
26 type OCPP16FirmwareStatusNotificationResponse
,
27 type OCPP16HeartbeatResponse
,
28 OCPP16IncomingRequestCommand
,
29 type OCPP16MeterValuesRequest
,
30 type OCPP16MeterValuesResponse
,
32 OCPP16StandardParametersKey
,
33 type OCPP16StartTransactionRequest
,
34 type OCPP16StartTransactionResponse
,
35 type OCPP16StatusNotificationRequest
,
36 type OCPP16StatusNotificationResponse
,
37 type OCPP16StopTransactionRequest
,
38 type OCPP16StopTransactionResponse
,
39 type OCPP16TriggerMessageResponse
,
40 type OCPP16UpdateFirmwareResponse
,
42 RegistrationStatusEnumType
,
44 type SetChargingProfileResponse
,
45 type UnlockConnectorResponse
,
46 } from
'../../../types';
47 import { Constants
, Utils
, logger
} from
'../../../utils';
48 import { OCPP16ServiceUtils
, OCPPResponseService
} from
'../internal';
50 const moduleName
= 'OCPP16ResponseService';
52 export class OCPP16ResponseService
extends OCPPResponseService
{
53 public jsonIncomingRequestResponseSchemas
: Map
<
54 OCPP16IncomingRequestCommand
,
55 JSONSchemaType
<JsonObject
>
58 private responseHandlers
: Map
<OCPP16RequestCommand
, ResponseHandler
>;
59 private jsonSchemas
: Map
<OCPP16RequestCommand
, JSONSchemaType
<JsonObject
>>;
61 public constructor() {
62 // if (new.target?.name === moduleName) {
63 // throw new TypeError(`Cannot construct ${new.target?.name} instances directly`);
65 super(OCPPVersion
.VERSION_16
);
66 this.responseHandlers
= new Map
<OCPP16RequestCommand
, ResponseHandler
>([
67 [OCPP16RequestCommand
.BOOT_NOTIFICATION
, this.handleResponseBootNotification
.bind(this)],
68 [OCPP16RequestCommand
.HEARTBEAT
, this.emptyResponseHandler
.bind(this)],
69 [OCPP16RequestCommand
.AUTHORIZE
, this.handleResponseAuthorize
.bind(this)],
70 [OCPP16RequestCommand
.START_TRANSACTION
, this.handleResponseStartTransaction
.bind(this)],
71 [OCPP16RequestCommand
.STOP_TRANSACTION
, this.handleResponseStopTransaction
.bind(this)],
72 [OCPP16RequestCommand
.STATUS_NOTIFICATION
, this.emptyResponseHandler
.bind(this)],
73 [OCPP16RequestCommand
.METER_VALUES
, this.emptyResponseHandler
.bind(this)],
74 [OCPP16RequestCommand
.DIAGNOSTICS_STATUS_NOTIFICATION
, this.emptyResponseHandler
.bind(this)],
75 [OCPP16RequestCommand
.DATA_TRANSFER
, this.emptyResponseHandler
.bind(this)],
76 [OCPP16RequestCommand
.FIRMWARE_STATUS_NOTIFICATION
, this.emptyResponseHandler
.bind(this)],
78 this.jsonSchemas
= new Map
<OCPP16RequestCommand
, JSONSchemaType
<JsonObject
>>([
80 OCPP16RequestCommand
.BOOT_NOTIFICATION
,
81 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16BootNotificationResponse
>(
82 '../../../assets/json-schemas/ocpp/1.6/BootNotificationResponse.json',
88 OCPP16RequestCommand
.HEARTBEAT
,
89 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16HeartbeatResponse
>(
90 '../../../assets/json-schemas/ocpp/1.6/HeartbeatResponse.json',
96 OCPP16RequestCommand
.AUTHORIZE
,
97 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16AuthorizeResponse
>(
98 '../../../assets/json-schemas/ocpp/1.6/AuthorizeResponse.json',
104 OCPP16RequestCommand
.START_TRANSACTION
,
105 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16StartTransactionResponse
>(
106 '../../../assets/json-schemas/ocpp/1.6/StartTransactionResponse.json',
112 OCPP16RequestCommand
.STOP_TRANSACTION
,
113 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16StopTransactionResponse
>(
114 '../../../assets/json-schemas/ocpp/1.6/StopTransactionResponse.json',
120 OCPP16RequestCommand
.STATUS_NOTIFICATION
,
121 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16StatusNotificationResponse
>(
122 '../../../assets/json-schemas/ocpp/1.6/StatusNotificationResponse.json',
128 OCPP16RequestCommand
.METER_VALUES
,
129 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16MeterValuesResponse
>(
130 '../../../assets/json-schemas/ocpp/1.6/MeterValuesResponse.json',
136 OCPP16RequestCommand
.DIAGNOSTICS_STATUS_NOTIFICATION
,
137 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16DiagnosticsStatusNotificationResponse
>(
138 '../../../assets/json-schemas/ocpp/1.6/DiagnosticsStatusNotificationResponse.json',
144 OCPP16RequestCommand
.DATA_TRANSFER
,
145 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16DataTransferResponse
>(
146 '../../../assets/json-schemas/ocpp/1.6/DataTransferResponse.json',
152 OCPP16RequestCommand
.FIRMWARE_STATUS_NOTIFICATION
,
153 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16FirmwareStatusNotificationResponse
>(
154 '../../../assets/json-schemas/ocpp/1.6/FirmwareStatusNotificationResponse.json',
160 this.jsonIncomingRequestResponseSchemas
= new Map([
162 OCPP16IncomingRequestCommand
.RESET
,
163 OCPP16ServiceUtils
.parseJsonSchemaFile
<GenericResponse
>(
164 '../../../assets/json-schemas/ocpp/1.6/ResetResponse.json',
170 OCPP16IncomingRequestCommand
.CLEAR_CACHE
,
171 OCPP16ServiceUtils
.parseJsonSchemaFile
<GenericResponse
>(
172 '../../../assets/json-schemas/ocpp/1.6/ClearCacheResponse.json',
178 OCPP16IncomingRequestCommand
.CHANGE_AVAILABILITY
,
179 OCPP16ServiceUtils
.parseJsonSchemaFile
<ChangeAvailabilityResponse
>(
180 '../../../assets/json-schemas/ocpp/1.6/ChangeAvailabilityResponse.json',
186 OCPP16IncomingRequestCommand
.UNLOCK_CONNECTOR
,
187 OCPP16ServiceUtils
.parseJsonSchemaFile
<UnlockConnectorResponse
>(
188 '../../../assets/json-schemas/ocpp/1.6/UnlockConnectorResponse.json',
194 OCPP16IncomingRequestCommand
.GET_CONFIGURATION
,
195 OCPP16ServiceUtils
.parseJsonSchemaFile
<GetConfigurationResponse
>(
196 '../../../assets/json-schemas/ocpp/1.6/GetConfigurationResponse.json',
202 OCPP16IncomingRequestCommand
.CHANGE_CONFIGURATION
,
203 OCPP16ServiceUtils
.parseJsonSchemaFile
<ChangeConfigurationResponse
>(
204 '../../../assets/json-schemas/ocpp/1.6/ChangeConfigurationResponse.json',
210 OCPP16IncomingRequestCommand
.SET_CHARGING_PROFILE
,
211 OCPP16ServiceUtils
.parseJsonSchemaFile
<SetChargingProfileResponse
>(
212 '../../../assets/json-schemas/ocpp/1.6/SetChargingProfileResponse.json',
218 OCPP16IncomingRequestCommand
.CLEAR_CHARGING_PROFILE
,
219 OCPP16ServiceUtils
.parseJsonSchemaFile
<ClearChargingProfileResponse
>(
220 '../../../assets/json-schemas/ocpp/1.6/ClearChargingProfileResponse.json',
226 OCPP16IncomingRequestCommand
.REMOTE_START_TRANSACTION
,
227 OCPP16ServiceUtils
.parseJsonSchemaFile
<GenericResponse
>(
228 '../../../assets/json-schemas/ocpp/1.6/RemoteStartTransactionResponse.json',
234 OCPP16IncomingRequestCommand
.REMOTE_STOP_TRANSACTION
,
235 OCPP16ServiceUtils
.parseJsonSchemaFile
<GenericResponse
>(
236 '../../../assets/json-schemas/ocpp/1.6/RemoteStopTransactionResponse.json',
242 OCPP16IncomingRequestCommand
.GET_DIAGNOSTICS
,
243 OCPP16ServiceUtils
.parseJsonSchemaFile
<GetDiagnosticsResponse
>(
244 '../../../assets/json-schemas/ocpp/1.6/GetDiagnosticsResponse.json',
250 OCPP16IncomingRequestCommand
.TRIGGER_MESSAGE
,
251 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16TriggerMessageResponse
>(
252 '../../../assets/json-schemas/ocpp/1.6/TriggerMessageResponse.json',
258 OCPP16IncomingRequestCommand
.DATA_TRANSFER
,
259 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16DataTransferResponse
>(
260 '../../../assets/json-schemas/ocpp/1.6/DataTransferResponse.json',
266 OCPP16IncomingRequestCommand
.UPDATE_FIRMWARE
,
267 OCPP16ServiceUtils
.parseJsonSchemaFile
<OCPP16UpdateFirmwareResponse
>(
268 '../../../assets/json-schemas/ocpp/1.6/UpdateFirmwareResponse.json',
274 this.validatePayload
.bind(this);
277 public async responseHandler(
278 chargingStation
: ChargingStation
,
279 commandName
: OCPP16RequestCommand
,
281 requestPayload
: JsonType
284 chargingStation
.isRegistered() === true ||
285 commandName
=== OCPP16RequestCommand
.BOOT_NOTIFICATION
288 this.responseHandlers
.has(commandName
) === true &&
289 OCPP16ServiceUtils
.isRequestCommandSupported(chargingStation
, commandName
) === true
292 this.validatePayload(chargingStation
, commandName
, payload
);
293 await this.responseHandlers
.get(commandName
)(chargingStation
, payload
, requestPayload
);
296 `${chargingStation.logPrefix()} ${moduleName}.responseHandler: Handle response error:`,
304 ErrorType
.NOT_IMPLEMENTED
,
305 `${commandName} is not implemented to handle response PDU ${JSON.stringify(
316 ErrorType
.SECURITY_ERROR
,
317 `${commandName} cannot be issued to handle response PDU ${JSON.stringify(
321 )} while the charging station is not registered on the central server.`,
328 private validatePayload(
329 chargingStation
: ChargingStation
,
330 commandName
: OCPP16RequestCommand
,
333 if (this.jsonSchemas
.has(commandName
) === true) {
334 return this.validateResponsePayload(
337 this.jsonSchemas
.get(commandName
),
342 `${chargingStation.logPrefix()} ${moduleName}.validatePayload: No JSON schema found for command '${commandName}' PDU validation`
347 private handleResponseBootNotification(
348 chargingStation
: ChargingStation
,
349 payload
: OCPP16BootNotificationResponse
351 if (payload
.status === RegistrationStatusEnumType
.ACCEPTED
) {
352 ChargingStationConfigurationUtils
.addConfigurationKey(
354 OCPP16StandardParametersKey
.HeartbeatInterval
,
355 payload
.interval
.toString(),
357 { overwrite
: true, save
: true }
359 ChargingStationConfigurationUtils
.addConfigurationKey(
361 OCPP16StandardParametersKey
.HeartBeatInterval
,
362 payload
.interval
.toString(),
364 { overwrite
: true, save
: true }
366 OCPP16ServiceUtils
.startHeartbeatInterval(chargingStation
, payload
.interval
);
368 if (Object.values(RegistrationStatusEnumType
).includes(payload
.status)) {
369 const logMsg
= `${chargingStation.logPrefix()} Charging station in '${
371 }' state on the central server`;
372 payload
.status === RegistrationStatusEnumType
.REJECTED
373 ? logger
.warn(logMsg
)
374 : logger
.info(logMsg
);
377 `${chargingStation.logPrefix()} Charging station boot notification response received: %j with undefined registration status`,
383 private handleResponseAuthorize(
384 chargingStation
: ChargingStation
,
385 payload
: OCPP16AuthorizeResponse
,
386 requestPayload
: OCPP16AuthorizeRequest
388 let authorizeConnectorId
: number;
389 for (const connectorId
of chargingStation
.connectors
.keys()) {
392 chargingStation
.getConnectorStatus(connectorId
)?.authorizeIdTag
=== requestPayload
.idTag
394 authorizeConnectorId
= connectorId
;
398 const authorizeConnectorIdDefined
= authorizeConnectorId
!== undefined;
399 if (payload
.idTagInfo
.status === OCPP16AuthorizationStatus
.ACCEPTED
) {
400 authorizeConnectorIdDefined
&&
401 (chargingStation
.getConnectorStatus(authorizeConnectorId
).idTagAuthorized
= true);
403 `${chargingStation.logPrefix()} IdTag '${requestPayload.idTag}' accepted${
404 authorizeConnectorIdDefined ? ` on connector ${authorizeConnectorId}
` : ''
408 if (authorizeConnectorIdDefined
) {
409 chargingStation
.getConnectorStatus(authorizeConnectorId
).idTagAuthorized
= false;
410 delete chargingStation
.getConnectorStatus(authorizeConnectorId
)?.authorizeIdTag
;
413 `${chargingStation.logPrefix()} IdTag '${requestPayload.idTag}' rejected with status '${
414 payload.idTagInfo.status
415 }'${authorizeConnectorIdDefined ? ` on connector ${authorizeConnectorId}` : ''}`
420 private async handleResponseStartTransaction(
421 chargingStation: ChargingStation,
422 payload: OCPP16StartTransactionResponse,
423 requestPayload: OCPP16StartTransactionRequest
425 const connectorId = requestPayload.connectorId;
427 let transactionConnectorId: number;
428 for (const id of chargingStation.connectors.keys()) {
429 if (id > 0 && id === connectorId) {
430 transactionConnectorId = id;
434 if (Utils.isNullOrUndefined(transactionConnectorId)) {
436 `${chargingStation.logPrefix()} Trying to start a transaction on a non existing connector Id ${connectorId.toString()}
`
441 chargingStation.getConnectorStatus(connectorId)?.transactionRemoteStarted === true &&
442 chargingStation.getAuthorizeRemoteTxRequests() === true &&
443 chargingStation.getLocalAuthListEnabled() === true &&
444 chargingStation.hasAuthorizedTags() &&
445 chargingStation.getConnectorStatus(connectorId)?.idTagLocalAuthorized === false
448 `${chargingStation.logPrefix()} Trying to start a transaction
with a not local authorized idTag $
{
449 chargingStation
.getConnectorStatus(connectorId
)?.localAuthorizeIdTag
450 } on connector Id ${connectorId.toString()}
`
452 await this.resetConnectorOnStartTransactionError(chargingStation, connectorId);
456 chargingStation.getConnectorStatus(connectorId)?.transactionRemoteStarted === true &&
457 chargingStation.getAuthorizeRemoteTxRequests() === true &&
458 chargingStation.getMustAuthorizeAtRemoteStart() === true &&
459 chargingStation.getConnectorStatus(connectorId)?.idTagLocalAuthorized === false &&
460 chargingStation.getConnectorStatus(connectorId)?.idTagAuthorized === false
463 `${chargingStation.logPrefix()} Trying to start a transaction
with a not authorized idTag $
{
464 chargingStation
.getConnectorStatus(connectorId
)?.authorizeIdTag
465 } on connector Id ${connectorId.toString()}
`
467 await this.resetConnectorOnStartTransactionError(chargingStation, connectorId);
471 chargingStation.getConnectorStatus(connectorId)?.idTagAuthorized &&
472 chargingStation.getConnectorStatus(connectorId)?.authorizeIdTag !== requestPayload.idTag
475 `${chargingStation.logPrefix()} Trying to start a transaction
with an idTag $
{
477 } different from the authorize request one $
{
478 chargingStation
.getConnectorStatus(connectorId
)?.authorizeIdTag
479 } on connector Id ${connectorId.toString()}
`
481 await this.resetConnectorOnStartTransactionError(chargingStation, connectorId);
485 chargingStation.getConnectorStatus(connectorId)?.idTagLocalAuthorized &&
486 chargingStation.getConnectorStatus(connectorId)?.localAuthorizeIdTag !== requestPayload.idTag
489 `${chargingStation.logPrefix()} Trying to start a transaction
with an idTag $
{
491 } different from the local authorized one $
{
492 chargingStation
.getConnectorStatus(connectorId
)?.localAuthorizeIdTag
493 } on connector Id ${connectorId.toString()}
`
495 await this.resetConnectorOnStartTransactionError(chargingStation, connectorId);
498 if (chargingStation.getConnectorStatus(connectorId)?.transactionStarted === true) {
500 `${chargingStation.logPrefix()} Trying to start a transaction on an already used connector ${connectorId.toString()}
: %j
`,
501 chargingStation.getConnectorStatus(connectorId)
506 chargingStation.getConnectorStatus(connectorId)?.status !==
507 OCPP16ChargePointStatus.Available &&
508 chargingStation.getConnectorStatus(connectorId)?.status !== OCPP16ChargePointStatus.Preparing
511 `${chargingStation.logPrefix()} Trying to start a transaction on connector ${connectorId.toString()}
with status $
{
512 chargingStation
.getConnectorStatus(connectorId
)?.status
517 // if (!Number.isInteger(payload.transactionId)) {
519 // `${chargingStation.logPrefix()} Trying to start a transaction on connector ${connectorId.toString()}
with a non integer transaction Id $
{
520 // payload.transactionId
521 // }, converting to integer`
523 // payload.transactionId = Utils.convertToInt(payload.transactionId);
526 if (payload
.idTagInfo
?.status === OCPP16AuthorizationStatus
.ACCEPTED
) {
527 chargingStation
.getConnectorStatus(connectorId
).transactionStarted
= true;
528 chargingStation
.getConnectorStatus(connectorId
).transactionId
= payload
.transactionId
;
529 chargingStation
.getConnectorStatus(connectorId
).transactionIdTag
= requestPayload
.idTag
;
530 chargingStation
.getConnectorStatus(
532 ).transactionEnergyActiveImportRegisterValue
= 0;
533 chargingStation
.getConnectorStatus(connectorId
).transactionBeginMeterValue
=
534 OCPP16ServiceUtils
.buildTransactionBeginMeterValue(
537 requestPayload
.meterStart
539 chargingStation
.getBeginEndMeterValues() &&
540 (await chargingStation
.ocppRequestService
.requestHandler
<
541 OCPP16MeterValuesRequest
,
542 OCPP16MeterValuesResponse
543 >(chargingStation
, OCPP16RequestCommand
.METER_VALUES
, {
545 transactionId
: payload
.transactionId
,
546 meterValue
: [chargingStation
.getConnectorStatus(connectorId
).transactionBeginMeterValue
],
548 await chargingStation
.ocppRequestService
.requestHandler
<
549 OCPP16StatusNotificationRequest
,
550 OCPP16StatusNotificationResponse
551 >(chargingStation
, OCPP16RequestCommand
.STATUS_NOTIFICATION
, {
553 status: OCPP16ChargePointStatus
.Charging
,
554 errorCode
: OCPP16ChargePointErrorCode
.NO_ERROR
,
556 chargingStation
.getConnectorStatus(connectorId
).status = OCPP16ChargePointStatus
.Charging
;
558 `${chargingStation.logPrefix()} Transaction ${payload.transactionId.toString()} STARTED on ${
559 chargingStation.stationInfo.chargingStationId
560 }#${connectorId.toString()} for idTag '${requestPayload.idTag}'`
562 if (chargingStation
.stationInfo
.powerSharedByConnectors
) {
563 chargingStation
.powerDivider
++;
565 const configuredMeterValueSampleInterval
=
566 ChargingStationConfigurationUtils
.getConfigurationKey(
568 OCPP16StandardParametersKey
.MeterValueSampleInterval
570 chargingStation
.startMeterValues(
572 configuredMeterValueSampleInterval
573 ? Utils
.convertToInt(configuredMeterValueSampleInterval
.value
) * 1000
574 : Constants
.DEFAULT_METER_VALUES_INTERVAL
578 `${chargingStation.logPrefix()} Starting transaction id ${payload.transactionId.toString()} REJECTED with status '${
579 payload.idTagInfo?.status
580 }', idTag '${requestPayload.idTag}'`
582 await this.resetConnectorOnStartTransactionError(chargingStation
, connectorId
);
586 private async resetConnectorOnStartTransactionError(
587 chargingStation
: ChargingStation
,
590 chargingStation
.resetConnectorStatus(connectorId
);
592 chargingStation
.getConnectorStatus(connectorId
)?.status !== OCPP16ChargePointStatus
.Available
594 await chargingStation
.ocppRequestService
.requestHandler
<
595 OCPP16StatusNotificationRequest
,
596 OCPP16StatusNotificationResponse
597 >(chargingStation
, OCPP16RequestCommand
.STATUS_NOTIFICATION
, {
599 status: OCPP16ChargePointStatus
.Available
,
600 errorCode
: OCPP16ChargePointErrorCode
.NO_ERROR
,
602 chargingStation
.getConnectorStatus(connectorId
).status = OCPP16ChargePointStatus
.Available
;
606 private async handleResponseStopTransaction(
607 chargingStation
: ChargingStation
,
608 payload
: OCPP16StopTransactionResponse
,
609 requestPayload
: OCPP16StopTransactionRequest
611 const transactionConnectorId
= chargingStation
.getConnectorIdByTransactionId(
612 requestPayload
.transactionId
614 if (Utils
.isNullOrUndefined(transactionConnectorId
)) {
616 `${chargingStation.logPrefix()} Trying to stop a non existing transaction ${requestPayload.transactionId.toString()}`
620 chargingStation
.getBeginEndMeterValues() === true &&
621 chargingStation
.getOcppStrictCompliance() === false &&
622 chargingStation
.getOutOfOrderEndMeterValues() === true &&
623 (await chargingStation
.ocppRequestService
.requestHandler
<
624 OCPP16MeterValuesRequest
,
625 OCPP16MeterValuesResponse
626 >(chargingStation
, OCPP16RequestCommand
.METER_VALUES
, {
627 connectorId
: transactionConnectorId
,
628 transactionId
: requestPayload
.transactionId
,
630 OCPP16ServiceUtils
.buildTransactionEndMeterValue(
632 transactionConnectorId
,
633 requestPayload
.meterStop
638 chargingStation
.isChargingStationAvailable() === false ||
639 chargingStation
.isConnectorAvailable(transactionConnectorId
) === false
641 await chargingStation
.ocppRequestService
.requestHandler
<
642 OCPP16StatusNotificationRequest
,
643 OCPP16StatusNotificationResponse
644 >(chargingStation
, OCPP16RequestCommand
.STATUS_NOTIFICATION
, {
645 connectorId
: transactionConnectorId
,
646 status: OCPP16ChargePointStatus
.Unavailable
,
647 errorCode
: OCPP16ChargePointErrorCode
.NO_ERROR
,
649 chargingStation
.getConnectorStatus(transactionConnectorId
).status =
650 OCPP16ChargePointStatus
.Unavailable
;
652 await chargingStation
.ocppRequestService
.requestHandler
<
653 OCPP16BootNotificationRequest
,
654 OCPP16BootNotificationResponse
655 >(chargingStation
, OCPP16RequestCommand
.STATUS_NOTIFICATION
, {
656 connectorId
: transactionConnectorId
,
657 status: OCPP16ChargePointStatus
.Available
,
658 errorCode
: OCPP16ChargePointErrorCode
.NO_ERROR
,
660 chargingStation
.getConnectorStatus(transactionConnectorId
).status =
661 OCPP16ChargePointStatus
.Available
;
663 if (chargingStation
.stationInfo
.powerSharedByConnectors
) {
664 chargingStation
.powerDivider
--;
666 chargingStation
.resetConnectorStatus(transactionConnectorId
);
667 const logMsg
= `${chargingStation.logPrefix()} Transaction ${requestPayload.transactionId.toString()} STOPPED on ${
668 chargingStation.stationInfo.chargingStationId
669 }#${transactionConnectorId?.toString()} with status '${
670 payload.idTagInfo?.status ?? 'undefined'
673 Utils
.isNullOrUndefined(payload
.idTagInfo
) ||
674 payload
.idTagInfo
?.status === OCPP16AuthorizationStatus
.ACCEPTED