ATG: unify start/stop on connector API

Signed-off-by: Jérôme Benoit <jerome.benoit@piment-noir.org>

diff --git a/src/charging-station/AutomaticTransactionGenerator.ts b/src/charging-station/AutomaticTransactionGenerator.ts
index 5fcf83a6d2b345a7444099362a50be0f76fcfa62..7645e27e77d96e491a5c916becc7cbca2950c93e 100644 (file)
--- a/src/charging-station/AutomaticTransactionGenerator.ts
+++ b/src/charging-station/AutomaticTransactionGenerator.ts
@@ -43,10 +43,7 @@ export default class AutomaticTransactionGenerator {
     for (const connector in this.chargingStation.connectors) {
       const connectorId = Utils.convertToInt(connector);
       if (connectorId > 0) {
-        // Avoid hogging the event loop with a busy loop
-        setImmediate(() => {
-          this.startConnector(connectorId).catch(() => { /* This is intentional */ });
-        });
+        this.startConnector(connectorId);
       }
     }
   }
@@ -60,7 +57,7 @@ export default class AutomaticTransactionGenerator {
     }
   }
 
-  private async startConnector(connectorId: number): Promise<void> {
+  private async internalStartConnector(connectorId: number): Promise<void> {
     this.initStartConnectorStatus(connectorId);
     logger.info(this.logPrefix(connectorId) + ' started on connector and will run for ' + Utils.formatDurationMilliSeconds(this.connectorsStatus.get(connectorId).stopDate.getTime() - this.connectorsStatus.get(connectorId).startDate.getTime()));
     while (this.connectorsStatus.get(connectorId).start) {
@@ -124,6 +121,13 @@ export default class AutomaticTransactionGenerator {
     logger.debug(`${this.logPrefix(connectorId)} connector status %j`, this.connectorsStatus.get(connectorId));
   }
 
+  private startConnector(connectorId: number): void {
+    // Avoid hogging the event loop with a busy loop
+    setImmediate(() => {
+      this.internalStartConnector(connectorId).catch(() => { /* This is intentional */ });
+    });
+  }
+
   private stopConnector(connectorId: number): void {
     this.connectorsStatus.set(connectorId, { ...this.connectorsStatus.get(connectorId), start: false });
   }