build(simulator): silence linter

[e-mobility-charging-stations-simulator.git] / src / charging-station / AutomaticTransactionGenerator.ts

diff --git a/src/charging-station/AutomaticTransactionGenerator.ts b/src/charging-station/AutomaticTransactionGenerator.ts
index 0389526fd6a9400a90404903a360d8d607448fd6..f29945290c94c5f519a0b932418e55dd596413f2 100644 (file)
--- a/src/charging-station/AutomaticTransactionGenerator.ts
+++ b/src/charging-station/AutomaticTransactionGenerator.ts
@@ -3,7 +3,7 @@
 import { AsyncResource } from 'node:async_hooks';
 
 import type { ChargingStation } from './ChargingStation';
-import { ChargingStationUtils } from './ChargingStationUtils';
+import { checkChargingStation } from './ChargingStationUtils';
 import { IdTagsCache } from './IdTagsCache';
 import { BaseError } from '../exception';
 import { PerformanceStatistics } from '../performance';
@@ -19,7 +19,17 @@ import {
   StopTransactionReason,
   type StopTransactionResponse,
 } from '../types';
-import { Constants, Utils, logger } from '../utils';
+import {
+  Constants,
+  cloneObject,
+  formatDurationMilliSeconds,
+  getRandomInteger,
+  isNullOrUndefined,
+  logPrefix,
+  logger,
+  secureRandom,
+  sleep,
+} from '../utils';
 
 const moduleName = 'AutomaticTransactionGenerator';
 
@@ -46,21 +56,19 @@ export class AutomaticTransactionGenerator extends AsyncResource {
   }
 
   public static getInstance(
-    chargingStation: ChargingStation
+    chargingStation: ChargingStation,
   ): AutomaticTransactionGenerator | undefined {
     if (AutomaticTransactionGenerator.instances.has(chargingStation.stationInfo.hashId) === false) {
       AutomaticTransactionGenerator.instances.set(
         chargingStation.stationInfo.hashId,
-        new AutomaticTransactionGenerator(chargingStation)
+        new AutomaticTransactionGenerator(chargingStation),
       );
     }
     return AutomaticTransactionGenerator.instances.get(chargingStation.stationInfo.hashId);
   }
 
   public start(): void {
-    if (
-      ChargingStationUtils.checkChargingStation(this.chargingStation, this.logPrefix()) === false
-    ) {
+    if (checkChargingStation(this.chargingStation, this.logPrefix()) === false) {
       return;
     }
     if (this.started === true) {
@@ -93,12 +101,7 @@ export class AutomaticTransactionGenerator extends AsyncResource {
   }
 
   public startConnector(connectorId: number): void {
-    if (
-      ChargingStationUtils.checkChargingStation(
-        this.chargingStation,
-        this.logPrefix(connectorId)
-      ) === false
-    ) {
+    if (checkChargingStation(this.chargingStation, this.logPrefix(connectorId)) === false) {
       return;
     }
     if (this.connectorsStatus.has(connectorId) === false) {
@@ -109,10 +112,10 @@ export class AutomaticTransactionGenerator extends AsyncResource {
       this.runInAsyncScope(
         this.internalStartConnector.bind(this) as (
           this: AutomaticTransactionGenerator,
-          ...args: any[]
+          ...args: unknown[]
         ) => Promise<void>,
         this,
-        connectorId
+        connectorId,
       ).catch(Constants.EMPTY_FUNCTION);
     } else if (this.connectorsStatus.get(connectorId)?.start === true) {
       logger.warn(`${this.logPrefix(connectorId)} is already started on connector`);
@@ -178,11 +181,11 @@ export class AutomaticTransactionGenerator extends AsyncResource {
     this.setStartConnectorStatus(connectorId);
     logger.info(
       `${this.logPrefix(
-        connectorId
-      )} started on connector and will run for ${Utils.formatDurationMilliSeconds(
+        connectorId,
+      )} started on connector and will run for ${formatDurationMilliSeconds(
         this.connectorsStatus.get(connectorId).stopDate.getTime() -
-          this.connectorsStatus.get(connectorId).startDate.getTime()
-      )}`
+          this.connectorsStatus.get(connectorId).startDate.getTime(),
+      )}`,
     );
     while (this.connectorsStatus.get(connectorId)?.start === true) {
       if (new Date() > this.connectorsStatus.get(connectorId).stopDate) {
@@ -192,8 +195,8 @@ export class AutomaticTransactionGenerator extends AsyncResource {
       if (this.chargingStation.inAcceptedState() === false) {
         logger.error(
           `${this.logPrefix(
-            connectorId
-          )} entered in transaction loop while the charging station is not in accepted state`
+            connectorId,
+          )} entered in transaction loop while the charging station is not in accepted state`,
         );
         this.stopConnector(connectorId);
         break;
@@ -201,8 +204,8 @@ export class AutomaticTransactionGenerator extends AsyncResource {
       if (this.chargingStation.isChargingStationAvailable() === false) {
         logger.info(
           `${this.logPrefix(
-            connectorId
-          )} entered in transaction loop while the charging station is unavailable`
+            connectorId,
+          )} entered in transaction loop while the charging station is unavailable`,
         );
         this.stopConnector(connectorId);
         break;
@@ -210,8 +213,8 @@ export class AutomaticTransactionGenerator extends AsyncResource {
       if (this.chargingStation.isConnectorAvailable(connectorId) === false) {
         logger.info(
           `${this.logPrefix(
-            connectorId
-          )} entered in transaction loop while the connector ${connectorId} is unavailable`
+            connectorId,
+          )} entered in transaction loop while the connector ${connectorId} is unavailable`,
         );
         this.stopConnector(connectorId);
         break;
@@ -222,8 +225,8 @@ export class AutomaticTransactionGenerator extends AsyncResource {
       ) {
         logger.info(
           `${this.logPrefix(
-            connectorId
-          )} entered in transaction loop while the connector ${connectorId} status is unavailable`
+            connectorId,
+          )} entered in transaction loop while the connector ${connectorId} status is unavailable`,
         );
         this.stopConnector(connectorId);
         break;
@@ -231,25 +234,23 @@ export class AutomaticTransactionGenerator extends AsyncResource {
       if (!this.chargingStation?.ocppRequestService) {
         logger.info(
           `${this.logPrefix(
-            connectorId
-          )} transaction loop waiting for charging station service to be initialized`
+            connectorId,
+          )} transaction loop waiting for charging station service to be initialized`,
         );
         do {
-          await Utils.sleep(Constants.CHARGING_STATION_ATG_INITIALIZATION_TIME);
+          await sleep(Constants.CHARGING_STATION_ATG_INITIALIZATION_TIME);
         } while (!this.chargingStation?.ocppRequestService);
       }
       const wait =
-        Utils.getRandomInteger(
+        getRandomInteger(
           this.chargingStation.getAutomaticTransactionGeneratorConfiguration()
             .maxDelayBetweenTwoTransactions,
           this.chargingStation.getAutomaticTransactionGeneratorConfiguration()
-            .minDelayBetweenTwoTransactions
+            .minDelayBetweenTwoTransactions,
         ) * 1000;
-      logger.info(
-        `${this.logPrefix(connectorId)} waiting for ${Utils.formatDurationMilliSeconds(wait)}`
-      );
-      await Utils.sleep(wait);
-      const start = Utils.secureRandom();
+      logger.info(`${this.logPrefix(connectorId)} waiting for ${formatDurationMilliSeconds(wait)}`);
+      await sleep(wait);
+      const start = secureRandom();
       if (
         start <
         this.chargingStation.getAutomaticTransactionGeneratorConfiguration().probabilityOfStart
@@ -260,23 +261,23 @@ export class AutomaticTransactionGenerator extends AsyncResource {
         if (startResponse?.idTagInfo?.status === AuthorizationStatus.ACCEPTED) {
           // Wait until end of transaction
           const waitTrxEnd =
-            Utils.getRandomInteger(
+            getRandomInteger(
               this.chargingStation.getAutomaticTransactionGeneratorConfiguration().maxDuration,
-              this.chargingStation.getAutomaticTransactionGeneratorConfiguration().minDuration
+              this.chargingStation.getAutomaticTransactionGeneratorConfiguration().minDuration,
             ) * 1000;
           logger.info(
             `${this.logPrefix(connectorId)} transaction started with id ${this.chargingStation
               .getConnectorStatus(connectorId)
-              ?.transactionId?.toString()} and will stop in ${Utils.formatDurationMilliSeconds(
-              waitTrxEnd
-            )}`
+              ?.transactionId?.toString()} and will stop in ${formatDurationMilliSeconds(
+              waitTrxEnd,
+            )}`,
           );
-          await Utils.sleep(waitTrxEnd);
+          await sleep(waitTrxEnd);
           // Stop transaction
           logger.info(
             `${this.logPrefix(connectorId)} stop transaction with id ${this.chargingStation
               .getConnectorStatus(connectorId)
-              ?.transactionId?.toString()}`
+              ?.transactionId?.toString()}`,
           );
           await this.stopTransaction(connectorId);
         }
@@ -288,7 +289,7 @@ export class AutomaticTransactionGenerator extends AsyncResource {
             .get(connectorId)
             ?.skippedConsecutiveTransactions?.toString()}/${this.connectorsStatus
             .get(connectorId)
-            ?.skippedTransactions?.toString()} transaction(s)`
+            ?.skippedTransactions?.toString()} transaction(s)`,
         );
       }
       this.connectorsStatus.get(connectorId).lastRunDate = new Date();
@@ -296,15 +297,15 @@ export class AutomaticTransactionGenerator extends AsyncResource {
     this.connectorsStatus.get(connectorId).stoppedDate = new Date();
     logger.info(
       `${this.logPrefix(
-        connectorId
-      )} stopped on connector and lasted for ${Utils.formatDurationMilliSeconds(
+        connectorId,
+      )} stopped on connector and lasted for ${formatDurationMilliSeconds(
         this.connectorsStatus.get(connectorId).stoppedDate.getTime() -
-          this.connectorsStatus.get(connectorId).startDate.getTime()
-      )}`
+          this.connectorsStatus.get(connectorId).startDate.getTime(),
+      )}`,
     );
     logger.debug(
       `${this.logPrefix(connectorId)} connector status: %j`,
-      this.connectorsStatus.get(connectorId)
+      this.connectorsStatus.get(connectorId),
     );
   }
 
@@ -322,7 +323,7 @@ export class AutomaticTransactionGenerator extends AsyncResource {
         this.chargingStation.getAutomaticTransactionGeneratorConfiguration().stopAfterHours *
           3600 *
           1000 -
-        previousRunDuration
+        previousRunDuration,
     );
     this.connectorsStatus.get(connectorId).start = true;
   }
@@ -346,8 +347,8 @@ export class AutomaticTransactionGenerator extends AsyncResource {
   }
 
   private getConnectorStatus(connectorId: number): Status {
-    const connectorStatus = Utils.cloneObject(
-      this.chargingStation.getAutomaticTransactionGeneratorStatuses()
+    const connectorStatus = cloneObject(
+      this.chargingStation.getAutomaticTransactionGeneratorStatuses(),
     )[connectorId];
     delete connectorStatus?.startDate;
     delete connectorStatus?.lastRunDate;
@@ -372,7 +373,7 @@ export class AutomaticTransactionGenerator extends AsyncResource {
   }
 
   private async startTransaction(
-    connectorId: number
+    connectorId: number,
   ): Promise<StartTransactionResponse | undefined> {
     const measureId = 'StartTransaction with ATG';
     const beginId = PerformanceStatistics.beginMeasure(measureId);
@@ -381,10 +382,10 @@ export class AutomaticTransactionGenerator extends AsyncResource {
       const idTag = IdTagsCache.getInstance().getIdTag(
         this.chargingStation.getAutomaticTransactionGeneratorConfiguration()?.idTagDistribution,
         this.chargingStation,
-        connectorId
+        connectorId,
       );
       const startTransactionLogMsg = `${this.logPrefix(
-        connectorId
+        connectorId,
       )} start transaction with an idTag '${idTag}'`;
       if (this.getRequireAuthorize()) {
         this.chargingStation.getConnectorStatus(connectorId).authorizeIdTag = idTag;
@@ -441,7 +442,7 @@ export class AutomaticTransactionGenerator extends AsyncResource {
 
   private async stopTransaction(
     connectorId: number,
-    reason: StopTransactionReason = StopTransactionReason.LOCAL
+    reason: StopTransactionReason = StopTransactionReason.LOCAL,
   ): Promise<StopTransactionResponse> {
     const measureId = 'StopTransaction with ATG';
     const beginId = PerformanceStatistics.beginMeasure(measureId);
@@ -458,8 +459,8 @@ export class AutomaticTransactionGenerator extends AsyncResource {
       const transactionId = this.chargingStation.getConnectorStatus(connectorId)?.transactionId;
       logger.warn(
         `${this.logPrefix(connectorId)} stopping a not started transaction${
-          !Utils.isNullOrUndefined(transactionId) ? ` with id ${transactionId?.toString()}` : ''
-        }`
+          !isNullOrUndefined(transactionId) ? ` with id ${transactionId?.toString()}` : ''
+        }`,
       );
     }
     PerformanceStatistics.endMeasure(measureId, beginId);
@@ -473,16 +474,16 @@ export class AutomaticTransactionGenerator extends AsyncResource {
   }
 
   private logPrefix = (connectorId?: number): string => {
-    return Utils.logPrefix(
+    return logPrefix(
       ` ${this.chargingStation.stationInfo.chargingStationId} | ATG${
-        !Utils.isNullOrUndefined(connectorId) ? ` on connector #${connectorId.toString()}` : ''
-      }:`
+        !isNullOrUndefined(connectorId) ? ` on connector #${connectorId.toString()}` : ''
+      }:`,
     );
   };
 
   private handleStartTransactionResponse(
     connectorId: number,
-    startResponse: StartTransactionResponse
+    startResponse: StartTransactionResponse,
   ): void {
     ++this.connectorsStatus.get(connectorId).startTransactionRequests;
     if (startResponse?.idTagInfo?.status === AuthorizationStatus.ACCEPTED) {