Cleanups.
authorJérôme Benoit <jerome.benoit@sap.com>
Tue, 20 Oct 2020 14:58:41 +0000 (16:58 +0200)
committerJérôme Benoit <jerome.benoit@sap.com>
Tue, 20 Oct 2020 14:58:41 +0000 (16:58 +0200)
Signed-off-by: Jérôme Benoit <jerome.benoit@sap.com>
src/charging-station/AutomaticTransactionGenerator.js
src/charging-station/ChargingStation.js
src/utils/Constants.js

index 90576e9e16aaf8e0ea33e6de1ced1efde4b0e56f..6e2afe1265563a467dbd5f98ca57644263b8e31f 100644 (file)
@@ -1,4 +1,5 @@
 const logger = require('../utils/Logger');
+const Constants = require('../utils/Constants');
 const Utils = require('../utils/Utils');
 const {performance, PerformanceObserver} = require('perf_hooks');
 
@@ -68,7 +69,7 @@ class AutomaticTransactionGenerator {
         const startResponse = await startTransaction(connectorId, this);
         if (startResponse.idTagInfo.status !== 'Accepted') {
           logger.info(this._basicFormatLog(connectorId) + ' transaction rejected');
-          await Utils.sleep(2000);
+          await Utils.sleep(Constants.CHARGING_STATION_ATG_WAIT_TIME);
         } else {
           // Wait until end of transaction
           const wait = Utils.getRandomInt(this._chargingStation._stationInfo.AutomaticTransactionGenerator.maxDuration,
index f644003c139f995c846eb8e6c54dfc3c9d398a3f..397bef201e8a3febe94c8ccacce849ee6b51bab5 100644 (file)
@@ -268,7 +268,7 @@ class ChargingStation {
         await sendMeterValues(connectorID, interval, this);
       }, interval);
     } else {
-      logger.info(`${this._basicFormatLog()} Charging station MeterValueSampleInterval configuration set to ${interval}ms, not sending MeterValues`);
+      logger.error(`${this._basicFormatLog()} Charging station MeterValueSampleInterval configuration set to ${interval}ms, not sending MeterValues`);
     }
   }
 
@@ -350,7 +350,7 @@ class ChargingStation {
     }
     if (this._isSocketRestart) {
       this._basicStartMessageSequence();
-      if (this._messageQueue.length > 0) {
+      if (!Utils.isEmptyArray(this._messageQueue)) {
         this._messageQueue.forEach((message) => {
           if (this._wsConnection && this._wsConnection.readyState === WebSocket.OPEN) {
             this._wsConnection.send(message);
@@ -740,7 +740,7 @@ class ChargingStation {
   }
 
   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) {
index 38e4b221e2f9fd974ac000454115beb34939854e..ba2412c2a08d87f723c8093c1a1b960fcd9eb38e 100644 (file)
@@ -139,7 +139,8 @@ class Constants {
   static STATUS_NOTIFICATION_TIMEOUT = 500;
   static START_TRANSACTION_TIMEOUT = 500;
 
-  static CHARGING_STATION_DEFAULT_RESET_TIME = 60000 // ms;
+  static CHARGING_STATION_DEFAULT_RESET_TIME = 60000; // ms
+  static CHARGING_STATION_ATG_WAIT_TIME = 2000; // ms
 }
 
 module.exports = Constants;