1 // Partial Copyright Jerome Benoit. 2021. All Rights Reserved.
3 import { AvailabilityType
, BootNotificationRequest
, CachedRequest
, IncomingRequest
, IncomingRequestCommand
, RequestCommand
} from
'../types/ocpp/Requests';
4 import { BootNotificationResponse
, RegistrationStatus
} from
'../types/ocpp/Responses';
5 import ChargingStationConfiguration
, { ConfigurationKey
} from
'../types/ChargingStationConfiguration';
6 import ChargingStationTemplate
, { CurrentType
, PowerUnits
, Voltage
} from
'../types/ChargingStationTemplate';
7 import { ConnectorPhaseRotation
, StandardParametersKey
, SupportedFeatureProfiles
} from
'../types/ocpp/Configuration';
8 import { ConnectorStatus
, SampledValueTemplate
} from
'../types/Connectors';
9 import { MeterValueMeasurand
, MeterValuePhase
} from
'../types/ocpp/MeterValues';
10 import { WSError
, WebSocketCloseEventStatusCode
} from
'../types/WebSocket';
11 import WebSocket
, { ClientOptions
, Data
, OPEN
} from
'ws';
13 import AutomaticTransactionGenerator from
'./AutomaticTransactionGenerator';
14 import { ChargePointStatus
} from
'../types/ocpp/ChargePointStatus';
15 import { ChargingProfile
} from
'../types/ocpp/ChargingProfile';
16 import ChargingStationInfo from
'../types/ChargingStationInfo';
17 import { ClientRequestArgs
} from
'http';
18 import Configuration from
'../utils/Configuration';
19 import Constants from
'../utils/Constants';
20 import { ErrorType
} from
'../types/ocpp/ErrorType';
21 import FileUtils from
'../utils/FileUtils';
22 import { MessageType
} from
'../types/ocpp/MessageType';
23 import OCPP16IncomingRequestService from
'./ocpp/1.6/OCPP16IncomingRequestService';
24 import OCPP16RequestService from
'./ocpp/1.6/OCPP16RequestService';
25 import OCPP16ResponseService from
'./ocpp/1.6/OCPP16ResponseService';
26 import OCPPError from
'./ocpp/OCPPError';
27 import OCPPIncomingRequestService from
'./ocpp/OCPPIncomingRequestService';
28 import OCPPRequestService from
'./ocpp/OCPPRequestService';
29 import { OCPPVersion
} from
'../types/ocpp/OCPPVersion';
30 import PerformanceStatistics from
'../performance/PerformanceStatistics';
31 import { StopTransactionReason
} from
'../types/ocpp/Transaction';
32 import { URL
} from
'url';
33 import Utils from
'../utils/Utils';
34 import crypto from
'crypto';
36 import logger from
'../utils/Logger';
37 import path from
'path';
39 export default class ChargingStation
{
40 public readonly stationTemplateFile
: string;
41 public authorizedTags
: string[];
42 public stationInfo
!: ChargingStationInfo
;
43 public readonly connectors
: Map
<number, ConnectorStatus
>;
44 public configuration
!: ChargingStationConfiguration
;
45 public wsConnection
!: WebSocket
;
46 public readonly requests
: Map
<string, CachedRequest
>;
47 public performanceStatistics
!: PerformanceStatistics
;
48 public heartbeatSetInterval
!: NodeJS
.Timeout
;
49 public ocppRequestService
!: OCPPRequestService
;
50 private readonly index
: number;
51 private bootNotificationRequest
!: BootNotificationRequest
;
52 private bootNotificationResponse
!: BootNotificationResponse
| null;
53 private connectorsConfigurationHash
!: string;
54 private ocppIncomingRequestService
!: OCPPIncomingRequestService
;
55 private readonly messageBuffer
: Set
<string>;
56 private wsConnectionUrl
!: URL
;
57 private wsConnectionRestarted
: boolean;
58 private stopped
: boolean;
59 private autoReconnectRetryCount
: number;
60 private automaticTransactionGenerator
!: AutomaticTransactionGenerator
;
61 private webSocketPingSetInterval
!: NodeJS
.Timeout
;
63 constructor(index
: number, stationTemplateFile
: string) {
65 this.stationTemplateFile
= stationTemplateFile
;
66 this.connectors
= new Map
<number, ConnectorStatus
>();
70 this.wsConnectionRestarted
= false;
71 this.autoReconnectRetryCount
= 0;
73 this.requests
= new Map
<string, CachedRequest
>();
74 this.messageBuffer
= new Set
<string>();
76 this.authorizedTags
= this.getAuthorizedTags();
79 public logPrefix(): string {
80 return Utils
.logPrefix(` ${this.stationInfo.chargingStationId} |`);
83 public getBootNotificationRequest(): BootNotificationRequest
{
84 return this.bootNotificationRequest
;
87 public getRandomIdTag(): string {
88 const index
= Math.floor(Utils
.secureRandom() * this.authorizedTags
.length
);
89 return this.authorizedTags
[index
];
92 public hasAuthorizedTags(): boolean {
93 return !Utils
.isEmptyArray(this.authorizedTags
);
96 public getEnableStatistics(): boolean | undefined {
97 return !Utils
.isUndefined(this.stationInfo
.enableStatistics
) ? this.stationInfo
.enableStatistics
: true;
100 public getMayAuthorizeAtRemoteStart(): boolean | undefined {
101 return this.stationInfo
.mayAuthorizeAtRemoteStart
?? true;
104 public getNumberOfPhases(): number | undefined {
105 switch (this.getCurrentOutType()) {
107 return !Utils
.isUndefined(this.stationInfo
.numberOfPhases
) ? this.stationInfo
.numberOfPhases
: 3;
113 public isWebSocketConnectionOpened(): boolean {
114 return this.wsConnection
?.readyState
=== OPEN
;
117 public isRegistered(): boolean {
118 return this.bootNotificationResponse
?.status === RegistrationStatus
.ACCEPTED
;
121 public isChargingStationAvailable(): boolean {
122 return this.getConnectorStatus(0).availability
=== AvailabilityType
.OPERATIVE
;
125 public isConnectorAvailable(id
: number): boolean {
126 return this.getConnectorStatus(id
).availability
=== AvailabilityType
.OPERATIVE
;
129 public getNumberOfConnectors(): number {
130 return this.connectors
.get(0) ? this.connectors
.size
- 1 : this.connectors
.size
;
133 public getConnectorStatus(id
: number): ConnectorStatus
{
134 return this.connectors
.get(id
);
137 public getCurrentOutType(): CurrentType
| undefined {
138 return this.stationInfo
.currentOutType
?? CurrentType
.AC
;
141 public getVoltageOut(): number | undefined {
142 const errMsg
= `${this.logPrefix()} Unknown ${this.getCurrentOutType()} currentOutType in template file ${this.stationTemplateFile}, cannot define default voltage out`;
143 let defaultVoltageOut
: number;
144 switch (this.getCurrentOutType()) {
146 defaultVoltageOut
= Voltage
.VOLTAGE_230
;
149 defaultVoltageOut
= Voltage
.VOLTAGE_400
;
152 logger
.error(errMsg
);
153 throw new Error(errMsg
);
155 return !Utils
.isUndefined(this.stationInfo
.voltageOut
) ? this.stationInfo
.voltageOut
: defaultVoltageOut
;
158 public getTransactionIdTag(transactionId
: number): string | undefined {
159 for (const connectorId
of this.connectors
.keys()) {
160 if (connectorId
> 0 && this.getConnectorStatus(connectorId
).transactionId
=== transactionId
) {
161 return this.getConnectorStatus(connectorId
).transactionIdTag
;
166 public getOutOfOrderEndMeterValues(): boolean {
167 return this.stationInfo
.outOfOrderEndMeterValues
?? false;
170 public getBeginEndMeterValues(): boolean {
171 return this.stationInfo
.beginEndMeterValues
?? false;
174 public getMeteringPerTransaction(): boolean {
175 return this.stationInfo
.meteringPerTransaction
?? true;
178 public getTransactionDataMeterValues(): boolean {
179 return this.stationInfo
.transactionDataMeterValues
?? false;
182 public getMainVoltageMeterValues(): boolean {
183 return this.stationInfo
.mainVoltageMeterValues
?? true;
186 public getPhaseLineToLineVoltageMeterValues(): boolean {
187 return this.stationInfo
.phaseLineToLineVoltageMeterValues
?? false;
190 public getEnergyActiveImportRegisterByTransactionId(transactionId
: number): number | undefined {
191 if (this.getMeteringPerTransaction()) {
192 for (const connectorId
of this.connectors
.keys()) {
193 if (connectorId
> 0 && this.getConnectorStatus(connectorId
).transactionId
=== transactionId
) {
194 return this.getConnectorStatus(connectorId
).transactionEnergyActiveImportRegisterValue
;
198 for (const connectorId
of this.connectors
.keys()) {
199 if (connectorId
> 0 && this.getConnectorStatus(connectorId
).transactionId
=== transactionId
) {
200 return this.getConnectorStatus(connectorId
).energyActiveImportRegisterValue
;
205 public getEnergyActiveImportRegisterByConnectorId(connectorId
: number): number | undefined {
206 if (this.getMeteringPerTransaction()) {
207 return this.getConnectorStatus(connectorId
).transactionEnergyActiveImportRegisterValue
;
209 return this.getConnectorStatus(connectorId
).energyActiveImportRegisterValue
;
212 public getAuthorizeRemoteTxRequests(): boolean {
213 const authorizeRemoteTxRequests
= this.getConfigurationKey(StandardParametersKey
.AuthorizeRemoteTxRequests
);
214 return authorizeRemoteTxRequests
? Utils
.convertToBoolean(authorizeRemoteTxRequests
.value
) : false;
217 public getLocalAuthListEnabled(): boolean {
218 const localAuthListEnabled
= this.getConfigurationKey(StandardParametersKey
.LocalAuthListEnabled
);
219 return localAuthListEnabled
? Utils
.convertToBoolean(localAuthListEnabled
.value
) : false;
222 public restartWebSocketPing(): void {
223 // Stop WebSocket ping
224 this.stopWebSocketPing();
225 // Start WebSocket ping
226 this.startWebSocketPing();
229 public getSampledValueTemplate(connectorId
: number, measurand
: MeterValueMeasurand
= MeterValueMeasurand
.ENERGY_ACTIVE_IMPORT_REGISTER
,
230 phase
?: MeterValuePhase
): SampledValueTemplate
| undefined {
231 if (!Constants
.SUPPORTED_MEASURANDS
.includes(measurand
)) {
232 logger
.warn(`${this.logPrefix()} Trying to get unsupported MeterValues measurand '${measurand}' ${phase ? `on phase ${phase} ` : ''}in template on connectorId ${connectorId}
`);
235 if (measurand !== MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER && !this.getConfigurationKey(StandardParametersKey.MeterValuesSampledData).value.includes(measurand)) {
236 logger.debug(`${this.logPrefix()} Trying to get MeterValues measurand
'${measurand}' ${phase ? `on phase ${phase}
` : ''}in template on connectorId ${connectorId} not found in '${StandardParametersKey.MeterValuesSampledData}' OCPP parameter`);
239 const sampledValueTemplates
: SampledValueTemplate
[] = this.getConnectorStatus(connectorId
).MeterValues
;
240 for (let index
= 0; !Utils
.isEmptyArray(sampledValueTemplates
) && index
< sampledValueTemplates
.length
; index
++) {
241 if (!Constants
.SUPPORTED_MEASURANDS
.includes(sampledValueTemplates
[index
]?.measurand
?? MeterValueMeasurand
.ENERGY_ACTIVE_IMPORT_REGISTER
)) {
242 logger
.warn(`${this.logPrefix()} Unsupported MeterValues measurand '${measurand}' ${phase ? `on phase ${phase} ` : ''}in template on connectorId ${connectorId}
`);
243 } else if (phase && sampledValueTemplates[index]?.phase === phase && sampledValueTemplates[index]?.measurand === measurand
244 && this.getConfigurationKey(StandardParametersKey.MeterValuesSampledData).value.includes(measurand)) {
245 return sampledValueTemplates[index];
246 } else if (!phase && !sampledValueTemplates[index].phase && sampledValueTemplates[index]?.measurand === measurand
247 && this.getConfigurationKey(StandardParametersKey.MeterValuesSampledData).value.includes(measurand)) {
248 return sampledValueTemplates[index];
249 } else if (measurand === MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER
250 && (!sampledValueTemplates[index].measurand || sampledValueTemplates[index].measurand === measurand)) {
251 return sampledValueTemplates[index];
254 if (measurand === MeterValueMeasurand.ENERGY_ACTIVE_IMPORT_REGISTER) {
255 const errorMsg = `${this.logPrefix()} Missing MeterValues
for default measurand
'${measurand}' in template on connectorId ${connectorId}
`;
256 logger.error(errorMsg);
257 throw new Error(errorMsg);
259 logger.debug(`${this.logPrefix()} No MeterValues
for measurand
'${measurand}' ${phase ? `on phase ${phase}
` : ''}in template on connectorId ${connectorId}`);
262 public getAutomaticTransactionGeneratorRequireAuthorize(): boolean {
263 return this.stationInfo
.AutomaticTransactionGenerator
.requireAuthorize
?? true;
266 public startHeartbeat(): void {
267 if (this.getHeartbeatInterval() && this.getHeartbeatInterval() > 0 && !this.heartbeatSetInterval
) {
268 // eslint-disable-next-line @typescript-eslint/no-misused-promises
269 this.heartbeatSetInterval
= setInterval(async (): Promise
<void> => {
270 await this.ocppRequestService
.sendHeartbeat();
271 }, this.getHeartbeatInterval());
272 logger
.info(this.logPrefix() + ' Heartbeat started every ' + Utils
.formatDurationMilliSeconds(this.getHeartbeatInterval()));
273 } else if (this.heartbeatSetInterval
) {
274 logger
.info(this.logPrefix() + ' Heartbeat already started every ' + Utils
.formatDurationMilliSeconds(this.getHeartbeatInterval()));
276 logger
.error(`${this.logPrefix()} Heartbeat interval set to ${this.getHeartbeatInterval() ? Utils.formatDurationMilliSeconds(this.getHeartbeatInterval()) : this.getHeartbeatInterval()}, not starting the heartbeat`);
280 public restartHeartbeat(): void {
282 this.stopHeartbeat();
284 this.startHeartbeat();
287 public startMeterValues(connectorId
: number, interval
: number): void {
288 if (connectorId
=== 0) {
289 logger
.error(`${this.logPrefix()} Trying to start MeterValues on connector Id ${connectorId.toString()}`);
292 if (!this.getConnectorStatus(connectorId
)) {
293 logger
.error(`${this.logPrefix()} Trying to start MeterValues on non existing connector Id ${connectorId.toString()}`);
296 if (!this.getConnectorStatus(connectorId
)?.transactionStarted
) {
297 logger
.error(`${this.logPrefix()} Trying to start MeterValues on connector Id ${connectorId} with no transaction started`);
299 } else if (this.getConnectorStatus(connectorId
)?.transactionStarted
&& !this.getConnectorStatus(connectorId
)?.transactionId
) {
300 logger
.error(`${this.logPrefix()} Trying to start MeterValues on connector Id ${connectorId} with no transaction id`);
304 // eslint-disable-next-line @typescript-eslint/no-misused-promises
305 this.getConnectorStatus(connectorId
).transactionSetInterval
= setInterval(async (): Promise
<void> => {
306 await this.ocppRequestService
.sendMeterValues(connectorId
, this.getConnectorStatus(connectorId
).transactionId
, interval
);
309 logger
.error(`${this.logPrefix()} Charging station ${StandardParametersKey.MeterValueSampleInterval} configuration set to ${interval ? Utils.formatDurationMilliSeconds(interval) : interval}, not sending MeterValues`);
313 public start(): void {
314 if (this.getEnableStatistics()) {
315 this.performanceStatistics
.start();
317 this.openWSConnection();
318 // Monitor authorization file
319 this.startAuthorizationFileMonitoring();
320 // Monitor station template file
321 this.startStationTemplateFileMonitoring();
322 // Handle WebSocket message
323 this.wsConnection
.on('message', this.onMessage
.bind(this));
324 // Handle WebSocket error
325 this.wsConnection
.on('error', this.onError
.bind(this));
326 // Handle WebSocket close
327 this.wsConnection
.on('close', this.onClose
.bind(this));
328 // Handle WebSocket open
329 this.wsConnection
.on('open', this.onOpen
.bind(this));
330 // Handle WebSocket ping
331 this.wsConnection
.on('ping', this.onPing
.bind(this));
332 // Handle WebSocket pong
333 this.wsConnection
.on('pong', this.onPong
.bind(this));
336 public async stop(reason
: StopTransactionReason
= StopTransactionReason
.NONE
): Promise
<void> {
337 // Stop message sequence
338 await this.stopMessageSequence(reason
);
339 for (const connectorId
of this.connectors
.keys()) {
340 if (connectorId
> 0) {
341 await this.ocppRequestService
.sendStatusNotification(connectorId
, ChargePointStatus
.UNAVAILABLE
);
342 this.getConnectorStatus(connectorId
).status = ChargePointStatus
.UNAVAILABLE
;
345 if (this.isWebSocketConnectionOpened()) {
346 this.wsConnection
.close();
348 if (this.getEnableStatistics()) {
349 this.performanceStatistics
.stop();
351 this.bootNotificationResponse
= null;
355 public getConfigurationKey(key
: string | StandardParametersKey
, caseInsensitive
= false): ConfigurationKey
| undefined {
356 return this.configuration
.configurationKey
.find((configElement
) => {
357 if (caseInsensitive
) {
358 return configElement
.key
.toLowerCase() === key
.toLowerCase();
360 return configElement
.key
=== key
;
364 public addConfigurationKey(key
: string | StandardParametersKey
, value
: string, readonly = false, visible
= true, reboot
= false): void {
365 const keyFound
= this.getConfigurationKey(key
);
367 this.configuration
.configurationKey
.push({
375 logger
.error(`${this.logPrefix()} Trying to add an already existing configuration key: %j`, keyFound
);
379 public setConfigurationKeyValue(key
: string | StandardParametersKey
, value
: string): void {
380 const keyFound
= this.getConfigurationKey(key
);
382 const keyIndex
= this.configuration
.configurationKey
.indexOf(keyFound
);
383 this.configuration
.configurationKey
[keyIndex
].value
= value
;
385 logger
.error(`${this.logPrefix()} Trying to set a value on a non existing configuration key: %j`, { key
, value
});
389 public setChargingProfile(connectorId
: number, cp
: ChargingProfile
): void {
390 let cpReplaced
= false;
391 if (!Utils
.isEmptyArray(this.getConnectorStatus(connectorId
).chargingProfiles
)) {
392 this.getConnectorStatus(connectorId
).chargingProfiles
?.forEach((chargingProfile
: ChargingProfile
, index
: number) => {
393 if (chargingProfile
.chargingProfileId
=== cp
.chargingProfileId
394 || (chargingProfile
.stackLevel
=== cp
.stackLevel
&& chargingProfile
.chargingProfilePurpose
=== cp
.chargingProfilePurpose
)) {
395 this.getConnectorStatus(connectorId
).chargingProfiles
[index
] = cp
;
400 !cpReplaced
&& this.getConnectorStatus(connectorId
).chargingProfiles
?.push(cp
);
403 public resetConnectorStatus(connectorId
: number): void {
404 this.getConnectorStatus(connectorId
).idTagLocalAuthorized
= false;
405 this.getConnectorStatus(connectorId
).idTagAuthorized
= false;
406 this.getConnectorStatus(connectorId
).transactionRemoteStarted
= false;
407 this.getConnectorStatus(connectorId
).transactionStarted
= false;
408 delete this.getConnectorStatus(connectorId
).localAuthorizeIdTag
;
409 delete this.getConnectorStatus(connectorId
).authorizeIdTag
;
410 delete this.getConnectorStatus(connectorId
).transactionId
;
411 delete this.getConnectorStatus(connectorId
).transactionIdTag
;
412 this.getConnectorStatus(connectorId
).transactionEnergyActiveImportRegisterValue
= 0;
413 delete this.getConnectorStatus(connectorId
).transactionBeginMeterValue
;
414 this.stopMeterValues(connectorId
);
417 public bufferMessage(message
: string): void {
418 this.messageBuffer
.add(message
);
421 private flushMessageBuffer() {
422 if (this.messageBuffer
.size
> 0) {
423 this.messageBuffer
.forEach((message
) => {
424 // TODO: evaluate the need to track performance
425 this.wsConnection
.send(message
);
426 this.messageBuffer
.delete(message
);
431 private getChargingStationId(stationTemplate
: ChargingStationTemplate
): string {
432 // In case of multiple instances: add instance index to charging station id
433 const instanceIndex
= process
.env
.CF_INSTANCE_INDEX
?? 0;
434 const idSuffix
= stationTemplate
.nameSuffix
?? '';
435 return stationTemplate
.fixedName
? stationTemplate
.baseName
: stationTemplate
.baseName
+ '-' + instanceIndex
.toString() + ('000000000' + this.index
.toString()).substr(('000000000' + this.index
.toString()).length
- 4) + idSuffix
;
438 private buildStationInfo(): ChargingStationInfo
{
439 let stationTemplateFromFile
: ChargingStationTemplate
;
441 // Load template file
442 const fileDescriptor
= fs
.openSync(this.stationTemplateFile
, 'r');
443 stationTemplateFromFile
= JSON
.parse(fs
.readFileSync(fileDescriptor
, 'utf8')) as ChargingStationTemplate
;
444 fs
.closeSync(fileDescriptor
);
446 FileUtils
.handleFileException(this.logPrefix(), 'Template', this.stationTemplateFile
, error
);
448 const stationInfo
: ChargingStationInfo
= stationTemplateFromFile
?? {} as ChargingStationInfo
;
449 stationInfo
.wsOptions
= stationTemplateFromFile
?.wsOptions
?? {};
450 if (!Utils
.isEmptyArray(stationTemplateFromFile
.power
)) {
451 stationTemplateFromFile
.power
= stationTemplateFromFile
.power
as number[];
452 const powerArrayRandomIndex
= Math.floor(Utils
.secureRandom() * stationTemplateFromFile
.power
.length
);
453 stationInfo
.maxPower
= stationTemplateFromFile
.powerUnit
=== PowerUnits
.KILO_WATT
454 ? stationTemplateFromFile
.power
[powerArrayRandomIndex
] * 1000
455 : stationTemplateFromFile
.power
[powerArrayRandomIndex
];
457 stationTemplateFromFile
.power
= stationTemplateFromFile
.power
as number;
458 stationInfo
.maxPower
= stationTemplateFromFile
.powerUnit
=== PowerUnits
.KILO_WATT
459 ? stationTemplateFromFile
.power
* 1000
460 : stationTemplateFromFile
.power
;
462 delete stationInfo
.power
;
463 delete stationInfo
.powerUnit
;
464 stationInfo
.chargingStationId
= this.getChargingStationId(stationTemplateFromFile
);
465 stationInfo
.resetTime
= stationTemplateFromFile
.resetTime
? stationTemplateFromFile
.resetTime
* 1000 : Constants
.CHARGING_STATION_DEFAULT_RESET_TIME
;
469 private getOCPPVersion(): OCPPVersion
{
470 return this.stationInfo
.ocppVersion
? this.stationInfo
.ocppVersion
: OCPPVersion
.VERSION_16
;
473 private handleUnsupportedVersion(version
: OCPPVersion
) {
474 const errMsg
= `${this.logPrefix()} Unsupported protocol version '${version}' configured in template file ${this.stationTemplateFile}`;
475 logger
.error(errMsg
);
476 throw new Error(errMsg
);
479 private initialize(): void {
480 this.stationInfo
= this.buildStationInfo();
481 this.configuration
= this.getTemplateChargingStationConfiguration();
482 delete this.stationInfo
.Configuration
;
483 this.bootNotificationRequest
= {
484 chargePointModel
: this.stationInfo
.chargePointModel
,
485 chargePointVendor
: this.stationInfo
.chargePointVendor
,
486 ...!Utils
.isUndefined(this.stationInfo
.chargeBoxSerialNumberPrefix
) && { chargeBoxSerialNumber
: this.stationInfo
.chargeBoxSerialNumberPrefix
},
487 ...!Utils
.isUndefined(this.stationInfo
.firmwareVersion
) && { firmwareVersion
: this.stationInfo
.firmwareVersion
},
489 this.wsConnectionUrl
= new URL(this.getSupervisionURL().href
+ '/' + this.stationInfo
.chargingStationId
);
490 // Build connectors if needed
491 const maxConnectors
= this.getMaxNumberOfConnectors();
492 if (maxConnectors
<= 0) {
493 logger
.warn(`${this.logPrefix()} Charging station template ${this.stationTemplateFile} with ${maxConnectors} connectors`);
495 const templateMaxConnectors
= this.getTemplateMaxNumberOfConnectors();
496 if (templateMaxConnectors
<= 0) {
497 logger
.warn(`${this.logPrefix()} Charging station template ${this.stationTemplateFile} with no connector configuration`);
499 if (!this.stationInfo
.Connectors
[0]) {
500 logger
.warn(`${this.logPrefix()} Charging station template ${this.stationTemplateFile} with no connector Id 0 configuration`);
503 if (maxConnectors
> (this.stationInfo
.Connectors
[0] ? templateMaxConnectors
- 1 : templateMaxConnectors
) && !this.stationInfo
.randomConnectors
) {
504 logger
.warn(`${this.logPrefix()} Number of connectors exceeds the number of connector configurations in template ${this.stationTemplateFile}, forcing random connector configurations affectation`);
505 this.stationInfo
.randomConnectors
= true;
507 const connectorsConfigHash
= crypto
.createHash('sha256').update(JSON
.stringify(this.stationInfo
.Connectors
) + maxConnectors
.toString()).digest('hex');
508 const connectorsConfigChanged
= this.connectors
?.size
!== 0 && this.connectorsConfigurationHash
!== connectorsConfigHash
;
509 if (this.connectors
?.size
=== 0 || connectorsConfigChanged
) {
510 connectorsConfigChanged
&& (this.connectors
.clear());
511 this.connectorsConfigurationHash
= connectorsConfigHash
;
512 // Add connector Id 0
513 let lastConnector
= '0';
514 for (lastConnector
in this.stationInfo
.Connectors
) {
515 const lastConnectorId
= Utils
.convertToInt(lastConnector
);
516 if (lastConnectorId
=== 0 && this.getUseConnectorId0() && this.stationInfo
.Connectors
[lastConnector
]) {
517 this.connectors
.set(lastConnectorId
, Utils
.cloneObject
<ConnectorStatus
>(this.stationInfo
.Connectors
[lastConnector
]));
518 this.getConnectorStatus(lastConnectorId
).availability
= AvailabilityType
.OPERATIVE
;
519 if (Utils
.isUndefined(this.getConnectorStatus(lastConnectorId
)?.chargingProfiles
)) {
520 this.getConnectorStatus(lastConnectorId
).chargingProfiles
= [];
524 // Generate all connectors
525 if ((this.stationInfo
.Connectors
[0] ? templateMaxConnectors
- 1 : templateMaxConnectors
) > 0) {
526 for (let index
= 1; index
<= maxConnectors
; index
++) {
527 const randConnectorId
= this.stationInfo
.randomConnectors
? Utils
.getRandomInteger(Utils
.convertToInt(lastConnector
), 1) : index
;
528 this.connectors
.set(index
, Utils
.cloneObject
<ConnectorStatus
>(this.stationInfo
.Connectors
[randConnectorId
]));
529 this.getConnectorStatus(index
).availability
= AvailabilityType
.OPERATIVE
;
530 if (Utils
.isUndefined(this.getConnectorStatus(index
)?.chargingProfiles
)) {
531 this.getConnectorStatus(index
).chargingProfiles
= [];
536 // Avoid duplication of connectors related information
537 delete this.stationInfo
.Connectors
;
538 // Initialize transaction attributes on connectors
539 for (const connectorId
of this.connectors
.keys()) {
540 if (connectorId
> 0 && !this.getConnectorStatus(connectorId
)?.transactionStarted
) {
541 this.initializeConnectorStatus(connectorId
);
544 switch (this.getOCPPVersion()) {
545 case OCPPVersion
.VERSION_16
:
546 this.ocppIncomingRequestService
= new OCPP16IncomingRequestService(this);
547 this.ocppRequestService
= new OCPP16RequestService(this, new OCPP16ResponseService(this));
550 this.handleUnsupportedVersion(this.getOCPPVersion());
554 this.initOCPPParameters();
555 if (this.stationInfo
.autoRegister
) {
556 this.bootNotificationResponse
= {
557 currentTime
: new Date().toISOString(),
558 interval
: this.getHeartbeatInterval() / 1000,
559 status: RegistrationStatus
.ACCEPTED
562 this.stationInfo
.powerDivider
= this.getPowerDivider();
563 if (this.getEnableStatistics()) {
564 this.performanceStatistics
= new PerformanceStatistics(this.stationInfo
.chargingStationId
, this.wsConnectionUrl
);
568 private initOCPPParameters(): void {
569 if (!this.getConfigurationKey(StandardParametersKey
.SupportedFeatureProfiles
)) {
570 this.addConfigurationKey(StandardParametersKey
.SupportedFeatureProfiles
, `${SupportedFeatureProfiles.Core},${SupportedFeatureProfiles.Local_Auth_List_Management},${SupportedFeatureProfiles.Smart_Charging}`);
572 this.addConfigurationKey(StandardParametersKey
.NumberOfConnectors
, this.getNumberOfConnectors().toString(), true);
573 if (!this.getConfigurationKey(StandardParametersKey
.MeterValuesSampledData
)) {
574 this.addConfigurationKey(StandardParametersKey
.MeterValuesSampledData
, MeterValueMeasurand
.ENERGY_ACTIVE_IMPORT_REGISTER
);
576 if (!this.getConfigurationKey(StandardParametersKey
.ConnectorPhaseRotation
)) {
577 const connectorPhaseRotation
= [];
578 for (const connectorId
of this.connectors
.keys()) {
580 if (connectorId
=== 0 && this.getNumberOfPhases() === 0) {
581 connectorPhaseRotation
.push(`${connectorId}.${ConnectorPhaseRotation.RST}`);
582 } else if (connectorId
> 0 && this.getNumberOfPhases() === 0) {
583 connectorPhaseRotation
.push(`${connectorId}.${ConnectorPhaseRotation.NotApplicable}`);
585 } else if (connectorId
> 0 && this.getNumberOfPhases() === 1) {
586 connectorPhaseRotation
.push(`${connectorId}.${ConnectorPhaseRotation.NotApplicable}`);
587 } else if (connectorId
> 0 && this.getNumberOfPhases() === 3) {
588 connectorPhaseRotation
.push(`${connectorId}.${ConnectorPhaseRotation.RST}`);
591 this.addConfigurationKey(StandardParametersKey
.ConnectorPhaseRotation
, connectorPhaseRotation
.toString());
593 if (!this.getConfigurationKey(StandardParametersKey
.AuthorizeRemoteTxRequests
)) {
594 this.addConfigurationKey(StandardParametersKey
.AuthorizeRemoteTxRequests
, 'true');
596 if (!this.getConfigurationKey(StandardParametersKey
.LocalAuthListEnabled
)
597 && this.getConfigurationKey(StandardParametersKey
.SupportedFeatureProfiles
).value
.includes(SupportedFeatureProfiles
.Local_Auth_List_Management
)) {
598 this.addConfigurationKey(StandardParametersKey
.LocalAuthListEnabled
, 'false');
600 if (!this.getConfigurationKey(StandardParametersKey
.ConnectionTimeOut
)) {
601 this.addConfigurationKey(StandardParametersKey
.ConnectionTimeOut
, Constants
.DEFAULT_CONNECTION_TIMEOUT
.toString());
605 private async onOpen(): Promise
<void> {
606 logger
.info(`${this.logPrefix()} Connected to OCPP server through ${this.wsConnectionUrl.toString()}`);
607 if (!this.isRegistered()) {
608 // Send BootNotification
609 let registrationRetryCount
= 0;
611 this.bootNotificationResponse
= await this.ocppRequestService
.sendBootNotification(this.bootNotificationRequest
.chargePointModel
,
612 this.bootNotificationRequest
.chargePointVendor
, this.bootNotificationRequest
.chargeBoxSerialNumber
, this.bootNotificationRequest
.firmwareVersion
);
613 if (!this.isRegistered()) {
614 registrationRetryCount
++;
615 await Utils
.sleep(this.bootNotificationResponse
?.interval
? this.bootNotificationResponse
.interval
* 1000 : Constants
.OCPP_DEFAULT_BOOT_NOTIFICATION_INTERVAL
);
617 } while (!this.isRegistered() && (registrationRetryCount
<= this.getRegistrationMaxRetries() || this.getRegistrationMaxRetries() === -1));
619 if (this.isRegistered()) {
620 await this.startMessageSequence();
621 this.stopped
&& (this.stopped
= false);
622 if (this.wsConnectionRestarted
&& this.isWebSocketConnectionOpened()) {
623 this.flushMessageBuffer();
626 logger
.error(`${this.logPrefix()} Registration failure: max retries reached (${this.getRegistrationMaxRetries()}) or retry disabled (${this.getRegistrationMaxRetries()})`);
628 this.autoReconnectRetryCount
= 0;
629 this.wsConnectionRestarted
= false;
632 private async onClose(code
: number, reason
: string): Promise
<void> {
635 case WebSocketCloseEventStatusCode
.CLOSE_NORMAL
:
636 case WebSocketCloseEventStatusCode
.CLOSE_NO_STATUS
:
637 logger
.info(`${this.logPrefix()} WebSocket normally closed with status '${Utils.getWebSocketCloseEventStatusString(code)}' and reason '${reason}'`);
638 this.autoReconnectRetryCount
= 0;
642 logger
.error(`${this.logPrefix()} WebSocket abnormally closed with status '${Utils.getWebSocketCloseEventStatusString(code)}' and reason '${reason}'`);
643 await this.reconnect(code
);
648 private async onMessage(data
: Data
): Promise
<void> {
649 let [messageType
, messageId
, commandName
, commandPayload
, errorDetails
]: IncomingRequest
= [0, '', '' as IncomingRequestCommand
, {}, {}];
650 let responseCallback
: (payload
: Record
<string, unknown
> | string, requestPayload
: Record
<string, unknown
>) => void;
651 let rejectCallback
: (error
: OCPPError
, requestStatistic
?: boolean) => void;
652 let requestCommandName
: RequestCommand
| IncomingRequestCommand
;
653 let requestPayload
: Record
<string, unknown
>;
654 let cachedRequest
: CachedRequest
;
657 const request
= JSON
.parse(data
.toString()) as IncomingRequest
;
658 if (Utils
.isIterable(request
)) {
660 [messageType
, messageId
, commandName
, commandPayload
, errorDetails
] = request
;
662 throw new OCPPError(ErrorType
.PROTOCOL_ERROR
, 'Incoming request is not iterable', commandName
);
664 // Check the Type of message
665 switch (messageType
) {
667 case MessageType
.CALL_MESSAGE
:
668 if (this.getEnableStatistics()) {
669 this.performanceStatistics
.addRequestStatistic(commandName
, messageType
);
672 await this.ocppIncomingRequestService
.handleRequest(messageId
, commandName
, commandPayload
);
675 case MessageType
.CALL_RESULT_MESSAGE
:
677 cachedRequest
= this.requests
.get(messageId
);
678 if (Utils
.isIterable(cachedRequest
)) {
679 [responseCallback
, , , requestPayload
] = cachedRequest
;
681 throw new OCPPError(ErrorType
.PROTOCOL_ERROR
, `Cached request for message id ${messageId} response is not iterable`, commandName
);
683 if (!responseCallback
) {
685 throw new OCPPError(ErrorType
.INTERNAL_ERROR
, `Response for unknown message id ${messageId}`, commandName
);
687 responseCallback(commandName
, requestPayload
);
690 case MessageType
.CALL_ERROR_MESSAGE
:
691 cachedRequest
= this.requests
.get(messageId
);
692 if (Utils
.isIterable(cachedRequest
)) {
693 [, rejectCallback
, requestCommandName
] = cachedRequest
;
695 throw new OCPPError(ErrorType
.PROTOCOL_ERROR
, `Cached request for message id ${messageId} error response is not iterable`);
697 if (!rejectCallback
) {
699 throw new OCPPError(ErrorType
.INTERNAL_ERROR
, `Error response for unknown message id ${messageId}`, requestCommandName
);
701 rejectCallback(new OCPPError(commandName
, commandPayload
.toString(), requestCommandName
, errorDetails
));
705 errMsg
= `${this.logPrefix()} Wrong message type ${messageType}`;
706 logger
.error(errMsg
);
707 throw new OCPPError(ErrorType
.PROTOCOL_ERROR
, errMsg
);
711 logger
.error('%s Incoming OCPP message %j matching cached request %j processing error %j', this.logPrefix(), data
.toString(), this.requests
.get(messageId
), error
);
713 messageType
=== MessageType
.CALL_MESSAGE
&& await this.ocppRequestService
.sendError(messageId
, error
, commandName
);
717 private onPing(): void {
718 logger
.debug(this.logPrefix() + ' Received a WS ping (rfc6455) from the server');
721 private onPong(): void {
722 logger
.debug(this.logPrefix() + ' Received a WS pong (rfc6455) from the server');
725 private async onError(error
: WSError
): Promise
<void> {
726 logger
.error(this.logPrefix() + ' WebSocket error: %j', error
);
727 // switch (error.code) {
728 // case 'ECONNREFUSED':
729 // await this.reconnect(error);
734 private getTemplateChargingStationConfiguration(): ChargingStationConfiguration
{
735 return this.stationInfo
.Configuration
?? {} as ChargingStationConfiguration
;
738 private getAuthorizationFile(): string | undefined {
739 return this.stationInfo
.authorizationFile
&& path
.join(path
.resolve(__dirname
, '../'), 'assets', path
.basename(this.stationInfo
.authorizationFile
));
742 private getAuthorizedTags(): string[] {
743 let authorizedTags
: string[] = [];
744 const authorizationFile
= this.getAuthorizationFile();
745 if (authorizationFile
) {
747 // Load authorization file
748 const fileDescriptor
= fs
.openSync(authorizationFile
, 'r');
749 authorizedTags
= JSON
.parse(fs
.readFileSync(fileDescriptor
, 'utf8')) as string[];
750 fs
.closeSync(fileDescriptor
);
752 FileUtils
.handleFileException(this.logPrefix(), 'Authorization', authorizationFile
, error
);
755 logger
.info(this.logPrefix() + ' No authorization file given in template file ' + this.stationTemplateFile
);
757 return authorizedTags
;
760 private getUseConnectorId0(): boolean | undefined {
761 return !Utils
.isUndefined(this.stationInfo
.useConnectorId0
) ? this.stationInfo
.useConnectorId0
: true;
764 private getNumberOfRunningTransactions(): number {
766 for (const connectorId
of this.connectors
.keys()) {
767 if (connectorId
> 0 && this.getConnectorStatus(connectorId
)?.transactionStarted
) {
775 private getConnectionTimeout(): number | undefined {
776 if (this.getConfigurationKey(StandardParametersKey
.ConnectionTimeOut
)) {
777 return parseInt(this.getConfigurationKey(StandardParametersKey
.ConnectionTimeOut
).value
) ?? Constants
.DEFAULT_CONNECTION_TIMEOUT
;
779 return Constants
.DEFAULT_CONNECTION_TIMEOUT
;
782 // -1 for unlimited, 0 for disabling
783 private getAutoReconnectMaxRetries(): number | undefined {
784 if (!Utils
.isUndefined(this.stationInfo
.autoReconnectMaxRetries
)) {
785 return this.stationInfo
.autoReconnectMaxRetries
;
787 if (!Utils
.isUndefined(Configuration
.getAutoReconnectMaxRetries())) {
788 return Configuration
.getAutoReconnectMaxRetries();
794 private getRegistrationMaxRetries(): number | undefined {
795 if (!Utils
.isUndefined(this.stationInfo
.registrationMaxRetries
)) {
796 return this.stationInfo
.registrationMaxRetries
;
801 private getPowerDivider(): number {
802 let powerDivider
= this.getNumberOfConnectors();
803 if (this.stationInfo
.powerSharedByConnectors
) {
804 powerDivider
= this.getNumberOfRunningTransactions();
809 private getTemplateMaxNumberOfConnectors(): number {
810 return Object.keys(this.stationInfo
.Connectors
).length
;
813 private getMaxNumberOfConnectors(): number {
814 let maxConnectors
= 0;
815 if (!Utils
.isEmptyArray(this.stationInfo
.numberOfConnectors
)) {
816 const numberOfConnectors
= this.stationInfo
.numberOfConnectors
as number[];
817 // Distribute evenly the number of connectors
818 maxConnectors
= numberOfConnectors
[(this.index
- 1) % numberOfConnectors
.length
];
819 } else if (!Utils
.isUndefined(this.stationInfo
.numberOfConnectors
)) {
820 maxConnectors
= this.stationInfo
.numberOfConnectors
as number;
822 maxConnectors
= this.stationInfo
.Connectors
[0] ? this.getTemplateMaxNumberOfConnectors() - 1 : this.getTemplateMaxNumberOfConnectors();
824 return maxConnectors
;
827 private async startMessageSequence(): Promise
<void> {
828 // Start WebSocket ping
829 this.startWebSocketPing();
831 this.startHeartbeat();
832 // Initialize connectors status
833 for (const connectorId
of this.connectors
.keys()) {
834 if (connectorId
=== 0) {
836 } else if (!this.stopped
&& !this.getConnectorStatus(connectorId
)?.status && this.getConnectorStatus(connectorId
)?.bootStatus
) {
837 // Send status in template at startup
838 await this.ocppRequestService
.sendStatusNotification(connectorId
, this.getConnectorStatus(connectorId
).bootStatus
);
839 this.getConnectorStatus(connectorId
).status = this.getConnectorStatus(connectorId
).bootStatus
;
840 } else if (this.stopped
&& this.getConnectorStatus(connectorId
)?.status && this.getConnectorStatus(connectorId
)?.bootStatus
) {
841 // Send status in template after reset
842 await this.ocppRequestService
.sendStatusNotification(connectorId
, this.getConnectorStatus(connectorId
).bootStatus
);
843 this.getConnectorStatus(connectorId
).status = this.getConnectorStatus(connectorId
).bootStatus
;
844 } else if (!this.stopped
&& this.getConnectorStatus(connectorId
)?.status) {
845 // Send previous status at template reload
846 await this.ocppRequestService
.sendStatusNotification(connectorId
, this.getConnectorStatus(connectorId
).status);
848 // Send default status
849 await this.ocppRequestService
.sendStatusNotification(connectorId
, ChargePointStatus
.AVAILABLE
);
850 this.getConnectorStatus(connectorId
).status = ChargePointStatus
.AVAILABLE
;
854 this.startAutomaticTransactionGenerator();
857 private startAutomaticTransactionGenerator() {
858 if (this.stationInfo
.AutomaticTransactionGenerator
.enable
) {
859 if (!this.automaticTransactionGenerator
) {
860 this.automaticTransactionGenerator
= new AutomaticTransactionGenerator(this);
862 if (!this.automaticTransactionGenerator
.started
) {
863 this.automaticTransactionGenerator
.start();
868 private async stopMessageSequence(reason
: StopTransactionReason
= StopTransactionReason
.NONE
): Promise
<void> {
869 // Stop WebSocket ping
870 this.stopWebSocketPing();
872 this.stopHeartbeat();
874 if (this.stationInfo
.AutomaticTransactionGenerator
.enable
&&
875 this.automaticTransactionGenerator
&&
876 this.automaticTransactionGenerator
.started
) {
877 this.automaticTransactionGenerator
.stop();
879 for (const connectorId
of this.connectors
.keys()) {
880 if (connectorId
> 0 && this.getConnectorStatus(connectorId
)?.transactionStarted
) {
881 const transactionId
= this.getConnectorStatus(connectorId
).transactionId
;
882 await this.ocppRequestService
.sendStopTransaction(transactionId
, this.getEnergyActiveImportRegisterByTransactionId(transactionId
),
883 this.getTransactionIdTag(transactionId
), reason
);
889 private startWebSocketPing(): void {
890 const webSocketPingInterval
: number = this.getConfigurationKey(StandardParametersKey
.WebSocketPingInterval
)
891 ? Utils
.convertToInt(this.getConfigurationKey(StandardParametersKey
.WebSocketPingInterval
).value
)
893 if (webSocketPingInterval
> 0 && !this.webSocketPingSetInterval
) {
894 this.webSocketPingSetInterval
= setInterval(() => {
895 if (this.isWebSocketConnectionOpened()) {
896 this.wsConnection
.ping((): void => { /* This is intentional */ });
898 }, webSocketPingInterval
* 1000);
899 logger
.info(this.logPrefix() + ' WebSocket ping started every ' + Utils
.formatDurationSeconds(webSocketPingInterval
));
900 } else if (this.webSocketPingSetInterval
) {
901 logger
.info(this.logPrefix() + ' WebSocket ping every ' + Utils
.formatDurationSeconds(webSocketPingInterval
) + ' already started');
903 logger
.error(`${this.logPrefix()} WebSocket ping interval set to ${webSocketPingInterval ? Utils.formatDurationSeconds(webSocketPingInterval) : webSocketPingInterval}, not starting the WebSocket ping`);
907 private stopWebSocketPing(): void {
908 if (this.webSocketPingSetInterval
) {
909 clearInterval(this.webSocketPingSetInterval
);
913 private getSupervisionURL(): URL
{
914 const supervisionUrls
= Utils
.cloneObject
<string | string[]>(this.stationInfo
.supervisionURL
? this.stationInfo
.supervisionURL
: Configuration
.getSupervisionURLs());
916 if (!Utils
.isEmptyArray(supervisionUrls
)) {
917 if (Configuration
.getDistributeStationsToTenantsEqually()) {
918 indexUrl
= this.index
% supervisionUrls
.length
;
921 indexUrl
= Math.floor(Utils
.secureRandom() * supervisionUrls
.length
);
923 return new URL(supervisionUrls
[indexUrl
]);
925 return new URL(supervisionUrls
as string);
928 private getHeartbeatInterval(): number | undefined {
929 const HeartbeatInterval
= this.getConfigurationKey(StandardParametersKey
.HeartbeatInterval
);
930 if (HeartbeatInterval
) {
931 return Utils
.convertToInt(HeartbeatInterval
.value
) * 1000;
933 const HeartBeatInterval
= this.getConfigurationKey(StandardParametersKey
.HeartBeatInterval
);
934 if (HeartBeatInterval
) {
935 return Utils
.convertToInt(HeartBeatInterval
.value
) * 1000;
937 !this.stationInfo
.autoRegister
&& logger
.warn(`${this.logPrefix()} Heartbeat interval configuration key not set, using default value: ${Constants.DEFAULT_HEARTBEAT_INTERVAL}`);
938 return Constants
.DEFAULT_HEARTBEAT_INTERVAL
;
941 private stopHeartbeat(): void {
942 if (this.heartbeatSetInterval
) {
943 clearInterval(this.heartbeatSetInterval
);
947 private openWSConnection(options
: ClientOptions
& ClientRequestArgs
= this.stationInfo
.wsOptions
, forceCloseOpened
= false): void {
948 options
.handshakeTimeout
= options
?.handshakeTimeout
?? this.getConnectionTimeout() * 1000;
949 if (!Utils
.isNullOrUndefined(this.stationInfo
.supervisionUser
) && !Utils
.isNullOrUndefined(this.stationInfo
.supervisionPassword
)) {
950 options
.auth
= `${this.stationInfo.supervisionUser}:${this.stationInfo.supervisionPassword}`;
952 if (this.isWebSocketConnectionOpened() && forceCloseOpened
) {
953 this.wsConnection
.close();
956 switch (this.getOCPPVersion()) {
957 case OCPPVersion
.VERSION_16
:
958 protocol
= 'ocpp' + OCPPVersion
.VERSION_16
;
961 this.handleUnsupportedVersion(this.getOCPPVersion());
964 this.wsConnection
= new WebSocket(this.wsConnectionUrl
, protocol
, options
);
965 logger
.info(this.logPrefix() + ' Open OCPP connection to URL ' + this.wsConnectionUrl
.toString());
968 private stopMeterValues(connectorId
: number) {
969 if (this.getConnectorStatus(connectorId
)?.transactionSetInterval
) {
970 clearInterval(this.getConnectorStatus(connectorId
).transactionSetInterval
);
974 private startAuthorizationFileMonitoring(): void {
975 const authorizationFile
= this.getAuthorizationFile();
976 if (authorizationFile
) {
978 fs
.watch(authorizationFile
, (event
, filename
) => {
979 if (filename
&& event
=== 'change') {
981 logger
.debug(this.logPrefix() + ' Authorization file ' + authorizationFile
+ ' have changed, reload');
982 // Initialize authorizedTags
983 this.authorizedTags
= this.getAuthorizedTags();
985 logger
.error(this.logPrefix() + ' Authorization file monitoring error: %j', error
);
990 FileUtils
.handleFileException(this.logPrefix(), 'Authorization', authorizationFile
, error
);
993 logger
.info(this.logPrefix() + ' No authorization file given in template file ' + this.stationTemplateFile
+ '. Not monitoring changes');
997 private startStationTemplateFileMonitoring(): void {
999 fs
.watch(this.stationTemplateFile
, (event
, filename
): void => {
1000 if (filename
&& event
=== 'change') {
1002 logger
.debug(this.logPrefix() + ' Template file ' + this.stationTemplateFile
+ ' have changed, reload');
1006 if (!this.stationInfo
.AutomaticTransactionGenerator
.enable
&&
1007 this.automaticTransactionGenerator
) {
1008 this.automaticTransactionGenerator
.stop();
1010 this.startAutomaticTransactionGenerator();
1011 if (this.getEnableStatistics()) {
1012 this.performanceStatistics
.restart();
1014 this.performanceStatistics
.stop();
1016 // FIXME?: restart heartbeat and WebSocket ping when their interval values have changed
1018 logger
.error(this.logPrefix() + ' Charging station template file monitoring error: %j', error
);
1023 FileUtils
.handleFileException(this.logPrefix(), 'Template', this.stationTemplateFile
, error
);
1027 private getReconnectExponentialDelay(): boolean | undefined {
1028 return !Utils
.isUndefined(this.stationInfo
.reconnectExponentialDelay
) ? this.stationInfo
.reconnectExponentialDelay
: false;
1031 private async reconnect(code
: number): Promise
<void> {
1032 // Stop WebSocket ping
1033 this.stopWebSocketPing();
1035 this.stopHeartbeat();
1036 // Stop the ATG if needed
1037 if (this.stationInfo
.AutomaticTransactionGenerator
.enable
&&
1038 this.stationInfo
.AutomaticTransactionGenerator
.stopOnConnectionFailure
&&
1039 this.automaticTransactionGenerator
&&
1040 this.automaticTransactionGenerator
.started
) {
1041 this.automaticTransactionGenerator
.stop();
1043 if (this.autoReconnectRetryCount
< this.getAutoReconnectMaxRetries() || this.getAutoReconnectMaxRetries() === -1) {
1044 this.autoReconnectRetryCount
++;
1045 const reconnectDelay
= (this.getReconnectExponentialDelay() ? Utils
.exponentialDelay(this.autoReconnectRetryCount
) : this.getConnectionTimeout() * 1000);
1046 const reconnectTimeout
= (reconnectDelay
- 100) > 0 && reconnectDelay
;
1047 logger
.error(`${this.logPrefix()} WebSocket: connection retry in ${Utils.roundTo(reconnectDelay, 2)}ms, timeout ${reconnectTimeout}ms`);
1048 await Utils
.sleep(reconnectDelay
);
1049 logger
.error(this.logPrefix() + ' WebSocket: reconnecting try #' + this.autoReconnectRetryCount
.toString());
1050 this.openWSConnection({ ...this.stationInfo
.wsOptions
, handshakeTimeout
: reconnectTimeout
}, true);
1051 this.wsConnectionRestarted
= true;
1052 } else if (this.getAutoReconnectMaxRetries() !== -1) {
1053 logger
.error(`${this.logPrefix()} WebSocket reconnect failure: max retries reached (${this.autoReconnectRetryCount}) or retry disabled (${this.getAutoReconnectMaxRetries()})`);
1057 private initializeConnectorStatus(connectorId
: number): void {
1058 this.getConnectorStatus(connectorId
).idTagLocalAuthorized
= false;
1059 this.getConnectorStatus(connectorId
).idTagAuthorized
= false;
1060 this.getConnectorStatus(connectorId
).transactionRemoteStarted
= false;
1061 this.getConnectorStatus(connectorId
).transactionStarted
= false;
1062 this.getConnectorStatus(connectorId
).energyActiveImportRegisterValue
= 0;
1063 this.getConnectorStatus(connectorId
).transactionEnergyActiveImportRegisterValue
= 0;