src/charging-station/AutomaticTransactionGenerator.ts

   1 import { AuthorizationStatus, AuthorizeResponse, StartTransactionResponse, StopTransactionReason, StopTransactionResponse } from '../types/ocpp/1.6/Transaction';
   2 import { PerformanceObserver, performance } from 'perf_hooks';
   3
   4 import ChargingStation from './ChargingStation';
   5 import Constants from '../utils/Constants';
   6 import Utils from '../utils/Utils';
   7 import logger from '../utils/Logger';
   8
   9 export default class AutomaticTransactionGenerator {
  10   public timeToStop: boolean;
  11   private chargingStation: ChargingStation;
  12   private performanceObserver: PerformanceObserver;
  13
  14   constructor(chargingStation: ChargingStation) {
  15     this.chargingStation = chargingStation;
  16     this.timeToStop = true;
  17     if (this.chargingStation.getEnableStatistics()) {
  18       this.performanceObserver = new PerformanceObserver((list) => {
  19         const entry = list.getEntries()[0];
  20         this.chargingStation.statistics.logPerformance(entry, Constants.ENTITY_AUTOMATIC_TRANSACTION_GENERATOR);
  21         this.performanceObserver.disconnect();
  22       });
  23     }
  24   }
  25
  26   _logPrefix(connectorId: number = null): string {
  27     if (connectorId) {
  28       return Utils.logPrefix(' ' + this.chargingStation.stationInfo.chargingStationId + ' ATG on connector #' + connectorId.toString() + ':');
  29     }
  30     return Utils.logPrefix(' ' + this.chargingStation.stationInfo.chargingStationId + ' ATG:');
  31   }
  32
  33   start(): void {
  34     this.timeToStop = false;
  35     if (this.chargingStation.stationInfo.AutomaticTransactionGenerator.stopAfterHours &&
  36       this.chargingStation.stationInfo.AutomaticTransactionGenerator.stopAfterHours > 0) {
  37       setTimeout(() => {
  38         void this.stop();
  39       }, this.chargingStation.stationInfo.AutomaticTransactionGenerator.stopAfterHours * 3600 * 1000);
  40     }
  41     for (const connector in this.chargingStation.connectors) {
  42       if (Utils.convertToInt(connector) > 0) {
  43         void this.startConnector(Utils.convertToInt(connector));
  44       }
  45     }
  46     logger.info(this._logPrefix() + ' ATG started and will stop in ' + Utils.secondsToHHMMSS(this.chargingStation.stationInfo.AutomaticTransactionGenerator.stopAfterHours * 3600));
  47   }
  48
  49   async stop(reason: StopTransactionReason = StopTransactionReason.NONE): Promise<void> {
  50     logger.info(this._logPrefix() + ' ATG OVER => STOPPING ALL TRANSACTIONS');
  51     for (const connector in this.chargingStation.connectors) {
  52       if (this.chargingStation.getConnector(Utils.convertToInt(connector)).transactionStarted) {
  53         logger.info(this._logPrefix(Utils.convertToInt(connector)) + ' ATG OVER. Stop transaction ' + this.chargingStation.getConnector(Utils.convertToInt(connector)).transactionId.toString());
  54         await this.chargingStation.sendStopTransaction(this.chargingStation.getConnector(Utils.convertToInt(connector)).transactionId, reason);
  55       }
  56     }
  57     this.timeToStop = true;
  58   }
  59
  60   async startConnector(connectorId: number): Promise<void> {
  61     do {
  62       if (this.timeToStop) {
  63         logger.error(this._logPrefix(connectorId) + ' Entered in transaction loop while a request to stop it was made');
  64         break;
  65       }
  66       if (!this.chargingStation._isRegistered()) {
  67         logger.error(this._logPrefix(connectorId) + ' Entered in transaction loop while the charging station is not registered');
  68         break;
  69       }
  70       if (!this.chargingStation._isChargingStationAvailable()) {
  71         logger.info(this._logPrefix(connectorId) + ' Entered in transaction loop while the charging station is unavailable');
  72         await this.stop();
  73         break;
  74       }
  75       if (!this.chargingStation._isConnectorAvailable(connectorId)) {
  76         logger.info(`${this._logPrefix(connectorId)} Entered in transaction loop while the connector ${connectorId} is unavailable, stop it`);
  77         break;
  78       }
  79       const wait = Utils.getRandomInt(this.chargingStation.stationInfo.AutomaticTransactionGenerator.maxDelayBetweenTwoTransactions,
  80         this.chargingStation.stationInfo.AutomaticTransactionGenerator.minDelayBetweenTwoTransactions) * 1000;
  81       logger.info(this._logPrefix(connectorId) + ' wait for ' + Utils.milliSecondsToHHMMSS(wait));
  82       await Utils.sleep(wait);
  83       const start = Math.random();
  84       let skip = 0;
  85       if (start < this.chargingStation.stationInfo.AutomaticTransactionGenerator.probabilityOfStart) {
  86         skip = 0;
  87         // Start transaction
  88         let startResponse: StartTransactionResponse | AuthorizeResponse;
  89         if (this.chargingStation.getEnableStatistics()) {
  90           const startTransaction = performance.timerify(this.startTransaction);
  91           this.performanceObserver.observe({ entryTypes: ['function'] });
  92           startResponse = await startTransaction(connectorId, this);
  93         } else {
  94           startResponse = await this.startTransaction(connectorId, this);
  95         }
  96         if (startResponse?.idTagInfo?.status !== AuthorizationStatus.ACCEPTED) {
  97           logger.info(this._logPrefix(connectorId) + ' transaction rejected');
  98           await Utils.sleep(Constants.CHARGING_STATION_ATG_WAIT_TIME);
  99         } else {
 100           // Wait until end of transaction
 101           const waitTrxEnd = Utils.getRandomInt(this.chargingStation.stationInfo.AutomaticTransactionGenerator.maxDuration,
 102             this.chargingStation.stationInfo.AutomaticTransactionGenerator.minDuration) * 1000;
 103           logger.info(this._logPrefix(connectorId) + ' transaction ' + this.chargingStation.getConnector(connectorId).transactionId.toString() + ' will stop in ' + Utils.milliSecondsToHHMMSS(waitTrxEnd));
 104           await Utils.sleep(waitTrxEnd);
 105           // Stop transaction
 106           if (this.chargingStation.getConnector(connectorId)?.transactionStarted) {
 107             logger.info(this._logPrefix(connectorId) + ' stop transaction ' + this.chargingStation.getConnector(connectorId).transactionId.toString());
 108             if (this.chargingStation.getEnableStatistics()) {
 109               const stopTransaction = performance.timerify(this.stopTransaction);
 110               this.performanceObserver.observe({ entryTypes: ['function'] });
 111               await stopTransaction(connectorId, this);
 112             } else {
 113               await this.stopTransaction(connectorId, this);
 114             }
 115           }
 116         }
 117       } else {
 118         skip++;
 119         logger.info(this._logPrefix(connectorId) + ' transaction skipped ' + skip.toString());
 120       }
 121     } while (!this.timeToStop);
 122     logger.info(this._logPrefix(connectorId) + ' ATG STOPPED on the connector');
 123   }
 124
 125   // eslint-disable-next-line consistent-this
 126   private async startTransaction(connectorId: number, self: AutomaticTransactionGenerator): Promise<StartTransactionResponse | AuthorizeResponse> {
 127     if (self.chargingStation.hasAuthorizedTags()) {
 128       const tagId = self.chargingStation.getRandomTagId();
 129       if (self.chargingStation.stationInfo.AutomaticTransactionGenerator.requireAuthorize) {
 130         // Authorize tagId
 131         const authorizeResponse = await self.chargingStation.sendAuthorize(tagId);
 132         if (authorizeResponse?.idTagInfo?.status === AuthorizationStatus.ACCEPTED) {
 133           logger.info(self._logPrefix(connectorId) + ' start transaction for tagID ' + tagId);
 134           // Start transaction
 135           return await self.chargingStation.sendStartTransaction(connectorId, tagId);
 136         }
 137         return authorizeResponse;
 138       }
 139       logger.info(self._logPrefix(connectorId) + ' start transaction for tagID ' + tagId);
 140       // Start transaction
 141       return await self.chargingStation.sendStartTransaction(connectorId, tagId);
 142     }
 143     logger.info(self._logPrefix(connectorId) + ' start transaction without a tagID');
 144     return await self.chargingStation.sendStartTransaction(connectorId);
 145   }
 146
 147   // eslint-disable-next-line consistent-this
 148   private async stopTransaction(connectorId: number, self: AutomaticTransactionGenerator): Promise<StopTransactionResponse> {
 149     return await self.chargingStation.sendStopTransaction(self.chargingStation.getConnector(connectorId).transactionId);
 150   }
 151 }