X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FChargingStation.js;h=cb0cf3a5dd4bb62cb3e41a65eff663fb8cc5fc6f;hb=2d0e26f5083da9e14cdfa2fdb181a30fac93a64e;hp=be4f161380c6fad845520e4cb2b5139fe79fd621;hpb=d20c21a0906551f6d22f07688ca2cd9b10bbd84b;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/ChargingStation.js b/src/charging-station/ChargingStation.js index be4f1613..cb0cf3a5 100644 --- a/src/charging-station/ChargingStation.js +++ b/src/charging-station/ChargingStation.js @@ -15,6 +15,7 @@ class ChargingStation { this._stationTemplateFile = stationTemplateFile; this._initialize(); + this._isSocketRestart = false; this._autoReconnectRetryCount = 0; this._autoReconnectMaxRetries = Configuration.getAutoReconnectMaxRetries(); // -1 for unlimited this._autoReconnectTimeout = Configuration.getAutoReconnectTimeout() * 1000; // ms, zero for disabling @@ -22,11 +23,34 @@ class ChargingStation { this._requests = {}; this._messageQueue = []; - this._isSocketRestart = false; - this._authorizedTags = this._loadAndGetAuthorizedTags(); } + _getStationName(stationTemplate) { + return stationTemplate.fixedName ? stationTemplate.baseName : stationTemplate.baseName + '-' + ('000000000' + this._index).substr(('000000000' + this._index).length - 4); + } + + _buildStationInfo() { + let stationTemplateFromFile; + try { + // Load template file + const fileDescriptor = fs.openSync(this._stationTemplateFile, 'r'); + stationTemplateFromFile = JSON.parse(fs.readFileSync(fileDescriptor, 'utf8')); + fs.closeSync(fileDescriptor); + } catch (error) { + logger.error(this._basicFormatLog() + ' Template file loading error: ' + error); + } + const stationTemplate = stationTemplateFromFile || {}; + if (!Utils.isEmptyArray(stationTemplateFromFile.power)) { + stationTemplate.maxPower = stationTemplateFromFile.power[Math.floor(Math.random() * stationTemplateFromFile.power.length)]; + } else { + stationTemplate.maxPower = stationTemplateFromFile.power; + } + stationTemplate.name = this._getStationName(stationTemplateFromFile); + stationTemplate.resetTime = stationTemplateFromFile.resetTime ? stationTemplateFromFile.resetTime * 1000 : Constants.CHARGING_STATION_DEFAULT_RESET_TIME; + return stationTemplate; + } + _initialize() { this._stationInfo = this._buildStationInfo(); this._bootNotificationMessage = { @@ -37,6 +61,35 @@ class ChargingStation { }; this._configuration = this._getConfiguration(); this._supervisionUrl = this._getSupervisionURL(); + this._wsConnectionUrl = this._supervisionUrl + '/' + this._stationInfo.name; + // Build connectors if needed + const maxConnectors = this._getMaxConnectors(); + const connectorsConfig = Utils.cloneJSonDocument(this._stationInfo.Connectors); + const connectorsConfigLength = Utils.convertToBoolean(this._stationInfo.useConnectorId0) && Object.keys(connectorsConfig).includes('0') ? Object.keys(connectorsConfig).length : Object.keys(connectorsConfig).length - 1; + if (!this._connectors || (this._connectors && Object.keys(this._connectors).length !== connectorsConfigLength)) { + this._connectors = {}; + // Determine number of customized connectors + let lastConnector; + for (lastConnector in connectorsConfig) { + // Add connector 0, OCPP specification violation that for example KEBA have + if (Utils.convertToInt(lastConnector) === 0 && Utils.convertToBoolean(this._stationInfo.useConnectorId0) && + connectorsConfig[lastConnector]) { + this._connectors[lastConnector] = connectorsConfig[lastConnector]; + } + } + this._addConfigurationKey('NumberOfConnectors', maxConnectors, true); + // Generate all connectors + for (let index = 1; index <= maxConnectors; index++) { + const randConnectorID = Utils.convertToBoolean(this._stationInfo.randomConnectors) ? Utils.getRandomInt(lastConnector, 1) : index; + this._connectors[index] = connectorsConfig[randConnectorID]; + } + } + // Initialize transaction attributes on connectors + for (const connector in this._connectors) { + if (!this._connectors[connector].transactionStarted) { + this._initTransactionOnConnector(connector); + } + } this._statistics = new Statistics(this._stationInfo.name); this._performanceObserver = new PerformanceObserver((list) => { const entry = list.getEntries()[0]; @@ -75,36 +128,34 @@ class ChargingStation { return authorizedTags; } - _startAuthorizationFileMonitoring() { - // eslint-disable-next-line no-unused-vars - fs.watchFile(this._getAuthorizationFile(), (current, previous) => { - try { - logger.debug(this._basicFormatLog() + ' Authorization file ' + this._getAuthorizationFile() + ' have changed, reload'); - // Initialize _authorizedTags - this._authorizedTags = this._loadAndGetAuthorizedTags(); - } catch (error) { - logger.error(this._basicFormatLog() + ' Authorization file monitoring error: ' + error); - } - }); + getRandomTagId() { + const index = Math.floor(Math.random() * this._authorizedTags.length); + return this._authorizedTags[index]; } - _startStationTemplateFileMonitoring() { - // eslint-disable-next-line no-unused-vars - fs.watchFile(this._stationTemplateFile, (current, previous) => { - try { - logger.debug(this._basicFormatLog() + ' Template file ' + this._stationTemplateFile + ' have changed, reload'); - // Initialize - this._initialize(); - } catch (error) { - logger.error(this._basicFormatLog() + ' Charging station template file monitoring error: ' + error); - } - }); + hasAuthorizedTags() { + return !Utils.isEmptyArray(this._authorizedTags); + } + + _getConnector(number) { + return this._stationInfo.Connectors[number]; + } + + _getMaxConnectors() { + let maxConnectors = 0; + if (!Utils.isEmptyArray(this._stationInfo.numberOfConnectors)) { + // Get evenly the number of connectors + maxConnectors = this._stationInfo.numberOfConnectors[(this._index - 1) % this._stationInfo.numberOfConnectors.length]; + } else { + maxConnectors = this._stationInfo.numberOfConnectors; + } + return maxConnectors; } _getSupervisionURL() { const supervisionUrls = Utils.cloneJSonDocument(this._stationInfo.supervisionURL ? this._stationInfo.supervisionURL : Configuration.getSupervisionURLs()); let indexUrl = 0; - if (Array.isArray(supervisionUrls)) { + if (!Utils.isEmptyArray(supervisionUrls)) { if (Configuration.getDistributeStationToTenantEqually()) { indexUrl = this._index % supervisionUrls.length; } else { @@ -116,10 +167,6 @@ class ChargingStation { return supervisionUrls; } - _getStationName(stationTemplate) { - return stationTemplate.fixedName ? stationTemplate.baseName : stationTemplate.baseName + '-' + ('000000000' + this._index).substr(('000000000' + this._index).length - 4); - } - _getAuthorizeRemoteTxRequests() { const authorizeRemoteTxRequests = this._getConfigurationKey('AuthorizeRemoteTxRequests'); return authorizeRemoteTxRequests ? Utils.convertToBoolean(authorizeRemoteTxRequests.value) : false; @@ -130,30 +177,107 @@ class ChargingStation { return localAuthListEnabled ? Utils.convertToBoolean(localAuthListEnabled.value) : false; } - _buildStationInfo() { - let stationTemplateFromFile; - try { - // Load template file - const fileDescriptor = fs.openSync(this._stationTemplateFile, 'r'); - stationTemplateFromFile = JSON.parse(fs.readFileSync(fileDescriptor, 'utf8')); - fs.closeSync(fileDescriptor); - } catch (error) { - logger.error(this._basicFormatLog() + ' Template file loading error: ' + error); + async _basicStartMessageSequence() { + // Start heartbeat + this._startHeartbeat(this); + // Initialize connectors status + for (const connector in this._connectors) { + if (!this._connectors[connector].transactionStarted) { + if (this._connectors[connector].bootStatus) { + this.sendStatusNotificationWithTimeout(connector, this._connectors[connector].bootStatus); + } else { + this.sendStatusNotificationWithTimeout(connector, 'Available'); + } + } else { + this.sendStatusNotificationWithTimeout(connector, 'Charging'); + } } - const stationTemplate = stationTemplateFromFile || {}; - if (Array.isArray(stationTemplateFromFile.power)) { - stationTemplate.maxPower = stationTemplateFromFile.power[Math.floor(Math.random() * stationTemplateFromFile.power.length)]; + // Start the ATG + if (Utils.convertToBoolean(this._stationInfo.AutomaticTransactionGenerator.enable)) { + if (!this._automaticTransactionGeneration) { + this._automaticTransactionGeneration = new AutomaticTransactionGenerator(this); + } + if (this._automaticTransactionGeneration.timeToStop) { + this._automaticTransactionGeneration.start(); + } + } + this._statistics.start(); + } + + // eslint-disable-next-line class-methods-use-this + async _startHeartbeat(self) { + if (self._heartbeatInterval && self._heartbeatInterval > 0 && !self._heartbeatSetInterval) { + self._heartbeatSetInterval = setInterval(() => { + this.sendHeartbeat(); + }, self._heartbeatInterval); + logger.info(self._basicFormatLog() + ' Heartbeat started every ' + self._heartbeatInterval + 'ms'); } else { - stationTemplate.maxPower = stationTemplateFromFile.power; + logger.error(`${self._basicFormatLog()} Heartbeat interval set to ${self._heartbeatInterval}, not starting the heartbeat`); + } + } + + async _stopHeartbeat() { + if (this._heartbeatSetInterval) { + clearInterval(this._heartbeatSetInterval); + this._heartbeatSetInterval = null; + } + } + + _startAuthorizationFileMonitoring() { + // eslint-disable-next-line no-unused-vars + fs.watchFile(this._getAuthorizationFile(), (current, previous) => { + try { + logger.debug(this._basicFormatLog() + ' Authorization file ' + this._getAuthorizationFile() + ' have changed, reload'); + // Initialize _authorizedTags + this._authorizedTags = this._loadAndGetAuthorizedTags(); + } catch (error) { + logger.error(this._basicFormatLog() + ' Authorization file monitoring error: ' + error); + } + }); + } + + _startStationTemplateFileMonitoring() { + // eslint-disable-next-line no-unused-vars + fs.watchFile(this._stationTemplateFile, (current, previous) => { + try { + logger.debug(this._basicFormatLog() + ' Template file ' + this._stationTemplateFile + ' have changed, reload'); + // Initialize + this._initialize(); + this._addConfigurationKey('HeartBeatInterval', Utils.convertToInt(this._heartbeatInterval ? this._heartbeatInterval / 1000 : 0)); + this._addConfigurationKey('HeartbeatInterval', Utils.convertToInt(this._heartbeatInterval ? this._heartbeatInterval / 1000 : 0), false, false); + } catch (error) { + logger.error(this._basicFormatLog() + ' Charging station template file monitoring error: ' + error); + } + }); + } + + async _startMeterValues(connectorID, interval) { + if (!this._connectors[connectorID].transactionStarted) { + logger.error(`${this._basicFormatLog()} Trying to start MeterValues on connector ID ${connectorID} with no transaction started`); + return; + } else if (this._connectors[connectorID].transactionStarted && !this._connectors[connectorID].transactionId) { + logger.error(`${this._basicFormatLog()} Trying to start MeterValues on connector ID ${connectorID} with no transaction id`); + return; + } + if (interval > 0) { + this._connectors[connectorID].transactionSetInterval = setInterval(async () => { + const sendMeterValues = performance.timerify(this.sendMeterValues); + this._performanceObserver.observe({ + entryTypes: ['function'], + }); + await sendMeterValues(connectorID, interval, this); + }, interval); + } else { + logger.error(`${this._basicFormatLog()} Charging station MeterValueSampleInterval configuration set to ${interval}ms, not sending MeterValues`); } - stationTemplate.name = this._getStationName(stationTemplateFromFile); - return stationTemplate; } async start() { - this._url = this._supervisionUrl + '/' + this._stationInfo.name; - this._wsConnection = new WebSocket(this._url, 'ocpp1.6'); - logger.info(this._basicFormatLog() + ' Will communicate with ' + this._supervisionUrl); + if (!this._wsConnectionUrl) { + this._wsConnectionUrl = this._supervisionUrl + '/' + this._stationInfo.name; + } + this._wsConnection = new WebSocket(this._wsConnectionUrl, 'ocpp' + Constants.OCPP_VERSION_16); + logger.info(this._basicFormatLog() + ' Will communicate through URL ' + this._supervisionUrl); // Monitor authorization file this._startAuthorizationFileMonitoring(); // Monitor station template file @@ -170,21 +294,65 @@ class ChargingStation { this._wsConnection.on('ping', this.onPing.bind(this)); } + async stop(reason = '') { + // Stop heartbeat + await this._stopHeartbeat(); + // Stop the ATG + if (Utils.convertToBoolean(this._stationInfo.AutomaticTransactionGenerator.enable) && + this._automaticTransactionGeneration && + !this._automaticTransactionGeneration.timeToStop) { + await this._automaticTransactionGeneration.stop(reason); + } else { + for (const connector in this._connectors) { + if (this._connectors[connector].transactionStarted) { + await this.sendStopTransaction(this._connectors[connector].transactionId, reason); + } + } + } + // eslint-disable-next-line guard-for-in + for (const connector in this._connectors) { + await this.sendStatusNotification(connector, 'Unavailable'); + } + if (this._wsConnection && this._wsConnection.readyState === WebSocket.OPEN) { + await this._wsConnection.close(); + } + } + + _reconnect(error) { + logger.error(this._basicFormatLog() + ' Socket: abnormally closed', error); + // Stop the ATG if needed + if (Utils.convertToBoolean(this._stationInfo.AutomaticTransactionGenerator.enable) && + Utils.convertToBoolean(this._stationInfo.AutomaticTransactionGenerator.stopOnConnectionFailure) && + this._automaticTransactionGeneration && + !this._automaticTransactionGeneration.timeToStop) { + this._automaticTransactionGeneration.stop(); + } + // Stop heartbeat + this._stopHeartbeat(); + if (this._autoReconnectTimeout !== 0 && + (this._autoReconnectRetryCount < this._autoReconnectMaxRetries || this._autoReconnectMaxRetries === -1)) { + logger.error(`${this._basicFormatLog()} Socket: connection retry with timeout ${this._autoReconnectTimeout}ms`); + this._autoReconnectRetryCount++; + setTimeout(() => { + logger.error(this._basicFormatLog() + ' Socket: reconnecting try #' + this._autoReconnectRetryCount); + this.start(); + }, this._autoReconnectTimeout); + } else if (this._autoReconnectTimeout !== 0 || this._autoReconnectMaxRetries !== -1) { + logger.error(`${this._basicFormatLog()} Socket: max retries reached (${this._autoReconnectRetryCount}) or retry disabled (${this._autoReconnectTimeout})`); + } + } + onOpen() { - logger.info(`${this._basicFormatLog()} Is connected to server through ${this._url}`); - if (!this._heartbeatInterval) { + logger.info(`${this._basicFormatLog()} Is connected to server through ${this._wsConnectionUrl}`); + if (!this._isSocketRestart) { // Send BootNotification - try { - this.sendMessage(Utils.generateUUID(), this._bootNotificationMessage, Constants.OCPP_JSON_CALL_MESSAGE, 'BootNotification'); - } catch (error) { - logger.error(this._basicFormatLog() + ' Send boot notification error: ' + error); - } + this.sendBootNotification(); } if (this._isSocketRestart) { this._basicStartMessageSequence(); - if (this._messageQueue.length > 0) { + if (!Utils.isEmptyArray(this._messageQueue)) { this._messageQueue.forEach((message) => { - if (this._wsConnection.readyState === WebSocket.OPEN) { + if (this._wsConnection && this._wsConnection.readyState === WebSocket.OPEN) { this._wsConnection.send(message); } }); @@ -282,59 +450,27 @@ class ChargingStation { } } - // eslint-disable-next-line class-methods-use-this - async _startHeartbeat(self) { - if (self._heartbeatInterval && !self._heartbeatSetInterval) { - self._heartbeatSetInterval = setInterval(() => { - try { - const payload = { - currentTime: new Date().toISOString(), - }; - self.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'Heartbeat'); - } catch (error) { - logger.error(self._basicFormatLog() + ' Send heartbeat error: ' + error); - } - }, self._heartbeatInterval); - logger.info(self._basicFormatLog() + ' Heartbeat started every ' + self._heartbeatInterval + 'ms'); - } else { - logger.error(self._basicFormatLog() + ' Heartbeat interval undefined, not starting the heartbeat'); + sendHeartbeat() { + try { + const payload = { + currentTime: new Date().toISOString(), + }; + this.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'Heartbeat'); + } catch (error) { + logger.error(this._basicFormatLog() + ' Send Heartbeat error: ' + error); + throw error; } } - _reconnect(error) { - logger.error(this._basicFormatLog() + ' Socket: abnormally closed', error); - // Stop heartbeat - if (this._heartbeatSetInterval) { - clearInterval(this._heartbeatSetInterval); - this._heartbeatSetInterval = null; - } - // Stop the ATG if needed - if (Utils.convertToBoolean(this._stationInfo.AutomaticTransactionGenerator.enable) && - Utils.convertToBoolean(this._stationInfo.AutomaticTransactionGenerator.stopOnConnectionFailure) && - this._automaticTransactionGeneration && - !this._automaticTransactionGeneration.timeToStop) { - this._automaticTransactionGeneration.stop(); - } - if (this._autoReconnectTimeout !== 0 && - (this._autoReconnectRetryCount < this._autoReconnectMaxRetries || this._autoReconnectMaxRetries === -1)) { - logger.error(`${this._basicFormatLog()} Socket: connection retry with timeout ${this._autoReconnectTimeout}ms`); - this._autoReconnectRetryCount++; - setTimeout(() => { - logger.error(this._basicFormatLog() + ' Socket: reconnecting try #' + this._autoReconnectRetryCount); - this.start(); - }, this._autoReconnectTimeout); - } else if (this._autoReconnectTimeout !== 0 || this._autoReconnectMaxRetries !== -1) { - logger.error(`${this._basicFormatLog()} Socket: max retries reached (${this._autoReconnectRetryCount}) or retry disabled (${this._autoReconnectTimeout})`); + sendBootNotification() { + try { + this.sendMessage(Utils.generateUUID(), this._bootNotificationMessage, Constants.OCPP_JSON_CALL_MESSAGE, 'BootNotification'); + } catch (error) { + logger.error(this._basicFormatLog() + ' Send BootNotification error: ' + error); + throw error; } } - sendError(messageId, err) { - // Check exception: only OCPP error are accepted - const error = err instanceof OCPPError ? err : new OCPPError(Constants.OCPP_ERROR_INTERNAL_ERROR, err.message); - // Send error - return this.sendMessage(messageId, error, Constants.OCPP_JSON_CALL_ERROR_MESSAGE); - } - async sendStatusNotification(connectorId, status, errorCode = 'NoError') { try { const payload = { @@ -344,14 +480,121 @@ class ChargingStation { }; await this.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'StatusNotification'); } catch (error) { - logger.error(this._basicFormatLog() + ' Send status error: ' + error); + logger.error(this._basicFormatLog() + ' Send StatusNotification error: ' + error); + throw error; } } - async sendStatusNotificationWithTimeout(connectorId, status, errorCode = 'NoError', timeout = Constants.STATUS_NOTIFICATION_TIMEOUT) { + sendStatusNotificationWithTimeout(connectorId, status, errorCode = 'NoError', timeout = Constants.STATUS_NOTIFICATION_TIMEOUT) { setTimeout(() => this.sendStatusNotification(connectorId, status, errorCode), timeout); } + async sendStartTransaction(connectorID, idTag) { + try { + const payload = { + connectorId: connectorID, + idTag, + meterStart: 0, + timestamp: new Date().toISOString(), + }; + return await this.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'StartTransaction'); + } catch (error) { + logger.error(this._basicFormatLog() + ' Send StartTransaction error: ' + error); + throw error; + } + } + + sendStartTransactionWithTimeout(connectorID, idTag, timeout) { + setTimeout(() => this.sendStartTransaction(connectorID, idTag), timeout); + } + + async sendStopTransaction(transactionId, reason = '') { + try { + let payload = {}; + if (reason) { + payload = { + transactionId, + meterStop: 0, + timestamp: new Date().toISOString(), + reason, + }; + } else { + payload = { + transactionId, + meterStop: 0, + timestamp: new Date().toISOString(), + }; + } + await this.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'StopTransaction'); + } catch (error) { + logger.error(this._basicFormatLog() + ' Send StopTransaction error: ' + error); + throw error; + } + } + + // eslint-disable-next-line class-methods-use-this + async sendMeterValues(connectorID, interval, self, debug = false) { + try { + const sampledValueLcl = { + timestamp: new Date().toISOString(), + }; + const meterValuesClone = Utils.cloneJSonDocument(self._getConnector(connectorID).MeterValues); + if (!Utils.isEmptyArray(meterValuesClone)) { + sampledValueLcl.sampledValue = meterValuesClone; + } else { + sampledValueLcl.sampledValue = [meterValuesClone]; + } + for (let index = 0; index < sampledValueLcl.sampledValue.length; index++) { + const connector = self._connectors[connectorID]; + // SoC measurand + if (sampledValueLcl.sampledValue[index].measurand && sampledValueLcl.sampledValue[index].measurand === 'SoC') { + sampledValueLcl.sampledValue[index].value = Utils.getRandomInt(100); + if (sampledValueLcl.sampledValue[index].value > 100 || debug) { + logger.error(`${self._basicFormatLog()} MeterValues measurand ${sampledValueLcl.sampledValue[index].measurand ? sampledValueLcl.sampledValue[index].measurand : 'Energy.Active.Import.Register'}: connectorID ${connectorID}, transaction ${connector.transactionId}, value: ${sampledValueLcl.sampledValue[index].value}`); + } + // Voltage measurand + } else if (sampledValueLcl.sampledValue[index].measurand && sampledValueLcl.sampledValue[index].measurand === 'Voltage') { + sampledValueLcl.sampledValue[index].value = 230; + // Energy.Active.Import.Register measurand (default) + } else if (!sampledValueLcl.sampledValue[index].measurand || sampledValueLcl.sampledValue[index].measurand === 'Energy.Active.Import.Register') { + // Persist previous value in connector + const consumption = Utils.getRandomInt(self._stationInfo.maxPower / 3600000 * interval); + if (connector && connector.lastConsumptionValue >= 0) { + connector.lastConsumptionValue += consumption; + } else { + connector.lastConsumptionValue = 0; + } + const maxConsumption = self._stationInfo.maxPower * 3600 / interval; + logger.info(`${self._basicFormatLog()} MeterValues measurand ${sampledValueLcl.sampledValue[index].measurand ? sampledValueLcl.sampledValue[index].measurand : 'Energy.Active.Import.Register'}: connectorID ${connectorID}, transaction ${connector.transactionId}, value ${connector.lastConsumptionValue}`); + sampledValueLcl.sampledValue[index].value = connector.lastConsumptionValue; + if (sampledValueLcl.sampledValue[index].value > maxConsumption || debug) { + logger.error(`${self._basicFormatLog()} MeterValues measurand ${sampledValueLcl.sampledValue[index].measurand ? sampledValueLcl.sampledValue[index].measurand : 'Energy.Active.Import.Register'}: connectorID ${connectorID}, transaction ${connector.transactionId}, value: ${sampledValueLcl.sampledValue[index].value}/${maxConsumption}`); + } + // Unsupported measurand + } else { + logger.info(`${self._basicFormatLog()} Unsupported MeterValues measurand ${sampledValueLcl.sampledValue[index].measurand ? sampledValueLcl.sampledValue[index].measurand : 'Energy.Active.Import.Register'} on connectorID ${connectorID}`); + } + } + + const payload = { + connectorId: connectorID, + transactionId: self._connectors[connectorID].transactionId, + meterValue: [sampledValueLcl], + }; + await self.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'MeterValues'); + } catch (error) { + logger.error(self._basicFormatLog() + ' Send MeterValues error: ' + error); + throw error; + } + } + + sendError(messageId, err) { + // Check exception: only OCPP error are accepted + const error = err instanceof OCPPError ? err : new OCPPError(Constants.OCPP_ERROR_INTERNAL_ERROR, err.message); + // Send error + return this.sendMessage(messageId, error, Constants.OCPP_JSON_CALL_ERROR_MESSAGE); + } + sendMessage(messageId, command, messageType = Constants.OCPP_JSON_CALL_RESULT_MESSAGE, commandName = '') { // Send a message through wsConnection const self = this; @@ -381,7 +624,7 @@ class ChargingStation { break; } // Check if wsConnection is ready - if (this._wsConnection.readyState === WebSocket.OPEN) { + if (this._wsConnection && this._wsConnection.readyState === WebSocket.OPEN) { // Yes: Send Message this._wsConnection.send(messageToSend); } else { @@ -392,7 +635,7 @@ class ChargingStation { if (messageType !== Constants.OCPP_JSON_CALL_MESSAGE) { // Yes: send Ok resolve(); - } else if (this._wsConnection.readyState === WebSocket.OPEN) { + } else if (this._wsConnection && this._wsConnection.readyState === WebSocket.OPEN) { // Send timeout in case connection is open otherwise wait for ever // FIXME: Handle message on timeout setTimeout(() => rejectCallback(`Timeout for message ${messageId}`), Constants.OCPP_SOCKET_TIMEOUT); @@ -424,85 +667,37 @@ class ChargingStation { }); } - async _basicStartMessageSequence() { - // Start heartbeat - this._startHeartbeat(this); - // Build connectors - if (!this._connectors) { - this._connectors = {}; - const connectorsConfig = Utils.cloneJSonDocument(this._stationInfo.Connectors); - // Determine number of customized connectors - let lastConnector; - for (lastConnector in connectorsConfig) { - // Add connector 0, OCPP specification violation that for example KEBA have - if (Utils.convertToInt(lastConnector) === 0 && Utils.convertToBoolean(this._stationInfo.useConnectorId0) && - connectorsConfig[lastConnector]) { - this._connectors[lastConnector] = connectorsConfig[lastConnector]; - } - } - let maxConnectors = 0; - if (Array.isArray(this._stationInfo.numberOfConnectors)) { - // Generate some connectors - maxConnectors = this._stationInfo.numberOfConnectors[(this._index - 1) % this._stationInfo.numberOfConnectors.length]; - } else { - maxConnectors = this._stationInfo.numberOfConnectors; - } - this._addConfigurationKey('NumberOfConnectors', maxConnectors, true); - // Generate all connectors - for (let index = 1; index <= maxConnectors; index++) { - const randConnectorID = Utils.convertToBoolean(this._stationInfo.randomConnectors) ? Utils.getRandomInt(lastConnector, 1) : index; - this._connectors[index] = connectorsConfig[randConnectorID]; - } - } - - for (const connector in this._connectors) { - if (!this._connectors[connector].transactionStarted) { - if (this._connectors[connector].bootStatus) { - this.sendStatusNotificationWithTimeout(connector, this._connectors[connector].bootStatus); - } else { - this.sendStatusNotificationWithTimeout(connector, 'Available'); - } - } else { - this.sendStatusNotificationWithTimeout(connector, 'Charging'); - } - } - - if (Utils.convertToBoolean(this._stationInfo.AutomaticTransactionGenerator.enable)) { - if (!this._automaticTransactionGeneration) { - this._automaticTransactionGeneration = new AutomaticTransactionGenerator(this); - } - if (this._automaticTransactionGeneration.timeToStop) { - this._automaticTransactionGeneration.start(); - } + handleResponseBootNotification(payload) { + if (payload.status === 'Accepted') { + this._heartbeatInterval = payload.interval * 1000; + this._addConfigurationKey('HeartBeatInterval', Utils.convertToInt(payload.interval)); + this._addConfigurationKey('HeartbeatInterval', Utils.convertToInt(payload.interval), false, false); + this._basicStartMessageSequence(); + } else if (payload.status === 'Pending') { + logger.info(this._basicFormatLog() + ' Charging station pending on the central server'); + } else { + logger.info(this._basicFormatLog() + ' Charging station rejected by the central server'); } - this._statistics.start(); } - _resetTransactionOnConnector(connectorID) { + _initTransactionOnConnector(connectorID) { this._connectors[connectorID].transactionStarted = false; this._connectors[connectorID].transactionId = null; this._connectors[connectorID].idTag = null; this._connectors[connectorID].lastConsumptionValue = -1; - this._connectors[connectorID].lastSoC = -1; - if (this._connectors[connectorID].transactionSetInterval) { - clearInterval(this._connectors[connectorID].transactionSetInterval); - } } - handleResponseBootNotification(payload) { - if (payload.status === 'Accepted') { - this._heartbeatInterval = payload.interval * 1000; - this._addConfigurationKey('HeartBeatInterval', Utils.convertToInt(payload.interval)); - this._addConfigurationKey('HeartbeatInterval', Utils.convertToInt(payload.interval), false, false); - this._basicStartMessageSequence(); - } else { - logger.info(this._basicFormatLog() + ' Boot Notification rejected'); + _resetTransactionOnConnector(connectorID) { + this._initTransactionOnConnector(connectorID); + if (this._connectors[connectorID].transactionSetInterval) { + clearInterval(this._connectors[connectorID].transactionSetInterval); } } handleResponseStartTransaction(payload, requestPayload) { if (this._connectors[requestPayload.connectorId].transactionStarted) { - logger.debug(this._basicFormatLog() + ' Try to start a transaction on an already used connector ' + requestPayload.connectorId + ' by transaction ' + this._connectors[requestPayload.connectorId].transactionId); + logger.debug(this._basicFormatLog() + ' Try to start a transaction on an already used connector ' + requestPayload.connectorId + ': %s', this._connectors[requestPayload.connectorId]); + return; } let transactionConnectorId; @@ -521,11 +716,10 @@ class ChargingStation { this._connectors[transactionConnectorId].transactionId = payload.transactionId; this._connectors[transactionConnectorId].idTag = requestPayload.idTag; this._connectors[transactionConnectorId].lastConsumptionValue = 0; - this._connectors[transactionConnectorId].lastSoC = 0; this.sendStatusNotification(requestPayload.connectorId, 'Charging'); - logger.info(this._basicFormatLog() + ' Transaction ' + this._connectors[transactionConnectorId].transactionId + ' STARTED on ' + this._stationInfo.name + '#' + requestPayload.connectorId + ' for idTag ' + requestPayload.idTag); + logger.info(this._basicFormatLog() + ' Transaction ' + payload.transactionId + ' STARTED on ' + this._stationInfo.name + '#' + requestPayload.connectorId + ' for idTag ' + requestPayload.idTag); const configuredMeterValueSampleInterval = this._getConfigurationKey('MeterValueSampleInterval'); - this.startMeterValues(requestPayload.connectorId, + this._startMeterValues(requestPayload.connectorId, configuredMeterValueSampleInterval ? configuredMeterValueSampleInterval.value * 1000 : 60000); } else { logger.error(this._basicFormatLog() + ' Starting transaction id ' + payload.transactionId + ' REJECTED with status ' + payload.idTagInfo.status + ', idTag ' + requestPayload.idTag); @@ -548,15 +742,15 @@ class ChargingStation { } if (payload.idTagInfo && payload.idTagInfo.status === 'Accepted') { this.sendStatusNotification(transactionConnectorId, 'Available'); - logger.info(this._basicFormatLog() + ' Transaction ' + this._connectors[transactionConnectorId].transactionId + ' STOPPED on ' + this._stationInfo.name + '#' + transactionConnectorId); + logger.info(this._basicFormatLog() + ' Transaction ' + requestPayload.transactionId + ' STOPPED on ' + this._stationInfo.name + '#' + transactionConnectorId); this._resetTransactionOnConnector(transactionConnectorId); } else { - logger.error(this._basicFormatLog() + ' Stopping transaction id ' + this._connectors[transactionConnectorId].transactionId + ' REJECTED with status ' + payload.idTagInfo.status); + logger.error(this._basicFormatLog() + ' Stopping transaction id ' + requestPayload.transactionId + ' REJECTED with status ' + payload.idTagInfo.status); } } handleResponseStatusNotification(payload, requestPayload) { - logger.debug(this._basicFormatLog() + ' Status notification response received: %j to status notification request: %j', payload, requestPayload); + logger.debug(this._basicFormatLog() + ' Status notification response received: %j to StatusNotification request: %j', payload, requestPayload); } handleResponseMeterValues(payload, requestPayload) { @@ -590,6 +784,17 @@ class ChargingStation { await this.sendMessage(messageId, result, Constants.OCPP_JSON_CALL_RESULT_MESSAGE); } + async handleReset(commandPayload) { + // Simulate charging station restart + setImmediate(async () => { + await this.stop(commandPayload.type + 'Reset'); + await Utils.sleep(this._stationInfo.resetTime); + await this.start(); + }); + logger.info(`${this._basicFormatLog()} ${commandPayload.type} reset command received, simulating it. The station will be back online in ${this._stationInfo.resetTime}ms`); + return Constants.OCPP_RESPONSE_ACCEPTED; + } + _getConfigurationKey(key) { return this._configuration.configurationKey.find((configElement) => configElement.key === key); } @@ -683,10 +888,7 @@ class ChargingStation { if (triggerHeartbeatRestart) { this._heartbeatInterval = Utils.convertToInt(commandPayload.value) * 1000; // Stop heartbeat - if (this._heartbeatSetInterval) { - clearInterval(this._heartbeatSetInterval); - this._heartbeatSetInterval = null; - } + this._stopHeartbeat(); // Start heartbeat this._startHeartbeat(this); } @@ -726,115 +928,6 @@ class ChargingStation { logger.info(this._basicFormatLog() + ' Try to stop remotely a non existing transaction ' + commandPayload.transactionId); return Constants.OCPP_RESPONSE_REJECTED; } - - async sendStartTransaction(connectorID, idTag) { - try { - const payload = { - connectorId: connectorID, - idTag, - meterStart: 0, - timestamp: new Date().toISOString(), - }; - return await this.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'StartTransaction'); - } catch (error) { - logger.error(this._basicFormatLog() + ' Send start transaction error: ' + error); - throw error; - } - } - async sendStartTransactionWithTimeout(connectorID, idTag, timeout) { - setTimeout(() => this.sendStartTransaction(connectorID, idTag), timeout); - } - - async sendStopTransaction(transactionId) { - try { - const payload = { - transactionId, - meterStop: 0, - timestamp: new Date().toISOString(), - }; - await this.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'StopTransaction'); - } catch (error) { - logger.error(this._basicFormatLog() + ' Send stop transaction error: ' + error); - throw error; - } - } - - // eslint-disable-next-line class-methods-use-this - async sendMeterValues(connectorID, interval, self, debug = false) { - try { - const sampledValueLcl = { - timestamp: new Date().toISOString(), - }; - const meterValuesClone = Utils.cloneJSonDocument(self._getConnector(connectorID).MeterValues); - if (Array.isArray(meterValuesClone)) { - sampledValueLcl.sampledValue = meterValuesClone; - } else { - sampledValueLcl.sampledValue = [meterValuesClone]; - } - for (let index = 0; index < sampledValueLcl.sampledValue.length; index++) { - const connector = self._connectors[connectorID]; - if (sampledValueLcl.sampledValue[index].measurand && sampledValueLcl.sampledValue[index].measurand === 'SoC') { - sampledValueLcl.sampledValue[index].value = Utils.getRandomInt(100); - if (sampledValueLcl.sampledValue[index].value > 100 || debug) { - logger.error(`${self._basicFormatLog()} MeterValues measurand ${sampledValueLcl.sampledValue[index].measurand ? sampledValueLcl.sampledValue[index].measurand : 'Energy.Active.Import.Register'}: connectorID ${connectorID}, transaction ${connector.transactionId}, value: ${sampledValueLcl.sampledValue[index].value}`); - } - } else { - // Persist previous value in connector - const consumption = Utils.getRandomInt(self._stationInfo.maxPower / 3600000 * interval); - if (connector && connector.lastConsumptionValue >= 0) { - connector.lastConsumptionValue += consumption; - } else { - connector.lastConsumptionValue = 0; - } - const maxConsumption = self._stationInfo.maxPower * 3600 / interval; - logger.info(`${self._basicFormatLog()} MeterValues measurand ${sampledValueLcl.sampledValue[index].measurand ? sampledValueLcl.sampledValue[index].measurand : 'Energy.Active.Import.Register'}: connectorID ${connectorID}, transaction ${connector.transactionId}, value ${connector.lastConsumptionValue}`); - sampledValueLcl.sampledValue[index].value = connector.lastConsumptionValue; - if (sampledValueLcl.sampledValue[index].value > maxConsumption || debug) { - logger.error(`${self._basicFormatLog()} MeterValues measurand ${sampledValueLcl.sampledValue[index].measurand ? sampledValueLcl.sampledValue[index].measurand : 'Energy.Active.Import.Register'}: connectorID ${connectorID}, transaction ${connector.transactionId}, value: ${sampledValueLcl.sampledValue[index].value}/${maxConsumption}`); - } - } - } - - const payload = { - connectorId: connectorID, - transactionId: self._connectors[connectorID].transactionId, - meterValue: [sampledValueLcl], - }; - await self.sendMessage(Utils.generateUUID(), payload, Constants.OCPP_JSON_CALL_MESSAGE, 'MeterValues'); - } catch (error) { - logger.error(self._basicFormatLog() + ' Send MeterValues error: ' + error); - } - } - - async startMeterValues(connectorID, interval) { - if (!this._connectors[connectorID].transactionStarted) { - logger.error(`${this._basicFormatLog()} Trying to start MeterValues on connector ID ${connectorID} with no transaction started`); - return; - } else if (this._connectors[connectorID].transactionStarted && !this._connectors[connectorID].transactionId) { - logger.error(`${this._basicFormatLog()} Trying to start MeterValues on connector ID ${connectorID} with no transaction id`); - return; - } - this._connectors[connectorID].transactionSetInterval = setInterval(async () => { - const sendMeterValues = performance.timerify(this.sendMeterValues); - this._performanceObserver.observe({ - entryTypes: ['function'], - }); - await sendMeterValues(connectorID, interval, this); - }, interval); - } - - hasAuthorizedTags() { - return !Utils.isEmptyArray(this._authorizedTags); - } - - getRandomTagId() { - const index = Math.floor(Math.random() * this._authorizedTags.length); - return this._authorizedTags[index]; - } - - _getConnector(number) { - return this._stationInfo.Connectors[number]; - } } module.exports = ChargingStation;