X-Git-Url: https://git.piment-noir.org/?a=blobdiff_plain;f=src%2Fcharging-station%2FAutomaticTransactionGenerator.ts;h=b27e15648792e527836a5f10868a776739789ae7;hb=f4bf2abdd27ce5ddb64d0efd3763608320efc8d8;hp=942410eba9c6115a5a8a6284c75b42eb4c9d5723;hpb=6ed92bc13120d78f84f2182ddbafd3cbcaa37359;p=e-mobility-charging-stations-simulator.git diff --git a/src/charging-station/AutomaticTransactionGenerator.ts b/src/charging-station/AutomaticTransactionGenerator.ts index 942410eb..b27e1564 100644 --- a/src/charging-station/AutomaticTransactionGenerator.ts +++ b/src/charging-station/AutomaticTransactionGenerator.ts @@ -1,62 +1,60 @@ +// Partial Copyright Jerome Benoit. 2021. All Rights Reserved. + import { AuthorizationStatus, AuthorizeResponse, StartTransactionResponse, StopTransactionReason, StopTransactionResponse } from '../types/ocpp/Transaction'; -import { PerformanceObserver, performance } from 'perf_hooks'; import ChargingStation from './ChargingStation'; import Constants from '../utils/Constants'; +import PerformanceStatistics from '../performance/PerformanceStatistics'; import Utils from '../utils/Utils'; import logger from '../utils/Logger'; export default class AutomaticTransactionGenerator { - public timeToStop: boolean; + public started: boolean; + private startDate!: Date; + private lastRunDate!: Date; + private stopDate!: Date; private chargingStation: ChargingStation; - private performanceObserver!: PerformanceObserver; constructor(chargingStation: ChargingStation) { this.chargingStation = chargingStation; - this.timeToStop = true; - if (this.chargingStation.getEnableStatistics()) { - this.performanceObserver = new PerformanceObserver((list) => { - const entry = list.getEntries()[0]; - this.chargingStation.performanceStatistics.logPerformance(entry, Constants.ENTITY_AUTOMATIC_TRANSACTION_GENERATOR); - this.performanceObserver.disconnect(); - }); - } + this.started = false; } - public async start(): Promise { - this.timeToStop = false; - if (this.chargingStation.stationInfo.AutomaticTransactionGenerator.stopAfterHours && - this.chargingStation.stationInfo.AutomaticTransactionGenerator.stopAfterHours > 0) { - // eslint-disable-next-line @typescript-eslint/no-misused-promises - setTimeout(async (): Promise => { - await this.stop(); - }, this.chargingStation.stationInfo.AutomaticTransactionGenerator.stopAfterHours * 3600 * 1000); - } + public start(): void { + const previousRunDuration = (this?.startDate && this?.lastRunDate) ? (this.lastRunDate.getTime() - this.startDate.getTime()) : 0; + this.startDate = new Date(); + this.lastRunDate = this.startDate; + this.stopDate = new Date(this.startDate.getTime() + + (this.chargingStation.stationInfo?.AutomaticTransactionGenerator?.stopAfterHours ?? Constants.CHARGING_STATION_ATG_DEFAULT_STOP_AFTER_HOURS) * 3600 * 1000 + - previousRunDuration); + this.started = true; for (const connector in this.chargingStation.connectors) { if (Utils.convertToInt(connector) > 0) { - await this.startConnector(Utils.convertToInt(connector)); + // Avoid hogging the event loop with a busy loop + setImmediate(() => { + this.startOnConnector(Utils.convertToInt(connector)).catch(() => { /* This is intentional */ }); + }); } } - logger.info(this.logPrefix() + ' ATG started and will stop in ' + Utils.secondsToHHMMSS(this.chargingStation.stationInfo.AutomaticTransactionGenerator.stopAfterHours * 3600)); + logger.info(this.logPrefix() + ' started and will run for ' + Utils.formatDurationMilliSeconds(this.stopDate.getTime() - this.startDate.getTime())); } - public async stop(reason: StopTransactionReason = StopTransactionReason.NONE): Promise { - logger.info(this.logPrefix() + ' ATG OVER => STOPPING ALL TRANSACTIONS'); - for (const connector in this.chargingStation.connectors) { - const transactionId = this.chargingStation.getConnector(Utils.convertToInt(connector)).transactionId; - if (this.chargingStation.getConnector(Utils.convertToInt(connector)).transactionStarted) { - logger.info(this.logPrefix(Utils.convertToInt(connector)) + ' ATG OVER. Stop transaction ' + transactionId.toString()); - await this.chargingStation.ocppRequestService.sendStopTransaction(transactionId, this.chargingStation.getEnergyActiveImportRegisterByTransactionId(transactionId), - this.chargingStation.getTransactionIdTag(transactionId), reason); - } + public stop(): void { + if (!this.started) { + logger.error(`${this.logPrefix()} trying to stop while not started`); + return; } - this.timeToStop = true; + this.started = false; + logger.info(`${this.logPrefix()} over and lasted for ${Utils.formatDurationMilliSeconds(this.lastRunDate.getTime() - this.startDate.getTime())}. Stopping all transactions`); } - private async startConnector(connectorId: number): Promise { - do { - if (this.timeToStop) { - logger.error(this.logPrefix(connectorId) + ' Entered in transaction loop while a request to stop it was made'); + private async startOnConnector(connectorId: number): Promise { + logger.info(this.logPrefix(connectorId) + ' started on connector'); + let skippedTransactions = 0; + let skippedTransactionsTotal = 0; + while (this.started) { + if ((new Date()) > this.stopDate) { + this.stop(); break; } if (!this.chargingStation.isRegistered()) { @@ -65,7 +63,7 @@ export default class AutomaticTransactionGenerator { } if (!this.chargingStation.isChargingStationAvailable()) { logger.info(this.logPrefix(connectorId) + ' Entered in transaction loop while the charging station is unavailable'); - await this.stop(); + this.stop(); break; } if (!this.chargingStation.isConnectorAvailable(connectorId)) { @@ -80,21 +78,13 @@ export default class AutomaticTransactionGenerator { } const wait = Utils.getRandomInt(this.chargingStation.stationInfo.AutomaticTransactionGenerator.maxDelayBetweenTwoTransactions, this.chargingStation.stationInfo.AutomaticTransactionGenerator.minDelayBetweenTwoTransactions) * 1000; - logger.info(this.logPrefix(connectorId) + ' wait for ' + Utils.milliSecondsToHHMMSS(wait)); + logger.info(this.logPrefix(connectorId) + ' waiting for ' + Utils.formatDurationMilliSeconds(wait)); await Utils.sleep(wait); - const start = Math.random(); - let skip = 0; + const start = Utils.secureRandom(); if (start < this.chargingStation.stationInfo.AutomaticTransactionGenerator.probabilityOfStart) { - skip = 0; + skippedTransactions = 0; // Start transaction - let startResponse: StartTransactionResponse | AuthorizeResponse; - if (this.chargingStation.getEnableStatistics()) { - const startTransaction = performance.timerify(this.startTransaction); - this.performanceObserver.observe({ entryTypes: ['function'] }); - startResponse = await startTransaction(connectorId, this); - } else { - startResponse = await this.startTransaction(connectorId, this); - } + const startResponse = await this.startTransaction(connectorId); if (startResponse?.idTagInfo?.status !== AuthorizationStatus.ACCEPTED) { logger.warn(this.logPrefix(connectorId) + ' transaction rejected'); await Utils.sleep(Constants.CHARGING_STATION_ATG_WAIT_TIME); @@ -102,55 +92,70 @@ export default class AutomaticTransactionGenerator { // Wait until end of transaction const waitTrxEnd = Utils.getRandomInt(this.chargingStation.stationInfo.AutomaticTransactionGenerator.maxDuration, this.chargingStation.stationInfo.AutomaticTransactionGenerator.minDuration) * 1000; - logger.info(this.logPrefix(connectorId) + ' transaction ' + this.chargingStation.getConnector(connectorId).transactionId.toString() + ' will stop in ' + Utils.milliSecondsToHHMMSS(waitTrxEnd)); + logger.info(this.logPrefix(connectorId) + ' transaction ' + this.chargingStation.getConnector(connectorId).transactionId.toString() + ' will stop in ' + Utils.formatDurationMilliSeconds(waitTrxEnd)); await Utils.sleep(waitTrxEnd); // Stop transaction - if (this.chargingStation.getConnector(connectorId)?.transactionStarted) { - logger.info(this.logPrefix(connectorId) + ' stop transaction ' + this.chargingStation.getConnector(connectorId).transactionId.toString()); - if (this.chargingStation.getEnableStatistics()) { - const stopTransaction = performance.timerify(this.stopTransaction); - this.performanceObserver.observe({ entryTypes: ['function'] }); - await stopTransaction(connectorId, this); - } else { - await this.stopTransaction(connectorId, this); - } - } + logger.info(this.logPrefix(connectorId) + ' stop transaction ' + this.chargingStation.getConnector(connectorId).transactionId.toString()); + await this.stopTransaction(connectorId); } } else { - skip++; - logger.info(this.logPrefix(connectorId) + ' transaction skipped ' + skip.toString()); + skippedTransactions++; + skippedTransactionsTotal++; + logger.info(this.logPrefix(connectorId) + ' skipped transaction ' + skippedTransactions.toString() + '/' + skippedTransactionsTotal.toString()); } - } while (!this.timeToStop); - logger.info(this.logPrefix(connectorId) + ' ATG STOPPED on the connector'); + this.lastRunDate = new Date(); + } + await this.stopTransaction(connectorId); + logger.info(this.logPrefix(connectorId) + ' stopped on connector'); } - // eslint-disable-next-line consistent-this - private async startTransaction(connectorId: number, self: AutomaticTransactionGenerator): Promise { - if (self.chargingStation.hasAuthorizedTags()) { - const tagId = self.chargingStation.getRandomTagId(); - if (self.chargingStation.getAutomaticTransactionGeneratorRequireAuthorize()) { - // Authorize tagId - const authorizeResponse = await self.chargingStation.ocppRequestService.sendAuthorize(tagId); + private async startTransaction(connectorId: number): Promise { + const measureId = 'StartTransaction with ATG'; + const beginId = PerformanceStatistics.beginMeasure(measureId); + let startResponse: StartTransactionResponse; + if (this.chargingStation.hasAuthorizedTags()) { + const idTag = this.chargingStation.getRandomIdTag(); + if (this.chargingStation.getAutomaticTransactionGeneratorRequireAuthorize()) { + // Authorize idTag + const authorizeResponse = await this.chargingStation.ocppRequestService.sendAuthorize(connectorId, idTag); if (authorizeResponse?.idTagInfo?.status === AuthorizationStatus.ACCEPTED) { - logger.info(self.logPrefix(connectorId) + ' start transaction for tagID ' + tagId); + logger.info(this.logPrefix(connectorId) + ' start transaction for idTag ' + idTag); // Start transaction - return await self.chargingStation.ocppRequestService.sendStartTransaction(connectorId, tagId); + startResponse = await this.chargingStation.ocppRequestService.sendStartTransaction(connectorId, idTag); + PerformanceStatistics.endMeasure(measureId, beginId); + return startResponse; } + PerformanceStatistics.endMeasure(measureId, beginId); return authorizeResponse; } - logger.info(self.logPrefix(connectorId) + ' start transaction for tagID ' + tagId); + logger.info(this.logPrefix(connectorId) + ' start transaction for idTag ' + idTag); // Start transaction - return await self.chargingStation.ocppRequestService.sendStartTransaction(connectorId, tagId); + startResponse = await this.chargingStation.ocppRequestService.sendStartTransaction(connectorId, idTag); + PerformanceStatistics.endMeasure(measureId, beginId); + return startResponse; } - logger.info(self.logPrefix(connectorId) + ' start transaction without a tagID'); - return await self.chargingStation.ocppRequestService.sendStartTransaction(connectorId); + logger.info(this.logPrefix(connectorId) + ' start transaction without a idTag'); + startResponse = await this.chargingStation.ocppRequestService.sendStartTransaction(connectorId); + PerformanceStatistics.endMeasure(measureId, beginId); + return startResponse; } - // eslint-disable-next-line consistent-this - private async stopTransaction(connectorId: number, self: AutomaticTransactionGenerator): Promise { - const transactionId = self.chargingStation.getConnector(connectorId).transactionId; - return await self.chargingStation.ocppRequestService.sendStopTransaction(transactionId, self.chargingStation.getEnergyActiveImportRegisterByTransactionId(transactionId), - self.chargingStation.getTransactionIdTag(transactionId)); + private async stopTransaction(connectorId: number, reason: StopTransactionReason = StopTransactionReason.NONE): Promise { + const measureId = 'StopTransaction with ATG'; + const beginId = PerformanceStatistics.beginMeasure(measureId); + let transactionId = 0; + let stopResponse: StopTransactionResponse; + if (this.chargingStation.getConnector(connectorId)?.transactionStarted) { + transactionId = this.chargingStation.getConnector(connectorId).transactionId; + stopResponse = await this.chargingStation.ocppRequestService.sendStopTransaction(transactionId, + this.chargingStation.getEnergyActiveImportRegisterByTransactionId(transactionId), + this.chargingStation.getTransactionIdTag(transactionId), + reason); + } else { + logger.warn(`${this.logPrefix(connectorId)} trying to stop a not started transaction${transactionId ? ' ' + transactionId.toString() : ''}`); + } + PerformanceStatistics.endMeasure(measureId, beginId); + return stopResponse; } private logPrefix(connectorId?: number): string {